fix(activitystream): move activity creation after transaction commimt

2024-12-02 12:14:57 +01:00
parent 450ad95afc
commit f227a9b91d
1 changed files with 6 additions and 9 deletions
@@ -521,19 +521,16 @@ export const cloneStreamFactory =
      const { newStream } = coreCloneResult
      // Clone comments
      await cloneStreamCommentsFactory(deps)(state, coreCloneResult)
-      // Create activity item
-      await deps.addStreamClonedActivity(
-        {
-          sourceStreamId,
-          newStream,
-          clonerId: userId
-        },
-        { trx: state.trx }
-      )

      // Commit transaction
      await state.trx.commit()

+      // Create activity item
+      await deps.addStreamClonedActivity({
+        sourceStreamId,
+        newStream,
+        clonerId: userId
+      })
      return coreCloneResult.newStream
    } catch (e) {
      await state.trx.rollback()