Function runCodeMigrations

apps/cloud/scripts/code-migrations/runner.ts:84–118

(
  sql: CodeMigrationSql,
  migrations: readonly CodeMigration[],
  options: RunCodeMigrationsOptions = {},
)

};

export const runCodeMigrations = async (
  sql: CodeMigrationSql,
  migrations: readonly CodeMigration[],
  options: RunCodeMigrationsOptions = {},
): Promise<readonly string[]> => {
  const dryRun = options.dryRun ?? false;
  const log = options.log ?? console.log;
  assertUniqueNames(migrations);

  return withMigrationLock(sql, dryRun, async () => {
    const completed = await readCompletedMigrations(sql, dryRun);
    const applied: string[] = [];

    for (const migration of migrations) {
      if (completed.has(migration.name)) {
        log(`[code-migrate] skip ${migration.name}`);
        continue;
      }

      log(`[code-migrate] ${dryRun ? "plan" : "run"} ${migration.name}`);
      const result = await migration.run({ sql, dryRun, log });
      log(`[code-migrate] ${result.summary}`);

      if (!dryRun) {
        await sql.unsafe(
          `INSERT INTO "${LEDGER_TABLE}" ("name", "time_completed") VALUES ($1, $2)`,
          [migration.name, Date.now()],
        );
      }
      applied.push(migration.name);
    }

    return applied;
  });
};