app/lib/waiting.server.ts

Functions

Imports

It imports app/db/schema.ts, app/lib/content.server.ts, app/lib/index.server.ts, app/lib/people.server.ts, app/lib/roles.ts. Imported by app/routes/project.tsx.

Source

1// Work that waits on a person and is not in Carrel's index of the site: an AI draft or a draft of
2// their own for a post the site does not have yet. Without this the project's list shows only what
3// the site reports, and such a draft is reachable only by typing its URL. The list also marks an
4// indexed post that has AI drafts waiting beside the person's own.
5
6import { and, eq } from "drizzle-orm";
7import { drizzle } from "drizzle-orm/d1";
8
9import { aiDrafts, drafts } from "~/db/schema";
10import type { Filters, IndexedItem } from "~/lib/index.server";
11import type { Viewer } from "~/lib/people.server";
12import type { ProjectRole } from "~/lib/content.server";
13import { can } from "~/lib/roles";
14
15export type Waiting = {
16  itemId: string;
17  aiDrafts: number;
18  ownDraft: boolean;
19  title: string;
20  /** The title, id and text, lower-cased, for the list's search. Never sent to the browser. */
21  text: string;
22  at: string;
23};
24
25export type ListedItem = IndexedItem & { aiDrafts: number; isNew: boolean; ownDraft: boolean };
26
27/** The title from a source's frontmatter, or "" when it has none. */
28export function titleOf(source: string): string {
29  const front = /^---\r?\n([\s\S]*?)\r?\n---/.exec(source);
30  const line = front?.[1]?.match(/^title:\s*(.+)$/m)?.[1]?.trim() ?? "";
31  return line.replace(/^(["'])(.*)\1$/, "$2");
32}
33
34/** Every item the person has an AI draft or a draft of their own for, with what is waiting. */
35export async function waitingWork(db: D1Database, project: ProjectRole, viewer: Viewer): Promise<Waiting[]> {
36  if (!can(project.role, "read")) throw new Response("Forbidden", { status: 403 });
37  const d = drizzle(db);
38  const [ai, own] = await Promise.all([
39    d
40      .select({ itemId: aiDrafts.itemId, source: aiDrafts.source, at: aiDrafts.createdAt })
41      .from(aiDrafts)
42      .where(and(eq(aiDrafts.projectId, project.id), eq(aiDrafts.personId, viewer.id)))
43      .all(),
44    d
45      .select({ itemId: drafts.itemId, source: drafts.source, at: drafts.updatedAt })
46      .from(drafts)
47      .where(and(eq(drafts.projectId, project.id), eq(drafts.personId, viewer.id)))
48      .all(),
49  ]);
50  const byItem = new Map<string, Waiting>();
51  const entry = (itemId: string) => {
52    let w = byItem.get(itemId);
53    if (!w) byItem.set(itemId, (w = { itemId, aiDrafts: 0, ownDraft: false, title: "", text: itemId.toLowerCase(), at: "" }));
54    return w;
55  };
56  for (const row of own) {
57    const w = entry(row.itemId);
58    w.ownDraft = true;
59    w.title = titleOf(row.source) || w.title;
60    w.text += `\n${row.source.toLowerCase()}`;
61    if (row.at > w.at) w.at = row.at;
62  }
63  for (const row of ai) {
64    const w = entry(row.itemId);
65    w.aiDrafts += 1;
66    w.title ||= titleOf(row.source);
67    w.text += `\n${row.source.toLowerCase()}`;
68    if (row.at > w.at) w.at = row.at;
69  }
70  return [...byItem.values()];
71}
72
73/**
74 * The index's items with the waiting work laid over them: an indexed item gets its count of AI
75 * drafts, and an item the index does not have is listed as a new draft. A new item has no kind the
76 * site knows, so a kind filter leaves it out; the status filter and the search apply to it as to
77 * the rest.
78 */
79export function withWaitingWork(items: IndexedItem[], waiting: Waiting[], filters: Filters): ListedItem[] {
80  const byId = new Map(waiting.map((w) => [w.itemId, w]));
81  const listed: ListedItem[] = items.map((item) => ({
82    ...item,
83    aiDrafts: byId.get(item.itemId)?.aiDrafts ?? 0,
84    isNew: false,
85    ownDraft: byId.get(item.itemId)?.ownDraft ?? false,
86  }));
87  if (filters.kind || (filters.status && filters.status !== "draft")) return listed;
88  const words = filters.q?.toLowerCase().match(/[\p{L}\p{N}]+/gu) ?? [];
89  if (filters.q && words.length === 0) return listed;
90  const indexed = new Set(items.map((i) => i.itemId));
91  const fresh: ListedItem[] = waiting
92    .filter((w) => !indexed.has(w.itemId) && words.every((word) => w.text.includes(word)))
93    .map((w) => ({
94      itemId: w.itemId,
95      kind: "",
96      title: w.title || w.itemId,
97      status: "draft" as const,
98      path: null,
99      publishAt: null,
100      publishedAt: null,
101      updatedAt: w.at,
102      aiDrafts: w.aiDrafts,
103      isNew: true,
104      ownDraft: w.ownDraft,
105    }));
106  return [...fresh, ...listed];
107}