app/db/registry.ts

Functions

Imports

It imports app/db/client.ts, app/db/schema.ts, app/kb/registry/compile.mjs. Imported by app/kb/form.server.ts, app/kb/registry/save.server.ts, app/lab/inventory.server.ts, app/lib/carrel/registry-handler.server.ts, app/lib/operator/api.server.ts, app/lib/site-urls.server.ts, app/routes/admin.kb.tsx, app/routes/lab.kind.tsx, app/routes/lab.tsx, app/routes/lab[.md].ts, app/routes/protocols.tsx.

Source

1// The registry table: read by the registry's pages and the operator API. Written only by writeRegistryRow in
2// app/kb/registry/save.server.ts and by sync:content, from a compile (app/kb/registry/compile.mjs).
3import { and, asc, eq } from "drizzle-orm";
4
5import { itemFromRow, sortRegistry, type RegistryItem } from "~/kb/registry/compile.mjs";
6
7import { getDb } from "./client";
8import { registry } from "./schema";
9
10/**
11 * Every item, or one kind's, in the site's order. Drafts are the signed-in admin's alone, so a public read passes
12 * `published: true`. An empty table is a valid answer: the registry has no records until a kind brings its own.
13 */
14export async function listRegistry(env: Env, options: { kind?: string; published?: boolean } = {}): Promise<RegistryItem[]> {
15  const where = [
16    ...(options.kind ? [eq(registry.kind, options.kind)] : []),
17    ...(options.published ? [eq(registry.status, "published")] : []),
18  ];
19  const rows = await getDb(env)
20    .select({ kind: registry.kind, id: registry.id, name: registry.name, status: registry.status, record: registry.record })
21    .from(registry)
22    .where(where.length > 0 ? and(...where) : undefined);
23  return sortRegistry(rows.map(itemFromRow));
24}
25
26/** For the sitemap's dates (app/lib/site-urls.server.ts): every published item's source file, by `kind/id`. */
27export async function listPublishedRegistrySources(env: Env) {
28  const rows = await getDb(env)
29    .select({ kind: registry.kind, id: registry.id, sourcePath: registry.sourcePath })
30    .from(registry)
31    .where(eq(registry.status, "published"));
32  return new Map(rows.map((row) => [`${row.kind}/${row.id}`, row.sourcePath]));
33}
34
35/** One item by its address, or null. */
36export async function getRegistryItem(env: Env, kind: string, id: string): Promise<RegistryItem | null> {
37  const row = await getDb(env)
38    .select({ kind: registry.kind, id: registry.id, name: registry.name, status: registry.status, record: registry.record })
39    .from(registry)
40    .where(and(eq(registry.kind, kind), eq(registry.id, id)))
41    .get();
42  return row ? itemFromRow(row) : null;
43}
44
45/** For list_registry and Carrel's list: every row, with when D1 last wrote it. */
46export async function listRegistryRows(env: Env) {
47  const rows = await getDb(env)
48    .select({
49      kind: registry.kind,
50      id: registry.id,
51      name: registry.name,
52      status: registry.status,
53      record: registry.record,
54      syncedAt: registry.syncedAt,
55    })
56    .from(registry)
57    .orderBy(asc(registry.kind), asc(registry.name));
58  return rows.map(({ syncedAt, ...row }) => ({ ...itemFromRow(row), syncedAt }));
59}