エラーが発生した場合、async.waterfallを再起動するにはどうすればよいですか？

Question

私はnode.jsにTwitterボットゲームを構築しています。私は、同期関数（getImage）を持つasync.waterfallを持っているTwitterのストリームを開くstreamOnのスクリプトを持っています。 getImageは、スクリプトがトリガーされたときに301の応答を返すことがあります。 streamOnは引き続き開いたままですが、プレーヤーはエラーについて知らないので、返される画像はありません。

async.waterfallは、プレーヤーがまだ画像を取得するためにエラーが発生した場合、ステップの最初から「再試行」するにはどうすればよいですか？ここで

はasync.waterfall次のとおりです。これは私がそれは次のようになり想像ものです

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

：

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機能の簡易版です。コールバックにコールを追加しました。非同期ではそれを続行する必要があるためです。

リダイレクトループが発生する可能性があります。.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); 
     }); 
     } 
    ); 
}