Повторные запросы GET петлей последовательно используя Q.js

Question

меня в качестве основной функции следующим образом:

function main(body) { 
    var deferred = Q.defer(); 
    // Make an API request 
    console.log("body :"+ body); 

    var jsonbody = JSON.parse(body); 
    partialSequence = jsonbody['partialSequence']; 
    uniqID = jsonbody['uniq']; 
    resultLength = jsonbody['resultLength']; 

    console.log("resultLength :"+ resultLength); 

    if (partialSequence.indexOf("G") > -1) ns.push("G"); 
    if (partialSequence.indexOf("A") > -1) ns.push("A"); 
    if (partialSequence.indexOf("C") > -1) ns.push("C"); 
    if (partialSequence.indexOf("T") > -1) ns.push("T"); 

    uniq = uniqID; 
    var sequence = Promise.resolve(); 

    for (var i = 0; i < resultLength; i++) { 
     location = i; 
     for (var j = 0; j < nuclides.length; j++) { 

     n = nuclides[j] 

     var promise = getLocation(n, location, uniq); 
     promise.then(function(values) { 
      console.log("location :"+values[0] + " "+ values[1]); 
      if (expressed) { 
      isExpressed = true; 
      if(route > 0) { 
       for (var key in resultSeq) { 
       if (resultSeq.hasOwnProperty(key)) { 
        var temp = resultSeq[key] 
        delete resultSeq[key]; 
        temp = temp.concat(n); 
        resultSeq[temp] = temp; 
       } 
       } 
      } else { 
       resultSeq[n] = n; 
      } 
      } 
     }); 
     } 
     if (isExpressed) route++; //used to check if we append to existing sequences. 
    } 
    deferred.resolve(); 
    return deferred.promise 
} 

function getLocation(n, location, uniq) { 
    var expressed 
    var deferred = Q.defer(); 
    Q.ninvoke(request, 'get', { 
    url:   "https://myapi.com/location?"+"location="+location+"&"+"nucleotide="+n+"&"+"uniq= "+uniq 
    }).spread(function(response, body) { 
    expressed=1; 
    var jsonbody = JSON.parse(body); 
    return [jsonbody["expressed"], location]; 
    }); 

    return deferred.promise 
} 

Когда я console.log расположение values[0] неисправна, когда он должен быть 0,1,2 .. ..... п. Как я могу это достичь? Большое спасибо!

Answer 1

Во-первых, упростите внутренний цикл for, поставив этот код в функцию, передаваемую индексом местоположения, и затем возвращает новое обещание, когда код будет выполнен. Поскольку вы просто обрабатываете содержимое массива, вы можете использовать шаблон дизайна .reduce(), чтобы связать обещание для каждого элемента массива. Это будет выполнять их все последовательно:

function innerWork(locationIndex) { 
    // process the nuclides array for a given locationIndex 
    return nuclides.reduce(function (p, n) { 
     return p.then(function() { 
      // now process a single locationIndex 
      return getLocation(n, locationIndex, uniq).then(function (values) { 
       console.log("location :" + values[0] + " " + values[1]); 
       if (expressed) { 
        isExpressed = true; 
        if (route > 0) { 
         for (var key in resultSeq) { 
          if (resultSeq.hasOwnProperty(key)) { 
           var temp = resultSeq[key] 
           delete resultSeq[key]; 
           temp = temp.concat(n); 
           resultSeq[temp] = temp; 
          } 
         } 
        } else { 
         resultSeq[n] = n; 
        } 
       } 
      }); 
     }); 
    }, Promise.resolve()); 
} 

Затем внешний цикл может быть сделано только вручную цепочками для одного обещания, как это:

var sequence = Promise.resolve(); 
for (var i = 0; i < resultLength; i++) { 
    (function(index) { 
     sequence = sequence.then(function() { 
      return innerWork(index); 
     }); 
    })(i); 
} 

Это использует внутренний IIFE, чтобы захватить индекс цикла в замыкании, поэтому мы имеем правильное значение, когда вызов функции innerWork(index) выполняется через некоторое время как цепочка обещаний и выполняется вовремя.

Что это такое, это построить цепочку обещаний, которые все связаны друг с другом, а затем они начинаются спереди и выполняются один за другим.

Собираем все вместе, вы в конечном итоге с этим:

function main(body) { 
    // Make an API request 
    console.log("body :" + body); 

    var jsonbody = JSON.parse(body); 
    partialSequence = jsonbody['partialSequence']; 
    uniqID = jsonbody['uniq']; 
    resultLength = jsonbody['resultLength']; 

    console.log("resultLength :" + resultLength); 

    if (partialSequence.indexOf("G") > -1) ns.push("G"); 
    if (partialSequence.indexOf("A") > -1) ns.push("A"); 
    if (partialSequence.indexOf("C") > -1) ns.push("C"); 
    if (partialSequence.indexOf("T") > -1) ns.push("T"); 

    uniq = uniqID; 

    function innerWork(locationIndex) { 
     // process the nuclides array for a given locationIndex 
     return nuclides.reduce(function (p, n) { 
      return p.then(function() { 
       // now process a single locationIndex 
       return getLocation(n, locationIndex, uniq).then(function (values) { 
        console.log("location :" + values[0] + " " + values[1]); 
        if (expressed) { 
         isExpressed = true; 
         if (route > 0) { 
          for (var key in resultSeq) { 
           if (resultSeq.hasOwnProperty(key)) { 
            var temp = resultSeq[key] 
            delete resultSeq[key]; 
            temp = temp.concat(n); 
            resultSeq[temp] = temp; 
           } 
          } 
         } else { 
          resultSeq[n] = n; 
         } 
        } 
       }); 
      }); 
     }, Promise.resolve()); 
    } 

    var sequence = Promise.resolve(); 
    for (var i = 0; i < resultLength; i++) { 
     (function (index) { 
      sequence = sequence.then(function() { 
       return innerWork(index); 
      }); 
     })(); 
    } 
    if (isExpressed) route++; //used to check if we append to existing sequences. 
    return sequence; 
} 

Кроме того, пожалуйста, помните, улучшенную getLocation() функцию с другого вопроса/ответа:

function getLocation(n, location, uniq) { 
    var expressed 
    return Q.ninvoke(request, 'get', { 
    url:   "https://myapi.com/location?"+"location="+location+"&"+"nucleotide="+n+"&"+"uniq= "+uniq 
    }).spread(function(response, body) { 
    expressed = 1; 
    var jsonbody = JSON.parse(body); 
    return [jsonbody["expressed"], location]; 
    }); 
}  

PS, Ваш исходный код имеет несколько необъявленных переменных, на которые вы ссылаетесь. Убедитесь, что ВСЕ переменные объявлены в соответствующей области. Например, я не знаю, где объявлена ​​переменная expressed, которая находится в вашей функции main(), и есть много переменных, для которых я не вижу локального объявления в main(), на которое вы ссылались. Это, как правило, плохая практика.