在 Node.js/Express 中处理 POST 请求数据并在另一函数中使用

const express = require('express');
const bodyParser = require('body-parser');
const http = require('http');

const app = express();
const port = 3000;

// 使用 body-parser 中间件解析请求体
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());

app.post("/movies", function (req, res) {
  const imdbIDs = req.body;

  if (!Array.isArray(imdbIDs)) {
    res.status(400).send('Invalid input. Expected an array of imdbIDs.');
    return;
  }

  const apiKEY = 'YOUR_API_KEY'; // 替换为你的 API 密钥
  const movies = [];
  let completedRequests = 0;

  imdbIDs.forEach((imdbID, index) => {
    const apiUrl = `http://www.omdbapi.com/?&apikey=${apiKEY}&i=${imdbID}`;

    http.get(apiUrl, (response) => {
      let responseData = '';

      response.on('data', (chunk) => {
        responseData += chunk;
      });

      response.on('end', () => {
        try {
          const movieData = JSON.parse(responseData);

          if (movieData.Response === 'True') {
            const movie = {
              Released: movieData.Released !== 'N/A' ? new Date(movieData.Released).toISOString() : null,
              Runtime: movieData.Runtime !== 'N/A' ? parseInt(movieData.Runtime) : null,
              Genres: movieData.Genre ? movieData.Genre.split(',').map(genre => genre.trim()) : [],
              Directors: movieData.Director ? movieData.Director.split(',').map(director => director.trim()) : [],
              Writers: movieData.Writer ? movieData.Writer.split(',').map(writer => writer.trim()) : [],
              Actors: movieData.Actors ? movieData.Actors.split(',').map(actor => actor.trim()) : [],
              MetaScore: movieData.Metascore !== 'N/A' ? parseInt(movieData.Metascore) : null,
              imdbRating: movieData.imdbRating !== 'N/A' ? Number(movieData.imdbRating) : null
            };
            movies.push(movie);
          } else {
            console.error(`Error retrieving movie with imdbID ${imdbID}: ${movieData.Error}`);
          }
        } catch (error) {
          console.error('Error parsing movie data:', error);
        } finally {
          completedRequests++;
          if (completedRequests === imdbIDs.length) {
            // 所有请求完成后发送响应
            res.status(200).json(movies);
          }
        }
      });
    }).on('error', (error) => {
      console.error('Error fetching movie data:', error);
      completedRequests++;
      if (completedRequests === imdbIDs.length) {
        // 即使有错误，也在所有请求完成后发送响应
        res.status(200).json(movies);
      }
    });
  });
});

app.listen(port, () => {
  console.log(`Server listening at http://localhost:${port}`);
});

function loadMovies(imdbIDs) {
  const xhr = new XMLHttpRequest();
  xhr.open("POST", "/movies");
  xhr.setRequestHeader("Content-Type", "application/json"); // 设置请求头

  xhr.onload = function () {
    const mainElement = document.querySelector("main");

    while (mainElement.childElementCount > 0) {
      mainElement.firstChild.remove()
    }

    if (xhr.status === 200) {
      JSON.parse(xhr.responseText)
        .forEach(movie => {
            // 这里可以调用 MovieBuilder，或者直接操作 DOM
            console.log(movie); // 打印接收到的电影数据
            //new MovieBuilder(movie, deleteMovie).appendTo(mainElement)
        });
    } else {
      mainElement.append(`Data could not be loaded, status ${xhr.status} - ${xhr.statusText}`);
    }
  }
  xhr.onerror = function() {
    console.error("Request failed");
  }
  xhr.send(JSON.stringify(imdbIDs)); // 将数据转换为 JSON 字符串并发送
}

// 示例调用
const movieIds = ["tt0076759", "tt0080684", "tt0086190"]; // 示例 IMDB ID
loadMovies(movieIds);