{"header":{"message":"refactor: handlers, introduce stub PristineReader","description":null,"timestamp":"2026-04-03T15:31:07.166019848Z","authors":[{}]},"hash":"MTPFRBM4CQYIOAABKBYVSOW4KMRG6YD3U6ZC6D4XIQZ42LN5FSGQC","authors":[{"login":"tetov","key":"5HQnLNFtg9kqy7Qbt6KVMLvtgUhtPcUGET8SoKVUDNNF"}],"deps":{"hashes":[["MTPFRBM4CQYIOAABKBYVSOW4KMRG6YD3U6ZC6D4XIQZ42LN5FSGQC","refactor: handlers, introduce stub PristineReader"],["AA",null],["QZ4ZAYJJGG3NWG4KB5ZDDP6JAQX2UYDQX7PRKVIMPSAOBC6U543AC","refacor: responses"],["WRBOA3JH5NUP47SV755EX77CAVDL4HGOVZZWF2BBB6FSPA3N3RQQC","refactor: url handling"],["F6WZWYNDIMFPVDTZC6SLW67IFJD5AKOU4SK5HMYHFCAKIJKZFQLAC","add bench for parse_url, split funcs into lib"],["MGWNH72NNBWQCVZ7HSIFSUYHC4MSKJKLQA42UIR3VM6ULF3H2TZQC","scaffolding"]],"deps":["QZ4ZAYJJGG3NWG4KB5ZDDP6JAQX2UYDQX7PRKVIMPSAOBC6U543AC"],"known":["F6WZWYNDIMFPVDTZC6SLW67IFJD5AKOU4SK5HMYHFCAKIJKZFQLAC","WRBOA3JH5NUP47SV755EX77CAVDL4HGOVZZWF2BBB6FSPA3N3RQQC"]},"hunks":[{"FileAdd":{"meta":{"basename":"pristine.rs","metadata":0},"context":[{"change":6,"pos":15}],"contents":[{"Add":"//! (Stub) Reader for pijul's pristine sanakirja database."},{"Add":""},{"Add":"pub struct PristineReader {}"},{"Add":""},{"Add":"/// Entry from the changelist, representing a single change or tag in a channel."},{"Add":"///"},{"Add":"/// These entries are serialized by `serve_changelist()` in the format expected"},{"Add":"/// by `Http::download_changelist()` in the pijul client:"},{"Add":"/// - Regular change: `{position}.{hash}.{merkle}`"},{"Add":"/// - Tag: `{position}.{hash}.{merkle}.` (trailing dot indicates tag)"},{"Add":"#[derive(Debug, Clone)]"},{"Add":"pub struct ChangeEntry {"},{"Add":" /// Sequential position of this change in the channel's history."},{"Add":" pub position: u64,"},{"Add":" /// Base32-encoded hash of the change (content-addressed identifier)."},{"Add":" pub hash: String,"},{"Add":" /// Base32-encoded merkle hash representing cumulative state up to this"},{"Add":" /// position."},{"Add":" pub merkle: String,"},{"Add":" /// True if this entry is a tag (immutable state snapshot) rather than a"},{"Add":" /// regular change"},{"Add":" pub is_tag: bool,"},{"Add":"}"},{"Add":""},{"Add":"impl PristineReader {"},{"Add":" pub fn get_changelist(&self, channel: &str, from: u64) -> Vec {"},{"Add":" dbg!(channel, from);"},{"Add":" todo!()"},{"Add":" }"},{"Add":""},{"Add":" pub fn get_state(&self, channel: &str, n: u64) -> Option<(u64, String, String)> {"},{"Add":" dbg!(channel, n);"},{"Add":" todo!()"},{"Add":" }"},{"Add":""},{"Add":" pub fn list_channels(&self) -> Vec {"},{"Add":" todo!()"},{"Add":" }"},{"Add":"}"}]}},{"Edit":{"inode":{"change":3,"pos":31},"path":"src/lib.rs","line":1,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":31}],"down_context":[{"change":2,"pos":4869}],"flag":"BLOCK","start":1315,"end":1351,"inode":{"change":3,"pos":31}}},"contents":[{"Add":"pub mod handlers;"},{"Add":"pub mod pristine;"}]}},{"FileAdd":{"meta":{"basename":"handlers.rs","metadata":0},"context":[{"change":6,"pos":15}],"contents":[{"Add":"//! HTTP request handlers for pijul remote protocol endpoints."},{"Add":"//!"},{"Add":"//! These handlers implement the server-side of the pijul HTTP remote protocol"},{"Add":"//! as defined in pijul-remote/src/http.rs. The pijul client makes requests to"},{"Add":"//! `{url}/.pijul?{query}` and these handlers respond with the appropriate data."},{"Add":"//!"},{"Add":"//! Protocol version: 3 (PROTOCOL_VERSION in pijul-remote/src/lib.rs)"},{"Add":""},{"Add":"use std::path::Path;"},{"Add":""},{"Add":"use crate::pristine::PristineReader;"},{"Add":"use crate::responses::{HttpResponse, not_found, ok_json, ok_text, serve_file};"},{"Add":""},{"Add":"/// Serve channel RemoteId (16 bytes binary)."},{"Add":"///"},{"Add":"/// # Pijul Client Interaction"},{"Add":"/// - **Endpoint**: `GET /.pijul?channel={name}&id`"},{"Add":"/// - **Called by**: `Http::get_remote_id()` in pijul-remote/src/http.rs"},{"Add":"/// - **Response format**: Raw 16-byte binary RemoteId"},{"Add":"/// - **Purpose**: The client uses RemoteId to identify and cache remote state."},{"Add":"/// When syncing, pijul checks if the remote's ID matches the cached ID to"},{"Add":"/// determine if it can use cached changelist data."},{"Add":"///"},{"Add":"/// # Errors"},{"Add":"/// Returns 404 if the channel doesn't exist."},{"Add":"pub fn serve_channel_id(_reader: &PristineReader, _channel: &str) -> HttpResponse {"},{"Add":" todo!()"},{"Add":"}"},{"Add":""},{"Add":"/// Serve channel state information as JSON."},{"Add":"///"},{"Add":"/// # Pijul Client Interaction"},{"Add":"/// - **Endpoint**: `GET /.pijul?channel={name}` (without `id` flag)"},{"Add":"/// - **Response format**: JSON `{\"position\":N,\"merkle\":\"...\",\"tag_merkle\":\"...\"}`"},{"Add":"/// - **Purpose**: Provides the current state of a channel at position 0."},{"Add":"/// Note: The standard pijul client typically uses `get_state()` instead,"},{"Add":"/// but this endpoint provides a convenient JSON summary."},{"Add":"///"},{"Add":"/// # Errors"},{"Add":"/// Returns 404 if the channel doesn't exist."},{"Add":"pub fn serve_channel(reader: &PristineReader, channel: &str) -> HttpResponse {"},{"Add":" // Return channel state at position 0"},{"Add":" match reader.get_state(channel, 0) {"},{"Add":" Some((pos, merkle, tag_merkle)) => {"},{"Add":" let json = format!("},{"Add":" r#\"{{\"position\":{},\"merkle\":\"{}\",\"tag_merkle\":\"{}\"}}\"#,"},{"Add":" pos, merkle, tag_merkle"},{"Add":" );"},{"Add":" ok_json(&json)"},{"Add":" }"},{"Add":" None => not_found(\"channel not found\"),"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"/// Serve changelist starting from a given position."},{"Add":"///"},{"Add":"/// # Pijul Client Interaction"},{"Add":"/// - **Endpoint**: `GET /.pijul?changelist={from}&channel={name}`"},{"Add":"/// - **Called by**: `Http::download_changelist()` in pijul-remote/src/http.rs"},{"Add":"/// - **Response format**: Text, one entry per line:"},{"Add":"/// - Format: `{position}.{hash}.{merkle}` (no trailing `.` = regular change)"},{"Add":"/// - Format: `{position}.{hash}.{merkle}.` (trailing `.` = tag)"},{"Add":"/// - **Client parsing regex**: `(?P[0-9]+)\\.(?P[A-Za-z0-9]+)\\.(?P[A-Za-z0-9]+)(?P\\.)?`"},{"Add":"/// - **Purpose**: The client requests changelist to discover which changes exist"},{"Add":"/// on the remote that it doesn't have locally. It starts from position 0 for"},{"Add":"/// a fresh clone or from its last known position for incremental sync."},{"Add":"///"},{"Add":"/// # Data Sources"},{"Add":"/// - Reads from channel's `revchanges` btree (position -> ChangeId + Merkle)"},{"Add":"/// - Looks up change hashes in the `EXTERNAL` table (ChangeId -> SerializedHash)"},{"Add":"/// - Checks `tags` btree to determine if an entry is a tag"},{"Add":"pub fn serve_changelist(reader: &PristineReader, channel: &str, from: u64) -> HttpResponse {"},{"Add":" let entries = reader.get_changelist(channel, from);"},{"Add":""},{"Add":" let output: String = entries"},{"Add":" .iter()"},{"Add":" .map(|e| {"},{"Add":" let suffix = if e.is_tag { \".\" } else { \"\" };"},{"Add":" format!(\"{}.{}.{}{}\", e.position, e.hash, e.merkle, suffix)"},{"Add":" })"},{"Add":" .collect::>()"},{"Add":" .join(\"\\n\");"},{"Add":""},{"Add":" ok_text(output)"},{"Add":"}"},{"Add":""},{"Add":"/// Serve a change file by its base32-encoded hash."},{"Add":"///"},{"Add":"/// # Pijul Client Interaction"},{"Add":"/// - **Endpoint**: `GET /.pijul?change={hash}`"},{"Add":"/// - **Called by**: `Http::download_changes()` in pijul-remote/src/http.rs"},{"Add":"/// - **Response format**: Binary change file content (`application/octet-stream`)"},{"Add":"/// - **Purpose**: Downloads individual change files during clone/pull operations."},{"Add":"/// The client discovers needed changes via `changelist`, then downloads each"},{"Add":"/// missing change via this endpoint. Downloads occur in parallel (up to"},{"Add":"/// POOL_SIZE=20 concurrent requests in the pijul client)."},{"Add":"///"},{"Add":"/// # File Location"},{"Add":"/// Changes are stored at: `.pijul/changes/{first-2-chars}/{rest}.change`"},{"Add":"/// Example: hash `ABCDEF123` -> `.pijul/changes/AB/CDEF123.change`"},{"Add":"///"},{"Add":"/// # Caching"},{"Add":"/// Response includes `Cache-Control: public, max-age=31536000, immutable`"},{"Add":"/// because change files are content-addressed and never change."},{"Add":"///"},{"Add":"/// # Validation"},{"Add":"/// Hash must be at least 3 characters and contain only alphanumeric chars."},{"Add":"/// Returns 404 for invalid hashes or missing files."},{"Add":"pub fn serve_change(repo_path: &Path, hash: &str) -> HttpResponse {"},{"Add":" if hash.len() < 3 || !hash.chars().all(|c| c.is_ascii_alphanumeric()) {"},{"Add":" return not_found(\"invalid change hash\");"},{"Add":" }"},{"Add":""},{"Add":" let (pfx, sfx) = hash.split_at(2);"},{"Add":" let path = repo_path"},{"Add":" .join(\".pijul\")"},{"Add":" .join(\"changes\")"},{"Add":" .join(pfx)"},{"Add":" .join(format!(\"{}.change\", sfx));"},{"Add":""},{"Add":" serve_file(&path, \"application/octet-stream\")"},{"Add":"}"},{"Add":""},{"Add":"/// Serve channel state at a specific position."},{"Add":"///"},{"Add":"/// # Pijul Client Interaction"},{"Add":"/// - **Endpoint**: `GET /.pijul?state={position}&channel={name}`"},{"Add":"/// - **Called by**: `Http::get_state()` in pijul-remote/src/http.rs"},{"Add":"/// - **Response format**: Space-separated text: `{position} {merkle} {tag_merkle}`"},{"Add":"/// - **Purpose**: The client uses this to verify remote state and determine"},{"Add":"/// sync boundaries. The merkle hash allows efficient comparison of repository"},{"Add":"/// states without transferring all changes."},{"Add":"///"},{"Add":"/// # Data Sources"},{"Add":"/// - Reads from channel's `revchanges` btree for merkle at position N"},{"Add":"/// - Reads from channel's `tags` btree for tag_merkle at position N"},{"Add":"///"},{"Add":"/// # Special Return"},{"Add":"/// Returns \"-\" if the requested position doesn't exist"},{"Add":"pub fn serve_state(reader: &PristineReader, channel: &str, n: u64) -> HttpResponse {"},{"Add":" match reader.get_state(channel, n) {"},{"Add":" Some((pos, merkle, tag_merkle)) => ok_text(format!(\"{} {} {}\", pos, merkle, tag_merkle)),"},{"Add":" None => ok_text(\"-\".to_string()), // Spec says return \"-\" if not found"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"/// Serve a tag (state) file by its base32-encoded hash."},{"Add":"///"},{"Add":"/// # Pijul Client Interaction"},{"Add":"/// - **Endpoint**: `GET /.pijul?tag={hash}`"},{"Add":"/// - **Called by**: `Http::download_changes()` in pijul-remote/src/http.rs (for tags)"},{"Add":"/// - **Response format**: Binary tag file content (`application/octet-stream`)"},{"Add":"/// - **Purpose**: Downloads tag/state files. The changelist response"},{"Add":"/// indicates which entries are tags (trailing `.`), and the client downloads"},{"Add":"/// these via this endpoint."},{"Add":"///"},{"Add":"/// # File Location"},{"Add":"/// Tags are stored at: `.pijul/tags/{first-2-chars}/{rest}.tag`"},{"Add":"/// Example: hash `XYZABC789` -> `.pijul/tags/XY/ZABC789.tag`"},{"Add":"///"},{"Add":"/// # Caching"},{"Add":"/// Response includes `Cache-Control: public, max-age=31536000, immutable`"},{"Add":"/// because tag files are content-addressed and never change."},{"Add":"///"},{"Add":"/// # Validation"},{"Add":"/// Hash must be at least 3 characters and contain only alphanumeric chars."},{"Add":"/// Returns 404 for invalid hashes or missing files."},{"Add":"pub fn serve_tag(repo_path: &Path, hash: &str) -> HttpResponse {"},{"Add":" if hash.len() < 3 || !hash.chars().all(|c| c.is_ascii_alphanumeric()) {"},{"Add":" return not_found(\"invalid tag hash\");"},{"Add":" }"},{"Add":""},{"Add":" let (pfx, sfx) = hash.split_at(2);"},{"Add":" let path = repo_path"},{"Add":" .join(\".pijul\")"},{"Add":" .join(\"tags\")"},{"Add":" .join(pfx)"},{"Add":" .join(format!(\"{}.tag\", sfx));"},{"Add":""},{"Add":" serve_file(&path, \"application/octet-stream\")"},{"Add":"}"},{"Add":""},{"Add":"/// Serve identity certificates from the repository."},{"Add":"///"},{"Add":"/// # Pijul Client Interaction"},{"Add":"/// - **Endpoint**: `GET /.pijul?identities` or `GET /.pijul?identities={rev}`"},{"Add":"/// - **Called by**: `Http::update_identities()` in pijul-remote/src/http.rs"},{"Add":"/// - **Response format**: JSON `{\"id\":[...],\"rev\":N}`"},{"Add":"/// - `id`: Array of identity certificates (currently empty)"},{"Add":"/// - `rev`: Revision number for incremental updates"},{"Add":"/// - **Purpose**: Pijul supports cryptographic identity verification. The client"},{"Add":"/// requests identities to verify change authorship and establish trust."},{"Add":"/// The `rev` parameter allows incremental updates (only fetch new identities"},{"Add":"/// since a given revision)."},{"Add":"///"},{"Add":"/// # Current Implementation"},{"Add":"/// Returns empty identity list. A full implementation would read from"},{"Add":"/// `.pijul/identities/` and return serialized identity certificates."},{"Add":"pub fn serve_identities() -> HttpResponse {"},{"Add":" ok_json(r#\"{\"id\":[],\"rev\":0}\"#)"},{"Add":"}"},{"Add":""},{"Add":"/// Serve repository information including channel list."},{"Add":"///"},{"Add":"/// # Pijul Client Interaction"},{"Add":"/// - **Endpoint**: `GET /.pijul` (no query) or `GET /.pijul?log`"},{"Add":"/// - **Response format**: JSON `{\"channels\":[\"main\",...],\"head\":null}`"},{"Add":"/// - `channels`: Array of channel names in the repository"},{"Add":"/// - `head`: Currently always null (reserved for future use)"},{"Add":"/// - **Purpose**: Provides discovery information about the repository."},{"Add":"/// Clients can use this to enumerate available channels before cloning"},{"Add":"/// or pulling. The `?log` variant exists for compatibility but returns"},{"Add":"/// the same information."},{"Add":"///"},{"Add":"/// # Data Sources"},{"Add":"/// - Reads channel names from the `CHANNELS` root table in the pristine database"},{"Add":"pub fn serve_info(reader: &PristineReader) -> HttpResponse {"},{"Add":" let channels = reader.list_channels();"},{"Add":""},{"Add":" let mut out = String::from(\"{\");"},{"Add":""},{"Add":" if !channels.is_empty() {"},{"Add":" let names: Vec = channels.iter().map(|s| format!(\"\\\"{s}\\\"\")).collect();"},{"Add":" out.push_str(\"\\\"channels\\\":[\");"},{"Add":" out.push_str(&names.join(\",\"));"},{"Add":" out.push_str(\"],\");"},{"Add":" }"},{"Add":""},{"Add":" out.push_str(\"\\\"head\\\":null}\");"},{"Add":" ok_json(&out)"},{"Add":"}"},{"Add":""},{"Add":"#[cfg(test)]"},{"Add":"mod tests {"},{"Add":" use super::*;"},{"Add":" use std::fs;"},{"Add":" use std::io::Write;"},{"Add":" use tempfile::TempDir;"},{"Add":""},{"Add":" fn get_status(resp: &HttpResponse) -> u16 {"},{"Add":" resp.status_code().0"},{"Add":" }"},{"Add":""},{"Add":" fn get_header<'a>(resp: &'a HttpResponse, name: &str) -> Option<&'a str> {"},{"Add":" resp.headers()"},{"Add":" .iter()"},{"Add":" .find(|h| h.field.as_str().as_str().eq_ignore_ascii_case(name))"},{"Add":" .map(|h| h.value.as_str())"},{"Add":" }"},{"Add":""},{"Add":" // serve_change"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_change_hash_too_short() {"},{"Add":" let dir = TempDir::new().unwrap();"},{"Add":" let resp = serve_change(dir.path(), \"ab\");"},{"Add":" assert_eq!(get_status(&resp), 404);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_change_hash_empty() {"},{"Add":" let dir = TempDir::new().unwrap();"},{"Add":" let resp = serve_change(dir.path(), \"\");"},{"Add":" assert_eq!(get_status(&resp), 404);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_change_hash_invalid_chars() {"},{"Add":" let dir = TempDir::new().unwrap();"},{"Add":" let resp = serve_change(dir.path(), \"abc-def\");"},{"Add":" assert_eq!(get_status(&resp), 404);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_change_hash_with_slash() {"},{"Add":" let dir = TempDir::new().unwrap();"},{"Add":" let resp = serve_change(dir.path(), \"ab/cdef\");"},{"Add":" assert_eq!(get_status(&resp), 404);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_change_valid_hash_file_missing() {"},{"Add":" let dir = TempDir::new().unwrap();"},{"Add":" let resp = serve_change(dir.path(), \"abcdef123\");"},{"Add":" assert_eq!(get_status(&resp), 404);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_change_valid_hash_file_exists() {"},{"Add":" let dir = tempfile::TempDir::new().unwrap();"},{"Add":" let change_dir = dir.path().join(\".pijul\").join(\"changes\").join(\"ab\");"},{"Add":" fs::create_dir_all(&change_dir).unwrap();"},{"Add":" let change_file = change_dir.join(\"cdef123.change\");"},{"Add":" fs::File::create(&change_file)"},{"Add":" .unwrap()"},{"Add":" .write_all(b\"change data\")"},{"Add":" .unwrap();"},{"Add":""},{"Add":" let resp = serve_change(dir.path(), \"abcdef123\");"},{"Add":" assert_eq!(get_status(&resp), 200);"},{"Add":" assert_eq!("},{"Add":" get_header(&resp, \"Content-Type\"),"},{"Add":" Some(\"application/octet-stream\")"},{"Add":" );"},{"Add":" }"},{"Add":""},{"Add":" // serve_tag"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_tag_hash_too_short() {"},{"Add":" let dir = TempDir::new().unwrap();"},{"Add":" let resp = serve_tag(dir.path(), \"ab\");"},{"Add":" assert_eq!(get_status(&resp), 404);"},{"Add":" }"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_tag_valid_hash_file_exists() {"},{"Add":" let dir = TempDir::new().unwrap();"},{"Add":" let tag_dir = dir.path().join(\".pijul\").join(\"tags\").join(\"ab\");"},{"Add":" fs::create_dir_all(&tag_dir).unwrap();"},{"Add":" let tag_file = tag_dir.join(\"cdef123.tag\");"},{"Add":" fs::File::create(&tag_file)"},{"Add":" .unwrap()"},{"Add":" .write_all(b\"tag data\")"},{"Add":" .unwrap();"},{"Add":""},{"Add":" let resp = serve_tag(dir.path(), \"abcdef123\");"},{"Add":" assert_eq!(get_status(&resp), 200);"},{"Add":" assert_eq!("},{"Add":" get_header(&resp, \"Content-Type\"),"},{"Add":" Some(\"application/octet-stream\")"},{"Add":" );"},{"Add":" }"},{"Add":""},{"Add":" // serve_identities tests"},{"Add":""},{"Add":" #[test]"},{"Add":" fn test_serve_identities() {"},{"Add":" let resp = serve_identities();"},{"Add":" assert_eq!(get_status(&resp), 200);"},{"Add":" assert_eq!(get_header(&resp, \"Content-Type\"), Some(\"application/json\"));"},{"Add":" }"},{"Add":"}"}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":1,"ins":{"up_context":[{"change":3,"pos":2771}],"down_context":[{"change":3,"pos":4729}],"flag":"BLOCK","start":14203,"end":14482,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2771},"to":{"change":2,"start":4889,"end":4967},"introduced_by":2}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":"use pijul_srv_lite::handlers::{"},{"Add":" serve_change, serve_changelist, serve_channel, serve_channel_id, serve_identities, serve_info,"},{"Add":" serve_state, serve_tag,"},{"Add":"};"},{"Add":"use pijul_srv_lite::pristine::PristineReader;"},{"Add":"use pijul_srv_lite::responses::{HttpResponse, bad_request, not_found};"}],"del_contents":[{"Del":"use pijul_srv_lite::responses::{bad_request, not_found, ok_json, serve_file};\n"}]}},{"Edit":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":8,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4765}],"down_context":[{"change":3,"pos":2803}],"flag":"BLOCK","start":14483,"end":14484,"inode":{"change":3,"pos":2771}}},"contents":[{"Add":""}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":52,"ins":{"up_context":[{"change":3,"pos":4033}],"down_context":[{"change":3,"pos":4120}],"flag":"BLOCK","start":14485,"end":14550,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4033},"to":{"change":3,"start":4033,"end":4120},"introduced_by":3}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":"fn handle_request(url: &str, repo_path: &Path) -> HttpResponse {"}],"del_contents":[{"Del":"fn handle_request(url: &str, repo_path: &Path) -> Response>> {\n"}]}},{"Edit":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":59,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4244}],"down_context":[{"change":3,"pos":4244}],"flag":"BLOCK","start":14551,"end":14588,"inode":{"change":3,"pos":2771}}},"contents":[{"Add":" let reader = PristineReader {};"},{"Add":""}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":62,"ins":{"up_context":[{"change":3,"pos":4270}],"down_context":[{"change":3,"pos":4308}],"flag":"BLOCK","start":14589,"end":14625,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4270},"to":{"change":3,"start":4270,"end":4308},"introduced_by":3}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":" return serve_info(&reader);"}],"del_contents":[{"Del":" return serve_info(repo_path);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":71,"ins":{"up_context":[{"change":3,"pos":4418}],"down_context":[{"change":3,"pos":4534}],"flag":"BLOCK","start":14626,"end":14734,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4418},"to":{"change":3,"start":4901,"end":5021},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":5021},"to":{"change":3,"start":4482,"end":4534},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4482},"to":{"change":3,"start":4482,"end":4534},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4534},"to":{"change":3,"start":5022,"end":5053},"introduced_by":3}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":" if let Some(changelists) = query.get(\"changelist\")"},{"Add":" && let Some(channels) = query.get(\"channel\")"}],"del_contents":[{"Del":" if let Some(changelist) = query.get(\"changelist\")\n && !changelist.is_empty()\n && changelist[0] == \"0\"\n"},{"Del":" && let Some(channel) = query.get(\"channel\")\n"},{"Del":" && !channel.is_empty()\n"}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":74,"ins":{"up_context":[{"change":3,"pos":4540}],"down_context":[{"change":3,"pos":4593}],"flag":"BLOCK","start":14735,"end":15023,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4540},"to":{"change":3,"start":5054,"end":5111},"introduced_by":3}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":" match (changelists.as_slice(), channels.as_slice()) {"},{"Add":" ([from], [channel]) => {"},{"Add":" if let Ok(from) = from.parse::() {"},{"Add":" return serve_changelist(&reader, channel, from);"},{"Add":" };"},{"Add":" }"},{"Add":" _ => (),"},{"Add":" }"}],"del_contents":[{"Del":" return serve_changelist(repo_path, &channel[0]);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":84,"ins":{"up_context":[{"change":3,"pos":4600}],"down_context":[{"change":3,"pos":4745}],"flag":"BLOCK","start":15024,"end":15328,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4600},"to":{"change":3,"start":5112,"end":5197},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":5197},"to":{"change":3,"start":4650,"end":4688},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4650},"to":{"change":3,"start":4650,"end":4688},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4688},"to":{"change":3,"start":5198,"end":5259},"introduced_by":3}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":" if let Some(channel) = query.get(\"channel\") {"},{"Add":" match channel.as_slice() {"},{"Add":" [channel] => match query.get(\"id\") {"},{"Add":" Some(_) => return serve_channel_id(&reader, channel),"},{"Add":" None => return serve_channel(&reader, channel),"},{"Add":" },"},{"Add":" _ => (),"}],"del_contents":[{"Del":" if let Some(channel) = query.get(\"channel\")\n && !channel.is_empty()\n {\n"},{"Del":" if query.contains_key(\"id\") {\n"},{"Del":" return serve_channel_id(repo_path, &channel[0]);\n"}]}},{"Edit":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":92,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4755},"to":{"change":3,"start":5260,"end":5314},"introduced_by":3}],"inode":{"change":3,"pos":2771}}},"contents":[{"Del":" return serve_channel(repo_path, &channel[0]);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":94,"ins":{"up_context":[{"change":3,"pos":4812}],"down_context":[{"change":3,"pos":4894}],"flag":"BLOCK","start":15329,"end":15739,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4812},"to":{"change":3,"start":4812,"end":4894},"introduced_by":3}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":" if let Some(positions) = query.get(\"state\")"},{"Add":" && let Some(channels) = query.get(\"channel\")"},{"Add":" {"},{"Add":" match (positions.as_slice(), channels.as_slice()) {"},{"Add":" ([position], [channel]) => {"},{"Add":" if let Ok(position) = position.parse::() {"},{"Add":" return serve_state(&reader, channel, position);"},{"Add":" }"},{"Add":" }"},{"Add":" _ => (),"},{"Add":" }"},{"Add":" };"}],"del_contents":[{"Del":" if query.contains_key(\"state\") {\n return serve_state(repo_path);\n }\n"}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":112,"ins":{"up_context":[{"change":3,"pos":5014}],"down_context":[{"change":3,"pos":5052}],"flag":"BLOCK","start":15740,"end":15776,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5014},"to":{"change":3,"start":5014,"end":5052},"introduced_by":3}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":" return serve_info(&reader);"}],"del_contents":[{"Del":" return serve_info(repo_path);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":115,"ins":{"up_context":[{"change":3,"pos":5059}],"down_context":[{"change":3,"pos":5131}],"flag":"BLOCK","start":15777,"end":15938,"inode":{"change":3,"pos":2771}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5059},"to":{"change":3,"start":5059,"end":5131},"introduced_by":3}],"inode":{"change":3,"pos":2771}},"ins_contents":[{"Add":" if let Some(tags) = query.get(\"tag\") {"},{"Add":" match tags.as_slice() {"},{"Add":" [tag] => return serve_tag(repo_path, tag),"},{"Add":" _ => (),"},{"Add":" }"}],"del_contents":[{"Del":" if query.contains_key(\"tag\") {\n return serve_tag(repo_path);\n"}]}},{"Edit":{"inode":{"change":3,"pos":2771},"path":"src/bin/main.rs","line":124,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5158},"to":{"change":3,"start":5158,"end":5159},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5218},"to":{"change":3,"start":5218,"end":7400},"introduced_by":3}],"inode":{"change":3,"pos":2771}}},"contents":[{"Del":"\n"},{"Del":"fn serve_channel_id(repo_path: &Path, _channel: &str) -> Response>> {\n let path = repo_path.join(\".pijul\").join(\"pristine\").join(\"db\");\n\n serve_file(&path, \"application/octet-stream\")\n}\n\nfn serve_channel(repo_path: &Path, _channel: &str) -> Response>> {\n let path = repo_path.join(\".pijul\").join(\"pristine\").join(\"db\");\n\n serve_file(&path, \"application/octet-stream\")\n}\n\nfn serve_changelist(repo_path: &Path, channel: &str) -> Response>> {\n let path = repo_path.join(\"changelists\").join(channel);\n\n serve_file(&path, \"text/plain\")\n}\n\nfn serve_change(repo_path: &Path, hash: &str) -> Response>> {\n if hash.len() < 3 || !hash.chars().all(|c| c.is_ascii_alphanumeric()) {\n return not_found(\"invalid change hash\");\n }\n\n let (pfx, sfx) = hash.split_at(2);\n let path = repo_path\n .join(\".pijul\")\n .join(\"changes\")\n .join(pfx)\n .join(format!(\"{}.change\", sfx));\n\n serve_file(&path, \"application/octet-stream\")\n}\n\nfn serve_state(repo_path: &Path) -> Response>> {\n let path = repo_path.join(\".pijul\").join(\"pristine\").join(\"db\");\n\n serve_file(&path, \"application/octet-stream\")\n}\n\nfn serve_tag(repo_path: &Path) -> Response>> {\n let path = repo_path.join(\".pijul\").join(\"pristine\").join(\"db\");\n\n serve_file(&path, \"application/octet-stream\")\n}\n\nfn serve_identities() -> Response>> {\n ok_json(r#\"{\"id\":[],\"rev\":0}\"#)\n}\n\nfn serve_info(repo_path: &Path) -> Response>> {\n let mut out = String::from(\"{\");\n\n let path = repo_path.join(\"changelists\");\n if let Ok(entries) = std::fs::read_dir(path) {\n let names: Vec = entries\n .filter_map(|e| e.ok().and_then(|e| e.file_name().into_string().ok()))\n .map(|s| format!(\"\\\"{s}\\\"\"))\n .collect();\n\n if !names.is_empty() {\n out.push_str(\"\\\"channels\\\":[\");\n out.push_str(&names.join(\",\"));\n out.push_str(\"],\");\n }\n }\n\n out.push_str(\"\\\"head\\\":null}\");\n ok_json(&out)\n}\n"}]}}],"owner":"tetov","repo":"pijul-srv-lite","token":"HUSQU6sxpG/WrxVvRmUvT9n+K7MdMhYVH/LrOyAzIsU=","login":null}

…

Dependencies

Change contents