Function dbSchema

packages/core/src/scripts/db/schema.ts:225–363

(args: string[])

// ---------------------------------------------------------------------------

export default async function dbSchema(args: string[]): Promise<void> {
  const parsed = parseArgs(args);

  if (parsed.help === "true") {
    console.log(`Usage: pnpm action db-schema [--db <path>] [--format json]

Options:
  --db <path>     Path to SQLite database (default: data/app.db)
  --format json   Output as JSON instead of human-readable text
  --help          Show this help message`);
    return;
  }

  // Resolve database URL: --db flag → DATABASE_URL env → default file path
  let url: string;
  if (parsed.db) {
    url = "file:" + path.resolve(parsed.db);
  } else if (getDatabaseUrl()) {
    url = getDatabaseUrl();
  } else {
    url = "file:" + path.resolve(process.cwd(), "data", "app.db");
  }

  // Postgres path
  if (isPostgresUrl(url)) {
    return introspectPostgres(url, parsed);
  }

  // SQLite / libsql path
  const client = createClient({
    url,
    authToken: getDatabaseAuthToken(),
  });

  try {
    const tablesResult = await client.execute(
      `SELECT name FROM sqlite_master WHERE type='table' AND name NOT LIKE 'sqlite_%' ORDER BY name`,
    );
    const tables = tablesResult.rows.map((row) => ({
      name: row[0] as string,
    }));

    const tableInfos: TableInfo[] = [];

    for (const t of tables) {
      const escaped = t.name.replace(/"/g, '""');

      const columns = await pragma(client, `PRAGMA table_info("${escaped}")`);
      const fks = await pragma(client, `PRAGMA foreign_key_list("${escaped}")`);
      const idxList = await pragma(client, `PRAGMA index_list("${escaped}")`);

      const indexes: { name: string; unique: boolean; columns: string[] }[] =
        [];
      for (const idx of idxList) {
        const idxName = idx.name as string;
        if (idxName.startsWith("sqlite_")) continue;
        const idxInfo = await pragma(
          client,