[calendar/messaging] fix google refresh token transaction (twentyhq#4989

)

## Context
The full-sync job was enqueued within a transaction, which means it
could be executed before the transaction was commit and
connected-account was not created yet.
This PR re-arrange the code a bit to avoid this

cc @bosiraphael thx for flagging this!

packages/twenty-server/src/engine/core-modules/auth/services/google-apis.service.ts

@@ -84,23 +84,23 @@ export class GoogleAPIsService {
 
     const isCalendarEnabled =
       this.environmentService.get('CALENDAR_PROVIDER_GOOGLE_ENABLED') &&
-      !!isCalendarEnabledFlag;
+      !!isCalendarEnabledFlag?.value;
 
-    await workspaceDataSource?.transaction(async (manager: EntityManager) => {
-      const connectedAccounts =
-        await this.connectedAccountRepository.getAllByHandleAndWorkspaceMemberId(
-          handle,
-          workspaceMemberId,
-          workspaceId,
-          manager,
-        );
+    const connectedAccounts =
+      await this.connectedAccountRepository.getAllByHandleAndWorkspaceMemberId(
+        handle,
+        workspaceMemberId,
+        workspaceId,
+      );
 
-      if (!connectedAccounts || connectedAccounts?.length === 0) {
-        const newConnectedAccountId = v4();
+    const existingAccountId = connectedAccounts?.[0]?.id;
+    const newOrExistingConnectedAccountId = existingAccountId ?? v4();
 
+    await workspaceDataSource?.transaction(async (manager: EntityManager) => {
+      if (!existingAccountId) {
         await this.connectedAccountRepository.create(
           {
-            id: newConnectedAccountId,
+            id: newOrExistingConnectedAccountId,
             handle,
             provider: ConnectedAccountProvider.GOOGLE,
             accessToken: input.accessToken,
@@ -114,7 +114,7 @@ export class GoogleAPIsService {
         await this.messageChannelRepository.create(
           {
             id: v4(),
-            connectedAccountId: newConnectedAccountId,
+            connectedAccountId: newOrExistingConnectedAccountId,
             type: MessageChannelType.EMAIL,
             handle,
             visibility: MessageChannelVisibility.SHARE_EVERYTHING,
@@ -127,42 +127,36 @@ export class GoogleAPIsService {
           await this.calendarChannelRepository.create(
             {
               id: v4(),
-              connectedAccountId: newConnectedAccountId,
+              connectedAccountId: newOrExistingConnectedAccountId,
               handle,
               visibility: CalendarChannelVisibility.SHARE_EVERYTHING,
             },
             workspaceId,
             manager,
           );
         }
-
-        await this.enqueueSyncJobs(
-          newConnectedAccountId,
-          workspaceId,
-          isCalendarEnabled,
-        );
       } else {
         await this.connectedAccountRepository.updateAccessTokenAndRefreshToken(
           input.accessToken,
           input.refreshToken,
-          connectedAccounts[0].id,
+          newOrExistingConnectedAccountId,
           workspaceId,
           manager,
         );
 
         await this.messageChannelRepository.resetSync(
-          connectedAccounts[0].id,
+          newOrExistingConnectedAccountId,
           workspaceId,
           manager,
         );
-
-        await this.enqueueSyncJobs(
-          connectedAccounts[0].id,
-          workspaceId,
-          isCalendarEnabled,
-        );
       }
     });
+
+    await this.enqueueSyncJobs(
+      newOrExistingConnectedAccountId,
+      workspaceId,
+      isCalendarEnabled,
+    );
   }
 
   private async enqueueSyncJobs(