Transactions in upsert content

Author: Joan Reyero

backend/src/services/eagleEyeContentService.ts

@@ -15,6 +15,7 @@ import {
 import { PageData, QueryData } from '../types/common'
 import Error400 from '../errors/Error400'
 import UserRepository from '../database/repositories/userRepository'
+import SequelizeRepository from '../database/repositories/sequelizeRepository'
 
 export interface EagleEyeContentUpsertData extends EagleEyeAction {
   content: EagleEyeContent
@@ -38,19 +39,36 @@ export default class EagleEyeContentService extends LoggingBase {
     if (!data.url) {
       throw new Error400(this.options.language, 'errors.eagleEye.urlRequiredWhenUpserting')
     }
+    const transaction = await SequelizeRepository.createTransaction(this.options)
 
-    // find by url
-    const existing = await EagleEyeContentRepository.findByUrl(data.url, this.options)
+    try {
+      // find by url
+      const existing = await EagleEyeContentRepository.findByUrl(data.url, {
+        ...this.options,
+        transaction,
+      })
+
+      let record
+
+      if (existing) {
+        record = await EagleEyeContentRepository.update(existing.id, data, {
+          ...this.options,
+          transaction,
+        })
+      } else {
+        record = await EagleEyeContentRepository.create(data, {
+          ...this.options,
+          transaction,
+        })
+      }
 
-    let record
+      await SequelizeRepository.commitTransaction(transaction)
 
-    if (existing) {
-      record = await EagleEyeContentRepository.update(existing.id, data, this.options)
-    } else {
-      record = await EagleEyeContentRepository.create(data, this.options)
+      return record
+    } catch (error) {
+      await SequelizeRepository.rollbackTransaction(transaction)
+      throw error
     }
-
-    return record
   }
 
   async findById(id: string): Promise<EagleEyeContent> {