feat: Enable cross-trigger transactions via shared context

.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

@@ -1698,9 +1698,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

@@ -97,6 +97,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();
@@ -167,7 +171,12 @@ RestWrite.prototype.execute = function () {
         throw new Parse.Error(Parse.Error.EMAIL_NOT_FOUND, 'User email is not verified.');
       }
       return this.response;
-    });
+    }).finally(() => {
+      if (this.context.transaction) {
+        // Ensure isolation even on uncaught errors
+        this.config.database.setTransactionalSession(null);
+      }
+    });;
 };
 
 // Uses the Auth object to get the list of roles, adds the user id

src/triggers.js

@@ -292,7 +292,15 @@ 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(
+      {},
+      context,
+      {
+        createTransactionalSession: config.database.createTransactionalSession.bind(config.database),
+        commitTransactionalSession: config.database.commitTransactionalSession.bind(config.database),
+        abortTransactionalSession: config.database.abortTransactionalSession.bind(config.database),
+      }
+    );
   }
 
   if (!auth) {