Node.js嵌套异步函数的Promise提前返回问题如何正确实现链式调用

核心问题是findPeaks内部通过setInterval实现异步循环，但它本身没有返回Promise，也没有提供执行完成的通知机制，导致decodeSoundFile调用findPeaks后直接向下执行了resolve/reject判断逻辑，没有等待findPeaks真正执行结束。同时原有代码中回调内直接throw err的写法会导致错误无法被Promise捕获，容易出现异常逃逸。

1. 改造findPeaks为返回Promise的异步函数 #

将findPeaks的执行结束点（clearInterval位置）作为Promise的resolve触发点，确保外部可以感知到它的执行完成状态。

2. 改造decodeSoundFile的执行逻辑 #

等待findPeaks的Promise执行完成后，再判断lightPlant的状态执行resolve/reject。

3. 优化错误处理 #

将回调内的throw err改为调用Promise的reject，确保异常能被上层捕获。

// 两种startTheater写法可选，async/await写法更简洁
async function startTheater(sourceAudioFile) {
  try {
    const result = await decodeSoundFile(sourceAudioFile);
    setLight();
  } catch (err) {
    console.error('流程执行失败：', err);
  }
}

// 原有Promise回调写法也可兼容
// function startTheater(sourceAudioFile) {
//   decodeSoundFile(sourceAudioFile)
//     .then((result) => {
//       setLight(); 
//     })
//     .catch(err => console.error('流程执行失败：', err));
// }

function decodeSoundFile(soundfile) {
  return new Promise(function(resolve, reject) {
    fs.readFile(soundfile, function(err, buf) {
      if (err) return reject(err); // 用reject抛出错误，不要直接throw
      context.decodeAudioData(buf, function(audioBuffer) {
        playSound();
        // 原代码缺失pcmdata、samplerate赋值逻辑，这里补充示例，可根据实际业务调整
        const pcmdata = audioBuffer.getChannelData(0);
        const samplerate = audioBuffer.sampleRate;
        // 等待findPeaks执行完成后再走后续判断逻辑
        findPeaks(pcmdata, samplerate)
          .then(() => {
            if (lightPlant.length != 0) {
              resolve("light plan populated");
            } else {
              reject(new Error("broke promise. unable to populate"));
            }
          })
          .catch(err => reject(err));
      }, function(err) {
        return reject(err); // 用reject抛出错误
      })
    })
  });
}

function findPeaks(pcmdata, samplerate) {
  return new Promise((resolve, reject) => {
    // 原代码的index、max、prevmax建议放在函数内部，避免全局变量污染
    let index = 0;
    let max = 0;
    let prevmax = 0;
    const interval = 0.5 * 1000;
    const step = samplerate * (interval / 1000);

    const samplesound = setInterval(function() {
      try {
        if (index >= pcmdata.length) {
          clearInterval(samplesound);
          console.log("finished sampling sound");
          return resolve(); // 采样完成，通知外部
        }
        for (var i = index; i < index + step; i++) {
          max = pcmdata[i] > max ? pcmdata[i].toFixed(1) : max;
        }
        prevmax = max;
        max = 0;
        index += step;
      } catch (err) {
        clearInterval(samplesound);
        return reject(err);
      }
    }, interval, pcmdata);
  })
}

改造后findPeaks会在所有采样循环执行完成后才返回成功状态，decodeSoundFile会等待这个状态返回后再判断灯光方案是否生成完成，最终返回结果，此时触发的setLight自然是在全链路执行完成后才运行，符合业务要求。

内容的提问来源于stack exchange，提问作者user2607717