constitution · epochs · watch · epoch 3

comparison

c_509fc5155034 (tommy-mor) vs c_effff18688f9 (tommy-mor)

download prompt · raw event · cmp_707cde704dbab0

council reasoning

~anthropic/claude-sonnet-latest · winner B · 6:4 · permalink

Side B consolidates three duplicated endpoints (/post, /post/check, /post/redact) into the single /ui RPC dispatch path, removing ~350 lines of near-duplicate handler code and unifying session resolution, which is a real architectural simplification with test/fixture updates to match. Side A introduces a large new hierarchical ItemId/tree model (also substantial and well-tested), but it's a bigger, less proven refactor with more speculative surface (breadcrumbs, entity panels, reddit.rs stub) versus B's more contained, verifiably correct consolidation.

~x-ai/grok-latest · winner A · 4:1 · permalink

Commit A replaces flat string scopes with a hierarchical GlobalTree/ItemId model, path canonicalization, breadcrumbs, journaled votes, and node ensure events—core lasting domain design. Commit B mainly consolidates existing /post* handlers into POST /ui (delete web_post.rs, rewire forms/tests), which cleans the API but mostly relocates behavior without comparable architectural depth.

openai/gpt-chat-latest · winner A · 5:2 · permalink

Side A introduces a substantive new hierarchical data model centered on `ItemId` and `GlobalTree`, migrates voting from flat scope strings to parent-node rankings, adds canonical Reddit URL parsing, breadcrumb navigation, node persistence (`NodeEnsured`), and a journal worker that updates the tree after durable event logging. Side B is primarily a refactor that consolidates existing `/post` endpoints into the `/ui` RPC flow, factors out shared session resolution, and rewires forms and tests; while it reduces duplication and simplifies routing, it mostly reorganizes existing behavior rather than adding comparable long-term functionality.

sides

A — c_509fc5155034 (tommy-mor)

message

[88577c56] reconfigure

diff preview

diff --git a/server/src/api/ui_html.rs b/server/src/api/ui_html.rs
index c4ab9d65c7b3cd42a5b4d093ba429993c101e9a8..82b2aa51d21ada1d0d849d3ddfc3a81e4241d861 100644
--- a/server/src/api/ui_html.rs
+++ b/server/src/api/ui_html.rs
@@ -9,7 +9,9 @@ use crate::{
     html::{js_string_literal, ranking_panel, JsBuilder},
     parser::parse_reddit_url,
     parser_render::navigate_panel,
-    state::AppState,
+    path_types::ItemId,
+    reddit::ensure_partial_tree,
+    state::{parse_item_param, AppState},
     ui_action::{parse_html_ui_from_form, HtmlUiAction},
 };
 
@@ -25,6 +27,10 @@ fn ui_js_warn(msg: &str) -> Response {
         .unwrap()
 }
 
+fn parent_from_scope(scope: &str) -> ItemId {
+    parse_item_param(scope)
+}
+
 pub async fn post_ui_html(
     State(state): State<AppState>,
     Form(form): Form<HashMap<String, String>>,
@@ -42,24 +48,36 @@ pub async fn post_ui_html(
             ratio_right,
             scope,
         } => {
+            let parent = parent_from_scope(&scope);
             if let Err(e) = state
-                .record_vote(&scope, &a, &b, ratio_left, ratio_right)
+                .record_vote(&parent, &a, &b, ratio_left, ratio_right)
                 .await
             {
                 return ui_js_warn(&e).into_response();
             }
-            let scope = crate::state::normalize_scope(&scope);
-            let groups = state.groups.read().await;
+            let tree = state.tree.read().await;
             let empty = crate::reducer::GroupState::new();
-            let group = groups.get(&scope).unwrap_or(&empty);
-            let panel = ranking_panel(&scope, group);
+            let group = tree
+                .get(&parent)
+                .map(|n| &n.local_ranking)
+                .unwrap_or(&empty);
+            let panel = ranking_panel(&parent, group);
             JsBuilder::new()
                 .morph_selector("#ranking-panel", panel)
                 .into_response()
         }
         HtmlUiAction::ParseQuery { query } => match parse_reddit_url(&query) {
-            Ok(subreddit) => {
-                let dest = format!("/?sub={subreddit}");
+            Ok(item) => {
+                {
+                    let mut tree = state.tree.write().await;
+                    ensure_partial_tree(&mut tree, &item);
+                }
+                let _ = state.ensure_node(&item).await;
+                let dest = if item.is_root() {
+                    "/".to_string()
+                } else {
+                    format!("/?item={}", item.as_str())
+                };
                 JsBuilder::new()
                     .raw(&format!(
                         "window.location.href={};",
diff --git a/server/src/events.rs b/server/src/events.rs
index a862370fc840ffe02184a11c578e18239cc9474d..ed5be6b13b9d46e838831d6ce0f96f569b401730 100644
--- a/server/src/events.rs
+++ b/server/src/events.rs
@@ -5,8 +5,8 @@ use serde::{Deserialize, Serialize};
 pub enum Event {
     /// Page view recorded (path → counter in views.json).
     ViewRecorded { path: String, ts: i64 },
-    /// Pairwise comparison vote (replayed into the scope's [`crate::reducer::GroupState`] on boot).
-    /// `scope` is the ranking subject (e.g. a subreddit); empty string is the default/global scope.
+    /// Pairwise comparison vote (replayed into the parent node's [`crate::reducer::GroupState`] on boot).
+    /// `scope` is the parent [`crate::path_types::ItemId`] string; empty string is the tree root.
     VoteRecorded {
         ts: i64,
         a: String,
@@ -16,4 +16,6 @@ pub enum Event {
         #[serde(default)]
         scope: String,
     },
+    /// Register a node path in the fractal tree (no external fetch).
+    NodeEnsured { id: String },
 }
diff --git a/server/src/html/mod.rs b/server/src/html/mod.rs
index 9650d333d29c4ac94ceb407aee3ee00399c7f40b..c973cb718ac74b95570dabea76e24459417790b9 100644
--- a/server/src/html/mod.rs
+++ b/server/src/html/mod.rs
@@ -12,9 +12,10 @@ use serde::Deserialize;
 use crate::{
     form_template::template_json_compact,
     parser_render::navigate_panel,
+    path_types::ItemId,
     ranking::{top_bottom, RankedItem},
-    reducer::GroupState,
-    state::{normalize_scope, AppState},
+    reducer::{GroupState, NodeState},
+    state::{parse_item_param, AppState},
     ui_action::UI_RPC_FIELD,
 };
 
@@ -216,6 +217,48 @@ fn layout(title: &str, body: Markup, views: u64, theme: &str, theme_next: &str)
     }
 }
 
+fn item_href(id: &ItemId) -> String {
+    if id.is_root() {
+        "/".to_string()
+    } else {
+        format!("/?item={}", id.as_str())
+    }
+}
+
+fn segment_label(seg: &str) -> &str {
+    seg
+}
+
+/// Generic breadcrumb trail from an [`ItemId`] path.
+pub fn breadcrumb_path(item: &ItemId) -> Markup {
+    html! {
+        nav class="breadcrumbs" aria-label="Breadcrumb" {
+            a href="/" { "Internet" }
+            @for path in item.breadcrumb_paths() {
+                @let seg = path.segments().last().map_or("", |v| *v);
+                span class="separator" { " / " }
+                a href=(item_href(&path)) { (segment_label(seg)) }
+            }
+        }
+    }
+}
+
+fn entity_panel(node: &NodeState) -> Markup {
+    html! {
+        @if let Some(data) = &node.data {
+            section id="entity-panel" class="demo-panel entity-card" {
+                h2 { (data.title) }
+                @if let Some(author) = &data.author {
+                    p class="muted small" { "by " (author) }
+                }
+                @if let Some(body) = &data.body_html {
+                    div class="entity-body" { (maud::PreEscaped(body)) }
+                }
+            }
+        }
+    }
+}
+
 fn rank_list(label: &str, items: &[RankedItem], start_rank: usize) -> Markup {
     html! {
         @if !items.is_empty() {
@@ -224,7 +267,9 @@ fn rank_list(label: &str, items: &[RankedItem], start_rank: usize) -> Markup {
                 @for (i, r) in items.iter().enumerate() {
                     li {
                         span class="rank-num" { (start_rank + i) ". " }
-                        strong { (r.item.as_str()) }
+                        a href=(item_href(&r.item)) {
+                            strong { (display_label(&r.item)) }
+                        }
                         span class="muted" {
                             " — "
                             ({ format!("{:.1}%", r.score * 100.0) })
@@ -236,23 +281,30 @@ fn rank_list(label: &str, items: &[RankedItem], start_rank: usize) -> Markup {
     }
 }
 
-pub fn ranking_panel(scope: &str, group: &GroupState) -> Markup {
+fn display_label(id: &ItemId) -> String {
+    id.segments()
+        .last()
+        .map_or("Internet", |v| *v)
+        .to_string()
+}
+
+pub fn ranking_panel(item: &ItemId, group: &GroupState) -> Markup {
     let total = group.idx_to_item.len();
     let (top, bottom) = top_bottom(group, 8);
     html! {
         section id="ranking-panel" class="demo-panel" {
             h2 {
                 "Ranking"
-                @if !scope.is_empty() {
-                    " — " span class="scope-name" { "r/" (scope) }
+                @if !item.is_root() {
+                    " — " span class="scope-name" { (item.as_str()) }
                 }
             }
             @if total == 0 {
                 p class="muted" {
-                    @if scope.is_empty() {
+                    @if item.is_root() {
                         "No votes yet — compare two items below."
                     } @else {
-                        "No votes yet for r/" (scope) " — compare two items below to start the ranking."
+                        "No votes yet for " (item.as_str()) " — compare two items below to start the ranking."
                     }
                 }
             } @else {
@@ -266,7 +318,8 @@ pub fn ranking_panel(scope: &str, group: &GroupState) -> Markup {
     }
 }
 
-pub fn vote_panel(scope: &str) -> Markup {
+pub fn vote_panel(parent: &ItemId) -> Markup {
+    let parent_str = parent.as_str();
     let rpc = template_json_compact(&serde_json::json!({
         "action": "record_vote",
         "a": {"$form": "item_a"},
@@ -280,16 +333,17 @@ pub fn vote_panel(scope: &str) -> Markup {
         section id="vote-panel" class="demo-panel" {
             h2 { "Compare" }
             p class="muted small" {
-                @if scope.is_empty() {
+                @if parent.is_root() {
                     "Left item wins at 2:1. Votes append to the JSONL log and update rank centrality."
                 } @else {
-                    "Ranking " span class="scope-name" { "r/" (scope) }
+                    "Ranking children of "
+                    span class="scope-name" { (parent_str) }
                     ". Left item wins at 2:1; each vote updates this ranking."
                 }
             }
             form method="post" action="/ui" id="vote-form" {
                 input type="hidden" name=(UI_RPC_FIELD) value=(rpc);
-                input type="hidden" name="scope" value=(scope);
+                input type="hidden" name="scope" value=(parent_str);
                 div class="vote-fields" {
                     label {
                         "Left (wins) "
@@ -329,17 +383,30 @@ pub async fn home(
     let views = state.views.get_views(&path);
     let theme = theme_from_jar(&jar);
     let theme_next = theme_next_from_uri(&uri);
-    let scope = normalize_scope(&query_param(&uri, "sub").unwrap_or_default());
 
-    let groups = state.groups.read().await;
-    let empty = GroupState::new();
-    let group = groups.get(&scope).unwrap_or(&empty);
+    let item_raw = query_param(&uri, "item")
+        .or_else(|| query_param(&uri, "sub").map(|sub| {
+            if sub.is_empty() {
+                String::new()
+            } else {
+                format!("reddit.com/r/{sub}")
+            }
+        }))
+        .unwrap_or_default();
+    let item = parse_item_param(&item_raw);
+
+    let tree = state.tree.read().await;
+    let empty_node = NodeState::default();
+    let node = tree.get(&item).unwrap_or(&empty_node);
+    let group = &node.local_ranking;
 
     let body = html! {
         h1 { "sorter2" }
+        (breadcrumb_path(&item))
         (navigate_panel("", None))
-        (vote_panel(&scope))
-        (ranking_panel(&scope, group))
+        (entity_panel(node))
+        (vote_panel(&item))
+        (ranking_panel(&item, group))
     };
     layout("sorter2", body, views, theme, &theme_next)
 }
diff --git a/server/src/journal.rs b/server/src/journal.rs
new file mode 100644
index 0000000000000000000000000000000000000000..b02ca025683621470ffdf8cd85cf9b85c56d024d
--- /dev/null
+++ b/server/src/journal.rs
@@ -0,0 +1,89 @@
+use std::sync::Arc;
+
+use tokio::sync::{mpsc, oneshot, RwLock};
+
+use crate::{
+    event_log::EventLog,
+    events::Event,
+    path_types::ItemId,
+    reducer::{GlobalTree, VoteData},
+};
+
+pub struct JournalCommand {
+    pub parent: ItemId,
+    pub vote: VoteData,
+    pub event: Event,
+    pub reply: oneshot::Sender<Result<(), String>>,
+}
+
+#[derive(Clone)]
+pub struct JournalClient {
+    tx: mpsc::Sender<JournalCommand>,
+}
+
+impl JournalClient {
+    pub fn spawn(tree: Arc<RwLock<GlobalTree>>, event_log: Arc<EventLog>) -> Self {
+        let (tx, rx) = mpsc::channel(64);
+        tokio::spawn(journal_worker(rx, tree, event_log));
+        Self { tx }
+    }
+
+    pub async fn record_vote(
+        &self,
+        parent: ItemId,
+        vote: VoteData,
+        event: Event,
+    ) -> Result<(), String> {
+        let (reply, rx) = oneshot::channel();
+        self.tx
+            .send(JournalCommand {
+                parent,
+                vote,
+                event,
+                reply,
+            })
+            .await
+            .map_err(|_| "journal worker stopped".to_string())?;
+        rx.await
+            .map_err(|_| "journal worker stopped".to_string())?
+    }
+}
+
+async fn journal_worker(
+

… preview truncated; 29,088 characters omitted

download full diff A

B — c_effff18688f9 (tommy-mor)

message

[c3cbcaa7] refactor

diff preview

diff --git a/server/src/api/auth.rs b/server/src/api/auth.rs
index b3631b06153d52f88348fef927e7a024b7b85ad6..cd556eb89e9dd8203eba6c8969ffd144db5d329d 100644
--- a/server/src/api/auth.rs
+++ b/server/src/api/auth.rs
@@ -71,6 +71,24 @@ pub fn optional_principal(headers: &HeaderMap, jar: &CookieJar, reduced: &Reduce
     verify_token(reduced, c.value()).ok()
 }
 
+/// Browser session: principal + bearer token string (same shape as CLI session cookie).
+#[derive(Debug, Clone)]
+pub struct WebSession {
+    pub username: String,
+    pub bearer: String,
+}
+
+/// Resolve username and bearer together for `POST /ui` dispatch (one read of headers + jar).
+pub fn resolve_web_session(headers: &HeaderMap, jar: &CookieJar, reduced: &ReducerState) -> Option<WebSession> {
+    let username = optional_principal(headers, jar, reduced)?;
+    let bearer = headers
+        .get(header::AUTHORIZATION)
+        .and_then(|v| v.to_str().ok())
+        .and_then(|s| s.strip_prefix("Bearer ").map(|t| t.trim().to_string()))
+        .or_else(|| jar.get(SLUG_SESSION_COOKIE).map(|c| c.value().to_string()))?;
+    Some(WebSession { username, bearer })
+}
+
 fn redirect_with_session_cookie(public_url: &str, path_and_query: &str, bearer: &str, jar: &CookieJar) -> Response {
     let mut res = Response::builder()
         .status(StatusCode::TEMPORARY_REDIRECT)
diff --git a/server/src/api/mod.rs b/server/src/api/mod.rs
index a986f706ea4b261cbaf004c02b4cf84184b41371..4e223a7460997c464706dca850281447bd754ed5 100644
--- a/server/src/api/mod.rs
+++ b/server/src/api/mod.rs
@@ -4,7 +4,6 @@ mod rpc;
 mod stream;
 mod validate;
 mod ui_html;
-mod web_post;
 
 pub use auth::{
     get_join_invite,
@@ -19,7 +18,9 @@ pub use auth::{
     get_web_login,
     get_logout,
     optional_principal,
+    resolve_web_session,
     session_cookie_header_value,
+    WebSession,
     SLUG_SESSION_COOKIE,
 };
 
@@ -35,7 +36,6 @@ pub use stream::{get_html_stream, get_stream};
 pub use validate::{normalize_room_and_thread, validate_ingest_document, ValidatedIngest};
 
 pub use ui_html::post_ui_html;
-pub use web_post::{check_web_ingest, post_web_ingest, post_web_redact};
 
 #[cfg(test)]
 mod tests {
diff --git a/server/src/api/ui_html.rs b/server/src/api/ui_html.rs
index 2b40a72059981d558768f73d189b991f3448c257..497f8fdd222a8ec7c3d76b0695e0352e973ca3ba 100644
--- a/server/src/api/ui_html.rs
+++ b/server/src/api/ui_html.rs
@@ -1,25 +1,29 @@
-//! Single `POST /ui` entry for browser [`crate::html::ui_action::HtmlUiAction`] (JSON in `__rpc__` + holes).
+//! Single `POST /ui` entry: parse `__rpc__` → [`HtmlUiAction`], resolve [`WebSession`] once, dispatch.
 
 use axum::{
-    body::Body,
+    body,
     extract::State,
-    http::{header, HeaderMap, StatusCode},
+    http::{header, HeaderMap, HeaderValue, StatusCode},
     response::{IntoResponse, Response},
     Form,
 };
 use axum_extra::extract::cookie::CookieJar;
+use slug_types::{RpcBatch, RpcBatchResponse, RpcCommand, RpcResult};
 use std::collections::HashMap;
 
 use crate::{
     api::{
-        auth::optional_principal,
-        web_post::{run_check_web_ingest, run_post_web_ingest, run_post_web_redact, WebPostForm, WebRedactForm},
+        auth::{resolve_web_session, WebSession},
+        handle_rpc_batch,
+        rpc::{rpc_post_redact, rpc_post_with_bearer},
     },
+    canonical_path::canonicalize_tag,
     html::{
         fragment_public_new_thread_form, fragment_room_new_thread_form, login_to_post_hint_markup,
-        parse_html_ui_from_form, user_can_post_room, user_can_view_room, HtmlUiAction, JsBuilder,
-        ThreadNav,
+        parse_html_ui_from_form, thread_feed_html, thread_feed_html_for_room, thread_feed_region_markup,
+        user_can_post_room, user_can_view_room, HtmlUiAction, JsBuilder, ThreadNav,
     },
+    reducer::{scope_from_room_wire, ScopeId},
     state::AppState,
 };
 
@@ -34,6 +38,19 @@ pub async fn post_ui_html(
         Err(e) => return ui_js_warn(&e.to_string()).into_response(),
     };
 
+    let reduced = state.reduced.read().await;
+    let session = resolve_web_session(&headers, &jar, &reduced);
+    drop(reduced);
+
+    dispatch_ui_action(&state, session.as_ref(), action).await
+}
+
+/// All UI command logic: HTTP extractors stop above; this only sees [`AppState`], session, and [`HtmlUiAction`].
+async fn dispatch_ui_action(
+    state: &AppState,
+    session: Option<&WebSession>,
+    action: HtmlUiAction,
+) -> Response {
     match action {
         HtmlUiAction::PostIngest {
             room,
@@ -42,47 +59,87 @@ pub async fn post_ui_html(
             error_target,
             form_id,
         } => {
-            run_post_web_ingest(
-                &state,
-                &headers,
-                &jar,
-                WebPostForm {
-                    room,
-                    thread_tag,
-                    text,
-                    error_target,
-                    form_id,
-                },
-            )
-            .await
+            let Some(session) = session else {
+                return js_redirect("/login").into_response();
+            };
+            let room = room.trim().to_string();
+            let thread_tag = thread_tag.trim().to_string();
+            if text.trim().is_empty() {
+                return form_js_error(
+                    error_target.as_ref(),
+                    "empty post",
+                    "Write something in the text area (DSL / prose).",
+                )
+                .into_response();
+            }
+            match rpc_post_with_bearer(state, &session.bearer, room.clone(), thread_tag.clone(), text).await {
+                Ok(RpcResult::PostOk { .. }) => {
+                    post_success_response(
+                        state,
+                        &room,
+                        &thread_tag,
+                        error_target.as_ref(),
+                        form_id.as_ref(),
+                        Some(session.username.as_str()),
+                    )
+                    .await
+                    .into_response()
+                }
+                Ok(_) => form_js_error(
+                    error_target.as_ref(),
+                    "unexpected response",
+                    "Post did not return PostOk.",
+                )
+                .into_response(),
+                Err((msg, hint)) => form_js_error(error_target.as_ref(), &msg, hint.as_deref().unwrap_or("")).into_response(),
+            }
         }
         HtmlUiAction::CheckIngest {
             room,
             thread_tag,
             text,
             error_target,
-            form_id,
+            form_id: _,
         } => {
-            run_check_web_ingest(
-                &state,
-                &headers,
-                &jar,
-                WebPostForm {
-                    room,
-                    thread_tag,
-                    text,
-                    error_target,
-                    form_id,
-                },
-            )
-            .await
+            let Some(session) = session else {
+                return js_redirect("/login").into_response();
+            };
+            let room = room.trim().to_string();
+            let thread_tag = canonicalize_tag(&thread_tag);
+            if thread_tag.is_empty() {
+                return form_js_error(
+                    error_target.as_ref(),
+                    "missing thread tag",
+                    "Set a thread tag before posting.",
+                )
+                .into_response();
+            }
+            if text.trim().is_empty() {
+                return js_clear_errors(&form_error_target(error_target.as_ref())).into_response();
+            }
+            match rpc_check_with_bearer(state, &session.bearer, room, text.clone()).await {
+                Ok(RpcResult::CheckOk { .. }) => js_clear_errors(&form_error_target(error_target.as_ref())).into_response(),
+                Ok(_) => form_js_error(error_target.as_ref(), "unexpected response", "Check did not return CheckOk.").into_response(),
+                Err((msg, hint)) => form_js_error(error_target.as_ref(), &msg, hint.as_deref().unwrap_or("")).into_response(),
+            }
         }
         HtmlUiAction::RedactPost { post_id } => {
-            run_post_web_redact(&state, &headers, &jar, WebRedactForm { post_id }).await
+            let Some(session) = session else {
+                return js_redirect("/login").into_response();
+            };
+            let h = headers_from_bearer(&session.bearer);
+            match rpc_post_redact(state, &h, post_id).await {
+                Ok(RpcResult::RedactPostOk {}) => redact_success_response(state).await.into_response(),
+                Ok(_) => (StatusCode::BAD_REQUEST, "unexpected response").into_response(),
+                Err((msg, hint)) => {
+                    let detail = hint.as_deref().unwrap_or("");
+                    js_error("#errors", &msg, detail).into_response()
+                }
+            }
         }
         HtmlUiAction::ExpandPublicNewThreadForm => {
             let reduced = state.reduced.read().await;
-            let user = optional_principal(&headers, &jar, &reduced);
+            let user = session.map(|s| s.username.as_str());
             drop(reduced);
             let markup = if user.is_some() {
                 fragment_public_new_thread_form(true)
@@ -99,18 +156,18 @@ pub async fn post_ui_html(
                 return ui_js_warn("missing room").into_response();
             }
             let reduced = state.reduced.read().await;
-            let user = optional_principal(&headers, &jar, &reduced);
+            let user = session.map(|s| s.username.as_str());
             if !reduced.rooms.contains(&room_wire) {
                 drop(reduced);
                 return ui_js_warn("room not found").into_response();
             }
-            if !user_can_view_room(&reduced, &room_wire, user.as_deref()) {
+            if !user_can_view_room(&reduced, &room_wire, user) {
                 drop(reduced);
                 return ui_js_warn("forbidden").into_response();
             }
-            let can_post = user
+            let can_post = session
                 .as_ref()
-                .map(|u| user_can_post_room(&reduced, &room_wire, u))
+                .map(|s| user_can_post_room(&reduced, &room_wire, &s.username))
                 .unwrap_or(false);
             drop(reduced);
             let Some(nav) = ThreadNav::from_room_id(&room_wire) else {
@@ -128,12 +185,195 @@ pub async fn post_ui_html(
     }
 }
 
+fn headers_from_bearer(bearer: &str) -> HeaderMap {
+    let mut headers = HeaderMap::new();
+    if let Ok(hv) = HeaderValue::from_str(&format!("Bearer {bearer}")) {
+        headers.insert(header::AUTHORIZATION, hv);
+    }
+    headers
+}
+
+fn post_redirect_location(room: &str, thread_tag: &str) -> String {
+    let tag = canonicalize_tag(thread_tag);
+    if room.trim() == "public" {
+        format!("/t/{tag}")
+    } else {
+        let room = room.trim();
+        let Some((a, b)) = room.split_once('/') else {
+            return "/".to_string();
+        };
+        format!("/r/{a}/{b}/t/{tag}")
+    }
+}
+
+fn js_quote(s: &str) -> String {
+    serde_json::to_string(s).expect("js string escaping must succeed")
+}
+
+fn js_redirect(to: &str) -> Response {
+    let js = format!("window.location = {};", js_quote(to));
+    Response::builder()
+        .status(StatusCode::OK)
+        .header(header::CONTENT_TYPE, "text/javascript; charset=utf-8")
+        .body(axum::body::Body::from(js))
+        .unwrap()
+}
+
+fn js_error(error_target: &str, title: &str, detail: &str) -> Response {
+    let markup = maud::html! {
+        div id=(error_target.trim_start_matches('#')) {
+            p class="auth-error" { (title) }
+            @if !detail.is_empty() {
+                pre class="muted" { (detail) }
+            }
+        }
+    };
+    JsBuilder::new()
+        .morph_selector(error_targe

… preview truncated; 33,445 characters omitted

download full diff B

Hardlinks — judgments / attempts / prompt

prompt download

judgments

attempts

Prompt text is loaded only by the download route.