Request/forLoop/Promise 嵌套娃娃地狱 - Node JS

Question

我正在使用功能有限的 API，并且我正在尝试组合对多个路由的多个调用，以基于单个关键字搜索为用户提供特定信息。这会在 for 循环中创建许多单独的请求，这些请求本身就在其他请求结果的回调中，等等。最后，我无法等待所有嵌套请求完成，直到我解决了原始 Promise 和我的模板引擎呈现页面并响应用户获取请求。因此，模板引擎正在渲染一个结果数组仍然为空的页面。

        let discoveredMovies = [];
        let personSearchCast = new Promise ((resolve) => {
            request(UserSearchParamsURL1, {json:true}, (err, res, body) =>{
                if (err) { 
                    console.log(err); 
                    resolve();
                }
                else if(!body.results.length || !body) { 
                    resolve();
                }
                else {
                    for (const person of body) {
                        request(URL2, {json: true}, (err, res2, body2) => {
                            for (const movie of body2) {
                                    request(URL3, {json:true}, (err, res3, body3) => {
                                        movie[CertainParam] = false;

                                        if (Certain Conditions) {
                                            discoveredMovies.push(movie);
                                        }
            
                                        if (Other Conditions) {
                                            discoveredMovies.push(movie);
                                        }
                                        if(More Conditions) {
                                            movie[CertainParam] = true;
                                            Object.assign(movie, {body3info: body3});
                                        }
        
                                        resolve();
                
                                });
                            };
                        });
                    };
                }
            });
        });
        
        personSearchCast.then(() => {
            res.render("partials/foundpeoplemovies.ejs", {movies: discoveredMovies});
        });

就目前而言，我知道所有的请求调用都会发生，因为我可以将它们注销，但是模板会在它们完成之前呈现。我已经尝试创建几个异步等待函数并尝试连接它们，但我无法理解它。我还尝试使用计数器来调节 resolve()，直到循环中的所有循环都完成，但这也没有让我走得太远。

我知道代码很乱，但是有什么想法可以干净利落地做我想做的事吗？否则我将不得不弄乱用户界面并为用户添加一系列间歇性步骤，而不是在一次快速搜索中为用户提供所有信息。

Answer 1

要回应 Bergi 的评论，您需要“承诺”您的 request 函数 -

async function requestJson(url) {
  return new Promise((resolve, reject) =>
    request(url, {json: true}, (err, res, body) => {
      if (err)
        reject(err)
      else
        resolve({ res, body })
    })
  )
}

现在您可以按预期使用 Promise -

async function searchCast(URL1) {
  const discoveredMovies = []
  const { body: cast } = await requestJson(URL1)
  for (const actor of cast) {
    const { body: movies } = await requestJson(URL2)
    for (const movie of movies) {
      const { body: details } = await requestJSON(URL3)
      if (details[CertainParam] == someCondition)
        discoveredMovies.push({ movie, details })
    }
  }
  return discoveredMovies
}

这是一个如何在 Web 表单中使用 searchCast 的示例 -

myForm.addEventListener("submit", async event => {
  try {
    const searchUrl = ...
    const discoveredMovies = await searchCast(searchUrl)
    console.log(discoveredMovies)
  }
  catch (err) {
    console.error(err.message)
  }
})

像我们上面所做的那样使用for 循环将导致串行查询，即movies 子查询必须在移动到下一个之前完成。您可以使用Promise.all 并行运行所有子查询。另一种选择是对Pool 建模以限制/限制多个请求，以防止远程 API 泛滥。在this Q&A 中描述了这种技术。