From 7d64ee85ac93e25a599ff31c456dd147de2a42cf Mon Sep 17 00:00:00 2001 From: neo773 <62795688+neo773@users.noreply.github.com> Date: Wed, 28 Jan 2026 06:16:25 +0530 Subject: [PATCH] Clean up and enhance logging for messaging and calendar (#17498) This PR reduces noise to signal ratio for messaging and calendar logging in production Impact would be faster queries and debugging --- .../services/caldav-get-events.service.ts | 4 ++-- .../google-calendar-get-events.service.ts | 2 +- ...-event-import-exception-handler.service.ts | 12 ++++++----- .../services/calendar-fetch-events.service.ts | 9 ++++++--- .../messaging-message-cleaner.service.ts | 6 +++--- .../services/gmail-get-all-folders.service.ts | 2 +- .../microsoft-get-all-folders.service.ts | 2 +- .../services/imap-get-messages.service.ts | 4 ++-- .../imap/services/imap-sync.service.ts | 6 +++--- ...essage-list-fetch-error-handler.service.ts | 2 +- ...t-messages-import-error-handler.service.ts | 2 +- ...essaging-delete-folder-messages.service.ts | 2 +- ...ing-delete-group-email-messages.service.ts | 4 ++-- ...saging-import-exception-handler.service.ts | 5 ++++- .../messaging-message-list-fetch.service.ts | 20 ++++++++----------- .../messaging-messages-import.service.ts | 2 +- ...essaging-process-folder-actions.service.ts | 6 +++--- ...ing-process-group-email-actions.service.ts | 10 +++++----- 18 files changed, 52 insertions(+), 48 deletions(-) diff --git a/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/drivers/caldav/services/caldav-get-events.service.ts b/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/drivers/caldav/services/caldav-get-events.service.ts index 2e88d8bbdef..8929b4ed81f 100644 --- a/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/drivers/caldav/services/caldav-get-events.service.ts +++ b/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/drivers/caldav/services/caldav-get-events.service.ts @@ -23,7 +23,7 @@ export class CalDavGetEventsService { >, syncCursor?: string, ): Promise { - this.logger.log(`Getting calendar events for ${connectedAccount.handle}`); + this.logger.debug(`Getting calendar events for ${connectedAccount.handle}`); try { const caldavCalendarClient = @@ -46,7 +46,7 @@ export class CalDavGetEventsService { syncCursor: syncCursor ? JSON.parse(syncCursor) : undefined, }); - this.logger.log( + this.logger.debug( `Found ${result.events.length} calendar events for ${connectedAccount.handle}`, ); diff --git a/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/drivers/google-calendar/services/google-calendar-get-events.service.ts b/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/drivers/google-calendar/services/google-calendar-get-events.service.ts index 03b0288e4a4..ca1535b1c58 100644 --- a/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/drivers/google-calendar/services/google-calendar-get-events.service.ts +++ b/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/drivers/google-calendar/services/google-calendar-get-events.service.ts @@ -108,7 +108,7 @@ export class GoogleCalendarGetEventsService { this.logger.error( `Calendar event import error for Google Calendar. status: ${error.response?.status}`, ); - this.logger.log(error); + this.logger.error(error); const googleCalendarError = { code: error.response?.status, reason: 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 e170a8067a8..f870f8fa01e 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,7 @@ export class CalendarEventImportErrorHandlerService { calendarChannel: Pick, workspaceId: string, ): Promise { - this.logger.log( + this.logger.debug( `CalendarChannelId: ${calendarChannel.id} - Sync cursor error, resetting and rescheduling`, ); @@ -112,7 +112,7 @@ export class CalendarEventImportErrorHandlerService { ); const calendarEventImportException = new CalendarEventImportException( - `Temporary error occurred ${CALENDAR_THROTTLE_MAX_ATTEMPTS} times while importing calendar events for calendar channel ${calendarChannel.id.slice(0, 5)}... in workspace ${workspaceId} with throttleFailureCount ${calendarChannel.throttleFailureCount}`, + `Temporary error occurred ${CALENDAR_THROTTLE_MAX_ATTEMPTS} times while importing calendar events for calendar channel ${calendarChannel.id} in workspace ${workspaceId} with throttleFailureCount ${calendarChannel.throttleFailureCount}`, CalendarEventImportExceptionCode.UNKNOWN, ); @@ -121,6 +121,8 @@ export class CalendarEventImportErrorHandlerService { { additionalData: { calendarChannelId: calendarChannel.id, + syncStep, + throttleFailureCount: calendarChannel.throttleFailureCount, }, workspace: { id: workspaceId, @@ -194,17 +196,17 @@ export class CalendarEventImportErrorHandlerService { ); const calendarEventImportException = new CalendarEventImportException( - `Unknown error importing calendar events for calendar channel ${calendarChannel.id.slice(0, 5)}... in workspace ${workspaceId}: ${exception.message}`, + `Unknown error importing calendar events for calendar channel ${calendarChannel.id} in workspace ${workspaceId}: ${exception.message}`, CalendarEventImportExceptionCode.UNKNOWN, ); - this.logger.log(exception); + this.logger.error(exception); this.exceptionHandlerService.captureExceptions( [calendarEventImportException], { additionalData: { calendarChannelId: calendarChannel.id, - exception, + exceptionMessage: exception.message, }, workspace: { id: workspaceId, diff --git a/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/services/calendar-fetch-events.service.ts b/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/services/calendar-fetch-events.service.ts index ab67cc4ec0d..45076235c80 100644 --- a/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/services/calendar-fetch-events.service.ts +++ b/packages/twenty-server/src/modules/calendar/calendar-event-import-manager/services/calendar-fetch-events.service.ts @@ -41,6 +41,10 @@ export class CalendarFetchEventsService { connectedAccount: ConnectedAccountWorkspaceEntity, workspaceId: string, ): Promise { + this.logger.log( + `WorkspaceId: ${workspaceId}, CalendarChannelId: ${calendarChannel.id} - Fetching calendar events`, + ); + await this.calendarChannelSyncStatusService.markAsCalendarEventListFetchOngoing( [calendarChannel.id], workspaceId, @@ -141,10 +145,9 @@ export class CalendarFetchEventsService { ); } } catch (error) { - this.logger.log( - `Calendar event fetch error for workspace ${workspaceId} and calendar channel ${calendarChannel.id}`, + this.logger.error( + `WorkspaceId: ${workspaceId}, CalendarChannelId: ${calendarChannel.id} - Calendar event fetch error: ${error.message}`, ); - this.logger.error(error); await this.calendarEventImportErrorHandlerService.handleDriverException( error, CalendarEventImportSyncStep.CALENDAR_EVENT_LIST_FETCH, diff --git a/packages/twenty-server/src/modules/messaging/message-cleaner/services/messaging-message-cleaner.service.ts b/packages/twenty-server/src/modules/messaging/message-cleaner/services/messaging-message-cleaner.service.ts index 8a22c85db35..5601f1984f9 100644 --- a/packages/twenty-server/src/modules/messaging/message-cleaner/services/messaging-message-cleaner.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-cleaner/services/messaging-message-cleaner.service.ts @@ -88,7 +88,7 @@ export class MessagingMessageCleanerService { continue; } - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId} Deleting ${orphanMessages.length} orphan messages`, ); @@ -109,7 +109,7 @@ export class MessagingMessageCleanerService { continue; } - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId} Deleting ${orphanMessageThreads.length} orphan message threads`, ); @@ -171,7 +171,7 @@ export class MessagingMessageCleanerService { workspaceId: string, transactionManager?: WorkspaceEntityManager, ) => { - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId} Deleting ${ids.length} messages from message cleaner`, ); await messageRepository.delete(ids, transactionManager); diff --git a/packages/twenty-server/src/modules/messaging/message-folder-manager/drivers/gmail/services/gmail-get-all-folders.service.ts b/packages/twenty-server/src/modules/messaging/message-folder-manager/drivers/gmail/services/gmail-get-all-folders.service.ts index 3319e0349d5..b6d83aea031 100644 --- a/packages/twenty-server/src/modules/messaging/message-folder-manager/drivers/gmail/services/gmail-get-all-folders.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-folder-manager/drivers/gmail/services/gmail-get-all-folders.service.ts @@ -100,7 +100,7 @@ export class GmailGetAllFoldersService implements MessageFolderDriver { }); } - this.logger.log( + this.logger.debug( `Found ${folders.length} folders for Gmail account ${connectedAccount.handle}`, ); diff --git a/packages/twenty-server/src/modules/messaging/message-folder-manager/drivers/microsoft/services/microsoft-get-all-folders.service.ts b/packages/twenty-server/src/modules/messaging/message-folder-manager/drivers/microsoft/services/microsoft-get-all-folders.service.ts index d155b7618de..cd64d0ee670 100644 --- a/packages/twenty-server/src/modules/messaging/message-folder-manager/drivers/microsoft/services/microsoft-get-all-folders.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-folder-manager/drivers/microsoft/services/microsoft-get-all-folders.service.ts @@ -99,7 +99,7 @@ export class MicrosoftGetAllFoldersService implements MessageFolderDriver { }); } - this.logger.log( + this.logger.debug( `Found ${folderInfos.length} folders for Microsoft account ${connectedAccount.handle}`, ); diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/services/imap-get-messages.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/services/imap-get-messages.service.ts index 343ad540726..b06e2039159 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/services/imap-get-messages.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/services/imap-get-messages.service.ts @@ -107,7 +107,7 @@ export class ImapGetMessagesService { client: ImapFlow, connectedAccount: ConnectedAccount, ): Promise { - this.logger.log( + this.logger.debug( `Fetching ${messageUids.length} messages from ${folderPath}`, ); const startTime = Date.now(); @@ -146,7 +146,7 @@ export class ImapGetMessagesService { ); } - this.logger.log( + this.logger.debug( `Parsed ${messages.length}/${results.length} messages from ${folderPath} in ${Date.now() - startTime}ms`, ); diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/services/imap-sync.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/services/imap-sync.service.ts index fb9292f4437..734bb56a01a 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/services/imap-sync.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/imap/services/imap-sync.service.ts @@ -66,7 +66,7 @@ export class ImapSyncService { const { maxUid } = mailboxState; if (canUseQresync(client, previousCursor, mailboxState)) { - this.logger.log(`Using QRESYNC for folder ${folderPath}`); + this.logger.debug(`Using QRESYNC for folder ${folderPath}`); try { return await this.fetchWithQresync( @@ -81,7 +81,7 @@ export class ImapSyncService { } } - this.logger.log(`Using UID range fetch for folder ${folderPath}`); + this.logger.debug(`Using UID range fetch for folder ${folderPath}`); return this.fetchWithUidRange(client, lastSyncedUid, maxUid); } @@ -122,7 +122,7 @@ export class ImapSyncService { return []; } - this.logger.log(`QRESYNC found ${uids.length} new/modified messages`); + this.logger.debug(`QRESYNC found ${uids.length} new/modified messages`); return uids; } diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/microsoft/services/microsoft-message-list-fetch-error-handler.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/microsoft/services/microsoft-message-list-fetch-error-handler.service.ts index db6b083471b..8f2904d8bce 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/microsoft/services/microsoft-message-list-fetch-error-handler.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/microsoft/services/microsoft-message-list-fetch-error-handler.service.ts @@ -15,7 +15,7 @@ export class MicrosoftMessageListFetchErrorHandler { // eslint-disable-next-line @typescript-eslint/no-explicit-any public handleError(error: any): void { - this.logger.log(`Error fetching message list: ${JSON.stringify(error)}`); + this.logger.error(`Error fetching message list: ${JSON.stringify(error)}`); const networkError = this.microsoftNetworkErrorHandler.handleError(error); diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/microsoft/services/microsoft-messages-import-error-handler.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/microsoft/services/microsoft-messages-import-error-handler.service.ts index 1328740bfd1..2d041d1ff30 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/microsoft/services/microsoft-messages-import-error-handler.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/drivers/microsoft/services/microsoft-messages-import-error-handler.service.ts @@ -15,7 +15,7 @@ export class MicrosoftMessagesImportErrorHandler { // eslint-disable-next-line @typescript-eslint/no-explicit-any public handleError(error: any): void { - this.logger.log(`Error fetching messages: ${JSON.stringify(error)}`); + this.logger.error(`Error fetching messages: ${JSON.stringify(error)}`); const networkError = this.microsoftNetworkErrorHandler.handleError(error); diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-folder-messages.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-folder-messages.service.ts index 173ab172469..7638c50ec1e 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-folder-messages.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-folder-messages.service.ts @@ -62,7 +62,7 @@ export class MessagingDeleteFolderMessagesService { totalDeletedCount += validExternalIds.length; - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id}, FolderId: ${messageFolder.id} - Processed ${validExternalIds.length} message deletions`, ); } diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-group-email-messages.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-group-email-messages.service.ts index 00eeffc05c2..ec3dcf0e04e 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-group-email-messages.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-delete-group-email-messages.service.ts @@ -55,7 +55,7 @@ export class MessagingDeleteGroupEmailMessagesService { }); if (!firstRecord) { - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannelId} - No message associations found`, ); @@ -125,7 +125,7 @@ export class MessagingDeleteGroupEmailMessagesService { totalDeletedCount += messageExternalIdsChunk.length; - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannelId} - Deleted ${messageExternalIdsChunk.length} group email messages`, ); } diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-import-exception-handler.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-import-exception-handler.service.ts index 45d61c92e9e..ebf85b75017 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-import-exception-handler.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-import-exception-handler.service.ts @@ -134,12 +134,14 @@ export class MessageImportExceptionHandlerService { this.exceptionHandlerService.captureExceptions( [ new Error( - `Temporary error occurred ${MESSAGING_THROTTLE_MAX_ATTEMPTS} times while importing messages for message channel ${messageChannel.id.slice(0, 5)}... in workspace ${workspaceId}: ${exception?.message}`, + `Temporary error occurred ${MESSAGING_THROTTLE_MAX_ATTEMPTS} times while importing messages for message channel ${messageChannel.id} in workspace ${workspaceId}: ${exception?.message}`, ), ], { additionalData: { messageChannelId: messageChannel.id, + syncStep, + throttleFailureCount: messageChannel.throttleFailureCount, }, workspace: { id: workspaceId }, }, @@ -247,6 +249,7 @@ export class MessageImportExceptionHandlerService { { additionalData: { messageChannelId: messageChannel.id, + syncStep, }, workspace: { id: workspaceId }, }, diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-message-list-fetch.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-message-list-fetch.service.ts index 96a71aeaf4b..77be3c02072 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-message-list-fetch.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-message-list-fetch.service.ts @@ -75,7 +75,7 @@ export class MessagingMessageListFetchService { ); this.logger.log( - `messageChannelId: ${messageChannel.id} Processing message list fetch`, + `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id} - Processing message list fetch`, ); const messageChannelRepository = @@ -96,7 +96,7 @@ export class MessagingMessageListFetchService { if (!isDefined(freshMessageChannel)) { this.logger.error( - `error processing message list fetch: messageChannelId: ${messageChannel.id} Message channel not found`, + `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id} - Message channel not found`, ); return; @@ -157,11 +157,7 @@ export class MessagingMessageListFetchService { let totalMessagesToImportCount = 0; this.logger.log( - `messageChannelId: ${freshMessageChannel.id} Is full sync: ${isFullSync} and toImportCount: ${messageExternalIds.length}, toDeleteCount: ${messageExternalIdsToDelete.length}, cursors: ${messageLists.map( - (messageList) => { - messageList.nextSyncCursor; - }, - )}`, + `WorkspaceId: ${workspaceId}, MessageChannelId: ${freshMessageChannel.id} - Is full sync: ${isFullSync}, toImportCount: ${messageExternalIds.length}, toDeleteCount: ${messageExternalIdsToDelete.length}`, ); const messageChannelMessageAssociationRepository = @@ -198,7 +194,7 @@ export class MessagingMessageListFetchService { ); if (messageExternalIdsToImport.length) { - this.logger.log( + this.logger.debug( `messageChannelId: ${freshMessageChannel.id} Adding ${messageExternalIdsToImport.length} message external ids to import in batch ${index + 1}`, ); @@ -241,13 +237,13 @@ export class MessagingMessageListFetchService { if (allMessageExternalIdsToDelete.length) { this.logger.log( - `messageChannelId: ${freshMessageChannel.id} Deleting ${allMessageExternalIdsToDelete.length} message channel message associations`, + `WorkspaceId: ${workspaceId}, MessageChannelId: ${freshMessageChannel.id} - Deleting ${allMessageExternalIdsToDelete.length} message channel message associations`, ); const toDeleteChunks = chunk(allMessageExternalIdsToDelete, 200); for (const [index, toDeleteChunk] of toDeleteChunks.entries()) { - this.logger.log( + this.logger.debug( `messageChannelId: ${freshMessageChannel.id} Deleting ${toDeleteChunk.length} message channel message associations in batch ${index + 1}`, ); @@ -264,7 +260,7 @@ export class MessagingMessageListFetchService { } this.logger.log( - `messageChannelId: ${freshMessageChannel.id} Total messages to import count: ${totalMessagesToImportCount}`, + `WorkspaceId: ${workspaceId}, MessageChannelId: ${freshMessageChannel.id} - Total messages to import count: ${totalMessagesToImportCount}`, ); if (totalMessagesToImportCount === 0) { @@ -276,7 +272,7 @@ export class MessagingMessageListFetchService { return; } - this.logger.log( + this.logger.debug( `messageChannelId: ${freshMessageChannel.id} Scheduling direct messages import`, ); 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 4a9958cee79..debc8074885 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 @@ -198,7 +198,7 @@ export class MessagingMessagesImportService { ); } catch (error) { this.logger.error( - `Error (${error.code}) importing messages for workspace ${workspaceId.slice(0, 8)} and account ${connectedAccount.id.slice(0, 8)}: ${error.message} - ${error.body}`, + `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id} - Error (${error.code}) importing messages: ${error.message}`, ); await this.cacheStorage.setAdd( `messages-to-import:${workspaceId}:${messageChannel.id}`, diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-process-folder-actions.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-process-folder-actions.service.ts index 5042509e724..6e955e43cf6 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-process-folder-actions.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-process-folder-actions.service.ts @@ -49,7 +49,7 @@ export class MessagingProcessFolderActionsService { for (const folder of foldersWithPendingActions) { try { - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id}, FolderId: ${folder.id} - Processing folder action: ${folder.pendingSyncAction}`, ); @@ -65,7 +65,7 @@ export class MessagingProcessFolderActionsService { folderIdsToDelete.push(folder.id); - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id}, FolderId: ${folder.id} - Completed FOLDER_DELETION action`, ); } @@ -109,7 +109,7 @@ export class MessagingProcessFolderActionsService { transactionManager, ); - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id} - Reset pendingSyncAction to NONE for ${processedFolderIds.length} folders`, ); } diff --git a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-process-group-email-actions.service.ts b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-process-group-email-actions.service.ts index 6db0f46f208..f3f36c07d86 100644 --- a/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-process-group-email-actions.service.ts +++ b/packages/twenty-server/src/modules/messaging/message-import-manager/services/messaging-process-group-email-actions.service.ts @@ -42,7 +42,7 @@ export class MessagingProcessGroupEmailActionsService { { pendingGroupEmailsAction }, ); - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id} - Marked message channel as pending group emails action: ${pendingGroupEmailsAction}`, ); }, authContext); @@ -61,7 +61,7 @@ export class MessagingProcessGroupEmailActionsService { return; } - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id} - Processing group email action: ${pendingGroupEmailsAction}`, ); @@ -106,7 +106,7 @@ export class MessagingProcessGroupEmailActionsService { transactionManager, ); - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannel.id} - Reset pendingGroupEmailsAction to NONE`, ); } catch (error) { @@ -137,7 +137,7 @@ export class MessagingProcessGroupEmailActionsService { transactionManager, }); - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannelId} - Completed GROUP_EMAILS_DELETION action`, ); } @@ -153,7 +153,7 @@ export class MessagingProcessGroupEmailActionsService { transactionManager, }); - this.logger.log( + this.logger.debug( `WorkspaceId: ${workspaceId}, MessageChannelId: ${messageChannelId} - Completed GROUP_EMAILS_IMPORT action`, ); }