Node.js：优化内部API调用，实现多路由端点复用

// all-alarms.js (部分代码，展示思路)
const { spawn } = require('child_process');
const path = require('path');

router.get('/all-alarms', authenticateUser, getSiteIds, async (req, res) => {
  const endpoints = ['/alarm1', '/alarm2'];
  const bearerToken = req.headers.authorization;
  const processes = [];

  const handleEndpoint = (endpoint) => {
    return new Promise((resolve, reject) => {
      // 通过子进程启动另一个脚本，该脚本再通过axios调用HTTP端点
      const process = spawn('node', [path.join(__dirname, '../../', 'call-alarms.js'), endpoint, bearerToken]);
      process.stdout.on('data', (data) => resolve(JSON.parse(data)));
      process.stderr.on('data', (data) => reject(data.toString()));
    });
  };

  try {
    for (const endpoint of endpoints) {
      processes.push(handleEndpoint(endpoint));
    }
    const results = await Promise.all(processes);
    // ... 合并结果
    res.json(aggregatedData);
  } catch (error) {
    res.status(500).json({ error: 'Error occurred.' });
  }
});

// call-alarms.js (部分代码)
const axios = require('axios');
const endpoint = process.argv[2];
const bearerToken = process.argv[3];

axios.get(`http://localhost:3000${endpoint}`, {
  headers: { Authorization: bearerToken }
})
.then((response) => process.stdout.write(JSON.stringify(response.data)))
.catch((error) => process.stderr.write(error.message));

const express = require('express');
const router = express.Router();

// 假设这些是您的中间件
// function authenticateUser(req, res, next) { /* ... */ next(); }
// function getSiteIds(req, res, next) { /* ... */ next(); }

// 1. 抽象业务逻辑为可复用函数
// 如果数据获取是异步的，函数也应为async
async function getAlarm1Data(req) {
  // 这里可以包含从数据库、缓存或其他服务获取 alarm1 数据的逻辑
  // 模拟异步操作
  return new Promise(resolve => setTimeout(() => {
    // 假设需要req对象中的某些信息，如用户ID或站点ID
    // console.log("Fetching alarm1 for user:", req.user.id);
    resolve({
      id: 1,
      status: 'active',
      message: 'Alarm 1 is active'
    });
  }, 100));
}

async function getAlarm2Data(req) {
  // 模拟异步操作
  return new Promise(resolve => setTimeout(() => {
    resolve({
      id: 2,
      status: 'inactive',
      message: 'Alarm 2 is inactive'
    });
  }, 150));
}

// 2. 应用共享中间件
// 确保 authenticateUser 和 getSiteIds 在所有相关路由中被应用
// 可以在这里统一应用，或在每个路由单独应用
// router.use(authenticateUser);
// router.use(getSiteIds);

// 3. 定义独立端点，直接调用业务逻辑函数
router.get('/alarm1', authenticateUser, getSiteIds, async (req, res) => {
  try {
    const data = await getAlarm1Data(req);
    res.json(data);
  } catch (error) {
    res.status(500).json({
      error: 'Failed to retrieve alarm1 data.'
    });
  }
});

router.get('/alarm2', authenticateUser, getSiteIds, async (req, res) => {
  try {
    const data = await getAlarm2Data(req);
    res.json(data);
  } catch (error) {
    res.status(500).json({
      error: 'Failed to retrieve alarm2 data.'
    });
  }
});

// 4. 定义聚合端点，并行调用所有业务逻辑函数
router.get('/all-alarms', authenticateUser, getSiteIds, async (req, res) => {
  try {
    // 使用 Promise.all 并行执行所有异步数据获取操作
    const [alarm1Data, alarm2Data] = await Promise.all([
      getAlarm1Data(req), // 直接调用函数
      getAlarm2Data(req) // 直接调用函数
    ]);

    res.json({
      alarm1: alarm1Data,
      alarm2: alarm2Data
    });
  } catch (error) {
    console.error('Error fetching all alarms:', error);
    res.status(500).json({
      error: 'Failed to retrieve all alarm data.'
    });
  }
});

module.exports = router;