JavaScript Promise：在链式函数中捕获错误

Question

我有一个用于向 IndexDb 数据库添加记录的函数：

async function addAsync(storeName, object) {
    return new Promise((res, rej) => {
        // openDatabaseAsync() is another reusable method to open the db.  That works fine.
        openDatabaseAsync().then(db => {
            var store = openObjectStore(db, storeName, 'readwrite');
            var addResult = store.add(JSON.parse(object));
            addResult.onsuccess = res;
            addResult.onerror = (e) => {
                console.log("addResult Error");
                throw e;
            };
        }).catch(e => {
            // Error from "throw e;" above NOT GETTING CAUGHT HERE!
            console.error("addAsync ERROR > ", e, storeName, object);
            rej(e);
        });
    })
}

如果我尝试添加重复键，那么我期望：

addResult.onerror = (e) => {
    console.log("addResult Error");
    throw e;
}

捕捉它。确实如此。

但是，我也期待我的

.catch(e => {
    // Error from "throw e;" above NOT GETTING CAUGHT HERE!
    console.error("addAsync ERROR > ", e, storeName, object);
    rej(e);
})

捕获该错误。但相反，我得到了一个“未捕获”的日志。

控制台输出：

addResult Error
Uncaught Event {isTrusted: true, type: "error", target: IDBRequest, currentTarget: IDBRequest, eventPhase: 2, …}

最后的 .catch 是否只处理来自 openDatabaseAsync 调用的异常？我现在会想到，因为它被链接到 .then.

总之，我对上述代码的期望如下：

• 如果 openDatabaseAsync() 失败，那么我没有发现它，因此错误将被发送给 addAsync() 的调用者。
• 如果 .then 失败，那么我希望 .catch 能够捕获它，记录错误，然后拒绝承诺，这意味着调用 addAsync() 需要处理。

但是，我认为我应该从该行获取日志：

console.error("addAsync ERROR > ", e, storeName, object);

在拒绝被发送回 addAsync() 的调用者之前，此时可能未处理。

Answer 1

您的方法将受益于更大的检修。

• 一般来说，当函数不使用await时，不要写成async。
• 不要将new Promise() 用于返回承诺的操作，例如openDatabaseAsync()。回复该承诺，或切换到async/await。
• 包装 IndexedDB 操作以使其遵循 Promise 语义会很有用。

以IDBRequest为例：

function promisifyIDBRequest(idbr) {
    return new Promise( (resolve, reject) => {
        idbr.onsuccess = () => resolve(idbr.result);
        idbr.onerror = (e) => reject(e.target.error);
    });
}

现在你可以这样做了：

async function addAsync(storeName, object) {
    const db = await openDatabaseAsync();
    const store = openObjectStore(db, storeName, 'readwrite');
    return promisifyIDBRequest(store.add(JSON.parse(object)));
}

如果您想处理 addAsync() 内部的错误，请添加一个 try/catch 块。

值得一试现有的解决方案，这些解决方案使用承诺语义封装了整个 IndexedDB 接口，例如 https://github.com/jakearchibald/idb。

---

FWIW，上述函数的 promise-chain 变体如下所示：

function addAsync(storeName, object) {
    return openDatabaseAsync().then( (db) => {
        const store = openObjectStore(db, storeName, 'readwrite');
        return promisifyIDBRequest(store.add(JSON.parse(object)));
    });
}

两种变体都返回一个 IDBRequest 结果的承诺。