diff --git a/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/services/calendar-event-import-exception-handler.service.ts b/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/services/calendar-event-import-exception-handler.service.ts index 0bb40aa6b..1356a7773 100644 --- a/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/services/calendar-event-import-exception-handler.service.ts +++ b/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/services/calendar-event-import-exception-handler.service.ts @@ -85,7 +85,10 @@ export class CalendarEventImportErrorHandlerService { workspaceId, ); - return; + throw new CalendarEventImportException( + `Unknown temporary error occurred while importing calendar events for calendar channel ${calendarChannel.id} in workspace ${workspaceId} with throttleFailureCount${calendarChannel.throttleFailureCount}`, + CalendarEventImportExceptionCode.UNKNOWN, + ); } const calendarChannelRepository = diff --git a/packages/twenty-server/src/modules/contact-creation-manager/services/create-company-and-contact.service.ts b/packages/twenty-server/src/modules/contact-creation-manager/services/create-company-and-contact.service.ts index 1e918db09..a0c113483 100644 --- a/packages/twenty-server/src/modules/contact-creation-manager/services/create-company-and-contact.service.ts +++ b/packages/twenty-server/src/modules/contact-creation-manager/services/create-company-and-contact.service.ts @@ -84,13 +84,14 @@ export class CreateCompanyAndContactService { }); const alreadyCreatedContactEmails: string[] = alreadyCreatedContacts?.map( - ({ emails }) => emails?.primaryEmail, + ({ emails }) => emails?.primaryEmail?.toLowerCase(), ); const filteredContactsToCreate = uniqueContacts.filter( (participant) => - !alreadyCreatedContactEmails.includes(participant.handle) && - participant.handle.includes('@'), + !alreadyCreatedContactEmails.includes( + participant.handle.toLowerCase(), + ) && participant.handle.includes('@'), ); const filteredContactsToCreateWithCompanyDomainNames = diff --git a/packages/twenty-server/src/modules/contact-creation-manager/services/create-contact.service.ts b/packages/twenty-server/src/modules/contact-creation-manager/services/create-contact.service.ts index d6800089b..91e3e11ec 100644 --- a/packages/twenty-server/src/modules/contact-creation-manager/services/create-contact.service.ts +++ b/packages/twenty-server/src/modules/contact-creation-manager/services/create-contact.service.ts @@ -51,7 +51,10 @@ export class CreateContactService { return { id, - emails: { primaryEmail: handle, additionalEmails: null }, + emails: { + primaryEmail: handle.toLowerCase(), + additionalEmails: null, + }, name: { firstName, lastName, diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-messages-import.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-messages-import.service.ts index f21e0d247..10a156bf7 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-messages-import.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-messages-import.service.ts @@ -146,7 +146,7 @@ export class MessagingMessagesImportService { blocklist.map((blocklistItem) => blocklistItem.handle), ); - await this.saveMessagesAndEnqueueContactCreationService.saveMessagesAndEnqueueContactCreationJob( + await this.saveMessagesAndEnqueueContactCreationService.saveMessagesAndEnqueueContactCreation( messagesToSave, messageChannel, connectedAccount, diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-save-messages-and-enqueue-contact-creation.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-save-messages-and-enqueue-contact-creation.service.ts index b92f99517..3ff7efd77 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-save-messages-and-enqueue-contact-creation.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-save-messages-and-enqueue-contact-creation.service.ts @@ -36,7 +36,7 @@ export class MessagingSaveMessagesAndEnqueueContactCreationService { private readonly twentyORMManager: TwentyORMManager, ) {} - async saveMessagesAndEnqueueContactCreationJob( + async saveMessagesAndEnqueueContactCreation( messagesToSave: MessageWithParticipants[], messageChannel: MessageChannelWorkspaceEntity, connectedAccount: ConnectedAccountWorkspaceEntity,