{"header":{"message":"Forwarding stdout/stderr","description":null,"timestamp":"2025-06-15T08:41:23.213906919Z","authors":[{}]},"hash":"BQ4E3XLAVS2AQAUYRGN6SZ4J35KQ2KIH7BBT2JNZXSPKKCGX7DYAC","authors":[{"login":"pmeunier","key":"FZQ2g7VfnzLYM4mtTVDk9HAZjA8Jk9ndkwN1icgbtWUr"}],"deps":{"hashes":[["BQ4E3XLAVS2AQAUYRGN6SZ4J35KQ2KIH7BBT2JNZXSPKKCGX7DYAC","Forwarding stdout/stderr"],["AA",null],["KOWYPLMX4TCQANL33QW5VQTKWBQVCMOVLBQUQCTOK6YVQUHZJR5QC","Nix and config.toml"],["HX4TXY2DTPEEQPU6CMHSD3X4VX7A4OKV7N3HT3QZKSNHNAZOK7GQC","Fixed-output derivations enable the network"],["6MGFBMON6ASGBRQJXY6VUGGZQHXPQSMQJZOOD5LKS2FZODB6ET7AC","Debug and cleanup"],["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","First working shell (with ocaml code)"],["SI454P2VFO6Y6RO2NIOH6ZROURP3OTB2BBXH2F36KJT6YML6YBIAC","Documentation and cleanup"],["ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","Adding the OCaml interface"]],"deps":["KOWYPLMX4TCQANL33QW5VQTKWBQVCMOVLBQUQCTOK6YVQUHZJR5QC","HX4TXY2DTPEEQPU6CMHSD3X4VX7A4OKV7N3HT3QZKSNHNAZOK7GQC"],"known":["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","ODUDDQRY373JMDR6W2BHUWSKEU6TEICQMNZIAIFKJPNUA5UN3C4QC","SI454P2VFO6Y6RO2NIOH6ZROURP3OTB2BBXH2F36KJT6YML6YBIAC","6MGFBMON6ASGBRQJXY6VUGGZQHXPQSMQJZOOD5LKS2FZODB6ET7AC"]},"hunks":[{"Edit":{"inode":{"change":4,"pos":1363},"path":"src/main.rs","line":8,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1587}],"down_context":[{"change":4,"pos":1587}],"flag":"BLOCK","start":0,"end":44,"inode":{"change":4,"pos":1363}}},"contents":[{"Add":"use tokio_stream::wrappers::ReceiverStream;"}]}},{"Replacement":{"inode":{"change":4,"pos":1363},"path":"src/main.rs","line":21,"ins":{"up_context":[{"change":4,"pos":1752}],"down_context":[{"change":4,"pos":1815}],"flag":"BLOCK","start":45,"end":103,"inode":{"change":4,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1752},"to":{"change":4,"start":1752,"end":1815},"introduced_by":4}],"inode":{"change":4,"pos":1363}},"ins_contents":[{"Add":" tokio::sync::mpsc::Sender,"}],"del_contents":[{"Del":" tokio::sync::oneshot::Sender>,\n"}]}},{"Edit":{"inode":{"change":4,"pos":1363},"path":"src/main.rs","line":24,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1696}],"down_context":[{"change":4,"pos":1711}],"flag":"BLOCK","start":104,"end":248,"inode":{"change":4,"pos":1363}}},"contents":[{"Add":""},{"Add":"use std::pin::Pin;"},{"Add":""},{"Add":"type ResponseStream ="},{"Add":" Pin> + Send>>;"}]}},{"Edit":{"inode":{"change":4,"pos":1363},"path":"src/main.rs","line":92,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":4356}],"down_context":[{"change":4,"pos":4356}],"flag":"BLOCK","start":249,"end":294,"inode":{"change":4,"pos":1363}}},"contents":[{"Add":""},{"Add":" type DerivationStream = ResponseStream;"}]}},{"Replacement":{"inode":{"change":4,"pos":1363},"path":"src/main.rs","line":98,"ins":{"up_context":[{"change":4,"pos":4456}],"down_context":[{"change":4,"pos":4530}],"flag":"BLOCK","start":295,"end":361,"inode":{"change":4,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4456},"to":{"change":4,"start":4456,"end":4530},"introduced_by":4}],"inode":{"change":4,"pos":1363}},"ins_contents":[{"Add":" ) -> Result, tonic::Status> {"}],"del_contents":[{"Del":" ) -> Result, tonic::Status> {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":1363},"path":"src/main.rs","line":101,"ins":{"up_context":[{"change":4,"pos":4606}],"down_context":[{"change":4,"pos":4662}],"flag":"BLOCK","start":362,"end":418,"inode":{"change":4,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4606},"to":{"change":4,"start":4606,"end":4662},"introduced_by":4}],"inode":{"change":4,"pos":1363}},"ins_contents":[{"Add":" let (tx, rx) = tokio::sync::mpsc::channel(200);"}],"del_contents":[{"Del":" let (tx, rx) = tokio::sync::oneshot::channel();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":1363},"path":"src/main.rs","line":114,"ins":{"up_context":[{"change":4,"pos":4975}],"down_context":[{"change":4,"pos":2198}],"flag":"BLOCK","start":419,"end":1519,"inode":{"change":4,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4975},"to":{"change":4,"start":4975,"end":5566},"introduced_by":4}],"inode":{"change":4,"pos":1363}},"ins_contents":[{"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: vec![out.to_str().unwrap().to_string()],"},{"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":" Ok(tonic::Response::new(Box::pin(output_stream)))"}],"del_contents":[{"Del":" Ok(tonic::Response::new(match rx.await.unwrap() {\n Ok(out) => proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Ok(\n proto::DerivationResult {\n destdir: vec![out.to_str().unwrap().to_string()],\n paths: Vec::new(),\n path_patterns: Vec::new(),\n },\n )),\n },\n Err(e) => proto::DerivationReply {\n result: Some(proto::derivation_reply::Result::Error(e)),\n },\n }))\n"}]}},{"Replacement":{"inode":{"change":4,"pos":1363},"path":"src/main.rs","line":243,"ins":{"up_context":[{"change":4,"pos":7219}],"down_context":[{"change":4,"pos":7286}],"flag":"BLOCK","start":1520,"end":1582,"inode":{"change":4,"pos":1363}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":7219},"to":{"change":4,"start":7219,"end":7286},"introduced_by":4}],"inode":{"change":4,"pos":1363}},"ins_contents":[{"Add":" tokio::sync::mpsc::Sender,"}],"del_contents":[{"Del":" tokio::sync::oneshot::Sender>,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":10326},"path":"src/lib.rs","line":102,"ins":{"up_context":[{"change":4,"pos":10235}],"down_context":[{"change":4,"pos":10287}],"flag":"BLOCK","start":1583,"end":1668,"inode":{"change":4,"pos":10326}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":10235},"to":{"change":4,"start":10235,"end":10287},"introduced_by":4}],"inode":{"change":4,"pos":10326}},"ins_contents":[{"Add":" in_release: Arc, Arc>>>,"}],"del_contents":[{"Del":" in_release: Arc>>>,\n"}]}},{"Edit":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":5,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":44835}],"down_context":[{"change":4,"pos":44835}],"flag":"BLOCK","start":1669,"end":1704,"inode":{"change":4,"pos":44692}}},"contents":[{"Add":"use std::os::fd::{AsRawFd, RawFd};"}]}},{"Edit":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":9,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":44926}],"down_context":[{"change":4,"pos":44926}],"flag":"BLOCK","start":1705,"end":1734,"inode":{"change":4,"pos":44692}}},"contents":[{"Add":"use tokio::io::AsyncReadExt;"}]}},{"Edit":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":31,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":45327}],"down_context":[{"change":4,"pos":45327}],"flag":"BLOCK","start":1735,"end":2054,"inode":{"change":4,"pos":44692}}},"contents":[{"Add":"}"},{"Add":""},{"Add":"/// The type of messages received from a contained process."},{"Add":"#[derive(bincode::Encode, bincode::Decode, Debug)]"},{"Add":"pub enum Msg {"},{"Add":" /// Success, with the result path."},{"Add":" Ok(PathBuf),"},{"Add":" /// Error."},{"Add":" Error(String),"},{"Add":" /// One chunk of stdout."},{"Add":" Stdout(Vec),"},{"Add":" /// One chunk of stderr."},{"Add":" Stderr(Vec),"}]}},{"Replacement":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":51,"ins":{"up_context":[{"change":4,"pos":45526}],"down_context":[{"change":4,"pos":45589}],"flag":"BLOCK","start":2055,"end":2095,"inode":{"change":4,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":45526},"to":{"change":4,"start":45526,"end":45589},"introduced_by":4}],"inode":{"change":4,"pos":44692}},"ins_contents":[{"Add":" tokio::sync::mpsc::Sender,"}],"del_contents":[{"Del":" tokio::sync::oneshot::Sender>,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":81,"ins":{"up_context":[{"change":4,"pos":46770}],"down_context":[{"change":4,"pos":47023}],"flag":"BLOCK","start":2096,"end":2686,"inode":{"change":4,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":46770},"to":{"change":4,"start":46770,"end":47023},"introduced_by":4}],"inode":{"change":4,"pos":44692}},"ins_contents":[{"Add":" let ((id, resp), _) = bincode::decode_from_slice::<(u64, Msg), _>(&msg, bincode::config::standard()).unwrap();"},{"Add":" match resp {"},{"Add":" Msg::Ok(_) | Msg::Error(_) => {"},{"Add":" let chan = pending.remove(&id).unwrap();"},{"Add":" chan.send(resp).await.unwrap_or(());"},{"Add":" }"},{"Add":" _ => {"},{"Add":" let chan = pending.get(&id).unwrap();"},{"Add":" chan.send(resp).await.unwrap_or(());"},{"Add":" }"},{"Add":" }"}],"del_contents":[{"Del":" let ((id, resp), _) = bincode::decode_from_slice::<(u64, ProcessResult), _>(&msg, bincode::config::standard()).unwrap();\n let chan = pending.remove(&id).unwrap();\n chan.send(resp).unwrap_or(());\n"}]}},{"Edit":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":99,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":47143},"to":{"change":4,"start":47143,"end":47190},"introduced_by":4}],"inode":{"change":4,"pos":44692}}},"contents":[{"Del":"\ntype ProcessResult = Result;\n"}]}},{"Edit":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":151,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":49250}],"down_context":[{"change":4,"pos":49250}],"flag":"BLOCK","start":2687,"end":2863,"inode":{"change":4,"pos":44692}}},"contents":[{"Add":" let (writer_out, mut reader_out) = tokio::net::unix::pipe::pipe().unwrap();"},{"Add":" let (writer_err, mut reader_err) = tokio::net::unix::pipe::pipe().unwrap();"}]}},{"Replacement":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":154,"ins":{"up_context":[{"change":4,"pos":49288}],"down_context":[{"change":4,"pos":49574}],"flag":"BLOCK","start":2864,"end":6054,"inode":{"change":4,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":49288},"to":{"change":4,"start":49288,"end":49574},"introduced_by":4}],"inode":{"change":4,"pos":44692}},"ins_contents":[{"Add":" let task = tokio::task::spawn_blocking(move || {"},{"Add":" run_in_container("},{"Add":" &user,"},{"Add":" &store,"},{"Add":" rec_msg,"},{"Add":" writer_out.as_raw_fd(),"},{"Add":" writer_err.as_raw_fd(),"},{"Add":" )"},{"Add":" .map_err(|e| format!(\"{:?}\", e))"},{"Add":" });"},{"Add":" tokio::pin!(task);"},{"Add":""},{"Add":" let mut result = None;"},{"Add":" let mut stdout_closed = false;"},{"Add":" let mut stderr_closed = false;"},{"Add":" let mut out_buf = [0; 4096];"},{"Add":" let mut err_buf = [0; 4096];"},{"Add":" while result.is_none() || !stdout_closed || !stderr_closed {"},{"Add":" tokio::select! {"},{"Add":" r = &mut task, if result.is_none() => {"},{"Add":" result = Some(match r {"},{"Add":" Ok(Ok(r)) => Msg::Ok(r),"},{"Add":" Ok(Err(r)) => Msg::Error(r),"},{"Add":" Err(e) => Msg::Error(format!(\"{:?}\", e)),"},{"Add":" });"},{"Add":" }"},{"Add":" r = reader_out.read(&mut out_buf), if !stdout_closed => {"},{"Add":" if let Ok(result) = r {"},{"Add":" if result == 0 {"},{"Add":" stdout_closed = true"},{"Add":" } else {"},{"Add":" println!(\"stdout: {:?}\", std::str::from_utf8(&out_buf[..result]));"},{"Add":" let v = bincode::encode_to_vec(&(id, Msg::Stdout((&out_buf[..result]).to_vec())), bincode::config::standard()).unwrap();"},{"Add":" let mut bytes = bytes::BytesMut::new();"},{"Add":" debug!(\"drv_process replying {:?}\", v.len());"},{"Add":" bytes.extend_from_slice(&v);"},{"Add":" writer.lock().await.send(bytes.into()).await.unwrap();"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" r = reader_err.read(&mut err_buf), if !stderr_closed => {"},{"Add":" if let Ok(result) = r {"},{"Add":" if result == 0 {"},{"Add":" stderr_closed = true"},{"Add":" } else {"},{"Add":" println!(\"stderr: {:?}\", std::str::from_utf8(&err_buf[..result]));"},{"Add":" let v = bincode::encode_to_vec(&(id, Msg::Stderr((&err_buf[..result]).to_vec())), bincode::config::standard()).unwrap();"},{"Add":" let mut bytes = bytes::BytesMut::new();"},{"Add":" debug!(\"drv_process replying {:?}\", v.len());"},{"Add":" bytes.extend_from_slice(&v);"},{"Add":" writer.lock().await.send(bytes.into()).await.unwrap();"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" let v = bincode::encode_to_vec(&(id, result.unwrap()), bincode::config::standard())"},{"Add":" .unwrap();"}],"del_contents":[{"Del":" let result: ProcessResult =\n run_in_container(&user, &store, rec_msg).map_err(|e| format!(\"{:?}\", e));\n debug!(\"result {:?}\", result);\n let v = bincode::encode_to_vec(&(id, result), bincode::config::standard()).unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":215,"ins":{"up_context":[{"change":4,"pos":49737}],"down_context":[{"change":4,"pos":49807}],"flag":"BLOCK","start":6055,"end":6126,"inode":{"change":4,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":49737},"to":{"change":4,"start":49737,"end":49807},"introduced_by":4}],"inode":{"change":4,"pos":44692}},"ins_contents":[{"Add":" writer.lock().await.send(bytes.into()).await.unwrap();"}],"del_contents":[{"Del":" writer.lock().await.send(bytes.into()).await.unwrap()\n"}]}},{"Replacement":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":222,"ins":{"up_context":[{"change":4,"pos":49875}],"down_context":[{"change":4,"pos":49966}],"flag":"BLOCK","start":6127,"end":6271,"inode":{"change":4,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":49875},"to":{"change":4,"start":49875,"end":49966},"introduced_by":4}],"inode":{"change":4,"pos":44692}},"ins_contents":[{"Add":"fn run_in_container("},{"Add":" user: &str,"},{"Add":" store: &Path,"},{"Add":" r: BuildRequest,"},{"Add":" stdout: RawFd,"},{"Add":" stderr: RawFd,"},{"Add":") -> Result {"}],"del_contents":[{"Del":"fn run_in_container(user: &str, store: &Path, r: BuildRequest) -> Result {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":301,"ins":{"up_context":[{"change":4,"pos":52093}],"down_context":[{"change":4,"pos":52204}],"flag":"BLOCK","start":6272,"end":6399,"inode":{"change":4,"pos":44692}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":52093},"to":{"change":4,"start":9347,"end":9427},"introduced_by":4}],"inode":{"change":4,"pos":44692}},"ins_contents":[{"Add":" inner_process("},{"Add":" user, &r, &tmp_dir, &dest, &store, &tmp_store, &name, stdout, stderr,"},{"Add":" )"}],"del_contents":[{"Del":" inner_process(user, &r, &tmp_dir, &dest, &store, &tmp_store, &name)\n"}]}},{"Edit":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":465,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":57164}],"down_context":[{"change":4,"pos":57164}],"flag":"BLOCK","start":6400,"end":6438,"inode":{"change":4,"pos":44692}}},"contents":[{"Add":" stdout: RawFd,"},{"Add":" stderr: RawFd,"}]}},{"Edit":{"inode":{"change":4,"pos":44692},"path":"src/container.rs","line":568,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":60960}],"down_context":[{"change":4,"pos":60960}],"flag":"BLOCK","start":6439,"end":6536,"inode":{"change":4,"pos":44692}}},"contents":[{"Add":" unsafe {"},{"Add":" libc::dup2(stdout, 1);"},{"Add":" libc::dup2(stderr, 2);"},{"Add":" }"}]}},{"Edit":{"inode":{"change":4,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":50,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":63852}],"down_context":[{"change":4,"pos":63852}],"flag":"BLOCK","start":6537,"end":6581,"inode":{"change":4,"pos":55490}}},"contents":[{"Add":" bytes stdout = 3;"},{"Add":" bytes stderr = 4;"}]}},{"Replacement":{"inode":{"change":4,"pos":55490},"path":"elpe/lib/elpegrpc.proto","line":73,"ins":{"up_context":[{"change":4,"pos":55921}],"down_context":[{"change":4,"pos":63895}],"flag":"BLOCK","start":6582,"end":6653,"inode":{"change":4,"pos":55490}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":55921},"to":{"change":4,"start":55921,"end":55985},"introduced_by":4}],"inode":{"change":4,"pos":55490}},"ins_contents":[{"Add":" rpc Derivation (DerivationRequest) returns (stream DerivationReply);"}],"del_contents":[{"Del":" rpc Derivation (DerivationRequest) returns (DerivationReply);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":56160},"path":"elpe/lib/elpe.ml","line":71,"ins":{"up_context":[{"change":4,"pos":64918}],"down_context":[{"change":4,"pos":58003}],"flag":"BLOCK","start":6654,"end":6743,"inode":{"change":4,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":64918},"to":{"change":4,"start":64918,"end":64971},"introduced_by":4}],"inode":{"change":4,"pos":56160}},"ins_contents":[{"Add":" let result = ref None in"},{"Add":" let* _ = Client.call ~service:\"elpe.Elpe\" ~rpc:\"Derivation\""}],"del_contents":[{"Del":" Client.call ~service:\"elpe.Elpe\" ~rpc:\"Derivation\"\n"}]}},{"Replacement":{"inode":{"change":4,"pos":56160},"path":"elpe/lib/elpe.ml","line":77,"ins":{"up_context":[{"change":4,"pos":58134}],"down_context":[{"change":4,"pos":58365}],"flag":"BLOCK","start":6744,"end":7380,"inode":{"change":4,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":58134},"to":{"change":4,"start":58134,"end":58365},"introduced_by":4}],"inode":{"change":4,"pos":56160}},"ins_contents":[{"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 path) -> (result := Some(`Ok path); Lwt.return ())"},{"Add":" | Ok (`Error path) -> (result := Some(`Error path); Lwt.return ())"},{"Add":" | Ok (`Stdout buf) -> ("},{"Add":" let buf = Bytes.unsafe_to_string buf in"},{"Add":" Printf.printf \"%s\" buf; Lwt.return ())"},{"Add":" | Ok (`Stderr buf) -> ("},{"Add":" let buf = Bytes.unsafe_to_string buf in"},{"Add":" Printf.eprintf \"%s\" buf; Lwt.return ())"}],"del_contents":[{"Del":" (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"}]}},{"Replacement":{"inode":{"change":4,"pos":56160},"path":"elpe/lib/elpe.ml","line":92,"ins":{"up_context":[{"change":4,"pos":58489}],"down_context":[{"change":4,"pos":58600}],"flag":"BLOCK","start":7381,"end":7594,"inode":{"change":4,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":58489},"to":{"change":4,"start":58489,"end":58600},"introduced_by":4}],"inode":{"change":4,"pos":56160}},"ins_contents":[{"Add":" (Result.show_error e))"},{"Add":" | _ -> Lwt.return ())"},{"Add":" responses"},{"Add":" ))"},{"Add":" ()"},{"Add":" in"},{"Add":" match !result with"},{"Add":" Some v -> Lwt.return v"},{"Add":" | None -> assert false"}],"del_contents":[{"Del":" (Result.show_error e)))\n | None -> Elpe.Derivation.Response.make ()))\n ()\n"}]}},{"Replacement":{"inode":{"change":4,"pos":56160},"path":"elpe/lib/elpe.ml","line":355,"ins":{"up_context":[{"change":3,"pos":968}],"down_context":[{"change":3,"pos":985}],"flag":"BLOCK","start":7595,"end":7610,"inode":{"change":4,"pos":56160}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":968},"to":{"change":3,"start":968,"end":985},"introduced_by":3}],"inode":{"change":4,"pos":56160}},"ins_contents":[{"Add":" let* r ="}],"del_contents":[{"Del":" let* res =\n"}]}},{"Replacement":{"inode":{"change":4,"pos":56160},"path":"elpe/lib/elpe.ml","line":359,"ins":{"up_context":[{"change":3,"pos":1103}],"down_context":[{"change":4,"pos":72562}],"flag":"BLOCK","start":7611,"end":7630,"inode":{"change":4,"pos":56160}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":1103},"to":{"change":4,"start":72501,"end":72562},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":72501},"to":{"change":4,"start":72501,"end":72562},"introduced_by":4}],"inode":{"change":4,"pos":56160}},"ins_contents":[{"Add":" match r with"}],"del_contents":[{"Del":" let res, _ = Result.get_ok res in\n match res with\n"}]}},{"Edit":{"inode":{"change":4,"pos":71016},"path":"Cargo.toml","line":51,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":9564}],"down_context":[{"change":4,"pos":71823}],"flag":"BLOCK","start":7631,"end":7655,"inode":{"change":4,"pos":71016}}},"contents":[{"Add":"tokio-stream = \"0.1.17\""}]}},{"Edit":{"inode":{"change":2,"pos":3315},"path":"Cargo.nix","line":1445,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":48208}],"down_context":[{"change":2,"pos":48208}],"flag":"BLOCK","start":7656,"end":7755,"inode":{"change":2,"pos":3315}}},"contents":[{"Add":" }"},{"Add":" {"},{"Add":" name = \"tokio-stream\";"},{"Add":" packageId = \"tokio-stream\";"}]}},{"Replacement":{"inode":{"change":2,"pos":3315},"path":"Cargo.nix","line":6519,"ins":{"up_context":[{"change":2,"pos":226526}],"down_context":[{"change":2,"pos":226571}],"flag":"BLOCK","start":7756,"end":7818,"inode":{"change":2,"pos":3315}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":226526},"to":{"change":2,"start":226526,"end":226571},"introduced_by":2}],"inode":{"change":2,"pos":3315}},"ins_contents":[{"Add":" resolvedDefaultFeatures = [ \"default\" \"net\" \"time\" ];"}],"del_contents":[{"Del":" resolvedDefaultFeatures = [ \"net\" ];\n"}]}},{"Edit":{"inode":{"change":4,"pos":71904},"path":"Cargo.lock","line":477,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":82419}],"down_context":[{"change":4,"pos":82419}],"flag":"BLOCK","start":7819,"end":7836,"inode":{"change":4,"pos":71904}}},"contents":[{"Add":" \"tokio-stream\","}]}}],"owner":"pmeunier","repo":"elpe","token":"1k1YgnBa6Rc3xu4THWy+htxrcaR8X4FSxrwLV8Ohxu8=","login":null}

…

Dependencies

Change contents