Release - Fix migration message command (#15148)

packages/twenty-server/src/database/commands/upgrade-version-command/1-8/1-8-migrate-channel-sync-stages.command.ts

@@ -316,7 +316,16 @@ export class MigrateChannelSyncStagesCommand extends ActiveOrSuspendedWorkspaces
         option.value === MessageChannelSyncStage.PENDING_CONFIGURATION,
     );
 
-    if (hasMessageListFetchScheduled && hasPendingConfiguration) {
+    const hasMessageListFetchPending = fieldOptions.some(
+      (option) =>
+        option.value === MessageChannelSyncStage.MESSAGE_LIST_FETCH_PENDING,
+    );
+
+    if (
+      hasMessageListFetchScheduled &&
+      hasPendingConfiguration &&
+      hasMessageListFetchPending
+    ) {
       this.logger.log(
         `MessageChannel syncStage field metadata already migrated for workspace ${workspaceId}`,
       );
@@ -350,6 +359,14 @@ export class MigrateChannelSyncStagesCommand extends ActiveOrSuspendedWorkspaces
       });
     }
 
+    if (!hasMessageListFetchPending) {
+      fieldOptions.push({
+        value: MessageChannelSyncStage.MESSAGE_LIST_FETCH_PENDING,
+        label: 'Messages list fetch pending',
+        position: 0,
+        color: 'blue',
+      });
+    }
     syncStageField.options = fieldOptions;
 
     await this.fieldMetadataRepository.save(syncStageField);
@@ -408,7 +425,17 @@ export class MigrateChannelSyncStagesCommand extends ActiveOrSuspendedWorkspaces
         option.value === CalendarChannelSyncStage.PENDING_CONFIGURATION,
     );
 
-    if (hasCalendarEventListFetchScheduled && hasPendingConfiguration) {
+    const hasCalendarEventListFetchPending = fieldOptions.some(
+      (option) =>
+        option.value ===
+        CalendarChannelSyncStage.CALENDAR_EVENT_LIST_FETCH_PENDING,
+    );
+
+    if (
+      hasCalendarEventListFetchScheduled &&
+      hasPendingConfiguration &&
+      hasCalendarEventListFetchPending
+    ) {
       this.logger.log(
         `CalendarChannel syncStage field metadata already migrated for workspace ${workspaceId}`,
       );
@@ -442,6 +469,15 @@ export class MigrateChannelSyncStagesCommand extends ActiveOrSuspendedWorkspaces
       });
     }
 
+    if (!hasCalendarEventListFetchPending) {
+      fieldOptions.push({
+        value: CalendarChannelSyncStage.CALENDAR_EVENT_LIST_FETCH_PENDING,
+        label: 'Calendar event list fetch pending',
+        position: 0,
+        color: 'blue',
+      });
+    }
+
     syncStageField.options = fieldOptions;
 
     await this.fieldMetadataRepository.save(syncStageField);