{"header":{"message":"Some better error handling + implements gzipping packets + corrects bug with architecture name in ubuntu repos","description":null,"timestamp":"2026-02-04T15:06:05.732052098Z","authors":[{}]},"hash":"NJOCBMW63YOWBM72N44C32BLSVKDL6TMOMGOUCZOLDSZQSENQAJAC","authors":[{"login":"Madx","key":"5GewrUUFjgxvfFXF5ECL1PHee2B3SKthxCg37jNfDZr9"}],"deps":{"hashes":[["NJOCBMW63YOWBM72N44C32BLSVKDL6TMOMGOUCZOLDSZQSENQAJAC","Some better error handling + implements gzipping packets + corrects bug with architecture name in ubuntu repos"],["AA",null],["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","First working shell (with ocaml code)"],["LIMIMBOUN3DCIKKTHOK4TAXAWQXNVQXBTMNZYN22DJX4L4FZQH4AC","Bootstrapping the Rust part"],["2GMRXGVB4TIODHNVO53MLMSVTZW4TVWITZAGPFIH5CCHVHLOGHYAC","Some better error handling + implements gzipping packets + corrects bug with architecture name in ubuntu repos"],["NT4JHHKXB7ARESVKFQAQCMFJUEIJDHKCTU4KAMBX7ZWIONJTL3JAC","Implementing the handshake call in the protocol"],["AJLMC7UMTMBYBXLOSMGT5PDNX4D7O7LV4GDV7AN25CPOBPRUFYVAC","Forwarding log to frontend"],["ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","Adding the OCaml interface"]],"deps":["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","LIMIMBOUN3DCIKKTHOK4TAXAWQXNVQXBTMNZYN22DJX4L4FZQH4AC","2GMRXGVB4TIODHNVO53MLMSVTZW4TVWITZAGPFIH5CCHVHLOGHYAC"],"known":["ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","AJLMC7UMTMBYBXLOSMGT5PDNX4D7O7LV4GDV7AN25CPOBPRUFYVAC","NT4JHHKXB7ARESVKFQAQCMFJUEIJDHKCTU4KAMBX7ZWIONJTL3JAC"]},"hunks":[{"FileDel":{"deleted_names":[{"basename":"deb.rs~","metadata":0}],"del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":2,"pos":15},"to":{"change":4,"start":0,"end":31},"introduced_by":4},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":31},"to":{"change":4,"start":32,"end":32},"introduced_by":4}],"inode":{"change":4,"pos":32}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":32},"to":{"change":4,"start":33,"end":22534},"introduced_by":4}],"inode":{"change":4,"pos":32}},"content":[{"Del":"use lazy_static::lazy_static;\nuse std::collections::HashMap;\nuse std::ffi::OsStr;\nuse std::io::{BufRead, BufReader, Read, Seek, SeekFrom};\nuse thiserror::*;\nuse tracing::*;\nmod index;\npub use index::*;\n\n/// A parsed .deb file.\n#[derive(Debug)]\npub struct Deb {\n md5sums: HashMap,\n control_file: String,\n _global: Header,\n _control: Header,\n data: Header,\n data_offset: u64,\n}\n\n/// A \"stanza\", i.e. a description of a Debian package.\n#[derive(Debug, Default, Clone)]\npub struct Stanza<'a> {\n #[allow(missing_docs)]\n pub package: &'a str,\n #[allow(missing_docs)]\n pub version: Version<'a>,\n #[allow(missing_docs)]\n pub architecture: &'a str,\n #[allow(missing_docs)]\n pub depends: Vec>,\n #[allow(missing_docs)]\n pub sha256: Option<&'a str>,\n #[allow(missing_docs)]\n pub size: Option,\n /// Path of the .deb file inside an index.\n pub file_name: Option<&'a str>,\n}\n\n/// A dependency, which is either a \"simple\" dependency, or a list of\n/// alternatives.\n#[derive(Debug, Clone)]\npub enum Dep<'a> {\n /// A simple dependency.\n Simple(SimpleDep<'a>),\n /// A dependency that can be supplied by multiple packages. This\n /// is an alternative mechanism to virtual packages.\n Alternatives {\n #[allow(missing_docs)]\n alt: Vec>,\n },\n}\n\n/// A single dependency.\n#[derive(Debug, Clone)]\npub struct SimpleDep<'a> {\n /// Name of the dependency.\n pub name: &'a str,\n /// Whether this dependency can have any version.\n pub any: bool,\n /// Constraints on dependencies.\n pub constraints: Vec<(&'a str, Version<'a>)>,\n}\n\nfn parse_control(s: &str) -> IResult<&str, Stanza> {\n let mut st = Stanza::default();\n\n for l in s.lines() {\n if l.is_empty() {\n let (_, b) = s.split_at(l.as_ptr() as usize - s.as_ptr() as usize);\n return Ok((b, st));\n }\n\n if let Some(i) = l.find(':') {\n let (key, val) = l.split_at(i);\n let (_, val) = val.split_at(1);\n debug!(\"key {:?} {:?}\", key, val);\n match key.trim() {\n \"Package\" => st.package = val.trim(),\n \"Version\" => st.version = parse_version(val.trim()).unwrap().1,\n \"Architecture\" => st.architecture = val.trim(),\n \"SHA256\" => st.sha256 = Some(val.trim()),\n \"Filename\" => st.file_name = Some(val.trim()),\n \"Depends\" | \"Pre-Depends\" => {\n let d = parse_deps(val.trim());\n debug!(\"{:?}\", d);\n if let Ok((\"\", a)) = d {\n st.depends = a\n } else {\n error!(\"error {:?}\", val.trim());\n return IResult::Err(nom::Err::Error(nom::error::make_error(\n s,\n nom::error::ErrorKind::Tag,\n )));\n }\n }\n _ => {}\n }\n }\n }\n\n Ok((\"\", st))\n}\n\n#[test]\nfn test_grub_common() {\n use tracing_subscriber::prelude::*;\n use tracing_subscriber::util::SubscriberInitExt;\n tracing_subscriber::registry()\n .with(\n tracing_subscriber::EnvFilter::try_from_default_env()\n .unwrap_or_else(|_| String::new().into()),\n )\n .with(tracing_subscriber::fmt::layer())\n .try_init()\n .unwrap();\n\n let (rest, p) = parse_control(\"Package: grub-common\\nArchitecture: amd64\\nVersion: 2.12-1ubuntu7\\nBuilt-Using: lzo2 (= 2.10-2build3)\\nMulti-Arch: foreign\\nPriority: optional\\nSection: admin\\nSource: grub2\\nOrigin: Ubuntu\\nMaintainer: Ubuntu Developers \\nOriginal-Maintainer: GRUB Maintainers \\nBugs: https://bugs.launchpad.net/ubuntu/+filebug\\nInstalled-Size: 12476\\nDepends: libc6 (>= 2.38), libdevmapper1.02.1 (>= 2:1.02.36), libefiboot1t64 (>=38), libefivar1t64 (>= 38), libfreetype6 (>= 2.2.1), libfuse3-3 (>= 3.2.3), liblzma5 (>= 5.1.1alpha+20120614), debconf (>= 0.5) | debconf-2.0, gettext-base, lsb-base (>= 3.0-6), python3, python3-apt\\nRecommends: os-prober (>= 1.33)\\nSuggests: multiboot-doc, grub-emu, mtools, xorriso (>= 0.5.6.pl00), desktop-base (>= 4.0.6), console-setup\\nConflicts: init-select\\nBreaks: apport (<< 2.1.1), friendly-recovery (<< 0.2.13), lupin-support (<< 0.55), mdadm (<< 2.6.7-2)\\nReplaces: grub-coreboot (<< 2.00-4), grub-efi (<< 1.99-1), grub-efi-amd64 (<< 2.00-4), grub-efi-ia32 (<< 2.00-4), grub-efi-ia64 (<< 2.00-4), grub-ieee1275 (<< 2.00-4), grub-linuxbios (<< 1.96+20080831-1), grub-pc (<< 2.00-4), grub-yeeloong (<< 2.00-4), init-select\\nFilename: pool/main/g/grub2/grub-common_2.12-1ubuntu7_amd64.deb\\nSize: 2119862\\nMD5sum: 86e63081ae4ee34d6a4f408ac6dbf0e4\\nSHA1: b98f9f88e5480423e041fd647b438ba2f6e6f5ea\\nSHA256: d8110b97b6fb6da40449c74b9cb527f02965dffaae8344399a711617f5a69249\\nSHA512: 85c63b8d3e6a870df48533ab525df13abe9ec4861ff4b5577def94f65a2ebf6ac44a54a6cd0eca1c825e1c7aa2bd14e4d4ed53f83d381963ac1dc51daa16482a\\nHomepage: https://www.gnu.org/software/grub/\\nDescription: GRand Unified Bootloader (common files)\\nTask: ubuntu-desktop-minimal, ubuntu-desktop, ubuntu-desktop-raspi, kubuntu-desktop, xubuntu-minimal, xubuntu-desktop, lubuntu-desktop, ubuntustudio-desktop-core, ubuntustudio-desktop, ubuntukylin-desktop,ubuntukylin-desktop-minimal, ubuntu-mate-core, ubuntu-mate-desktop, ubuntu-budgie-desktop-minimal, ubuntu-budgie-desktop, ubuntu-budgie-desktop-raspi, ubuntu-unity-desktop, edubuntu-desktop-gnome-minimal, edubuntu-desktop-gnome-raspi, ubuntucinnamon-desktop-minimal, ubuntucinnamon-desktop-raspi\\nDescription-md5: 9c75036dc0a0792fedbc58df208ed227\").unwrap();\n\n assert!(p.depends.iter().any(|x| match x {\n Dep::Simple(s) => s.name == \"liblzma5\",\n _ => false,\n }));\n\n assert!(rest.is_empty())\n}\n\n/// A version of a package.\n#[derive(Debug, Clone)]\npub struct Version<'a> {\n /// Epoch, i.e. a Debian mechanism to reorder upstream versions if\n /// necessary, for example if the upstream versioning scheme\n /// changes.\n pub epoch: u32,\n /// Upstream version.\n pub upstream_version: Upstream<'a>,\n /// Debian-specific suffix to distinguish between patches.\n pub debian: Option<&'a str>,\n}\n\nimpl<'a> Default for Version<'a> {\n fn default() -> Version<'a> {\n Version {\n epoch: 0,\n upstream_version: Upstream(\"\"),\n debian: None,\n }\n }\n}\n\nfn parse_constraint<'a>(s: &'a str) -> IResult<&'a str, (&'a str, Version<'a>)> {\n let (s, constraint) = tag(\"<<\")\n .or(tag(\"<=\"))\n .or(tag(\"=\"))\n .or(tag(\">=\"))\n .or(tag(\">>\"))\n .parse(s)?;\n debug!(\"parse_constraint {:?}\", constraint);\n let (s, _) = space0(s)?;\n let (s, version) = parse_version(s)?;\n debug!(\"parse_constraint {:?} {:?}\", s, (constraint, &version));\n Ok((s, (constraint, version)))\n}\n\nfn parse_dep<'a>(s0: &'a str) -> IResult<&'a str, Dep<'a>> {\n let (s, name) = parse_name(s0)?;\n let (s, any) = if s.starts_with(\":any\") {\n let (_, b) = s.split_at(4);\n (b, true)\n } else {\n (s, false)\n };\n let (s, _) = space0(s)?;\n let mut constraints = Vec::new();\n if let Ok((s, _)) = tag::<_, _, ()>(\"(\").parse(s) {\n let (s, version) = if let Some(i) = s.find(')') {\n let (a, b) = s.split_at(i);\n let (_, b) = b.split_at(1);\n (b, a)\n } else {\n return IResult::Err(nom::Err::Error(nom::error::make_error(\n s,\n nom::error::ErrorKind::Tag,\n )));\n };\n\n let mut v = version;\n while let Ok((v_, c)) = parse_constraint(v) {\n constraints.push(c);\n let (v_, _) = space0(v_)?;\n if let Ok((v_, _)) = tag::<_, _, ()>(\",\").parse(v_) {\n let (v_, _) = space0(v_)?;\n v = v_;\n } else {\n break;\n }\n }\n\n Ok((\n s,\n Dep::Simple(SimpleDep {\n name,\n any,\n constraints,\n }),\n ))\n } else {\n Ok((\n s,\n Dep::Simple(SimpleDep {\n name,\n any,\n constraints,\n }),\n ))\n }\n}\n\nfn parse_name(s: &str) -> IResult<&str, &str> {\n if let Some(i) = s.find(|c| {\n !((c >= 'a' && c <= 'z') || (c >= '0' && c <= '9') || c == '.' || c == '+' || c == '-')\n }) {\n if i > 0 {\n let (a, b) = s.split_at(i);\n return Ok((b, a));\n }\n } else {\n return Ok((\"\", s));\n }\n error!(\"ERROR {:?}\", s);\n return IResult::Err(nom::Err::Error(nom::error::make_error(\n s,\n nom::error::ErrorKind::Tag,\n )));\n}\n\nfn parse_deps<'a>(s: &'a str) -> IResult<&'a str, Vec>> {\n let mut d = Vec::new();\n let (mut s, _) = space0(s)?;\n let mut alt_is_open = false;\n while let Ok((s_, d_)) = parse_dep(s) {\n let (s_, _) = space0(s_)?;\n if let Ok((s_, _)) = tag::<_, _, ()>(\"|\").parse(s_) {\n let (s_, _) = space0(s_)?;\n s = s_;\n alt_is_open = true;\n if let Dep::Simple(d_) = d_ {\n if let Some(Dep::Alternatives { ref mut alt }) = d.last_mut() {\n alt.push(d_)\n } else {\n d.push(Dep::Alternatives { alt: vec![d_] })\n }\n } else {\n panic!(\"{:?}\", s);\n }\n } else if let Ok((s_, _)) = tag::<_, _, ()>(\",\").parse(s_) {\n if alt_is_open {\n if let Some(Dep::Alternatives { ref mut alt }) = d.last_mut() {\n if let Dep::Simple(d_) = d_ {\n alt.push(d_)\n } else {\n panic!(\"{:?}\", s);\n }\n }\n } else {\n d.push(d_)\n }\n alt_is_open = false;\n s = s_;\n } else {\n if alt_is_open {\n if let Some(Dep::Alternatives { ref mut alt }) = d.last_mut() {\n if let Dep::Simple(d_) = d_ {\n alt.push(d_)\n } else {\n panic!(\"{:?}\", s);\n }\n }\n } else {\n d.push(d_)\n }\n s = s_;\n break;\n }\n let (s_, _) = space0(s)?;\n s = s_;\n }\n Ok((s, d))\n}\n\n/// The representation of an upstream version. Will implement `Ord`.\n#[derive(Debug, Clone, PartialEq, Eq)]\npub struct Upstream<'a>(&'a str);\n\nimpl<'a> std::ops::Deref for Upstream<'a> {\n type Target = str;\n fn deref(&self) -> &str {\n self.0\n }\n}\n\nimpl<'a> PartialOrd for Upstream<'a> {\n /// Following the algorithm described here:\n /// https://www.debian.org/doc/debian-policy/ch-controlfields.html#version\n fn partial_cmp(&self, b: &Upstream<'a>) -> Option {\n fn split_initial(s: &str) -> (&str, &str, &str) {\n // Find `u`, the first digit, and `v > u`, the first non-digit after `u`.\n let mut u = s.len();\n let mut v = s.len();\n for (n, &b) in s.as_bytes().iter().enumerate() {\n if u == s.len() {\n if b >= b'0' && b <= b'9' {\n u = n\n }\n } else if b < b'0' || b > b'9' {\n v = n;\n break;\n }\n }\n let (ab, c) = s.split_at(v);\n let (a, b) = ab.split_at(u);\n (a, b, c)\n }\n let mut a = self.0;\n let mut b = b.0;\n use std::cmp::Ordering;\n loop {\n let (a0, a1, a_) = split_initial(a);\n let (b0, b1, b_) = split_initial(b);\n // Compare a0 / b0 using the modified ASCII ordering described in the Debian manual.\n let mut a0i = a0.as_bytes().iter();\n let mut b0i = b0.as_bytes().iter();\n loop {\n match (a0i.next(), b0i.next()) {\n (None, None) => break,\n (Some(c), Some(d)) if c == d => continue,\n (Some(b'~'), _) => return Some(Ordering::Less),\n (_, Some(b'~')) => return Some(Ordering::Greater),\n (Some(c), Some(d)) if c.is_ascii_alphabetic() && !d.is_ascii_alphabetic() => {\n return Some(Ordering::Less);\n }\n (Some(c), Some(d)) if d.is_ascii_alphabetic() && !c.is_ascii_alphabetic() => {\n return Some(Ordering::Greater);\n }\n (c, d) => return Some(c.cmp(&d)),\n }\n }\n // If we haven't returned, a0 == b0. Compare the digits part.\n let a1 = if a1.is_empty() {\n 0\n } else {\n a1.parse::().unwrap()\n };\n let b1 = if b1.is_empty() {\n 0\n } else {\n b1.parse::().unwrap()\n };\n let cmp1 = a1.cmp(&b1);\n if let Ordering::Equal = cmp1 {\n a = a_;\n b = b_;\n } else {\n return Some(cmp1);\n }\n }\n }\n}\n\nimpl<'a> Ord for Upstream<'a> {\n fn cmp(&self, b: &Upstream<'a>) -> std::cmp::Ordering {\n self.partial_cmp(b).unwrap()\n }\n}\n\n#[test]\nfn test_upstream_ordering() {\n let mut x = [\n Upstream(\"~~\"),\n Upstream(\"~~a\"),\n Upstream(\"~\"),\n Upstream(\"\"),\n Upstream(\"a\"),\n ];\n let y = x.clone();\n x.sort();\n assert_eq!(x, y,);\n}\n\nuse nom::{\n bytes::tag,\n character::complete::{digit1, newline, space0},\n multi::separated_list1,\n IResult, Parser,\n};\n\n/// Parse a version in the Debian version format.\nfn parse_version<'a>(s: &'a str) -> IResult<&'a str, Version<'a>> {\n fn epoch(s: &str) -> IResult<&str, u32> {\n let (s, i) = digit1(s)?;\n let (s, _) = tag(\":\").parse(s)?;\n Ok((s, i.parse().unwrap()))\n }\n\n let (s, epoch) = epoch(s).unwrap_or((s, 0));\n lazy_static! {\n static ref RE_DASH: regex::Regex =\n regex::Regex::new(r\"^[a-z0-9\\.~+-]+-([a-z0-9\\.~+]+)\").unwrap();\n static ref RE: regex::Regex = regex::Regex::new(r\"^[a-z0-9\\.~+]+\").unwrap();\n }\n\n let (s, v) = if let Some(m) = RE_DASH.find(s) {\n debug!(\"parse_version RE_DASH {:?}\", s);\n let (a, b) = s.split_at(m.end());\n (b, a)\n } else if let Some(m) = RE.find(s) {\n debug!(\"parse_version RE {:?}\", s);\n let (a, b) = s.split_at(m.end());\n (b, a)\n } else {\n debug!(\"parse_version failed {:?}\", s);\n return IResult::Err(nom::Err::Error(nom::error::make_error(\n s,\n nom::error::ErrorKind::Tag,\n )));\n };\n\n let (upstream_version, debian) = if let Some(i) = v.rfind('-') {\n let (a, b) = v.split_at(i);\n (Upstream(a), Some(b.split_at(1).1))\n } else {\n (Upstream(v), None)\n };\n\n Ok((\n s,\n Version {\n epoch,\n upstream_version,\n debian,\n },\n ))\n}\n\n/// Structure of the \"headers\" in the debian file. No alignment\n/// necessary, the numbers are in decimal. No heap allocation.\n#[derive(Debug)]\n#[repr(C)]\nstruct H {\n file_id: [u8; 16],\n timestamp: [u8; 12],\n owner_id: [u8; 6],\n group_id: [u8; 6],\n file_mode: [u8; 8],\n file_size: [u8; 10],\n end_char: [u8; 2],\n}\n\n/// Parsed version of `H`, still no heap allocation.\n#[allow(dead_code)]\n#[derive(Debug)]\nstruct Header {\n file_id: [u8; 16],\n timestamp: u64,\n owner_id: u32,\n group_id: u32,\n file_mode: u32,\n file_size: u64,\n}\n\n#[allow(missing_docs)]\n/// Possible errors for .deb files.\n#[derive(Debug, Error)]\npub enum Error {\n #[error(\"Deb file parse error\")]\n ParseError,\n #[error(transparent)]\n Utf8(#[from] std::str::Utf8Error),\n #[error(transparent)]\n Int(#[from] std::num::ParseIntError),\n #[error(transparent)]\n IO(#[from] std::io::Error),\n #[error(\"Unsupported compression algorithm: {file_id}\")]\n UnsupportedCompression { file_id: String },\n #[error(\"Version parse: {version}\")]\n Version { version: String },\n}\n\nimpl Header {\n pub fn file_id(&self) -> &str {\n std::str::from_utf8(&self.file_id).unwrap().trim()\n }\n}\n\nimpl H {\n fn parse(&self) -> Result {\n std::str::from_utf8(&self.file_id)?;\n Ok(Header {\n file_id: self.file_id,\n timestamp: std::str::from_utf8(&self.timestamp)?.trim().parse()?,\n owner_id: std::str::from_utf8(&self.owner_id)?.trim().parse()?,\n group_id: std::str::from_utf8(&self.group_id)?.trim().parse().unwrap(),\n file_mode: u32::from_str_radix(std::str::from_utf8(&self.file_mode)?.trim(), 8)?,\n file_size: std::str::from_utf8(&self.file_size)?.trim().parse()?,\n })\n }\n}\n\nfn read_hdr(r: &mut R) -> Result {\n unsafe {\n assert_eq!(size_of::(), HEADER_SIZE as usize);\n let mut b: H = std::mem::zeroed();\n let pb: *mut H = &mut b;\n r.read_exact(&mut std::slice::from_raw_parts_mut(\n pb as *mut u8,\n size_of::(),\n ))?;\n debug!(\"{:?}\", b);\n b.parse()\n }\n}\n\nconst HEADER_SIZE: u64 = 60;\n\nimpl Deb {\n /// Parse the control part, containing the description (stanza) of this package.\n pub fn parse_control(&self) -> Vec {\n if let Ok((\"\", st)) = separated_list1(newline, parse_control).parse(&self.control_file) {\n st\n } else {\n Vec::new()\n }\n }\n\n /// Return the md5sums of each file.\n pub fn md5sums(&self) -> &HashMap {\n &self.md5sums\n }\n\n /// Decompress the data part of the deb file into a directory.\n pub fn decompress>(\n &self,\n mut r: R,\n path: P,\n ) -> Result<(), Error> {\n r.seek(SeekFrom::Start(self.data_offset))?;\n debug!(\"decompress {:?}\", self.data.file_id());\n if self.data.file_id().ends_with(\".tar.gz\") {\n unimplemented!()\n } else if self.data.file_id().ends_with(\".tar.zst\") {\n let mut ar = tar::Archive::new(\n zstd::stream::read::Decoder::new(r.take(self.data.file_size)).unwrap(),\n );\n for e in ar.entries().unwrap() {\n let mut e = e.unwrap();\n debug!(\"zstd decompress {:?}\", e.path());\n // f(&e.path()?);\n e.unpack_in(&path).unwrap();\n }\n } else if self.data.file_id().ends_with(\".tar.xz\") {\n let mut ar = tar::Archive::new(xz::read::XzDecoder::new(r.take(self.data.file_size)));\n for e in ar.entries().unwrap() {\n let mut e = e.unwrap();\n debug!(\"xz decompress {:?}\", e.path());\n // f(&e.path()?);\n e.unpack_in(&path).unwrap();\n }\n } else if self.data.file_id().ends_with(\".tar\") {\n let mut ar = tar::Archive::new(r.take(self.data.file_size));\n for e in ar.entries().unwrap() {\n let mut e = e.unwrap();\n debug!(\"tar extract {:?}\", e.path());\n // f(&e.path()?);\n e.unpack_in(&path).unwrap();\n }\n } else {\n unimplemented!()\n };\n Ok(())\n }\n\n /// Parse a `.deb` file from a buffered reader.\n pub fn read(mut r: R) -> Result {\n let mut b = [0; 8];\n r.read_exact(&mut b)?;\n if &b != b\"!\\n\" {\n return Err(Error::ParseError);\n }\n\n let global = read_hdr(&mut r)?;\n trace!(\"GLOBAL {:?}\", global);\n assert_eq!(global.file_size, 4);\n r.seek(SeekFrom::Current(global.file_size as i64))?;\n\n // r.skip_until(b'c')?; // 'control.…'\n // r.seek(SeekFrom::Current(-1))?;\n let control = read_hdr(&mut r)?;\n trace!(\"CONTROL {:?}\", control);\n\n // Control files are expected to be short, decompress.\n let mut ctrl = vec![0; control.file_size as usize];\n r.read_exact(&mut ctrl)?;\n\n // gzip xz zstd none\n let ctrl_tar = if control.file_id().ends_with(\".tar.gz\") {\n unimplemented!()\n } else if control.file_id().ends_with(\".tar.zst\") {\n zstd::decode_all(&ctrl[..])?\n } else if control.file_id().ends_with(\".tar.xz\") {\n let mut decompressor = xz::read::XzDecoder::new(&ctrl[..]);\n let mut result = Vec::new();\n decompressor.read_to_end(&mut result)?;\n result\n } else if control.file_id().ends_with(\".tar\") {\n ctrl\n } else {\n return Err(Error::UnsupportedCompression {\n file_id: control.file_id().to_string(),\n });\n };\n let mut ctrl_tar = tar::Archive::new(&ctrl_tar[..]);\n\n let mut control_file = String::new();\n let mut md5sums = HashMap::new();\n for e in ctrl_tar.entries().unwrap() {\n let mut e = e.unwrap();\n if e.path()?.file_name() == Some(OsStr::new(\"control\")) {\n e.read_to_string(&mut control_file)?;\n } else if e.path()?.file_name() == Some(OsStr::new(\"md5sums\")) {\n let mut e = BufReader::new(e);\n let mut s = String::new();\n while e.read_line(&mut s)? > 0 {\n let mut it = s.split(' ').filter(|x| !x.is_empty());\n if let (Some(hash), Some(file)) = (it.next(), it.next()) {\n md5sums.insert(file.trim().to_string(), hash.trim().to_string());\n }\n s.clear();\n }\n }\n }\n\n if control.file_size % 2 == 1 {\n r.seek(SeekFrom::Current(1))?;\n }\n let data = read_hdr(&mut r)?;\n debug!(\"data = {:?}\", data);\n\n Ok(Deb {\n md5sums,\n _global: global,\n _control: control,\n control_file,\n data,\n data_offset: r.seek(SeekFrom::Current(0))?,\n })\n }\n}\n"}]}},{"FileDel":{"deleted_names":[{"basename":"main.rs~","metadata":0}],"del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":2,"pos":15},"to":{"change":4,"start":44502,"end":44534},"introduced_by":4},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":44534},"to":{"change":4,"start":44535,"end":44535},"introduced_by":4}],"inode":{"change":4,"pos":44535}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":44535},"to":{"change":4,"start":44536,"end":45954},"introduced_by":4}],"inode":{"change":4,"pos":44535}},"content":[{"Del":"use clap::*;\nuse elpe::*;\nuse serde_derive::*;\nuse std::path::PathBuf;\nuse tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};\n\nmod server;\n\n#[derive(Deserialize)]\npub struct Config {\n pgp_home: PathBuf,\n store_path: PathBuf,\n package_index: String,\n user: String,\n}\n\n/// Elpe\n#[derive(Parser, Debug)]\n#[command(version, about, long_about = None)]\nstruct Args {\n /// Path to the configuration file\n #[arg(short, long)]\n config: PathBuf,\n}\n\nfn main() {\n tracing_subscriber::registry()\n .with(\n tracing_subscriber::EnvFilter::try_from_default_env()\n .unwrap_or_else(|_| String::new().into()),\n )\n .with(tracing_subscriber::fmt::layer())\n .init();\n\n let args = Args::parse();\n\n let config: Config = toml::from_str(&std::fs::read_to_string(&args.config).unwrap()).unwrap();\n\n let container_channel = crate::container::serve(&config.user, &config.store_path);\n\n let rt = tokio::runtime::Runtime::new().unwrap();\n rt.block_on(async move {\n privdrop::PrivDrop::default()\n .user(&config.user)\n .apply()\n .unwrap();\n\n let elpe = server::Elpe::new(\n Client::new(&config.pgp_home, &config.store_path, &config.package_index),\n container_channel,\n );\n\n let addr = \"0.0.0.0:50051\".parse().unwrap();\n elpe.serve(addr).await\n })\n}\n"}]}},{"Replacement":{"inode":{"change":3,"pos":34},"path":"src/server.rs","line":203,"ins":{"up_context":[{"change":3,"pos":6824}],"down_context":[{"change":3,"pos":6845}],"flag":"BLOCK","start":0,"end":28,"inode":{"change":3,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6824},"to":{"change":3,"start":6824,"end":6845},"introduced_by":3}],"inode":{"change":3,"pos":34}},"ins_contents":[{"Add":" let download = self"}],"del_contents":[{"Del":" let p = self\n"}]}},{"Replacement":{"inode":{"change":3,"pos":34},"path":"src/server.rs","line":226,"ins":{"up_context":[{"change":3,"pos":7597}],"down_context":[{"change":3,"pos":8001}],"flag":"BLOCK","start":29,"end":540,"inode":{"change":3,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":7597},"to":{"change":3,"start":7597,"end":8001},"introduced_by":3}],"inode":{"change":3,"pos":34}},"ins_contents":[{"Add":" .await;"},{"Add":" match download {"},{"Add":"\t Ok(p) => {"},{"Add":"\t\tOk(tonic::Response::new(proto::DerivationReply {"},{"Add":"\t\t result: Some(proto::derivation_reply::Result::Ok("},{"Add":"\t\t\tproto::DerivationResult {"},{"Add":"\t\t\t destdir: vec![p.to_str().unwrap().to_string()],"},{"Add":"\t\t\t paths: Vec::new(),"},{"Add":"\t\t\t path_patterns: Vec::new(),"},{"Add":"\t\t\t},"},{"Add":"\t\t )),"},{"Add":"\t\t}))"},{"Add":"\t }"},{"Add":"\t Err(e) => {"},{"Add":"\t\tOk(tonic::Response::new(proto::DerivationReply {"},{"Add":"\t\t result: Some(proto::derivation_reply::Result::Error("},{"Add":"\t\t\te.to_string()"},{"Add":"\t\t )),"},{"Add":"\t\t}))"},{"Add":"\t }"},{"Add":"\t}"}],"del_contents":[{"Del":" .await\n .unwrap();\n Ok(tonic::Response::new(proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Ok(\n proto::DerivationResult {\n destdir: vec![p.to_str().unwrap().to_string()],\n paths: Vec::new(),\n path_patterns: Vec::new(),\n },\n )),\n }))\n"}]}},{"Replacement":{"inode":{"change":3,"pos":34},"path":"src/server.rs","line":248,"ins":{"up_context":[{"change":3,"pos":8007}],"down_context":[{"change":3,"pos":8008}],"flag":"BLOCK","start":541,"end":543,"inode":{"change":3,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8007},"to":{"change":3,"start":8007,"end":8008},"introduced_by":3}],"inode":{"change":3,"pos":34}},"ins_contents":[{"Add":"\t"}],"del_contents":[{"Del":"\n"}]}},{"Replacement":{"inode":{"change":3,"pos":34},"path":"src/server.rs","line":259,"ins":{"up_context":[{"change":3,"pos":8457}],"down_context":[{"change":3,"pos":8485}],"flag":"BLOCK","start":544,"end":570,"inode":{"change":3,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8457},"to":{"change":3,"start":8457,"end":8485},"introduced_by":3}],"inode":{"change":3,"pos":34}},"ins_contents":[{"Add":" 1 => \"arm64\","}],"del_contents":[{"Del":" 1 => \"aarch64\",\n"}]}},{"Replacement":{"inode":{"change":3,"pos":34},"path":"src/server.rs","line":266,"ins":{"up_context":[{"change":3,"pos":8640}],"down_context":[{"change":3,"pos":8663}],"flag":"BLOCK","start":571,"end":633,"inode":{"change":3,"pos":34}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8640},"to":{"change":3,"start":8640,"end":8663},"introduced_by":3}],"inode":{"change":3,"pos":34}},"ins_contents":[{"Add":" .expect(&format!(\"{} {}\", &r.repository, &arch));"}],"del_contents":[{"Del":" .unwrap();\n"}]}}],"owner":"pmeunier","repo":"elpe","token":"OCjOkExrmA5OqNY5nlrFXVV7OwPvrkpKEsYiOdMtypA=","login":null}

…

Dependencies

Change contents