Function runMigrations

migrate-db.ts:66–86

(missingMigrations: string[])

}

async function runMigrations(missingMigrations: string[]): Promise<void> {
  for (const missingMigration of missingMigrations) {
    console.log(`Running "${missingMigration}"...`);

    try {
      const migrationSql = await Deno.readTextFile(`${migrationsDirectoryPath}/${missingMigration}`);

      await db.query(migrationSql);

      await db.query(sql`INSERT INTO "public"."bewcloud_migrations" ("name", "executed_at") VALUES ($1, NOW())`, [
        missingMigration,
      ]);

      console.log('Success!');
    } catch (error) {
      console.log('Failed!');
      console.error(error);
      throw error;
    }
  }
}

try {
  const missingMigrations = await getMissingMigrations();