Handle undefined cases and improve code quality

Author: ijreilly

packages/twenty-server/src/engine/metadata-modules/remote-server/remote-table/distant-table/distant-table.service.ts

@@ -26,9 +26,14 @@ export class DistantTableService {
   public async fetchDistantTables(
     remoteServer: RemoteServerEntity<RemoteServerType>,
     workspaceId: string,
+    tableName?: string,
   ): Promise<DistantTables> {
     if (remoteServer.schema) {
-      return this.getDistantTablesFromDynamicSchema(remoteServer, workspaceId);
+      return this.getDistantTablesFromDynamicSchema(
+        remoteServer,
+        workspaceId,
+        tableName,
+      );
     }
 
     return this.getDistantTablesFromStaticSchema(remoteServer);
@@ -39,20 +44,13 @@ export class DistantTableService {
     workspaceId: string,
     tableName: string,
   ): Promise<PostgresTableSchemaColumn[]> {
-    if (remoteServer.schema) {
-      const distantTables = await this.getDistantTablesFromDynamicSchema(
-        remoteServer,
-        workspaceId,
-        tableName,
-      );
-
-      return distantTables[tableName];
-    }
-
-    const distantTables =
-      await this.getDistantTablesFromStaticSchema(remoteServer);
+    const distantTables = await this.fetchDistantTables(
+      remoteServer,
+      workspaceId,
+      tableName,
+    );
 
-    return distantTables[tableName];
+    return distantTables[tableName] || [];
   }
 
   private async getDistantTablesFromDynamicSchema(

packages/twenty-server/src/engine/metadata-modules/remote-server/remote-table/remote-table-schema-update/remote-table-schema-update.service.ts

@@ -41,18 +41,18 @@ export class RemoteTableSchemaUpdateService {
         distantTables,
       });
 
-    const remoteTablesDistantNames = remoteTables.map(
-      (remoteTable) => remoteTable.distantTableName,
+    const remoteTablesDistantNames = new Set(
+      remoteTables.map((remoteTable) => remoteTable.distantTableName),
     );
 
     const distantTablesWithUpdates = Object.keys(distantTables).map(
       (tableName) => ({
         name: tableName,
         schema: remoteServerSchema,
-        status: remoteTablesDistantNames.includes(tableName)
+        status: remoteTablesDistantNames.has(tableName)
           ? RemoteTableStatus.SYNCED
           : RemoteTableStatus.NOT_SYNCED,
-        schemaPendingUpdates: schemaPendingUpdates[tableName],
+        schemaPendingUpdates: schemaPendingUpdates[tableName] || [],
       }),
     );
 
@@ -67,7 +67,7 @@ export class RemoteTableSchemaUpdateService {
         schemaPendingUpdates: updates,
       }));
 
-    return distantTablesWithUpdates.concat(deletedTables);
+    return [...distantTablesWithUpdates, ...deletedTables];
   }
 
   public computeForeignTableColumnsUpdates = (
@@ -146,8 +146,8 @@ export class RemoteTableSchemaUpdateService {
     foreignTableColumns: PostgresTableSchemaColumn[],
     distantTableColumns: PostgresTableSchemaColumn[],
   ) => {
-    const foreignTableColumnNames = foreignTableColumns.map(
-      (column) => column.columnName,
+    const foreignTableColumnNames = new Set(
+      foreignTableColumns.map((column) => column.columnName),
     );
     const distantTableColumnsWithConvertedName = distantTableColumns.map(
       (column) => {
@@ -159,9 +159,9 @@ export class RemoteTableSchemaUpdateService {
     );
 
     const columnsAdded = distantTableColumnsWithConvertedName.filter(
-      (column) => !foreignTableColumnNames.includes(column.name),
+      (column) => !foreignTableColumnNames.has(column.name),
     );
-    const columnsDeleted = foreignTableColumnNames.filter(
+    const columnsDeleted = Array.from(foreignTableColumnNames).filter(
       (columnName) =>
         !distantTableColumnsWithConvertedName
           .map((column) => column.name)

packages/twenty-server/src/engine/metadata-modules/remote-server/remote-table/remote-table.service.ts

@@ -300,7 +300,7 @@ export class RemoteTableService {
         remoteTable.distantTableName,
       );
 
-    if (!distantTableColumns) {
+    if (isEmpty(distantTableColumns)) {
       await this.unsyncOne(workspaceId, remoteTable, remoteServer);
 
       return {};