src/fail-exemption.ts

Functions

Imports

It imports src/complete-ci.ts, src/env.ts, src/github/client.ts, src/job-checklist.ts, src/jobs-schema.ts. Imported by src/jobs-holder.ts.

Source

1import type { Env } from "./env";
2import type { JobRow } from "./jobs-schema";
3import { parsePrUrl } from "./github/client";
4import { readNamedPrs } from "./complete-ci";
5import { checklistItems, unchangedItems } from "./job-checklist";
6
7// Which holder fails the breaker does not count (src/job-breaker.ts; Grok design review
8// 2026-10-23, build step 7). "Not done, here's why" is a good outcome, but a breaker
9// that ignored every fail with a reason would stop nothing. So only two kinds are left
10// out, both shown by something other than the driver's word:
11//
12//   machinery  Capsid would refuse this job's complete right now, on the pull request it
13//              is bound to: red or unfinished CI, or a test taken away (src/complete-ci.ts).
14//              The fail is the outcome Capsid's own refusal asked for.
15//   remainder  the reason carries a line "REMAINING: 2, 4" naming DONE WHEN items
16//              (src/job-checklist.ts) that are left, some but not all of them; at least
17//              one item not named says it changes a path, and every such path is changed
18//              by the pull request the job is bound to. Part of the job is shown done in
19//              the diff, and the rest is stated item by item.
20
21export type BreakerExemption = "machinery" | "remainder";
22
23const REMAINING = /^[ \t]*REMAINING:[ \t]*(\d+(?:[ \t]*,[ \t]*\d+)*)[ \t]*(?:$|[.;:])/m;
24
25/** The item numbers a fail reason's REMAINING line names, or null without one. Pure. */
26function remainingItems(reason: string): number[] | null {
27  const m = REMAINING.exec(reason);
28  return m ? [...new Set(m[1].split(",").map((n) => Number(n.trim())))] : null;
29}
30
31export async function breakerExemption(env: Env, job: JobRow, reason: string): Promise<BreakerExemption | null> {
32  const urls = parsePrUrl(job.result_ref) ? [job.result_ref!.trim()] : [];
33  const read = urls.length > 0 ? await readNamedPrs(env, job.namespace, urls, job.body) : { changed: [], unread: false };
34  if (read && "refusal" in read) return "machinery";
35  const items = checklistItems(job.body);
36  const remaining = remainingItems(reason);
37  if (!remaining || remaining.length === 0 || remaining.length >= items.length) return null;
38  if (!remaining.every((n) => items.some((item) => item.n === n))) return null;
39  const done = items.filter((item) => !remaining.includes(item.n));
40  if (done.every((item) => item.paths.length === 0) || !read || read.unread) return null;
41  return unchangedItems(done, read.changed).length === 0 ? "remainder" : null;
42}