feat: allow running synchronize manually!

yujiosaka · Oct 29, 2023 · ba05e45 · ba05e45
1 parent 5de4fad
commit ba05e45
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -49,20 +49,26 @@ const app = new Elysia()
         break;
       case Source.MySQL:
         if (!url && !options) throw new CronyxServerError("Either URL or options is required for MySQL");
-        jobStore = await MysqlJobStore.connect((options || { url, type: "mysql" }) as MysqlConnectionOptions);
+        jobStore = await MysqlJobStore.connect(
+          (options || { url, type: "mysql", synchronize: true }) as MysqlConnectionOptions,
+        );
         break;
       case Source.AuroraMySQL:
         if (!url && !options) throw new CronyxServerError("Either URL or options is required for Aurora MySQL");
-        jobStore = await MysqlJobStore.connect((options || { url, type: "aurora-mysql" }) as AuroraMysqlConnectionOptions);
+        jobStore = await MysqlJobStore.connect(
+          (options || { url, type: "aurora-mysql", synchronize: true }) as AuroraMysqlConnectionOptions,
+        );
         break;
       case Source.Postgres:
         if (!url && !options) throw new CronyxServerError("Either URL or options is required for Postgres");
-        jobStore = await PostgresJobStore.connect((options || { url, type: "postgres" }) as PostgresConnectionOptions);
+        jobStore = await PostgresJobStore.connect(
+          (options || { url, type: "postgres", synchronize: true }) as PostgresConnectionOptions,
+        );
         break;
       case Source.AuroraPostgres:
         if (!url && !options) throw new CronyxServerError("Either URL or options is required for Aurora Postgres");
         jobStore = await PostgresJobStore.connect(
-          (options || { url, type: "aurora-postgres" }) as AuroraPostgresConnectionOptions,
+          (options || { url, type: "aurora-postgres", synchronize: true }) as AuroraPostgresConnectionOptions,
         );
         break;
     }