Как в node.js сделать задержку в цикле?

Question

[nezzard]

Добрый вечер, подскажите пожалуйста, как реализовать задержку в запросе такого вида

result.forEach(function(items) {
			request.get("https://www.googleapis.com/youtube/v3/search?part=snippet&order=viewCount&q="+items['song']+'+'+items['song']+"&type=video&key=AIzaSyAvDAdEnqrStOJNnpnGy9BkrC_sG-gcHIU", function(err,res,body){
          if(res.statusCode == 200 ) {          	
	           console.log(JSON.parse(body)['items'][0].id.videoId);	         
          }
      });
	});

Проблема в том, что ответ от сервера приходит, все работает, но приходит он каждый раз в разном порядке.
Скорее всего это из за того, что сервера гугла обрабатывают запросы с разной скоростью и исходя формируется разная последовательность выведенных данных
Но мне нужно строго по порядку, подскажите как сделать зарержку setInterval не подходит, выдает совсем не то, что нужно

Comments

[Антон Л]

Вам нужна задержка или что бы запросы выполнялись последовательно?

[nezzard]

Антон Л: самое главное чтобы последовательно

Answer 1

[Виталий]

Советую изучить Promise. Перед циклом создаётся экземпляр Promise, каждая итерация подписывается методом then на следующий запрос. После цикла можно в промис добавить последний then, который продолжит выполнять задачу, когда будет получен последний запрос. Когда функция завершается, event loop начинает последовательно выполнять запросы, добавленные Промисом.
Выглядит примерно так:

let promise = Promise.resolve();
for(...) {
  promise.then( () => {
    return new Promise((resolve) => {
      request.get(..., (data) => {... resolve(data);});
    }
  }
}
promise.then((lastData) => {...});

Comments

[Dark Hole]

promise - это то же ES6 :/

[nezzard]

Благодарю, этот вариант кажется большего всего подходит request-promise

var options = {
uri: "https://www.googleapis.com/youtube/v3/search?part=..."+result['song']+'+'+result['song']+"&type=video&key=AIzaSyAvDAdEnqrStOJNnpnGy9BkrC_sG-gcHIU",
headers: {
'User-Agent': 'Request-Promise'
},
json: true // Automatically parses the JSON string in the response
};

rp(options)
.then(function (repos) {
console.log(repos['items'][0]['id']);
})
.catch(function (err) {
// API call failed...
});

Вот сейчас вопрос, как сюда прикрутить массив, задача такая, в строке запроса к гуглу идут переменные, они приходят из массива в котором есть список композиций, не пойму можно ли сюда прикрутить for

[Влад Хеллсайт]

Как минимум такой вариант не очень потому что он ждёт предыдущего ответа.

[Виталий]

nezzard: есть вариант с Promise.all - он передаёт массив результатов. Но он обрабатывает запросы не последовательно, а параллельно. Если такой вариант не подходит, проще создать массив на верхнем уровне, который замыкается на колбэке промиса и в который добавляются результаты.

[Виталий]

Альтернативный вариант без замканий:
let promise = Promise.resolve([]);
for(...) {
promise.then( (results) => {
return new Promise((resolve) => {
request.get(..., (data) => {... resolve(results.push(data));});
}
}
}
promise.then((arrayData) => {...});

[nezzard]

Виталий: Для меня критически важно, чтобы запросы обработались последовательно, если ответ еще не пришел от первого, второй не обрабатывать либо обработать с задержкой

[nezzard]

Виталий: Сделал по примеру который вы давали, вот как получается, каждый раз приходит в разном расположении
{ kind: 'youtube#video', videoId: 'VK2Amr_V1Fg' }
{ kind: 'youtube#video', videoId: 'yobs0YX57YI' }
{ kind: 'youtube#video', videoId: 'V_8yP2lPhXI' }
{ kind: 'youtube#video', videoId: 'ka9mCmx9Jhs' }
{ kind: 'youtube#video', videoId: 'YQHsXMglC9A' }
{ kind: 'youtube#video', videoId: 'jtoncUzV6nA' }
{ kind: 'youtube#video', videoId: 's0GIaJuan9Y' }

потом

{ kind: 'youtube#video', videoId: 'ka9mCmx9Jhs' }
{ kind: 'youtube#video', videoId: 'jtoncUzV6nA' }
{ kind: 'youtube#video', videoId: 'VK2Amr_V1Fg' }
{ kind: 'youtube#video', videoId: 's0GIaJuan9Y' }
{ kind: 'youtube#video', videoId: 'YQHsXMglC9A' }
{ kind: 'youtube#video', videoId: 'yobs0YX57YI' }
{ kind: 'youtube#video', videoId: 'V_8yP2lPhXI' }

Каждый раз они меняются местами

[Виталий]

nezzard: да, я забыл присваивать результат, кажется это важно:
promise = promise.then( (results) => {
Если не поможет, попробуйте эмулировать возвращаемые данные из массива, чтобы понять, что проблема именно в нашем коде, а не на сервере. Если окажется в коде, буду разбираться. Прошу в любом случае отписаться - самому стало интересно.

Answer 2

[Dark Hole]

Отказаться от forEach... точнее, использовать вместо него for в генераторе.

function* code(result) {
  for(var i = 0; i < result.length; i++) yield result[i];
}
function code2(gen) {
  items = gen.next().value;
  request.get("https://www.googleapis.com/youtube/v3/search?part=snippet&order=viewCount&q="+items['song']+'+'+items['song']+"&type=video&key=AIzaSyAvDAdEnqrStOJNnpnGy9BkrC_sG-gcHIU", function(err,res,body){
          if(res.statusCode == 200 ) {          	
             console.log(JSON.parse(body)['items'][0].id.videoId);	
             code2(gen);         
          }
      });
}
let gen = code(result);
code2(gen);

Comments

[nezzard]

Не работает, ошибка на ошибке начиная с function* потом yield потом let gen

[Dark Hole]

nezzard: старый Node, наверно

[nezzard]

Dark Hole: Последняя версия

[Dark Hole]

nezzard: какая версия? У меня не ругается

[Dark Hole]

nezzard: у меня 6.9.2

[nezzard]

Dark Hole: 6.9.1 и на next жалуется

[Dark Hole]

nezzard: а, ну да, в code нужно массив подать

[nezzard]

Dark Hole: Если по вашему примеру должно работать, почему тогда с последней стабильной версией не работает?

[Dark Hole]

nezzard: ваши химикаты. У меня - почему то - все работает. И это ES6, который должен поддерживаться

Answer 3

[Антон Л]

Если вам не по душе ES6 (очень зря кстати), используйте старый добрый модуль async.

npm i async --save

var items = []; //здесь ваш массив
async.eachSeries(items, function(item, callback) {
      request.get("https://www.googleapis.com/youtube/v3/search?part=snippet&order=viewCount&q="+item['song']+'+'+item['song']+"&type=video&key=AIzaSyAvDAdEnqrStOJNnpnGy9BkrC_sG-gcHIU", function(err, res, body){
          if(res.statusCode == 200 ) {          	
             console.log(JSON.parse(body)['items'][0].id.videoId);	
             callback();
          } else {
              callback('Error');
          }
        
      });    
}, function(err) {
    if( err ) {
            console.log('Ошибка случилась');
          } else {
      console.log('Все хорошо едем дальше');
    }
});