yujunjun/strapi
1
0
Fork 0
mirror of https://github.com/strapi/strapi.git synced 2025-12-28 23:57:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: properly store commit callbacks

Browse Source
This commit is contained in:
Marc-Roig 2023-05-22 15:19:53 +02:00
parent f03406c812
commit a6a50ab194
No known key found for this signature in database
GPG Key ID: FB4E2C43A0BEE249
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/core/database/lib/transaction-context.js
View File

@ -25,7 +25,7 @@ const transactionCtx = {
// Commit transaction
await trx.commit();
if (!store?.commitCallbacks) return;
if (!store?.commitCallbacks.length) return;
// Run callbacks
store.commitCallbacks.forEach((cb) => cb());
@ -43,7 +43,7 @@ const transactionCtx = {
// Rollback transaction
await trx.rollback();
if (!store?.rollbackCallbacks) return;
if (!store?.rollbackCallbacks.length) return;
// Run callbacks
store.rollbackCallbacks.forEach((cb) => cb());
@ -52,15 +52,15 @@ const transactionCtx = {
onCommit(cb) {
const store = storage.getStore();
if (store?.callbacks) {
store.callbacks.push(cb);
if (store?.commitCallbacks) {
store.commitCallbacks = [...store.commitCallbacks, cb];
}
},
onRollback(cb) {
const store = storage.getStore();
if (store?.callbacks) {
store.callbacks.push(cb);
if (store?.rollbackCallbacks) {
store.rollbackCallbacks = [...store.rollbackCallbacks, cb];
}
},
};