src/watcher-digest.ts

Functions

Imports

It imports src/ops-types/feed.ts, src/watcher-checks.ts. Imported by src/digest.ts, src/ops-feed.ts.

Source

1import { findingClass, type FindingClass } from "./watcher-checks";
2import type { OpsFinding } from "./ops-types/feed";
3
4// The findings that post no job (digest and attention class, src/watcher-checks.ts), read from the
5// watcher's memory: the open rows with no job. The Portal's weekly digest panel and
6// attention list read them through the ops feed, and the Monday email through
7// weeklyDigestSection, so the three cannot disagree.
8
9const HEADLINE = /^Watcher: (.*?)\s*\[[^\]]+\]$/;
10const LINES_SHOWN = 3;
11
12interface Row {
13  fingerprint: string;
14  namespace: string;
15  title: string;
16  first_seen_at: string;
17  last_seen_at: string;
18  seen_count: number;
19  evidence: string;
20}
21
22function lastEvidence(raw: string): string[] {
23  try {
24    const list: unknown = JSON.parse(raw);
25    const last = Array.isArray(list) ? (list[list.length - 1] as { lines?: unknown } | undefined) : undefined;
26    return Array.isArray(last?.lines) ? (last.lines as unknown[]).filter((l): l is string => typeof l === "string").slice(0, LINES_SHOWN) : [];
27  } catch {
28    return [];
29  }
30}
31
32export async function openQuietFindings(db: D1Database): Promise<OpsFinding[]> {
33  const { results } = await db
34    .prepare(
35      `SELECT fingerprint, namespace, title, first_seen_at, last_seen_at, seen_count, evidence
36       FROM watcher_findings WHERE state = 'open' AND job_id IS NULL ORDER BY namespace, first_seen_at`
37    )
38    .all<Row>();
39  const out: OpsFinding[] = [];
40  for (const r of results ?? []) {
41    const klass: FindingClass = findingClass(r.fingerprint);
42    if (klass === "job") continue;
43    out.push({
44      fingerprint: r.fingerprint,
45      namespace: r.namespace,
46      class: klass,
47      headline: HEADLINE.exec(r.title)?.[1] ?? r.title,
48      first_seen: r.first_seen_at,
49      last_seen: r.last_seen_at,
50      seen_count: r.seen_count,
51      evidence: lastEvidence(r.evidence),
52    });
53  }
54  return out;
55}
56
57/** The email's weekly section: open digest-class findings per site. Empty on any day but
58 *  Monday UTC, and empty when none are open. */
59export async function weeklyDigestLines(db: D1Database, now: Date): Promise<string[]> {
60  if (now.getUTCDay() !== 1) return [];
61  const digest = (await openQuietFindings(db)).filter((f) => f.class === "digest");
62  if (digest.length === 0) return [];
63  const bySite = new Map<string, OpsFinding[]>();
64  for (const f of digest) bySite.set(f.namespace, [...(bySite.get(f.namespace) ?? []), f]);
65  const lines: string[] = [`Weekly digest (${digest.length} open, nothing here posts a job)`];
66  for (const [site, list] of bySite) {
67    lines.push(`${site}`);
68    for (const f of list) lines.push(`- ${f.headline} (since ${f.first_seen.slice(0, 10)})`);
69  }
70  return lines;
71}