如果抛出错误，我该如何重新启动async.waterfall？

Question

我在node.js中构建了一个Twitter机器人游戏。我有一个具有同步功能的脚本（打开Twitter流的streamOn），然后是具有HTTP GET请求功能的async.waterfall（getImage）。当脚本被触发时，getImage有时会返回301响应。 streamOn继续保持打开，但玩家不知道错误，只是没有图像返回。

如何让async.waterfall从其开始的步骤“重试”，如果它抛出一个错误，所以玩家仍然得到一个图像？

这里是async.waterfall：

streamOn(function(tweet) { 
    async.waterfall([ 
    getName, 
    searchImage, 
    getImage, 
    postTweet.bind(null, tweet) 
    ], 
    function(error, result) { 
    if (error) { 
     console.error(error); 
     return; 
    } 
    console.log(result); 

    }); 
} 

这里是getImage功能的简化版本：

function getImage() { 

    var http=require('http'), imageBuffer; 

    http.get(
     'http://www.kame.net/img/kame-anime-small.gif', 
     function(res) { 
     var body=new Buffer(0); 

     if (res.statusCode!==200) { 
      return console.error('HTTP '+res.statusCode); 
     } 

     res.on('data', function(chunk) { 
      body=Buffer.concat([body, chunk]); 
     }); 

     res.on('end', function() { 
      imageBuffer=body; 
     }); 

     res.on('error', function(err) { 
      console.error(err); 
     }); 
     } 
    ); 
} 

Answer 1

这就是我想象它会是什么样子。我添加了对回调的调用，因为异步需要继续。

请注意，您可能会进入重定向循环，并且我不确定.headers是否是响应的正确属性。

function getImage(url, callback) { 

    var http=require('http'), imageBuffer; 

    http.get(
     url, 
     function(res) { 
     var body=new Buffer(0); 

     if (res.statusCode!==200) { 
      if (res.statusCode === 301) { 
       getImage(res.headers["Location"], callback) //I'm not sure if .headers is correct 
       return; 
      } 
      console.error('HTTP '+res.statusCode); 
      callback(new Error('HTTP '+res.statusCode)) //Might want a better error 
     } 

     res.on('data', function(chunk) { 
      body=Buffer.concat([body, chunk]); 
     }); 

     res.on('end', function() { 
      imageBuffer=body; 
      callback(null, imageBuffer) 
     }); 

     res.on('error', function(err) { 
      console.error(err); 
      callback(err); 
     }); 
     } 
    ); 
}