Skip to content

Commit

Permalink
fix: failed to create ats user
Browse files Browse the repository at this point in the history
  • Loading branch information
irwansyahwii committed Sep 2, 2024
1 parent dbf61c4 commit 57b5a5d
Showing 1 changed file with 12 additions and 11 deletions.
23 changes: 12 additions & 11 deletions packages/api/src/ats/user/sync/sync.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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';
Expand Down Expand Up @@ -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) {
Expand Down Expand Up @@ -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;
}

Expand Down Expand Up @@ -133,7 +135,6 @@ export class SyncService implements OnModuleInit, IBaseSync {
const existingUser = await this.prisma.ats_users.findFirst({
where: {
remote_id: originId,

},
});

Expand Down Expand Up @@ -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,
},
});
}
Expand Down

0 comments on commit 57b5a5d

Please sign in to comment.