database transaction 在自定义 EventEmitter 事件处理上有什么特殊要求么？

[MarshalW]

有关 @nocobase/database transaction 的问题。

代码：

db.on('nft.afterUpdateWithAssociations', async (model, options) => {
    const { transaction } = options;
    eventEmitter.emit('ntfSeriesResetValues', { db, seriesIds, transaction }); // 报错
    // await updateNftSeries({ db, seriesIds, transaction }); // 正常使用
});

class MyEmitter extends EventEmitter {}
const eventEmitter = new MyEmitter();

eventEmitter.on('ntfSeriesResetValues', async function ({ db, seriesIds, transaction }) {
    await updateNftSeries({ db, seriesIds, transaction });
});

直接调用 updateNftSeries 方法（使用 repository api），正常执行。

eventEmitter.emit()触发执行相同的 updateNftSeries 方法，则会报错：

Error: commit has been called on this transaction(1fdc4d08-218c-4582-a7f8-135ba4467eeb), you can no longer use it. (The rejected query is attached as the 'sql' property of this error)
    at checkTransaction (/private/tmp/my-nocobase-app/node_modules/sequelize/src/sequelize.js:614:23)
    at /private/tmp/my-nocobase-app/node_modules/sequelize/src/sequelize.js:627:7
    at /private/tmp/my-nocobase-app/node_modules/retry-as-promised/index.js:69:21
    at new Promise (<anonymous>)
    at retryAsPromised (/private/tmp/my-nocobase-app/node_modules/retry-as-promised/index.js:59:10)
    at Sequelize.query (/private/tmp/my-nocobase-app/node_modules/sequelize/src/sequelize.js:622:12)
    at SQLiteQueryInterface.select (/private/tmp/my-nocobase-app/node_modules/sequelize/src/dialects/abstract/query-interface.js:1001:33)
    at Function.findAll (/private/tmp/my-nocobase-app/node_modules/sequelize/src/model.js:1815:47)

eventEmitter 应该是同步的，另外，nocobase自身也在使用。

@chenos 那么是不是 nocobase 对 transaction 在 EventEmitter 使用有什么限制或者要求么？

[chenos]

可以再试试，是因为之前 transaction 丢失了，问题已修复 #531

[MarshalW]

新的修复未在这里起到作用。

我新 clone 了一个 nocobase main 分支，通过 yarn dev 执行上述逻辑，报错是相同的：

Error: commit has been called on this transaction(e2e36561-6feb-4f83-899b-2dff7e5e75eb), you can no longer use it. (The rejected query is attached as the 'sql' property of this error)
    at checkTransaction (/private/tmp/nocobase/node_modules/sequelize/lib/sequelize.js:605:23)
    at /private/tmp/nocobase/node_modules/sequelize/lib/sequelize.js:618:7
    at /private/tmp/nocobase/node_modules/retry-as-promised/index.js:70:21
    at new Promise (<anonymous>)
    at retryAsPromised (/private/tmp/nocobase/node_modules/retry-as-promised/index.js:60:10)
    at Sequelize.query (/private/tmp/nocobase/node_modules/sequelize/lib/sequelize.js:613:12)
    at SQLiteQueryInterface.select (/private/tmp/nocobase/node_modules/sequelize/lib/dialects/abstract/query-interface.js:953:33)
    at Function.findAll (/private/tmp/nocobase/node_modules/sequelize/lib/model.js:1754:47)

只要是直接使用updateNftSeries 函数就可以正常使用 transaction，一旦通过 eventEmitter.emit 事件方式调用updateNftSeries 函数，就会报错。

完整的代码可以参见这里：https://github.com/MarshalW/my-nocobase-app/blob/nft/packages/plugins/nft/src/server/nft.ts

[chenos]

看了下，不能用 emit，要用 db.emitAsync，不然会导致 transaction 提前被 commit 了

[MarshalW]

是说，@nocobase/database 中的代码要从 db.emit 改为 db. emitAsync ，我要等更新后的代码库？

还是说，我的代码需要做处理:

// 原来代码
eventEmitter.emit('ntfSeriesResetValues', { db, seriesIds, transaction });

// 改为
eventEmitter. emitAsync('ntfSeriesResetValues', { db, seriesIds, transaction });

[chenos]

是的，emitAsync 现在就支持的

[chenos]

这样 await db.emitAsync()

[MarshalW]

在 Version 0.7.1-alpha.7 下测试没有问题了。

按照你所说的可以正常执行:

await db. emitAsync('ntfSeriesResetValues', { db, seriesIds, transaction });

也就是说，不能自己创建：

const eventEmitter = new MyEmitter();

而是要把 eventEmitter 换为 db