feat: enable cross-trigger transactions via shared context

Author: Yumcoder-dev

.gitpod.yml

@@ -0,0 +1,11 @@
+# This configuration file was automatically generated by Gitpod.
+# Please adjust to your needs (see https://www.gitpod.io/docs/introduction/learn-gitpod/gitpod-yaml)
+# and commit this file to your remote git repository to share the goodness with others.
+
+# Learn more from ready-to-use templates: https://www.gitpod.io/docs/introduction/getting-started/quickstart
+
+tasks:
+  - init: npm install && npm run build
+    command: npm run start
+
+

src/Controllers/DatabaseController.js

@@ -1686,9 +1686,14 @@ class DatabaseController {
     return protectedKeys;
   }
 
+  setTransactionalSession(transactionalSession) {
+    this._transactionalSession = transactionalSession;
+  }
+
   createTransactionalSession() {
     return this.adapter.createTransactionalSession().then(transactionalSession => {
       this._transactionalSession = transactionalSession;
+      return this._transactionalSession;
     });
   }
 

src/RestWrite.js

@@ -95,6 +95,10 @@ function RestWrite(config, auth, className, query, data, originalData, clientSDK
 // Returns a promise for a {response, status, location} object.
 // status and location are optional.
 RestWrite.prototype.execute = function () {
+  if (this.context.transaction) {
+    this.config.database.setTransactionalSession(this.context.transaction)
+  }
+
   return Promise.resolve()
     .then(() => {
       return this.getUserAndRoleACL();

src/triggers.js

@@ -281,7 +281,11 @@ export function getRequestObject(
     triggerType === Types.afterFind
   ) {
     // Set a copy of the context on the request object.
-    request.context = Object.assign({}, context);
+    request.context = Object.assign({
+      createTransactionalSession: config.database.createTransactionalSession.bind(config.database),
+      commitTransactionalSession: config.database.commitTransactionalSession.bind(config.database),
+      abortTransactionalSession: config.database.abortTransactionalSession.bind(config.database),
+    }, context);
   }
 
   if (!auth) {