✨ Ingest data to handle ensted objects when sync

panoratech · Jun 26, 2024 · 8a52d59 · 8a52d59
1 parent 3d358cb
commit 8a52d59
Show file tree

Hide file tree

Showing 7 changed files with 13 additions and 17 deletions.
diff --git a/packages/api/src/@core/@core-services/unification/ingest-data.service.ts b/packages/api/src/@core/@core-services/unification/ingest-data.service.ts
@@ -28,6 +28,7 @@ export class IngestDataService {
       slug: string;
       remote_id: string;
     }[],
+    extraParams?: { [key: string]: any },
   ): Promise<any[]> {
     const unifiedObject = (await this.coreUnification.unify<U[]>({
       sourceObject,
@@ -52,6 +53,7 @@ export class IngestDataService {
         unifiedObject,
         integrationId,
         sourceObject,
+        ...Object.values(extraParams || {}),
       );
     const event = await this.prisma.events.create({
       data: {

diff --git a/packages/api/src/@core/utils/types/interface.ts b/packages/api/src/@core/utils/types/interface.ts
@@ -43,5 +43,6 @@ export interface IBaseSync {
     data: any[],
     originSource: string,
     remote_data: Record<string, any>[],
+    ...rest: any
   ): Promise<any[]>;
 }
diff --git a/packages/api/src/ats/user/sync/sync.service.ts b/packages/api/src/ats/user/sync/sync.service.ts
@@ -34,9 +34,6 @@ export class SyncService implements OnModuleInit, IBaseSync {
   ) {
     this.logger.setContext(SyncService.name);
     this.registry.registerService('ats', 'user', this);
-  saveToDb(connection_id: string, linkedUserId: string, data: any[], originSource: string, remote_data: Record<string, any>[]): Promise<any[]> {
-    throw new Error('Method not implemented.');
-  }
   }
 
   async onModuleInit() {
@@ -193,7 +190,7 @@ export class SyncService implements OnModuleInit, IBaseSync {
     }
   }
 
-  async saveUsersInDb(
+  async saveToDb(
     linkedUserId: string,
     users: UnifiedUserOutput[],
     originSource: string,

diff --git a/packages/api/src/crm/stage/sync/sync.service.ts b/packages/api/src/crm/stage/sync/sync.service.ts
@@ -176,6 +176,7 @@ export class SyncService implements OnModuleInit, IBaseSync {
         'crm',
         'stage',
         customFieldMappings,
+        { id_deal: deal_id },
       );
     } catch (error) {
       throw error;
@@ -187,8 +188,8 @@ export class SyncService implements OnModuleInit, IBaseSync {
     linkedUserId: string,
     data: UnifiedStageOutput[],
     originSource: string,
-    deal_id: string,
     remote_data: Record<string, any>[],
+    deal_id: string,
   ): Promise<CrmStage[]> {
     try {
       let stages_results: CrmStage[] = [];

diff --git a/packages/api/src/ticketing/comment/sync/sync.service.ts b/packages/api/src/ticketing/comment/sync/sync.service.ts
@@ -169,6 +169,7 @@ export class SyncService implements OnModuleInit, IBaseSync {
         'tikceting',
         'comment',
         customFieldMappings,
+        { id_ticket: id_ticket },
       );
     } catch (error) {
       throw error;
@@ -179,8 +180,9 @@ export class SyncService implements OnModuleInit, IBaseSync {
     connection_id: string,
     linkedUserId: string,
     comments: UnifiedCommentOutput[],
-    id_ticket: string,
+    originSource: string,
     remote_data: Record<string, any>[],
+    id_ticket?: string,
   ): Promise<TicketingComment[]> {
     try {
       let comments_results: TicketingComment[] = [];

diff --git a/packages/api/src/ticketing/contact/sync/sync.service.ts b/packages/api/src/ticketing/contact/sync/sync.service.ts
@@ -37,15 +37,6 @@ export class SyncService implements OnModuleInit, IBaseSync {
     this.logger.setContext(SyncService.name);
     this.registry.registerService('ticketing', 'contact', this);
   }
-  saveToDb(
-    connection_id: string,
-    linkedUserId: string,
-    data: any[],
-    originSource: string,
-    remote_data: Record<string, any>[],
-  ): Promise<any[]> {
-    throw new Error('Method not implemented.');
-  }
 
   async onModuleInit() {
     try {
@@ -203,13 +194,14 @@ export class SyncService implements OnModuleInit, IBaseSync {
         'ticketing',
         'contact',
         customFieldMappings,
+        { remote_account_id: remote_account_id },
       );
     } catch (error) {
       throw error;
     }
   }
 
-  async saveContactsInDb(
+  async saveToDb(
     connection_id: string,
     linkedUserId: string,
     contacts: UnifiedContactOutput[],

diff --git a/packages/api/src/ticketing/tag/sync/sync.service.ts b/packages/api/src/ticketing/tag/sync/sync.service.ts
@@ -166,6 +166,7 @@ export class SyncService implements OnModuleInit, IBaseSync {
         'ticketing',
         'tag',
         customFieldMappings,
+        { id_ticket: id_ticket },
       );
       //TODO; do it in every file
       if (!sourceObject || sourceObject.length == 0) {
@@ -182,8 +183,8 @@ export class SyncService implements OnModuleInit, IBaseSync {
     linkedUserId: string,
     tags: UnifiedTagOutput[],
     originSource: string,
-    id_ticket: string,
     remote_data: Record<string, any>[],
+    id_ticket: string,
   ): Promise<TicketingTag[]> {
     try {
       let tags_results: TicketingTag[] = [];