使用承諾和循環？

Question

我正在從網站上提取數據。正在拖動的數據已被查看。當向第一頁發出請求時，收到一個包含nextCursor的響應。該光標必須用於獲取第2頁的結果。每個頁面請求需要nextCursor。

我努力實現這個使用Promise，因爲我找不到任何方式循環。這是我認爲它的工作原理沒有承諾（未測試，但它證明了我想要做的）：

let nextCursor = argv.initalCursor 

do { 
    let r = request('http://example.com/items.php?cursor=' + nextCursor, function(err, resp, body) { 
    if(err) throw new Error(err) 

    // Do something with the data 

    nextCursor = JSON.parse(body)['nextCursor'] 
    }) 
} while(nextCursor) 

正如你所看到的迭代循環中的數量是未知的。它將循環，直到響應中沒有nextCursor。

我想要做的是使用Promise實現這個。除了我不知道如何創建一個以類似方式工作的循環，因爲每個請求都依賴於最後一個請求。

這將如何使用承諾工作？

這是我當前的解決方案，當return self.cursorRequest時失敗。該腳本只是停止執行。

'use strict' 

let Promise = require('bluebird') 
let _ = require('lodash') 

class Event { 
    constructor(session) { 
    this.session = session 
    this.scrapedIDs = [] // I don't like this! 
    } 

    parseGuestsAndCursor(json, guestType) { 
    let ids = json['payload'][guestType]['sections'][2][1].map(function(user) { 
     return user['uniqueID'] 
    }) 

    return { 
     ids: _.uniq(ids), 
     cursor: json['payload'][guestType]['cursor'] 
    } 
    } 

    cursorRequest(cursor, eventID, guestType) { 
    let self = this 

    return new Promise(function(resolve, reject) { 
     let url = `https://example.com/events/typeahead/guest_list/?event_id=${eventID}&tabs[0]=${guestType}&order[${guestType}]=affinity&bucket_schema[${guestType}]=friends&cursor[${guestType}]=${cursor}&dpr=1&__user=${self.session.uid}&__a=1` 

     self.session.request(url, function(err, resp, body) { 
     if(err) reject(err) 
     let json 

     try { 
      json = JSON.parse(body.substring(9)) 
     } catch(err) { 
      reject(err) 
     } 

     resolve(self.parseGuestsAndCursor(json, guestType)) 
     }) 
    }) 
    } 

    members(eventID, limit, guestType) { 
    let self = this 
    let ids = [] 

    return new Promise(function(resolve, reject) { 
     let url = `https://example.com/events/typeahead/guest_list/?event_id=${eventID}&tabs[0]=watched&tabs[1]=going&tabs[2]=invited&order[declined]=affinity&order[going]=affinity&order[invited]=affinity&order[maybe]=affinity&order[watched]=affinity&order[ticket_purchased]=affinity&bucket_schema[watched]=friends&bucket_schema[going]=friends&bucket_schema[invited]=friends&bucket_schema[ticket_purchased]=friends&dpr=1&__user=${self.session.uid}&__a=1` 

     self.session.request(url, function(err, resp, body) { 
     if(err) reject(new Error(err)) 
     let json, guests 

     try { 
      json = JSON.parse(body.substring(9)) 
      guests = self.parseGuestsAndCursor(json, guestType) 
     } catch(err) { 
      reject(err) 
     } 

     self.cursorRequest(guests.cursor, eventID, guestType).then(function(guests) { 

      self.scrapedIDs.concat(guests.ids).map(function(user) { 
      return user['uniqueID'] 
      }) 

      if(guests.cursor) { 
      return self.cursorRequest(guests.cursor, eventID, guestType) 
      } 
      else { 
      resolve(self.scrapedIDs) 
      } 
     }) 
     }) 
    }) 
    } 
} 

module.exports = Event 

Answer 1

由於該過程是異步的，所以根本不使用循環構造;你只需要使用一個自己調用的函數（間接通過另一個函數）。在你的情況中，既然你已經說過你想用promises來實現這個，那麼你是怎麼做到的（實際上在代碼中最容易表達）;

var p = new Promise(function(resolve, reject) { 
    let nextCursor = argv.initialCursor; 

    doRequest(); 

    function doRequest() { 
     request('http://example.com/items.php?cursor=' + nextCursor, handleResult); 
    } 

    function handleResult(err, resp, body) { 
     if (err) { 
      // Got an error, reject the promise 
      reject(err); 
     } else { 
      // Do something with the data 

      // Next? 
      nextCursor = JSON.parse(body)['nextCursor']; 
      if (nextCursor) { 
       // Yup, do it 
       doRequest(); 
      } else { 
       // No, we're done 
       resolve(/*...resolution value here...*/); 
      } 
     } 
    } 
}); 

（該ES2015版外觀基本相同。）

Answer 2

另一種方式來做到這一點是promisify你使用異步函數，並建立在這一點。

這種方法的好處是，功能模塊化，所以你可以，如果你想使其他類型的請求與承諾重用makeRequest()功能：

let nextCursor = argv.initalCursor 

function requestPromise(url) { 
    return new Promise(function (resolve, reject) { 
     request(url, function (err, resp, body) { 
      if (err) { reject(new Error(err)); } 
      else { resolve({ resp: resp, body: body}); } 
     }); 
    }); 
} 

function queryCursor(cursor) { 
    return requestPromise('http://example.com/items.php?cursor=' + cursor) 
     .then(function (result) { 
      // do something with result 

      var nextCursor = JSON.parse(result.body).nextCursor; 

      if (nextCursor) { 
       return queryCursor(nextCursor); 
      } 
     }); 
} 

queryCursor(nextCursor) 
    .catch(function (err) { 
     // deal with err 
    });