{"messages":[{"content":"You are a constitutional council ranking individual git commits for ownership allocation.\n\nCompare these two commits. Decide which contributed more lasting value to the project.\n\nJudge substance, not spectacle:\n- Prefer correct, lasting design and real bugfixes over churn, formatting, renames, or generated noise.\n- Prefer clarity and necessity over sheer line count. A small precise change can beat a large diffuse one.\n- Do not favor a side merely because its patch is longer or noisier.\n- Weight what the change does for the project, not the contributor's name.\n\nReturn ONLY a JSON object: {\"winner\": \"A\" or \"B\", \"ratio\": \"N:M\", \"explanation\": \"...\"}\nThe explanation must cite concrete differences in the patches (1-3 sentences).\n\nSide A — contributor: tommy-mor\nSide A — commit message:\n[432e1450] nice\n\nSide A — unified diff (full patch):\ndiff --git a/reddit.rs b/reddit.rs\nnew file mode 100644\nindex 0000000000000000000000000000000000000000..da27f6f76482dd27d44cad9d7b844972bf042e64\n--- /dev/null\n+++ b/reddit.rs\n@@ -0,0 +1,420 @@\n+use governor::{Quota, RateLimiter, Jitter};\n+use nonzero_ext::nonzero;\n+use reqwest::{Client, StatusCode};\n+use serde::{Deserialize, Serialize};\n+use std::sync::Arc;\n+use std::time::Duration;\n+use anyhow::{Result, Context, anyhow};\n+\n+/// Reddit API client with built-in rate limiting\n+pub struct RedditClient {\n+ client: Client,\n+ limiter: Arc,\n+ user_agent: String,\n+}\n+\n+impl RedditClient {\n+ /// Create a new Reddit client with rate limiting\n+ /// Reddit API allows 60 requests per minute for OAuth2 authenticated apps\n+ /// We'll be conservative and use 50 requests per minute\n+ pub fn new() -> Self {\n+ // Create rate limiter: 50 requests per minute\n+ let quota = Quota::per_minute(nonzero!(50u32));\n+ let limiter = Arc::new(RateLimiter::direct(quota));\n+ \n+ // Create HTTP client with timeout\n+ let client = Client::builder()\n+ .timeout(Duration::from_secs(30))\n+ .build()\n+ .expect(\"Failed to create HTTP client\");\n+ \n+ // Reddit requires a unique user agent\n+ let user_agent = format!(\n+ \"rust:sorter:v{} (by /u/hourLong_arnould)\",\n+ env!(\"CARGO_PKG_VERSION\")\n+ );\n+ \n+ Self {\n+ client,\n+ limiter,\n+ user_agent,\n+ }\n+ }\n+ \n+ /// Fetch hot posts from a subreddit\n+ pub async fn get_subreddit_hot(&self, subreddit: &str, limit: usize) -> Result {\n+ // Wait for rate limiter\n+ self.limiter.until_ready_with_jitter(Jitter::up_to(Duration::from_millis(100))).await;\n+ \n+ let url = format!(\"https://www.reddit.com/r/{}/hot.json?limit={}\", subreddit, limit);\n+ \n+ let response = self.client\n+ .get(&url)\n+ .header(\"User-Agent\", &self.user_agent)\n+ .send()\n+ .await\n+ .context(\"Failed to send request to Reddit\")?;\n+ \n+ self.handle_response(response).await\n+ }\n+ \n+ /// Fetch top posts from a subreddit\n+ pub async fn get_subreddit_top(&self, subreddit: &str, limit: usize, time_period: &str) -> Result {\n+ self.limiter.until_ready_with_jitter(Jitter::up_to(Duration::from_millis(100))).await;\n+ \n+ let url = format!(\n+ \"https://www.reddit.com/r/{}/top.json?limit={}&t={}\",\n+ subreddit, limit, time_period\n+ );\n+ \n+ let response = self.client\n+ .get(&url)\n+ .header(\"User-Agent\", &self.user_agent)\n+ .send()\n+ .await\n+ .context(\"Failed to send request to Reddit\")?;\n+ \n+ self.handle_response(response).await\n+ }\n+ \n+ /// Fetch new posts from a subreddit\n+ pub async fn get_subreddit_new(&self, subreddit: &str, limit: usize) -> Result {\n+ self.limiter.until_ready_with_jitter(Jitter::up_to(Duration::from_millis(100))).await;\n+ \n+ let url = format!(\"https://www.reddit.com/r/{}/new.json?limit={}\", subreddit, limit);\n+ \n+ let response = self.client\n+ .get(&url)\n+ .header(\"User-Agent\", &self.user_agent)\n+ .send()\n+ .await\n+ .context(\"Failed to send request to Reddit\")?;\n+ \n+ self.handle_response(response).await\n+ }\n+ \n+ /// Fetch a specific post and its comments\n+ pub async fn get_post(&self, subreddit: &str, post_id: &str) -> Result> {\n+ self.limiter.until_ready_with_jitter(Jitter::up_to(Duration::from_millis(100))).await;\n+ \n+ let url = format!(\n+ \"https://www.reddit.com/r/{}/comments/{}.json\",\n+ subreddit, post_id\n+ );\n+ \n+ let response = self.client\n+ .get(&url)\n+ .header(\"User-Agent\", &self.user_agent)\n+ .send()\n+ .await\n+ .context(\"Failed to send request to Reddit\")?;\n+ \n+ match response.status() {\n+ StatusCode::OK => {\n+ let listings: Vec = response\n+ .json()\n+ .await\n+ .context(\"Failed to parse Reddit response\")?;\n+ Ok(listings)\n+ }\n+ StatusCode::TOO_MANY_REQUESTS => {\n+ Err(anyhow!(\"Reddit rate limit exceeded. Please try again later.\"))\n+ }\n+ StatusCode::NOT_FOUND => {\n+ Err(anyhow!(\"Post not found: r/{}/comments/{}\", subreddit, post_id))\n+ }\n+ status => {\n+ Err(anyhow!(\"Reddit API error: {}\", status))\n+ }\n+ }\n+ }\n+ \n+ /// Fetch user profile (posts and comments)\n+ pub async fn get_user_profile(&self, username: &str, content_type: &str, limit: usize) -> Result {\n+ self.limiter.until_ready_with_jitter(Jitter::up_to(Duration::from_millis(100))).await;\n+ \n+ let url = format!(\n+ \"https://www.reddit.com/user/{}/{}.json?limit={}\",\n+ username, content_type, limit\n+ );\n+ \n+ let response = self.client\n+ .get(&url)\n+ .header(\"User-Agent\", &self.user_agent)\n+ .send()\n+ .await\n+ .context(\"Failed to send request to Reddit\")?;\n+ \n+ self.handle_response(response).await\n+ }\n+ \n+ /// Handle Reddit API response with proper error checking\n+ async fn handle_response(&self, response: reqwest::Response) -> Result {\n+ match response.status() {\n+ StatusCode::OK => {\n+ let listing: RedditListingResponse = response\n+ .json()\n+ .await\n+ .context(\"Failed to parse Reddit response\")?;\n+ Ok(listing)\n+ }\n+ StatusCode::TOO_MANY_REQUESTS => {\n+ Err(anyhow!(\"Reddit rate limit exceeded. Please try again later.\"))\n+ }\n+ StatusCode::NOT_FOUND => {\n+ Err(anyhow!(\"Reddit resource not found\"))\n+ }\n+ StatusCode::FORBIDDEN => {\n+ Err(anyhow!(\"Access forbidden. The subreddit may be private.\"))\n+ }\n+ status => {\n+ Err(anyhow!(\"Reddit API error: {}\", status))\n+ }\n+ }\n+ }\n+}\n+\n+// Reddit API response types\n+#[derive(Debug, Clone, Serialize, Deserialize)]\n+pub struct RedditListingResponse {\n+ pub kind: String,\n+ pub data: RedditListingData,\n+}\n+\n+#[derive(Debug, Clone, Serialize, Deserialize)]\n+pub struct RedditListingData {\n+ #[serde(skip_serializing_if = \"Option::is_none\")]\n+ pub after: Option,\n+ #[serde(skip_serializing_if = \"Option::is_none\")]\n+ pub before: Option,\n+ pub children: Vec,\n+ #[serde(skip_serializing_if = \"Option::is_none\")]\n+ pub modhash: Option,\n+}\n+\n+#[derive(Debug, Clone, Serialize, Deserialize)]\n+pub struct RedditThing {\n+ pub kind: String,\n+ pub data: RedditThingData,\n+}\n+\n+/// Reddit's \"Thing\" data can be either a post, comment, or other types\n+/// We use untagged enum to handle different data structures\n+#[derive(Debug, Clone, Serialize, Deserialize)]\n+#[serde(untagged)]\n+pub enum RedditThingData {\n+ Post(RedditPost),\n+ Comment(RedditComment),\n+ // For things we don't care about yet (like \"more\" comments)\n+ Other(serde_json::Value),\n+}\n+\n+/// Reddit post data with serde handling all the parsing\n+#[derive(Debug, Clone, Serialize, Deserialize)]\n+pub struct RedditPost {\n+ pub id: String,\n+ pub name: String, // Full name (t3_xxx)\n+ #[serde(default = \"default_untitled\")]\n+ pub title: String,\n+ #[serde(default = \"default_deleted_user\")]\n+ pub author: String,\n+ pub subreddit: String,\n+ #[serde(default)]\n+ pub url: String,\n+ #[serde(default)]\n+ pub permalink: String,\n+ #[serde(default, deserialize_with = \"deserialize_selftext\")]\n+ pub selftext: Option,\n+ #[serde(default)]\n+ pub score: i64,\n+ #[serde(default)]\n+ pub num_comments: i64,\n+ #[serde(default)]\n+ pub created_utc: f64,\n+ #[serde(default, deserialize_with = \"deserialize_thumbnail\")]\n+ pub thumbnail: Option,\n+ #[serde(default)]\n+ pub is_video: bool,\n+ #[serde(default)]\n+ pub is_self: bool,\n+ // Additional useful fields\n+ #[serde(default)]\n+ pub ups: i64,\n+ #[serde(default)]\n+ pub downs: i64,\n+ #[serde(default)]\n+ pub upvote_ratio: f64,\n+ #[serde(default)]\n+ pub over_18: bool,\n+ #[serde(default)]\n+ pub spoiler: bool,\n+ #[serde(default)]\n+ pub stickied: bool,\n+ #[serde(default)]\n+ pub locked: bool,\n+ #[serde(default)]\n+ pub distinguished: Option,\n+}\n+\n+/// Reddit comment data\n+#[derive(Debug, Clone, Serialize, Deserialize)]\n+pub struct RedditComment {\n+ pub id: String,\n+ pub name: String, // Full name (t1_xxx)\n+ #[serde(default = \"default_deleted_user\")]\n+ pub author: String,\n+ #[serde(default)]\n+ pub body: String,\n+ #[serde(default)]\n+ pub score: i64,\n+ #[serde(default)]\n+ pub created_utc: f64,\n+ #[serde(default)]\n+ pub parent_id: String,\n+ #[serde(default)]\n+ pub permalink: String,\n+ #[serde(default)]\n+ pub depth: i32,\n+ // Additional useful fields\n+ #[serde(default)]\n+ pub ups: i64,\n+ #[serde(default)]\n+ pub downs: i64,\n+ #[serde(default)]\n+ pub edited: RedditEditStatus,\n+ #[serde(default)]\n+ pub stickied: bool,\n+ #[serde(default)]\n+ pub distinguished: Option,\n+ #[serde(default)]\n+ pub is_submitter: bool,\n+ #[serde(default)]\n+ pub collapsed: bool,\n+ #[serde(default)]\n+ pub controversiality: i32,\n+}\n+\n+/// Reddit's edit status - can be false or a timestamp\n+#[derive(Debug, Clone, Serialize, Deserialize)]\n+#[serde(untagged)]\n+pub enum RedditEditStatus {\n+ NotEdited(bool),\n+ EditedAt(f64),\n+}\n+\n+impl Default for RedditEditStatus {\n+ fn default() -> Self {\n+ RedditEditStatus::NotEdited(false)\n+ }\n+}\n+\n+// Helper functions for serde defaults\n+fn default_untitled() -> String {\n+ \"Untitled\".to_string()\n+}\n+\n+fn default_deleted_user() -> String {\n+ \"[deleted]\".to_string()\n+}\n+\n+// Custom deserializer for selftext (empty strings should be None)\n+fn deserialize_selftext<'de, D>(deserializer: D) -> Result, D::Error>\n+where\n+ D: serde::Deserializer<'de>,\n+{\n+ let s: Option = Option::deserialize(deserializer)?;\n+ Ok(s.filter(|text| !text.is_empty()))\n+}\n+\n+// Custom deserializer for thumbnail (filter out \"self\", \"default\", empty)\n+fn deserialize_thumbnail<'de, D>(deserializer: D) -> Result, D::Error>\n+where\n+ D: serde::Deserializer<'de>,\n+{\n+ let s: Option = Option::deserialize(deserializer)?;\n+ Ok(s.filter(|thumb| {\n+ !thumb.is_empty() && thumb != \"self\" && thumb != \"default\" && thumb != \"nsfw\" && thumb != \"spoiler\"\n+ }))\n+}\n+\n+// Helper methods for extracting typed data from Things\n+impl RedditThing {\n+ /// Try to get this Thing as a Post\n+ pub fn as_post(&self) -> Option<&RedditPost> {\n+ if self.kind != \"t3\" {\n+ return None;\n+ }\n+ match &self.data {\n+ RedditThingData::Post(post) => Some(post),\n+ _ => None,\n+ }\n+ }\n+ \n+ /// Try to get this Thing as a Comment\n+ pub fn as_comment(&self) -> Option<&RedditComment> {\n+ if self.kind != \"t1\" {\n+ return None;\n+ }\n+ match &self.data {\n+ RedditThingData::Comment(comment) => Some(comment),\n+ _ => None,\n+ }\n+ }\n+ \n+ /// Check if this is a \"more comments\" indicator\n+ pub fn is_more_comments(&self) -> bool {\n+ self.kind == \"more\"\n+ }\n+}\n+\n+// Helper methods for working with listing responses\n+impl RedditListingResponse {\n+ /// Extract all posts from this listing\n+ pub fn get_posts(&self) -> Vec<&RedditPost> {\n+ self.data.children.iter()\n+ .filter_map(|thing| thing.as_post())\n+ .collect()\n+ }\n+ \n+ /// Extract all comments from this listing\n+ pub fn get_comments(&self) -> Vec<&RedditComment> {\n+ self.data.children.iter()\n+ .filter_map(|thing| thing.as_comment())\n+ .collect()\n+ }\n+ \n+ /// Extract posts as owned values\n+ pub fn into_posts(self) -> Vec {\n+ self.data.children.into_iter()\n+ .filter_map(|thing| {\n+ if thing.kind == \"t3\" {\n+ match thing.data {\n+ RedditThingData::Post(post) => Some(post),\n+ _ => None,\n+ }\n+ } else {\n+ None\n+ }\n+ })\n+ .collect()\n+ }\n+ \n+ /// Extract comments as owned values\n+ pub fn into_comments(self) -> Vec {\n+ self.data.children.into_iter()\n+ .filter_map(|thing| {\n+ if thing.kind == \"t1\" {\n+ match thing.data {\n+ RedditThingData::Comment(comment) => Some(comment),\n+ _ => None,\n+ }\n+ } else {\n+ None\n+ }\n+ })\n+ .collect()\n+ }\n+}\n+\n+\n+\n\n\nSide B — contributor: tommy-mor\nSide B — commit message:\n[af6c4464] moved delete button\n\nSide B — unified diff (full patch):\ndiff --git a/server/src/html/forum/ingest.rs b/server/src/html/forum/ingest.rs\nindex 168106e495cf1a81f62f6a49e35c64beea287924..308358abc6cd6811079d9ec41b114093c0294d02 100644\n--- a/server/src/html/forum/ingest.rs\n+++ b/server/src/html/forum/ingest.rs\n@@ -45,6 +45,7 @@ fn post_header_meta(\n principal: &str,\n ts: i64,\n now: i64,\n+ delete_post_id: Option<&str>,\n ) -> Markup {\n let post_href = nav.post_url(tag, post_idx);\n let profile = profile_href(principal);\n@@ -52,11 +53,19 @@ fn post_header_meta(\n let ago = timeago::timeago(now, ts);\n html! {\n div class=\"ingest-meta muted\" title=(hover) {\n- a href=(post_href) class=\"post-num\" { \"#\" (post_idx) }\n- \" \"\n- a href=(profile) class=\"post-author\" { \"@\" (principal) }\n- \" · \"\n- (ago)\n+ span class=\"ingest-meta-primary\" {\n+ a href=(post_href) class=\"post-num\" { \"#\" (post_idx) }\n+ \" \"\n+ a href=(profile) class=\"post-author\" { \"@\" (principal) }\n+ \" · \"\n+ (ago)\n+ }\n+ @if let Some(pid) = delete_post_id {\n+ form class=\"post-delete-form\" method=\"POST\" action=\"/ui\" {\n+ input type=\"hidden\" name=(UI_RPC_FIELD) value=(template_json_compact(&HtmlUiAction::RedactPost { post_id: pid.to_string() }).unwrap());\n+ button type=\"submit\" class=\"post-delete-btn\" { \"delete\" }\n+ }\n+ }\n }\n }\n }\n@@ -70,18 +79,12 @@ pub(super) fn post_header_row(\n now: i64,\n show_delete: bool,\n ) -> Markup {\n- let meta = post_header_meta(nav, tag, post_idx, &ing.principal, ing.ts, now);\n- html! {\n- div class=\"ingest-header-row\" {\n- (meta)\n- @if show_delete {\n- form class=\"post-delete-form\" method=\"POST\" action=\"/ui\" {\n- input type=\"hidden\" name=(UI_RPC_FIELD) value=(template_json_compact(&HtmlUiAction::RedactPost { post_id: ing.id.clone() }).unwrap());\n- button type=\"submit\" class=\"post-delete-btn\" { \"delete\" }\n- }\n- }\n- }\n- }\n+ let delete_post_id = if show_delete {\n+ Some(ing.id.as_str())\n+ } else {\n+ None\n+ };\n+ post_header_meta(nav, tag, post_idx, &ing.principal, ing.ts, now, delete_post_id)\n }\n \n pub(super) fn redacted_header_row(\n@@ -92,7 +95,7 @@ pub(super) fn redacted_header_row(\n now: i64,\n expanded: bool,\n ) -> Markup {\n- let meta = post_header_meta(nav, tag, post_idx, &ing.principal, ing.ts, now);\n+ let meta = post_header_meta(nav, tag, post_idx, &ing.principal, ing.ts, now, None);\n let rpc_expand = template_json_compact(&json!({\n \"action\": \"expand_redacted_post\",\n \"room\": nav.room_wire,\ndiff --git a/server/static/theme_default.css b/server/static/theme_default.css\nindex 560881c1eec62f12d1e66875287be3c2f39198fc..83b49d079e6bf3e47c27fbd443a0ae75b1a03051 100644\n--- a/server/static/theme_default.css\n+++ b/server/static/theme_default.css\n@@ -552,12 +552,21 @@ pre a.pre-link {\n }\n \n div.ingest-meta {\n+ align-items: center;\n background: var(--g3);\n border-bottom: 2px solid var(--lo);\n color: var(--meta);\n+ display: flex;\n+ flex-wrap: wrap;\n font-size: 12px;\n+ gap: 6px 10px;\n+ justify-content: space-between;\n padding: 3px 10px;\n }\n+span.ingest-meta-primary {\n+ flex: 1 1 auto;\n+ min-width: 0;\n+}\n a.post-num { color: var(--meta); font-size: 12px; }\n a.post-num:hover { color: var(--signal); }\n a.post-author { color: var(--meta); font-size: 12px; text-decoration: none; }\n@@ -579,7 +588,12 @@ div.ingest-header-row div.ingest-meta {\n flex: 1 1 auto;\n padding: 0;\n }\n-form.post-delete-form { display: inline; margin: 0; }\n+form.post-delete-form {\n+ display: block;\n+ flex-shrink: 0;\n+ margin: 0;\n+ margin-left: auto;\n+}\n button.post-delete-btn {\n background: var(--g4);\n border: var(--bv) solid;\ndiff --git a/server/static/theme_retro_craft.css b/server/static/theme_retro_craft.css\nindex eb022a8c84c1d0cff36410541872d68a11195e31..7181c7f8547940a402ae0211220fd6ee93ee1364 100644\n--- a/server/static/theme_retro_craft.css\n+++ b/server/static/theme_retro_craft.css\n@@ -132,8 +132,22 @@ p.post-truncation-action {\n margin: 0;\n }\n div.ingest-meta {\n+ align-items: center;\n border-bottom: 1px solid var(--line);\n- padding: 0.35rem 0.65rem;\n+ display: flex;\n+ flex-wrap: wrap;\n+ justify-content: space-between;\n+ padding-left: 0.35rem;\n+}\n+span.ingest-meta-primary {\n+ flex: 1 1 auto;\n+ min-width: 0;\n+}\n+form.post-delete-form {\n+ display: block;\n+ flex-shrink: 0;\n+ margin: 0;\n+ margin-left: auto;\n }\n a.post-num {\n color: var(--ink-dim);\n","role":"user"}],"model":"openai/gpt-chat-latest"}