Function main

packages/core/fumadb/src/cli/index.ts:71–185

()

  return {
    async main() {
      const program = new Command();
      program
        .name(options.command)
        .description(
          options.description ??
            "FumaDB CLI for migrations and schema generation"
        )
        .version(options.version);

      program
        .command("migrate:up")
        .description("Migrate to the next schema version")
        .action(async () => {
          const migrator = db.createMigrator();
          const next = await migrator.next();
          if (!next) {
            console.log("Already up to date.");
            process.exit(1);
          }

          const result = await migrator.migrateTo(next.version);
          await result.execute();
          console.log(`Migration to ${next.version} executed.`);
        });

      program
        .command("migrate:down")
        .description("Rollback to the previous schema version")
        .action(async () => {
          const migrator = db.createMigrator();
          const prev = await migrator.previous();
          if (!prev) {
            console.log("Cannot downgrade.");
            process.exit(1);
          }

          const result = await migrator.migrateTo(prev.version);
          await result.execute();
          console.log(`Migration to ${prev.version} executed.`);
        });

      program
        .command("migrate:to [version]")
        .alias("migrate")
        .description(
          "Migrate to a specific schema version (interactive if not provided)"
        )
        .action(async (version: string | undefined) => {
          const migrator = db.createMigrator();
          version ??= await selectVersion(await migrator.getVersion());
          const result =
            version === "latest"
              ? await migrator.migrateToLatest()
              : await migrator.migrateTo(version);

          await result.execute();
          console.log(`Migrated to version ${version}.`);