CHANGELOG.md

@@ -2,6 +2,13 @@
 
 All notable changes to this project will be documented in this file. See [standard-version](https://github.com/conventional-changelog/standard-version) for commit guidelines.
 
+## [1.13.0](https://gitlab.coko.foundation/cokoapps/server/compare/v1.12.2...v1.13.0) (2021-04-10)
+
+
+### Features
+
+* **server:** add useTransaction ([d33b2f2](https://gitlab.coko.foundation/cokoapps/server/commit/d33b2f24b0a6e197410b1f96949a8a1455fcf2c4))
+
 ### [1.12.2](https://gitlab.coko.foundation/cokoapps/server/compare/v1.12.1...v1.12.2) (2021-03-30)
 
 

package.json

 {
   "name": "@coko/server",
-  "version": "1.12.2",
+  "version": "1.13.0",
   "description": "A tweaked version of pubsweet-server for use by Coko's projects",
   "main": "src/index.js",
   "scripts": {

src/index.js

@@ -9,6 +9,7 @@ const { send: sendEmail } = require('@pubsweet/component-send-email')
 
 const app = require('./app')
 const { boss, connectToJobQueue } = require('./pgboss')
+const useTransaction = require('./useTransaction')
 
 const createJWT = authentication.token.create
 
@@ -23,6 +24,7 @@ module.exports = {
   BaseModel,
   logger,
   db,
+  useTransaction,
 
   cron,
 

src/useTransaction.js

+const { BaseModel } = require('@pubsweet/base-model')
+
+const useTransaction = async (callback, options = {}) => {
+  const { passedTrxOnly = false, trx } = options
+
+  /**
+   * Most common case (eg. useTransaction(callback))
+   * No pre-defined transaction was provided.
+   * Use transaction anyway.
+   */
+
+  if (!trx && !passedTrxOnly) {
+    return BaseModel.transaction(async newtrx => callback(newtrx))
+  }
+
+  /**
+   * I want to use a transaction only if one is provided through the options,
+   * None was. Just run function without a transaction.
+   */
+
+  if (!trx && passedTrxOnly) return callback()
+
+  /**
+   * Transaction was passed from a parent.
+   * Use passed transaction on current cb.
+   */
+
+  if (trx) return callback(trx)
+
+  throw new Error('Use transaction: Invalid arguments!')
+}
+
+module.exports = useTransaction