From 57b5a5daed04cd155fb7ce9ec5bed9ea94515ec0 Mon Sep 17 00:00:00 2001
From: Irwansyah <irwansyah@gmail.com>
Date: Mon, 2 Sep 2024 12:42:47 +0700
Subject: [PATCH] fix: failed to create ats user

---
 .../api/src/ats/user/sync/sync.service.ts     | 23 ++++++++++---------
 1 file changed, 12 insertions(+), 11 deletions(-)

diff --git a/packages/api/src/ats/user/sync/sync.service.ts b/packages/api/src/ats/user/sync/sync.service.ts
index 8d2061c85..16a83946c 100644
--- a/packages/api/src/ats/user/sync/sync.service.ts
+++ b/packages/api/src/ats/user/sync/sync.service.ts
@@ -7,13 +7,13 @@ import { FieldMappingService } from '@@core/field-mapping/field-mapping.service'
 import { ServiceRegistry } from '../services/registry.service';
 import { WebhookService } from '@@core/@core-services/webhooks/panora-webhooks/webhook.service';
 import { CoreSyncRegistry } from '@@core/@core-services/registries/core-sync.registry';
-import { ApiResponse } from '@@core/utils/types';
+
 import { IUserService } from '../types';
 import { OriginalUserOutput } from '@@core/utils/types/original/original.ats';
 import { UnifiedAtsUserOutput } from '../types/model.unified';
 import { ats_users as AtsUser } from '@prisma/client';
 import { ATS_PROVIDERS } from '@panora/shared';
-import { AtsObject } from '@ats/@lib/@types';
+
 import { BullQueueService } from '@@core/@core-services/queues/shared.service';
 import { IBaseSync, SyncLinkedUserType } from '@@core/utils/types/interface';
 import { IngestDataService } from '@@core/@core-services/unification/ingest-data.service';
@@ -50,12 +50,12 @@ export class SyncService implements OnModuleInit, IBaseSync {
       this.logger.log('Syncing users...');
       const users = user_id
         ? [
-          await this.prisma.users.findUnique({
-            where: {
-              id_user: user_id,
-            },
-          }),
-        ]
+            await this.prisma.users.findUnique({
+              where: {
+                id_user: user_id,
+              },
+            }),
+          ]
         : await this.prisma.users.findMany();
       if (users && users.length > 0) {
         for (const user of users) {
@@ -102,7 +102,9 @@ export class SyncService implements OnModuleInit, IBaseSync {
       const service: IUserService =
         this.serviceRegistry.getService(integrationId);
       if (!service) {
-        this.logger.log(`No service found in {vertical:ats, commonObject: user} for integration ID: ${integrationId}`);
+        this.logger.log(
+          `No service found in {vertical:ats, commonObject: user} for integration ID: ${integrationId}`,
+        );
         return;
       }
 
@@ -133,7 +135,6 @@ export class SyncService implements OnModuleInit, IBaseSync {
         const existingUser = await this.prisma.ats_users.findFirst({
           where: {
             remote_id: originId,
-            
           },
         });
 
@@ -162,7 +163,7 @@ export class SyncService implements OnModuleInit, IBaseSync {
               id_ats_user: uuidv4(),
               created_at: new Date(),
               remote_id: originId,
-              
+              id_connection: connection_id,
             },
           });
         }