","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:2390"}},{"Add":{"text":" ","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:2615"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:2616"}},{"Add":{"text":" {#if open}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:2629"}},{"Add":{"text":" ","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:3252"}},{"Add":{"text":" {/if}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:3260"}},{"Add":{"text":"

","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:3267"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:3268"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5227"}}]}},{"FileAdd":{"meta":{"basename":"2026-07-29-000004-0000_notifications","metadata":576},"context":[{"change":2,"pos":297727}],"contents":[]}},{"FileAdd":{"meta":{"basename":"up.sql","metadata":0},"context":[{"change":0,"pos":5277}],"contents":[{"Add":{"text":"-- Site notifications: a per-user delivery log plus per-user communication","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5385"}},{"Add":{"text":"-- preferences. Events (CI jobs finishing, patches replaced/approved, review","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5462"}},{"Add":{"text":"-- comments, gate rejections, scan findings) fan out to the configured Zulip","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5539"}},{"Add":{"text":"-- stream AND to the affected user through a single personal channel: a","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5611"}},{"Add":{"text":"-- site-wide SSE push if the user has a tab open, otherwise email.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5678"}},{"Add":{"text":"--","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5681"}},{"Add":{"text":"-- `notifications` is that durable per-user log — it backs the in-app bell/list","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5763"}},{"Add":{"text":"-- and lets an offline user's items survive until they return. It deliberately","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5842"}},{"Add":{"text":"-- carries only metadata + a link (title/url/kind), never comment or commit body","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5923"}},{"Add":{"text":"-- text, so a later edit can't leak an earlier version.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:5979"}},{"Add":{"text":"CREATE TABLE notifications (","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6008"}},{"Add":{"text":" id UUID PRIMARY KEY DEFAULT gen_random_uuid(),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6059"}},{"Add":{"text":" user_id UUID NOT NULL REFERENCES users(id),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6107"}},{"Add":{"text":" kind TEXT NOT NULL,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6131"}},{"Add":{"text":" title TEXT NOT NULL,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6156"}},{"Add":{"text":" url TEXT NOT NULL,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6179"}},{"Add":{"text":" -- How it was delivered: 'sse' (user was present) or 'email' (offline).","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6255"}},{"Add":{"text":" via TEXT,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6269"}},{"Add":{"text":" created_at TIMESTAMPTZ NOT NULL DEFAULT now(),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6320"}},{"Add":{"text":" read_at TIMESTAMPTZ","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6344"}},{"Add":{"text":");","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6347"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6348"}},{"Add":{"text":"CREATE INDEX notifications_user_created ON notifications (user_id, created_at DESC);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6433"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6434"}},{"Add":{"text":"-- Per-user, per-event-kind opt-out. A missing row means \"both channels on\"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6510"}},{"Add":{"text":"-- (the default), so users only ever need rows for the categories they tune.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6587"}},{"Add":{"text":"CREATE TABLE notification_prefs (","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6621"}},{"Add":{"text":" user_id UUID NOT NULL REFERENCES users(id),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6669"}},{"Add":{"text":" kind TEXT NOT NULL,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6693"}},{"Add":{"text":" email BOOLEAN NOT NULL DEFAULT TRUE,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6734"}},{"Add":{"text":" inapp BOOLEAN NOT NULL DEFAULT TRUE,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6775"}},{"Add":{"text":" PRIMARY KEY (user_id, kind)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6807"}},{"Add":{"text":");","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6810"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6811"}},{"Add":{"text":"GRANT ALL PRIVILEGES ON TABLE notifications TO pijul;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6865"}},{"Add":{"text":"GRANT ALL PRIVILEGES ON TABLE notification_prefs TO pijul;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6924"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:6925"}},{"Add":{"text":"-- Idempotency flag for the job-outcome notifier. A CI job's final status can be","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7006"}},{"Add":{"text":"-- written either by the main process (build/build-only, via the status","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7078"}},{"Add":{"text":"-- endpoint) or by the detached deploy runner in a *separate* process that can't","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7159"}},{"Add":{"text":"-- reach the in-process SSE map. So a single main-process watcher polls finished","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7240"}},{"Add":{"text":"-- jobs and notifies exactly once — this flag is how it avoids re-notifying.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7319"}},{"Add":{"text":"ALTER TABLE jobs ADD COLUMN notified BOOLEAN NOT NULL DEFAULT false;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7388"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7389"}},{"Add":{"text":"-- Existing jobs must not fan out a backlog of notifications the first time the","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7469"}},{"Add":{"text":"-- watcher runs: mark everything that already exists as already-notified. Only","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7548"}},{"Add":{"text":"-- jobs created after this migration start unnotified.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7603"}},{"Add":{"text":"UPDATE jobs SET notified = true;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7636"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7637"}},{"Add":{"text":"GRANT ALL PRIVILEGES ON jobs TO pijul;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7676"}}]}},{"FileAdd":{"meta":{"basename":"down.sql","metadata":0},"context":[{"change":0,"pos":5277}],"contents":[{"Add":{"text":"ALTER TABLE jobs DROP COLUMN notified;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7750"}},{"Add":{"text":"DROP TABLE notification_prefs;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7781"}},{"Add":{"text":"DROP TABLE notifications;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7807"}}]}},{"FileAdd":{"meta":{"basename":"notify.rs","metadata":0},"context":[{"change":2,"pos":319271}],"contents":[{"Add":{"text":"//! Notification layer.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7867"}},{"Add":{"text":"//!","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7871"}},{"Add":{"text":"//! Every notify-worthy event (CI jobs finishing, patches replaced/approved,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:7948"}},{"Add":{"text":"//! review comments, gate rejections, scan findings) fans out to two places:","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8025"}},{"Add":{"text":"//!","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8029"}},{"Add":{"text":"//! 1. the configured Zulip stream (always), and","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8080"}},{"Add":{"text":"//! 2. the affected user(s), through a single personal channel — a site-wide","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8161"}},{"Add":{"text":"//! SSE push if the user has a tab open right now, otherwise email.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8234"}},{"Add":{"text":"//!","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8238"}},{"Add":{"text":"//! Per-user preferences (`notification_prefs`) can turn either channel off per","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8318"}},{"Add":{"text":"//! event kind. Every delivered event is also written to `notifications` so it","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8397"}},{"Add":{"text":"//! survives for the in-app bell/list even when the user is offline.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8466"}},{"Add":{"text":"//!","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8470"}},{"Add":{"text":"//! Messages carry only metadata + a link — never comment or commit body text —","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8554"}},{"Add":{"text":"//! so a later edit can't leak an earlier version.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8605"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8606"}},{"Add":{"text":"use crate::Config;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8625"}},{"Add":{"text":"use axum::{","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8637"}},{"Add":{"text":" Form, Json, Router,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8661"}},{"Add":{"text":" extract::State,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8681"}},{"Add":{"text":" response::sse::{Event, KeepAlive, Sse},","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8725"}},{"Add":{"text":" routing::{get, post},","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8751"}},{"Add":{"text":"};","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8754"}},{"Add":{"text":"use axum_extra::extract::SignedCookieJar;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8796"}},{"Add":{"text":"use diesel::{ExpressionMethods, OptionalExtension, QueryDsl};","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8858"}},{"Add":{"text":"use diesel_async::RunQueryDsl;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8889"}},{"Add":{"text":"use lettre::Transport as _;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8917"}},{"Add":{"text":"use serde_derive::*;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8938"}},{"Add":{"text":"use std::convert::Infallible;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8968"}},{"Add":{"text":"use std::sync::Arc;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:8988"}},{"Add":{"text":"use std::sync::atomic::{AtomicUsize, Ordering};","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9036"}},{"Add":{"text":"use std::time::Duration;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9061"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9062"}},{"Add":{"text":"/// The event kinds that can produce a notification. The string form is the","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9138"}},{"Add":{"text":"/// stable key stored in `notifications.kind` and `notification_prefs.kind`, so","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9218"}},{"Add":{"text":"/// it must not change once shipped.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9255"}},{"Add":{"text":"#[derive(Clone, Copy, Debug, PartialEq, Eq)]","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9300"}},{"Add":{"text":"pub enum Kind {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9316"}},{"Add":{"text":" JobCompleted,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9334"}},{"Add":{"text":" JobFailed,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9349"}},{"Add":{"text":" ReviewInProgress,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9371"}},{"Add":{"text":" ReviewDone,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9387"}},{"Add":{"text":" PatchReplaced,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9406"}},{"Add":{"text":" PatchApproved,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9425"}},{"Add":{"text":" PushRejected,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9443"}},{"Add":{"text":" ScanVuln,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9457"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9459"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9460"}},{"Add":{"text":"impl Kind {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9472"}},{"Add":{"text":" pub fn as_str(self) -> &'static str {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9514"}},{"Add":{"text":" match self {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9535"}},{"Add":{"text":" Kind::JobCompleted => \"job_completed\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9586"}},{"Add":{"text":" Kind::JobFailed => \"job_failed\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9631"}},{"Add":{"text":" Kind::ReviewInProgress => \"review_in_progress\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9691"}},{"Add":{"text":" Kind::ReviewDone => \"review_done\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9738"}},{"Add":{"text":" Kind::PatchReplaced => \"patch_replaced\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9791"}},{"Add":{"text":" Kind::PatchApproved => \"patch_approved\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9844"}},{"Add":{"text":" Kind::PushRejected => \"push_rejected\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9895"}},{"Add":{"text":" Kind::ScanVuln => \"scan_vuln\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9938"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9948"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9954"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:9955"}},{"Add":{"text":" /// Every kind, for building the preferences UI.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10008"}},{"Add":{"text":" pub const ALL: [Kind; 8] = [","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10041"}},{"Add":{"text":" Kind::JobCompleted,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10069"}},{"Add":{"text":" Kind::JobFailed,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10094"}},{"Add":{"text":" Kind::ReviewInProgress,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10126"}},{"Add":{"text":" Kind::ReviewDone,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10152"}},{"Add":{"text":" Kind::PatchReplaced,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10181"}},{"Add":{"text":" Kind::PatchApproved,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10210"}},{"Add":{"text":" Kind::PushRejected,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10238"}},{"Add":{"text":" Kind::ScanVuln,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10262"}},{"Add":{"text":" ];","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10269"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10270"}},{"Add":{"text":" /// Human label shown in the preferences UI.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10319"}},{"Add":{"text":" pub fn label(self) -> &'static str {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10360"}},{"Add":{"text":" match self {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10381"}},{"Add":{"text":" Kind::JobCompleted => \"CI job completed\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10435"}},{"Add":{"text":" Kind::JobFailed => \"CI job failed\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10483"}},{"Add":{"text":" Kind::ReviewInProgress => \"Review in progress (line comment)\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10558"}},{"Add":{"text":" Kind::ReviewDone => \"Review done (general comment)\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10623"}},{"Add":{"text":" Kind::PatchReplaced => \"Patch replaced (ready to re-review)\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10697"}},{"Add":{"text":" Kind::PatchApproved => \"Patch approved\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10750"}},{"Add":{"text":" Kind::PushRejected => \"Push rejected by a gate\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10811"}},{"Add":{"text":" Kind::ScanVuln => \"Security scan found vulnerabilities\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10880"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10890"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10896"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10897"}},{"Add":{"text":" /// Zulip topic (thread) this kind posts under, so the stream stays organised.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:10980"}},{"Add":{"text":" pub fn topic(self) -> &'static str {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11021"}},{"Add":{"text":" match self {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11042"}},{"Add":{"text":" Kind::JobCompleted | Kind::JobFailed => \"CI\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11100"}},{"Add":{"text":" Kind::ReviewInProgress | Kind::ReviewDone | Kind::PatchReplaced | Kind::PatchApproved => {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11203"}},{"Add":{"text":" \"Reviews\"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11229"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11243"}},{"Add":{"text":" Kind::PushRejected | Kind::ScanVuln => \"Security\",","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11306"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11316"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11322"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11324"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11325"}},{"Add":{"text":"/// What the SSE stream and broadcast channel carry. Serialised to JSON for the","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11405"}},{"Add":{"text":"/// browser. Metadata + link only.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11440"}},{"Add":{"text":"#[derive(Clone, Serialize, Deserialize)]","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11481"}},{"Add":{"text":"pub struct NotifPayload {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11507"}},{"Add":{"text":" pub id: uuid::Uuid,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11531"}},{"Add":{"text":" pub kind: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11553"}},{"Add":{"text":" pub title: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11576"}},{"Add":{"text":" pub url: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11597"}},{"Add":{"text":" pub created_at: chrono::DateTime,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11648"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11650"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11651"}},{"Add":{"text":"/// A single event to dispatch. `zulip` is the full markdown posted to the","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11726"}},{"Add":{"text":"/// stream; `title`/`url` are what the target user sees (bell entry, email","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11801"}},{"Add":{"text":"/// subject, link). None of these should contain user-authored body text.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11875"}},{"Add":{"text":"pub struct NEvent {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11895"}},{"Add":{"text":" pub kind: Kind,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11915"}},{"Add":{"text":" pub targets: Vec,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11949"}},{"Add":{"text":" pub actor: Option,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:11984"}},{"Add":{"text":" pub title: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12007"}},{"Add":{"text":" pub url: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12028"}},{"Add":{"text":" pub zulip: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12051"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12053"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12054"}},{"Add":{"text":"/// The dependencies the notifier needs, decoupled from the full axum `Config`","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12133"}},{"Add":{"text":"/// so the replication worker (which holds only a DB handle) can notify too.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12210"}},{"Add":{"text":"/// Cheap to clone — everything is an `Arc`, a pool handle, or a small `Option`.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12293"}},{"Add":{"text":"#[derive(Clone)]","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12310"}},{"Add":{"text":"pub struct Notifier {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12332"}},{"Add":{"text":" pub db: crate::config::Db,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12363"}},{"Add":{"text":" pub zulip: Option,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12419"}},{"Add":{"text":" pub email: Option,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12465"}},{"Add":{"text":" pub email_source: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12495"}},{"Add":{"text":" pub hostname: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12521"}},{"Add":{"text":" pub user_updates:","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12543"}},{"Add":{"text":" Arc>>,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12632"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12634"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12635"}},{"Add":{"text":"/// Is `uid` currently connected to the site (has at least one open SSE tab)?","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12713"}},{"Add":{"text":"fn is_present(n: &Notifier, uid: uuid::Uuid) -> bool {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12768"}},{"Add":{"text":" n.user_updates","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12787"}},{"Add":{"text":" .get(&uid)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12806"}},{"Add":{"text":" .map(|tx| tx.receiver_count() > 0)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12849"}},{"Add":{"text":" .unwrap_or(false)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12875"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12877"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12878"}},{"Add":{"text":"/// Who applied change `hash` onto `repo` — the change author, for review /","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:12956"}},{"Add":{"text":"/// approval / replacement notifications. None if unknown.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13015"}},{"Add":{"text":"pub async fn change_author(n: &Notifier, repo: uuid::Uuid, hash: &str) -> Option {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13110"}},{"Add":{"text":" use crate::db::channel_events::dsl as ce;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13156"}},{"Add":{"text":" let mut db = n.db.get().await.ok()?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13197"}},{"Add":{"text":" ce::channel_events","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13220"}},{"Add":{"text":" .filter(ce::repo_id.eq(repo))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13258"}},{"Add":{"text":" .filter(ce::hash.eq(hash))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13293"}},{"Add":{"text":" .filter(ce::operation.eq(\"apply\"))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13336"}},{"Add":{"text":" .order_by(ce::applied_at.desc())","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13377"}},{"Add":{"text":" .select(ce::pushed_by)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13408"}},{"Add":{"text":" .first::>(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13454"}},{"Add":{"text":" .await","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13469"}},{"Add":{"text":" .ok()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13483"}},{"Add":{"text":" .flatten()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13502"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13504"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13505"}},{"Add":{"text":"/// The most recent pusher on `repo`/`channel` — the person a CI job's outcome","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13586"}},{"Add":{"text":"/// most concerns. None if unknown.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13622"}},{"Add":{"text":"pub async fn last_pusher(n: &Notifier, repo: uuid::Uuid, channel: &str) -> Option {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13718"}},{"Add":{"text":" use crate::db::channel_events::dsl as ce;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13764"}},{"Add":{"text":" let mut db = n.db.get().await.ok()?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13805"}},{"Add":{"text":" ce::channel_events","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13828"}},{"Add":{"text":" .filter(ce::repo_id.eq(repo))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13866"}},{"Add":{"text":" .filter(ce::channel.eq(channel))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13907"}},{"Add":{"text":" .filter(ce::operation.eq(\"apply\"))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13950"}},{"Add":{"text":" .order_by(ce::applied_at.desc())","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:13991"}},{"Add":{"text":" .select(ce::pushed_by)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14022"}},{"Add":{"text":" .first::>(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14068"}},{"Add":{"text":" .await","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14083"}},{"Add":{"text":" .ok()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14097"}},{"Add":{"text":" .flatten()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14116"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14118"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14119"}},{"Add":{"text":"/// Distinct users who left a review comment on `hash` — the people to tell when","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14202"}},{"Add":{"text":"/// that patch is superseded and ready to re-review.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14255"}},{"Add":{"text":"pub async fn reviewers(n: &Notifier, repo: uuid::Uuid, hash: &str) -> Vec {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14343"}},{"Add":{"text":" use crate::db::review_comments::dsl as rc;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14390"}},{"Add":{"text":" let Ok(mut db) = n.db.get().await else {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14435"}},{"Add":{"text":" return Vec::new();","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14462"}},{"Add":{"text":" };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14469"}},{"Add":{"text":" rc::review_comments","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14493"}},{"Add":{"text":" .filter(rc::repository_id.eq(repo))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14537"}},{"Add":{"text":" .filter(rc::change.eq(hash))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14574"}},{"Add":{"text":" .filter(rc::author.is_not_null())","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14616"}},{"Add":{"text":" .select(rc::author)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14644"}},{"Add":{"text":" .distinct()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14664"}},{"Add":{"text":" .get_results::>(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14716"}},{"Add":{"text":" .await","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14731"}},{"Add":{"text":" .unwrap_or_default()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14760"}},{"Add":{"text":" .into_iter()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14781"}},{"Add":{"text":" .flatten()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14800"}},{"Add":{"text":" .collect()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14819"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14821"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14822"}},{"Add":{"text":"/// Fan an event out to Zulip and to each target user.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14877"}},{"Add":{"text":"pub async fn dispatch(n: &Notifier, event: NEvent) {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14930"}},{"Add":{"text":" // 1. Zulip — always, regardless of any per-user preference.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:14997"}},{"Add":{"text":" zulip(n, event.kind.topic(), &event.zulip).await;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15051"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15052"}},{"Add":{"text":" let Ok(mut db) = n.db.get().await else {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15097"}},{"Add":{"text":" return;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15113"}},{"Add":{"text":" };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15120"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15121"}},{"Add":{"text":" let mut seen = std::collections::HashSet::new();","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15174"}},{"Add":{"text":" for uid in event.targets {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15205"}},{"Add":{"text":" if Some(uid) == event.actor {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15243"}},{"Add":{"text":" continue; // never notify the actor about their own action","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15314"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15324"}},{"Add":{"text":" if !seen.insert(uid) {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15355"}},{"Add":{"text":" continue; // dedup","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15386"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15396"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15397"}},{"Add":{"text":" // Per-user, per-kind preferences. Missing row = both channels on.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15472"}},{"Add":{"text":" let (email_on, inapp_on) = {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15509"}},{"Add":{"text":" use crate::db::notification_prefs::dsl as np;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15567"}},{"Add":{"text":" np::notification_prefs","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15602"}},{"Add":{"text":" .find((uid, event.kind.as_str()))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15652"}},{"Add":{"text":" .select((np::email, np::inapp))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15700"}},{"Add":{"text":" .get_result::<(bool, bool)>(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15753"}},{"Add":{"text":" .await","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15776"}},{"Add":{"text":" .optional()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15804"}},{"Add":{"text":" .ok()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15826"}},{"Add":{"text":" .flatten()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15853"}},{"Add":{"text":" .unwrap_or((true, true))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15894"}},{"Add":{"text":" };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15905"}},{"Add":{"text":" if !email_on && !inapp_on {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15941"}},{"Add":{"text":" continue;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15963"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15973"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:15974"}},{"Add":{"text":" let present = inapp_on && is_present(n, uid);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16028"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16029"}},{"Add":{"text":" // A deliverable email address, if we might need one.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16091"}},{"Add":{"text":" let addr: Option = if !present && email_on {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16152"}},{"Add":{"text":" use crate::db::users::dsl as u;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16196"}},{"Add":{"text":" u::users","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16217"}},{"Add":{"text":" .find(uid)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16244"}},{"Add":{"text":" .filter(u::email_is_invalid.is_null())","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16299"}},{"Add":{"text":" .filter(u::is_active)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16337"}},{"Add":{"text":" .select(u::email)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16371"}},{"Add":{"text":" .get_result::(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16418"}},{"Add":{"text":" .await","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16441"}},{"Add":{"text":" .optional()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16469"}},{"Add":{"text":" .ok()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16491"}},{"Add":{"text":" .flatten()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16518"}},{"Add":{"text":" } else {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16535"}},{"Add":{"text":" None","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16552"}},{"Add":{"text":" };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16563"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16564"}},{"Add":{"text":" // Decide the channel: SSE if present, else email, else store-only.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16640"}},{"Add":{"text":" let via: Option<&'static str> = if present {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16693"}},{"Add":{"text":" Some(\"sse\")","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16717"}},{"Add":{"text":" } else if email_on && addr.is_some() {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16764"}},{"Add":{"text":" Some(\"email\")","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16790"}},{"Add":{"text":" } else if inapp_on {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16819"}},{"Add":{"text":" None // offline & no email: keep it for the bell only","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16885"}},{"Add":{"text":" } else {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16902"}},{"Add":{"text":" continue; // email wanted but no valid address, in-app off","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16973"}},{"Add":{"text":" };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16984"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:16985"}},{"Add":{"text":" // Durable record (backs the in-app bell/list).","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17041"}},{"Add":{"text":" let row = {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17061"}},{"Add":{"text":" use crate::db::notifications::dsl as n;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17113"}},{"Add":{"text":" diesel::insert_into(n::notifications)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17163"}},{"Add":{"text":" .values((","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17189"}},{"Add":{"text":" n::user_id.eq(uid),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17229"}},{"Add":{"text":" n::kind.eq(event.kind.as_str()),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17282"}},{"Add":{"text":" n::title.eq(&event.title),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17329"}},{"Add":{"text":" n::url.eq(&event.url),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17372"}},{"Add":{"text":" n::via.eq(via),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17408"}},{"Add":{"text":" ))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17427"}},{"Add":{"text":" .returning((n::id, n::created_at))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17478"}},{"Add":{"text":" .get_result::<(uuid::Uuid, chrono::DateTime)>(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17562"}},{"Add":{"text":" .await","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17585"}},{"Add":{"text":" .ok()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17607"}},{"Add":{"text":" };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17618"}},{"Add":{"text":" let Some((id, created_at)) = row else { continue };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17678"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17679"}},{"Add":{"text":" match via {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17699"}},{"Add":{"text":" Some(\"sse\") => {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17728"}},{"Add":{"text":" let payload = NotifPayload {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17773"}},{"Add":{"text":" id,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17797"}},{"Add":{"text":" kind: event.kind.as_str().to_string(),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17856"}},{"Add":{"text":" title: event.title.clone(),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17904"}},{"Add":{"text":" url: event.url.clone(),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17948"}},{"Add":{"text":" created_at,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17980"}},{"Add":{"text":" };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:17999"}},{"Add":{"text":" if let Some(tx) = n.user_updates.get(&uid) {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18060"}},{"Add":{"text":" let _ = tx.send(payload);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18106"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18124"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18138"}},{"Add":{"text":" Some(\"email\") => {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18169"}},{"Add":{"text":" if let Some(addr) = addr {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18212"}},{"Add":{"text":" let link = format!(\"{}{}\", n.hostname, event.url);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18283"}},{"Add":{"text":" send_email(n, &event.title, &link, &addr);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18346"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18364"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18378"}},{"Add":{"text":" _ => {}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18398"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18408"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18414"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18416"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18417"}},{"Add":{"text":"/// Send a plain notification email (metadata + link only). Best-effort.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18490"}},{"Add":{"text":"fn send_email(n: &Notifier, subject: &str, link: &str, addr: &str) {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18559"}},{"Add":{"text":" let Some(ref mailer) = n.email else { return };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18611"}},{"Add":{"text":" let Ok(from) = n.email_source.parse() else {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18660"}},{"Add":{"text":" return;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18676"}},{"Add":{"text":" };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18683"}},{"Add":{"text":" let Ok(to) = addr.parse() else { return };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18730"}},{"Add":{"text":" let body = lettre::message::MultiPart::alternative_plain_html(","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18797"}},{"Add":{"text":" format!(\"{subject}\\n\\n{link}\"),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18837"}},{"Add":{"text":" format!(\"

{subject}

{link}

\"),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18910"}},{"Add":{"text":" );","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18917"}},{"Add":{"text":" if let Ok(email) = lettre::Message::builder()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18967"}},{"Add":{"text":" .from(from)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:18987"}},{"Add":{"text":" .to(to)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19003"}},{"Add":{"text":" .subject(subject)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19029"}},{"Add":{"text":" .multipart(body)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19054"}},{"Add":{"text":" {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19060"}},{"Add":{"text":" if let Err(e) = mailer.send(&email) {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19106"}},{"Add":{"text":" tracing::warn!(\"notify email to {addr:?} failed: {e:?}\");","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19176"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19186"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19192"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19194"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19195"}},{"Add":{"text":"/// Post to the configured Zulip stream. No-op if Zulip isn't configured.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19269"}},{"Add":{"text":"pub async fn zulip(n: &Notifier, topic: &str, message: &str) {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19332"}},{"Add":{"text":" let Some(ref z) = n.zulip else { return };","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19379"}},{"Add":{"text":" let client = reqwest::Client::new();","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19420"}},{"Add":{"text":" let _ = client","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19439"}},{"Add":{"text":" .post(format!(\"{}/api/v1/messages\", z.site))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19492"}},{"Add":{"text":" .basic_auth(&z.bot_email, Some(&z.api_key))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19544"}},{"Add":{"text":" .form(&[","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19561"}},{"Add":{"text":" (\"type\", \"stream\"),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19593"}},{"Add":{"text":" (\"to\", z.stream.as_str()),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19632"}},{"Add":{"text":" (\"topic\", topic),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19662"}},{"Add":{"text":" (\"content\", message),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19696"}},{"Add":{"text":" ])","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19707"}},{"Add":{"text":" .send()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19723"}},{"Add":{"text":" .await;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19739"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19741"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19742"}},{"Add":{"text":"pub fn router() -> Router {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19778"}},{"Add":{"text":" Router::new()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19796"}},{"Add":{"text":" .route(\"/stream\", get(stream))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19835"}},{"Add":{"text":" .route(\"/\", get(list))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19866"}},{"Add":{"text":" .route(\"/read\", post(mark_read))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19907"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19909"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19910"}},{"Add":{"text":"/// Decrements the shared SSE task gauge on drop.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19960"}},{"Add":{"text":"struct TaskCounter(Arc);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:19998"}},{"Add":{"text":"impl Drop for TaskCounter {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20026"}},{"Add":{"text":" fn drop(&mut self) {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20051"}},{"Add":{"text":" self.0.fetch_sub(1, Ordering::Relaxed);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20099"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20105"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20107"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20108"}},{"Add":{"text":"/// Site-wide per-user notification stream. Any page can subscribe; the browser","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20188"}},{"Add":{"text":"/// receives `notification` events as they happen.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20239"}},{"Add":{"text":"async fn stream(","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20256"}},{"Add":{"text":" State(config): State,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20290"}},{"Add":{"text":" jar: SignedCookieJar,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20316"}},{"Add":{"text":") -> Result>>, crate::Error> {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20405"}},{"Add":{"text":" let (uid, _) = crate::get_user_login(&jar, &config)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20461"}},{"Add":{"text":" .await?","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20477"}},{"Add":{"text":" .ok_or(crate::Error::NeedsAuth)?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20519"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20520"}},{"Add":{"text":" let rx = config","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20540"}},{"Add":{"text":" .user_updates","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20562"}},{"Add":{"text":" .entry(uid)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20582"}},{"Add":{"text":" .or_insert_with(|| tokio::sync::broadcast::channel(32).0)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20648"}},{"Add":{"text":" .subscribe();","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20670"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20671"}},{"Add":{"text":" let counter = config.sse_task_count.clone();","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20720"}},{"Add":{"text":" counter.fetch_add(1, Ordering::Relaxed);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20765"}},{"Add":{"text":" let guard = TaskCounter(counter);","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20803"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20804"}},{"Add":{"text":" let stream = futures::stream::unfold((rx, guard), |(mut rx, guard)| async move {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20889"}},{"Add":{"text":" loop {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20904"}},{"Add":{"text":" match rx.recv().await {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20940"}},{"Add":{"text":" Ok(payload) => {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:20973"}},{"Add":{"text":" let data = serde_json::to_string(&payload).unwrap_or_default();","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21057"}},{"Add":{"text":" return Some((","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21091"}},{"Add":{"text":" Ok::(Event::default().event(\"notification\").data(data)),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21191"}},{"Add":{"text":" (rx, guard),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21228"}},{"Add":{"text":" ));","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21252"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21270"}},{"Add":{"text":" Err(tokio::sync::broadcast::error::RecvError::Lagged(_)) => continue,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21356"}},{"Add":{"text":" Err(tokio::sync::broadcast::error::RecvError::Closed) => return None,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21442"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21456"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21466"}},{"Add":{"text":" });","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21474"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21475"}},{"Add":{"text":" Ok(Sse::new(stream).keep_alive(KeepAlive::new().interval(Duration::from_secs(25))))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21563"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21565"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21566"}},{"Add":{"text":"#[derive(Serialize)]","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21587"}},{"Add":{"text":"struct NotifRow {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21605"}},{"Add":{"text":" id: uuid::Uuid,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21625"}},{"Add":{"text":" kind: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21643"}},{"Add":{"text":" title: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21662"}},{"Add":{"text":" url: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21679"}},{"Add":{"text":" created_at: chrono::DateTime,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21726"}},{"Add":{"text":" read: bool,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21742"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21744"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21745"}},{"Add":{"text":"/// The most recent notifications for the logged-in user (backs the bell/list).","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21825"}},{"Add":{"text":"async fn list(","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21840"}},{"Add":{"text":" State(config): State,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21874"}},{"Add":{"text":" jar: SignedCookieJar,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21900"}},{"Add":{"text":") -> Result>, crate::Error> {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:21949"}},{"Add":{"text":" let (uid, _) = crate::get_user_login(&jar, &config)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22005"}},{"Add":{"text":" .await?","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22021"}},{"Add":{"text":" .ok_or(crate::Error::NeedsAuth)?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22063"}},{"Add":{"text":" use crate::db::notifications::dsl as n;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22107"}},{"Add":{"text":" let mut db = config.db.get().await?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22148"}},{"Add":{"text":" let rows = n::notifications","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22180"}},{"Add":{"text":" .filter(n::user_id.eq(uid))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22216"}},{"Add":{"text":" .order_by(n::created_at.desc())","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22256"}},{"Add":{"text":" .limit(50)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22275"}},{"Add":{"text":" .select((n::id, n::kind, n::title, n::url, n::created_at, n::read_at))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22354"}},{"Add":{"text":" .get_results::<(","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22379"}},{"Add":{"text":" uuid::Uuid,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22403"}},{"Add":{"text":" String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22423"}},{"Add":{"text":" String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22443"}},{"Add":{"text":" String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22463"}},{"Add":{"text":" chrono::DateTime,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22506"}},{"Add":{"text":" Option>,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22557"}},{"Add":{"text":" )>(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22577"}},{"Add":{"text":" .await?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22594"}},{"Add":{"text":" Ok(Json(","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22607"}},{"Add":{"text":" rows.into_iter()","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22632"}},{"Add":{"text":" .map(|(id, kind, title, url, created_at, read_at)| NotifRow {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22706"}},{"Add":{"text":" id,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22726"}},{"Add":{"text":" kind,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22748"}},{"Add":{"text":" title,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22771"}},{"Add":{"text":" url,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22792"}},{"Add":{"text":" created_at,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22820"}},{"Add":{"text":" read: read_at.is_some(),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22861"}},{"Add":{"text":" })","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22876"}},{"Add":{"text":" .collect(),","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22900"}},{"Add":{"text":" ))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22907"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22909"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22910"}},{"Add":{"text":"#[derive(Deserialize)]","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22933"}},{"Add":{"text":"struct ReadForm {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:22951"}},{"Add":{"text":" /// A specific notification id, or empty to mark all read.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23014"}},{"Add":{"text":" #[serde(default)]","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23036"}},{"Add":{"text":" id: String,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23052"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23054"}},{"Add":{"text":"","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23055"}},{"Add":{"text":"/// Mark one (or all) of the user's notifications read.","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23111"}},{"Add":{"text":"async fn mark_read(","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23131"}},{"Add":{"text":" State(config): State,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23165"}},{"Add":{"text":" jar: SignedCookieJar,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23191"}},{"Add":{"text":" Form(form): Form,","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23223"}},{"Add":{"text":") -> Result {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23275"}},{"Add":{"text":" let (uid, _) = crate::get_user_login(&jar, &config)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23331"}},{"Add":{"text":" .await?","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23347"}},{"Add":{"text":" .ok_or(crate::Error::NeedsAuth)?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23389"}},{"Add":{"text":" use crate::db::notifications::dsl as n;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23433"}},{"Add":{"text":" let mut db = config.db.get().await?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23474"}},{"Add":{"text":" let id = form.id.trim();","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23503"}},{"Add":{"text":" if id.is_empty() {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23526"}},{"Add":{"text":" diesel::update(n::notifications.filter(n::user_id.eq(uid)))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23594"}},{"Add":{"text":" .filter(n::read_at.is_null())","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23636"}},{"Add":{"text":" .set(n::read_at.eq(diesel::dsl::now))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23686"}},{"Add":{"text":" .execute(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23716"}},{"Add":{"text":" .await?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23737"}},{"Add":{"text":" } else {","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23750"}},{"Add":{"text":" let nid: uuid::Uuid = id.parse().map_err(|_| crate::Error::NotFound)?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23829"}},{"Add":{"text":" diesel::update(n::notifications.find(nid))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23880"}},{"Add":{"text":" .filter(n::user_id.eq(uid))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23920"}},{"Add":{"text":" .set(n::read_at.eq(diesel::dsl::now))","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:23970"}},{"Add":{"text":" .execute(&mut db)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:24000"}},{"Add":{"text":" .await?;","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:24021"}},{"Add":{"text":" }","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:24027"}},{"Add":{"text":" Ok(axum::http::StatusCode::OK)","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:24062"}},{"Add":{"text":"}","pos":"XBFWSWLKEYA65GAGZFSJG34OXJWWXEHXZY7I66H2Z7BLRGEGQ43AC:24064"}}]}}],"owner":"pijul","repo":"nest","token":"yRTmPOmqmC5oAvT6132bbjl09ctcKVvf/iNjzi3l8+Y=","login":null}

…

Dependencies

Change contents

Review