uncomment logic (#792)

helium · Jan 30, 2025 · 80799e0 · 80799e0
1 parent cdbf530
commit 80799e0
Showing 1 changed file with 22 additions and 23 deletions.
diff --git a/packages/account-postgres-sink-service/src/utils/defineIdlModels.ts b/packages/account-postgres-sink-service/src/utils/defineIdlModels.ts
@@ -98,29 +98,28 @@ export const defineIdlModels = async ({
         }
       );
 
-      // const columns = Object.keys(model.getAttributes()).map((att) =>
-      //   camelize(att, true)
-      // );
-
-      // const existingColumns = (
-      //   await sequelize.query(
-      //     `
-      //   SELECT column_name
-      //     FROM information_schema.columns
-      //   WHERE table_schema = '${underscore(accConfig.schema || "public")}'
-      //     AND table_name = '${underscore(accConfig.table || acc.name)}'
-      // `,
-      //     { type: QueryTypes.SELECT }
-      //   )
-      // ).map((x: any) => camelize(x.column_name, true));
-
-      // if (
-      //   !existingColumns.length ||
-      //   !columns.every((col) => existingColumns.includes(col))
-      // ) {
-      //   model.sync({ alter: true });
-      // }
-      model.sync({ alter: true });
+      const columns = Object.keys(model.getAttributes()).map((att) =>
+        camelize(att, true)
+      );
+
+      const existingColumns = (
+        await sequelize.query(
+          `
+        SELECT column_name
+          FROM information_schema.columns
+        WHERE table_schema = '${underscore(accConfig.schema || "public")}'
+          AND table_name = '${underscore(accConfig.table || acc.name)}'
+      `,
+          { type: QueryTypes.SELECT }
+        )
+      ).map((x: any) => camelize(x.column_name, true));
+
+      if (
+        !existingColumns.length ||
+        !columns.every((col) => existingColumns.includes(col))
+      ) {
+        model.sync({ alter: true });
+      }
     }
   }
 };