g1t/apps/web/app/lib/mission.test.ts
| 1 | import assert from "node:assert/strict"; |
| 2 | import { test } from "node:test"; |
| 3 | |
| 4 | import { |
| 5 | type ActivityItem, |
| 6 | type Need, |
| 7 | ageBuckets, |
| 8 | agentHours, |
| 9 | dailyBuckets, |
| 10 | digestParts, |
| 11 | firstPassRate, |
| 12 | formatSpan, |
| 13 | greetingFor, |
| 14 | groupActivity, |
| 15 | hourIn, |
| 16 | issueToMerge, |
| 17 | median, |
| 18 | nextSeen, |
| 19 | pipelineStage, |
| 20 | queuedNumbers, |
| 21 | rankNeeds, |
| 22 | readCookie, |
| 23 | sparkPoints, |
| 24 | splitRequest, |
| 25 | stuckMinutes, |
| 26 | } from "./mission.ts"; |
| 27 | |
| 28 | const MIN = 60_000; |
| 29 | const HOUR = 60 * MIN; |
| 30 | const DAY = 24 * HOUR; |
| 31 | const NOW = Date.parse("2026-10-04T18:00:00Z"); |
| 32 | |
| 33 | test("a first visit has nothing to count from and starts the clock", () => { |
| 34 | assert.deepEqual(nextSeen(null, NOW), { since: null, value: `0.${NOW}` }); |
| 35 | assert.deepEqual(nextSeen("garbage", NOW), { since: null, value: `0.${NOW}` }); |
| 36 | }); |
| 37 | |
| 38 | test("views within a visit keep counting from the visit before", () => { |
| 39 | const visitStart = NOW - 5 * MIN; |
| 40 | const before = NOW - 3 * DAY; |
| 41 | assert.deepEqual(nextSeen(`${before}.${visitStart}`, NOW), { since: before, value: `${before}.${NOW}` }); |
| 42 | // A first visit, refreshed: still nothing to count from. |
| 43 | assert.deepEqual(nextSeen(`0.${visitStart}`, NOW), { since: null, value: `0.${NOW}` }); |
| 44 | }); |
| 45 | |
| 46 | test("a long gap starts a new visit, counting from the last view", () => { |
| 47 | const last = NOW - 2 * HOUR; |
| 48 | assert.deepEqual(nextSeen(`${NOW - DAY}.${last}`, NOW), { since: last, value: `${last}.${NOW}` }); |
| 49 | }); |
| 50 | |
| 51 | test("a cookie from the future is ignored", () => { |
| 52 | assert.equal(nextSeen(`0.${NOW + DAY}`, NOW).since, null); |
| 53 | }); |
| 54 | |
| 55 | test("cookies are read by name", () => { |
| 56 | assert.equal(readCookie("a=1; g1t_seen=0.5; b=2", "g1t_seen"), "0.5"); |
| 57 | assert.equal(readCookie("g1t_tz=America%2FLos_Angeles", "g1t_tz"), "America/Los_Angeles"); |
| 58 | assert.equal(readCookie(null, "x"), null); |
| 59 | assert.equal(readCookie("x=1", "y"), null); |
| 60 | }); |
| 61 | |
| 62 | test("greetings follow the hour, in the viewer's zone", () => { |
| 63 | assert.equal(greetingFor(8), "Good morning"); |
| 64 | assert.equal(greetingFor(13), "Good afternoon"); |
| 65 | assert.equal(greetingFor(20), "Good evening"); |
| 66 | assert.equal(greetingFor(2), "Good evening"); |
| 67 | assert.equal(hourIn(NOW, "UTC"), 18); |
| 68 | assert.equal(hourIn(NOW, "America/Los_Angeles"), 11); |
| 69 | assert.equal(hourIn(NOW, "Not/AZone"), 18); |
| 70 | }); |
| 71 | |
| 72 | test("the composer's first line is the title", () => { |
| 73 | assert.deepEqual(splitRequest(" Fix the login redirect "), { title: "Fix the login redirect", body: "" }); |
| 74 | assert.deepEqual(splitRequest("Fix it\n\nIt loops after signing in."), { title: "Fix it", body: "It loops after signing in." }); |
| 75 | const long = "word ".repeat(60).trim(); |
| 76 | const split = splitRequest(long, 40); |
| 77 | assert.ok(split.title.length <= 40); |
| 78 | assert.ok(split.title.endsWith("…")); |
| 79 | assert.equal(split.body, long); |
| 80 | }); |
| 81 | |
| 82 | const repo = { namespace: "acme", name: "api" }; |
| 83 | const item = (id: string, at: number, actor: string | null, verb: ActivityItem["verb"], number: number | null, other = repo): ActivityItem => ({ |
| 84 | id, |
| 85 | at, |
| 86 | repo: other, |
| 87 | actor, |
| 88 | verb, |
| 89 | number, |
| 90 | }); |
| 91 | |
| 92 | test("one agent's burst in one project reads as one line", () => { |
| 93 | const groups = groupActivity([ |
| 94 | item("1", NOW, "g1t-agent", "landed", 4), |
| 95 | item("2", NOW - 5 * MIN, "g1t-agent", "started", 5), |
| 96 | item("3", NOW - 10 * MIN, "g1t-agent", "started", 6), |
| 97 | item("4", NOW - 12 * MIN, "g1t-agent", "landed", 3), |
| 98 | item("5", NOW - 20 * MIN, "ana", "opened_issue", 7), |
| 99 | item("6", NOW - 25 * MIN, "g1t-agent", "landed", 2), |
| 100 | ]); |
| 101 | assert.equal(groups.length, 3); |
| 102 | assert.equal(groups[0].count, 4); |
| 103 | assert.deepEqual(groups[0].parts.map((p) => [p.verb, p.numbers]), [ |
| 104 | ["landed", [4, 3]], |
| 105 | ["started", [5, 6]], |
| 106 | ]); |
| 107 | assert.equal(groups[0].from, NOW - 12 * MIN); |
| 108 | assert.equal(groups[1].actor, "ana"); |
| 109 | }); |
| 110 | |
| 111 | test("a burst breaks across projects and long gaps", () => { |
| 112 | const other = { namespace: "acme", name: "web" }; |
| 113 | const groups = groupActivity([ |
| 114 | item("1", NOW, "g1t-agent", "landed", 1), |
| 115 | item("2", NOW - MIN, "g1t-agent", "landed", 2, other), |
| 116 | item("3", NOW - 2 * HOUR, "g1t-agent", "landed", 3, other), |
| 117 | ]); |
| 118 | assert.equal(groups.length, 3); |
| 119 | }); |
| 120 | |
| 121 | test("needs are ranked by urgency, then by how long they waited", () => { |
| 122 | const need = (key: string, kind: Need["kind"], at: number): Need => ({ key, kind, at, title: key, detail: "", to: "/", action: "Open", where: null }); |
| 123 | const ranked = rankNeeds([ |
| 124 | need("r1", "review", NOW - HOUR), |
| 125 | need("d", "deploy", NOW), |
| 126 | need("r2", "review", NOW - DAY), |
| 127 | need("r2", "review", NOW - DAY), |
| 128 | need("l", "limit", NOW), |
| 129 | ]); |
| 130 | assert.deepEqual(ranked.map((n) => n.key), ["l", "d", "r2", "r1"]); |
| 131 | }); |
| 132 | |
| 133 | test("a running agent quiet for ten minutes is stuck", () => { |
| 134 | assert.equal(stuckMinutes({ status: "running", updatedAt: new Date(NOW - 14 * MIN).toISOString() }, NOW), 14); |
| 135 | assert.equal(stuckMinutes({ status: "running", updatedAt: new Date(NOW - 2 * MIN).toISOString() }, NOW), null); |
| 136 | assert.equal(stuckMinutes({ status: "queued", updatedAt: new Date(NOW - HOUR).toISOString() }, NOW), null); |
| 137 | }); |
| 138 | |
| 139 | test("the digest says what moved, the urgent parts toned", () => { |
| 140 | const parts = digestParts({ landed: 3, reviews: 1, opened: 0, deploys: 2, failedDeploys: 1, stuck: 12 }); |
| 141 | assert.deepEqual(parts.map((p) => p.text), [ |
| 142 | "3 changes landed", |
| 143 | "1 pull request needs your review", |
| 144 | "an agent has been quiet for 12 min", |
| 145 | "1 deploy failed", |
| 146 | "2 deploys went out", |
| 147 | ]); |
| 148 | assert.deepEqual(digestParts({ landed: 0, reviews: 0, opened: 0, deploys: 0, failedDeploys: 0, stuck: null }), []); |
| 149 | }); |
| 150 | |
| 151 | test("daily buckets put each point on its day, oldest first", () => { |
| 152 | const buckets = dailyBuckets( |
| 153 | [{ at: NOW }, { at: NOW - DAY }, { at: NOW - DAY, value: 2 }, { at: NOW - 10 * DAY }], |
| 154 | 7, |
| 155 | NOW, |
| 156 | ); |
| 157 | assert.deepEqual(buckets, [0, 0, 0, 0, 0, 3, 1]); |
| 158 | }); |
| 159 | |
| 160 | test("median, pass rates and spans", () => { |
| 161 | assert.equal(median([]), null); |
| 162 | assert.equal(median([3, 1, 2]), 2); |
| 163 | assert.equal(median([4, 1, 2, 3]), 2.5); |
| 164 | const rate = firstPassRate([ |
| 165 | { repo: "a", number: 1, at: 2, passed: true }, |
| 166 | { repo: "a", number: 1, at: 1, passed: false }, |
| 167 | { repo: "a", number: 2, at: 1, passed: true }, |
| 168 | ]); |
| 169 | assert.deepEqual(rate, { rate: 0.5, of: 2 }); |
| 170 | assert.deepEqual(firstPassRate([]), { rate: null, of: 0 }); |
| 171 | assert.equal(formatSpan(null), "—"); |
| 172 | assert.equal(formatSpan(30 * MIN), "30m"); |
| 173 | assert.equal(formatSpan(5 * HOUR), "5h"); |
| 174 | assert.equal(formatSpan(2 * DAY + 4 * HOUR), "2d 4h"); |
| 175 | }); |
| 176 | |
| 177 | test("issue to merge pairs a merge with the issue it resolved", () => { |
| 178 | const spans = issueToMerge( |
| 179 | [{ repo: "a", number: 1, at: 100 }, { repo: "b", number: 1, at: 50 }], |
| 180 | [{ repo: "a", issue: 1, at: 400 }, { repo: "a", issue: null, at: 500 }, { repo: "c", issue: 1, at: 900 }], |
| 181 | ); |
| 182 | assert.deepEqual(spans, [300]); |
| 183 | }); |
| 184 | |
| 185 | test("agent hours count only agents, clipped to the window", () => { |
| 186 | const hours = agentHours( |
| 187 | [ |
| 188 | { kind: "implement", startedAt: new Date(NOW - 2 * HOUR).toISOString(), finishedAt: new Date(NOW - HOUR).toISOString() }, |
| 189 | { kind: "review", startedAt: new Date(NOW - 30 * MIN).toISOString(), finishedAt: null }, |
| 190 | { kind: "checks", startedAt: new Date(NOW - 5 * HOUR).toISOString(), finishedAt: null }, |
| 191 | { kind: "implement", startedAt: new Date(NOW - 9 * DAY).toISOString(), finishedAt: new Date(NOW - 7 * DAY + HOUR).toISOString() }, |
| 192 | ], |
| 193 | NOW - 7 * DAY, |
| 194 | NOW, |
| 195 | ); |
| 196 | assert.equal(hours, 2.5); |
| 197 | }); |
| 198 | |
| 199 | test("sparkline points span the box, zero on the floor", () => { |
| 200 | assert.deepEqual(sparkPoints([], 100, 20), []); |
| 201 | const points = sparkPoints([0, 5, 10], 100, 20, 2); |
| 202 | assert.deepEqual(points, [ |
| 203 | [2, 18], |
| 204 | [50, 10], |
| 205 | [98, 2], |
| 206 | ]); |
| 207 | assert.deepEqual(sparkPoints([0, 0], 10, 10, 1), [ |
| 208 | [1, 9], |
| 209 | [9, 9], |
| 210 | ]); |
| 211 | assert.deepEqual(sparkPoints([3], 10, 10, 1), [[5, 1]]); |
| 212 | }); |
| 213 | |
| 214 | test("a pull request's place in the pipeline", () => { |
| 215 | const queued = queuedNumbers([ |
| 216 | { number: 9, state: "waiting" }, |
| 217 | { number: 8, state: "landed" }, |
| 218 | ]); |
| 219 | assert.equal(pipelineStage({ status: "merged", checkStatus: null, number: 1 }, undefined, queued), "landed"); |
| 220 | assert.equal(pipelineStage({ status: "open", checkStatus: "passed", number: 9 }, undefined, queued), "queue"); |
| 221 | assert.equal(pipelineStage({ status: "draft", checkStatus: null, number: 2 }, undefined, queued), "working"); |
| 222 | assert.equal(pipelineStage({ status: "open", checkStatus: "running", number: 3 }, undefined, queued), "checking"); |
| 223 | assert.equal(pipelineStage({ status: "open", checkStatus: "passed", number: 4 }, { kind: "revise" }, queued), "working"); |
| 224 | assert.equal(pipelineStage({ status: "open", checkStatus: "passed", number: 5 }, { kind: "review" }, queued), "reviewing"); |
| 225 | assert.equal(pipelineStage({ status: "open", checkStatus: "failed", number: 6 }, undefined, queued), "reviewing"); |
| 226 | }); |
| 227 | |
| 228 | test("open issues by age", () => { |
| 229 | const buckets = ageBuckets( |
| 230 | [new Date(NOW - HOUR).toISOString(), new Date(NOW - 3 * DAY).toISOString(), new Date(NOW - 90 * DAY).toISOString()], |
| 231 | NOW, |
| 232 | ); |
| 233 | assert.deepEqual(buckets.map((b) => b.count), [1, 1, 0, 1]); |
| 234 | }); |