{"header":{"message":"Update file view when a new patch is applied","description":null,"timestamp":"2026-08-05T16:22:58.746055555Z","authors":[{}]},"hash":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC","authors":[{"login":"pmeunier","key":"AAAAC3NzaC1lZDI1NTE5AAAAILagOJFgwaMNhBWQINinKOXmqS4Gh5NgxgriXwdOoINJ"}],"deps":{"hashes":[["K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC","Update file view when a new patch is applied"],["AA",null],["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","Initial patch"],["AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC","Redesign (fat change)"],["VKU2L2AH6ID2HOEGL3VCRYSIWTXFFSPXKL5M42R5PS5PTRSXJR3AC","Fixing anchors (#id in urls), broken in markdown due to Shiki"],["DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC","Handling --amend from the Nest (unrecord + apply)"],["XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC","Notifications"],["KYWMDDGZTYQVRUO5QIXPLEPMW6JG5EDR2GO523XIPQZCB5B6577AC","Zulip mentions in notifications"],["G73NDZAN4APVCNWV6BY6S3P7K3BXONXNZQH3RQEJLABHJNBQ2QZQC","review: todo list"],["KUJXFMTMOVHBULDQ7O24QUKTAZAZJT7CNQFZPMHZQSJPE52A5HDQC","Improving the review process"],["PZOJXDJXK2T6DSQBV5IBSWT6TQH7XN4SODHBTKEZJ3DP5XL7C77AC","Review workflow: add author in discussion, not pusher"]],"deps":["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC","VKU2L2AH6ID2HOEGL3VCRYSIWTXFFSPXKL5M42R5PS5PTRSXJR3AC","DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC","XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC","KYWMDDGZTYQVRUO5QIXPLEPMW6JG5EDR2GO523XIPQZCB5B6577AC","G73NDZAN4APVCNWV6BY6S3P7K3BXONXNZQH3RQEJLABHJNBQ2QZQC","KUJXFMTMOVHBULDQ7O24QUKTAZAZJT7CNQFZPMHZQSJPE52A5HDQC","PZOJXDJXK2T6DSQBV5IBSWT6TQH7XN4SODHBTKEZJ3DP5XL7C77AC"],"known":[]},"hunks":[{"Edit":{"inode":{"change":8,"pos":54},"path":"ui/src/routes/reviews/+page.ts","line":30,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":334}],"down_context":[{"change":8,"pos":334}],"flag":"BLOCK","start":0,"end":201,"inode":{"change":8,"pos":54}}},"contents":[{"Add":{"text":"export interface PendingCi {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:28"}},{"Add":{"text":" owner: string;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:45"}},{"Add":{"text":" repo: string;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:61"}},{"Add":{"text":" channel: string;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:80"}},{"Add":{"text":" short: string;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:97"}},{"Add":{"text":" kind: 'failed' | 'scan';","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:124"}},{"Add":{"text":" code?: number;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:141"}},{"Add":{"text":" rolled_back: boolean;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:165"}},{"Add":{"text":" ended: number;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:182"}},{"Add":{"text":" url: string;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:197"}},{"Add":{"text":"}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:199"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:200"}}]}},{"Edit":{"inode":{"change":8,"pos":54},"path":"ui/src/routes/reviews/+page.ts","line":46,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":273}],"down_context":[{"change":8,"pos":409}],"flag":"BLOCK","start":202,"end":221,"inode":{"change":8,"pos":54}}},"contents":[{"Add":{"text":" ci: PendingCi[];","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:220"}}]}},{"Replacement":{"inode":{"change":8,"pos":54},"path":"ui/src/routes/reviews/+page.ts","line":55,"ins":{"up_context":[{"change":9,"pos":357}],"down_context":[{"change":9,"pos":406}],"flag":"BLOCK","start":222,"end":300,"inode":{"change":8,"pos":54}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":9,"pos":357},"to":{"change":9,"start":357,"end":406},"introduced_by":9}],"inode":{"change":8,"pos":54}},"ins_contents":[{"Add":{"text":" awaiting_approval: [] as PendingApproval[],","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:271"}},{"Add":{"text":" ci: [] as PendingCi[]","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:299"}}],"del_contents":[{"Del":{"text":" awaiting_approval: [] as PendingApproval[]","pos":"KUJXFMTMOVHBULDQ7O24QUKTAZAZJT7CNQFZPMHZQSJPE52A5HDQC:405"}}]}},{"Replacement":{"inode":{"change":8,"pos":54},"path":"ui/src/routes/reviews/+page.ts","line":62,"ins":{"up_context":[{"change":9,"pos":473}],"down_context":[{"change":9,"pos":525}],"flag":"BLOCK","start":301,"end":376,"inode":{"change":8,"pos":54}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":9,"pos":473},"to":{"change":9,"start":473,"end":525},"introduced_by":9}],"inode":{"change":8,"pos":54}},"ins_contents":[{"Add":{"text":" awaiting_approval: data.awaiting_approval ?? [],","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:353"}},{"Add":{"text":" ci: data.ci ?? []","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:375"}}],"del_contents":[{"Del":{"text":" awaiting_approval: data.awaiting_approval ?? []","pos":"KUJXFMTMOVHBULDQ7O24QUKTAZAZJT7CNQFZPMHZQSJPE52A5HDQC:524"}}]}},{"Replacement":{"inode":{"change":8,"pos":719},"path":"ui/src/routes/reviews/+page.svelte","line":7,"ins":{"up_context":[{"change":8,"pos":960}],"down_context":[{"change":8,"pos":1008}],"flag":"BLOCK","start":377,"end":453,"inode":{"change":8,"pos":719}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":960},"to":{"change":9,"start":531,"end":596},"introduced_by":9}],"inode":{"change":8,"pos":719}},"ins_contents":[{"Add":{"text":" import type { PendingThread, PendingApproval, PendingCi } from './+page';","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:452"}}],"del_contents":[{"Del":{"text":" import type { PendingThread, PendingApproval } from './+page';","pos":"KUJXFMTMOVHBULDQ7O24QUKTAZAZJT7CNQFZPMHZQSJPE52A5HDQC:595"}}]}},{"Edit":{"inode":{"change":8,"pos":719},"path":"ui/src/routes/reviews/+page.svelte","line":54,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":1235}],"down_context":[{"change":9,"pos":1235}],"flag":"BLOCK","start":454,"end":1068,"inode":{"change":8,"pos":719}}},"contents":[{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:459"}},{"Add":{"text":" return [...m.values()];","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:487"}},{"Add":{"text":" });","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:493"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:494"}},{"Add":{"text":" // CI failures / scan findings on the viewer's own pushes. Self-clearing on the","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:576"}},{"Add":{"text":" // server (only the latest run per channel), so no optimistic-removal state —","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:658"}},{"Add":{"text":" // just render what the loader returns, grouped by repo.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:717"}},{"Add":{"text":" const ci = $derived(data.ci ?? []);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:755"}},{"Add":{"text":" let ciGroups = $derived.by(() => {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:792"}},{"Add":{"text":" const m = new Map();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:878"}},{"Add":{"text":" for (const c of ci) {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:904"}},{"Add":{"text":" const k = `${c.owner}/${c.repo}`;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:944"}},{"Add":{"text":" const g = m.get(k);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:970"}},{"Add":{"text":" if (g) g.items.push(c);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1000"}},{"Add":{"text":" else m.set(k, { owner: c.owner, repo: c.repo, items: [c] });","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1067"}}]}},{"Replacement":{"inode":{"change":8,"pos":719},"path":"ui/src/routes/reviews/+page.svelte","line":97,"ins":{"up_context":[{"change":8,"pos":2363}],"down_context":[{"change":9,"pos":1834}],"flag":"BLOCK","start":1069,"end":1133,"inode":{"change":8,"pos":719}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":2363},"to":{"change":9,"start":1784,"end":1834},"introduced_by":9}],"inode":{"change":8,"pos":719}},"ins_contents":[{"Add":{"text":" {:else if !threads.length && !approvals.length && !ci.length}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1132"}}],"del_contents":[{"Del":{"text":" {:else if !threads.length && !approvals.length}","pos":"KUJXFMTMOVHBULDQ7O24QUKTAZAZJT7CNQFZPMHZQSJPE52A5HDQC:1833"}}]}},{"Edit":{"inode":{"change":8,"pos":719},"path":"ui/src/routes/reviews/+page.svelte","line":169,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":4954}],"down_context":[{"change":8,"pos":3745}],"flag":"BLOCK","start":1134,"end":2206,"inode":{"change":8,"pos":719}}},"contents":[{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1134"}},{"Add":{"text":"

problems on your pushes

","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1194"}},{"Add":{"text":" {#if !ci.length}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1215"}},{"Add":{"text":"

No failing CI or scan findings on your pushes.

","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1293"}},{"Add":{"text":" {:else}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1305"}},{"Add":{"text":" {#each ciGroups as g (`${g.owner}/${g.repo}`)}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1358"}},{"Add":{"text":"

","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1391"}},{"Add":{"text":" {g.owner}/{g.repo}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1472"}},{"Add":{"text":" {#each g.items as c (c.url)}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1511"}},{"Add":{"text":"

","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1548"}},{"Add":{"text":" {c.short}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1630"}},{"Add":{"text":" ","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1679"}},{"Add":{"text":" {#if c.kind === 'failed'}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1721"}},{"Add":{"text":" {c.code != null ? `CI failed (exit ${c.code})` : 'CI failed'}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1801"}},{"Add":{"text":" {:else}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1825"}},{"Add":{"text":" scan findings","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1857"}},{"Add":{"text":" {/if}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1879"}},{"Add":{"text":" ","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1901"}},{"Add":{"text":" ","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:1938"}},{"Add":{"text":" on {c.channel} · {timefmt(c.ended * 1000)}{c.rolled_back ? ' · rolled back' : ''}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2038"}},{"Add":{"text":" ","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2060"}},{"Add":{"text":" [view]","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2129"}},{"Add":{"text":"

","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2148"}},{"Add":{"text":" {/each}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2166"}},{"Add":{"text":"

","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2181"}},{"Add":{"text":" {/each}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2195"}},{"Add":{"text":" {/if}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2205"}}]}},{"Edit":{"inode":{"change":8,"pos":719},"path":"ui/src/routes/reviews/+page.svelte","line":258,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":5032}],"down_context":[{"change":9,"pos":4955}],"flag":"BLOCK","start":2207,"end":2383,"inode":{"change":8,"pos":719}}},"contents":[{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2210"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2211"}},{"Add":{"text":" .ci-view {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2224"}},{"Add":{"text":" margin-left: auto;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2247"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2251"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2252"}},{"Add":{"text":" .th-kind.ci-failed {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2275"}},{"Add":{"text":" color: var(--color-error);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2306"}},{"Add":{"text":" border-color: color-mix(in oklch, var(--color-error) 45%, transparent);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2382"}}]}},{"Edit":{"inode":{"change":8,"pos":719},"path":"ui/src/routes/reviews/+page.svelte","line":268,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":4959}],"down_context":[{"change":9,"pos":4959}],"flag":"BLOCK","start":2384,"end":2538,"inode":{"change":8,"pos":719}}},"contents":[{"Add":{"text":" .th-kind.ci-scan {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2404"}},{"Add":{"text":" color: var(--color-warning, #b8860b);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2446"}},{"Add":{"text":" border-color: color-mix(in oklch, var(--color-warning, #b8860b) 45%, transparent);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2533"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2537"}}]}},{"Edit":{"inode":{"change":2,"pos":55913},"path":"ui/src/routes/[user]/[repo]/tree/[...pos]/+page.svelte","line":42,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4733016}],"down_context":[{"change":4,"pos":0}],"flag":"BLOCK","start":2539,"end":3100,"inode":{"change":2,"pos":55913}}},"contents":[{"Add":{"text":" // Live-refresh: when a change lands on the channel we're viewing, the server","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2618"}},{"Add":{"text":" // pings this repo's SSE stream and we re-run the loader. The effect only","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2694"}},{"Add":{"text":" // reconnects when owner/repo/channel actually change (a same-value reload","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2771"}},{"Add":{"text":" // doesn't retrigger), so it survives its own invalidateAll without churn.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2848"}},{"Add":{"text":" $effect(() => {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2866"}},{"Add":{"text":" const url = `/api/tree/${data.owner}/${data.repo}/stream?channel=${encodeURIComponent(channel)}`;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:2968"}},{"Add":{"text":" const es = new EventSource(url);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3005"}},{"Add":{"text":" es.addEventListener('update', () => invalidateAll());","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3063"}},{"Add":{"text":" return () => es.close();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3092"}},{"Add":{"text":" });","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3098"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3099"}}]}},{"Edit":{"inode":{"change":8,"pos":7264},"path":"api/src/reviews.rs","line":70,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":15452}],"down_context":[{"change":8,"pos":9013}],"flag":"BLOCK","start":3101,"end":4019,"inode":{"change":8,"pos":7264}}},"contents":[{"Add":{"text":"}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3102"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3103"}},{"Add":{"text":"/// The latest CI run on a channel the viewer last pushed to, when it failed or a","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3185"}},{"Add":{"text":"/// security scan flagged findings. Self-clearing: as soon as a newer run on the","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3266"}},{"Add":{"text":"/// same channel passes (or someone else pushes), it drops off — it reflects the","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3349"}},{"Add":{"text":"/// current state, not history, so there's nothing to dismiss by hand.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3420"}},{"Add":{"text":"#[derive(Debug, Serialize)]","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3448"}},{"Add":{"text":"pub struct PendingCi {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3471"}},{"Add":{"text":" owner: String,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3490"}},{"Add":{"text":" repo: String,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3508"}},{"Add":{"text":" channel: String,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3529"}},{"Add":{"text":" /// First 8 chars of the job id, for display.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3579"}},{"Add":{"text":" short: String,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3598"}},{"Add":{"text":" /// `\"failed\"` (non-zero CI exit) or `\"scan\"` (security scan flagged findings).","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3682"}},{"Add":{"text":" kind: &'static str,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3706"}},{"Add":{"text":" /// The job's exit code, when it failed (absent for a scan-only finding).","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3784"}},{"Add":{"text":" #[serde(skip_serializing_if = \"Option::is_none\")]","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3838"}},{"Add":{"text":" code: Option,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3861"}},{"Add":{"text":" /// Whether an automatic rollback was performed after the failure.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3932"}},{"Add":{"text":" rolled_back: bool,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3955"}},{"Add":{"text":" ended: i64,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:3971"}},{"Add":{"text":" /// Link to the job page.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4001"}},{"Add":{"text":" url: String,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4018"}}]}},{"Edit":{"inode":{"change":8,"pos":7264},"path":"api/src/reviews.rs","line":103,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":15658}],"down_context":[{"change":8,"pos":9204}],"flag":"BLOCK","start":4020,"end":4107,"inode":{"change":8,"pos":7264}}},"contents":[{"Add":{"text":" /// Failing CI / flagged scans on the viewer's own pushes.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4082"}},{"Add":{"text":" ci: Vec,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4106"}}]}},{"Edit":{"inode":{"change":8,"pos":7264},"path":"api/src/reviews.rs","line":139,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":15706}],"down_context":[{"change":8,"pos":10537}],"flag":"BLOCK","start":4108,"end":4140,"inode":{"change":8,"pos":7264}}},"contents":[{"Add":{"text":" ci: Vec::new(),","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4139"}}]}},{"Edit":{"inode":{"change":8,"pos":7264},"path":"api/src/reviews.rs","line":296,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":15775}],"down_context":[{"change":9,"pos":15775}],"flag":"BLOCK","start":4141,"end":4188,"inode":{"change":8,"pos":7264}}},"contents":[{"Add":{"text":" let ci = ci_problems(&mut db, uid).await?;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4187"}}]}},{"Edit":{"inode":{"change":8,"pos":7264},"path":"api/src/reviews.rs","line":304,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":15808}],"down_context":[{"change":8,"pos":16343}],"flag":"BLOCK","start":4189,"end":4205,"inode":{"change":8,"pos":7264}}},"contents":[{"Add":{"text":" ci,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4204"}}]}},{"Edit":{"inode":{"change":8,"pos":7264},"path":"api/src/reviews.rs","line":446,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":21280}],"down_context":[{"change":9,"pos":21280}],"flag":"BLOCK","start":4206,"end":9348,"inode":{"change":8,"pos":7264}}},"contents":[{"Add":{"text":" Ok(out)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4217"}},{"Add":{"text":"}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4219"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4220"}},{"Add":{"text":"/// Failing CI runs (and scan-flagged runs) on channels the viewer last pushed","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4299"}},{"Add":{"text":"/// to. We keep only the *latest* finished job per `(repo, channel)` — the","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4376"}},{"Add":{"text":"/// current CI state — so a fixed failure disappears on its own. Attribution","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4455"}},{"Add":{"text":"/// matches the notification path: the channel's last `apply` pusher.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4525"}},{"Add":{"text":"async fn ci_problems(","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4547"}},{"Add":{"text":" db: &mut diesel_async::AsyncPgConnection,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4593"}},{"Add":{"text":" uid: uuid::Uuid,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4614"}},{"Add":{"text":") -> Result, crate::Error> {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4658"}},{"Add":{"text":" use crate::db::channel_events::dsl as ce;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4704"}},{"Add":{"text":" use crate::db::jobs::dsl as j;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4739"}},{"Add":{"text":" use crate::db::repositories::dsl as r;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4782"}},{"Add":{"text":" use crate::db::users::dsl as u;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4818"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4819"}},{"Add":{"text":" type JRow = (","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4837"}},{"Add":{"text":" uuid::Uuid, // job id","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4894"}},{"Add":{"text":" uuid::Uuid, // repo id","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:4952"}},{"Add":{"text":" String, // owner login","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5014"}},{"Add":{"text":" String, // repo name","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5074"}},{"Add":{"text":" String, // channel","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5132"}},{"Add":{"text":" Option, // status","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5189"}},{"Add":{"text":" Option, // scan_report","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5251"}},{"Add":{"text":" bool, // rolled_back","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5313"}},{"Add":{"text":" Option>, // ended","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5369"}},{"Add":{"text":" i64, // permissions bitmask","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5439"}},{"Add":{"text":" bool, // is_public","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5499"}},{"Add":{"text":" );","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5506"}},{"Add":{"text":" // All finished jobs, newest first, so the first row seen per (repo, channel)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5588"}},{"Add":{"text":" // is that channel's current CI state.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5631"}},{"Add":{"text":" let rows: Vec = j::jobs","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5665"}},{"Add":{"text":" .inner_join(r::repositories.on(r::id.eq(j::repo)))","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5724"}},{"Add":{"text":" .inner_join(u::users.on(u::id.eq(r::owner)))","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5777"}},{"Add":{"text":" .filter(j::ended.is_not_null())","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5817"}},{"Add":{"text":" .filter(j::status.is_not_null())","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5858"}},{"Add":{"text":" .filter(r::is_active)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5888"}},{"Add":{"text":" .filter(u::is_active)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5918"}},{"Add":{"text":" .order_by(j::ended.desc())","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5953"}},{"Add":{"text":" .select((","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5971"}},{"Add":{"text":" j::id,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:5990"}},{"Add":{"text":" j::repo,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6011"}},{"Add":{"text":" u::login,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6033"}},{"Add":{"text":" r::name,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6054"}},{"Add":{"text":" j::channel,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6078"}},{"Add":{"text":" j::status,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6101"}},{"Add":{"text":" j::scan_report,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6129"}},{"Add":{"text":" j::rolled_back,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6157"}},{"Add":{"text":" j::ended,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6179"}},{"Add":{"text":" crate::permissions!(uid, r::id),","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6224"}},{"Add":{"text":" crate::repository::is_public(),","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6268"}},{"Add":{"text":" ))","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6279"}},{"Add":{"text":" .get_results(db)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6304"}},{"Add":{"text":" .await?;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6321"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6322"}},{"Add":{"text":" let mut latest: HashMap<(uuid::Uuid, String), JRow> = HashMap::new();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6396"}},{"Add":{"text":" for row in rows {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6418"}},{"Add":{"text":" latest.entry((row.1, row.4.clone())).or_insert(row);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6479"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6485"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6486"}},{"Add":{"text":" // A scan report counts as a finding when it isn't empty / \"[]\" / \"{}\".","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6562"}},{"Add":{"text":" let scan_flagged = |s: &Option| {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6608"}},{"Add":{"text":" matches!(s.as_deref().map(str::trim), Some(t) if !t.is_empty() && t != \"[]\" && t != \"{}\")","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6706"}},{"Add":{"text":" };","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6713"}},{"Add":{"text":" // Keep accessible channels whose current run failed (non-zero, non-137 kill)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6795"}},{"Add":{"text":" // or flagged a scan.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6821"}},{"Add":{"text":" let cands: Vec = latest","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6855"}},{"Add":{"text":" .into_values()","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6878"}},{"Add":{"text":" .filter(|row| {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6902"}},{"Add":{"text":" let got = if row.10 {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6936"}},{"Add":{"text":" Perm::from_bits_truncate(row.9) | Perm::READ","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:6997"}},{"Add":{"text":" } else {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7018"}},{"Add":{"text":" Perm::from_bits_truncate(row.9)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7066"}},{"Add":{"text":" };","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7081"}},{"Add":{"text":" if !got.contains(Perm::READ) {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7124"}},{"Add":{"text":" return false;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7154"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7168"}},{"Add":{"text":" let failed = matches!(row.5, Some(c) if c != 0 && c != 137);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7241"}},{"Add":{"text":" failed || scan_flagged(&row.6)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7284"}},{"Add":{"text":" })","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7295"}},{"Add":{"text":" .collect();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7315"}},{"Add":{"text":" if cands.is_empty() {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7341"}},{"Add":{"text":" return Ok(Vec::new());","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7372"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7378"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7379"}},{"Add":{"text":" // Attribute each candidate channel to its last `apply` pusher (same rule the","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7461"}},{"Add":{"text":" // job notifications use), so only the person who pushed the broken state sees it.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7548"}},{"Add":{"text":" let repo_ids: Vec =","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7584"}},{"Add":{"text":" cands.iter().map(|c| c.1).collect::>().into_iter().collect();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7665"}},{"Add":{"text":" let ce_rows: Vec<(uuid::Uuid, String, Option, chrono::DateTime)> =","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7761"}},{"Add":{"text":" ce::channel_events","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7788"}},{"Add":{"text":" .filter(ce::repo_id.eq_any(&repo_ids))","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7839"}},{"Add":{"text":" .filter(ce::operation.eq(\"apply\"))","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7886"}},{"Add":{"text":" .order_by(ce::applied_at.desc())","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:7931"}},{"Add":{"text":" .select((ce::repo_id, ce::channel, ce::pushed_by, ce::applied_at))","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8010"}},{"Add":{"text":" .get_results(db)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8039"}},{"Add":{"text":" .await?;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8060"}},{"Add":{"text":" let mut last_pusher: HashMap<(uuid::Uuid, String), Option> = HashMap::new();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8153"}},{"Add":{"text":" for (repo, channel, pusher, _at) in ce_rows {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8203"}},{"Add":{"text":" last_pusher.entry((repo, channel)).or_insert(pusher);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8265"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8271"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8272"}},{"Add":{"text":" let mut out: Vec = cands","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8312"}},{"Add":{"text":" .into_iter()","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8333"}},{"Add":{"text":" .filter_map(|row| {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8361"}},{"Add":{"text":" let (id, repo_id, owner, repo, channel, status, _scan, rolled_back, ended, _p, _pub) =","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8460"}},{"Add":{"text":" row;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8481"}},{"Add":{"text":" if last_pusher.get(&(repo_id, channel.clone())).copied().flatten() != Some(uid) {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8575"}},{"Add":{"text":" return None;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8604"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8618"}},{"Add":{"text":" let ended = ended?;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8650"}},{"Add":{"text":" let failed = matches!(status, Some(c) if c != 0 && c != 137);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8724"}},{"Add":{"text":" let ids = id.to_string();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8762"}},{"Add":{"text":" let short = ids.get(..8).unwrap_or(&ids).to_string();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8828"}},{"Add":{"text":" let url = format!(\"/{}/{}/jobs/{}\", owner, repo, id);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8894"}},{"Add":{"text":" Some(PendingCi {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8923"}},{"Add":{"text":" kind: if failed { \"failed\" } else { \"scan\" },","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:8985"}},{"Add":{"text":" code: if failed { status } else { None },","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9043"}},{"Add":{"text":" rolled_back,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9072"}},{"Add":{"text":" ended: ended.timestamp(),","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9114"}},{"Add":{"text":" short,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9137"}},{"Add":{"text":" url,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9158"}},{"Add":{"text":" owner,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9181"}},{"Add":{"text":" repo,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9203"}},{"Add":{"text":" channel,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9228"}},{"Add":{"text":" })","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9243"}},{"Add":{"text":" })","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9254"}},{"Add":{"text":" .collect();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9274"}},{"Add":{"text":" // Most recent first.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9300"}},{"Add":{"text":" out.sort_by(|a, b| b.ended.cmp(&a.ended));","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9347"}}]}},{"Edit":{"inode":{"change":2,"pos":391778},"path":"api/src/repository/router.rs","line":338,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":397383}],"down_context":[{"change":2,"pos":397383}],"flag":"BLOCK","start":9349,"end":9550,"inode":{"change":2,"pos":391778}}},"contents":[{"Add":{"text":"}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9350"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9351"}},{"Add":{"text":"#[derive(Debug, Deserialize)]","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9381"}},{"Add":{"text":"pub struct StreamQuery {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9406"}},{"Add":{"text":" /// Which channel's activity to watch (defaults to `main`, or the `repo:chan`","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9488"}},{"Add":{"text":" /// suffix if present).","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9516"}},{"Add":{"text":" pub channel: Option,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9549"}}]}},{"Edit":{"inode":{"change":2,"pos":391778},"path":"api/src/repository/router.rs","line":346,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":397385}],"down_context":[],"flag":"BLOCK","start":9551,"end":11338,"inode":{"change":2,"pos":391778}}},"contents":[{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9551"}},{"Add":{"text":"/// Server-sent events for a repo view: emits an `update` whenever a change is","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9630"}},{"Add":{"text":"/// applied to the watched channel, so the tree/log page can refresh itself.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9707"}},{"Add":{"text":"/// Requires read access; the subscription is reaped once the tab closes.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9781"}},{"Add":{"text":"#[debug_handler]","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9798"}},{"Add":{"text":"pub async fn stream(","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9819"}},{"Add":{"text":" State(config): State,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9853"}},{"Add":{"text":" jar: SignedCookieJar,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9879"}},{"Add":{"text":" tree: crate::repository::RepoPath,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9918"}},{"Add":{"text":" Query(q): Query,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9952"}},{"Add":{"text":") -> Result<","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9965"}},{"Add":{"text":" axum::response::sse::Sse<","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:9995"}},{"Add":{"text":" impl futures::Stream>,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10094"}},{"Add":{"text":" >,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10101"}},{"Add":{"text":" crate::Error,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10119"}},{"Add":{"text":"> {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10123"}},{"Add":{"text":" use axum::response::sse::{Event, KeepAlive, Sse};","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10177"}},{"Add":{"text":" let (uid, _login) = crate::get_user_login_(&jar, &config).await?;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10247"}},{"Add":{"text":" let mut db = config.db.get().await?;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10288"}},{"Add":{"text":" let (id, _, _) =","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10309"}},{"Add":{"text":" super::repository_id(&mut db, &tree.owner, &tree.repo, uid, Perm::READ).await?;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10397"}},{"Add":{"text":" drop(db);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10411"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10412"}},{"Add":{"text":" let channel = q","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10432"}},{"Add":{"text":" .channel","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10449"}},{"Add":{"text":" .or(tree.channel)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10475"}},{"Add":{"text":" .unwrap_or_else(|| \"main\".to_string());","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10523"}},{"Add":{"text":" let rx = config","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10543"}},{"Add":{"text":" .repo_updates","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10565"}},{"Add":{"text":" .entry((id, channel))","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10595"}},{"Add":{"text":" .or_insert_with(|| tokio::sync::broadcast::channel(16).0)","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10661"}},{"Add":{"text":" .subscribe();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10683"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10684"}},{"Add":{"text":" let stream = futures::stream::unfold(rx, |mut rx| async move {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10751"}},{"Add":{"text":" loop {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10766"}},{"Add":{"text":" match rx.recv().await {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10802"}},{"Add":{"text":" Ok(()) => {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10830"}},{"Add":{"text":" return Some((","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10864"}},{"Add":{"text":" Ok::(Event::default().event(\"update\")),","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10961"}},{"Add":{"text":" rx,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:10989"}},{"Add":{"text":" ));","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11013"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11031"}},{"Add":{"text":" Err(tokio::sync::broadcast::error::RecvError::Lagged(_)) => continue,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11117"}},{"Add":{"text":" Err(tokio::sync::broadcast::error::RecvError::Closed) => return None,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11203"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11217"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11227"}},{"Add":{"text":" });","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11235"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11236"}},{"Add":{"text":" Ok(Sse::new(stream).keep_alive(KeepAlive::new().interval(std::time::Duration::from_secs(25))))","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11335"}},{"Add":{"text":"}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11337"}}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":257,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4904456}],"down_context":[{"change":3,"pos":4904456}],"flag":"BLOCK","start":11339,"end":11583,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11339"}},{"Add":{"text":" // A change just landed on this channel — ping any open","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11421"}},{"Add":{"text":" // repo view so it refreshes itself (SSE). Cheap ping.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11500"}},{"Add":{"text":" crate::notify::broadcast_repo(&s.notify, repo, &channel);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11582"}}]}},{"Edit":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":163,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":12633}],"down_context":[{"change":7,"pos":424}],"flag":"BLOCK","start":11584,"end":12167,"inode":{"change":6,"pos":7843}}},"contents":[{"Add":{"text":" /// Per-`(repo, channel)` live-update channels, so an applied change can ping","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11665"}},{"Add":{"text":" /// open repo views (threaded here too so the replication worker can fire it).","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11748"}},{"Add":{"text":" pub repo_updates:","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11770"}},{"Add":{"text":" Arc>>,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11859"}},{"Add":{"text":"}","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11861"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11862"}},{"Add":{"text":"/// Ping every open repo-view subscriber for `(repo, channel)` so their page can","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11943"}},{"Add":{"text":"/// refresh. No-op when nobody is watching.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:11987"}},{"Add":{"text":"pub fn broadcast_repo(n: &Notifier, repo: uuid::Uuid, channel: &str) {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12058"}},{"Add":{"text":" if let Some(tx) = n.repo_updates.get(&(repo, channel.to_string())) {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12131"}},{"Add":{"text":" let _ = tx.send(());","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12160"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12166"}}]}},{"Edit":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":429,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":2815}],"down_context":[{"change":7,"pos":2815}],"flag":"BLOCK","start":12168,"end":12436,"inode":{"change":6,"pos":7843}}},"contents":[{"Add":{"text":" /// Matched to a Zulip account, so they receive the stream @-mention. When","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12250"}},{"Add":{"text":" /// we actually post to the stream, that ping already reached them — the","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12333"}},{"Add":{"text":" /// email fallback would be redundant (\"if I already know it, no mail\").","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12414"}},{"Add":{"text":" zulip: bool,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12435"}}]}},{"Edit":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":457,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":3614}],"down_context":[{"change":7,"pos":3614}],"flag":"BLOCK","start":12437,"end":12468,"inode":{"change":6,"pos":7843}}},"contents":[{"Add":{"text":" let mut zulip = false;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12467"}}]}},{"Edit":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":461,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":3752}],"down_context":[{"change":7,"pos":3752}],"flag":"BLOCK","start":12469,"end":12499,"inode":{"change":6,"pos":7843}}},"contents":[{"Add":{"text":" zulip = true;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12498"}}]}},{"Edit":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":470,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":3940}],"down_context":[{"change":7,"pos":3940}],"flag":"BLOCK","start":12500,"end":12519,"inode":{"change":6,"pos":7843}}},"contents":[{"Add":{"text":" zulip,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12518"}}]}},{"Replacement":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":480,"ins":{"up_context":[{"change":10,"pos":3005}],"down_context":[{"change":10,"pos":3045}],"flag":"BLOCK","start":12520,"end":12605,"inode":{"change":6,"pos":7843}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":10,"pos":3005},"to":{"change":10,"start":3005,"end":3045},"introduced_by":10}],"inode":{"change":6,"pos":7843}},"ins_contents":[{"Add":{"text":" let posted_to_stream = !event.zulip.trim().is_empty();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12578"}},{"Add":{"text":" if posted_to_stream {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12604"}}],"del_contents":[{"Del":{"text":" if !event.zulip.trim().is_empty() {","pos":"PZOJXDJXK2T6DSQBV5IBSWT6TQH7XN4SODHBTKEZJ3DP5XL7C77AC:3044"}}]}},{"Replacement":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":490,"ins":{"up_context":[{"change":7,"pos":4314}],"down_context":[{"change":6,"pos":15398}],"flag":"BLOCK","start":12606,"end":12950,"inode":{"change":6,"pos":7843}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4314},"to":{"change":7,"start":4314,"end":4425},"introduced_by":7}],"inode":{"change":6,"pos":7843}},"ins_contents":[{"Add":{"text":" // 2. Personal delivery per target: SSE if present; else email — but only if","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12688"}},{"Add":{"text":" // the ping didn't already reach them on Zulip (deliver once, by the channel","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12769"}},{"Add":{"text":" // that reaches them). Either way the durable in-app record is kept (it backs","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12851"}},{"Add":{"text":" // the todo-list/bell), so nothing is lost.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12899"}},{"Add":{"text":" for Target { uid, email, zulip } in targets {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:12949"}}],"del_contents":[{"Del":{"text":" // 2. Personal delivery per target: SSE if present, else email.","pos":"KYWMDDGZTYQVRUO5QIXPLEPMW6JG5EDR2GO523XIPQZCB5B6577AC:4381"}},{"Del":{"text":" for Target { uid, email } in targets {","pos":"KYWMDDGZTYQVRUO5QIXPLEPMW6JG5EDR2GO523XIPQZCB5B6577AC:4424"}}]}},{"Replacement":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":514,"ins":{"up_context":[{"change":6,"pos":16030}],"down_context":[{"change":6,"pos":16564}],"flag":"BLOCK","start":12951,"end":13435,"inode":{"change":6,"pos":7843}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":16030},"to":{"change":7,"start":4426,"end":4589},"introduced_by":7}],"inode":{"change":6,"pos":7843}},"ins_contents":[{"Add":{"text":" // Already reached on Zulip? (matched account + we actually posted the","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13029"}},{"Add":{"text":" // stream ping). If so, the email fallback is redundant — suppress it.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13110"}},{"Add":{"text":" let zulip_reached = posted_to_stream && zulip;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13165"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13166"}},{"Add":{"text":" // Email fallback only when offline, wanted, addressable, and NOT already","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13248"}},{"Add":{"text":" // pinged on Zulip.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13276"}},{"Add":{"text":" let will_email = !present && email_on && !zulip_reached && email.is_some();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13360"}},{"Add":{"text":" let addr: Option = if will_email { email } else { None };","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13434"}}],"del_contents":[{"Del":{"text":" // Deliverable email address, if we might need one (prefetched above).","pos":"KYWMDDGZTYQVRUO5QIXPLEPMW6JG5EDR2GO523XIPQZCB5B6577AC:4504"}},{"Del":{"text":" let addr: Option = if !present && email_on { email } else { None };","pos":"KYWMDDGZTYQVRUO5QIXPLEPMW6JG5EDR2GO523XIPQZCB5B6577AC:4588"}}]}},{"Replacement":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":526,"ins":{"up_context":[{"change":6,"pos":16718}],"down_context":[{"change":6,"pos":16765}],"flag":"BLOCK","start":13436,"end":13467,"inode":{"change":6,"pos":7843}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":16718},"to":{"change":6,"start":16718,"end":16765},"introduced_by":6}],"inode":{"change":6,"pos":7843}},"ins_contents":[{"Add":{"text":" } else if will_email {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13466"}}],"del_contents":[{"Del":{"text":" } else if email_on && addr.is_some() {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16764"}}]}},{"Replacement":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":529,"ins":{"up_context":[{"change":6,"pos":16820}],"down_context":[{"change":6,"pos":16886}],"flag":"BLOCK","start":13468,"end":13565,"inode":{"change":6,"pos":7843}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":16820},"to":{"change":6,"start":16820,"end":16886},"introduced_by":6}],"inode":{"change":6,"pos":7843}},"ins_contents":[{"Add":{"text":" None // offline & no email (or already pinged on Zulip): keep for the bell/todo-list","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13564"}}],"del_contents":[{"Del":{"text":" None // offline & no email: keep it for the bell only","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16885"}}]}},{"Replacement":{"inode":{"change":6,"pos":7843},"path":"api/src/notify.rs","line":531,"ins":{"up_context":[{"change":6,"pos":16903}],"down_context":[{"change":6,"pos":16974}],"flag":"BLOCK","start":13566,"end":13624,"inode":{"change":6,"pos":7843}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":16903},"to":{"change":6,"start":16903,"end":16974},"introduced_by":6}],"inode":{"change":6,"pos":7843}},"ins_contents":[{"Add":{"text":" continue; // nothing reachable and in-app off","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13623"}}],"del_contents":[{"Del":{"text":" continue; // email wanted but no valid address, in-app off","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16973"}}]}},{"Edit":{"inode":{"change":2,"pos":452154},"path":"api/src/main.rs","line":248,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4924748}],"down_context":[{"change":3,"pos":4924748}],"flag":"BLOCK","start":13625,"end":13922,"inode":{"change":2,"pos":452154}}},"contents":[{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13638"}},{"Add":{"text":" }","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13648"}},{"Add":{"text":" });","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13656"}},{"Add":{"text":"","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13657"}},{"Add":{"text":" tokio::spawn({","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13676"}},{"Add":{"text":" let repo_updates = config.repo_updates.clone();","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13732"}},{"Add":{"text":" async move {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13753"}},{"Add":{"text":" loop {","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13772"}},{"Add":{"text":" tokio::time::sleep(std::time::Duration::from_secs(300)).await;","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13851"}},{"Add":{"text":" repo_updates.retain(|_, tx| tx.receiver_count() > 0);","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13921"}}]}},{"Edit":{"inode":{"change":2,"pos":452154},"path":"api/src/main.rs","line":468,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":463447}],"down_context":[{"change":3,"pos":4927639}],"flag":"BLOCK","start":13923,"end":14037,"inode":{"change":2,"pos":452154}}},"contents":[{"Add":{"text":" .route(","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13938"}},{"Add":{"text":" \"/tree/{owner}/{repo}/stream\",","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:13981"}},{"Add":{"text":" get(repository::router::stream),","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14026"}},{"Add":{"text":" )","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14036"}}]}},{"Edit":{"inode":{"change":2,"pos":532759},"path":"api/src/config.rs","line":64,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4994803}],"down_context":[{"change":5,"pos":27367}],"flag":"BLOCK","start":14038,"end":14467,"inode":{"change":2,"pos":532759}}},"contents":[{"Add":{"text":" /// Per-`(repo, channel)` live-update channels. A subscriber exists while a","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14117"}},{"Add":{"text":" /// repo view (tree/log) is open; a broadcast fires when a change is applied","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14198"}},{"Add":{"text":" /// to that channel, so the page can refresh itself. Cheap: the payload is a","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14279"}},{"Add":{"text":" /// bare ping, and Pijul's channel state makes \"did it change\" trivial.","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14355"}},{"Add":{"text":" pub repo_updates:","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14377"}},{"Add":{"text":" Arc>>,","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14466"}}]}},{"Edit":{"inode":{"change":2,"pos":532759},"path":"api/src/config.rs","line":93,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":28248}],"down_context":[{"change":5,"pos":28248}],"flag":"BLOCK","start":14468,"end":14521,"inode":{"change":2,"pos":532759}}},"contents":[{"Add":{"text":" repo_updates: self.repo_updates.clone(),","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14520"}}]}},{"Edit":{"inode":{"change":2,"pos":532759},"path":"api/src/config.rs","line":220,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4995885}],"down_context":[{"change":5,"pos":28265}],"flag":"BLOCK","start":14522,"end":14579,"inode":{"change":2,"pos":532759}}},"contents":[{"Add":{"text":" repo_updates: Arc::new(dashmap::DashMap::new()),","pos":"K7A7BIR5QCA2NWTXHGBCELJEKNITORMA6PTN6U5I353A6UUTULSQC:14578"}}]}}],"owner":"pijul","repo":"nest","token":"c97nCqpvPE2u+qYzpEnwRU0D/04ysZ9TPpj189hByC4=","login":null}

…

Dependencies

Change contents

Review