Function schemaGenerateAction

packages/core/cli/src/commands/schema.ts:20–66

(opts: SchemaGenerateOptions)

};

const schemaGenerateAction = async (opts: SchemaGenerateOptions) => {
  const cwd = path.resolve(opts.cwd);
  if (!existsSync(cwd)) {
    console.error(`The directory "${cwd}" does not exist.`);
    process.exit(1);
  }

  if (opts.adapter !== "drizzle") {
    console.error(`Unsupported schema adapter "${opts.adapter}". Supported adapters: drizzle.`);
    process.exit(1);
  }
  if (opts.provider !== "mysql" && opts.provider !== "postgresql" && opts.provider !== "sqlite") {
    console.error(
      `Unsupported drizzle provider "${opts.provider}". Supported providers: mysql, postgresql, sqlite.`,
    );
    process.exit(1);
  }

  const [{ fumadb }, { drizzleAdapter }, { schema: fumaSchema }] = await Promise.all([
    import("@executor-js/fumadb"),
    import("@executor-js/fumadb/adapters/drizzle"),
    import("@executor-js/fumadb/schema"),
  ]);

  const schema = fumaSchema({
    version: opts.version,
    tables: collectTables(),
  });
  const factory = fumadb({
    namespace: opts.namespace,
    schemas: [schema],
  });
  const generated = factory
    .client(
      drizzleAdapter({
        db: {},
        provider: opts.provider,
      }),
    )
    .generateSchema("latest", opts.namespace);

  const output = opts.output ?? generated.path;
  const outPath = path.resolve(cwd, output);
  await fs.mkdir(path.dirname(outPath), { recursive: true });
  await fs.writeFile(outPath, generated.code);
  console.log(`Schema generated: ${path.relative(cwd, outPath)}`);
};

export const schema = new Command("schema")
  .description("Database schema utilities")