{"header":{"message":"Bootstrapping the Rust part","description":null,"timestamp":"2025-07-26T19:17:43.393468314Z","authors":[{}]},"hash":"LIMIMBOUN3DCIKKTHOK4TAXAWQXNVQXBTMNZYN22DJX4L4FZQH4AC","authors":[{"login":"pmeunier","key":"FZQ2g7VfnzLYM4mtTVDk9HAZjA8Jk9ndkwN1icgbtWUr"}],"deps":{"hashes":[["LIMIMBOUN3DCIKKTHOK4TAXAWQXNVQXBTMNZYN22DJX4L4FZQH4AC","Bootstrapping the Rust part"],["AA",null],["F2C3TLOI4KEEWK427YMSHZ47352IEYL24PHCW5ELJID7BCSZCRLAC","Fetching URLs (server-side)"],["RBGQQMWXRUO4W2P5GFH24VRIP52IW5BNSE2ZOBXKFIYARDOPBFWAC","Container: cleanup after failure"],["AJLMC7UMTMBYBXLOSMGT5PDNX4D7O7LV4GDV7AN25CPOBPRUFYVAC","Forwarding log to frontend"],["A7YP2YT6WQ4WDFQTQRHPFC7EFJBCWYHV6HERQD6CUTWUBC4FLBTAC","Adding /tmp to containers"],["LTB4YNHF75FTVQG6S5PL46CGS4CMDWZRAEXWEIXUHQHIWVYVKFKAC","Rust compilation works!"],["VAKO4QFFT35EXJIEQ7PHSUYVBSSUW5P2HSQDIJSTZCTOWQZKPHXQC","Formatting"],["BDEVQIAUBDZLH5NNXJ3HD3WK2ART4V6K2FLHMAQVAQYNXGL4TOIQC","Handle cyclic Ubuntu dependencies"],["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","First working shell (with ocaml code)"],["LIUJQXB752UIHJFF32LKJ7ECUZ2VDIFDDHBLAUVNBRTPDYNCAUYQC","Allow merging two packages based on regular expressions of their name"],["YJYXDY6AUDJMBUVKKUKM2GO2XVIKZVQFT4SRD4Z7XSTQBTSJ5ZSAC","Capturing stdout/stderr for the derivations that ask"],["HX4TXY2DTPEEQPU6CMHSD3X4VX7A4OKV7N3HT3QZKSNHNAZOK7GQC","Fixed-output derivations enable the network"],["ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","Adding the OCaml interface"],["SI454P2VFO6Y6RO2NIOH6ZROURP3OTB2BBXH2F36KJT6YML6YBIAC","Documentation and cleanup"],["R7J4254ZZREVMWXXDUM772GPLZSCZSIJKOLEAI33WUF2CPS3X6WQC","Reorganisation of the frontend"],["LQBZJUGCEIU56WBYBLE757W2DHPZWJ4JNG3ILB52RDXMXUYAPZCQC","Adding a basic Rust builder"],["6BIW5YDCZXIH3SNKNTZ3MSHUFGN3VKAYPKI4MWJIFVUY7YQSJJ3AC","Rust builder: compiling the crates"],["6MGFBMON6ASGBRQJXY6VUGGZQHXPQSMQJZOOD5LKS2FZODB6ET7AC","Debug and cleanup"],["VWVW5VOIYXHVNZI7LEIXM6HGCWWTTOKWGA7NGB65M6FSGYG6BCZQC","Copying the sources in /src instead of /"],["BQ4E3XLAVS2AQAUYRGN6SZ4J35KQ2KIH7BBT2JNZXSPKKCGX7DYAC","Forwarding stdout/stderr"],["KOWYPLMX4TCQANL33QW5VQTKWBQVCMOVLBQUQCTOK6YVQUHZJR5QC","Nix and config.toml"]],"deps":["F2C3TLOI4KEEWK427YMSHZ47352IEYL24PHCW5ELJID7BCSZCRLAC","RBGQQMWXRUO4W2P5GFH24VRIP52IW5BNSE2ZOBXKFIYARDOPBFWAC","AJLMC7UMTMBYBXLOSMGT5PDNX4D7O7LV4GDV7AN25CPOBPRUFYVAC","A7YP2YT6WQ4WDFQTQRHPFC7EFJBCWYHV6HERQD6CUTWUBC4FLBTAC","LTB4YNHF75FTVQG6S5PL46CGS4CMDWZRAEXWEIXUHQHIWVYVKFKAC"],"known":["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","SI454P2VFO6Y6RO2NIOH6ZROURP3OTB2BBXH2F36KJT6YML6YBIAC","HX4TXY2DTPEEQPU6CMHSD3X4VX7A4OKV7N3HT3QZKSNHNAZOK7GQC","6MGFBMON6ASGBRQJXY6VUGGZQHXPQSMQJZOOD5LKS2FZODB6ET7AC","BDEVQIAUBDZLH5NNXJ3HD3WK2ART4V6K2FLHMAQVAQYNXGL4TOIQC","BQ4E3XLAVS2AQAUYRGN6SZ4J35KQ2KIH7BBT2JNZXSPKKCGX7DYAC","VWVW5VOIYXHVNZI7LEIXM6HGCWWTTOKWGA7NGB65M6FSGYG6BCZQC","VAKO4QFFT35EXJIEQ7PHSUYVBSSUW5P2HSQDIJSTZCTOWQZKPHXQC","YJYXDY6AUDJMBUVKKUKM2GO2XVIKZVQFT4SRD4Z7XSTQBTSJ5ZSAC","R7J4254ZZREVMWXXDUM772GPLZSCZSIJKOLEAI33WUF2CPS3X6WQC","LQBZJUGCEIU56WBYBLE757W2DHPZWJ4JNG3ILB52RDXMXUYAPZCQC","LIUJQXB752UIHJFF32LKJ7ECUZ2VDIFDDHBLAUVNBRTPDYNCAUYQC","6BIW5YDCZXIH3SNKNTZ3MSHUFGN3VKAYPKI4MWJIFVUY7YQSJJ3AC"]},"hunks":[{"FileAdd":{"meta":{"basename":"server.rs","metadata":0},"context":[{"change":7,"pos":15}],"contents":[{"Add":"use elpe::extract::*;"},{"Add":"use elpe::*;"},{"Add":"use std::sync::Arc;"},{"Add":"use tokio::io::AsyncWriteExt;"},{"Add":"use tokio_stream::wrappers::ReceiverStream;"},{"Add":"use tokio_util::sync::PollSender;"},{"Add":"use tonic::codegen::tokio_stream::StreamExt;"},{"Add":"use tracing::*;"},{"Add":""},{"Add":"pub struct Elpe {"},{"Add":" deb_client: elpe::Client,"},{"Add":" sender: tokio::sync::mpsc::UnboundedSender<("},{"Add":" crate::container::BuildRequest,"},{"Add":" tokio::sync::mpsc::Sender,"},{"Add":" )>,"},{"Add":" t: Option>>,"},{"Add":"}"},{"Add":""},{"Add":"pub mod proto {"},{"Add":" tonic::include_proto!(\"elpe\");"},{"Add":"}"},{"Add":""},{"Add":"impl Elpe {"},{"Add":" pub fn new("},{"Add":" deb_client: elpe::Client,"},{"Add":" container_channel: elpe::container::ContainerChannel,"},{"Add":" ) -> Self {"},{"Add":" let (sender, receiver) = tokio::sync::mpsc::unbounded_channel::<("},{"Add":" crate::container::BuildRequest,"},{"Add":" tokio::sync::mpsc::Sender,"},{"Add":" )>();"},{"Add":""},{"Add":" let t = tokio::spawn(crate::container::forward(receiver, container_channel));"},{"Add":""},{"Add":" Elpe {"},{"Add":" deb_client,"},{"Add":" sender,"},{"Add":" t: Some(t),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" pub async fn serve(mut self, addr: std::net::SocketAddr) {"},{"Add":" let t = self.t.take().unwrap();"},{"Add":" tokio::select! {"},{"Add":" _ = tonic::transport::Server::builder()"},{"Add":" .add_service(proto::elpe_server::ElpeServer::new(self))"},{"Add":" .serve(addr)"},{"Add":" => {}"},{"Add":" _ = t => {}"},{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"use std::pin::Pin;"},{"Add":""},{"Add":"type ResponseStream ="},{"Add":" Pin> + Send>>;"},{"Add":""},{"Add":"#[tonic::async_trait]"},{"Add":"impl proto::elpe_server::Elpe for Elpe {"},{"Add":" async fn add_path("},{"Add":" &self,"},{"Add":" request: tonic::Request>,"},{"Add":" ) -> Result, tonic::Status> {"},{"Add":" let mut r = request.into_inner();"},{"Add":" debug!(\"add_path\");"},{"Add":" let mut current_file = None;"},{"Add":" let ref store = self.deb_client.store_path();"},{"Add":" debug!(\"store\");"},{"Add":" let tmp_dir = tempfile::tempdir_in(store).unwrap();"},{"Add":" debug!(\"store {:?}\", tmp_dir);"},{"Add":""},{"Add":" let mut hasher = blake3::Hasher::new();"},{"Add":" debug!(\"loop\");"},{"Add":" loop {"},{"Add":" trace!(\"waiting for next in stream\");"},{"Add":" let Some(r) = r.next().await else { break };"},{"Add":" let r = r.unwrap();"},{"Add":" match r.request {"},{"Add":" Some(proto::add_path_request::Request::File(f)) => {"},{"Add":" info!(\"Adding file {:?}\", f.name);"},{"Add":" hasher.update(b\"\\0f\");"},{"Add":" hasher.update(f.name.as_bytes());"},{"Add":" hasher.update(b\"\\0\");"},{"Add":" let p = tmp_dir.path().join(&f.name);"},{"Add":" tokio::fs::create_dir_all(p.parent().unwrap()).await?;"},{"Add":" current_file = Some(tokio::fs::File::create(&p).await?)"},{"Add":" }"},{"Add":" Some(proto::add_path_request::Request::Directory(d)) => {"},{"Add":" info!(\"Adding file {:?}\", d.name);"},{"Add":" hasher.update(b\"\\0d\");"},{"Add":" hasher.update(d.name.as_bytes());"},{"Add":" hasher.update(b\"\\0\");"},{"Add":" let p = tmp_dir.path().join(&d.name);"},{"Add":" tokio::fs::create_dir_all(&p).await.unwrap();"},{"Add":" }"},{"Add":" Some(proto::add_path_request::Request::Contents(c)) => {"},{"Add":" hasher.update(&c.content);"},{"Add":" current_file.as_mut().unwrap().write_all(&c.content).await?;"},{"Add":" }"},{"Add":" None => break,"},{"Add":" }"},{"Add":" }"},{"Add":" debug!(\"loop done\");"},{"Add":" let path = store.join(data_encoding::HEXLOWER.encode(hasher.finalize().as_bytes()));"},{"Add":" use tokio::io::ErrorKind;"},{"Add":" let new = tmp_dir.into_path();"},{"Add":" match tokio::fs::rename(&new, &path).await {"},{"Add":" Ok(()) => (),"},{"Add":" Err(e) if e.kind() == ErrorKind::DirectoryNotEmpty => (),"},{"Add":" Err(e) => {"},{"Add":" tokio::fs::remove_dir_all(&new).await?;"},{"Add":" return Err(e.into());"},{"Add":" }"},{"Add":" }"},{"Add":" info!(\"add_path extracted to {:?}\", path);"},{"Add":" Ok(tonic::Response::new(proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Ok("},{"Add":" proto::DerivationResult {"},{"Add":" destdir: vec![path.to_str().unwrap().to_string()],"},{"Add":" paths: Vec::new(),"},{"Add":" path_patterns: Vec::new(),"},{"Add":" },"},{"Add":" )),"},{"Add":" }))"},{"Add":" }"},{"Add":""},{"Add":" type DerivationStream = ResponseStream;"},{"Add":""},{"Add":" async fn derivation("},{"Add":" &self,"},{"Add":" request: tonic::Request,"},{"Add":" ) -> Result, tonic::Status> {"},{"Add":" debug!(\"derivation request\");"},{"Add":" let now = std::time::Instant::now();"},{"Add":" let r = request.into_inner();"},{"Add":" let (tx, rx) = tokio::sync::mpsc::channel(200);"},{"Add":" debug!(\"derivation request: {:?} {:?}\", r.name, r.paths);"},{"Add":" self.sender"},{"Add":" .send(("},{"Add":" crate::container::BuildRequest {"},{"Add":" name: r.name.clone(),"},{"Add":" paths: r.paths,"},{"Add":" script: r.builder,"},{"Add":" target: r.target,"},{"Add":" output_hash: r.output_hash,"},{"Add":" },"},{"Add":" tx,"},{"Add":" ))"},{"Add":" .unwrap();"},{"Add":" use crate::container::Msg;"},{"Add":" let output_stream = ReceiverStream::new(rx).map(|x| {"},{"Add":" Ok(match x {"},{"Add":" Msg::Ok(out) => proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Ok("},{"Add":" proto::DerivationResult {"},{"Add":" destdir: out"},{"Add":" .into_iter()"},{"Add":" .map(|x| x.to_str().unwrap().to_string())"},{"Add":" .collect(),"},{"Add":" paths: Vec::new(),"},{"Add":" path_patterns: Vec::new(),"},{"Add":" },"},{"Add":" )),"},{"Add":" },"},{"Add":" Msg::Error(p) => proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Error(p)),"},{"Add":" },"},{"Add":" Msg::Stdout(p) => proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Stdout(p)),"},{"Add":" },"},{"Add":" Msg::Stderr(p) => proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Stderr(p)),"},{"Add":" },"},{"Add":" })"},{"Add":" });"},{"Add":" info!(\"request {:?}: {:?}\", r.name, now.elapsed());"},{"Add":" Ok(tonic::Response::new(Box::pin(output_stream)))"},{"Add":" }"},{"Add":""},{"Add":" async fn add_url("},{"Add":" &self,"},{"Add":" request: tonic::Request,"},{"Add":" ) -> Result, tonic::Status> {"},{"Add":" let r = request.into_inner();"},{"Add":" debug!(\"add_url request {:?}\", r);"},{"Add":" let p = self"},{"Add":" .deb_client"},{"Add":" .http_download("},{"Add":" &r.url,"},{"Add":" match r.hash_algorithm {"},{"Add":" 0 => {"},{"Add":" let mut h = [0; 32];"},{"Add":" h.clone_from_slice(&r.hash);"},{"Add":" Hash::Blake3(h)"},{"Add":" }"},{"Add":" 1 => {"},{"Add":" let mut h = [0; 32];"},{"Add":" h.clone_from_slice(&r.hash);"},{"Add":" Hash::Sha256(h)"},{"Add":" }"},{"Add":" 2 => {"},{"Add":" let mut h = [0; 64];"},{"Add":" h.clone_from_slice(&r.hash);"},{"Add":" Hash::Sha512(h)"},{"Add":" }"},{"Add":" _ => unreachable!(),"},{"Add":" },"},{"Add":" )"},{"Add":" .await"},{"Add":" .unwrap();"},{"Add":" Ok(tonic::Response::new(proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Ok("},{"Add":" proto::DerivationResult {"},{"Add":" destdir: vec![p.to_str().unwrap().to_string()],"},{"Add":" paths: Vec::new(),"},{"Add":" path_patterns: Vec::new(),"},{"Add":" },"},{"Add":" )),"},{"Add":" }))"},{"Add":" }"},{"Add":""},{"Add":" async fn ubuntu_release("},{"Add":" &self,"},{"Add":" request: tonic::Request,"},{"Add":" ) -> Result, tonic::Status> {"},{"Add":" debug!(\"ubuntu release {:?}\", request);"},{"Add":" let now = std::time::Instant::now();"},{"Add":" let r = request.into_inner();"},{"Add":" let h = self.deb_client.in_release(r.release.clone()).await.unwrap();"},{"Add":" let arch = match r.arch {"},{"Add":" 0 => \"amd64\","},{"Add":" 1 => \"aarch64\","},{"Add":" _ => unreachable!(),"},{"Add":" };"},{"Add":" let p = self"},{"Add":" .deb_client"},{"Add":" .packages(&h, &r.repository, arch)"},{"Add":" .await"},{"Add":" .unwrap();"},{"Add":" info!("},{"Add":" \"ubuntu release request {:?}: {:?}\","},{"Add":" r.release,"},{"Add":" now.elapsed()"},{"Add":" );"},{"Add":" Ok(tonic::Response::new(proto::DerivationReply {"},{"Add":" result: Some(proto::derivation_reply::Result::Ok("},{"Add":" proto::DerivationResult {"},{"Add":" destdir: vec![p.to_str().unwrap().to_string()],"},{"Add":" paths: Vec::new(),"},{"Add":" path_patterns: Vec::new(),"},{"Add":" },"},{"Add":" )),"},{"Add":" }))"},{"Add":" }"},{"Add":""},{"Add":" type UbuntuPackageStream = ResponseStream;"},{"Add":""},{"Add":" async fn ubuntu_package("},{"Add":" &self,"},{"Add":" request: tonic::Request,"},{"Add":" ) -> Result, tonic::Status> {"},{"Add":" let now = std::time::Instant::now();"},{"Add":" let r = request.into_inner();"},{"Add":" let index: Result, _> = r"},{"Add":" .index"},{"Add":" .into_iter()"},{"Add":" .map(|index| deb::Index::open(&index))"},{"Add":" .collect();"},{"Add":" let index = index.unwrap();"},{"Add":""},{"Add":" let link_extra: Vec<_> = r"},{"Add":" .link_extra"},{"Add":" .into_iter()"},{"Add":" .map(|l| {"},{"Add":" ("},{"Add":" regex::Regex::new(&l.pkg).unwrap(),"},{"Add":" regex::Regex::new(&l.dep).unwrap(),"},{"Add":" )"},{"Add":" })"},{"Add":" .collect();"},{"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)),"},{"Add":" },"},{"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":" info!(\"ubuntu package request {:?}: {:?}\", r.name, now.elapsed());"},{"Add":""},{"Add":" Ok(tonic::Response::new(Box::pin(output_stream)))"},{"Add":" }"},{"Add":"}"}]}},{"Edit":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":2,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":7,"pos":286},"to":{"change":7,"start":1489,"end":1511},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1363},"to":{"change":7,"start":1489,"end":1511},"introduced_by":7}],"inode":{"change":7,"pos":1363}}},"contents":[{"Del":"use elpe::extract::*;\n"}]}},{"Edit":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":5,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":7,"pos":332},"to":{"change":7,"start":1421,"end":1441},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":1556},"to":{"change":7,"start":1421,"end":1441},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1421},"to":{"change":7,"start":1421,"end":1441},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1441},"to":{"change":7,"start":1557,"end":1587},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1587},"to":{"change":7,"start":0,"end":44},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":44},"to":{"change":4,"start":0,"end":34},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":34},"to":{"change":7,"start":1587,"end":1632},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":7,"pos":44},"to":{"change":7,"start":1587,"end":1632},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1587},"to":{"change":7,"start":1587,"end":1632},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":1632},"to":{"change":7,"start":1441,"end":1457},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1441},"to":{"change":7,"start":1441,"end":1457},"introduced_by":7}],"inode":{"change":7,"pos":1363}}},"contents":[{"Del":"use std::sync::Arc;\n"},{"Del":"use tokio::io::AsyncWriteExt;\n"},{"Del":"use tokio_stream::wrappers::ReceiverStream;\n"},{"Del":"use tokio_util::sync::PollSender;\n"},{"Del":"use tonic::codegen::tokio_stream::StreamExt;\n"},{"Del":"use tracing::*;\n"}]}},{"Edit":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":6,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1586},"to":{"change":7,"start":1586,"end":1640},"introduced_by":7}],"inode":{"change":7,"pos":1363}}},"contents":[{"Del":"\npub mod proto {\n tonic::include_proto!(\"elpe\");\n}\n"}]}},{"Replacement":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":7,"ins":{"up_context":[{"change":7,"pos":1641}],"down_context":[{"change":7,"pos":104}],"flag":"BLOCK","start":11730,"end":11742,"inode":{"change":7,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1641},"to":{"change":7,"start":1641,"end":1659},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1659},"to":{"change":7,"start":1633,"end":1752},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1752},"to":{"change":7,"start":45,"end":103},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":103},"to":{"change":7,"start":1815,"end":1823},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1815},"to":{"change":7,"start":1815,"end":1823},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":1823},"to":{"change":7,"start":1694,"end":1696},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1694},"to":{"change":7,"start":1694,"end":1696},"introduced_by":7}],"inode":{"change":7,"pos":1363}},"ins_contents":[{"Add":"mod server;"}],"del_contents":[{"Del":"pub struct Elpe {\n"},{"Del":" deb_client: elpe::Client,\n sender: tokio::sync::mpsc::UnboundedSender<(\n crate::container::BuildRequest,\n"},{"Del":" tokio::sync::mpsc::Sender,\n"},{"Del":" )>,\n"},{"Del":"}\n"}]}},{"Edit":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":9,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":105},"to":{"change":7,"start":105,"end":248},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":248},"to":{"change":7,"start":1711,"end":1775},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1711},"to":{"change":7,"start":1711,"end":1775},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1775},"to":{"change":7,"start":1824,"end":1847},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":1847},"to":{"change":7,"start":1800,"end":1815},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1800},"to":{"change":7,"start":1800,"end":1815},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1815},"to":{"change":7,"start":1848,"end":2038},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2038},"to":{"change":4,"start":35,"end":63},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":63},"to":{"change":7,"start":2038,"end":2075},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2038},"to":{"change":7,"start":2038,"end":2075},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2075},"to":{"change":7,"start":333,"end":387},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":387},"to":{"change":4,"start":64,"end":188},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":188},"to":{"change":7,"start":2179,"end":2228},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2179},"to":{"change":7,"start":2179,"end":2228},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2228},"to":{"change":4,"start":189,"end":213},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":213},"to":{"change":7,"start":2229,"end":2482},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2001},"to":{"change":7,"start":2229,"end":2482},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2482},"to":{"change":4,"start":214,"end":269},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":269},"to":{"change":7,"start":2482,"end":2922},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2482},"to":{"change":7,"start":2482,"end":2922},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2922},"to":{"change":4,"start":270,"end":325},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":325},"to":{"change":7,"start":2922,"end":3477},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2922},"to":{"change":7,"start":2922,"end":3477},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":3477},"to":{"change":4,"start":326,"end":355},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":355},"to":{"change":7,"start":3477,"end":4356},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":3477},"to":{"change":7,"start":3477,"end":4356},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4356},"to":{"change":7,"start":249,"end":294},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":294},"to":{"change":7,"start":4356,"end":4456},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4356},"to":{"change":7,"start":4356,"end":4456},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4456},"to":{"change":7,"start":295,"end":361},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":361},"to":{"change":7,"start":4530,"end":4606},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4530},"to":{"change":7,"start":4530,"end":4606},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4606},"to":{"change":7,"start":362,"end":418},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":418},"to":{"change":7,"start":4662,"end":4898},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4662},"to":{"change":7,"start":4662,"end":4898},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4898},"to":{"change":7,"start":0,"end":48},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":48},"to":{"change":7,"start":4898,"end":4975},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4898},"to":{"change":7,"start":4898,"end":4975},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4975},"to":{"change":7,"start":419,"end":718},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":718},"to":{"change":2,"start":0,"end":204},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":204},"to":{"change":7,"start":796,"end":1519},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":796},"to":{"change":7,"start":796,"end":1519},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":1519},"to":{"change":7,"start":2198,"end":2205},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":5566},"to":{"change":7,"start":2198,"end":2205},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2198},"to":{"change":7,"start":2198,"end":2205},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2205},"to":{"change":2,"start":205,"end":1636},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":1636},"to":{"change":7,"start":2205,"end":2249},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2205},"to":{"change":7,"start":2205,"end":2249},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2249},"to":{"change":7,"start":5567,"end":5703},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":5703},"to":{"change":7,"start":2371,"end":2850},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2371},"to":{"change":7,"start":2371,"end":2850},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2850},"to":{"change":7,"start":5704,"end":5997},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":5997},"to":{"change":7,"start":2932,"end":2951},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2932},"to":{"change":7,"start":2932,"end":2951},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2951},"to":{"change":4,"start":356,"end":404},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":404},"to":{"change":7,"start":2951,"end":2995},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2951},"to":{"change":7,"start":2951,"end":2995},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2995},"to":{"change":7,"start":5998,"end":6060},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":6060},"to":{"change":4,"start":405,"end":482},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":482},"to":{"change":7,"start":3117,"end":3392},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":7,"pos":6134},"to":{"change":7,"start":3117,"end":3392},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":3117},"to":{"change":7,"start":3117,"end":3392},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":3392},"to":{"change":7,"start":0,"end":1},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1},"to":{"change":7,"start":0,"end":294},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":294},"to":{"change":4,"start":483,"end":803},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":803},"to":{"change":7,"start":6646,"end":6665},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":6646},"to":{"change":7,"start":6646,"end":6665},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":6665},"to":{"change":4,"start":804,"end":2149},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2149},"to":{"change":7,"start":4845,"end":4851},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4845},"to":{"change":7,"start":4845,"end":4851},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4851},"to":{"change":7,"start":388,"end":391},"introduced_by":7}],"inode":{"change":7,"pos":1363}}},"contents":[{"Del":"use std::pin::Pin;\n\ntype ResponseStream =\n Pin> + Send>>;\n"},{"Del":"\n#[tonic::async_trait]\nimpl proto::elpe_server::Elpe for Elpe {\n"},{"Del":" async fn add_path(\n"},{"Del":" &self,\n"},{"Del":" request: tonic::Request>,\n ) -> Result, tonic::Status> {\n let mut r = request.into_inner();\n"},{"Del":" debug!(\"add_path\");\n"},{"Del":" let mut current_file = None;\n"},{"Del":" let ref store = self.deb_client.store_path();\n"},{"Del":" debug!(\"store\");\n let tmp_dir = tempfile::tempdir_in(store).unwrap();\n debug!(\"store {:?}\", tmp_dir);\n"},{"Del":"\n let mut hasher = blake3::Hasher::new();\n"},{"Del":" debug!(\"loop\");\n"},{"Del":" loop {\n trace!(\"waiting for next in stream\");\n let Some(r) = r.next().await else { break };\n let r = r.unwrap();\n match r.request {\n Some(proto::add_path_request::Request::File(f)) => {\n"},{"Del":" info!(\"Adding file {:?}\", f.name);\n"},{"Del":" hasher.update(b\"\\0f\");\n hasher.update(f.name.as_bytes());\n hasher.update(b\"\\0\");\n let p = tmp_dir.path().join(&f.name);\n tokio::fs::create_dir_all(p.parent().unwrap()).await?;\n current_file = Some(tokio::fs::File::create(&p).await?)\n }\n Some(proto::add_path_request::Request::Directory(d)) => {\n"},{"Del":" info!(\"Adding file {:?}\", d.name);\n"},{"Del":" hasher.update(b\"\\0d\");\n hasher.update(d.name.as_bytes());\n hasher.update(b\"\\0\");\n let p = tmp_dir.path().join(&d.name);\n tokio::fs::create_dir_all(&p).await.unwrap();\n }\n Some(proto::add_path_request::Request::Contents(c)) => {\n hasher.update(&c.content);\n current_file.as_mut().unwrap().write_all(&c.content).await?;\n }\n None => break,\n }\n }\n"},{"Del":" debug!(\"loop done\");\n"},{"Del":" let path = store.join(data_encoding::HEXLOWER.encode(hasher.finalize().as_bytes()));\n use tokio::io::ErrorKind;\n let new = tmp_dir.into_path();\n match tokio::fs::rename(&new, &path).await {\n Ok(()) => (),\n Err(e) if e.kind() == ErrorKind::DirectoryNotEmpty => (),\n Err(e) => {\n tokio::fs::remove_dir_all(&new).await?;\n return Err(e.into());\n }\n }\n info!(\"add_path extracted to {:?}\", path);\n Ok(tonic::Response::new(proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Ok(\n proto::DerivationResult {\n destdir: vec![path.to_str().unwrap().to_string()],\n paths: Vec::new(),\n path_patterns: Vec::new(),\n },\n )),\n }))\n }\n"},{"Del":"\n type DerivationStream = ResponseStream;\n"},{"Del":"\n async fn derivation(\n &self,\n request: tonic::Request,\n"},{"Del":" ) -> Result, tonic::Status> {\n"},{"Del":" debug!(\"derivation request\");\n let r = request.into_inner();\n"},{"Del":" let (tx, rx) = tokio::sync::mpsc::channel(200);\n"},{"Del":" self.sender\n .send((\n crate::container::BuildRequest {\n name: r.name,\n paths: r.paths,\n script: r.builder,\n target: r.target,\n"},{"Del":" output_hash: r.output_hash,\n"},{"Del":" },\n tx,\n ))\n .unwrap();\n"},{"Del":" use crate::container::Msg;\n let output_stream = ReceiverStream::new(rx).map(|x| {\n Ok(match x {\n Msg::Ok(out) => proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Ok(\n proto::DerivationResult {\n"},{"Del":" destdir: out\n .into_iter()\n .map(|x| x.to_str().unwrap().to_string())\n .collect(),\n"},{"Del":" paths: Vec::new(),\n path_patterns: Vec::new(),\n },\n )),\n },\n Msg::Error(p) => proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Error(p)),\n },\n Msg::Stdout(p) => proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Stdout(p)),\n },\n Msg::Stderr(p) => proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Stderr(p)),\n },\n })\n });\n Ok(tonic::Response::new(Box::pin(output_stream)))\n"},{"Del":" }\n\n"},{"Del":" async fn add_url(\n &self,\n request: tonic::Request,\n ) -> Result, tonic::Status> {\n let r = request.into_inner();\n debug!(\"add_url request {:?}\", r);\n let p = self\n .deb_client\n .http_download(\n &r.url,\n match r.hash_algorithm {\n 0 => {\n let mut h = [0; 32];\n h.clone_from_slice(&r.hash);\n Hash::Blake3(h)\n }\n 1 => {\n let mut h = [0; 32];\n h.clone_from_slice(&r.hash);\n Hash::Sha256(h)\n }\n 2 => {\n let mut h = [0; 64];\n h.clone_from_slice(&r.hash);\n Hash::Sha512(h)\n }\n _ => unreachable!(),\n },\n )\n .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 }\n\n"},{"Del":" async fn ubuntu_release(\n &self,\n"},{"Del":" request: tonic::Request,\n ) -> Result, tonic::Status> {\n"},{"Del":" debug!(\"ubuntu release {:?}\", request);\n let r = request.into_inner();\n let h = self.deb_client.in_release(r.release).await.unwrap();\n let arch = match r.arch {\n 0 => \"amd64\",\n 1 => \"aarch64\",\n _ => unreachable!(),\n };\n let p = self\n .deb_client\n .packages(&h, &r.repository, arch)\n .await\n .unwrap();\n Ok(tonic::Response::new(proto::DerivationReply {\n"},{"Del":" 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"},{"Del":" }))\n }\n\n"},{"Del":" type UbuntuPackageStream = ResponseStream;\n\n"},{"Del":" async fn ubuntu_package(\n &self,\n"},{"Del":" request: tonic::Request,\n"},{"Del":" ) -> Result, tonic::Status> {\n"},{"Del":" debug!(\"request {:?}\", request);\n let r = request.into_inner();\n let index: Result, _> = r\n .index\n .into_iter()\n .map(|index| deb::Index::open(&index))\n .collect();\n let index = index.unwrap();\n"},{"Del":"\n"},{"Del":" let link_extra: Vec<_> = r\n .link_extra\n .into_iter()\n .map(|l| {\n (\n regex::Regex::new(&l.pkg).unwrap(),\n regex::Regex::new(&l.dep).unwrap(),\n )\n })\n .collect();\n"},{"Del":"\n let (tx, rx) = tokio::sync::mpsc::channel(200);\n use crate::extract::Msg;\n let output_stream = ReceiverStream::new(rx).map(|x| {\n Ok(match x {\n Msg::Downloading(p) => proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Loading(p)),\n"},{"Del":" },\n"},{"Del":" Msg::Ok(p) => proto::DerivationReply {\n 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 },\n )),\n },\n Msg::Error(e) => proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Error(e.to_string())),\n },\n })\n });\n\n match download_extract_deps(\n &index,\n &self.deb_client,\n &r.name,\n &link_extra,\n PollSender::new(tx.clone()),\n )\n .await\n {\n Ok(p) => {\n info!(\"path {:?} {:#?}\", r.name, p);\n tx.send(Msg::Ok(p)).await.unwrap();\n }\n Err(e) => tx.send(Msg::Error(e)).await.unwrap(),\n }\n\n Ok(tonic::Response::new(Box::pin(output_stream)))\n"},{"Del":" }\n"},{"Del":"}\n\n"}]}},{"Edit":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":47,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1043},"to":{"change":7,"start":1043,"end":1044},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":1044},"to":{"change":7,"start":7101,"end":7219},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":7101},"to":{"change":7,"start":7101,"end":7219},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":7219},"to":{"change":7,"start":1520,"end":1582},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":1582},"to":{"change":7,"start":7286,"end":7300},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":7286},"to":{"change":7,"start":7286,"end":7300},"introduced_by":7}],"inode":{"change":7,"pos":1363}}},"contents":[{"Del":"\n"},{"Del":" let (sender, receiver) = tokio::sync::mpsc::unbounded_channel::<(\n crate::container::BuildRequest,\n"},{"Del":" tokio::sync::mpsc::Sender,\n"},{"Del":" )>();\n"}]}},{"Replacement":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":48,"ins":{"up_context":[{"change":7,"pos":8639}],"down_context":[{"change":7,"pos":8830}],"flag":"BLOCK","start":11743,"end":11909,"inode":{"change":7,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":8639},"to":{"change":7,"start":7301,"end":7387},"introduced_by":7}],"inode":{"change":7,"pos":1363}},"ins_contents":[{"Add":" let elpe = server::Elpe::new("},{"Add":" Client::new(&config.pgp_home, &config.store_path, &config.package_index),"},{"Add":" container_channel,"},{"Add":" );"}],"del_contents":[{"Del":" let t = tokio::spawn(crate::container::forward(receiver, container_channel));\n"}]}},{"Edit":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":53,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":8831},"to":{"change":7,"start":7388,"end":7414},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":7414},"to":{"change":7,"start":1045,"end":1143},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":1143},"to":{"change":7,"start":7502,"end":7533},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":7502},"to":{"change":7,"start":7502,"end":7533},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":7533},"to":{"change":7,"start":9063,"end":9064},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":9063},"to":{"change":7,"start":9063,"end":9064},"introduced_by":7}],"inode":{"change":7,"pos":1363}}},"contents":[{"Del":" let elpe = Elpe {\n"},{"Del":" deb_client: Client::new(&config.pgp_home, &config.store_path, &config.package_index),\n"},{"Del":" sender,\n };\n"},{"Del":"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":1363},"path":"src/main.rs","line":54,"ins":{"up_context":[{"change":7,"pos":7792}],"down_context":[{"change":7,"pos":8026}],"flag":"BLOCK","start":11910,"end":11941,"inode":{"change":7,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":7792},"to":{"change":7,"start":7792,"end":8026},"introduced_by":7}],"inode":{"change":7,"pos":1363}},"ins_contents":[{"Add":" elpe.serve(addr).await"}],"del_contents":[{"Del":" tokio::select! {\n _ = tonic::transport::Server::builder()\n .add_service(proto::elpe_server::ElpeServer::new(elpe))\n .serve(addr)\n => {}\n _ = t => {}\n }\n"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":5,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":44835}],"down_context":[{"change":7,"pos":1669}],"flag":"BLOCK","start":11942,"end":11968,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":"use std::os::fd::OwnedFd;"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":80,"ins":{"up_context":[{"change":7,"pos":46666}],"down_context":[{"change":7,"pos":46727}],"flag":"BLOCK","start":11969,"end":12029,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":46666},"to":{"change":7,"start":46666,"end":46727},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" info!(\"received process response {:?}\", x);"}],"del_contents":[{"Del":" debug!(\"received process response {:?}\", x);\n"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":86,"ins":{"up_context":[{"change":7,"pos":2385}],"down_context":[{"change":7,"pos":2450}],"flag":"BLOCK","start":12030,"end":12090,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2385},"to":{"change":7,"start":2385,"end":2450},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" chan.send(resp).await.unwrap();"}],"del_contents":[{"Del":" chan.send(resp).await.unwrap_or(());\n"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":90,"ins":{"up_context":[{"change":7,"pos":2573}],"down_context":[{"change":7,"pos":2638}],"flag":"BLOCK","start":12091,"end":12151,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2573},"to":{"change":7,"start":2573,"end":2638},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" chan.send(resp).await.unwrap();"}],"del_contents":[{"Del":" chan.send(resp).await.unwrap_or(());\n"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":141,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":48764}],"down_context":[{"change":7,"pos":48764}],"flag":"BLOCK","start":12152,"end":12171,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" let mut n = 0;"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":153,"ins":{"up_context":[{"change":7,"pos":49250}],"down_context":[{"change":7,"pos":49250}],"flag":"BLOCK","start":12172,"end":12215,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":49250},"to":{"change":7,"start":2687,"end":2863},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" let m = n;"},{"Add":" n += 1;"}],"del_contents":[{"Del":" let (writer_out, mut reader_out) = tokio::net::unix::pipe::pipe().unwrap();\n let (writer_err, mut reader_err) = tokio::net::unix::pipe::pipe().unwrap();\n"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":156,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":49288}],"down_context":[{"change":7,"pos":2864}],"flag":"BLOCK","start":12216,"end":12602,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" let (reader_out, writer_out) = std::io::pipe().unwrap();"},{"Add":" let (reader_err, writer_err) = std::io::pipe().unwrap();"},{"Add":" let reader_out_fd = reader_out.as_raw_fd();"},{"Add":" let reader_err_fd = reader_err.as_raw_fd();"},{"Add":" let writer_out_fd = writer_out.as_raw_fd();"},{"Add":" let writer_err_fd = writer_err.as_raw_fd();"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":163,"ins":{"up_context":[{"change":7,"pos":2929}],"down_context":[{"change":7,"pos":2967}],"flag":"BLOCK","start":12603,"end":12890,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2929},"to":{"change":7,"start":2929,"end":2967},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" let writer_out_fd: OwnedFd = writer_out.into();"},{"Add":" let writer_err_fd: OwnedFd = writer_err.into();"},{"Add":" info!(\"run_in_container {}: {}\", m, rec_msg.script);"},{"Add":" let result = run_in_container("},{"Add":" m,"}],"del_contents":[{"Del":" run_in_container(\n"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":171,"ins":{"up_context":[{"change":7,"pos":3063}],"down_context":[{"change":7,"pos":3159}],"flag":"BLOCK","start":12891,"end":13047,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":3063},"to":{"change":7,"start":3063,"end":3159},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" reader_out_fd,"},{"Add":" writer_out_fd,"},{"Add":" reader_err_fd,"},{"Add":" writer_err_fd,"}],"del_contents":[{"Del":" writer_out.as_raw_fd(),\n writer_err.as_raw_fd(),\n"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":176,"ins":{"up_context":[{"change":7,"pos":3181}],"down_context":[{"change":7,"pos":3234}],"flag":"BLOCK","start":13048,"end":13188,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":3181},"to":{"change":7,"start":3181,"end":3234},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" .map_err(|e| format!(\"{:?}\", e));"},{"Add":" info!(\"run_in_container {}: done\", m);"},{"Add":" result"}],"del_contents":[{"Del":" .map_err(|e| format!(\"{:?}\", e))\n"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":182,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":3290}],"down_context":[{"change":7,"pos":3290}],"flag":"BLOCK","start":13189,"end":13458,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" let mut reader_out ="},{"Add":" tokio::net::unix::pipe::Receiver::from_owned_fd(reader_out.into()).unwrap();"},{"Add":" let mut reader_err ="},{"Add":" tokio::net::unix::pipe::Receiver::from_owned_fd(reader_err.into()).unwrap();"},{"Add":""}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":193,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":3590}],"down_context":[{"change":7,"pos":3590}],"flag":"BLOCK","start":13459,"end":13634,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" info!("},{"Add":" \"waiting for run_in_container {} {:?} {:?}\","},{"Add":" m, stdout_closed, stderr_closed"},{"Add":" );"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":217,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":4882}],"down_context":[{"change":7,"pos":4882}],"flag":"BLOCK","start":13635,"end":13725,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" } else {"},{"Add":" stdout_closed = true"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":233,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":5827}],"down_context":[{"change":7,"pos":5827}],"flag":"BLOCK","start":13726,"end":13816,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" } else {"},{"Add":" stderr_closed = true"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":237,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":5883}],"down_context":[{"change":7,"pos":5883}],"flag":"BLOCK","start":13817,"end":13938,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" _ = tokio::time::sleep(std::time::Duration::from_secs(10)) => {info!(\"Still waiting for {}\", m)}"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":243,"ins":{"up_context":[{"change":7,"pos":49630}],"down_context":[{"change":7,"pos":49692}],"flag":"BLOCK","start":13939,"end":14006,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":49630},"to":{"change":7,"start":49630,"end":49692},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" info!(\"drv_process {} replying {:?}\", m, v.len());"}],"del_contents":[{"Del":" debug!(\"drv_process replying {:?}\", v.len());\n"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":246,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":6126}],"down_context":[{"change":7,"pos":49807}],"flag":"BLOCK","start":14007,"end":14044,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" info!(\"sent {}\", m);"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":254,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":6148}],"down_context":[{"change":7,"pos":6148}],"flag":"BLOCK","start":14045,"end":14059,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" m: usize,"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":258,"ins":{"up_context":[{"change":7,"pos":6203}],"down_context":[{"change":7,"pos":75}],"flag":"BLOCK","start":14060,"end":14144,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":6203},"to":{"change":7,"start":6203,"end":6241},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" stdout_r: RawFd,"},{"Add":" stdout: OwnedFd,"},{"Add":" stderr_r: RawFd,"},{"Add":" stderr: OwnedFd,"}],"del_contents":[{"Del":" stdout: RawFd,\n stderr: RawFd,\n"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":272,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":105}],"down_context":[{"change":7,"pos":50195}],"flag":"BLOCK","start":14145,"end":14173,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" debug!(\"{}\", r.script);"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":285,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":50538}],"down_context":[{"change":7,"pos":50538}],"flag":"BLOCK","start":14174,"end":14218,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" drop(stdout);"},{"Add":" drop(stderr);"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":297,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":50931}],"down_context":[{"change":7,"pos":114}],"flag":"BLOCK","start":14219,"end":14259,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" info!(\"{} returning early\", m);"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":321,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":171}],"down_context":[{"change":7,"pos":51447}],"flag":"BLOCK","start":14260,"end":14286,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" info!(\"clone {}\", m);"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":342,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":52049}],"down_context":[{"change":7,"pos":52049}],"flag":"BLOCK","start":14287,"end":14650,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" unsafe {"},{"Add":" if libc::close(stdout_r) != 0 {"},{"Add":" error!(\"couldn't close\");"},{"Add":" return Err(std::io::Error::last_os_error().into());"},{"Add":" }"},{"Add":" if libc::close(stderr_r) != 0 {"},{"Add":" error!(\"couldn't close\");"},{"Add":" return Err(std::io::Error::last_os_error().into());"},{"Add":" }"},{"Add":" }"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":354,"ins":{"up_context":[{"change":7,"pos":6299}],"down_context":[{"change":7,"pos":6385}],"flag":"BLOCK","start":14651,"end":14889,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":6299},"to":{"change":7,"start":6299,"end":6385},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" user,"},{"Add":" &r,"},{"Add":" &tmp_dir,"},{"Add":" &dest,"},{"Add":" &store,"},{"Add":" &tmp_store,"},{"Add":" &name,"},{"Add":" stdout.as_raw_fd(),"},{"Add":" stderr.as_raw_fd(),"}],"del_contents":[{"Del":" user, &r, &tmp_dir, &dest, &store, &tmp_store, &name, stdout, stderr,\n"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":376,"ins":{"up_context":[{"change":7,"pos":52411}],"down_context":[{"change":7,"pos":52438}],"flag":"BLOCK","start":14890,"end":14966,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":52411},"to":{"change":7,"start":52411,"end":52438},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" drop(stdout);"},{"Add":" drop(stderr);"},{"Add":" info!(\"waitpid {}\", m);"}],"del_contents":[{"Del":" debug!(\"waitpid\");\n"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":381,"ins":{"up_context":[{"change":7,"pos":52528}],"down_context":[{"change":7,"pos":52702}],"flag":"BLOCK","start":14967,"end":15018,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":52528},"to":{"change":7,"start":52528,"end":52573},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" info!(\"{} return status {:?}\", m, status);"}],"del_contents":[{"Del":" info!(\"return status {:?}\", status);\n"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":395,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":174}],"down_context":[{"change":3,"pos":174}],"flag":"BLOCK","start":15019,"end":15077,"inode":{"change":7,"pos":44692}}},"contents":[{"Add":" std::fs::remove_dir_all(&dest).unwrap_or(());"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":540,"ins":{"up_context":[{"change":7,"pos":57164}],"down_context":[{"change":7,"pos":57164}],"flag":"BLOCK","start":15078,"end":15120,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":57164},"to":{"change":7,"start":6400,"end":6438},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" stdout_w: RawFd,"},{"Add":" stderr_w: RawFd,"}],"del_contents":[{"Del":" stdout: RawFd,\n stderr: RawFd,\n"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":662,"ins":{"up_context":[{"change":7,"pos":6456}],"down_context":[{"change":7,"pos":520}],"flag":"BLOCK","start":15121,"end":15176,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":6456},"to":{"change":7,"start":467,"end":520},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" if libc::dup2(stdout_w, this_stdout) < 0 {"}],"del_contents":[{"Del":" if libc::dup2(stdout, this_stdout) < 0 {\n"}]}},{"Replacement":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":665,"ins":{"up_context":[{"change":7,"pos":602}],"down_context":[{"change":7,"pos":655}],"flag":"BLOCK","start":15177,"end":15232,"inode":{"change":7,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":602},"to":{"change":7,"start":602,"end":655},"introduced_by":7}],"inode":{"change":7,"pos":44692}},"ins_contents":[{"Add":" if libc::dup2(stderr_w, this_stderr) < 0 {"}],"del_contents":[{"Del":" if libc::dup2(stderr, this_stderr) < 0 {\n"}]}},{"Edit":{"inode":{"change":7,"pos":44692},"path":"src/container.rs","line":668,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":737},"to":{"change":7,"start":737,"end":775},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":775},"to":{"change":7,"start":6491,"end":6526},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":6491},"to":{"change":7,"start":6491,"end":6526},"introduced_by":7}],"inode":{"change":7,"pos":44692}}},"contents":[{"Del":" // libc::dup2(stdout, 1);\n"},{"Del":" libc::dup2(stderr, 2);\n"}]}},{"Edit":{"inode":{"change":22,"pos":34},"path":"shell.nix","line":101,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":70}],"down_context":[{"change":22,"pos":2728}],"flag":"BLOCK","start":15233,"end":15289,"inode":{"change":22,"pos":34}}},"contents":[{"Add":" ocamlPackages.ppx_string"},{"Add":" ocamlPackages.ppx_blob"}]}},{"FileAdd":{"meta":{"basename":"semantic_versions.ml","metadata":0},"context":[{"change":7,"pos":55449}],"contents":[{"Add":"let of_string input ="},{"Add":" try"},{"Add":" Scanf.sscanf input \"%u.%u.%u-%s\" (fun v1 v2 v3 v4 -> (v1, v2, v3, Some v4))"},{"Add":" with _ -> Scanf.sscanf input \"%u.%u.%u\" (fun v1 v2 v3 -> (v1, v2, v3, None))"},{"Add":""},{"Add":"let to_string (v1, v2, v3, v4) ="},{"Add":" match v4 with"},{"Add":" | None -> Printf.sprintf \"%u.%u.%u\" v1 v2 v3"},{"Add":" | Some s -> Printf.sprintf \"%u.%u.%u-%s\" v1 v2 v3 s"}]}},{"FileAdd":{"meta":{"basename":"rust","metadata":576},"context":[{"change":7,"pos":55449}],"contents":[]}},{"FileMove":{"meta":{"basename":"rust.ml","metadata":0},"old":[{"basename":"rust.ml","metadata":0}],"up":[{"change":0,"pos":15691}],"down":[{"change":7,"pos":32}],"show_perms":false}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":14,"ins":{"up_context":[{"change":7,"pos":292}],"down_context":[{"change":7,"pos":299}],"flag":"BLOCK","start":15712,"end":15731,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":292},"to":{"change":7,"start":292,"end":299},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" http ~name:crate"}],"del_contents":[{"Del":" http\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":30,"ins":{"up_context":[{"change":7,"pos":677}],"down_context":[{"change":7,"pos":702}],"flag":"BLOCK","start":15732,"end":15775,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":677},"to":{"change":7,"start":677,"end":702},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" method name = \"rust-unzip-\" ^ pkg#name"}],"del_contents":[{"Del":" method name = \"rust\"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":39,"ins":{"up_context":[{"change":7,"pos":1068}],"down_context":[{"change":7,"pos":1150}],"flag":"BLOCK","start":15776,"end":16381,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1068},"to":{"change":6,"start":475,"end":1069},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" [%string"},{"Add":" {|mkdir -p $DESTDIR"},{"Add":" tar -xf %{List.hd zipped.destdir} -C $DESTDIR"},{"Add":" cd $DESTDIR/*"},{"Add":" echo -n \\{\\\"files\\\":\\{ >.cargo-checksum.json"},{"Add":" n=0"},{"Add":" for f in $(find . -type f -printf '%P\\n'); do"},{"Add":" if [[ $n -gt 0 ]]; then"},{"Add":" echo -n , >>.cargo-checksum.json"},{"Add":" fi"},{"Add":" echo -n \\\"$f\\\":\\\"$(sha256sum $f | cut -d\" \" -f 1)\\\" >> .cargo-checksum.json"},{"Add":" n=$((n+1))"},{"Add":" done"},{"Add":" echo -n \\},\\\"package\\\":\\\"%{hash}\\\"\\} >> .cargo-checksum.json"},{"Add":" |}]"},{"Add":""},{"Add":" method! install_phase = Lwt.return \"\""}],"del_contents":[{"Del":" (\"mkdir -p $DESTDIR; tar -xf \" ^ List.hd zipped.destdir\n ^ \" -C $DESTDIR; cd $DESTDIR/*; echo -n \\\\{\\\\\\\"files\\\\\\\":\\\\{ \\\n >.cargo-checksum.json\\n\\\n n=0\\n\\\n for f in $(find . -type f -printf '%P\\\\n'); do\\n\\\n if [[ $n -gt 0 ]]; then\\n\\\n echo -n , >>.cargo-checksum.json\\n\\\n fi\\n\\\n echo -n \\\\\\\"$f\\\\\\\":\\\\\\\"$(sha256sum $f | cut -d\\\" \\\" -f 1)\\\\\\\" >> \\\n .cargo-checksum.json;\\n\\\n n=$((n+1))\\n\\\n done\\n\\\n echo -n \\\\},\\\\\\\"package\\\\\\\":\\\\\\\"\" ^ hash\n ^ \"\\\\\\\"\\\\} >> .cargo-checksum.json\")\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":57,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":1156}],"down_context":[{"change":7,"pos":186}],"flag":"BLOCK","start":16382,"end":16558,"inode":{"change":7,"pos":32}}},"contents":[{"Add":""},{"Add":"let extra_crate_dependencies name version ="},{"Add":" match (name, version) with"},{"Add":" | \"openssl\", _ | \"openssl-sys\", _ ->"},{"Add":" [ ubuntu \"libssl-dev\"; ubuntu \"pkg-config\" ]"},{"Add":" | _ -> []"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":83,"ins":{"up_context":[{"change":7,"pos":466}],"down_context":[{"change":7,"pos":1110}],"flag":"BLOCK","start":16559,"end":17172,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":466},"to":{"change":7,"start":466,"end":845},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":845},"to":{"change":6,"start":1457,"end":1525},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":1525},"to":{"change":7,"start":895,"end":1110},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":895},"to":{"change":7,"start":895,"end":1110},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" Lwt_list.map_s"},{"Add":" (fun pkg ->"},{"Add":" try"},{"Add":" let source = str_from_toml_table \"source\" pkg in"},{"Add":" let checksum = str_from_toml_table \"checksum\" pkg in"},{"Add":" let name = str_from_toml_table \"name\" pkg in"},{"Add":" let version = str_from_toml_table \"version\" pkg in"},{"Add":" let h = fetch_crate source checksum name version in"},{"Add":" let drv = (unzip_checksum h checksum :> derivation) in"},{"Add":" let* built = drv#build in"},{"Add":" n_packages := !n_packages + 1;"},{"Add":" Lwt.return (Some (name, version, source, drv, built))"},{"Add":" with Not_found -> Lwt.return None)"},{"Add":" packages"}],"del_contents":[{"Del":" Lwt.all\n (List.map\n (fun pkg ->\n try\n let source = str_from_toml_table \"source\" pkg in\n let checksum = str_from_toml_table \"checksum\" pkg in\n let name = str_from_toml_table \"name\" pkg in\n let version = str_from_toml_table \"version\" pkg in\n let h = fetch_crate source checksum name version in\n"},{"Del":" let drv = (unzip_checksum h checksum :> derivation) in\n"},{"Del":" let* built = drv#build in\n n_packages := !n_packages + 1;\n Lwt.return (Some (name, version, source, drv, built))\n with Not_found -> Lwt.return None)\n packages)\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":123,"ins":{"up_context":[{"change":7,"pos":1673}],"down_context":[{"change":7,"pos":1398}],"flag":"BLOCK","start":17173,"end":17230,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1673},"to":{"change":7,"start":1673,"end":1780},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" let platform = \" --filter-platform \" ^ platform in"}],"del_contents":[{"Del":" let platform =\n match platform with Some s -> \" --filter-platform \" ^ s | None -> \"\"\n in\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":126,"ins":{"up_context":[{"change":7,"pos":1826}],"down_context":[{"change":7,"pos":2331}],"flag":"BLOCK","start":17231,"end":18144,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1826},"to":{"change":7,"start":1826,"end":1984},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1984},"to":{"change":6,"start":1783,"end":1979},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":1979},"to":{"change":7,"start":2128,"end":2147},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2128},"to":{"change":7,"start":2128,"end":2147},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2147},"to":{"change":6,"start":1980,"end":2035},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":2035},"to":{"change":7,"start":2147,"end":2331},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2147},"to":{"change":7,"start":2147,"end":2331},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" let package_list ="},{"Add":" List.fold_left"},{"Add":" (fun acc x ->"},{"Add":" match x with"},{"Add":" | Some (crate_name, version, _, _, built) ->"},{"Add":" let target ="},{"Add":" if Hashtbl.find_opt h crate_name = None then ("},{"Add":" Hashtbl.add h crate_name ();"},{"Add":" crate_name)"},{"Add":" else crate_name ^ \"-\" ^ version"},{"Add":" in"},{"Add":" List.iter self#add_path built.destdir;"},{"Add":" ["},{"Add":" \"ln -s \";"},{"Add":" List.hd built.destdir;"},{"Add":" \"/\";"},{"Add":" crate_name;"},{"Add":" \"-\";"},{"Add":" version;"},{"Add":" \" vendor/\";"},{"Add":" target;"},{"Add":" \"\\n\";"},{"Add":" ]"},{"Add":" @ acc"},{"Add":" | None -> acc)"},{"Add":" [] packages"},{"Add":" in"},{"Add":" String.concat \"\" package_list"}],"del_contents":[{"Del":" List.fold_left\n (fun acc x ->\n match x with\n | Some (crate_name, version, _, _, built) ->\n let target =\n"},{"Del":" if Hashtbl.find_opt h crate_name = None then (\n Hashtbl.add h crate_name ();\n crate_name)\n else crate_name ^ \"-\" ^ version\n"},{"Del":" in\n"},{"Del":" List.iter self#add_path built.destdir;\n"},{"Del":" acc ^ \"ln -s \" ^ List.hd built.destdir ^ \"/\" ^ crate_name ^ \"-\"\n ^ version ^ \" vendor/\" ^ target ^ \"\\n\"\n | None -> acc)\n \"\" packages\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":156,"ins":{"up_context":[{"change":7,"pos":2358}],"down_context":[{"change":7,"pos":1630}],"flag":"BLOCK","start":18145,"end":18559,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2358},"to":{"change":7,"start":2358,"end":2913},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" [%string"},{"Add":" {|export HOME=/home/me"},{"Add":"mkdir -p $HOME"},{"Add":"export PATH=%{List.hd rustc}/usr/lib/rust-%{rust_version}/bin:%{List.hd cargo}/usr/lib/rust-%{rust_version}/bin:$PATH"},{"Add":"mkdir -p vendor .cargo"},{"Add":"%{packages}"},{"Add":"cat <> .cargo/config.toml"},{"Add":"[source.crates-io]"},{"Add":"replace-with = \"vendored-sources\""},{"Add":"[source.vendored-sources]"},{"Add":"directory = \"vendor\""},{"Add":"EOF"},{"Add":"cargo metadata --offline --format-version 1 %{platform}"},{"Add":"|}]"}],"del_contents":[{"Del":" \"export HOME=/home/me\\nmkdir -p $HOME\\nexport PATH=\" ^ List.hd rustc\n ^ \"/usr/lib/rust-\" ^ rust_version ^ \"/bin:\" ^ List.hd cargo\n ^ \"/usr/lib/rust-\" ^ rust_version\n ^ \"/bin:$PATH\\nmkdir -p vendor .cargo\\n\" ^ packages\n ^ \"\\n\\\n cat <> .cargo/config.toml\\n\\\n [source.crates-io]\\n\\\n replace-with = \\\"vendored-sources\\\"\\n\\n\\\n [source.vendored-sources]\\n\\\n directory = \\\"vendor\\\"\\n\\\n EOF\\n\\\n cargo metadata --offline --format-version 1\" ^ platform\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":178,"ins":{"up_context":[{"change":6,"pos":2167}],"down_context":[{"change":6,"pos":2234}],"flag":"BLOCK","start":18560,"end":18856,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":2167},"to":{"change":6,"start":2167,"end":2234},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":"type deps = {"},{"Add":" build_dependencies : (string * string * string * bool * build_result) list;"},{"Add":" dependencies : (string * string * string * bool * build_result) list;"},{"Add":" transitive_build_dependencies : (string, build_result) Hashtbl.t;"},{"Add":" transitive_dependencies : (string, build_result) Hashtbl.t;"},{"Add":"}"}],"del_contents":[{"Del":"type deps = { build_dependencies : string; dependencies : string }\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":187,"ins":{"up_context":[{"change":6,"pos":2322}],"down_context":[{"change":7,"pos":3151}],"flag":"BLOCK","start":18857,"end":19200,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":2322},"to":{"change":6,"start":2322,"end":2403},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":"class compiled_crate ~rust_version ~rustc ~cc ~host ~target ~package ~path"},{"Add":" ~dependencies ~features ~opt_level ~is_top_level ="},{"Add":" let package_deps ="},{"Add":" let d = package |> member \"dependencies\" |> to_list in"},{"Add":" let h = Hashtbl.create (List.length d) in"},{"Add":" List.iter (fun d -> Hashtbl.add h (d |> member \"name\" |> to_string) d) d;"},{"Add":" h"},{"Add":" in"}],"del_contents":[{"Del":"class compiled_crate rust_version rustc cc platform package path deps features =\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":199,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":2503}],"down_context":[{"change":7,"pos":3250}],"flag":"BLOCK","start":19201,"end":19272,"inode":{"change":7,"pos":32}}},"contents":[{"Add":" method semantic_version = Semantic_versions.of_string self#version"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":201,"ins":{"up_context":[{"change":7,"pos":3284}],"down_context":[{"change":7,"pos":3284}],"flag":"BLOCK","start":19273,"end":19333,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":3284},"to":{"change":6,"start":2504,"end":2539},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" method targets = package |> member \"targets\" |> to_list"}],"del_contents":[{"Del":" val target_platform = platform\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":208,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":2672}],"down_context":[{"change":7,"pos":2324}],"flag":"BLOCK","start":19334,"end":19721,"inode":{"change":7,"pos":32}}},"contents":[{"Add":" let* deps = self#dependencies in"},{"Add":" let dependencies ="},{"Add":" String.concat \" \""},{"Add":" (List.map"},{"Add":" (fun (_, _, _, _, r) -> List.hd r.destdir)"},{"Add":" deps.dependencies)"},{"Add":" in"},{"Add":" let build_dependencies ="},{"Add":" String.concat \" \""},{"Add":" (List.map"},{"Add":" (fun (_, _, _, _, r) -> List.hd r.destdir)"},{"Add":" deps.build_dependencies)"},{"Add":" in"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":222,"ins":{"up_context":[{"change":7,"pos":2341}],"down_context":[{"change":7,"pos":2913}],"flag":"BLOCK","start":19722,"end":20069,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2341},"to":{"change":6,"start":2673,"end":2814},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" [%string"},{"Add":" {|%{s}"},{"Add":" for i in %{dependencies} %{build_dependencies}; do"},{"Add":" if [[ -s $i/lib/env ]]; then"},{"Add":" source $i/lib/env"},{"Add":" fi"},{"Add":" done"},{"Add":" export HOME=/home/me"},{"Add":" mkdir -p $HOME"},{"Add":" export PATH=%{List.hd rustc}/usr/lib/rust-%{rust_version}/bin:$PATH"},{"Add":" |}]"}],"del_contents":[{"Del":" (s ^ \"export HOME=/home/me\\nmkdir -p $HOME\\nexport PATH=\"\n ^ List.hd rustc ^ \"/usr/lib/rust-\" ^ rust_version ^ \"/bin:$PATH\\n\")\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":242,"ins":{"up_context":[{"change":6,"pos":3090}],"down_context":[{"change":6,"pos":3154}],"flag":"BLOCK","start":20070,"end":20139,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":3090},"to":{"change":6,"start":3090,"end":3154},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" (fun acc x -> [%string {|%{acc} --cfg 'feature=\"%{x}\"'|}])"}],"del_contents":[{"Del":" (fun acc x -> acc ^ \" --cfg 'feature=\\\"\" ^ x ^ \"\\\"'\")\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":272,"ins":{"up_context":[{"change":7,"pos":4203}],"down_context":[{"change":6,"pos":4342}],"flag":"BLOCK","start":20140,"end":20335,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4203},"to":{"change":6,"start":4189,"end":4342},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" method private compile_target setup target build_target kind"},{"Add":" transitive_dependencies dependencies out ="},{"Add":" let initial_src_path = build_target |> member \"src_path\" |> to_string in"}],"del_contents":[{"Del":" method private compile_target setup platform target kind dependencies out =\n let initial_src_path = target |> member \"src_path\" |> to_string in\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":276,"ins":{"up_context":[{"change":6,"pos":4403}],"down_context":[{"change":6,"pos":4460}],"flag":"BLOCK","start":20336,"end":20399,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":4403},"to":{"change":6,"start":4403,"end":4460},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" let name = build_target |> member \"name\" |> to_string in"}],"del_contents":[{"Del":" let name = target |> member \"name\" |> to_string in\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":279,"ins":{"up_context":[{"change":6,"pos":4519}],"down_context":[{"change":6,"pos":4595}],"flag":"BLOCK","start":20400,"end":20492,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":4519},"to":{"change":6,"start":4519,"end":4595},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" try"},{"Add":" \" --edition=\" ^ (build_target |> member \"edition\" |> to_string) ^ \" \""}],"del_contents":[{"Del":" try \" --edition=\" ^ (target |> member \"edition\" |> to_string) ^ \" \"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":285,"ins":{"up_context":[{"change":6,"pos":4744}],"down_context":[{"change":6,"pos":4833}],"flag":"BLOCK","start":20493,"end":21082,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":4744},"to":{"change":6,"start":4744,"end":4833},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":""},{"Add":" let dependencies_str ="},{"Add":" List.fold_left"},{"Add":" (fun acc (rename, name, h, is_proc_macro, b) ->"},{"Add":" acc ^ \" --extern \" ^ underscorize rename ^ \"=\" ^ List.hd b.destdir"},{"Add":" ^ \"/lib/lib\" ^ underscorize name ^ \"-\" ^ h"},{"Add":" ^"},{"Add":" if is_proc_macro then \".so\""},{"Add":" else if kind = \"lib\" then \".rmeta\""},{"Add":" else \".rlib\")"},{"Add":" \"\" dependencies"},{"Add":" in"},{"Add":""},{"Add":" let dependencies_str ="},{"Add":" Hashtbl.fold"},{"Add":" (fun _ v acc -> acc ^ \" -L dependency=\" ^ List.hd v.destdir ^ \"/lib\")"},{"Add":" transitive_dependencies dependencies_str"}],"del_contents":[{"Del":" let platform =\n match platform with Some p -> \" --target \" ^ p | None -> \"\"\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":303,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":4842}],"down_context":[{"change":6,"pos":4842}],"flag":"BLOCK","start":21083,"end":21143,"inode":{"change":7,"pos":32}}},"contents":[{"Add":" let target = \" --target \" ^ Platform.triple target in"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":306,"ins":{"up_context":[{"change":7,"pos":4220}],"down_context":[{"change":6,"pos":5110}],"flag":"BLOCK","start":21144,"end":21506,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4220},"to":{"change":6,"start":4870,"end":5110},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" [%string"},{"Add":" {|"},{"Add":" %{!setup}"},{"Add":" set -x"},{"Add":" rustc --crate-name %{under} %{edition} %{src_path} %{target} --crate-type bin -C linker=gcc $RUSTC_FLAGS %{features_args} -C metadata=%{hash} --out-dir %{out} %{dependencies_str} -L dependency=../lib --cap-lints allow"},{"Add":" { set +x; } 2>/dev/null"},{"Add":" |}]"}],"del_contents":[{"Del":" !setup ^ \"rustc --crate-name \" ^ under ^ edition ^ src_path ^ platform\n ^ \" --crate-type bin -C linker=gcc\" ^ features_args ^ \" -C metadata=\"\n ^ hash ^ \" --out-dir \" ^ out ^ dependencies ^ \" --cap-lints allow\\n\"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":315,"ins":{"up_context":[{"change":6,"pos":5138}],"down_context":[{"change":6,"pos":5501}],"flag":"BLOCK","start":21507,"end":22067,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":5138},"to":{"change":6,"start":5138,"end":5501},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" [%string"},{"Add":" {|"},{"Add":" %{!setup}"},{"Add":" set -x"},{"Add":" rustc --crate-name %{under} %{edition} %{src_path} --crate-type %{kind} %{target} --emit=dep-info,metadata,link -C linker=gcc -C embed-bitcode=no -C debuginfo=2 $RUSTC_FLAGS %{if kind = \"proc-macro\" then \" -C prefer-dynamic\" else \"\"} %{features_args} -C metadata=%{hash} --out-dir %{out} -C extra-filename=-%{hash} %{dependencies_str} %{if kind = \"proc-macro\" then \" --extern proc_macro\" else \"\"} --cap-lints allow"},{"Add":" { set +x; } 2>/dev/null"},{"Add":" |}];"}],"del_contents":[{"Del":" !setup ^ \"rustc --crate-name \" ^ under ^ edition ^ src_path\n ^ \" --crate-type \" ^ kind ^ platform\n ^ \" --emit=dep-info,metadata,link -C embed-bitcode=no -C debuginfo=2\"\n ^ features_args ^ \" -C metadata=\" ^ hash ^ \" --out-dir \" ^ out\n ^ \" -C extra-filename=-\" ^ hash ^ dependencies\n ^ \" --cap-lints allow\\n\";\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":325,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":5515}],"down_context":[{"change":6,"pos":5515}],"flag":"BLOCK","start":22068,"end":22929,"inode":{"change":7,"pos":32}}},"contents":[{"Add":" val accumulated_deps : (string, compiled_crate) Hashtbl.t option ref ="},{"Add":" ref None"},{"Add":""},{"Add":" method accumulated_deps ="},{"Add":" match !accumulated_deps with"},{"Add":" | Some acc -> Lwt.return acc"},{"Add":" | None ->"},{"Add":" let h = Hashtbl.create 256 in"},{"Add":" let* _ ="},{"Add":" Lwt_list.iter_s"},{"Add":" (fun d ->"},{"Add":" let dd = Hashtbl.find package_deps d#name in"},{"Add":" let is_build ="},{"Add":" dd |> member \"kind\" |> to_option to_string = Some \"build\""},{"Add":" in"},{"Add":" Hashtbl.add h d#name d;"},{"Add":" let* acc = d#accumulated_deps in"},{"Add":" Lwt.return"},{"Add":" (if not is_build then"},{"Add":" Hashtbl.iter (fun k v -> Hashtbl.add h k v) acc"},{"Add":" else ()))"},{"Add":" dependencies"},{"Add":" in"},{"Add":" accumulated_deps := Some h;"},{"Add":" Lwt.return h"},{"Add":""}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":360,"ins":{"up_context":[{"change":6,"pos":5840}],"down_context":[{"change":6,"pos":6195}],"flag":"BLOCK","start":22930,"end":23080,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":5840},"to":{"change":6,"start":5840,"end":6195},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" let de = ref [] in"},{"Add":" let h = Hashtbl.create 256 in"},{"Add":" let build_h = Hashtbl.create 256 in"},{"Add":" let build_de = ref [] in"}],"del_contents":[{"Del":" let package_deps =\n let d = package |> member \"dependencies\" |> to_list in\n let h = Hashtbl.create (List.length d) in\n List.iter\n (fun d -> Hashtbl.add h (d |> member \"name\" |> to_string) d)\n d;\n h\n in\n let de = ref \"\" in\n let build_de = ref \"\" in\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":365,"ins":{"up_context":[{"change":6,"pos":6217}],"down_context":[{"change":6,"pos":6244}],"flag":"BLOCK","start":23081,"end":23108,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":6217},"to":{"change":6,"start":6217,"end":6244},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" Lwt_list.map_s"}],"del_contents":[{"Del":" Lwt_list.map_p\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":368,"ins":{"up_context":[{"change":6,"pos":6304}],"down_context":[{"change":6,"pos":6352}],"flag":"BLOCK","start":23109,"end":24745,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":6304},"to":{"change":6,"start":6304,"end":6352},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" Lwt.return (x, x#name, x#hash, b))"},{"Add":" dependencies"},{"Add":" in"},{"Add":" let* _ ="},{"Add":" Lwt_list.iter_s"},{"Add":" (fun (x, x_name, x_hash, b) ->"},{"Add":" let d = Hashtbl.find package_deps x_name in"},{"Add":" let is_build ="},{"Add":" d |> member \"kind\" |> to_option to_string = Some \"build\""},{"Add":" in"},{"Add":" List.iter self#add_path b.destdir;"},{"Add":" let name ="},{"Add":" match d |> member \"rename\" |> to_option to_string with"},{"Add":" | Some rename -> rename"},{"Add":" | None -> x_name"},{"Add":" in"},{"Add":" let r, h = if is_build then (build_de, build_h) else (de, h) in"},{"Add":" let* acc = x#accumulated_deps in"},{"Add":" let* _ ="},{"Add":" Hashtbl.fold"},{"Add":" (fun name v acc ->"},{"Add":" if Hashtbl.find_opt h name = None then ("},{"Add":" let* _ = acc in"},{"Add":" let* b = v#build in"},{"Add":" List.iter self#add_path b.destdir;"},{"Add":" Hashtbl.add h name b;"},{"Add":" Lwt.return ())"},{"Add":" else Lwt.return ())"},{"Add":" acc (Lwt.return ())"},{"Add":" in"},{"Add":" let is_proc_macro ="},{"Add":" List.exists"},{"Add":" (fun t ->"},{"Add":" List.exists"},{"Add":" (fun k -> k = \"proc-macro\")"},{"Add":" (t |> member \"kind\" |> to_list |> filter_string))"},{"Add":" x#targets"},{"Add":" in"},{"Add":" r := (name, x_name, x_hash, is_proc_macro, b) :: !r;"},{"Add":" Lwt.return ())"}],"del_contents":[{"Del":" Lwt.return (x#name, x#hash, b))\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":410,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":6384},"to":{"change":6,"start":6384,"end":7125},"introduced_by":6}],"inode":{"change":7,"pos":32}}},"contents":[{"Del":" List.iter\n (fun (x_name, x_hash, b) ->\n let d = Hashtbl.find package_deps x_name in\n let is_build =\n d |> member \"kind\" |> to_option to_string = Some \"build\"\n in\n List.iter self#add_path b.destdir;\n let name =\n match d |> member \"rename\" |> to_option to_string with\n | Some rename -> rename\n | None -> x_name\n in\n let r = if is_build then build_de else de in\n r :=\n !r ^ \" -L dependency=target/deps --extern \" ^ name ^ \"=\"\n ^ List.hd b.destdir ^ \"/lib/lib\" ^ x_name ^ \"-\" ^ x_hash\n ^ \".rlib\")\n deps;\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":411,"ins":{"up_context":[{"change":6,"pos":7126}],"down_context":[{"change":6,"pos":7207}],"flag":"BLOCK","start":24746,"end":24988,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":7126},"to":{"change":6,"start":7126,"end":7207},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" let result ="},{"Add":" {"},{"Add":" build_dependencies = !build_de;"},{"Add":" transitive_build_dependencies = build_h;"},{"Add":" dependencies = !de;"},{"Add":" transitive_dependencies = h;"},{"Add":" }"},{"Add":" in"}],"del_contents":[{"Del":" let result = { build_dependencies = !build_de; dependencies = !de } in\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":422,"ins":{"up_context":[{"change":6,"pos":7284}],"down_context":[{"change":6,"pos":7349}],"flag":"BLOCK","start":24989,"end":25262,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":7284},"to":{"change":6,"start":7284,"end":7349},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" method! build_inputs ="},{"Add":" Lwt.return"},{"Add":" (["},{"Add":" ubuntu \"coreutils\";"},{"Add":" ubuntu \"sed\";"},{"Add":" ubuntu \"gcc\";"},{"Add":" ubuntu \"grep\";"},{"Add":" ubuntu \"gawk\";"},{"Add":" cc;"},{"Add":" ]"},{"Add":" @ extra_crate_dependencies self#name self#version)"}],"del_contents":[{"Del":" method! build_inputs = Lwt.return [ ubuntu \"coreutils\"; cc ]\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":438,"ins":{"up_context":[{"change":6,"pos":7481}],"down_context":[{"change":6,"pos":7562}],"flag":"BLOCK","start":25263,"end":25336,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":7481},"to":{"change":6,"start":7481,"end":7562},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" ref (\"mkdir -p target/build-\" ^ hash ^ \"\\nexport RUSTC=rustc\\n\")"}],"del_contents":[{"Del":" ref (\"set -x\\nmkdir -p target/build-\" ^ hash ^ \"\\nexport RUSTC=rustc\\n\")\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":448,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":7793}],"down_context":[{"change":6,"pos":7793}],"flag":"BLOCK","start":25337,"end":25455,"inode":{"change":7,"pos":32}}},"contents":[{"Add":" let v0, v1, v2, v4 = self#semantic_version in"},{"Add":" let name = self#name in"},{"Add":" let version = self#version in"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":452,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":7853}],"down_context":[{"change":6,"pos":7853}],"flag":"BLOCK","start":25456,"end":26521,"inode":{"change":7,"pos":32}}},"contents":[{"Add":" setup :="},{"Add":" !setup"},{"Add":" ^ [%string"},{"Add":" {|export OUT_DIR=$DESTDIR/lib"},{"Add":" export CARGO_PKG_VERSION=\"%{version}\""},{"Add":" export CARGO_PKG_NAME=\"%{name}\""},{"Add":" export CARGO_PKG_VERSION_MAJOR=%{v0#Int}"},{"Add":" export CARGO_PKG_VERSION_MINOR=%{v1#Int}"},{"Add":" export CARGO_PKG_VERSION_PATCH=%{v2#Int}"},{"Add":" export CARGO_PKG_VERSION_PATCH=%{Option.value v4 ~default:\"\"}"},{"Add":" export TARGET=\"%{Platform.triple target}\""},{"Add":" export HOST=\"%{Platform.triple host}\""},{"Add":" export OPT_LEVEL=%{opt_level}"},{"Add":" export CARGO_CFG_UNIX=1"},{"Add":" export CARGO_CFG_TARGET_ABI=\"\""},{"Add":" export CARGO_CFG_TARGET_OS=linux"},{"Add":" export CARGO_CFG_TARGET_ENDIAN=\"%{Platform.string_of_endianness (Platform.endianness target)}\""},{"Add":" export CARGO_CFG_TARGET_POINTER_WIDTH=%{(Platform.pointer_width target)#Int}"},{"Add":" export CARGO_CFG_TARGET_ENV=\"%{Platform.env target}\""},{"Add":" export CARGO_CFG_TARGET_ARCH=\"%{Platform.string_of_arch target.arch}\""},{"Add":" |}];"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":487,"ins":{"up_context":[{"change":6,"pos":8408}],"down_context":[{"change":6,"pos":8551}],"flag":"BLOCK","start":26522,"end":26724,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":8408},"to":{"change":6,"start":8408,"end":8551},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" (self#compile_target setup host target \"bin\""},{"Add":" d.transitive_build_dependencies d.build_dependencies"},{"Add":" (\"target/build-\" ^ hash))"}],"del_contents":[{"Del":" (self#compile_target setup None target \"bin\"\n d.build_dependencies (\"target/build-\" ^ hash))\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":493,"ins":{"up_context":[{"change":6,"pos":8686}],"down_context":[{"change":6,"pos":8760}],"flag":"BLOCK","start":26725,"end":26761,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":8686},"to":{"change":6,"start":8686,"end":8760},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" (true, None) self#targets"}],"del_contents":[{"Del":" (true, None)\n (package |> member \"targets\" |> to_list)\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":495,"ins":{"up_context":[{"change":6,"pos":8769}],"down_context":[{"change":6,"pos":8818}],"flag":"BLOCK","start":26762,"end":26818,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":8769},"to":{"change":6,"start":8769,"end":8818},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" setup := !setup ^ \"mkdir -p $OUT_DIR || true\\n\";"},{"Add":""}],"del_contents":[{"Del":" (* If there is a build script, call it. *)\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":500,"ins":{"up_context":[{"change":6,"pos":8890}],"down_context":[{"change":6,"pos":8966}],"flag":"BLOCK","start":26819,"end":27202,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":8890},"to":{"change":6,"start":8890,"end":8966},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" setup :="},{"Add":" !setup"},{"Add":" ^ [%string"},{"Add":" {|CRATENAME=$(echo %{name} | sed -e \"s/\$.*\$-sys$/\\U\\1/\" -e \"s/-/_/g\")"},{"Add":" CRATEVERSION=$(echo %{version} | sed -e \"s/[\\.\\+-]/_/g\")"},{"Add":" |}]"},{"Add":" ^ String.trim [%blob \"run_build_script.sh\"]"},{"Add":" ^ [%string \"<<< $(target/build-%{hash}/%{bs_name})\\n\"]"}],"del_contents":[{"Del":" setup := !setup ^ \"target/build-\" ^ hash ^ \"/\" ^ bs_name ^ \"\\n\"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":521,"ins":{"up_context":[{"change":7,"pos":4771}],"down_context":[{"change":7,"pos":4794}],"flag":"BLOCK","start":27203,"end":27232,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4771},"to":{"change":7,"start":4771,"end":4794},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" (fun build_target ->"}],"del_contents":[{"Del":" (fun target ->\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":524,"ins":{"up_context":[{"change":7,"pos":4839}],"down_context":[{"change":6,"pos":9449}],"flag":"BLOCK","start":27233,"end":27309,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4839},"to":{"change":6,"start":9257,"end":9449},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" if kind = \"bin\" then if !has_bin then () else has_bin := true"}],"del_contents":[{"Del":" if kind = \"bin\" then\n if !has_bin then ()\n else (\n has_bin := true;\n setup := !setup ^ \"mkdir -p $DESTDIR/bin\\n\")\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":526,"ins":{"up_context":[{"change":6,"pos":9488}],"down_context":[{"change":7,"pos":4839}],"flag":"BLOCK","start":27310,"end":27346,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":9488},"to":{"change":6,"start":9488,"end":9604},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" else has_lib := true;"}],"del_contents":[{"Del":" else (\n has_lib := true;\n setup := !setup ^ \"mkdir -p $DESTDIR/lib\\n\");\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":531,"ins":{"up_context":[{"change":6,"pos":9650}],"down_context":[{"change":6,"pos":9776}],"flag":"BLOCK","start":27347,"end":27492,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":9650},"to":{"change":6,"start":9650,"end":9776},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" self#compile_target setup target build_target kind"},{"Add":" d.transitive_dependencies d.dependencies \"$OUT_DIR\""}],"del_contents":[{"Del":" self#compile_target setup target_platform target kind\n d.dependencies \"$DESTDIR/lib\"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":536,"ins":{"up_context":[{"change":7,"pos":4975}],"down_context":[{"change":7,"pos":5020}],"flag":"BLOCK","start":27493,"end":27812,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4975},"to":{"change":6,"start":9819,"end":10013},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" if is_top_level then"},{"Add":" let _ ="},{"Add":" self#compile_target setup target build_target kind"},{"Add":" d.transitive_dependencies d.dependencies"},{"Add":" \"$OUT_DIR/../bin\""},{"Add":" in"},{"Add":" ()"},{"Add":" else ()"}],"del_contents":[{"Del":" let _ =\n self#compile_target setup target_platform target kind\n d.dependencies \"$DESTDIR/bin\"\n in\n ()\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":545,"ins":{"up_context":[{"change":7,"pos":5045}],"down_context":[{"change":7,"pos":5162}],"flag":"BLOCK","start":27813,"end":27908,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":5045},"to":{"change":7,"start":5045,"end":5162},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" (build_target |> member \"kind\" |> to_list |> filter_string))"},{"Add":" self#targets;"}],"del_contents":[{"Del":" (target |> member \"kind\" |> to_list |> filter_string))\n (package |> member \"targets\" |> to_list);\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":548,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":5186}],"down_context":[{"change":7,"pos":5264}],"flag":"BLOCK","start":27909,"end":28095,"inode":{"change":7,"pos":32}}},"contents":[{"Add":""},{"Add":" method! install_phase ="},{"Add":" Lwt.return"},{"Add":" {|"},{"Add":" if [[ -s target/env ]]; then"},{"Add":" mkdir -p $DESTDIR/lib"},{"Add":" cp target/env $DESTDIR/lib"},{"Add":" fi"},{"Add":" |}"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":559,"ins":{"up_context":[{"change":7,"pos":4399}],"down_context":[{"change":7,"pos":5346}],"flag":"BLOCK","start":28096,"end":28882,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4399},"to":{"change":6,"start":10014,"end":10073},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":"let rec dfs nodes seen result n ="},{"Add":" match Hashtbl.find_opt seen n with"},{"Add":" | Some () -> result"},{"Add":" | None ->"},{"Add":" let _ = Hashtbl.add seen n () in"},{"Add":" let node = Hashtbl.find nodes n in"},{"Add":" let deps = node |> member \"dependencies\" |> to_list |> filter_string in"},{"Add":" let result = List.fold_left (dfs nodes seen) result deps in"},{"Add":" node :: result"},{"Add":""},{"Add":"let topo_sort n_nodes nodes ="},{"Add":" let h = Hashtbl.create n_nodes in"},{"Add":" let nodes_list ="},{"Add":" List.fold_left"},{"Add":" (fun list node ->"},{"Add":" let id = node |> member \"id\" |> to_string in"},{"Add":" Hashtbl.add h id node;"},{"Add":" id :: list)"},{"Add":" [] nodes"},{"Add":" in"},{"Add":""},{"Add":" let seen = Hashtbl.create n_nodes in"},{"Add":" List.fold_left (dfs h seen) [] nodes_list"},{"Add":""},{"Add":"let rust ?(rust_version = \"1.84\") ?(target = !Platform.target)"},{"Add":" ?(host = !Platform.host) src ="}],"del_contents":[{"Del":"let rust ?(rust_version = \"1.84\") ?(platform = None) src =\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":593,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":5896},"to":{"change":6,"start":10155,"end":10194},"introduced_by":6}],"inode":{"change":7,"pos":32}}},"contents":[{"Del":" let cc = ubuntu \"build-essential\" in\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":595,"ins":{"up_context":[{"change":7,"pos":5914}],"down_context":[{"change":7,"pos":5985}],"flag":"BLOCK","start":28883,"end":28980,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":5914},"to":{"change":6,"start":10195,"end":10270},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" new metadata"},{"Add":" rust_version cargo rustc (Platform.triple target) src n_packages packages"}],"del_contents":[{"Del":" new metadata rust_version cargo rustc platform src n_packages packages\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":609,"ins":{"up_context":[{"change":7,"pos":6439}],"down_context":[{"change":7,"pos":6440}],"flag":"BLOCK","start":28981,"end":29084,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":6439},"to":{"change":7,"start":6439,"end":6440},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" let workspace_members ="},{"Add":" meta_json |> member \"workspace_members\" |> to_list |> filter_string"},{"Add":" in"}],"del_contents":[{"Del":"\n"}]}},{"Edit":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":627,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4515},"to":{"change":7,"start":4515,"end":4516},"introduced_by":7}],"inode":{"change":7,"pos":32}}},"contents":[{"Del":"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":633,"ins":{"up_context":[{"change":7,"pos":7236}],"down_context":[{"change":7,"pos":7237}],"flag":"BLOCK","start":29085,"end":29200,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":7236},"to":{"change":7,"start":7236,"end":7237},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" let is_top_level = List.exists (fun w -> w = name) workspace_members in"},{"Add":" let cc = (cc :> derivation) in"}],"del_contents":[{"Del":"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":637,"ins":{"up_context":[{"change":6,"pos":10298}],"down_context":[{"change":7,"pos":4792}],"flag":"BLOCK","start":29201,"end":29337,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":10298},"to":{"change":6,"start":10298,"end":10370},"introduced_by":6}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" ~rust_version ~rustc ~cc ~target ~host ~package:meta ~path:drv"},{"Add":" ~dependencies ~features ~opt_level:\"3\" ~is_top_level"}],"del_contents":[{"Del":" rust_version rustc cc platform meta drv dependencies features\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":641,"ins":{"up_context":[{"change":7,"pos":7372}],"down_context":[{"change":7,"pos":4862}],"flag":"BLOCK","start":29338,"end":29383,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":7372},"to":{"change":7,"start":7372,"end":7383},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" (List.rev (topo_sort n_packages nodes));"}],"del_contents":[{"Del":" nodes;\n"}]}},{"Replacement":{"inode":{"change":7,"pos":32},"path":"elpe/lib/rust/rust.ml","line":643,"ins":{"up_context":[{"change":7,"pos":4863}],"down_context":[],"flag":"BLOCK","start":29384,"end":29450,"inode":{"change":7,"pos":32}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4863},"to":{"change":7,"start":7384,"end":7513},"introduced_by":7}],"inode":{"change":7,"pos":32}},"ins_contents":[{"Add":" Lwt.return (List.map (Hashtbl.find resolved) workspace_members)"}],"del_contents":[{"Del":" Lwt.return\n (List.map (Hashtbl.find resolved)\n (meta_json |> member \"workspace_members\" |> to_list |> filter_string))\n"}]}},{"FileAdd":{"meta":{"basename":"run_build_script.sh","metadata":0},"context":[{"change":0,"pos":15691}],"contents":[{"Add":"while read cargo; do"},{"Add":""},{"Add":" eval $(echo $cargo | sed -ne 's/cargo:rustc-link-arg=\$.*\$/RUSTC_FLAGS=\"-C link_arg=\\1 $RUSTC_FLAGS\"/p')"},{"Add":""},{"Add":" eval $(echo $cargo | sed -ne 's/cargo:rustc-link-lib=\$.*\$/RUSTC_FLAGS=\"-l\\1 $RUSTC_FLAGS\"/p')"},{"Add":""},{"Add":" eval $(echo $cargo | sed -ne 's/cargo:rustc-link-search=\$.*\$/RUSTC_FLAGS=\"-L\\1 $RUSTC_FLAGS\"/p')"},{"Add":""},{"Add":" eval $(echo $cargo | sed -ne \"s/cargo:rustc-cfg=\$.*\$/RUSTC_FLAGS='--cfg \\1 $RUSTC_FLAGS'/p\")"},{"Add":""},{"Add":" eval $(echo $cargo | sed -ne 's/cargo:rustc-flags=\$.*\$/RUSTC_FLAGS=\"\\1 $RUSTC_FLAGS\"/p')"},{"Add":""},{"Add":" echo $cargo | grep -P \"^cargo:(?!:?(rustc-|warning=|rerun-if-changed=|rerun-if-env-changed))\" \\"},{"Add":" | gawk -F= \"/^cargo::metadata=/ { gsub(/-/, \\\"_\\\", \\$2); print \\\"export \\\" toupper(\\\"DEP_$(echo $CRATENAME)_\\\" \\$2) \\\"=\\\" \\\"\\\\\\\"\\\"\\$3\\\"\\\\\\\"\\\"; next }"},{"Add":" /^cargo:/ { sub(/^cargo::?/, \\\"\\\", \\$1); gsub(/-/, \\\"_\\\", \\$1); print \\\"export \\\" toupper(\\\"DEP_$(echo $CRATENAME)_\\\" \\$1) \\\"=\\\" \\\"\\\\\\\"\\\"\\$2\\\"\\\\\\\"\\\"; print \\\"export \\\" toupper(\\\"DEP_$(echo $CRATENAME)_$(echo $CRATEVERSION)_\\\" \\$1) \\\"=\\\" \\\"\\\\\\\"\\\"\\$2\\\"\\\\\\\"\\\"; next }\" >> target/env"},{"Add":""},{"Add":"done"}]}},{"FileAdd":{"meta":{"basename":"platform.ml","metadata":0},"context":[{"change":7,"pos":55449}],"contents":[{"Add":"type arch = Amd64 | Aarch64"},{"Add":"type endianness = Little | Big"},{"Add":"type platform = { arch : arch; env : string }"},{"Add":""},{"Add":"let default = { arch = Amd64; env = \"gnu\" }"},{"Add":"let endianness p = match p.arch with Amd64 | Aarch64 -> Little"},{"Add":"let env p = p.env"},{"Add":"let string_of_endianness = function Little -> \"little\" | Big -> \"big\""},{"Add":"let string_of_arch = function Amd64 -> \"x86_64\" | Aarch64 -> \"aarch64\""},{"Add":"let pointer_width _ = 64"},{"Add":""},{"Add":"let triple p ="},{"Add":" match p.arch with"},{"Add":" | Amd64 -> \"x86_64-unknown-linux-gnu\""},{"Add":" | Aarch64 -> \"aarch64-unknown-linux-gnu\""},{"Add":""},{"Add":"let host = ref default"},{"Add":"let target = ref default"}]}},{"Edit":{"inode":{"change":7,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":73,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":55726}],"down_context":[{"change":7,"pos":55726}],"flag":"BLOCK","start":31188,"end":31234,"inode":{"change":7,"pos":55490}}},"contents":[{"Add":"enum Endianness {"},{"Add":" big = 0;"},{"Add":" little = 1;"},{"Add":"}"},{"Add":""}]}},{"Edit":{"inode":{"change":7,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":93,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":16524}],"down_context":[{"change":7,"pos":55903}],"flag":"BLOCK","start":31235,"end":31335,"inode":{"change":7,"pos":55490}}},"contents":[{"Add":"}"},{"Add":""},{"Add":"message PlatformReply {"},{"Add":" Arch arch = 1;"},{"Add":" Endianness endianness = 2;"},{"Add":" int32 pointer_width = 3;"}]}},{"Edit":{"inode":{"change":7,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":101,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":55906}],"down_context":[{"change":7,"pos":55906}],"flag":"BLOCK","start":31336,"end":31354,"inode":{"change":7,"pos":55490}}},"contents":[{"Add":"message Empty {}"},{"Add":""}]}},{"Edit":{"inode":{"change":7,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":104,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":55921}],"down_context":[{"change":7,"pos":6582}],"flag":"BLOCK","start":31355,"end":31404,"inode":{"change":7,"pos":55490}}},"contents":[{"Add":" rpc Handshake (Empty) returns (PlatformReply);"}]}},{"Replacement":{"inode":{"change":7,"pos":56160},"path":"elpe/lib/elpe.ml","line":11,"ins":{"up_context":[{"change":7,"pos":58601}],"down_context":[{"change":7,"pos":65023}],"flag":"BLOCK","start":31405,"end":31949,"inode":{"change":7,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":58601},"to":{"change":7,"start":64972,"end":65023},"introduced_by":7}],"inode":{"change":7,"pos":56160}},"ins_contents":[{"Add":"let rec is_ignored ignored dir path current ="},{"Add":" match ignored with"},{"Add":" | [] -> current"},{"Add":" | (negated, dir_only, h) :: t ->"},{"Add":" is_ignored t dir path"},{"Add":" (if negated && current then not (Str.string_match h path 0)"},{"Add":" else if (dir_only && dir) || not dir_only then"},{"Add":" current || Str.string_match h path 0"},{"Add":" else current)"},{"Add":""},{"Add":"let is_ignored_dir ignored path = is_ignored ignored true path false"},{"Add":"let is_ignored_file ignored path = is_ignored ignored false path false"},{"Add":""},{"Add":"let rec walk_dir_rec encode f buf ignored path path_name ="}],"del_contents":[{"Del":"let rec walk_dir_rec encode f buf path path_name =\n"}]}},{"Replacement":{"inode":{"change":7,"pos":56160},"path":"elpe/lib/elpe.ml","line":43,"ins":{"up_context":[{"change":7,"pos":65607}],"down_context":[{"change":7,"pos":66091}],"flag":"BLOCK","start":31950,"end":32573,"inode":{"change":7,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":65607},"to":{"change":7,"start":65607,"end":66091},"introduced_by":7}],"inode":{"change":7,"pos":56160}},"ins_contents":[{"Add":" if not (is_ignored_dir ignored path_name) then ("},{"Add":" let req ="},{"Add":" AddPathRequest.make"},{"Add":" ~request:"},{"Add":" (`Directory"},{"Add":" (AddPathRequest.Directory.make ~name:path_name"},{"Add":" ~permissions:0o644 ()))"},{"Add":" ()"},{"Add":" in"},{"Add":" let enc = encode req |> Writer.contents in"},{"Add":" f (Some enc);"},{"Add":" walk_dir_rec encode f buf ignored path path_name)"},{"Add":" else Lwt.return ()"}],"del_contents":[{"Del":" let req =\n AddPathRequest.make\n ~request:\n (`Directory\n (AddPathRequest.Directory.make ~name:path_name\n ~permissions:0o644 ()))\n ()\n in\n let enc = encode req |> Writer.contents in\n f (Some enc);\n walk_dir_rec encode f buf path path_name\n"}]}},{"Replacement":{"inode":{"change":7,"pos":56160},"path":"elpe/lib/elpe.ml","line":57,"ins":{"up_context":[{"change":7,"pos":66123}],"down_context":[{"change":7,"pos":67319}],"flag":"BLOCK","start":32574,"end":33927,"inode":{"change":7,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":66123},"to":{"change":7,"start":66123,"end":67319},"introduced_by":7}],"inode":{"change":7,"pos":56160}},"ins_contents":[{"Add":" if not (is_ignored_file ignored path_name) then"},{"Add":" let* file = Lwt_unix.openfile path [ O_RDONLY ] 0 in"},{"Add":" let ff ="},{"Add":" AddPathRequest.File.make ~name:path_name"},{"Add":" ~length:stat.st_size ~permissions:0o644 ()"},{"Add":" in"},{"Add":" let req = AddPathRequest.make ~request:(`File ff) () in"},{"Add":" let enc = encode req |> Writer.contents in"},{"Add":" let () = f (Some enc) in"},{"Add":" let rec read_all n ="},{"Add":" let* r = Lwt_unix.read file buf 0 4096 in"},{"Add":" if r != 0 then"},{"Add":" let req ="},{"Add":" AddPathRequest.make"},{"Add":" ~request:"},{"Add":" (`Contents"},{"Add":" (AddPathRequest.FileContents.make ~start:n"},{"Add":" ~content:(Bytes.sub buf 0 r) ()))"},{"Add":" ()"},{"Add":" in"},{"Add":" let enc = encode req |> Writer.contents in"},{"Add":" let () = f (Some enc) in"},{"Add":" read_all (n + r)"},{"Add":" else Lwt.return ()"},{"Add":" in"},{"Add":" read_all 0"},{"Add":" else Lwt.return ()"}],"del_contents":[{"Del":" let* file = Lwt_unix.openfile path [ O_RDONLY ] 0 in\n let ff =\n AddPathRequest.File.make ~name:path_name\n ~length:stat.st_size ~permissions:0o644 ()\n in\n let req = AddPathRequest.make ~request:(`File ff) () in\n let enc = encode req |> Writer.contents in\n let () = f (Some enc) in\n let rec read_all n =\n let* r = Lwt_unix.read file buf 0 4096 in\n if r != 0 then\n let req =\n AddPathRequest.make\n ~request:\n (`Contents\n (AddPathRequest.FileContents.make ~start:n\n ~content:(Bytes.sub buf 0 r) ()))\n ()\n in\n let enc = encode req |> Writer.contents in\n let () = f (Some enc) in\n read_all (n + r)\n else Lwt.return ()\n in\n read_all 0\n"}]}},{"Replacement":{"inode":{"change":7,"pos":56160},"path":"elpe/lib/elpe.ml","line":92,"ins":{"up_context":[{"change":7,"pos":67527}],"down_context":[{"change":7,"pos":67559}],"flag":"BLOCK","start":33928,"end":33968,"inode":{"change":7,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":67527},"to":{"change":7,"start":67527,"end":67559},"introduced_by":7}],"inode":{"change":7,"pos":56160}},"ins_contents":[{"Add":"let add_path connection ignored path0 ="}],"del_contents":[{"Del":"let add_path connection path0 =\n"}]}},{"Replacement":{"inode":{"change":7,"pos":56160},"path":"elpe/lib/elpe.ml","line":104,"ins":{"up_context":[{"change":7,"pos":67971}],"down_context":[{"change":7,"pos":68029}],"flag":"BLOCK","start":33969,"end":34035,"inode":{"change":7,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":67971},"to":{"change":7,"start":67971,"end":68029},"introduced_by":7}],"inode":{"change":7,"pos":56160}},"ins_contents":[{"Add":" let* _ = walk_dir_rec encode f buf ignored path0 \"\" in"}],"del_contents":[{"Del":" let* _ = walk_dir_rec encode f buf path0 \"\" in\n"}]}},{"Edit":{"inode":{"change":7,"pos":56160},"path":"elpe/lib/elpe.ml","line":118,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":68469}],"down_context":[{"change":7,"pos":68469}],"flag":"BLOCK","start":34036,"end":35589,"inode":{"change":7,"pos":56160}}},"contents":[{"Add":""},{"Add":"let rec read_ignore ign ="},{"Add":" try"},{"Add":" let line = input_line ign in"},{"Add":" let rest = read_ignore ign in"},{"Add":" let regexp = Str.regexp {|\$\\\\#\$\\|\$^#\$\\|\$^!\$\\|\$\\*\\*\$\\|\\*|} in"},{"Add":""},{"Add":" let result = ref \"\" in"},{"Add":" let i = ref 0 in"},{"Add":" let negated = ref false in"},{"Add":" let _ ="},{"Add":" try"},{"Add":" let ended = ref false in"},{"Add":" while not !ended do"},{"Add":" let next = Str.search_forward regexp line !i in"},{"Add":" let _ ="},{"Add":" if next - !i > 0 then"},{"Add":" result := !result ^ Str.quote (String.sub line !i (next - !i))"},{"Add":" else ()"},{"Add":" in"},{"Add":" let m = Str.matched_string line in"},{"Add":" let _ ="},{"Add":" match m with"},{"Add":" | \"!\" -> negated := true"},{"Add":" | \"#\" -> ended := true"},{"Add":" | \"**\" -> result := !result ^ \".*\""},{"Add":" | \"*\" -> result := !result ^ \"[^/]*\""},{"Add":" | \"\\\\#\" -> result := !result ^ \"#\""},{"Add":" | m -> result := !result ^ Str.quote m"},{"Add":" in"},{"Add":" i := next + String.length m"},{"Add":" done"},{"Add":" with Not_found ->"},{"Add":" result :="},{"Add":" !result ^ Str.quote (String.sub line !i (String.length line - !i))"},{"Add":" in"},{"Add":" if String.length !result > 0 then"},{"Add":" let dir_only = !result.[String.length !result - 1] = '/' in"},{"Add":" let result ="},{"Add":" if dir_only then String.sub !result 0 (String.length !result - 1)"},{"Add":" else !result"},{"Add":" in"},{"Add":" if String.contains result '/' then"},{"Add":" (!negated, dir_only, Str.regexp result) :: rest"},{"Add":" else"},{"Add":" (!negated, dir_only, Str.regexp ({|\$\\(.+/\$\\|^\\)|} ^ result)) :: rest"},{"Add":" else rest"},{"Add":" with End_of_file -> []"}]}},{"Edit":{"inode":{"change":7,"pos":56160},"path":"elpe/lib/elpe.ml","line":171,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":279}],"down_context":[{"change":7,"pos":58889}],"flag":"BLOCK","start":35590,"end":35616,"inode":{"change":7,"pos":56160}}},"contents":[{"Add":" val cached = ref None"}]}},{"Replacement":{"inode":{"change":7,"pos":56160},"path":"elpe/lib/elpe.ml","line":174,"ins":{"up_context":[{"change":7,"pos":58910}],"down_context":[{"change":7,"pos":72688}],"flag":"BLOCK","start":35617,"end":36277,"inode":{"change":7,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":58910},"to":{"change":7,"start":58910,"end":58998},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":59300},"to":{"change":7,"start":59300,"end":59309},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":59309},"to":{"change":7,"start":280,"end":313},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":313},"to":{"change":7,"start":59399,"end":59439},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":59399},"to":{"change":7,"start":59399,"end":59439},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":59439},"to":{"change":7,"start":68948,"end":68969},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":7630},"to":{"change":7,"start":72562,"end":72631},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":72562},"to":{"change":7,"start":72562,"end":72631},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":72631},"to":{"change":4,"start":4737,"end":4783},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4783},"to":{"change":7,"start":72662,"end":72688},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":72662},"to":{"change":7,"start":72662,"end":72688},"introduced_by":7}],"inode":{"change":7,"pos":56160}},"ins_contents":[{"Add":" match !cached with"},{"Add":" | None ->"},{"Add":" let c ="},{"Add":" match !backend_conn with None -> failwith \"no conn\" | Some c -> c"},{"Add":" in"},{"Add":" let ignored ="},{"Add":" try read_ignore (open_in \".ignore\") with Sys_error _ -> []"},{"Add":" in"},{"Add":" let* res = add_path c ignored p in"},{"Add":" let res, _ = Result.get_ok res in"},{"Add":" let result ="},{"Add":" match res with"},{"Add":" | `Ok r -> { destdir = r.destdir; paths = r.paths }"},{"Add":" | `Error e -> raise (DerivationError e)"},{"Add":" | _ -> assert false"},{"Add":" in"},{"Add":" cached := Some result;"},{"Add":" Lwt.return result"},{"Add":" | Some cached -> Lwt.return cached"}],"del_contents":[{"Del":" let c =\n match !backend_conn with None -> failwith \"no conn\" | Some c -> c\n"},{"Del":" in\n"},{"Del":" let* res = add_path c p in\n"},{"Del":" let res, _ = Result.get_ok res in\n"},{"Del":" match res with\n"},{"Del":" | `Ok r -> Lwt.return { destdir = r.destdir; paths = r.paths }\n"},{"Del":" | `Error e -> raise (DerivationError e)\n"},{"Del":" | _ -> assert false\n"}]}},{"Edit":{"inode":{"change":7,"pos":62377},"path":"elpe/lib/dune","line":1,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":62377}],"down_context":[{"change":7,"pos":62378}],"flag":"BLOCK","start":36278,"end":36308,"inode":{"change":7,"pos":62377}}},"contents":[{"Add":"(include_subdirs unqualified)"}]}},{"Replacement":{"inode":{"change":7,"pos":62377},"path":"elpe/lib/dune","line":3,"ins":{"up_context":[{"change":7,"pos":62387}],"down_context":[{"change":7,"pos":7727}],"flag":"BLOCK","start":36309,"end":36531,"inode":{"change":7,"pos":62377}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":62387},"to":{"change":7,"start":62387,"end":62434},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":62434},"to":{"change":7,"start":314,"end":406},"introduced_by":7}],"inode":{"change":7,"pos":62377}},"ins_contents":[{"Add":"(name elpe)"},{"Add":"(public_name elpe)"},{"Add":"(modes byte)"},{"Add":"(preprocess (pps ppx_blob ppx_string))"},{"Add":"(preprocessor_deps (file run_build_script.sh))"},{"Add":""},{"Add":"(libraries grpc-lwt lwt lwt.unix h2 h2-lwt-unix ocaml-protoc-plugin core yojson toml hex))"}],"del_contents":[{"Del":" (name elpe)\n (public_name elpe)\n (modes byte)\n"},{"Del":" (libraries grpc-lwt lwt lwt.unix h2 h2-lwt-unix ocaml-protoc-plugin core yojson toml hex))\n"}]}},{"Replacement":{"inode":{"change":7,"pos":62377},"path":"elpe/lib/dune","line":12,"ins":{"up_context":[{"change":7,"pos":62517}],"down_context":[],"flag":"BLOCK","start":36532,"end":36688,"inode":{"change":7,"pos":62377}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":62517},"to":{"change":7,"start":62517,"end":62611},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":62611},"to":{"change":7,"start":72941,"end":73010},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":73010},"to":{"change":7,"start":62676,"end":62691},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":62676},"to":{"change":7,"start":62676,"end":62691},"introduced_by":7}],"inode":{"change":7,"pos":62377}},"ins_contents":[{"Add":"(targets elpegrpc.ml)"},{"Add":"(deps"},{"Add":"(:proto elpegrpc.proto))"},{"Add":"(action"},{"Add":"(run"},{"Add":"protoc"},{"Add":"-I"},{"Add":"."},{"Add":"\"--ocaml_out=annot=[@@deriving show { with_path = false }, eq]:.\""},{"Add":"%{proto})))"}],"del_contents":[{"Del":" (targets elpegrpc.ml)\n (deps\n (:proto elpegrpc.proto))\n (action\n (run\n protoc\n -I\n .\n"},{"Del":" \"--ocaml_out=annot=[@@deriving show { with_path = false }, eq]:.\"\n"},{"Del":" %{proto})))\n"}]}},{"Edit":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":36,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":1296}],"down_context":[{"change":7,"pos":1296}],"flag":"BLOCK","start":36689,"end":36775,"inode":{"change":7,"pos":445}}},"contents":[{"Add":""},{"Add":"let ubuntu_releases = Hashtbl.create 8"},{"Add":"let ubuntu_release_lock = Lwt_mutex.create ()"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":41,"ins":{"up_context":[{"change":7,"pos":1356}],"down_context":[{"change":7,"pos":16525}],"flag":"BLOCK","start":36776,"end":38259,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":1356},"to":{"change":7,"start":1356,"end":2288},"introduced_by":7}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" Lwt_mutex.with_lock ubuntu_release_lock (fun () ->"},{"Add":" match Hashtbl.find_opt ubuntu_releases (release, arch, repository) with"},{"Add":" | None ->"},{"Add":" let req ="},{"Add":" Elpegrpc.Elpe.UbuntuReleaseRequest.make ~release ~arch ~repository"},{"Add":" ()"},{"Add":" in"},{"Add":" let open Ocaml_protoc_plugin in"},{"Add":" let encode, decode ="},{"Add":" Service.make_client_functions Elpegrpc.Elpe.Elpe.ubuntuRelease"},{"Add":" in"},{"Add":" let enc = encode req |> Writer.contents in"},{"Add":" let* r ="},{"Add":" Client.call ~service:\"elpe.Elpe\" ~rpc:\"UbuntuRelease\""},{"Add":" ~do_request:"},{"Add":" (H2_lwt_unix.Client.request connection ~error_handler:(fun _ ->"},{"Add":" failwith \"Error\"))"},{"Add":" ~handler:"},{"Add":" (Client.Rpc.unary enc ~f:(fun decoder ->"},{"Add":" let+ decoder = decoder in"},{"Add":" match decoder with"},{"Add":" | Some decoder -> ("},{"Add":" Reader.create decoder |> decode |> function"},{"Add":" | Ok v -> v"},{"Add":" | Error e ->"},{"Add":" failwith"},{"Add":" (Printf.sprintf \"Could not decode request: %s\""},{"Add":" (Result.show_error e)))"},{"Add":" | None -> Elpegrpc.Elpe.Elpe.Derivation.Response.make ()))"},{"Add":" ()"},{"Add":" in"},{"Add":" Hashtbl.add ubuntu_releases (release, arch, repository) r;"},{"Add":" Lwt.return r"},{"Add":" | Some x -> Lwt.return x)"}],"del_contents":[{"Del":" let req =\n Elpegrpc.Elpe.UbuntuReleaseRequest.make ~release ~arch ~repository ()\n in\n let open Ocaml_protoc_plugin in\n let encode, decode =\n Service.make_client_functions Elpegrpc.Elpe.Elpe.ubuntuRelease\n in\n let enc = encode req |> Writer.contents in\n Client.call ~service:\"elpe.Elpe\" ~rpc:\"UbuntuRelease\"\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"}]}},{"Edit":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":77,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":16587}],"down_context":[{"change":7,"pos":2288}],"flag":"BLOCK","start":38260,"end":38346,"inode":{"change":7,"pos":445}}},"contents":[{"Add":"let ubuntu_packages = Hashtbl.create 64"},{"Add":"let ubuntu_packages_locks = Hashtbl.create 64"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":81,"ins":{"up_context":[{"change":7,"pos":2334}],"down_context":[{"change":7,"pos":16705}],"flag":"BLOCK","start":38347,"end":38550,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2334},"to":{"change":7,"start":16588,"end":16705},"introduced_by":7}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" let lock ="},{"Add":" try Hashtbl.find ubuntu_packages_locks (index, name)"},{"Add":" with Not_found ->"},{"Add":" let lock = Lwt_mutex.create () in"},{"Add":" Hashtbl.add ubuntu_packages_locks (index, name) lock;"},{"Add":" lock"}],"del_contents":[{"Del":" let link_extra =\n List.map\n (fun (pkg, dep) -> Elpegrpc.Elpe.LinkExtra.make ~pkg ~dep ())\n link_extra\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":88,"ins":{"up_context":[{"change":7,"pos":16710}],"down_context":[{"change":7,"pos":3246}],"flag":"BLOCK","start":38551,"end":40503,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":16710},"to":{"change":7,"start":16710,"end":16799},"introduced_by":7},{"previous":"","flag":"DELETED","from":{"change":7,"pos":16799},"to":{"change":7,"start":2405,"end":2579},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2405},"to":{"change":7,"start":2405,"end":2579},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":2579},"to":{"change":4,"start":4822,"end":5909},"introduced_by":4}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" Lwt_mutex.with_lock lock (fun () ->"},{"Add":" match Hashtbl.find_opt ubuntu_packages (index, name) with"},{"Add":" | Some x -> Lwt.return x"},{"Add":" | None ->"},{"Add":" let link_extra ="},{"Add":" List.map"},{"Add":" (fun (pkg, dep) -> Elpegrpc.Elpe.LinkExtra.make ~pkg ~dep ())"},{"Add":" link_extra"},{"Add":" in"},{"Add":" let req ="},{"Add":" Elpegrpc.Elpe.UbuntuPackageRequest.make ~index ~name ~link_extra ()"},{"Add":" in"},{"Add":" let open Ocaml_protoc_plugin in"},{"Add":" let encode, decode ="},{"Add":" Service.make_client_functions Elpegrpc.Elpe.Elpe.ubuntuPackage"},{"Add":" in"},{"Add":" let enc = encode req |> Writer.contents in"},{"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":" 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":" let result ="},{"Add":" match x with Ok _ -> Ok (Option.get !result) | Error e -> Error e"},{"Add":" in"},{"Add":" Hashtbl.add ubuntu_packages (index, name) result;"},{"Add":" Lwt.return result)"}],"del_contents":[{"Del":" let req =\n Elpegrpc.Elpe.UbuntuPackageRequest.make ~index ~name ~link_extra ()\n in\n"},{"Del":" let open Ocaml_protoc_plugin in\n let encode, decode =\n Service.make_client_functions Elpegrpc.Elpe.Elpe.ubuntuPackage\n in\n let enc = encode req |> Writer.contents in\n"},{"Del":" let result = ref None in\n let* x =\n 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.server_streaming enc ~f:(fun responses ->\n Lwt_stream.iter_s\n (fun str ->\n Reader.create str |> decode |> function\n | Ok (`Ok v) ->\n result := Some v;\n Lwt.return ()\n | Ok (`Loading v) ->\n Printf.eprintf \"Downloading %s\\n\" v;\n Stdlib.flush Stdlib.stderr;\n Lwt.return ()\n | Error e ->\n failwith\n (Printf.sprintf \"Could not decode request: %s\"\n (Result.show_error e))\n | _ -> Lwt.return ())\n responses))\n ()\n in\n match x with\n | Ok _ -> Lwt.return (Ok (Option.get !result))\n | Error e -> Lwt.return (Error e)\n\ntype arch = Amd64 | Aarch64\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":136,"ins":{"up_context":[{"change":7,"pos":3247}],"down_context":[{"change":7,"pos":3287}],"flag":"BLOCK","start":40504,"end":40575,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":3247},"to":{"change":4,"start":5910,"end":5966},"introduced_by":4}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":"let ubuntu ?(release = \"plucky\") ?(platform = !Platform.target) name ="}],"del_contents":[{"Del":"let ubuntu ?(release = \"plucky\") ?(arch = Amd64) name =\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":157,"ins":{"up_context":[{"change":6,"pos":10856}],"down_context":[{"change":6,"pos":10894}],"flag":"BLOCK","start":40576,"end":40623,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":10856},"to":{"change":6,"start":10856,"end":10894},"introduced_by":6}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" match platform.arch with"}],"del_contents":[{"Del":" match arch with\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":215,"ins":{"up_context":[{"change":7,"pos":5575}],"down_context":[{"change":7,"pos":5625}],"flag":"BLOCK","start":40624,"end":40676,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":5575},"to":{"change":4,"start":5967,"end":6072},"introduced_by":4}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" Printf.printf \"%s%!\" buf"}],"del_contents":[{"Del":" Printf.printf \"%s\" buf;\n Stdlib.flush Stdlib.stdout\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":224,"ins":{"up_context":[{"change":7,"pos":5944}],"down_context":[{"change":7,"pos":5994}],"flag":"BLOCK","start":40677,"end":40730,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":5944},"to":{"change":4,"start":6073,"end":6179},"introduced_by":4}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" Printf.eprintf \"%s%!\" buf"}],"del_contents":[{"Del":" Printf.eprintf \"%s\" buf;\n Stdlib.flush Stdlib.stderr\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":364,"ins":{"up_context":[{"change":7,"pos":10411}],"down_context":[{"change":7,"pos":10449}],"flag":"BLOCK","start":40731,"end":40775,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":10411},"to":{"change":7,"start":10411,"end":10449},"introduced_by":7}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":"let http ~name ~url ~hash_algorithm ~hash ="}],"del_contents":[{"Del":"let http ~url ~hash_algorithm ~hash =\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":367,"ins":{"up_context":[{"change":7,"pos":10481}],"down_context":[{"change":7,"pos":10506}],"flag":"BLOCK","start":40776,"end":40840,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":10481},"to":{"change":7,"start":10481,"end":10506},"introduced_by":7}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" method name = \"http\" ^ if name = \"\" then \"\" else \"-\" ^ name"}],"del_contents":[{"Del":" method name = \"http\"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":407,"ins":{"up_context":[{"change":6,"pos":13973}],"down_context":[{"change":6,"pos":13989}],"flag":"BLOCK","start":40841,"end":40870,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":13973},"to":{"change":6,"start":13973,"end":13989},"introduced_by":6}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":"let unzip ?(name = \"\") pkg ="}],"del_contents":[{"Del":"let unzip pkg =\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":410,"ins":{"up_context":[{"change":6,"pos":14032}],"down_context":[{"change":6,"pos":14057}],"flag":"BLOCK","start":40871,"end":40936,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":14032},"to":{"change":6,"start":14032,"end":14057},"introduced_by":6}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" method name = \"unzip\" ^ if name = \"\" then \"\" else \"-\" ^ name"}],"del_contents":[{"Del":" method name = \"rust\"\n"}]}},{"Replacement":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":414,"ins":{"up_context":[{"change":6,"pos":14126}],"down_context":[{"change":6,"pos":14336}],"flag":"BLOCK","start":40937,"end":41006,"inode":{"change":7,"pos":445}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":14126},"to":{"change":6,"start":14126,"end":14336},"introduced_by":6}],"inode":{"change":7,"pos":445}},"ins_contents":[{"Add":" Lwt.return [ ubuntu \"coreutils\"; ubuntu \"tar\"; ubuntu \"gzip\" ]"}],"del_contents":[{"Del":" Lwt.return\n [\n (ubuntu \"libc6-dev\" :> derivation);\n (ubuntu \"coreutils\" :> derivation);\n (ubuntu \"tar\" :> derivation);\n (ubuntu \"gzip\" :> derivation);\n ]\n"}]}},{"Edit":{"inode":{"change":7,"pos":445},"path":"elpe/lib/derivation.ml","line":421,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":14511}],"down_context":[],"flag":"BLOCK","start":41007,"end":41445,"inode":{"change":7,"pos":445}}},"contents":[{"Add":""},{"Add":"let cc ="},{"Add":" object (self)"},{"Add":" inherit std_derivation"},{"Add":" method name = \"cc\""},{"Add":" method! build_inputs = Lwt.return [ ubuntu \"coreutils\"; ubuntu \"gcc\" ]"},{"Add":" method! unpack_phase = Lwt.return \"\""},{"Add":""},{"Add":" method! build_phase ="},{"Add":" let* gcc = (ubuntu \"gcc\")#build in"},{"Add":" List.iter self#add_path gcc.destdir;"},{"Add":" Lwt.return"},{"Add":" (\"mkdir -p $DESTDIR/usr/bin; ln -s \" ^ List.hd gcc.destdir"},{"Add":" ^ \"/usr/bin/gcc $DESTDIR/usr/bin/cc\")"},{"Add":" end"}]}},{"Edit":{"inode":{"change":7,"pos":64932},"path":"default.nix","line":122,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":11934}],"down_context":[{"change":7,"pos":69968}],"flag":"BLOCK","start":41446,"end":41510,"inode":{"change":7,"pos":64932}}},"contents":[{"Add":" ocamlPackages.ppx_string"},{"Add":" ocamlPackages.ppx_blob"}]}}],"owner":"pmeunier","repo":"elpe","token":"Zjr+ugQPnjJxTGHmDgV+eVL9eX1UjrrmDZHxOv6ev9o=","login":null}

…

Dependencies

Change contents