MeteorJS基于Promise的迁移同步 解决完成通知提前弹出问题

提前弹出迁移完成提示的核心原因有两个：

1. 你写的Meteor.wrapAsync封装不符合Node.js错误优先回调规范，没有正确捕获异步任务的等待状态。Meteor.wrapAsync要求传入的回调函数第一个参数接收错误对象、第二个参数接收正常返回结果，你原来的写法直接把Promise resolve结果作为第一个参数传入回调，会让封装逻辑误判异步任务执行状态，没有真正阻塞执行链等待异步任务完成。
2. 你使用的迁移库默认判定迁移完成的逻辑是「迁移函数同步执行栈清空」，本身不会主动等待函数内部抛出的异步Promise任务，只要有未被同步等待的异步逻辑，就会提前触发完成提示。

修正异步封装逻辑 #

把原来的wrapAsync写法改成符合错误优先回调规范的版本，确保异步任务的成功、失败状态都能被正确捕获，阻塞执行链等待任务完成：

const wrapIntoMongoTransaction = Meteor.wrapAsync(function (func, callback) {
  wrapIntoMongoTransactionAsync(func)
    .then(result => callback(null, result))
    .catch(err => callback(err));
});

如果不想处理回调参数的兼容问题，可以直接用Meteor内置的Promise.await做适配，写法更简单不容易出错，它可以直接在服务端Fiber环境中同步等待Promise执行完成：

const wrapIntoMongoTransaction = function(func) {
  return Promise.await(wrapIntoMongoTransactionAsync(func));
};

规范迁移函数写法 #

所有迁移逻辑必须完全包裹在同步封装的执行域内，所有异步操作（包括你通过MongoInternals拿到的原生db实例的所有操作，这些操作默认全是异步Promise形式）都要确保被等待，不能留游离的异步任务：

Migrations.add({
  version: 你的迁移版本号,
  name: '迁移任务备注名',
  up: function() {
    wrapIntoMongoTransaction(async (session) => {
      // 所有Mongo操作、其他异步调用都必须加await
      await db.collection('你的集合名').updateMany(/* 迁移逻辑 */, { session });
      await db.collection('你的集合名').insertMany(/* 种子数据 */, { session });
      // 不要在函数内留未await的异步调用
    });
  }
});

• 迁移函数内不要直接使用未做同步封装的第三方异步回调、setTimeout类宏任务，这类任务不会被Meteor的Fiber环境捕获，会直接导致执行链提前结束
• 可以在迁移逻辑最后一行加打印日志，对比完成提示的弹出时间：如果日志打印在提示弹出之前，说明还有未被等待的异步逻辑；如果日志打印完成后才弹出提示，说明适配生效。

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