app/db/pages.ts

Functions

Imports

It imports app/db/client.ts, app/db/schema.ts, app/lib/pages/compile.mjs, app/lib/search/visibility.mjs. Imported by app/lib/carrel/page-handler.server.ts, app/lib/llms/save.server.ts, app/lib/operator/api.server.ts, app/lib/pages/save.server.ts, app/lib/site-urls.server.ts, app/routes/about.tsx, app/routes/content-page.tsx, app/routes/content-page[.md].ts, app/routes/phages.tsx, app/routes/protocols.tsx, app/routes/protocols[.md].ts.

Source

1// The pages table: read by the content-page route, its twin, the sitemap and the operator API. Written only
2// by writeRow in app/lib/pages/save.server.ts and by sync:content, from a compile
3// (app/lib/pages/compile.mjs).
4import { and, asc, eq, inArray } from "drizzle-orm";
5
6import { PUBLISHED_STATUS } from "~/lib/search/visibility.mjs";
7import type { PageRecord } from "~/lib/pages/compile.mjs";
8
9import { getDb } from "./client";
10import { pages } from "./schema";
11
12export type PageRow = {
13  slug: string;
14  path: string;
15  status: "draft" | "published";
16  record: PageRecord;
17};
18
19/** The page's row, or null. A draft comes back too: the route decides who may see it. */
20export async function getPageByPath(env: Env, path: string): Promise<PageRow | null> {
21  const row = (
22    await getDb(env)
23      .select({ slug: pages.slug, path: pages.path, status: pages.status, record: pages.record })
24      .from(pages)
25      .where(eq(pages.path, path))
26      .limit(1)
27  )[0];
28  if (!row) return null;
29  return { ...row, record: JSON.parse(row.record) as PageRecord };
30}
31
32/** The twin, published rows only: a draft's twin answers 404 like its page. */
33export async function getPublishedPageMarkdown(env: Env, path: string) {
34  const row = (
35    await getDb(env)
36      .select({ markdown: pages.markdown })
37      .from(pages)
38      .where(and(eq(pages.path, path), eq(pages.status, PUBLISHED_STATUS)))
39      .limit(1)
40  )[0];
41  return row?.markdown ?? null;
42}
43
44/** The titles of other pages, for the trail above a page that sits under one. Published rows only. */
45export async function getPublishedPageTitles(env: Env, paths: string[]) {
46  if (paths.length === 0) return new Map<string, string>();
47  const rows = await getDb(env)
48    .select({ path: pages.path, title: pages.title })
49    .from(pages)
50    .where(and(inArray(pages.path, paths), eq(pages.status, PUBLISHED_STATUS)));
51  return new Map(rows.map((row) => [row.path, row.title]));
52}
53
54/**
55 * Every published page's title, by path: the sitemap's list (app/lib/site-urls.server.ts) and the llms.txt save.
56 * No IN list: D1 binds at most 100 parameters, and the page registry is not bounded by that.
57 */
58export async function listPublishedPageTitles(env: Env) {
59  const rows = await getDb(env)
60    .select({ path: pages.path, title: pages.title })
61    .from(pages)
62    .where(eq(pages.status, PUBLISHED_STATUS));
63  return new Map(rows.map((row) => [row.path, row.title]));
64}
65
66/** For the sitemap's dates (app/lib/site-urls.server.ts): every published page's source file, by path. */
67export async function listPublishedPageSources(env: Env) {
68  const rows = await getDb(env)
69    .select({ path: pages.path, sourcePath: pages.sourcePath })
70    .from(pages)
71    .where(eq(pages.status, PUBLISHED_STATUS));
72  return new Map(rows.map((row) => [row.path, row.sourcePath]));
73}
74
75/** For the save-time link check: every published page's rendered HTML, by path. */
76export async function listPublishedPageHtml(env: Env) {
77  const rows = await getDb(env)
78    .select({ path: pages.path, record: pages.record })
79    .from(pages)
80    .where(eq(pages.status, PUBLISHED_STATUS));
81  return new Map(rows.map((row) => [row.path, (JSON.parse(row.record) as PageRecord).html]));
82}
83
84/** For list_pages and Carrel's list: every row, drafts included, with when D1 last wrote it. */
85export async function listPageRows(env: Env) {
86  const rows = await getDb(env)
87    .select({ slug: pages.slug, path: pages.path, title: pages.title, status: pages.status, syncedAt: pages.syncedAt })
88    .from(pages)
89    .orderBy(asc(pages.path));
90  return rows.map(({ status, ...row }) => ({ ...row, draft: status === "draft" }));
91}