承诺似乎没有按正确的顺序调用？

Question

我正在尝试重写我编写的用于为 MongoDB 数据库提供种子的模块。它最初可以很好地处理回调，但我想转向 Promises。但是，执行和结果似乎没有任何意义。

Seeder 对象中有三个通用函数：

// functions will be renamed
Seeder.prototype.connectPromise = function (url, opts) {
    return new Promise((resolve,reject) => {
        try {
            mongoose.connect(url, opts).then(() => {
                const connected = mongoose.connection.readyState == 1
                this.connected = connected
                resolve(connected)
            })
        } catch (error) {
            reject(error)
        }
    })
}
[...]
Seeder.prototype.seedDataPromise = function (data) {
    return new Promise((resolve,reject) => {
        if (!this.connected) reject(new Error('Not connected to MongoDB'))
        // Stores all promises to be resolved
        var promises = []
        // Fetch the model via its name string from mongoose
        const Model = mongoose.model(data.model)
        // For each object in the 'documents' field of the main object
        data.documents.forEach((item) => {
            // generates a Promise for a single item insertion.
            promises.push(promise(Model, item))
        })
        // Fulfil each Promise in parallel
        Promise.all(promises).then(resolve(true)).catch((e)=>{
            reject(e)
        })
    })
}
[...]
Seeder.prototype.disconnect = function () {
    mongoose.disconnect()
    this.connected = false
    this.listeners.forEach((l) => {
        if (l.cause == 'onDisconnect') l.effect()
   })
}

代码的主要逻辑没有问题。我可以让它正确地播种数据。然而，当使用 Promises 时，数据库在其他任何事情完成之前就断开连接，尽管断开连接函数被称为 .finally()。

我正在像这样运行这些函数：

Seeder.addListener('onConnect', function onConnect () { console.log('Connected') })
Seeder.addListener('onDisconnect', function onDisconnect () {console.log('Disconnected')})

Seeder.connectPromise(mongoURI, options).then(
    Seeder.seedDataPromise(data)
    ).catch((error) => {  <-- I am catching the error, why is it saying its unhandled?
        console.error(error)
}).finally(Seeder.disconnect())

输出是这样的：

Disconnected
(node:14688) UnhandledPromiseRejectionWarning: Error: Not connected to MongoDB
    at Promise (C:\Users\johnn\Documents\Code\node projects\mongoose-seeder\seed.js:83:37)

坦率地说，这对我来说没有意义，正如我在调用reject() 的堆栈跟踪中指出的那样。并且处理了这个拒绝，因为我有一个如上所示的 catch 语句。此外，我不明白为什么数据库甚至没有机会连接，因为 finally() 块应该最后调用。

除了其他建议外，解决方案是返回Promise.all 调用。

Answer 1

您将错误的参数传递给then 和finally。首先在这里：

Seeder.connectPromise(mongoURI, options).then(
    Seeder.seedDataPromise(data)
)

您实际上不是将回调函数传递给then，而是当场执行该函数（因此无需等待承诺解决并触发then回调——这不是回调）。

你应该这样做：

Seeder.connectPromise(mongoURI, options).then(
    () => Seeder.seedDataPromise(data)
)

这里出现了类似的错误：

finally(Seeder.disconnect())

应该是：

finally(() => Seeder.disconnect())

Promise 构造函数反模式

与您的问题无关，但您正在通过使用 new Promise 创建新的承诺来实现反模式，而实际上您已经通过使用 mongodb API 获得了承诺。

例如，您在此处执行此操作：

Seeder.prototype.connectPromise = function (url, opts) {
    return new Promise((resolve,reject) => {
        try {
            mongoose.connect(url, opts).then(() => {
                const connected = mongoose.connection.readyState == 1
                this.connected = connected
                resolve(connected)
            })
        } catch (error) {
            reject(error)
        }
    })
}

但是使用new 创建的包装承诺只是一个包装器，没有添加任何有用的东西。随便写：

Seeder.prototype.connectPromise = function (url, opts) {
    return mongoose.connect(url, opts).then(() => {
        const connected = mongoose.connection.readyState == 1
        this.connected = connected
        return connected;
    });
}

同样的情况发生在你的下一个原型函数中。我将留给您在此处应用类似的简化，因此请避免使用 promise constructor antipattern。

---

在稍后对您问题的编辑中，您包含了此更改，但您没有在该函数中返回承诺。在此处添加return：

  return Promise.all(promises).then(() => {
//^^^^^^
      return true
  }).catch(() => {
      console.log(`Connected:\t${this.connected}`)
  })