app/db/publications.ts

Functions

Imports

It imports app/db/client.ts, app/db/schema.ts, app/lib/publications/record.mjs, app/lib/publications/types.ts, app/lib/search/visibility.mjs. Imported by app/db/cv.ts, app/kb/procedures/proof.server.ts, app/lib/carrel/publication-handler.server.ts, app/lib/cv/save.server.ts, app/lib/llms/save.server.ts, app/lib/operator/api.server.ts, app/lib/publications/by-slug.ts, app/lib/publications/save.server.ts, app/lib/publications/sources.server.ts, app/lib/search/ask.server.ts, app/lib/site-urls.server.ts, app/routes/home.tsx, app/routes/publications.$slug[.md].ts, app/routes/publications.tsx, app/routes/publications[.bib].ts, app/routes/publications[.json].ts, app/routes/publications[.ris].ts.

Source

1// The publications and publication_citations tables: read by the paper pages, the exports, the sitemap,
2// the home page and the operator API. Written only by app/lib/publications/write.server.ts, from a compile
3// (app/lib/publications/compile.mjs).
4import { and, asc, eq } from "drizzle-orm";
5
6import type { Publication } from "~/lib/publications/types";
7import { sortPublications } from "~/lib/publications/record.mjs";
8import { PUBLISHED_STATUS } from "~/lib/search/visibility.mjs";
9
10import { getDb } from "./client";
11import { publications } from "./schema";
12
13/** Every published paper, newest first: the order the index, the exports and the CSL file all follow. */
14export async function listPublishedPublications(env: Env): Promise<Publication[]> {
15  const rows = await getDb(env)
16    .select({ record: publications.record })
17    .from(publications)
18    .where(eq(publications.status, PUBLISHED_STATUS));
19  return sortPublications(rows.map((row) => JSON.parse(row.record) as Publication));
20}
21
22/** For the sitemap's dates (app/lib/site-urls.server.ts): every published paper's source file, by slug. */
23export async function listPublishedPublicationSources(env: Env) {
24  const rows = await getDb(env)
25    .select({ slug: publications.slug, sourcePath: publications.sourcePath })
26    .from(publications)
27    .where(eq(publications.status, PUBLISHED_STATUS));
28  return new Map(rows.map((row) => [row.slug, row.sourcePath]));
29}
30
31/** The paper a `/research/publications/<slug>` URL names, or null. A draft is not public: it answers as absent. */
32export async function getPublishedPublication(env: Env, slug: string): Promise<Publication | null> {
33  const row = (
34    await getDb(env)
35      .select({ record: publications.record })
36      .from(publications)
37      .where(and(eq(publications.slug, slug), eq(publications.status, PUBLISHED_STATUS)))
38      .limit(1)
39  )[0];
40  return row ? (JSON.parse(row.record) as Publication) : null;
41}
42
43/** The twin, published rows only: a draft's twin answers 404 like its page. */
44export async function getPublishedPublicationMarkdown(env: Env, slug: string): Promise<string | null> {
45  const row = (
46    await getDb(env)
47      .select({ markdown: publications.markdown })
48      .from(publications)
49      .where(and(eq(publications.slug, slug), eq(publications.status, PUBLISHED_STATUS)))
50      .limit(1)
51  )[0];
52  return row?.markdown ?? null;
53}
54
55/** Each published twin by slug, for the Ask index to upload. */
56export async function listPublishedPublicationTwins(env: Env): Promise<Array<{ slug: string; markdown: string }>> {
57  return getDb(env)
58    .select({ slug: publications.slug, markdown: publications.markdown })
59    .from(publications)
60    .where(eq(publications.status, PUBLISHED_STATUS))
61    .orderBy(asc(publications.slug));
62}
63
64/** The raw Crossref records of the published papers that carry one, in the index's order, for the .json export. */
65export async function listPublishedCslRecords(env: Env): Promise<unknown[]> {
66  const rows = await getDb(env)
67    .select({ title: publications.title, year: publications.year, csl: publications.csl })
68    .from(publications)
69    .where(eq(publications.status, PUBLISHED_STATUS));
70  return sortPublications(rows)
71    .filter((row) => row.csl !== null)
72    .map((row) => JSON.parse(row.csl as string) as unknown);
73}
74
75/** Every row's identity, any status, for the save's uniqueness checks and the operator's list. */
76export async function listPublicationIdentities(env: Env) {
77  return getDb(env)
78    .select({
79      slug: publications.slug,
80      doiKey: publications.doiKey,
81      status: publications.status,
82      stage: publications.stage,
83      type: publications.type,
84      title: publications.title,
85      year: publications.year,
86      record: publications.record,
87      sourceBlobSha: publications.sourceBlobSha,
88      syncedAt: publications.syncedAt,
89    })
90    .from(publications)
91    .orderBy(asc(publications.slug));
92}
93
94/** The stored row for a slug, any status, or null. */
95export async function getPublicationRow(env: Env, slug: string) {
96  return (
97    (
98      await getDb(env)
99        .select({
100          slug: publications.slug,
101          status: publications.status,
102          sourceBlobSha: publications.sourceBlobSha,
103          syncedAt: publications.syncedAt,
104          record: publications.record,
105        })
106        .from(publications)
107        .where(eq(publications.slug, slug))
108        .limit(1)
109    )[0] ?? null
110  );
111}