| 1 | import assert from "node:assert/strict"; |
| 2 | import { test } from "node:test"; |
| 3 | |
| 4 | import type { Claim, Decision, G1tEvent, WorkSession } from "@g1t/contracts"; |
| 5 | |
| 6 | import { |
| 7 | ENDED_BY_HAND, |
| 8 | checkHref, |
| 9 | endReasonText, |
| 10 | evidenceOf, |
| 11 | expiresIn, |
| 12 | feedLine, |
| 13 | harnessName, |
| 14 | intentTitle, |
| 15 | awakeAndIdle, |
| 16 | liveByItem, |
| 17 | sessionTitle, |
| 18 | duration, |
| 19 | mayEndSession, |
| 20 | mergeSessions, |
| 21 | numberedParts, |
| 22 | parseBlockedBy, |
| 23 | pendingLines, |
| 24 | resolutionOf, |
| 25 | sessionTree, |
| 26 | span, |
| 27 | standingFailure, |
| 28 | touchedByKind, |
| 29 | treeSize, |
| 30 | viaLabel, |
| 31 | } from "./coordination.ts"; |
| 32 | |
| 33 | const ana = { id: "usr_ana", username: "ana" }; |
| 34 | const bo = { id: "usr_bo", username: "bo" }; |
| 35 | |
| 36 | function claim(item: number, over: Partial<Claim> = {}): Claim { |
| 37 | return { |
| 38 | id: `clm_${item}_${over.actor?.username ?? "ana"}`, |
| 39 | repoId: "rep_1", |
| 40 | workspace: "acme", |
| 41 | item, |
| 42 | sessionId: null, |
| 43 | actor: ana, |
| 44 | harness: "claude_code", |
| 45 | note: null, |
| 46 | state: "active", |
| 47 | createdAt: "2026-10-12T10:00:00Z", |
| 48 | expiresAt: "2026-10-12T10:30:00Z", |
| 49 | endedAt: null, |
| 50 | endReason: null, |
| 51 | handoffTo: null, |
| 52 | ...over, |
| 53 | }; |
| 54 | } |
| 55 | |
| 56 | function session(id: string, over: Partial<WorkSession> = {}): WorkSession { |
| 57 | return { |
| 58 | id, |
| 59 | repoId: "rep_1", |
| 60 | item: null, |
| 61 | pull: null, |
| 62 | branch: null, |
| 63 | actor: bo, |
| 64 | harness: "codex", |
| 65 | harnessSessionId: null, |
| 66 | title: null, |
| 67 | state: "active", |
| 68 | headCommit: null, |
| 69 | startedAt: "2026-10-12T10:00:00Z", |
| 70 | lastSeenAt: "2026-10-12T10:05:00Z", |
| 71 | endedAt: null, |
| 72 | endReason: null, |
| 73 | ...over, |
| 74 | }; |
| 75 | } |
| 76 | |
| 77 | function decision(kind: Decision["kind"], at: string, over: Partial<Decision> = {}): Decision { |
| 78 | return { |
| 79 | id: `dec_${kind}_${at}`, |
| 80 | item: 2, |
| 81 | pull: 5, |
| 82 | sessionId: null, |
| 83 | actor: null, |
| 84 | kind, |
| 85 | confidence: "tested", |
| 86 | summary: kind, |
| 87 | evidence: {}, |
| 88 | createdAt: at, |
| 89 | ...over, |
| 90 | }; |
| 91 | } |
| 92 | |
| 93 | const event = (type: string, data: unknown): G1tEvent => |
| 94 | ({ id: `evt_${type}`, type, source: "work", time: "2026-10-12T10:00:00Z", repoId: "rep_1", actor: "usr_ana", data }) as G1tEvent; |
| 95 | |
| 96 | test("harnesses are named as people know them", () => { |
| 97 | assert.equal(harnessName("claude_code"), "Claude Code"); |
| 98 | assert.equal(harnessName("codex"), "Codex"); |
| 99 | assert.equal(harnessName("claude_managed_agents"), "Claude Managed Agents"); |
| 100 | assert.equal(harnessName(null), null); |
| 101 | }); |
| 102 | |
| 103 | test("a claim says when it lapses; one that ended says nothing", () => { |
| 104 | const now = Date.parse("2026-10-12T10:07:00Z"); |
| 105 | assert.equal(expiresIn(claim(1), now), "expires in 23m"); |
| 106 | assert.equal(expiresIn(claim(1, { expiresAt: "2026-10-12T12:00:00Z" }), now), "expires in 1h 53m"); |
| 107 | assert.equal(expiresIn(claim(1, { expiresAt: "2026-10-12T10:00:00Z" }), now), "expiring now"); |
| 108 | assert.equal(expiresIn(claim(1, { state: "released" }), now), null); |
| 109 | assert.equal(span(30_000), "less than a minute"); |
| 110 | assert.equal(span(2 * 3_600_000), "2h"); |
| 111 | }); |
| 112 | |
| 113 | test("Live now lists sessions heard from lately and folds away the idle, the latest first", () => { |
| 114 | const { awake, idle } = awakeAndIdle([ |
| 115 | session("ses_a", { state: "active" }), |
| 116 | session("ses_b", { state: "idle", title: "Tidy the README", lastSeenAt: "2026-10-12T10:00:00Z" }), |
| 117 | session("ses_c", { state: "idle", lastSeenAt: "2026-10-12T10:10:00Z" }), |
| 118 | ]); |
| 119 | assert.deepEqual(awake.map((one) => one.id), ["ses_a"]); |
| 120 | assert.deepEqual(idle.map((one) => one.id), ["ses_c", "ses_b"]); |
| 121 | // A tab opened and never typed in is in neither; once it says what it is for, it shows. |
| 122 | const opened = session("ses_d", { state: "active", title: null, startedAt: "2026-10-12T10:00:00Z", lastSeenAt: "2026-10-12T10:00:00Z" }); |
| 123 | assert.deepEqual(awakeAndIdle([opened]), { awake: [], idle: [] }); |
| 124 | assert.equal(awakeAndIdle([{ ...opened, lastSeenAt: "2026-10-12T10:00:05Z" }]).awake.length, 1); |
| 125 | assert.equal(awakeAndIdle([{ ...opened, title: "Fix the build" }]).awake.length, 1); |
| 126 | }); |
| 127 | |
| 128 | test("live work is grouped by work item, most recent first, with sessions on no work item apart", () => { |
| 129 | const { items, loose } = liveByItem( |
| 130 | [claim(1), claim(2, { createdAt: "2026-10-12T10:20:00Z" }), claim(2, { actor: bo })], |
| 131 | [session("ses_a", { item: 1, lastSeenAt: "2026-10-12T10:30:00Z" }), session("ses_b")], |
| 132 | ); |
| 133 | assert.deepEqual( |
| 134 | items.map((group) => [group.item, group.claims.length, group.sessions.length]), |
| 135 | [ |
| 136 | [1, 1, 1], |
| 137 | [2, 2, 0], |
| 138 | ], |
| 139 | ); |
| 140 | assert.deepEqual(loose.map((one) => one.id), ["ses_b"]); |
| 141 | }); |
| 142 | |
| 143 | test("sessions on no work item are grouped by pull request, then by a branch of their own, then the rest together", () => { |
| 144 | const seen = (minute: number) => `2026-10-12T10:${String(minute).padStart(2, "0")}:00Z`; |
| 145 | const { items, groups, loose } = liveByItem( |
| 146 | [], |
| 147 | [ |
| 148 | session("ses_main", { branch: "main", lastSeenAt: seen(50) }), |
| 149 | session("ses_fix1", { branch: "fix-previews", lastSeenAt: seen(10) }), |
| 150 | session("ses_pr", { pull: 12, branch: "tidy-readme", lastSeenAt: seen(20) }), |
| 151 | session("ses_fix2", { branch: "fix-previews", lastSeenAt: seen(40) }), |
| 152 | session("ses_none", { lastSeenAt: seen(30) }), |
| 153 | session("ses_issue", { item: 3, branch: "3-x", lastSeenAt: seen(5) }), |
| 154 | ], |
| 155 | "main", |
| 156 | ); |
| 157 | assert.deepEqual(items.map((group) => group.item), [3]); |
| 158 | assert.deepEqual( |
| 159 | groups.map((group) => [group.kind === "pull" ? `#${group.pull}` : group.kind === "branch" ? group.branch : "none", group.sessions.map((one) => one.id)]), |
| 160 | [ |
| 161 | // The most recently heard from first; the rest, on no branch of their own (the default branch is none), last. |
| 162 | ["fix-previews", ["ses_fix2", "ses_fix1"]], |
| 163 | ["#12", ["ses_pr"]], |
| 164 | ["none", ["ses_main", "ses_none"]], |
| 165 | ], |
| 166 | ); |
| 167 | assert.deepEqual(loose.map((one) => one.id), ["ses_fix2", "ses_fix1", "ses_pr", "ses_main", "ses_none"]); |
| 168 | // Without the default branch known, its sessions are a branch's. |
| 169 | assert.equal(liveByItem([], [session("ses_main", { branch: "main" })]).groups[0].kind, "branch"); |
| 170 | }); |
| 171 | |
| 172 | test("a session is never title-less: its title, its first prompt's intent, its branch, or untitled", () => { |
| 173 | assert.equal(sessionTitle({ title: "Rewrite the auth flow", branch: "auth", firstPrompt: "fix it" }), "Rewrite the auth flow"); |
| 174 | // A title that is only a pasted block's tag reads as none: the first prompt's words title it. |
| 175 | assert.equal(sessionTitle({ title: '<pasted_content id="5c50">', branch: "main", firstPrompt: '<pasted_content id="5c50">\nlog\n</pasted_content>\nship the runner setup' }), "Ship the runner setup"); |
| 176 | assert.equal(sessionTitle({ title: '<pasted_content id="5c50">', branch: "main", firstPrompt: null }), "Session on main"); |
| 177 | assert.equal(sessionTitle({ title: null, branch: "auth", firstPrompt: "fix the login redirect. It loops." }), "Fix the login redirect"); |
| 178 | assert.equal(sessionTitle({ title: " ", branch: "auth", firstPrompt: "/clear" }), "Session on auth"); |
| 179 | assert.equal(sessionTitle({ title: null, branch: null }), "Untitled session"); |
| 180 | assert.equal(sessionTitle({ title: null, branch: null }, "look at the CI"), "Look at the CI", "a first prompt given stands in"); |
| 181 | }); |
| 182 | |
| 183 | test("a prompt's intent is its first line or sentence, plain, clipped on a word", () => { |
| 184 | assert.equal(intentTitle("Make preview builds faster. They time out on big repositories."), "Make preview builds faster"); |
| 185 | // What an editor puts ahead of the prompt is not the prompt. |
| 186 | assert.equal(intentTitle("<ide_opened_file>The user opened a.ts in the IDE.</ide_opened_file>\nWhy is the page crashing?"), "Why is the page crashing?"); |
| 187 | assert.equal(intentTitle("Why does `src/app.ts` fail? It worked yesterday."), "Why does src/app.ts fail?"); |
| 188 | assert.equal(intentTitle("```js\nconst a = 1;\n```\n## Clean **this** up\nmore"), "Clean this up"); |
| 189 | assert.equal(intentTitle("\n\n- look at [the docs](https://docs.g1t.sh) for g1t.mjs"), "Look at the docs for g1t.mjs"); |
| 190 | const long = intentTitle("Tidy up the README and then look at the CI pipeline, which keeps failing on the Windows runners every night")!; |
| 191 | assert.ok(long.length <= 80 && long.endsWith("…") && !long.endsWith(" …"), long); |
| 192 | for (const prompt of ["/clear", "/g1t:status 4", "<command-name>/clear</command-name>", "```\ncode only\n```", "?", "", null]) { |
| 193 | assert.equal(intentTitle(prompt), null, String(prompt)); |
| 194 | } |
| 195 | }); |
| 196 | |
| 197 | test("evidence is read as far as it goes", () => { |
| 198 | const failed = decision("integration_failure", "2026-10-12T10:00:00Z", { |
| 199 | evidence: { commit: "abc1234", check: { name: "CI / merge_group", conclusion: "failure", url: "https://g1t.sh/acme/web/actions/runs/run_1" }, combination: [4, 5], suspects: [4], bisected: false }, |
| 200 | }); |
| 201 | assert.deepEqual(evidenceOf(failed), { |
| 202 | commit: "abc1234", |
| 203 | check: { name: "CI / merge_group", conclusion: "failure", url: "https://g1t.sh/acme/web/actions/runs/run_1" }, |
| 204 | combination: [4, 5], |
| 205 | suspects: [4], |
| 206 | bisected: false, |
| 207 | }); |
| 208 | assert.deepEqual(evidenceOf(decision("note", "2026-10-12T10:00:00Z", { evidence: { combination: "nope" } })).combination, []); |
| 209 | assert.equal(checkHref("https://g1t.sh/acme/web/actions/runs/run_1"), "/acme/web/actions/runs/run_1"); |
| 210 | assert.equal(checkHref("https://ci.example.com/build/9"), "https://ci.example.com/build/9"); |
| 211 | assert.equal(checkHref(null), null); |
| 212 | }); |
| 213 | |
| 214 | test("a failure stands until the pull request passes in the queue or merges, and a fix after it answers it", () => { |
| 215 | const failed = decision("integration_failure", "2026-10-12T10:00:00Z"); |
| 216 | const fix = decision("fix", "2026-10-12T10:10:00Z", { confidence: "claimed" }); |
| 217 | const passed = decision("integration_passed", "2026-10-12T10:20:00Z"); |
| 218 | assert.equal(standingFailure([failed], 5), failed); |
| 219 | assert.equal(standingFailure([failed, fix], 5), failed); |
| 220 | assert.equal(standingFailure([passed, failed], 5), null); |
| 221 | assert.equal(standingFailure([failed], 6), null); |
| 222 | assert.deepEqual(resolutionOf([failed, fix, passed], failed), { fix, passed }); |
| 223 | assert.deepEqual(resolutionOf([fix, failed], { ...failed, createdAt: "2026-10-12T10:15:00Z" }), { fix: null, passed: null }); |
| 224 | }); |
| 225 | |
| 226 | test("coordination events read as lines of the feed", () => { |
| 227 | const claimed = feedLine(event("work.claimed", { repoId: "rep_1", number: 2, item: 2, claim: claim(2, { actor: bo, harness: "codex" }), others: [claim(2)] }))!; |
| 228 | assert.equal(claimed.who, "bo"); |
| 229 | assert.equal(claimed.harness, "codex"); |
| 230 | assert.equal(claimed.text, "claimed #2 (ana is on it too)"); |
| 231 | assert.equal(claimed.tone, "warn"); |
| 232 | |
| 233 | const failed = feedLine( |
| 234 | event("integration.failed", { |
| 235 | repoId: "rep_1", pullId: "pul_5", number: 5, pull: 5, item: 2, combination: [4, 5], |
| 236 | check: { name: "CI / merge_group", conclusion: "failure", url: null }, bisected: false, suspects: [4], otherPulls: [4], commit: null, |
| 237 | }), |
| 238 | )!; |
| 239 | assert.equal(failed.who, null); |
| 240 | assert.equal(failed.text, "#5 failed in the merge queue combined as #4, #5: CI / merge_group; fails with #4"); |
| 241 | assert.equal(failed.tone, "danger"); |
| 242 | |
| 243 | const unblocked = feedLine( |
| 244 | event("dependency.changed", { repoId: "rep_1", number: 2, item: 2, blockedBy: [1], added: [], removed: [], cleared: [1], remaining: [], mergedPull: 4 }), |
| 245 | )!; |
| 246 | assert.equal(unblocked.text, "#2 #1 landed (#4 merged); unblocked"); |
| 247 | |
| 248 | const overlap = feedLine(event("overlap.detected", { repoId: "rep_1", number: 5, pull: 5, otherPull: 4, files: ["src/auth.rs"] }))!; |
| 249 | assert.equal(overlap.text, "#5 and #4 change the same file: src/auth.rs"); |
| 250 | assert.equal(overlap.session, undefined); |
| 251 | |
| 252 | const sessions = feedLine( |
| 253 | event("overlap.detected", { repoId: "rep_1", sessionId: "ses_a", otherSessionId: "ses_b", otherActor: "bo", files: ["a.rs", "b.rs", "c.rs", "d.rs"], item: 2 }), |
| 254 | )!; |
| 255 | assert.equal(sessions.who, "bo"); |
| 256 | assert.equal(sessions.text, "touched the same files in a session as another session: a.rs, b.rs, c.rs and 1 more"); |
| 257 | assert.equal(sessions.session, "ses_a"); |
| 258 | assert.equal(sessions.number, 2); |
| 259 | assert.equal(feedLine(event("session.progressed", { repoId: "rep_1", number: 2, sessionId: "ses_a" })), null); |
| 260 | |
| 261 | const started = feedLine(event("session.started", { repoId: "rep_1", session: session("ses_a", { item: 2 }) }))!; |
| 262 | assert.equal(started.text, "started a session on #2"); |
| 263 | assert.equal(feedLine(event("session.appended", { repoId: "rep_1", number: 5, pullId: "p", count: 3 })), null); |
| 264 | }); |
| 265 | |
| 266 | test("a session is ended by hand by whoever runs it, or by anyone who can write", () => { |
| 267 | const live = session("ses_a"); |
| 268 | assert.equal(mayEndSession(live, bo.id, false), true); |
| 269 | assert.equal(mayEndSession(live, ana.id, false), false); |
| 270 | assert.equal(mayEndSession(live, ana.id, true), true); |
| 271 | assert.equal(mayEndSession(session("ses_b", { state: "idle" }), ana.id, true), true); |
| 272 | // Ended already, or nobody signed in: nothing to offer. |
| 273 | assert.equal(mayEndSession(session("ses_c", { state: "ended" }), bo.id, true), false); |
| 274 | assert.equal(mayEndSession(live, null, true), false); |
| 275 | // One g1t runs is stopped from its page, which stops the run too. |
| 276 | assert.equal(mayEndSession(session("ses_d", { harness: "claude_managed_agents" }), bo.id, true), false); |
| 277 | assert.equal(endReasonText("timed_out"), "timed out"); |
| 278 | assert.equal(endReasonText(`${ENDED_BY_HAND}ana`), "ended by hand by @ana"); |
| 279 | assert.equal(endReasonText(null), null); |
| 280 | }); |
| 281 | |
| 282 | test("a session ended by hand says who ended it in the feed", () => { |
| 283 | const own = feedLine(event("session.ended", { repoId: "rep_1", session: session("ses_a", { item: 2, state: "ended", endReason: `${ENDED_BY_HAND}bo` }) }))!; |
| 284 | assert.equal(own.who, "bo"); |
| 285 | assert.equal(own.text, "ended a session on #2 by hand"); |
| 286 | const theirs = feedLine(event("session.ended", { repoId: "rep_1", session: session("ses_a", { state: "ended", endReason: `${ENDED_BY_HAND}ana` }) }))!; |
| 287 | assert.equal(theirs.who, "ana"); |
| 288 | assert.equal(theirs.harness, null); |
| 289 | assert.equal(theirs.text, "ended bo's session by hand"); |
| 290 | const timedOut = feedLine(event("session.ended", { repoId: "rep_1", session: session("ses_a", { state: "ended", endReason: "timed_out" }) }))!; |
| 291 | assert.equal(timedOut.text, "ended a session (timed out)"); |
| 292 | }); |
| 293 | |
| 294 | test("sessions become trees by their parents; one whose parent is missing is a root", () => { |
| 295 | const roots = sessionTree([ |
| 296 | session("ses_root"), |
| 297 | session("ses_a", { parentId: "ses_root" }), |
| 298 | session("ses_a1", { parentId: "ses_a" }), |
| 299 | session("ses_b", { parentId: "ses_root" }), |
| 300 | session("ses_orphan", { parentId: "ses_gone" }), |
| 301 | session("ses_other"), |
| 302 | ]); |
| 303 | const shape = (nodes: ReturnType<typeof sessionTree>): unknown[] => nodes.map((node) => [node.session.id, shape(node.children)]); |
| 304 | assert.deepEqual(shape(roots), [ |
| 305 | ["ses_root", [["ses_a", [["ses_a1", []]]], ["ses_b", []]]], |
| 306 | ["ses_orphan", []], |
| 307 | ["ses_other", []], |
| 308 | ]); |
| 309 | assert.equal(treeSize(roots[0]!), 3); |
| 310 | // A child listed before its parent still lands under it. |
| 311 | assert.deepEqual(shape(sessionTree([session("ses_c", { parentId: "ses_p" }), session("ses_p")])), [["ses_p", [["ses_c", []]]]]); |
| 312 | // A cycle does not lose sessions. |
| 313 | const cycle = sessionTree([session("ses_x", { parentId: "ses_y" }), session("ses_y", { parentId: "ses_x" })]); |
| 314 | assert.equal(cycle.length + cycle.reduce((n, node) => n + treeSize(node), 0), 2); |
| 315 | assert.deepEqual(sessionTree([]), []); |
| 316 | assert.deepEqual( |
| 317 | mergeSessions([session("ses_a"), session("ses_b")], null, [session("ses_b", { title: "later" }), session("ses_c")]).map((one) => [one.id, one.title]), |
| 318 | [ |
| 319 | ["ses_a", null], |
| 320 | ["ses_b", null], |
| 321 | ["ses_c", null], |
| 322 | ], |
| 323 | ); |
| 324 | }); |
| 325 | |
| 326 | test("how a session was tied to its work, what it touched, and how long it ran", () => { |
| 327 | assert.equal(viaLabel("attached"), "attached"); |
| 328 | assert.equal(viaLabel("claim"), "claimed"); |
| 329 | assert.equal(viaLabel("branch"), "its branch"); |
| 330 | assert.equal(viaLabel("commit"), "its commit"); |
| 331 | assert.equal(viaLabel("trailer"), "commit trailer"); |
| 332 | assert.equal(viaLabel("opened"), "opened it"); |
| 333 | assert.equal(viaLabel("ref"), "named it"); |
| 334 | assert.deepEqual( |
| 335 | touchedByKind([ |
| 336 | { kind: "commit", value: "abc" }, |
| 337 | { kind: "file", value: "b.rs" }, |
| 338 | { kind: "file", value: "a.rs" }, |
| 339 | { kind: "file", value: "b.rs" }, |
| 340 | ]), |
| 341 | [ |
| 342 | { kind: "file", values: ["b.rs", "a.rs"] }, |
| 343 | { kind: "commit", values: ["abc"] }, |
| 344 | ], |
| 345 | ); |
| 346 | const now = Date.parse("2026-10-12T10:30:00Z"); |
| 347 | assert.equal(duration(session("ses_a"), now), "30m"); |
| 348 | assert.equal(duration(session("ses_a", { state: "ended", endedAt: "2026-10-12T10:00:42Z" }), now), "42s"); |
| 349 | assert.equal(duration(session("ses_a", { state: "ended", endedAt: null }), now), "5m"); |
| 350 | }); |
| 351 | |
| 352 | test("numbers in a sentence are found for linking", () => { |
| 353 | assert.deepEqual(numberedParts("#5 fails with #4."), [5, " fails with ", 4, "."]); |
| 354 | assert.deepEqual(numberedParts("no numbers"), ["no numbers"]); |
| 355 | }); |
| 356 | |
| 357 | test("blocked_by is typed as numbers", () => { |
| 358 | assert.deepEqual(parseBlockedBy("#12, 14 #12"), [12, 14]); |
| 359 | assert.deepEqual(parseBlockedBy(""), []); |
| 360 | assert.equal(parseBlockedBy("#12, soon"), null); |
| 361 | assert.equal(parseBlockedBy("0"), null); |
| 362 | }); |
| 363 | |
| 364 | test("a session's pending updates read as the feed does, leaving out what it does not show", () => { |
| 365 | const lines = pendingLines([ |
| 366 | { id: "upd_1", kind: "work.claimed", at: "2026-10-14T10:00:00Z", data: { repoId: "rep_1", number: 4, item: 4, claim: claim(4, { actor: bo, harness: "codex" }) } }, |
| 367 | { id: "upd_2", kind: "session.progressed", at: "2026-10-14T10:00:01Z", data: {} }, |
| 368 | ]); |
| 369 | assert.equal(lines.length, 1); |
| 370 | assert.equal(lines[0].id, "upd_1"); |
| 371 | assert.equal(lines[0].who, "bo"); |
| 372 | assert.match(lines[0].text, /claimed #4/); |
| 373 | }); |