Function dbCheckScoping

packages/core/src/scripts/db/check-scoping.ts:119–208

(args: string[])

}

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

  if (parsed.help === "true") {
    console.log(`Usage: pnpm action db-check-scoping [options]

Options:
  --db <path>       Path to SQLite database (default: data/app.db)
  --require-org     Also check for org_id column (for multi-org apps)
  --format json     Output as JSON
  --help            Show this help message`);
    return;
  }

  const requireOrg = parsed["require-org"] === "true";
  const format = parsed.format;

  // Resolve database URL
  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");
  }

  let allColumns: TableColumn[];

  if (isPostgresUrl(url)) {
    const { default: pg } = await import("postgres");
    const pgSql = pg(url);
    try {
      allColumns = await discoverColumnsPostgres(pgSql);
    } finally {
      await pgSql.end();
    }
  } else {
    const client = createClient({
      url,
      authToken: getDatabaseAuthToken(),
    });
    try {
      allColumns = await discoverColumnsSqlite(client);
    } finally {
      client.close();
    }
  }

  const results = validate(allColumns, requireOrg);

  if (format === "json") {
    console.log(JSON.stringify({ tables: results }, null, 2));
    return;
  }

  const withIssues = results.filter((r) => r.issues.length > 0);
  const ok = results.filter((r) => r.issues.length === 0);