Function migrate

packages/db/code-migrations/migrate.ts:17–89

()

} from './helpers';

async function migrate() {
  const args = process.argv.slice(2);
  const migration = args.filter((arg) => !arg.startsWith('--'))[0];

  const migrationsDir = path.join(__dirname, '..', 'code-migrations');
  const migrations = fs
    .readdirSync(migrationsDir)
    .filter((file) => {
      const version = file.split('-')[0];
      return (
        !Number.isNaN(Number.parseInt(version ?? '')) && file.endsWith('.ts')
      );
    })
    .sort((a, b) => {
      const aVersion = Number.parseInt(a.split('-')[0]!);
      const bVersion = Number.parseInt(b.split('-')[0]!);
      return aVersion - bVersion;
    });

  const finishedMigrations = await db.codeMigration.findMany();

  printBoxMessage('📋 Plan', [
    '\t✅ Finished:',
    ...finishedMigrations.map(
      (migration) => `\t- ${migration.name} (${migration.createdAt})`,
    ),
    '',
    '\t🔄 Will run now:',
    ...migrations
      .filter(
        (migration) =>
          !finishedMigrations.some(
            (finishedMigration) => finishedMigration.name === migration,
          ),
      )
      .map((migration) => `\t- ${migration}`),
  ]);

  printBoxMessage('🤝 Config', [
    `isClustered:   ${getIsCluster()}`,
    `isSelfHosting: ${getIsSelfHosting()}`,
  ]);

  printBoxMessage('🌍 Environment', [
    `POSTGRES:   ${process.env.DATABASE_URL}`,
    `CLICKHOUSE: ${process.env.CLICKHOUSE_URL}`,
  ]);

  if (!getIsSelfHosting()) {
    if (!getIsDry()) {
      printBoxMessage('🕒 Migrations starts in 10 seconds', []);
      await new Promise((resolve) => setTimeout(resolve, 10000));
    } else {
      printBoxMessage('🕒 Migrations starts now (dry run)', []);
    }
  }

  if (migration) {