{"header":{"message":"Handling --amend from the Nest (unrecord + apply)","description":null,"timestamp":"2026-07-29T11:34:57.969465064Z","authors":[{}]},"hash":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC","authors":[{"login":"pmeunier","key":"AAAAC3NzaC1lZDI1NTE5AAAAILagOJFgwaMNhBWQINinKOXmqS4Gh5NgxgriXwdOoINJ"}],"deps":{"hashes":[["DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC","Handling --amend from the Nest (unrecord + apply)"],["AA",null],["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","Initial patch"],["LE34RHBBMJT2BWLU5BHZJSHNMHQWX66QQNM2MAEDWEARCWOCSYLAC","Fixing a CORS bug"],["5VX32NQS4TFOXTKH3UOMTMTCUZ2IGCKO2BFBXRZAEQ3GKTTNX5SQC","Debugging settings/repos"],["YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","Initial attempt at CI/CD"],["PCR2LDLTK6XVSBXJL6IMGQP7GSE5UNFCT6WRM2H5EPQ2AZWFRCFAC","update + CI"],["AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC","Redesign (fat change)"],["66J2FRHA63N4X4CPVLMYADCZRZ3XC5LHGOKYXC6SOKG7DNVBIOTQC","Showing patches in context"],["APRMGSDR2JE5AXXTIF7LZ7K5N54YDSQR4DJWKILZET45B6ODZPPAC","SSH: approve"],["EG3MNPQXLNF62UQAP3342JC4OL47MAUCYJM6Q4G7BVVBM2VXMDCAC","Patch reviews"],["HY6KW56TNL5TWFPDQLZBDURE2DZSHKSBDKW53VQOR55DSEU7I7QQC","Missing files"],["3UYOLOBPKKDEBN4VX4GZT2KXVH3WJF3SBTWZADD2SQW4463KDKBAC","Rollback failed CI/CD jobs, and allow CI-only channels"],["IXMVMCZMQP2DJL3VILNPIJPOM6N7H2Z5DSFEIDCX7NE5CDTKDTTAC","Replacing approvals with 'different pusher and author'"],["OJUGWEVPQPIE2SH3ECNWC7XBW7E6GJ64YSPQAWXVAYN5IJTRTXHQC","Grandfathering: marking existing history as ok when switching to a strict review policy"],["AH4IBU3TU6SQEJHUA3RNI2RFXZSSIC4NAWX72WVS6X3LLG5LQMXAC","New approval system"],["AAPXKG56GGV7IQGFIG55DBWLPME5RIRRFTM36ANXGVYXXUTVKLNQC","jobs: display state in UI"],["FU37JBX4JISRV26VYEMLU3LZ67CVTUO62JP6H6SO6P2RAIIHRUMAC","Audits CI-side"]],"deps":["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","LE34RHBBMJT2BWLU5BHZJSHNMHQWX66QQNM2MAEDWEARCWOCSYLAC","5VX32NQS4TFOXTKH3UOMTMTCUZ2IGCKO2BFBXRZAEQ3GKTTNX5SQC","YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","PCR2LDLTK6XVSBXJL6IMGQP7GSE5UNFCT6WRM2H5EPQ2AZWFRCFAC","AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC","66J2FRHA63N4X4CPVLMYADCZRZ3XC5LHGOKYXC6SOKG7DNVBIOTQC","APRMGSDR2JE5AXXTIF7LZ7K5N54YDSQR4DJWKILZET45B6ODZPPAC","EG3MNPQXLNF62UQAP3342JC4OL47MAUCYJM6Q4G7BVVBM2VXMDCAC","HY6KW56TNL5TWFPDQLZBDURE2DZSHKSBDKW53VQOR55DSEU7I7QQC","3UYOLOBPKKDEBN4VX4GZT2KXVH3WJF3SBTWZADD2SQW4463KDKBAC","IXMVMCZMQP2DJL3VILNPIJPOM6N7H2Z5DSFEIDCX7NE5CDTKDTTAC","OJUGWEVPQPIE2SH3ECNWC7XBW7E6GJ64YSPQAWXVAYN5IJTRTXHQC"],"known":["AAPXKG56GGV7IQGFIG55DBWLPME5RIRRFTM36ANXGVYXXUTVKLNQC","AH4IBU3TU6SQEJHUA3RNI2RFXZSSIC4NAWX72WVS6X3LLG5LQMXAC","FU37JBX4JISRV26VYEMLU3LZ67CVTUO62JP6H6SO6P2RAIIHRUMAC"]},"hunks":[{"Edit":{"inode":{"change":2,"pos":31084},"path":"ui/src/routes/settings/+layout.svelte","line":18,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4728228}],"down_context":[{"change":7,"pos":4728228}],"flag":"BLOCK","start":0,"end":137,"inode":{"change":2,"pos":31084}}},"contents":[{"Add":{"text":" notifications","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:136"}}]}},{"Edit":{"inode":{"change":2,"pos":84733},"path":"ui/src/routes/[user]/[repo]/change/[hash]/+page.svelte","line":49,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":32581}],"down_context":[{"change":5,"pos":10783}],"flag":"BLOCK","start":138,"end":712,"inode":{"change":2,"pos":84733}}},"contents":[{"Add":{"text":" // Revisions of this logical change (amend history), oldest → newest. Reloads","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:219"}},{"Add":{"text":" // when navigating between iterations.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:260"}},{"Add":{"text":" type Revision = { hash: string; date: number; current: boolean; superseded: boolean };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:349"}},{"Add":{"text":" let revisions: Revision[] = $state([]);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:391"}},{"Add":{"text":" $effect(() => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:409"}},{"Add":{"text":" const h = data.hash;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:434"}},{"Add":{"text":" fetch(`/api/change/${data.owner}/${data.repo}/revisions/${h}`)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:501"}},{"Add":{"text":" .then((r) => (r.ok ? r.json() : { revisions: [] }))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:559"}},{"Add":{"text":" .then((j) => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:580"}},{"Add":{"text":" if (data.hash === h) revisions = j.revisions ?? [];","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:640"}},{"Add":{"text":" })","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:649"}},{"Add":{"text":" .catch(() => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:670"}},{"Add":{"text":" revisions = [];","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:694"}},{"Add":{"text":" });","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:704"}},{"Add":{"text":" });","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:710"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:711"}}]}},{"Edit":{"inode":{"change":2,"pos":84733},"path":"ui/src/routes/[user]/[repo]/change/[hash]/+page.svelte","line":99,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":86523}],"down_context":[{"change":2,"pos":86523}],"flag":"BLOCK","start":713,"end":1549,"inode":{"change":2,"pos":84733}}},"contents":[{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:713"}},{"Add":{"text":" {#if revisions.length > 1}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:742"}},{"Add":{"text":"

Revisions

","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:778"}},{"Add":{"text":"

","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:913"}},{"Add":{"text":" v{i + 1}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:969"}},{"Add":{"text":" {#if rev.current}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:997"}},{"Add":{"text":" {rev.hash.slice(0, 16)}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1059"}},{"Add":{"text":" current","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1120"}},{"Add":{"text":" {:else}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1138"}},{"Add":{"text":" {rev.hash.slice(0, 16)}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1286"}},{"Add":{"text":" {/if}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1302"}},{"Add":{"text":" {#if rev.superseded}superseded{/if}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1392"}},{"Add":{"text":" {new Date(rev.date * 1000).toLocaleDateString()}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1502"}},{"Add":{"text":"

","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1540"}},{"Add":{"text":" {/if}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1548"}}]}},{"Edit":{"inode":{"change":2,"pos":84733},"path":"ui/src/routes/[user]/[repo]/change/[hash]/+page.svelte","line":286,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4786398}],"down_context":[{"change":7,"pos":4786398}],"flag":"BLOCK","start":1550,"end":2330,"inode":{"change":2,"pos":84733}}},"contents":[{"Add":{"text":" .revisions {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1564"}},{"Add":{"text":" list-style: none;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1586"}},{"Add":{"text":" padding: 0;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1602"}},{"Add":{"text":" display: flex;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1621"}},{"Add":{"text":" flex-direction: column;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1649"}},{"Add":{"text":" gap: 0.25rem;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1667"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1671"}},{"Add":{"text":" .revision {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1685"}},{"Add":{"text":" display: flex;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1704"}},{"Add":{"text":" align-items: baseline;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1731"}},{"Add":{"text":" gap: 0.5rem;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1748"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1752"}},{"Add":{"text":" .revision.current {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1774"}},{"Add":{"text":" font-weight: 600;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1796"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1800"}},{"Add":{"text":" .rev-num {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1813"}},{"Add":{"text":" color: var(--color-neutral-content);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1854"}},{"Add":{"text":" min-width: 2.2rem;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1877"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1881"}},{"Add":{"text":" .rev-date {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1895"}},{"Add":{"text":" color: var(--color-neutral-content);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1936"}},{"Add":{"text":" margin-left: auto;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1959"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1963"}},{"Add":{"text":" .rev-tag {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1976"}},{"Add":{"text":" font-size: 0.7rem;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:1999"}},{"Add":{"text":" padding: 0 0.35rem;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2023"}},{"Add":{"text":" border-radius: 3px;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2047"}},{"Add":{"text":" line-height: 1.4;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2069"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2073"}},{"Add":{"text":" .rev-current {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2090"}},{"Add":{"text":" background: color-mix(in oklch, var(--color-primary, #6366f1) 25%, transparent);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2175"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2179"}},{"Add":{"text":" .rev-superseded {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2199"}},{"Add":{"text":" background: color-mix(in oklch, var(--color-neutral-content) 20%, transparent);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2283"}},{"Add":{"text":" color: var(--color-neutral-content);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2324"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2328"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2329"}}]}},{"Edit":{"inode":{"change":2,"pos":117811},"path":"ui/src/routes/+layout.svelte","line":7,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4829637}],"down_context":[{"change":5,"pos":13194}],"flag":"BLOCK","start":2331,"end":2394,"inode":{"change":2,"pos":117811}}},"contents":[{"Add":{"text":" import NotificationBell from '$lib/NotificationBell.svelte';","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2393"}}]}},{"Edit":{"inode":{"change":2,"pos":117811},"path":"ui/src/routes/+layout.svelte","line":23,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":118142}],"down_context":[{"change":7,"pos":4829992}],"flag":"BLOCK","start":2395,"end":2426,"inode":{"change":2,"pos":117811}}},"contents":[{"Add":{"text":" ","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2425"}}]}},{"FileMove":{"meta":{"basename":"2026-07-29-000003-0000_review_grandfathered","metadata":576},"old":[{"basename":"2026-07-29-000002-0000_review_grandfathered","metadata":576}],"up":[{"change":2,"pos":297727}],"down":[{"change":14,"pos":379}],"show_perms":false}},{"FileAdd":{"meta":{"basename":"2026-07-29-000002-0000_change_lineage","metadata":576},"context":[{"change":2,"pos":297727}],"contents":[]}},{"FileAdd":{"meta":{"basename":"up.sql","metadata":0},"context":[{"change":0,"pos":2531}],"contents":[{"Add":{"text":"-- Revision lineage of amended changes, as carried in each change's hashed","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2639"}},{"Add":{"text":"-- metadata (`replaces` / `root`, base32) and recorded here on apply so the change","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2722"}},{"Add":{"text":"-- view can list a logical change's revisions without scanning the changestore.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2802"}},{"Add":{"text":"--","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2805"}},{"Add":{"text":"-- `root` is the stable group id (the original iteration's hash; a change that","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2884"}},{"Add":{"text":"-- replaces nothing is its own root). `replaces` is the immediate predecessor.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:2963"}},{"Add":{"text":"-- Keyed by the origin repo id, matching the per-origin changestore.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3032"}},{"Add":{"text":"CREATE TABLE change_lineage (","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3062"}},{"Add":{"text":" repo_id UUID NOT NULL,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3089"}},{"Add":{"text":" hash TEXT NOT NULL,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3113"}},{"Add":{"text":" root TEXT NOT NULL,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3137"}},{"Add":{"text":" replaces TEXT,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3156"}},{"Add":{"text":" recorded_at TIMESTAMPTZ NOT NULL DEFAULT now(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3208"}},{"Add":{"text":" PRIMARY KEY (repo_id, hash)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3240"}},{"Add":{"text":");","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3243"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3244"}},{"Add":{"text":"CREATE INDEX change_lineage_root ON change_lineage (repo_id, root);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3312"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3313"}},{"Add":{"text":"GRANT ALL PRIVILEGES ON TABLE change_lineage TO pijul;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3368"}}]}},{"FileAdd":{"meta":{"basename":"down.sql","metadata":0},"context":[{"change":0,"pos":2531}],"contents":[{"Add":{"text":"DROP TABLE IF EXISTS change_lineage;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3440"}}]}},{"Replacement":{"inode":{"change":2,"pos":319304},"path":"api/src/ssh.rs","line":850,"ins":{"up_context":[{"change":13,"pos":11302}],"down_context":[{"change":9,"pos":1540}],"flag":"BLOCK","start":3442,"end":3496,"inode":{"change":2,"pos":319304}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":13,"pos":11302},"to":{"change":13,"start":11302,"end":11366},"introduced_by":13}],"inode":{"change":2,"pos":319304}},"ins_contents":[{"Add":{"text":" match crate::push_sig::record_push_signature(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3495"}}],"del_contents":[{"Del":{"text":" if let Err(e) = crate::push_sig::record_push_signature(","pos":"IXMVMCZMQP2DJL3VILNPIJPOM6N7H2Z5DSFEIDCX7NE5CDTKDTTAC:11365"}}]}},{"Replacement":{"inode":{"change":2,"pos":319304},"path":"api/src/ssh.rs","line":862,"ins":{"up_context":[{"change":9,"pos":1714}],"down_context":[{"change":2,"pos":349695}],"flag":"BLOCK","start":3497,"end":5293,"inode":{"change":2,"pos":319304}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":9,"pos":1714},"to":{"change":13,"start":11462,"end":11529},"introduced_by":13}],"inode":{"change":2,"pos":319304}},"ins_contents":[{"Add":{"text":" Err(e) => info!(\"pushsig {} {} rejected: {}\", channel, hash, e),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3573"}},{"Add":{"text":" Ok(_) => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3596"}},{"Add":{"text":" // A stored push signature from a non-author is an approval of the","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3679"}},{"Add":{"text":" // patch — tell its author. (Self-approval is filtered out by the","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3763"}},{"Add":{"text":" // dispatcher's actor == target check.)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3819"}},{"Add":{"text":" let n = self.config.notifier();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3867"}},{"Add":{"text":" let repo_uuid = id.origin_id();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3915"}},{"Add":{"text":" let approver = self.user.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:3965"}},{"Add":{"text":" let approver_id = self.user_id;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4013"}},{"Add":{"text":" let owner = self.owner.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4061"}},{"Add":{"text":" let repo_name = self.repo.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4112"}},{"Add":{"text":" let hash2 = hash.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4154"}},{"Add":{"text":" crate::tracked_spawn(async move {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4204"}},{"Add":{"text":" if let Some(author) = crate::notify::change_author(&n, repo_uuid, &hash2).await {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4306"}},{"Add":{"text":" let short = hash2.get(..10).unwrap_or(&hash2);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4377"}},{"Add":{"text":" let url = format!(\"/{}/{}/change/{}\", owner, repo_name, hash2);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4465"}},{"Add":{"text":" crate::notify::dispatch(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4514"}},{"Add":{"text":" &n,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4546"}},{"Add":{"text":" crate::notify::NEvent {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4598"}},{"Add":{"text":" kind: crate::notify::Kind::PatchApproved,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4672"}},{"Add":{"text":" targets: vec![author],","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4727"}},{"Add":{"text":" actor: approver_id,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4779"}},{"Add":{"text":" title: format!(\"{} approved your patch {}\", approver, short),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4873"}},{"Add":{"text":" url: url.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4923"}},{"Add":{"text":" zulip: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:4971"}},{"Add":{"text":" \"**{}** approved patch [{}]({}{})\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5043"}},{"Add":{"text":" approver, short, n.hostname, url","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5112"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5147"}},{"Add":{"text":" },","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5178"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5204"}},{"Add":{"text":" .await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5236"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5258"}},{"Add":{"text":" });","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5278"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5292"}}],"del_contents":[{"Del":{"text":" info!(\"pushsig {} {} rejected: {}\", channel, hash, e);","pos":"IXMVMCZMQP2DJL3VILNPIJPOM6N7H2Z5DSFEIDCX7NE5CDTKDTTAC:11528"}}]}},{"Edit":{"inode":{"change":2,"pos":319304},"path":"api/src/ssh.rs","line":1373,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":365261}],"down_context":[{"change":2,"pos":365261}],"flag":"BLOCK","start":5294,"end":6618,"inode":{"change":2,"pos":319304}}},"contents":[{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5299"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5300"}},{"Add":{"text":" /// Best-effort: tell the pusher their apply was refused by a change-control","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5381"}},{"Add":{"text":" /// gate. Fire-and-forget so it never blocks (or fails) the SSH path.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5455"}},{"Add":{"text":" fn notify_push_rejected(&self, channel: &str, hash: &pijul_core::Hash, reason: String) {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5548"}},{"Add":{"text":" let Some(pusher) = self.user_id else { return };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5605"}},{"Add":{"text":" let n = self.config.notifier();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5645"}},{"Add":{"text":" let owner = self.owner.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5685"}},{"Add":{"text":" let repo = self.repo.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5723"}},{"Add":{"text":" let channel = channel.to_string();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5766"}},{"Add":{"text":" let hash32 = hash.to_base32();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5805"}},{"Add":{"text":" crate::tracked_spawn(async move {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5847"}},{"Add":{"text":" let short = hash32.get(..10).unwrap_or(&hash32);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5908"}},{"Add":{"text":" let url = format!(\"/{}/{}/change/{}\", owner, repo, hash32);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:5980"}},{"Add":{"text":" crate::notify::dispatch(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6017"}},{"Add":{"text":" &n,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6037"}},{"Add":{"text":" crate::notify::NEvent {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6077"}},{"Add":{"text":" kind: crate::notify::Kind::PushRejected,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6138"}},{"Add":{"text":" targets: vec![pusher],","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6181"}},{"Add":{"text":" actor: None,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6214"}},{"Add":{"text":" title: format!(\"Your push of {short} to {channel} was rejected: {reason}\"),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6310"}},{"Add":{"text":" url: url.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6348"}},{"Add":{"text":" zulip: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6384"}},{"Add":{"text":" \"🚫 Push of [{short}]({}{url}) to `{owner}/{repo}` `{channel}` rejected: {reason}\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6494"}},{"Add":{"text":" n.hostname","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6529"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6552"}},{"Add":{"text":" },","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6571"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6585"}},{"Add":{"text":" .await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6605"}},{"Add":{"text":" });","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6617"}}]}},{"Edit":{"inode":{"change":2,"pos":319304},"path":"api/src/ssh.rs","line":1450,"atom":{"NewVertex":{"up_context":[{"change":13,"pos":13730}],"down_context":[{"change":13,"pos":13730}],"flag":"BLOCK","start":6619,"end":6841,"inode":{"change":2,"pos":319304}}},"contents":[{"Add":{"text":" );","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6645"}},{"Add":{"text":" self.notify_push_rejected(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6696"}},{"Add":{"text":" &c,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6728"}},{"Add":{"text":" &hash,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6763"}},{"Add":{"text":" \"you cannot approve your own patch\".to_string(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6840"}}]}},{"Edit":{"inode":{"change":2,"pos":319304},"path":"api/src/ssh.rs","line":1491,"atom":{"NewVertex":{"up_context":[{"change":13,"pos":15151}],"down_context":[{"change":13,"pos":15151}],"flag":"BLOCK","start":6842,"end":7048,"inode":{"change":2,"pos":319304}}},"contents":[{"Add":{"text":" );","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6864"}},{"Add":{"text":" self.notify_push_rejected(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6911"}},{"Add":{"text":" &c,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6939"}},{"Add":{"text":" &hash,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:6970"}},{"Add":{"text":" format!(\"needs {min_reviews} non-author review(s)\"),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7047"}}]}},{"Edit":{"inode":{"change":2,"pos":319304},"path":"api/src/ssh.rs","line":1532,"atom":{"NewVertex":{"up_context":[{"change":13,"pos":16768}],"down_context":[{"change":13,"pos":16768}],"flag":"BLOCK","start":7049,"end":7271,"inode":{"change":2,"pos":319304}}},"contents":[{"Add":{"text":" self.notify_push_rejected(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7095"}},{"Add":{"text":" &c,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7123"}},{"Add":{"text":" &hash,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7154"}},{"Add":{"text":" format!(\"needs {min_push_signatures} non-author push signature(s)\"),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7247"}},{"Add":{"text":" );","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7270"}}]}},{"Edit":{"inode":{"change":2,"pos":380222},"path":"api/src/settings.rs","line":35,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4866673}],"down_context":[{"change":2,"pos":381186}],"flag":"BLOCK","start":7272,"end":7395,"inode":{"change":2,"pos":380222}}},"contents":[{"Add":{"text":" .route(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7287"}},{"Add":{"text":" \"/notifications\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7317"}},{"Add":{"text":" get(notification_prefs).post(notification_prefs_post),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7384"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7394"}}]}},{"Edit":{"inode":{"change":2,"pos":380222},"path":"api/src/settings.rs","line":742,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":5156}],"down_context":[{"change":2,"pos":391669}],"flag":"BLOCK","start":7396,"end":9636,"inode":{"change":2,"pos":380222}}},"contents":[{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7401"}},{"Add":{"text":" Ok(StatusCode::OK)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7424"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7426"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7427"}},{"Add":{"text":"#[derive(Serialize)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7448"}},{"Add":{"text":"struct NotifPref {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7467"}},{"Add":{"text":" kind: &'static str,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7491"}},{"Add":{"text":" label: &'static str,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7516"}},{"Add":{"text":" email: bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7533"}},{"Add":{"text":" inapp: bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7550"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7552"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7553"}},{"Add":{"text":"#[derive(Serialize)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7574"}},{"Add":{"text":"struct NotifPrefsResponse {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7602"}},{"Add":{"text":" token: Option,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7629"}},{"Add":{"text":" prefs: Vec,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7656"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7658"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7659"}},{"Add":{"text":"/// Per-event communication preferences for the logged-in user. Every kind is","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7737"}},{"Add":{"text":"/// listed; a kind with no stored row defaults to both channels on.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7805"}},{"Add":{"text":"async fn notification_prefs(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7834"}},{"Add":{"text":" State(config): State,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7868"}},{"Add":{"text":" jar: SignedCookieJar,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7894"}},{"Add":{"text":" token: axum_csrf::CsrfToken,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:7927"}},{"Add":{"text":") -> Result<(axum_csrf::CsrfToken, Json), crate::Error> {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8005"}},{"Add":{"text":" use db::notification_prefs::dsl as np;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8048"}},{"Add":{"text":" let uid = get_user_id_strict(&jar)?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8089"}},{"Add":{"text":" let mut db = config.db.get().await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8130"}},{"Add":{"text":" let stored: HashMap = np::notification_prefs","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8201"}},{"Add":{"text":" .filter(np::user_id.eq(uid))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8238"}},{"Add":{"text":" .select((np::kind, np::email, np::inapp))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8288"}},{"Add":{"text":" .get_results::<(String, bool, bool)>(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8342"}},{"Add":{"text":" .await?","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8358"}},{"Add":{"text":" .into_iter()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8379"}},{"Add":{"text":" .map(|(k, e, i)| (k, (e, i)))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8417"}},{"Add":{"text":" .collect();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8437"}},{"Add":{"text":" let prefs = crate::notify::Kind::ALL","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8478"}},{"Add":{"text":" .iter()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8494"}},{"Add":{"text":" .map(|k| {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8513"}},{"Add":{"text":" let (email, inapp) = stored.get(k.as_str()).copied().unwrap_or((true, true));","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8603"}},{"Add":{"text":" NotifPref {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8627"}},{"Add":{"text":" kind: k.as_str(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8661"}},{"Add":{"text":" label: k.label(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8695"}},{"Add":{"text":" email,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8718"}},{"Add":{"text":" inapp,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8741"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8755"}},{"Add":{"text":" })","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8766"}},{"Add":{"text":" .collect();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8786"}},{"Add":{"text":" let resp = NotifPrefsResponse {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8822"}},{"Add":{"text":" token: token.authenticity_token().ok(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8870"}},{"Add":{"text":" prefs,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8885"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8892"}},{"Add":{"text":" Ok((token, Json(resp)))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8920"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8922"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8923"}},{"Add":{"text":"#[derive(Deserialize)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8946"}},{"Add":{"text":"struct NotifPrefForm {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8969"}},{"Add":{"text":" token: String,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:8988"}},{"Add":{"text":" kind: String,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9006"}},{"Add":{"text":" #[serde(default)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9028"}},{"Add":{"text":" email: bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9045"}},{"Add":{"text":" #[serde(default)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9067"}},{"Add":{"text":" inapp: bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9084"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9086"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9087"}},{"Add":{"text":"/// Upsert one event kind's preferences.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9128"}},{"Add":{"text":"async fn notification_prefs_post(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9162"}},{"Add":{"text":" State(config): State,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9196"}},{"Add":{"text":" jar: SignedCookieJar,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9222"}},{"Add":{"text":" token: axum_csrf::CsrfToken,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9255"}},{"Add":{"text":" Form(form): Form,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9292"}},{"Add":{"text":") -> Result {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9332"}},{"Add":{"text":" use db::notification_prefs::dsl as np;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9375"}},{"Add":{"text":" crate::csrf_verify(&token, &form.token)?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9421"}},{"Add":{"text":" let uid = get_user_id_strict(&jar)?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9462"}},{"Add":{"text":" // Only accept known kinds.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9494"}},{"Add":{"text":" if !crate::notify::Kind::ALL","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9527"}},{"Add":{"text":" .iter()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9543"}},{"Add":{"text":" .any(|k| k.as_str() == form.kind)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9585"}},{"Add":{"text":" {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9591"}},{"Add":{"text":" return Err(crate::Error::NotFound);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9635"}}]}},{"Edit":{"inode":{"change":2,"pos":380222},"path":"api/src/settings.rs","line":824,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":391675}],"down_context":[{"change":7,"pos":4879194}],"flag":"BLOCK","start":9637,"end":10078,"inode":{"change":2,"pos":380222}}},"contents":[{"Add":{"text":" let mut db = config.db.get().await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9677"}},{"Add":{"text":" diesel::insert_into(np::notification_prefs)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9725"}},{"Add":{"text":" .values((","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9743"}},{"Add":{"text":" np::user_id.eq(uid),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9776"}},{"Add":{"text":" np::kind.eq(&form.kind),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9813"}},{"Add":{"text":" np::email.eq(form.email),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9851"}},{"Add":{"text":" np::inapp.eq(form.inapp),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9889"}},{"Add":{"text":" ))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9900"}},{"Add":{"text":" .on_conflict((np::user_id, np::kind))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9946"}},{"Add":{"text":" .do_update()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:9967"}},{"Add":{"text":" .set((np::email.eq(form.email), np::inapp.eq(form.inapp)))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10034"}},{"Add":{"text":" .execute(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10060"}},{"Add":{"text":" .await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10077"}}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":24,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":432052}],"down_context":[{"change":2,"pos":432052}],"flag":"BLOCK","start":10079,"end":11184,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10079"}},{"Add":{"text":"/// Change lineage as written by `pijul record --amend` into the change's hashed","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10160"}},{"Add":{"text":"/// `metadata` blob (JSON, base32 hashes). Parsed here with the Nest's own","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10235"}},{"Add":{"text":"/// pijul-core, so we depend only on the stable JSON shape and not on a matching","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10316"}},{"Add":{"text":"/// crate version.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10335"}},{"Add":{"text":"#[derive(Debug, Default, Deserialize)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10374"}},{"Add":{"text":"struct ChangeLineage {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10397"}},{"Add":{"text":" #[serde(default)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10419"}},{"Add":{"text":" replaces: Option,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10449"}},{"Add":{"text":" #[serde(default)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10471"}},{"Add":{"text":" #[allow(dead_code)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10495"}},{"Add":{"text":" root: Option,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10521"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10523"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10524"}},{"Add":{"text":"/// Parse the lineage metadata of `hash`, or the default (all-`None`) if it has","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10604"}},{"Add":{"text":"/// none / isn't ours.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10627"}},{"Add":{"text":"fn read_change_lineage(changes: &C, hash: &pijul_core::Hash) -> ChangeLineage {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10723"}},{"Add":{"text":" changes","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10735"}},{"Add":{"text":" .get_change(hash)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10761"}},{"Add":{"text":" .ok()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10775"}},{"Add":{"text":" .and_then(|c| serde_json::from_slice(&c.hashed.metadata).ok())","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10846"}},{"Add":{"text":" .unwrap_or_default()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10875"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10877"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10878"}},{"Add":{"text":"/// The change that `hash` supersedes, if its metadata names one.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:10944"}},{"Add":{"text":"fn change_replaces(changes: &C, hash: &pijul_core::Hash) -> Option {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11047"}},{"Add":{"text":" read_change_lineage(changes, hash)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11086"}},{"Add":{"text":" .replaces","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11104"}},{"Add":{"text":" .and_then(|s| pijul_core::pristine::Hash::from_base32(s.as_bytes()))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11181"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11183"}}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":61,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":432140}],"down_context":[{"change":6,"pos":38442}],"flag":"BLOCK","start":11185,"end":11222,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":{"text":" notify: crate::notify::Notifier,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11221"}}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":70,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":18803}],"down_context":[{"change":5,"pos":18861}],"flag":"BLOCK","start":11223,"end":11264,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":{"text":" notify: crate::notify::Notifier,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11263"}}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":76,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":18958}],"down_context":[{"change":7,"pos":4901779}],"flag":"BLOCK","start":11265,"end":11285,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":{"text":" notify,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11284"}}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":140,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4902474}],"down_context":[{"change":7,"pos":4902474}],"flag":"BLOCK","start":11286,"end":11723,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":{"text":" // If this apply supersedes another change (`replaces`), the","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11366"}},{"Add":{"text":" // hash we unrecorded is carried out here so it can be logged.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11449"}},{"Add":{"text":" let unrecorded_parent: std::sync::Arc<","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11508"}},{"Add":{"text":" std::sync::Mutex>,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11576"}},{"Add":{"text":" > = std::sync::Arc::new(std::sync::Mutex::new(None));","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11650"}},{"Add":{"text":" let unrecorded_parent2 = unrecorded_parent.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11722"}}]}},{"Replacement":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":154,"ins":{"up_context":[{"change":5,"pos":19820}],"down_context":[{"change":8,"pos":10957}],"flag":"BLOCK","start":11724,"end":11767,"inode":{"change":2,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":19820},"to":{"change":8,"start":10918,"end":10957},"introduced_by":8}],"inode":{"change":2,"pos":431834}},"ins_contents":[{"Add":{"text":" let mut channel_ =","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11766"}}],"del_contents":[{"Del":{"text":" let channel_ =","pos":"66J2FRHA63N4X4CPVLMYADCZRZ3XC5LHGOKYXC6SOKG7DNVBIOTQC:10956"}}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":156,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":11050}],"down_context":[{"change":5,"pos":19900}],"flag":"BLOCK","start":11768,"end":13598,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11768"}},{"Add":{"text":" // Replace-aware apply: if this change supersedes another","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11850"}},{"Add":{"text":" // that is on this channel, unrecord that one first — in","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:11933"}},{"Add":{"text":" // the SAME txn, so the pair is atomic (any failure drops","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12015"}},{"Add":{"text":" // the txn and leaves the channel untouched). If the","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12092"}},{"Add":{"text":" // superseded change isn't here (the common","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12160"}},{"Add":{"text":" // amend-without-pushing case), it's a no-op; the apply","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12240"}},{"Add":{"text":" // proceeds and any resulting coexistence surfaces","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12315"}},{"Add":{"text":" // downstream as a conflict.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12368"}},{"Add":{"text":" if let Some(parent) = change_replaces(&repo_.changes, &hash) {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12455"}},{"Add":{"text":" let mut touched = pijul_core::unrecord::TouchedInodes::default();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12549"}},{"Add":{"text":" match txn_.unrecord(&repo_.changes, &mut channel_, &parent, 0, &mut touched)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12654"}},{"Add":{"text":" {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12684"}},{"Add":{"text":" Ok(_) => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12727"}},{"Add":{"text":" debug!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12771"}},{"Add":{"text":" \"replace: unrecorded {:?}, superseded by {:?}\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12859"}},{"Add":{"text":" parent, hash","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12912"}},{"Add":{"text":" );","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:12951"}},{"Add":{"text":" *unrecorded_parent2.lock().unwrap() = Some(parent);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13039"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13073"}},{"Add":{"text":" Err(pijul_core::UnrecordError::ChangeNotInChannel { .. }) => {}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13169"}},{"Add":{"text":" Err(e) => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13213"}},{"Add":{"text":" error!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13257"}},{"Add":{"text":" \"replace: cannot unrecord {:?} ({:?}); rejecting {:?}\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13353"}},{"Add":{"text":" parent, e, hash","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13409"}},{"Add":{"text":" );","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13448"}},{"Add":{"text":" return Err(e.into());","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13506"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13540"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13570"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13596"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13597"}}]}},{"Edit":{"inode":{"change":2,"pos":431834},"path":"api/src/replication.rs","line":258,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4904457}],"down_context":[{"change":7,"pos":4904457}],"flag":"BLOCK","start":13599,"end":18729,"inode":{"change":2,"pos":431834}}},"contents":[{"Add":{"text":" // Record this change's lineage so the change view can","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13677"}},{"Add":{"text":" // list a logical change's revisions by `root`. A change","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13758"}},{"Add":{"text":" // with no lineage metadata is its own root.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13827"}},{"Add":{"text":" {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13853"}},{"Add":{"text":" let repo_l = s.locks.get(&repo).await.unwrap();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:13929"}},{"Add":{"text":" let lineage = read_change_lineage(&repo_l.changes, &hash);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14016"}},{"Add":{"text":" let root = lineage.root.unwrap_or_else(|| hash.to_base32());","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14105"}},{"Add":{"text":" use crate::db::change_lineage::dsl as cl;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14175"}},{"Add":{"text":" diesel::insert_into(cl::change_lineage)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14243"}},{"Add":{"text":" .values((","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14285"}},{"Add":{"text":" cl::repo_id.eq(repo),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14343"}},{"Add":{"text":" cl::hash.eq(hash.to_base32()),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14410"}},{"Add":{"text":" cl::root.eq(root),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14465"}},{"Add":{"text":" cl::replaces.eq(lineage.replaces),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14536"}},{"Add":{"text":" ))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14571"}},{"Add":{"text":" .on_conflict((cl::repo_id, cl::hash))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14641"}},{"Add":{"text":" .do_nothing()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14687"}},{"Add":{"text":" .execute(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14737"}},{"Add":{"text":" .await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14778"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14804"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14805"}},{"Add":{"text":" // Record the supersession so the audit trail and the","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14883"}},{"Add":{"text":" // change-view revision list can see it. The superseded","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:14963"}},{"Add":{"text":" // change's file is retained by the GC gate if it has","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15041"}},{"Add":{"text":" // reviews.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15077"}},{"Add":{"text":" let replaced_parent = unrecorded_parent.lock().unwrap().take();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15165"}},{"Add":{"text":" if let Some(parent) = replaced_parent {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15229"}},{"Add":{"text":" diesel::insert_into(ce::channel_events)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15297"}},{"Add":{"text":" .values((","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15339"}},{"Add":{"text":" ce::repo_id.eq(repo),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15397"}},{"Add":{"text":" ce::channel.eq(&channel),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15459"}},{"Add":{"text":" ce::hash.eq(parent.to_base32()),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15528"}},{"Add":{"text":" ce::operation.eq(\"replaced\"),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15594"}},{"Add":{"text":" ce::pushed_by.eq(pushed_by),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15659"}},{"Add":{"text":" ))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15694"}},{"Add":{"text":" .execute(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15744"}},{"Add":{"text":" .await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15785"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15786"}},{"Add":{"text":" // Tell everyone who reviewed the superseded patch that","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15870"}},{"Add":{"text":" // a new revision landed and is ready to re-review.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:15950"}},{"Add":{"text":" // Metadata + link only — never the review text.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16029"}},{"Add":{"text":" let names = {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16071"}},{"Add":{"text":" use crate::db::repositories::dsl as r;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16142"}},{"Add":{"text":" use crate::db::users::dsl as u;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16206"}},{"Add":{"text":" r::repositories","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16254"}},{"Add":{"text":" .find(repo)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16302"}},{"Add":{"text":" .inner_join(u::users)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16360"}},{"Add":{"text":" .select((u::login, r::name))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16425"}},{"Add":{"text":" .get_result::<(String, String)>(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16502"}},{"Add":{"text":" .await","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16545"}},{"Add":{"text":" .ok()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16587"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16618"}},{"Add":{"text":" if let Some((owner, repo_name)) = names {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16688"}},{"Add":{"text":" let n = s.notify.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16746"}},{"Add":{"text":" let parent32 = parent.to_base32();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16813"}},{"Add":{"text":" let new32 = hash.to_base32();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16875"}},{"Add":{"text":" crate::tracked_spawn(async move {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16941"}},{"Add":{"text":" let targets =","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:16991"}},{"Add":{"text":" crate::notify::reviewers(&n, repo, &parent32).await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17084"}},{"Add":{"text":" if targets.is_empty() {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17144"}},{"Add":{"text":" return;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17192"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17230"}},{"Add":{"text":" let short = parent32.get(..10).unwrap_or(&parent32);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17319"}},{"Add":{"text":" let new_short = new32.get(..10).unwrap_or(&new32);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17406"}},{"Add":{"text":" let url =","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17452"}},{"Add":{"text":" format!(\"/{}/{}/change/{}\", owner, repo_name, new32);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17546"}},{"Add":{"text":" crate::notify::dispatch(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17607"}},{"Add":{"text":" &n,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17651"}},{"Add":{"text":" crate::notify::NEvent {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17715"}},{"Add":{"text":" kind: crate::notify::Kind::PatchReplaced,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17801"}},{"Add":{"text":" targets,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17854"}},{"Add":{"text":" actor: pushed_by,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17916"}},{"Add":{"text":" title: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:17976"}},{"Add":{"text":" \"Patch {short} you reviewed was replaced by {new_short} — ready to re-review\"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18104"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18151"}},{"Add":{"text":" url: url.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18213"}},{"Add":{"text":" zulip: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18273"}},{"Add":{"text":" \"Patch `{short}` was replaced by [{new_short}]({}{}) — ready to re-review\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18399"}},{"Add":{"text":" n.hostname, url","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18463"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18510"}},{"Add":{"text":" },","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18553"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18591"}},{"Add":{"text":" .await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18635"}},{"Add":{"text":" });","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18671"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18701"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18727"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18728"}}]}},{"Edit":{"inode":{"change":2,"pos":452154},"path":"api/src/main.rs","line":60,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4922343}],"down_context":[{"change":2,"pos":453006}],"flag":"BLOCK","start":18730,"end":18742,"inode":{"change":2,"pos":452154}}},"contents":[{"Add":{"text":"mod notify;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18741"}}]}},{"Replacement":{"inode":{"change":2,"pos":452154},"path":"api/src/main.rs","line":130,"ins":{"up_context":[{"change":7,"pos":4922914}],"down_context":[{"change":2,"pos":454517}],"flag":"BLOCK","start":18743,"end":18939,"inode":{"change":2,"pos":452154}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4922914},"to":{"change":7,"start":4922914,"end":4923012},"introduced_by":7}],"inode":{"change":2,"pos":452154}},"ins_contents":[{"Add":{"text":" crate::replication::H::new(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18782"}},{"Add":{"text":" config.ci.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18817"}},{"Add":{"text":" repo_locks.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18853"}},{"Add":{"text":" config.db.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18888"}},{"Add":{"text":" config.notifier(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18923"}},{"Add":{"text":" );","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18938"}}],"del_contents":[{"Del":{"text":" crate::replication::H::new(config.ci.clone(), repo_locks.clone(), config.db.clone());","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4923011"}}]}},{"Edit":{"inode":{"change":2,"pos":452154},"path":"api/src/main.rs","line":232,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":8602}],"down_context":[{"change":7,"pos":4924484}],"flag":"BLOCK","start":18940,"end":19190,"inode":{"change":2,"pos":452154}}},"contents":[{"Add":{"text":" #[cfg(feature = \"jobs\")]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:18968"}},{"Add":{"text":" tokio::spawn(jobs::job_notify_watcher(Config {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19019"}},{"Add":{"text":" config: config.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19051"}},{"Add":{"text":" repo_locks: repo_locks.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19091"}},{"Add":{"text":" replicator: replicator.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19131"}},{"Add":{"text":" sse_task_count: sse_task_count.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19179"}},{"Add":{"text":" }));","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19188"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19189"}}]}},{"Edit":{"inode":{"change":2,"pos":452154},"path":"api/src/main.rs","line":251,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4924800}],"down_context":[{"change":7,"pos":4924800}],"flag":"BLOCK","start":19191,"end":19488,"inode":{"change":2,"pos":452154}}},"contents":[{"Add":{"text":" let user_updates = config.user_updates.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19246"}},{"Add":{"text":" async move {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19267"}},{"Add":{"text":" loop {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19286"}},{"Add":{"text":" tokio::time::sleep(std::time::Duration::from_secs(300)).await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19365"}},{"Add":{"text":" user_updates.retain(|_, tx| tx.receiver_count() > 0);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19435"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19449"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19459"}},{"Add":{"text":" });","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19467"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19468"}},{"Add":{"text":" tokio::spawn({","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19487"}}]}},{"Edit":{"inode":{"change":2,"pos":452154},"path":"api/src/main.rs","line":451,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4928260}],"down_context":[{"change":7,"pos":4928260}],"flag":"BLOCK","start":19489,"end":19539,"inode":{"change":2,"pos":452154}}},"contents":[{"Add":{"text":" .nest(\"/notifications\", notify::router())","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19538"}}]}},{"Edit":{"inode":{"change":5,"pos":32096},"path":"api/src/jobs.rs","line":1008,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4953904}],"down_context":[{"change":5,"pos":37148}],"flag":"BLOCK","start":19540,"end":21309,"inode":{"change":5,"pos":32096}}},"contents":[{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19540"}},{"Add":{"text":"/// Background notifier for finished CI jobs. A job's final status can be written","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19622"}},{"Add":{"text":"/// by the main process (build / build-only via `status`) OR by the detached","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19699"}},{"Add":{"text":"/// deploy runner in a separate process that can't reach the in-process SSE map.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19780"}},{"Add":{"text":"/// So a single main-process loop polls finished-but-unnotified jobs and notifies","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19862"}},{"Add":{"text":"/// exactly once (guarded by `jobs.notified`), covering both paths uniformly and","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:19943"}},{"Add":{"text":"/// from the process where SSE presence is meaningful. One event per job outcome","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20024"}},{"Add":{"text":"/// — plus a separate scan-findings event when a scan report is non-empty — so a","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20109"}},{"Add":{"text":"/// failure and its later rollback never double-notify.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20165"}},{"Add":{"text":"pub async fn job_notify_watcher(config: Config) {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20215"}},{"Add":{"text":" use crate::db::jobs::dsl as jobs;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20253"}},{"Add":{"text":" loop {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20264"}},{"Add":{"text":" tokio::time::sleep(Duration::from_secs(15)).await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20323"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20324"}},{"Add":{"text":" let rows: Vec<(uuid::Uuid, uuid::Uuid, String, Option, Option, bool)> = {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20419"}},{"Add":{"text":" let mut db = match config.db.get().await {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20474"}},{"Add":{"text":" Ok(d) => d,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20502"}},{"Add":{"text":" Err(_) => continue,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20538"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20553"}},{"Add":{"text":" match jobs::jobs","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20582"}},{"Add":{"text":" .filter(jobs::ended.is_not_null())","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20633"}},{"Add":{"text":" .filter(jobs::status.is_not_null())","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20685"}},{"Add":{"text":" .filter(jobs::notified.eq(false))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20735"}},{"Add":{"text":" .order_by(jobs::ended.asc())","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20780"}},{"Add":{"text":" .select((","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20806"}},{"Add":{"text":" jobs::id,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20836"}},{"Add":{"text":" jobs::repo,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20868"}},{"Add":{"text":" jobs::channel,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20903"}},{"Add":{"text":" jobs::status,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20937"}},{"Add":{"text":" jobs::scan_report,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:20976"}},{"Add":{"text":" jobs::rolled_back,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21015"}},{"Add":{"text":" ))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21034"}},{"Add":{"text":" .get_results(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21072"}},{"Add":{"text":" .await","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21095"}},{"Add":{"text":" {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21109"}},{"Add":{"text":" Ok(v) => v,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21137"}},{"Add":{"text":" Err(e) => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21165"}},{"Add":{"text":" error!(\"job_notify_watcher query failed: {e:?}\");","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21235"}},{"Add":{"text":" continue;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21265"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21283"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21297"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21308"}}]}},{"Edit":{"inode":{"change":5,"pos":32096},"path":"api/src/jobs.rs","line":1051,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":37149}],"down_context":[{"change":7,"pos":4953905}],"flag":"BLOCK","start":21310,"end":26163,"inode":{"change":5,"pos":32096}}},"contents":[{"Add":{"text":" for (id, repo, channel, status, scan_report, rolled_back) in rows {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21385"}},{"Add":{"text":" if let Err(e) = notify_job_outcome(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21433"}},{"Add":{"text":" &config,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21458"}},{"Add":{"text":" id,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21478"}},{"Add":{"text":" repo,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21500"}},{"Add":{"text":" &channel,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21526"}},{"Add":{"text":" status,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21550"}},{"Add":{"text":" scan_report.as_deref(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21590"}},{"Add":{"text":" rolled_back,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21619"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21633"}},{"Add":{"text":" .await","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21652"}},{"Add":{"text":" {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21666"}},{"Add":{"text":" // Losing one notification is better than re-notifying every 15s","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21747"}},{"Add":{"text":" // forever (e.g. the repo was deleted): mark it done regardless.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21828"}},{"Add":{"text":" error!(\"notify_job_outcome {id} failed: {e:?}\");","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21893"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21907"}},{"Add":{"text":" let mut db = match config.db.get().await {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21962"}},{"Add":{"text":" Ok(d) => d,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:21990"}},{"Add":{"text":" Err(_) => continue,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22026"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22041"}},{"Add":{"text":" let _ = diesel::update(jobs::jobs.find(id))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22097"}},{"Add":{"text":" .set(jobs::notified.eq(true))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22143"}},{"Add":{"text":" .execute(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22177"}},{"Add":{"text":" .await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22201"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22211"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22217"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22219"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22220"}},{"Add":{"text":"/// Build and send the notification(s) for one finished job. Metadata + link","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22297"}},{"Add":{"text":"/// only — never build logs or patch text.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22342"}},{"Add":{"text":"async fn notify_job_outcome(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22371"}},{"Add":{"text":" config: &Config,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22392"}},{"Add":{"text":" id: uuid::Uuid,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22412"}},{"Add":{"text":" repo: uuid::Uuid,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22434"}},{"Add":{"text":" channel: &str,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22453"}},{"Add":{"text":" status: Option,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22478"}},{"Add":{"text":" scan_report: Option<&str>,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22509"}},{"Add":{"text":" rolled_back: bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22532"}},{"Add":{"text":") -> Result<(), crate::Error> {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22564"}},{"Add":{"text":" use crate::db::repositories::dsl as repositories;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22618"}},{"Add":{"text":" use crate::db::users::dsl as users;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22658"}},{"Add":{"text":" let (owner, repo_name): (String, String) = {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22707"}},{"Add":{"text":" let mut db = config.db.get().await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22752"}},{"Add":{"text":" repositories::repositories","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22787"}},{"Add":{"text":" .find(repo)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22811"}},{"Add":{"text":" .inner_join(users::users)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22849"}},{"Add":{"text":" .select((users::login, repositories::name))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22905"}},{"Add":{"text":" .get_result(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22938"}},{"Add":{"text":" .await?","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22958"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22965"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22966"}},{"Add":{"text":" let n = config.notifier();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:22997"}},{"Add":{"text":" // The last pusher on this channel is who the outcome most concerns. Anyone","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23077"}},{"Add":{"text":" // watching the job page already sees it live; this reaches them off-page","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23155"}},{"Add":{"text":" // (bell if online, email if not). Zulip is posted regardless of targets.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23233"}},{"Add":{"text":" let targets: Vec = crate::notify::last_pusher(&n, repo, channel)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23314"}},{"Add":{"text":" .await","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23329"}},{"Add":{"text":" .into_iter()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23350"}},{"Add":{"text":" .collect();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23370"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23371"}},{"Add":{"text":" let ids = id.to_string();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23401"}},{"Add":{"text":" let short = ids.get(..8).unwrap_or(&ids);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23447"}},{"Add":{"text":" let url = format!(\"/{}/{}/jobs/{}\", owner, repo_name, id);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23510"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23511"}},{"Add":{"text":" match status {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23530"}},{"Add":{"text":" Some(0) => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23551"}},{"Add":{"text":" crate::notify::dispatch(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23588"}},{"Add":{"text":" &n,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23608"}},{"Add":{"text":" crate::notify::NEvent {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23648"}},{"Add":{"text":" kind: crate::notify::Kind::JobCompleted,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23709"}},{"Add":{"text":" targets: targets.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23755"}},{"Add":{"text":" actor: None,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23788"}},{"Add":{"text":" title: format!(\"CI job succeeded on {owner}/{repo_name} ({channel})\"),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23879"}},{"Add":{"text":" url: url.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23917"}},{"Add":{"text":" zulip: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:23953"}},{"Add":{"text":" \"✅ CI job [{short}]({}{url}) on `{owner}/{repo_name}` `{channel}` succeeded\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24057"}},{"Add":{"text":" n.hostname","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24092"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24115"}},{"Add":{"text":" },","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24134"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24148"}},{"Add":{"text":" .await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24168"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24178"}},{"Add":{"text":" // 137 = 128 + SIGKILL: a manual kill, not a real outcome.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24245"}},{"Add":{"text":" Some(137) => {}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24269"}},{"Add":{"text":" Some(code) => {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24293"}},{"Add":{"text":" let extra = if rolled_back {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24334"}},{"Add":{"text":" \" — channel rolled back to last green\"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24391"}},{"Add":{"text":" } else {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24412"}},{"Add":{"text":" \"\"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24431"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24446"}},{"Add":{"text":" crate::notify::dispatch(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24483"}},{"Add":{"text":" &n,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24503"}},{"Add":{"text":" crate::notify::NEvent {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24543"}},{"Add":{"text":" kind: crate::notify::Kind::JobFailed,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24601"}},{"Add":{"text":" targets: targets.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24647"}},{"Add":{"text":" actor: None,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24680"}},{"Add":{"text":" title: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24716"}},{"Add":{"text":" \"CI job failed on {owner}/{repo_name} ({channel}) — exit {code}{extra}\"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24814"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24837"}},{"Add":{"text":" url: url.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24875"}},{"Add":{"text":" zulip: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:24911"}},{"Add":{"text":" \"❌ CI job [{short}]({}{url}) on `{owner}/{repo_name}` `{channel}` failed (exit {code}){extra}\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25033"}},{"Add":{"text":" n.hostname","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25068"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25091"}},{"Add":{"text":" },","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25110"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25124"}},{"Add":{"text":" .await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25144"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25154"}},{"Add":{"text":" None => {}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25173"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25179"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25180"}},{"Add":{"text":" // A non-empty scan report means the security scan surfaced findings. This is","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25262"}},{"Add":{"text":" // a distinct cause from the pass/fail outcome, so it's its own event.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25337"}},{"Add":{"text":" if let Some(rep) = scan_report {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25374"}},{"Add":{"text":" let t = rep.trim();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25402"}},{"Add":{"text":" if !t.is_empty() && t != \"[]\" && t != \"{}\" {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25455"}},{"Add":{"text":" crate::notify::dispatch(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25492"}},{"Add":{"text":" &n,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25512"}},{"Add":{"text":" crate::notify::NEvent {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25552"}},{"Add":{"text":" kind: crate::notify::Kind::ScanVuln,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25609"}},{"Add":{"text":" targets,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25638"}},{"Add":{"text":" actor: None,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25671"}},{"Add":{"text":" title: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25707"}},{"Add":{"text":" \"Security scan found findings on {owner}/{repo_name} ({channel})\"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25797"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25820"}},{"Add":{"text":" url: url.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25858"}},{"Add":{"text":" zulip: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:25894"}},{"Add":{"text":" \"⚠️ Security scan on job [{short}]({}{url}) `{owner}/{repo_name}` `{channel}` reported findings\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26020"}},{"Add":{"text":" n.hostname","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26055"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26078"}},{"Add":{"text":" },","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26097"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26111"}},{"Add":{"text":" .await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26131"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26141"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26147"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26148"}},{"Add":{"text":" Ok(())","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26159"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26161"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26162"}}]}},{"Replacement":{"inode":{"change":2,"pos":487675},"path":"api/src/discussions/mod.rs","line":132,"ins":{"up_context":[{"change":7,"pos":4972707}],"down_context":[{"change":2,"pos":489017}],"flag":"BLOCK","start":26164,"end":26238,"inode":{"change":2,"pos":487675}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4972707},"to":{"change":7,"start":4972707,"end":4973245},"introduced_by":7}],"inode":{"change":2,"pos":487675}},"ins_contents":[{"Add":{"text":" crate::notify::zulip(&config.notifier(), &subject, &zulip_msg).await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26237"}}],"del_contents":[{"Del":{"text":" zulip_notify(config, &subject, &zulip_msg).await;","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4972760"}},{"Del":{"text":"}","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4972762"}},{"Del":{"text":"","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4972763"}},{"Del":{"text":"async fn zulip_notify(config: &Config, topic: &str, message: &str) {","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4972832"}},{"Del":{"text":" let Some(ref z) = config.zulip else { return };","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4972884"}},{"Del":{"text":" let client = reqwest::Client::new();","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4972925"}},{"Del":{"text":" let _ = client","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4972944"}},{"Del":{"text":" .post(format!(\"{}/api/v1/messages\", z.site))","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4972997"}},{"Del":{"text":" .basic_auth(&z.bot_email, Some(&z.api_key))","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973049"}},{"Del":{"text":" .form(&[","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973066"}},{"Del":{"text":" (\"type\", \"stream\"),","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973098"}},{"Del":{"text":" (\"to\", z.stream.as_str()),","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973137"}},{"Del":{"text":" (\"topic\", topic),","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973167"}},{"Del":{"text":" (\"content\", message),","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973201"}},{"Del":{"text":" ])","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973212"}},{"Del":{"text":" .send()","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973228"}},{"Del":{"text":" .await;","pos":"AX7NN2MQXFV32SW32M2NKYGSLA775AWFIWUWX3R5YAMPG32HMZMQC:4973244"}}]}},{"Edit":{"inode":{"change":2,"pos":521565},"path":"api/src/db.rs","line":14,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4991430}],"down_context":[{"change":2,"pos":521972}],"flag":"BLOCK","start":26239,"end":26539,"inode":{"change":2,"pos":521565}}},"contents":[{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26244"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26246"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26247"}},{"Add":{"text":"diesel::table! {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26264"}},{"Add":{"text":" use diesel::sql_types::*;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26294"}},{"Add":{"text":" use diesel::pg::sql_types::*;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26328"}},{"Add":{"text":" use crate::{Keyalgorithm};","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26359"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26360"}},{"Add":{"text":" change_lineage (repo_id, hash) {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26397"}},{"Add":{"text":" repo_id -> Uuid,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26422"}},{"Add":{"text":" hash -> Text,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26444"}},{"Add":{"text":" root -> Text,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26466"}},{"Add":{"text":" replaces -> Nullable,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26502"}},{"Add":{"text":" recorded_at -> Timestamptz,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26538"}}]}},{"Edit":{"inode":{"change":2,"pos":521565},"path":"api/src/db.rs","line":80,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4992332},"to":{"change":10,"start":54752,"end":54788},"introduced_by":10}],"inode":{"change":2,"pos":521565}}},"contents":[{"Del":{"text":" position -> Nullable,","pos":"EG3MNPQXLNF62UQAP3342JC4OL47MAUCYJM6Q4G7BVVBM2VXMDCAC:54787"}}]}},{"Edit":{"inode":{"change":2,"pos":521565},"path":"api/src/db.rs","line":202,"atom":{"NewVertex":{"up_context":[{"change":12,"pos":31151}],"down_context":[{"change":2,"pos":524564}],"flag":"BLOCK","start":26540,"end":26566,"inode":{"change":2,"pos":521565}}},"contents":[{"Add":{"text":" notified -> Bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26565"}}]}},{"Edit":{"inode":{"change":2,"pos":521565},"path":"api/src/db.rs","line":211,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":524686}],"down_context":[{"change":2,"pos":524686}],"flag":"BLOCK","start":26567,"end":27189,"inode":{"change":2,"pos":521565}}},"contents":[{"Add":{"text":" notification_prefs (user_id, kind) {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26607"}},{"Add":{"text":" user_id -> Uuid,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26632"}},{"Add":{"text":" kind -> Text,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26654"}},{"Add":{"text":" email -> Bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26677"}},{"Add":{"text":" inapp -> Bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26700"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26706"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26708"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26709"}},{"Add":{"text":"diesel::table! {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26726"}},{"Add":{"text":" use diesel::sql_types::*;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26756"}},{"Add":{"text":" use diesel::pg::sql_types::*;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26790"}},{"Add":{"text":" use crate::{Keyalgorithm};","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26821"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26822"}},{"Add":{"text":" notifications (id) {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26847"}},{"Add":{"text":" id -> Uuid,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26867"}},{"Add":{"text":" user_id -> Uuid,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26892"}},{"Add":{"text":" kind -> Text,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26914"}},{"Add":{"text":" title -> Text,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26937"}},{"Add":{"text":" url -> Text,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26958"}},{"Add":{"text":" via -> Nullable,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:26989"}},{"Add":{"text":" created_at -> Timestamptz,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27024"}},{"Add":{"text":" read_at -> Nullable,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27066"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27072"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27074"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27075"}},{"Add":{"text":"diesel::table! {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27092"}},{"Add":{"text":" use diesel::sql_types::*;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27122"}},{"Add":{"text":" use diesel::pg::sql_types::*;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27156"}},{"Add":{"text":" use crate::{Keyalgorithm};","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27187"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27188"}}]}},{"Edit":{"inode":{"change":2,"pos":521565},"path":"api/src/db.rs","line":480,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":42708}],"down_context":[{"change":7,"pos":4993493}],"flag":"BLOCK","start":27190,"end":27301,"inode":{"change":2,"pos":521565}}},"contents":[{"Add":{"text":"diesel::joinable!(notification_prefs -> users (user_id));","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27247"}},{"Add":{"text":"diesel::joinable!(notifications -> users (user_id));","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27300"}}]}},{"Edit":{"inode":{"change":2,"pos":521565},"path":"api/src/db.rs","line":500,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4993637}],"down_context":[{"change":7,"pos":4993637}],"flag":"BLOCK","start":27302,"end":27322,"inode":{"change":2,"pos":521565}}},"contents":[{"Add":{"text":" change_lineage,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27321"}}]}},{"Edit":{"inode":{"change":2,"pos":521565},"path":"api/src/db.rs","line":511,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":42719}],"down_context":[{"change":2,"pos":529610}],"flag":"BLOCK","start":27323,"end":27366,"inode":{"change":2,"pos":521565}}},"contents":[{"Add":{"text":" notification_prefs,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27346"}},{"Add":{"text":" notifications,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27365"}}]}},{"Edit":{"inode":{"change":2,"pos":532759},"path":"api/src/config.rs","line":64,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4994803}],"down_context":[{"change":2,"pos":535282}],"flag":"BLOCK","start":27367,"end":28264,"inode":{"change":2,"pos":532759}}},"contents":[{"Add":{"text":" /// Per-user site-wide notification channels. A user gets an entry while they","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27448"}},{"Add":{"text":" /// have at least one open notification SSE tab; presence (receiver_count > 0)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27531"}},{"Add":{"text":" /// is how the notifier decides SSE-vs-email delivery.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27590"}},{"Add":{"text":" pub user_updates: Arc<","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27617"}},{"Add":{"text":" dashmap::DashMap>,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27716"}},{"Add":{"text":" >,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27723"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27725"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27726"}},{"Add":{"text":"impl Config {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27740"}},{"Add":{"text":" /// A cheap, self-contained handle for the notification layer (Zulip + SSE +","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27821"}},{"Add":{"text":" /// email), so components without the full `Config` can still notify.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27895"}},{"Add":{"text":" pub fn notifier(&self) -> crate::notify::Notifier {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27951"}},{"Add":{"text":" crate::notify::Notifier {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:27985"}},{"Add":{"text":" db: self.db.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28018"}},{"Add":{"text":" zulip: self.zulip.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28057"}},{"Add":{"text":" email: self.email.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28096"}},{"Add":{"text":" email_source: self.email_source.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28149"}},{"Add":{"text":" hostname: self.hostname.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28194"}},{"Add":{"text":" user_updates: self.user_updates.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28247"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28257"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28263"}}]}},{"Edit":{"inode":{"change":2,"pos":532759},"path":"api/src/config.rs","line":209,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4995885}],"down_context":[{"change":2,"pos":542913}],"flag":"BLOCK","start":28265,"end":28322,"inode":{"change":2,"pos":532759}}},"contents":[{"Add":{"text":" user_updates: Arc::new(dashmap::DashMap::new()),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28321"}}]}},{"FileAdd":{"meta":{"basename":"revisions.rs","metadata":0},"context":[{"change":2,"pos":548910}],"contents":[{"Add":{"text":"//! Revisions of a logical change — every iteration that shares the same `root`","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28442"}},{"Add":{"text":"//! (see [`crate::db::change_lineage`]), so the change view can show a patch's","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28521"}},{"Add":{"text":"//! amend history and link between iterations. Lineage is keyed by the origin","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28599"}},{"Add":{"text":"//! repo id (the per-origin changestore), so we resolve the origin first.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28673"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28674"}},{"Add":{"text":"use crate::Config;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28693"}},{"Add":{"text":"use crate::permissions::Perm;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28723"}},{"Add":{"text":"use axum::{","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28735"}},{"Add":{"text":" Json, debug_handler,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28760"}},{"Add":{"text":" extract::{Path, State},","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28788"}},{"Add":{"text":"};","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28791"}},{"Add":{"text":"use axum_extra::extract::SignedCookieJar;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28833"}},{"Add":{"text":"use diesel::prelude::*;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28857"}},{"Add":{"text":"use diesel_async::RunQueryDsl;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28888"}},{"Add":{"text":"use serde_derive::*;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28909"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28910"}},{"Add":{"text":"#[derive(Debug, Deserialize)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28940"}},{"Add":{"text":"pub struct RevisionsPath {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28967"}},{"Add":{"text":" hash: String,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28985"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28987"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:28988"}},{"Add":{"text":"#[derive(Debug, Serialize)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29016"}},{"Add":{"text":"pub struct Revision {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29038"}},{"Add":{"text":" hash: String,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29056"}},{"Add":{"text":" date: i64,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29071"}},{"Add":{"text":" /// The change currently being viewed.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29114"}},{"Add":{"text":" current: bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29133"}},{"Add":{"text":" /// Superseded by a later iteration (some revision `replaces` this one).","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29210"}},{"Add":{"text":" superseded: bool,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29232"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29234"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29235"}},{"Add":{"text":"#[derive(Debug, Serialize)]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29263"}},{"Add":{"text":"pub struct RevisionsResponse {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29294"}},{"Add":{"text":" /// Oldest → newest. Empty when the change has no known siblings (so the UI","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29376"}},{"Add":{"text":" /// shows nothing for ordinary, never-amended patches).","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29436"}},{"Add":{"text":" revisions: Vec,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29466"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29468"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29469"}},{"Add":{"text":"#[debug_handler]","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29486"}},{"Add":{"text":"pub async fn revisions(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29510"}},{"Add":{"text":" State(config): State,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29544"}},{"Add":{"text":" jar: SignedCookieJar,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29570"}},{"Add":{"text":" repo: crate::repository::RepoPath,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29609"}},{"Add":{"text":" Path(p): Path,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29643"}},{"Add":{"text":") -> Result, crate::Error> {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29696"}},{"Add":{"text":" let (uid, _login) = crate::get_user_login_(&jar, &config).await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29766"}},{"Add":{"text":" let mut db = config.db.get().await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29807"}},{"Add":{"text":" let (id, _, _) =","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29828"}},{"Add":{"text":" crate::repository::repository_id(&mut db, &repo.owner, &repo.repo, uid, Perm::READ).await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29928"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29929"}},{"Add":{"text":" // Lineage lives under the origin (the per-origin changestore).","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:29997"}},{"Add":{"text":" let origin: uuid::Uuid = {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30028"}},{"Add":{"text":" use crate::db::repositories::dsl as r;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30075"}},{"Add":{"text":" r::repositories","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30099"}},{"Add":{"text":" .find(id)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30121"}},{"Add":{"text":" .select(r::fork_origin)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30157"}},{"Add":{"text":" .get_result::>(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30212"}},{"Add":{"text":" .await?","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30232"}},{"Add":{"text":" .unwrap_or(id)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30259"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30266"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30267"}},{"Add":{"text":" use crate::db::change_lineage::dsl as cl;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30313"}},{"Add":{"text":" let Some(root): Option = cl::change_lineage","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30369"}},{"Add":{"text":" .filter(cl::repo_id.eq(origin))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30409"}},{"Add":{"text":" .filter(cl::hash.eq(&p.hash))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30447"}},{"Add":{"text":" .select(cl::root)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30473"}},{"Add":{"text":" .get_result::(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30512"}},{"Add":{"text":" .await","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30527"}},{"Add":{"text":" .optional()?","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30548"}},{"Add":{"text":" else {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30559"}},{"Add":{"text":" return Ok(Json(RevisionsResponse { revisions: vec![] }));","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30625"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30632"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30633"}},{"Add":{"text":" let rows: Vec<(String, Option, chrono::DateTime)> = cl::change_lineage","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30729"}},{"Add":{"text":" .filter(cl::repo_id.eq(origin))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30769"}},{"Add":{"text":" .filter(cl::root.eq(&root))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30805"}},{"Add":{"text":" .select((cl::hash, cl::replaces, cl::recorded_at))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30864"}},{"Add":{"text":" .order_by(cl::recorded_at.asc())","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30905"}},{"Add":{"text":" .get_results(&mut db)","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30935"}},{"Add":{"text":" .await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30952"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:30953"}},{"Add":{"text":" // Nothing interesting to show for a lone, never-amended change.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31022"}},{"Add":{"text":" if rows.len() <= 1 {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31047"}},{"Add":{"text":" return Ok(Json(RevisionsResponse { revisions: vec![] }));","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31113"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31119"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31120"}},{"Add":{"text":" let superseded: std::collections::HashSet = rows","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31181"}},{"Add":{"text":" .iter()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31197"}},{"Add":{"text":" .filter_map(|(_, replaces, _)| replaces.clone())","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31254"}},{"Add":{"text":" .collect();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31274"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31275"}},{"Add":{"text":" let revisions = rows","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31300"}},{"Add":{"text":" .iter()","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31316"}},{"Add":{"text":" .map(|(hash, _, date)| Revision {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31358"}},{"Add":{"text":" current: *hash == p.hash,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31396"}},{"Add":{"text":" superseded: superseded.contains(hash),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31447"}},{"Add":{"text":" hash: hash.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31479"}},{"Add":{"text":" date: date.timestamp(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31515"}},{"Add":{"text":" })","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31526"}},{"Add":{"text":" .collect();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31546"}},{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31547"}},{"Add":{"text":" Ok(Json(RevisionsResponse { revisions }))","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31593"}},{"Add":{"text":"}","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31595"}}]}},{"Edit":{"inode":{"change":2,"pos":548943},"path":"api/src/change/mod.rs","line":19,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":549294}],"down_context":[{"change":2,"pos":549294}],"flag":"BLOCK","start":31597,"end":31612,"inode":{"change":2,"pos":548943}}},"contents":[{"Add":{"text":"mod revisions;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31611"}}]}},{"Edit":{"inode":{"change":2,"pos":548943},"path":"api/src/change/mod.rs","line":39,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":56516}],"down_context":[{"change":7,"pos":4997018}],"flag":"BLOCK","start":31613,"end":31726,"inode":{"change":2,"pos":548943}}},"contents":[{"Add":{"text":" .route(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31628"}},{"Add":{"text":" \"/{owner}/{repo}/revisions/{hash}\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31676"}},{"Add":{"text":" get(revisions::revisions),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31715"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31725"}}]}},{"Replacement":{"inode":{"change":11,"pos":5383},"path":"api/src/change/comments.rs","line":165,"ins":{"up_context":[{"change":11,"pos":10356}],"down_context":[{"change":11,"pos":10446}],"flag":"BLOCK","start":31727,"end":31816,"inode":{"change":11,"pos":5383}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":11,"pos":10356},"to":{"change":11,"start":10356,"end":10446},"introduced_by":11}],"inode":{"change":11,"pos":5383}},"ins_contents":[{"Add":{"text":" let (uid, login, _email) = crate::get_user_login_email_strict(&jar, &config).await?;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31815"}}],"del_contents":[{"Del":{"text":" let (uid, _login, _email) = crate::get_user_login_email_strict(&jar, &config).await?;","pos":"HY6KW56TNL5TWFPDQLZBDURE2DZSHKSBDKW53VQOR55DSEU7I7QQC:10445"}}]}},{"Edit":{"inode":{"change":11,"pos":5383},"path":"api/src/change/comments.rs","line":237,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":12709}],"down_context":[{"change":11,"pos":12709}],"flag":"BLOCK","start":31817,"end":33557,"inode":{"change":11,"pos":5383}}},"contents":[{"Add":{"text":"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31817"}},{"Add":{"text":" // Notify the change's author that their patch is under review. A line","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31892"}},{"Add":{"text":" // comment (position set) = review in progress; a general, patch-level","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:31967"}},{"Add":{"text":" // comment = review done. The message carries only metadata + link, never","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32045"}},{"Add":{"text":" // the comment text — so later edits can't leak an earlier version.","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32119"}},{"Add":{"text":" {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32125"}},{"Add":{"text":" let kind = if position.is_some() {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32168"}},{"Add":{"text":" crate::notify::Kind::ReviewInProgress","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32218"}},{"Add":{"text":" } else {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32235"}},{"Add":{"text":" crate::notify::Kind::ReviewDone","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32279"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32290"}},{"Add":{"text":" let n = config.notifier();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32325"}},{"Add":{"text":" let owner = repo.owner.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32365"}},{"Add":{"text":" let repo_name = repo.repo.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32408"}},{"Add":{"text":" let hash = p.hash.clone();","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32443"}},{"Add":{"text":" crate::tracked_spawn(async move {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32485"}},{"Add":{"text":" if let Some(author) = crate::notify::change_author(&n, id, &hash).await {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32571"}},{"Add":{"text":" let short = hash.get(..10).unwrap_or(&hash);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32632"}},{"Add":{"text":" let url = format!(\"/{}/{}/change/{}\", owner, repo_name, hash);","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32711"}},{"Add":{"text":" let verb = if kind == crate::notify::Kind::ReviewDone {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32783"}},{"Add":{"text":" \"finished reviewing\"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32824"}},{"Add":{"text":" } else {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32849"}},{"Add":{"text":" \"left a review comment on\"","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32896"}},{"Add":{"text":" };","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32915"}},{"Add":{"text":" crate::notify::dispatch(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32956"}},{"Add":{"text":" &n,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:32980"}},{"Add":{"text":" crate::notify::NEvent {","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33024"}},{"Add":{"text":" kind,","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33054"}},{"Add":{"text":" targets: vec![author],","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33101"}},{"Add":{"text":" actor: Some(uid),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33143"}},{"Add":{"text":" title: format!(\"{} {} your change {}\", login, verb, short),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33227"}},{"Add":{"text":" url: url.clone(),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33269"}},{"Add":{"text":" zulip: format!(","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33309"}},{"Add":{"text":" \"**{}** {} change [{}]({}{})\",","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33368"}},{"Add":{"text":" login, verb, short, n.hostname, url","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33432"}},{"Add":{"text":" ),","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33459"}},{"Add":{"text":" },","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33482"}},{"Add":{"text":" )","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33500"}},{"Add":{"text":" .await;","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33524"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33538"}},{"Add":{"text":" });","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33550"}},{"Add":{"text":" }","pos":"DHKUBIY6MUOZ3R6LDZ236LVLGK4CT5X6VFGIPCXQ5W5S34ACZLFQC:33556"}}]}}],"owner":"pijul","repo":"nest","token":"sbyVD81zsz9iGdw3LN5xuUDEUQbaVl3uQuHMDZhqcyk=","login":null}

…

Dependencies

Change contents

Review