app/lib/editor/divergence.server.ts

Functions

Imports

It imports app/lib/error-message.mjs. Imported by app/lib/editor/publish.server.ts, app/lib/operator/sync-tools.server.ts.

Source

1import { errorMessage } from "~/lib/error-message.mjs";
2
3// KV, not D1, because the record says D1 failed. One key per slug, because one shared
4// array is a read-modify-write that loses a record when two saves fail at once.
5
6const PREFIX = "publish:divergence:";
7
8export interface Divergence {
9  slug: string;
10  commitSha: string;
11  error: string;
12  at: string;
13}
14
15/** No TTL: an expiring record would turn the status green while the index is still stale. */
16export async function recordDivergence(
17  env: Env,
18  facts: { slug: string; commitSha: string; error: string },
19): Promise<void> {
20  const entry: Divergence = { ...facts, at: new Date().toISOString() };
21  await env.APP_KV.put(`${PREFIX}${facts.slug}`, JSON.stringify(entry));
22}
23
24export async function clearDivergence(env: Env, slug: string): Promise<void> {
25  await env.APP_KV.delete(`${PREFIX}${slug}`);
26}
27
28/** KV list is eventually consistent: an empty result means none visible, not none exist. */
29export async function listDivergences(
30  env: Env,
31): Promise<{ known: true; entries: Divergence[] } | { known: false; reason: string }> {
32  try {
33    const listed = await env.APP_KV.list({ prefix: PREFIX });
34    const entries: Divergence[] = [];
35    for (const key of listed.keys) {
36      const raw = await env.APP_KV.get(key.name);
37      if (!raw) continue;
38      try {
39        entries.push(JSON.parse(raw) as Divergence);
40      } catch {
41        // Reported, not dropped: an unparseable key is still evidence of a divergence.
42        entries.push({
43          slug: key.name.slice(PREFIX.length),
44          commitSha: "(unparseable record)",
45          error: "the stored divergence record could not be parsed",
46          at: "",
47        });
48      }
49    }
50    return { known: true, entries };
51  } catch (error) {
52    return {
53      known: false,
54      reason: errorMessage(error),
55    };
56  }
57}