app/db/phages.ts

Functions

Imports

It imports app/db/client.ts, app/db/schema.ts, app/lib/phages/compile.mjs. Imported by app/kb/procedures/proof.server.ts, app/lib/carrel/phage-handler.server.ts, app/lib/operator/api.server.ts, app/lib/operator/sync-tools.server.ts, app/lib/pages/save.server.ts, app/lib/phages/save.server.ts, app/routes/lab.kind.tsx, app/routes/lab.tsx, app/routes/lab[.md].ts, app/routes/phages.tsx.

Source

1// The phages table: read by the page compile that draws the table on /research/phages (a page save and
2// sync_pages read it here) and by the operator API. Written only by writePhageRow in
3// app/lib/phages/save.server.ts and by sync:content, from a compile (app/lib/phages/compile.mjs).
4import { asc } from "drizzle-orm";
5
6import { sortPhages, type Phage } from "~/lib/phages/compile.mjs";
7
8import { getDb } from "./client";
9import { phages } from "./schema";
10
11/**
12 * Every phage, in the page's order. An empty table is a fault, never an empty table on the page: the page is
13 * compiled from these rows, and a table the sync has not written yet must not quietly compile a page with no
14 * phages on it (expandPhagePage refuses an empty set and names the sync).
15 */
16export async function listPhages(env: Env): Promise<Phage[]> {
17  const rows = await getDb(env).select({ record: phages.record }).from(phages);
18  return sortPhages(rows.map((row) => JSON.parse(row.record) as Phage));
19}
20
21/** For list_phages and Carrel's list: every row, with when D1 last wrote it. */
22export async function listPhageRows(env: Env) {
23  const rows = await getDb(env)
24    .select({ slug: phages.slug, name: phages.name, year: phages.year, record: phages.record, syncedAt: phages.syncedAt })
25    .from(phages)
26    .orderBy(asc(phages.year), asc(phages.name));
27  return rows.map(({ record, ...row }) => ({ ...row, phage: JSON.parse(record) as Phage }));
28}