Express.js 中处理嵌套异步数据并生成 JSON 响应的实践指南

{
  "title": "Star Trek: First Contact",
  "year": 1996,
  "runtime": 111,
  "genres": ["Action", "Adventure", "Drama"],
  "country": "United States",
  "principals": [
    {
      "id": "nm0005772",
      "category": "cinematographer",
      "name": "Matthew F. Leonetti",
      "characters": []
    },
    {
      "id": "nm0001772",
      "category": "actor",
      "name": "Patrick Stewart",
      "characters": ["Picard"]
    }
    // ...更多演职人员
  ],
  "boxoffice": 92027888,
  "poster": "https://m.media-amazon.com/images/M/MV5BYzMzZmE3MTItODYzYy00YWI5LWFkNWMtZTY5NmU2MDkxYWI1XkEyXkFqcGdeQXVyMjUzOTY1NTc@._V1_SX300.jpg",
  "plot": "The Borg travel back in time intent on preventing Earth's first contact with an alien species. Captain Picard and his crew pursue them to ensure that Zefram Cochrane makes his maiden flight reaching warp speed."
}

router.get('/movies/data/:imdbID', function(req, res, next) {
  const queryMovie = req.db.from('basics').select(
      'primaryTitle', 'year', 'runtimeMinutes', 'genres', 'country', 'boxoffice', 'poster', 'plot'
    ).where('tconst', req.params.imdbID);

  const queryPrincipals = req.db.from('principals').select('nconst', 'category', 'name', 'characters').where('tconst', req.params.imdbID);

  queryMovie.then((movieData) => {
    const movie = movieData.map(data => {
      return {
        title: data.primaryTitle, // 修正：原问题中为tconst
        year: data.year,
        runtime: data.runtimeMinutes,
        country: data.country,
        // 问题出在这里：principals 字段被赋值为一个 Promise
        principals: queryPrincipals.then((principals) => {
          return principals.map(principal => {
            return {
              id: principal.nconst,
              category: principal.category,
              name: principal.name,
              characters: principal.characters
            }
          })
        }),
        boxoffice: data.boxoffice, // 修正：原问题中为genres
        poster: data.poster,       // 修正：原问题中为genres
        plot: data.plot
      }
    });
    res.json(movie);
  });
});

router.get('/movies/data/:imdbID', async function(req, res, next) {
  try {
    // 定义主数据查询
    const queryMovieBuilder = req.db.from('basics')
      .select(
        'primaryTitle', 
        'year',
        'runtimeMinutes', 
        'genres', 
        'country', 
        'boxoffice', 
        'poster', 
        'plot'
      )
      .where('tconst', req.params.imdbID);

    // 定义嵌套数据查询（注意这里只是构建查询，尚未执行）
    const queryPrincipalsBuilder = req.db.from('principals')
      .select('nconst', 'category', 'name', 'characters')
      .where('tconst', req.params.imdbID);

    // 1. 等待主数据查询完成
    const movieData = await queryMovieBuilder; 

    // 2. 检查是否找到电影数据
    if (!movieData || movieData.length === 0) {
      return res.status(404).json({ message: 'Movie not found' });
    }

    // 3. 对电影数据进行映射，并在映射内部等待嵌套数据
    // 注意：在这个特定的场景下，由于 imdbID 唯一，movieData 数组通常只有一个元素。
    // 如果 movieData 可能包含多个电影，且每个电影的 principals 都需要独立查询，
    // 那么 map 的回调函数也需要是 async，并且外层需要 Promise.all。
    // 但根据原始问题和答案，这里是针对单个 imdbID 的查询。
    const movie = await Promise.all(movieData.map(async (data) => { // 将map的回调函数声明为async
      // 4. 等待嵌套数据查询完成，并进行映射
      const principalsRaw = await queryPrincipalsBuilder; // 执行 principals 查询
      const principals = principalsRaw.map(
        ({nconst:id, category, name, characters}) => ({ id, category, name, characters })
      );

      // 5. 返回完整的电影对象
      return {
        title: data.primaryTitle,
        year: data.year,
        runtime: data.runtimeMinutes,
        country: data.country,
        principals, // 此时 principals 已经是解析后的数组
        boxoffice: data.boxoffice,
        poster: data.poster,
        plot: data.plot,
        genres: data.genres ? data.genres.split(',') : [] // 假设genres是逗号分隔的字符串
      };
    }));

    // 6. 发送最终的 JSON 响应
    res.json(movie[0]); // 如果只查询一个电影，返回第一个元素
  } catch (error) {
    console.error("Error fetching movie data:", error);
    next(error); // 将错误传递给下一个错误处理中间件
  }
});