From 9fe88c26393e989a47b1b4ac6a7a79f6cf43a76d Mon Sep 17 00:00:00 2001
From: Charles Bochet <charlesBochet@users.noreply.github.com>
Date: Mon, 8 Sep 2025 00:25:45 +0200
Subject: [PATCH] Messaging cleaning fixes (#14345)

---
 .../services/messaging-message-cleaner.service.ts    | 12 ++++++++++++
 1 file changed, 12 insertions(+)

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 636c71723e..173333fa27 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
@@ -55,6 +55,10 @@ export class MessagingMessageCleanerService {
           },
         });
 
+      if (messageChannelMessageAssociationsToDelete.length <= 0) {
+        continue;
+      }
+
       await messageChannelMessageAssociationRepository.delete(
         messageChannelMessageAssociationsToDelete.map(({ id }) => id),
       );
@@ -76,6 +80,10 @@ export class MessagingMessageCleanerService {
         },
       });
 
+      if (orphanMessages.length <= 0) {
+        continue;
+      }
+
       this.logger.log(
         `WorkspaceId: ${workspaceId} Deleting ${orphanMessages.length} orphan messages`,
       );
@@ -91,6 +99,10 @@ export class MessagingMessageCleanerService {
         },
       });
 
+      if (orphanMessageThreads.length <= 0) {
+        continue;
+      }
+
       this.logger.log(
         `WorkspaceId: ${workspaceId} Deleting ${orphanMessageThreads.length} orphan message threads`,
       );