Pass the existing transaction to merge organizations on enrichment (#1661)

Author: skwowet

backend/src/services/IServiceOptions.ts

@@ -10,4 +10,5 @@ export interface IServiceOptions {
   currentSegments: SegmentData[]
   database: any
   redis: RedisClient
+  transaction?: any
 }

backend/src/services/premium/enrichment/organizationEnrichmentService.ts

@@ -168,7 +168,7 @@ export default class OrganizationEnrichmentService extends LoggerBase {
 
         // Check for an organization with the same website exists
         const existingOrg = await OrganizationRepository.findByDomain(org.website, this.options)
-        const orgService = new OrganizationService(this.options)
+        const orgService = new OrganizationService({ ...this.options, transaction })
 
         if (existingOrg && existingOrg.id !== org.id) {
           await orgService.merge(existingOrg.id, org.id)