app/lib/inbox-report.server.ts

Functions

Imports

It imports app/db/schema.ts, app/lib/mcp/server.ts, app/lib/timed-fetch.server.ts. Imported by workers/app.ts.

Source

1// What Carrel reports about itself to Capsid's inbox (POST /ops/inbox/report), for the app badge in
2// the shared AdminShell: the AI drafts waiting for Dustin's review. Each report replaces the last
3// whole and Capsid expires it after 6 hours, so the cron sends it every run (15 minutes), and sends
4// no items when nothing waits so a cleared queue clears the badge. The bearer is Carrel's own Capsid
5// agent key, the secret CAPSID_AGENT_KEY. Never on a page's path: a failure is logged, not thrown.
6
7import { count, min } from "drizzle-orm";
8import { drizzle } from "drizzle-orm/d1";
9
10import { aiDrafts } from "~/db/schema";
11import { carrelOrigin } from "~/lib/mcp/server";
12import { timedFetch } from "~/lib/timed-fetch.server";
13
14/** Capsid's origin, from the var CAPSID_ORIGIN; read loosely, as carrelOrigin does, for an older wrangler.jsonc without it. */
15function capsidOrigin(env: Env): string {
16  const configured = (env as { CAPSID_ORIGIN?: string }).CAPSID_ORIGIN?.trim();
17  return (configured || "https://mcp.dustinedwards.info").replace(/\/+$/, "");
18}
19
20type InboxItem = { title: string; link?: string; since?: string };
21type InboxReport = { namespace: "carrel"; items: InboxItem[] };
22
23/** The report body for `waiting` AI drafts, the oldest made at `since`. None waiting: no items. */
24function inboxReport(waiting: number, since: string | null, origin: string): InboxReport {
25  if (waiting <= 0) return { namespace: "carrel", items: [] };
26  const item: InboxItem = {
27    title: waiting === 1 ? "1 AI draft waits for review" : `${waiting} AI drafts wait for review`,
28    link: `${origin}/`,
29  };
30  if (since) item.since = since;
31  return { namespace: "carrel", items: [item] };
32}
33
34export type ReportResult = { state: "skipped" | "sent" | "failed"; detail: string };
35
36/** Counts the waiting AI drafts and reports them. Never throws; a failure is logged and returned. */
37export async function reportInbox(env: Env, fetcher: typeof fetch = timedFetch): Promise<ReportResult> {
38  const key = env.CAPSID_AGENT_KEY?.trim();
39  if (!key) return { state: "skipped", detail: "CAPSID_AGENT_KEY is not set." };
40  try {
41    const row = await drizzle(env.DB)
42      .select({ waiting: count(), since: min(aiDrafts.createdAt) })
43      .from(aiDrafts)
44      .get();
45    const body = inboxReport(row?.waiting ?? 0, row?.since ?? null, carrelOrigin(env));
46    const response = await fetcher(`${capsidOrigin(env)}/ops/inbox/report`, {
47      method: "POST",
48      headers: { authorization: `Bearer ${key}`, "content-type": "application/json" },
49      body: JSON.stringify(body),
50    });
51    if (!response.ok) throw new Error(`Capsid answered ${response.status}`);
52    return { state: "sent", detail: `${body.items.length} item(s) reported.` };
53  } catch (error) {
54    const detail = error instanceof Error ? error.message : String(error);
55    console.error(JSON.stringify({ inbox: "report-failed", error: detail }));
56    return { state: "failed", detail };
57  }
58}