{"header":{"message":"Forwarding log to frontend","description":null,"timestamp":"2025-07-02T21:15:01.660477891Z","authors":[{}]},"hash":"AJLMC7UMTMBYBXLOSMGT5PDNX4D7O7LV4GDV7AN25CPOBPRUFYVAC","authors":[{"login":"pmeunier","key":"FZQ2g7VfnzLYM4mtTVDk9HAZjA8Jk9ndkwN1icgbtWUr"}],"deps":{"hashes":[["AJLMC7UMTMBYBXLOSMGT5PDNX4D7O7LV4GDV7AN25CPOBPRUFYVAC","Forwarding log to frontend"],["AA",null],["LIUJQXB752UIHJFF32LKJ7ECUZ2VDIFDDHBLAUVNBRTPDYNCAUYQC","Allow merging two packages based on regular expressions of their name"],["BDEVQIAUBDZLH5NNXJ3HD3WK2ART4V6K2FLHMAQVAQYNXGL4TOIQC","Handle cyclic Ubuntu dependencies"],["BQ4E3XLAVS2AQAUYRGN6SZ4J35KQ2KIH7BBT2JNZXSPKKCGX7DYAC","Forwarding stdout/stderr"],["R7J4254ZZREVMWXXDUM772GPLZSCZSIJKOLEAI33WUF2CPS3X6WQC","Reorganisation of the frontend"],["5IT7CXFGK6HHEWB3D4T5GDV3FZ7I2U7UKXOVSD7RVYSI3GFGVRTAC","Debugging the dependency resolution (Tarjan's SCC algorithm)"],["F2C3TLOI4KEEWK427YMSHZ47352IEYL24PHCW5ELJID7BCSZCRLAC","Fetching URLs (server-side)"],["ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","Adding the OCaml interface"],["6BIW5YDCZXIH3SNKNTZ3MSHUFGN3VKAYPKI4MWJIFVUY7YQSJJ3AC","Rust builder: compiling the crates"],["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","First working shell (with ocaml code)"],["SI454P2VFO6Y6RO2NIOH6ZROURP3OTB2BBXH2F36KJT6YML6YBIAC","Documentation and cleanup"]],"deps":["LIUJQXB752UIHJFF32LKJ7ECUZ2VDIFDDHBLAUVNBRTPDYNCAUYQC"],"known":["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","SI454P2VFO6Y6RO2NIOH6ZROURP3OTB2BBXH2F36KJT6YML6YBIAC","BDEVQIAUBDZLH5NNXJ3HD3WK2ART4V6K2FLHMAQVAQYNXGL4TOIQC","BQ4E3XLAVS2AQAUYRGN6SZ4J35KQ2KIH7BBT2JNZXSPKKCGX7DYAC","5IT7CXFGK6HHEWB3D4T5GDV3FZ7I2U7UKXOVSD7RVYSI3GFGVRTAC","F2C3TLOI4KEEWK427YMSHZ47352IEYL24PHCW5ELJID7BCSZCRLAC","R7J4254ZZREVMWXXDUM772GPLZSCZSIJKOLEAI33WUF2CPS3X6WQC","6BIW5YDCZXIH3SNKNTZ3MSHUFGN3VKAYPKI4MWJIFVUY7YQSJJ3AC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":9,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":44}],"down_context":[{"change":3,"pos":1587}],"flag":"BLOCK","start":0,"end":34,"inode":{"change":3,"pos":1363}}},"contents":[{"Add":"use tokio_util::sync::PollSender;"}]}},{"Edit":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":38,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2038}],"down_context":[{"change":3,"pos":2038}],"flag":"BLOCK","start":35,"end":63,"inode":{"change":3,"pos":1363}}},"contents":[{"Add":" debug!(\"add_path\");"}]}},{"Replacement":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":41,"ins":{"up_context":[{"change":3,"pos":387}],"down_context":[{"change":3,"pos":2179}],"flag":"BLOCK","start":64,"end":188,"inode":{"change":3,"pos":1363}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":387},"to":{"change":3,"start":2127,"end":2179},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2127},"to":{"change":3,"start":2127,"end":2179},"introduced_by":3}],"inode":{"change":3,"pos":1363}},"ins_contents":[{"Add":" debug!(\"store\");"},{"Add":" let tmp_dir = tempfile::tempdir_in(store).unwrap();"},{"Add":" debug!(\"store {:?}\", tmp_dir);"}],"del_contents":[{"Del":" let tmp_dir = tempfile::tempdir_in(store)?;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":46,"ins":{"up_context":[{"change":3,"pos":2228}],"down_context":[{"change":3,"pos":2229}],"flag":"BLOCK","start":189,"end":213,"inode":{"change":3,"pos":1363}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":2228},"to":{"change":3,"start":2000,"end":2001},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2000},"to":{"change":3,"start":2000,"end":2001},"introduced_by":3}],"inode":{"change":3,"pos":1363}},"ins_contents":[{"Add":" debug!(\"loop\");"}],"del_contents":[{"Del":"\n"}]}},{"Edit":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":53,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2482}],"down_context":[{"change":3,"pos":2482}],"flag":"BLOCK","start":214,"end":269,"inode":{"change":3,"pos":1363}}},"contents":[{"Add":" info!(\"Adding file {:?}\", f.name);"}]}},{"Edit":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":62,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2922}],"down_context":[{"change":3,"pos":2922}],"flag":"BLOCK","start":270,"end":325,"inode":{"change":3,"pos":1363}}},"contents":[{"Add":" info!(\"Adding file {:?}\", d.name);"}]}},{"Edit":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":76,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3477}],"down_context":[{"change":3,"pos":3477}],"flag":"BLOCK","start":326,"end":355,"inode":{"change":3,"pos":1363}}},"contents":[{"Add":" debug!(\"loop done\");"}]}},{"Edit":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":220,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2951}],"down_context":[{"change":3,"pos":2951}],"flag":"BLOCK","start":356,"end":404,"inode":{"change":3,"pos":1363}}},"contents":[{"Add":" type UbuntuPackageStream = ResponseStream;"},{"Add":""}]}},{"Replacement":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":225,"ins":{"up_context":[{"change":3,"pos":6060}],"down_context":[{"change":3,"pos":3117}],"flag":"BLOCK","start":405,"end":482,"inode":{"change":3,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6060},"to":{"change":3,"start":6060,"end":6134},"introduced_by":3}],"inode":{"change":3,"pos":1363}},"ins_contents":[{"Add":" ) -> Result, tonic::Status> {"}],"del_contents":[{"Del":" ) -> Result, tonic::Status> {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":245,"ins":{"up_context":[{"change":2,"pos":294}],"down_context":[{"change":3,"pos":6646}],"flag":"BLOCK","start":483,"end":803,"inode":{"change":3,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":294},"to":{"change":2,"start":294,"end":380},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":380},"to":{"change":3,"start":3465,"end":3507},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3465},"to":{"change":3,"start":3465,"end":3507},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3507},"to":{"change":3,"start":6135,"end":6180},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6180},"to":{"change":3,"start":3538,"end":3595},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3538},"to":{"change":3,"start":3538,"end":3595},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3595},"to":{"change":3,"start":6181,"end":6646},"introduced_by":3}],"inode":{"change":3,"pos":1363}},"ins_contents":[{"Add":""},{"Add":" let (tx, rx) = tokio::sync::mpsc::channel(200);"},{"Add":" use crate::extract::Msg;"},{"Add":" let output_stream = ReceiverStream::new(rx).map(|x| {"},{"Add":" Ok(match x {"},{"Add":" Msg::Downloading(p) => proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Loading(p)),"}],"del_contents":[{"Del":" let p = download_extract_deps(&index, &self.deb_client, &r.name, &link_extra)\n"},{"Del":" .await\n .unwrap();\n"},{"Del":" info!(\"path {:?} {:#?}\", r.name, p);\n"},{"Del":" Ok(tonic::Response::new(proto::DerivationReply {\n"},{"Del":" result: Some(proto::derivation_reply::Result::Ok(\n proto::DerivationResult {\n destdir: p\n .result\n .iter()\n .rev()\n .map(|x| x.to_str().unwrap().to_string())\n .collect(),\n paths: p.paths.into_iter().filter_map(Arc::into_inner).collect(),\n path_patterns: Vec::new(),\n"}]}},{"Replacement":{"inode":{"change":3,"pos":1363},"path":"src/main.rs","line":253,"ins":{"up_context":[{"change":3,"pos":6665}],"down_context":[{"change":3,"pos":4845}],"flag":"BLOCK","start":804,"end":2149,"inode":{"change":3,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6665},"to":{"change":3,"start":6665,"end":6681},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6681},"to":{"change":3,"start":3773,"end":3785},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3773},"to":{"change":3,"start":3773,"end":3785},"introduced_by":3}],"inode":{"change":3,"pos":1363}},"ins_contents":[{"Add":" Msg::Ok(p) => proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Ok("},{"Add":" proto::DerivationResult {"},{"Add":" destdir: p"},{"Add":" .result"},{"Add":" .iter()"},{"Add":" .rev()"},{"Add":" .map(|x| x.to_str().unwrap().to_string())"},{"Add":" .collect(),"},{"Add":" paths: p.paths.into_iter().filter_map(Arc::into_inner).collect(),"},{"Add":" path_patterns: Vec::new(),"},{"Add":" },"},{"Add":" )),"},{"Add":" },"},{"Add":" Msg::Error(e) => proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Error(e.to_string())),"},{"Add":" },"},{"Add":" })"},{"Add":" });"},{"Add":""},{"Add":" match download_extract_deps("},{"Add":" &index,"},{"Add":" &self.deb_client,"},{"Add":" &r.name,"},{"Add":" &link_extra,"},{"Add":" PollSender::new(tx.clone()),"},{"Add":" )"},{"Add":" .await"},{"Add":" {"},{"Add":" Ok(p) => {"},{"Add":" info!(\"path {:?} {:#?}\", r.name, p);"},{"Add":" tx.send(Msg::Ok(p)).await.unwrap();"},{"Add":" }"},{"Add":" Err(e) => tx.send(Msg::Error(e)).await.unwrap(),"},{"Add":" }"},{"Add":""},{"Add":" Ok(tonic::Response::new(Box::pin(output_stream)))"}],"del_contents":[{"Del":" )),\n"},{"Del":" }))\n"}]}},{"Edit":{"inode":{"change":3,"pos":10326},"path":"src/lib.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":8271}],"down_context":[{"change":3,"pos":10327}],"flag":"BLOCK","start":2150,"end":2172,"inode":{"change":3,"pos":10326}}},"contents":[{"Add":"use futures::SinkExt;"}]}},{"Edit":{"inode":{"change":3,"pos":10326},"path":"src/lib.rs","line":36,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":8732}],"down_context":[{"change":3,"pos":10537}],"flag":"BLOCK","start":2173,"end":2209,"inode":{"change":3,"pos":10326}}},"contents":[{"Add":""},{"Add":"mod dummy_sink;"},{"Add":"use dummy_sink::*;"}]}},{"Edit":{"inode":{"change":3,"pos":10326},"path":"src/lib.rs","line":93,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":10103}],"down_context":[{"change":3,"pos":11210}],"flag":"BLOCK","start":2210,"end":2357,"inode":{"change":3,"pos":10326}}},"contents":[{"Add":" /// Package not found"},{"Add":" #[error(\"Package not found: {pkg}\")]"},{"Add":" PackageNotFound {"},{"Add":" /// The package name."},{"Add":" pkg: String,"},{"Add":" },"}]}},{"Edit":{"inode":{"change":3,"pos":10326},"path":"src/lib.rs","line":311,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1497}],"down_context":[{"change":3,"pos":11035}],"flag":"BLOCK","start":2358,"end":2421,"inode":{"change":3,"pos":10326}}},"contents":[{"Add":" std::fs::create_dir_all(store_path.as_ref()).unwrap();"}]}},{"Replacement":{"inode":{"change":3,"pos":10326},"path":"src/lib.rs","line":366,"ins":{"up_context":[{"change":3,"pos":12451}],"down_context":[{"change":3,"pos":12517}],"flag":"BLOCK","start":2422,"end":2507,"inode":{"change":3,"pos":10326}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":12451},"to":{"change":2,"start":381,"end":452},"introduced_by":2}],"inode":{"change":3,"pos":10326}},"ins_contents":[{"Add":" let p = extract::download_extract_deps(&index, self, pkg, &[], DummySink {})"}],"del_contents":[{"Del":" let p = extract::download_extract_deps(&index, self, pkg, &[])\n"}]}},{"Replacement":{"inode":{"change":3,"pos":10326},"path":"src/lib.rs","line":607,"ins":{"up_context":[{"change":3,"pos":14073}],"down_context":[{"change":3,"pos":18510}],"flag":"BLOCK","start":2508,"end":2748,"inode":{"change":3,"pos":10326}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":14073},"to":{"change":3,"start":18409,"end":18510},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":18409},"to":{"change":3,"start":18409,"end":18510},"introduced_by":3}],"inode":{"change":3,"pos":10326}},"ins_contents":[{"Add":" async fn download_url<'a, S: futures::Sink + Unpin>("},{"Add":" &self,"},{"Add":" url: &str,"},{"Add":" sha256: &str,"},{"Add":" mut tx: S,"},{"Add":" ) -> Result<(Downloaded, bool), Error>"},{"Add":" where"},{"Add":" S::Error: std::fmt::Debug,"},{"Add":" {"}],"del_contents":[{"Del":" async fn download_url<'a>(&self, url: &str, sha256: &str) -> Result<(Downloaded, bool), Error> {\n"}]}},{"Edit":{"inode":{"change":3,"pos":10326},"path":"src/lib.rs","line":624,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":14177}],"down_context":[{"change":3,"pos":14177}],"flag":"BLOCK","start":2749,"end":2851,"inode":{"change":3,"pos":10326}}},"contents":[{"Add":" tx.send(extract::Msg::Downloading(url.to_string()))"},{"Add":" .await"},{"Add":" .unwrap();"}]}},{"Edit":{"inode":{"change":3,"pos":19587},"path":"src/extract.rs","line":42,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":610}],"down_context":[{"change":3,"pos":502}],"flag":"BLOCK","start":2852,"end":3030,"inode":{"change":3,"pos":19587}}},"contents":[{"Add":"}"},{"Add":""},{"Add":"/// Messages from the extractor."},{"Add":"#[derive(Debug)]"},{"Add":"pub enum Msg {"},{"Add":" /// Downloading"},{"Add":" Downloading(String),"},{"Add":" /// Result"},{"Add":" Ok(Packages),"},{"Add":" /// Error"},{"Add":" Error(Error),"}]}},{"Replacement":{"inode":{"change":3,"pos":19587},"path":"src/extract.rs","line":57,"ins":{"up_context":[{"change":3,"pos":3343}],"down_context":[{"change":3,"pos":19873}],"flag":"BLOCK","start":3031,"end":3123,"inode":{"change":3,"pos":19587}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":3343},"to":{"change":3,"start":19837,"end":19873},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":17671},"to":{"change":3,"start":19837,"end":19873},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":19837},"to":{"change":3,"start":19837,"end":19873},"introduced_by":3}],"inode":{"change":3,"pos":19587}},"ins_contents":[{"Add":"pub async fn download_extract_deps + Clone + Send + Unpin + 'static>("}],"del_contents":[{"Del":"pub async fn download_extract_deps(\n"}]}},{"Replacement":{"inode":{"change":3,"pos":19587},"path":"src/extract.rs","line":62,"ins":{"up_context":[{"change":2,"pos":660}],"down_context":[{"change":3,"pos":506}],"flag":"BLOCK","start":3124,"end":3367,"inode":{"change":3,"pos":19587}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":2,"pos":660},"to":{"change":3,"start":17694,"end":17725},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":19944},"to":{"change":3,"start":17694,"end":17725},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":20068},"to":{"change":3,"start":17726,"end":17786},"introduced_by":3}],"inode":{"change":3,"pos":19587}},"ins_contents":[{"Add":" tx: F,"},{"Add":") -> Result"},{"Add":"where"},{"Add":" F::Error: std::fmt::Debug,"},{"Add":"{"},{"Add":" let Some(pkg) = multi_lookup(index, &package).await else {"},{"Add":" return Err(Error::PackageNotFound {"},{"Add":" pkg: package.to_string(),"},{"Add":" });"},{"Add":" };"}],"del_contents":[{"Del":") -> Result {\n"},{"Del":" let pkg = multi_lookup(index, &package).await.unwrap();\n"}]}},{"Replacement":{"inode":{"change":3,"pos":19587},"path":"src/extract.rs","line":107,"ins":{"up_context":[{"change":3,"pos":1773}],"down_context":[{"change":3,"pos":1837}],"flag":"BLOCK","start":3368,"end":3444,"inode":{"change":3,"pos":19587}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1773},"to":{"change":3,"start":1773,"end":1837},"introduced_by":3}],"inode":{"change":3,"pos":19587}},"ins_contents":[{"Add":" let rx = spawn_extract(client.clone(), &pkg, tx.clone()).await;"}],"del_contents":[{"Del":" let rx = spawn_extract(client.clone(), &pkg).await;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":19587},"path":"src/extract.rs","line":323,"ins":{"up_context":[{"change":3,"pos":5478}],"down_context":[{"change":3,"pos":5506}],"flag":"BLOCK","start":3445,"end":3521,"inode":{"change":3,"pos":19587}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5478},"to":{"change":3,"start":5478,"end":5506},"introduced_by":3}],"inode":{"change":3,"pos":19587}},"ins_contents":[{"Add":"async fn spawn_extract<'a, S: futures::Sink + Send + Unpin + 'static>("}],"del_contents":[{"Del":"async fn spawn_extract<'a>(\n"}]}},{"Replacement":{"inode":{"change":3,"pos":19587},"path":"src/extract.rs","line":326,"ins":{"up_context":[{"change":3,"pos":5556}],"down_context":[{"change":3,"pos":5621}],"flag":"BLOCK","start":3522,"end":3639,"inode":{"change":3,"pos":19587}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5556},"to":{"change":3,"start":5556,"end":5621},"introduced_by":3}],"inode":{"change":3,"pos":19587}},"ins_contents":[{"Add":" log_tx: S,"},{"Add":") -> tokio::sync::oneshot::Receiver>"},{"Add":"where"},{"Add":" S::Error: std::fmt::Debug,"},{"Add":"{"}],"del_contents":[{"Del":") -> tokio::sync::oneshot::Receiver> {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":19587},"path":"src/extract.rs","line":337,"ins":{"up_context":[{"change":3,"pos":5932}],"down_context":[{"change":3,"pos":6009}],"flag":"BLOCK","start":3640,"end":3725,"inode":{"change":3,"pos":19587}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5932},"to":{"change":3,"start":5932,"end":6009},"introduced_by":3}],"inode":{"change":3,"pos":19587}},"ins_contents":[{"Add":" let (mut task, _) = match client.download_url(&url, &sha256, log_tx).await {"}],"del_contents":[{"Del":" let (mut task, _) = match client.download_url(&url, &sha256).await {\n"}]}},{"FileAdd":{"meta":{"basename":"dummy_sink.rs","metadata":0},"context":[{"change":3,"pos":15}],"contents":[{"Add":"use std::convert::Infallible;"},{"Add":"use std::pin::Pin;"},{"Add":""},{"Add":"#[derive(Clone, Copy)]"},{"Add":"pub struct DummySink {}"},{"Add":""},{"Add":"impl futures::Sink for DummySink {"},{"Add":" type Error = Infallible;"},{"Add":""},{"Add":" fn poll_ready("},{"Add":" self: Pin<&mut Self>,"},{"Add":" _cx: &mut futures::task::Context<'_>,"},{"Add":" ) -> futures::task::Poll> {"},{"Add":" futures::task::Poll::Ready(Ok(()))"},{"Add":" }"},{"Add":""},{"Add":" fn start_send(self: Pin<&mut Self>, _item: T) -> Result<(), Infallible> {"},{"Add":" Ok(())"},{"Add":" }"},{"Add":" fn poll_flush("},{"Add":" self: Pin<&mut Self>,"},{"Add":" _cx: &mut futures::task::Context<'_>,"},{"Add":" ) -> futures::task::Poll> {"},{"Add":" futures::task::Poll::Ready(Ok(()))"},{"Add":" }"},{"Add":" fn poll_close("},{"Add":" self: Pin<&mut Self>,"},{"Add":" _cx: &mut futures::task::Context<'_>,"},{"Add":" ) -> futures::task::Poll> {"},{"Add":" futures::task::Poll::Ready(Ok(()))"},{"Add":" }"},{"Add":"}"}]}},{"Edit":{"inode":{"change":3,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":64,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":6581}],"down_context":[{"change":3,"pos":63852}],"flag":"BLOCK","start":4634,"end":4658,"inode":{"change":3,"pos":55490}}},"contents":[{"Add":" string loading = 5;"}]}},{"Replacement":{"inode":{"change":3,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":95,"ins":{"up_context":[{"change":3,"pos":56055}],"down_context":[{"change":3,"pos":56125}],"flag":"BLOCK","start":4659,"end":4736,"inode":{"change":3,"pos":55490}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":56055},"to":{"change":3,"start":56055,"end":56125},"introduced_by":3}],"inode":{"change":3,"pos":55490}},"ins_contents":[{"Add":" rpc UbuntuPackage (UbuntuPackageRequest) returns (stream DerivationReply);"}],"del_contents":[{"Del":" rpc UbuntuPackage (UbuntuPackageRequest) returns (DerivationReply);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":56160},"path":"elpe/lib/elpe.ml","line":115,"ins":{"up_context":[{"change":3,"pos":72631}],"down_context":[{"change":3,"pos":72662}],"flag":"BLOCK","start":4737,"end":4783,"inode":{"change":3,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":72631},"to":{"change":3,"start":72631,"end":72662},"introduced_by":3}],"inode":{"change":3,"pos":56160}},"ins_contents":[{"Add":" | `Error e -> raise (DerivationError e)"}],"del_contents":[{"Del":" | `Error e -> failwith e\n"}]}},{"Edit":{"inode":{"change":3,"pos":445},"path":"elpe/lib/derivation.ml","line":2,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":462}],"down_context":[{"change":3,"pos":462}],"flag":"BLOCK","start":4784,"end":4821,"inode":{"change":3,"pos":445}}},"contents":[{"Add":""},{"Add":"exception DerivationError of string"}]}},{"Replacement":{"inode":{"change":3,"pos":445},"path":"elpe/lib/derivation.ml","line":80,"ins":{"up_context":[{"change":3,"pos":2579}],"down_context":[{"change":3,"pos":3246}],"flag":"BLOCK","start":4822,"end":5909,"inode":{"change":3,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2579},"to":{"change":3,"start":2579,"end":3246},"introduced_by":3}],"inode":{"change":3,"pos":445}},"ins_contents":[{"Add":" let result = ref None in"},{"Add":" let* x ="},{"Add":" Client.call ~service:\"elpe.Elpe\" ~rpc:\"UbuntuPackage\""},{"Add":" ~do_request:"},{"Add":" (H2_lwt_unix.Client.request connection ~error_handler:(fun _ ->"},{"Add":" failwith \"Error\"))"},{"Add":" ~handler:"},{"Add":" (Client.Rpc.server_streaming enc ~f:(fun responses ->"},{"Add":" Lwt_stream.iter_s"},{"Add":" (fun str ->"},{"Add":" Reader.create str |> decode |> function"},{"Add":" | Ok (`Ok v) ->"},{"Add":" result := Some v;"},{"Add":" Lwt.return ()"},{"Add":" | Ok (`Loading v) ->"},{"Add":" Printf.eprintf \"Downloading %s\\n\" v;"},{"Add":" Stdlib.flush Stdlib.stderr;"},{"Add":" Lwt.return ()"},{"Add":" | Error e ->"},{"Add":" failwith"},{"Add":" (Printf.sprintf \"Could not decode request: %s\""},{"Add":" (Result.show_error e))"},{"Add":" | _ -> Lwt.return ())"},{"Add":" responses))"},{"Add":" ()"},{"Add":" in"},{"Add":" match x with"},{"Add":" | Ok _ -> Lwt.return (Ok (Option.get !result))"},{"Add":" | Error e -> Lwt.return (Error e)"},{"Add":""},{"Add":"type arch = Amd64 | Aarch64"}],"del_contents":[{"Del":" Client.call ~service:\"elpe.Elpe\" ~rpc:\"UbuntuPackage\"\n ~do_request:\n (H2_lwt_unix.Client.request connection ~error_handler:(fun _ ->\n failwith \"Error\"))\n ~handler:\n (Client.Rpc.unary enc ~f:(fun decoder ->\n let+ decoder = decoder in\n match decoder with\n | Some decoder -> (\n Reader.create decoder |> decode |> function\n | Ok v -> v\n | Error e ->\n failwith\n (Printf.sprintf \"Could not decode request: %s\"\n (Result.show_error e)))\n | None -> Elpegrpc.Elpe.Elpe.Derivation.Response.make ()))\n ()\n"}]}},{"Replacement":{"inode":{"change":3,"pos":445},"path":"elpe/lib/derivation.ml","line":112,"ins":{"up_context":[{"change":3,"pos":3247}],"down_context":[{"change":3,"pos":3287}],"flag":"BLOCK","start":5910,"end":5966,"inode":{"change":3,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3247},"to":{"change":3,"start":3247,"end":3287},"introduced_by":3}],"inode":{"change":3,"pos":445}},"ins_contents":[{"Add":"let ubuntu ?(release = \"plucky\") ?(arch = Amd64) name ="}],"del_contents":[{"Del":"let ubuntu ?(release = \"plucky\") name =\n"}]}},{"Replacement":{"inode":{"change":3,"pos":445},"path":"elpe/lib/derivation.ml","line":191,"ins":{"up_context":[{"change":3,"pos":5575}],"down_context":[{"change":3,"pos":5625}],"flag":"BLOCK","start":5967,"end":6072,"inode":{"change":3,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5575},"to":{"change":3,"start":5575,"end":5625},"introduced_by":3}],"inode":{"change":3,"pos":445}},"ins_contents":[{"Add":" Printf.printf \"%s\" buf;"},{"Add":" Stdlib.flush Stdlib.stdout"}],"del_contents":[{"Del":" Printf.printf \"%s\" buf\n"}]}},{"Replacement":{"inode":{"change":3,"pos":445},"path":"elpe/lib/derivation.ml","line":201,"ins":{"up_context":[{"change":3,"pos":5944}],"down_context":[{"change":3,"pos":5994}],"flag":"BLOCK","start":6073,"end":6179,"inode":{"change":3,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5944},"to":{"change":3,"start":5944,"end":5994},"introduced_by":3}],"inode":{"change":3,"pos":445}},"ins_contents":[{"Add":" Printf.eprintf \"%s\" buf;"},{"Add":" Stdlib.flush Stdlib.stderr"}],"del_contents":[{"Del":" Printf.printf \"%s\" buf\n"}]}}],"owner":"pmeunier","repo":"elpe","token":"Wtm5aFhxLocTJPT7yQwXlV+3I9cFUejpuJC3wOFsYwM=","login":null}

…

Dependencies

Change contents