{"header":{"message":"eval-vm increment 8: host_add_path, the client-streaming effect leaf (add_path). The CWD-confined directory walk moves to Rust (readdir/lstat/read are denied prims in the VM) and client-streams prost-encoded AddPathRequest to the backend; the single DerivationReply resolves the Lwt thread (unary-shaped via the bridge). Ignore POLICY stays in OCaml (default_src_ignores/.ignore), handed to the host as a resolved pattern set; only the match runs host-side. New: prost codegen of elpegrpc.proto in demo, addpath.rs walk, grpc.rs client_streaming. Vm_prelude add_path; demo test walks eval-vm/demo/ocaml and decodes the reply.","description":null,"timestamp":"2026-08-05T05:08:00.516904748Z","authors":[{}]},"hash":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC","authors":[{"login":"pmeunier","key":"AAAAC3NzaC1lZDI1NTE5AAAAILagOJFgwaMNhBWQINinKOXmqS4Gh5NgxgriXwdOoINJ"}],"deps":{"hashes":[["GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC","eval-vm increment 8: host_add_path, the client-streaming effect leaf (add_path). The CWD-confined directory walk moves to Rust (readdir/lstat/read are denied prims in the VM) and client-streams prost-encoded AddPathRequest to the backend; the single DerivationReply resolves the Lwt thread (unary-shaped via the bridge). Ignore POLICY stays in OCaml (default_src_ignores/.ignore), handed to the host as a resolved pattern set; only the match runs host-side. New: prost codegen of elpegrpc.proto in demo, addpath.rs walk, grpc.rs client_streaming. Vm_prelude add_path; demo test walks eval-vm/demo/ocaml and decodes the reply."],["AA",null],["7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC","eval-vm: Rust host embedding a sandboxed OCaml bytecode VM (increments 1-2) — curated prim table (no IO), async host prims bridged into Lwt (Lwt.all overlaps); crates ocaml-vm-sys/-build/-vm + demo"],["6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC","eval-vm: increment 3 — first real effect leaf host_backend_call (async bytes-in/bytes-out over a real socket round-trip, bridged into Lwt; two calls overlap). Bytes marshaling both ways via caml_string_length/caml_alloc_string."],["7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC","eval-vm: increment 4 — host_read_source (local_src leaf, CWD path policy in Rust; caml_failwith bridge) + OCaml Vm_prelude packaging the effect surface & Lwt run-loop so user bytecode is clean. Multi-source bytecode compile."],["JCR3N3JHGT5S2WZQRRF623Z2TTZZJMVRZ7TZC322HBYD5STP3GUAC","eval-vm: increment 6 — the REAL Elpe protobuf layer (ocaml-protoc-generated elpegrpc.ml, pure) runs INSIDE the curated sandbox VM. A real Handshake RPC is encoded/decoded with Service.make_client_functions (the exact grpc_call_unary pattern) and round-trips against the live backend -> real PlatformReply (arch=amd64). Proves the real-DSL port is mechanical: only the transport (h2 -> host_backend_call) changes."],["W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC","eval-vm increment 7: host_backend_stream, the server-streaming effect leaf (twin of host_backend_call). Bridge carries chunk/last events (push_chunk/finish); tonic server_streaming pushes each decoded reply as a chunk and terminates at end-of-stream; Vm_prelude backend_stream feeds chunks to an Lwt callback (the grpc_call_streaming pattern) and resolves at EOS. Demo test streams a real Derivation RPC. Unblocks porting derivation.ml Derivation/UbuntuPackage."],["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","First working shell (with ocaml code)"]],"deps":["7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC","6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC","7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC","JCR3N3JHGT5S2WZQRRF623Z2TTZZJMVRZ7TZC322HBYD5STP3GUAC","W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC"],"known":[]},"hunks":[{"Edit":{"inode":{"change":8,"pos":71904},"path":"Cargo.lock","line":556,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":18305}],"down_context":[{"change":6,"pos":18305}],"flag":"BLOCK","start":0,"end":26,"inode":{"change":8,"pos":71904}}},"contents":[{"Add":{"text":" \"prost\",","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9"}},{"Add":{"text":" \"prost-build\",","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:25"}}]}},{"Edit":{"inode":{"change":2,"pos":27088},"path":"eval-vm/demo/Cargo.toml","line":17,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":14698}],"down_context":[{"change":2,"pos":27495}],"flag":"BLOCK","start":27,"end":260,"inode":{"change":2,"pos":27088}}},"contents":[{"Add":{"text":"# Encode the AddPathRequest wire messages the Rust-side directory walk","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:97"}},{"Add":{"text":"# client-streams to the backend (the walk is the effect leaf; the ignore policy","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:177"}},{"Add":{"text":"# stays in OCaml). Same prost the backend uses, so identical wire.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:244"}},{"Add":{"text":"prost = \"0.13\"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:259"}}]}},{"Edit":{"inode":{"change":2,"pos":27088},"path":"eval-vm/demo/Cargo.toml","line":24,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":27565}],"down_context":[],"flag":"BLOCK","start":261,"end":282,"inode":{"change":2,"pos":27088}}},"contents":[{"Add":{"text":"prost-build = \"0.13\"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:281"}}]}},{"Edit":{"inode":{"change":2,"pos":25468},"path":"eval-vm/demo/build.rs","line":26,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":14419}],"down_context":[{"change":3,"pos":5996}],"flag":"BLOCK","start":283,"end":308,"inode":{"change":2,"pos":25468}}},"contents":[{"Add":{"text":" \"host_add_path\",","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:307"}}]}},{"Edit":{"inode":{"change":2,"pos":25468},"path":"eval-vm/demo/build.rs","line":34,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":26383}],"down_context":[{"change":2,"pos":26383}],"flag":"BLOCK","start":309,"end":902,"inode":{"change":2,"pos":25468}}},"contents":[{"Add":{"text":" // prost-generate the Elpe wire messages so the Rust-side directory walk can","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:389"}},{"Add":{"text":" // encode AddPathRequest (the walk is the host leaf — filesystem enumeration","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:472"}},{"Add":{"text":" // is denied in the VM; the ignore *policy* stays in OCaml). Same schema as","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:552"}},{"Add":{"text":" // the backend, same wire as ocaml-protoc. We use only the message structs —","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:635"}},{"Add":{"text":" // the service travels over the generic BytesCodec.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:691"}},{"Add":{"text":" let proto = \"../../elpe/lib/elpegrpc.proto\";","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:740"}},{"Add":{"text":" prost_build::compile_protos(&[proto], &[\"../../elpe/lib\"])","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:803"}},{"Add":{"text":" .expect(\"prost compile elpegrpc.proto\");","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:852"}},{"Add":{"text":" println!(\"cargo:rerun-if-changed={proto}\");","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:900"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:901"}}]}},{"Edit":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":70,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":3374}],"down_context":[{"change":5,"pos":1908}],"flag":"BLOCK","start":903,"end":2221,"inode":{"change":2,"pos":23492}}},"contents":[{"Add":{"text":" (* CLIENT-STREAMING vertical slice: the [add_path] leaf (elpe.ml). The host","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:980"}},{"Add":{"text":" walks a CWD-confined directory and client-streams AddPathRequest to the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1057"}},{"Add":{"text":" backend; we decode the single DerivationReply. The DSL owns the ignore","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1133"}},{"Add":{"text":" policy (the pattern list = default_src_ignores) and hands it to the host,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1212"}},{"Add":{"text":" which only applies the match while enumerating. This proves the THIRD gRPC","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1292"}},{"Add":{"text":" shape (client-streaming) end-to-end; the walk itself (readdir/lstat/read)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1371"}},{"Add":{"text":" is now a host leaf, absent from the VM's primitive table. *)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1437"}},{"Add":{"text":" let _apenc, apdec = Service.make_client_functions Elpe.addPath in","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1505"}},{"Add":{"text":" let ap_result =","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1523"}},{"Add":{"text":" run","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1531"}},{"Add":{"text":" ( add_path ~root:\"eval-vm/demo/ocaml\"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1575"}},{"Add":{"text":" [ \"elpe.*.lock\"; \"*.cmi\"; \"*.cmo\"; \"*.cmx\"; \"*.o\" ]","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1637"}},{"Add":{"text":" >>= fun bytes ->","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1660"}},{"Add":{"text":" match Reader.create bytes |> apdec with","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1708"}},{"Add":{"text":" | Error e -> Lwt.return (\"decode error: \" ^ Result.show_error e)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1781"}},{"Add":{"text":" | Ok reply ->","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1803"}},{"Add":{"text":" Lwt.return","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1826"}},{"Add":{"text":" (match reply with","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1858"}},{"Add":{"text":" | `Ok r ->","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1884"}},{"Add":{"text":" \"Ok destdir=\" ^ String.concat \",\" r.DerivationResult.destdir","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:1964"}},{"Add":{"text":" | `Error _ -> \"Error reply\"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2007"}},{"Add":{"text":" | `Loading p -> \"Loading \" ^ p","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2053"}},{"Add":{"text":" | `Stdout _ | `Stderr _ -> \"unexpected chunk\"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2114"}},{"Add":{"text":" | `not_set -> \"not_set\") )","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2156"}},{"Add":{"text":" in","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2161"}},{"Add":{"text":" emit (\"add_path (client-stream) done -> \" ^ ap_result);","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2219"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2220"}}]}},{"Edit":{"inode":{"change":4,"pos":3915},"path":"eval-vm/demo/ocaml/vm_prelude.ml","line":9,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":10364}],"down_context":[{"change":6,"pos":10364}],"flag":"BLOCK","start":2222,"end":2302,"inode":{"change":4,"pos":3915}}},"contents":[{"Add":{"text":"external host_add_path : int -> string -> string -> unit = \"host_add_path\"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2301"}}]}},{"Edit":{"inode":{"change":4,"pos":3915},"path":"eval-vm/demo/ocaml/vm_prelude.ml","line":49,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":4971}],"down_context":[{"change":4,"pos":4971}],"flag":"BLOCK","start":2303,"end":2864,"inode":{"change":4,"pos":3915}}},"contents":[{"Add":{"text":"(* Async effect leaf: client-streaming AddPath. The host walks the CWD-confined","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2382"}},{"Add":{"text":" [root] and streams its contents to the backend; [ignored] is the DSL's","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2456"}},{"Add":{"text":" resolved ignore pattern set (one per line — policy stays in OCaml, the host","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2537"}},{"Add":{"text":" only applies the match). Resolves to the single DerivationReply bytes, so from","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2619"}},{"Add":{"text":" here it looks unary. This is the [add_path] leaf (elpe.ml). *)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2685"}},{"Add":{"text":"let add_path ~root ignored =","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2714"}},{"Add":{"text":" let id = fresh_id () in","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2740"}},{"Add":{"text":" let p, r = Lwt.wait () in","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2768"}},{"Add":{"text":" Hashtbl.replace tbl id (Unary r);","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2804"}},{"Add":{"text":" host_add_path id root (String.concat \"\\n\" ignored);","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2858"}},{"Add":{"text":" p","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2862"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2863"}}]}},{"Edit":{"inode":{"change":6,"pos":1},"path":"eval-vm/demo/src/grpc.rs","line":104,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":3468}],"down_context":[{"change":6,"pos":3468}],"flag":"BLOCK","start":2865,"end":4356,"inode":{"change":6,"pos":1}}},"contents":[{"Add":{"text":"/// Spawn the `add_path` effect on tokio: walk the CWD-confined `root` (applying","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:2945"}},{"Add":{"text":"/// the OCaml-resolved ignore `patterns`), client-stream the encoded","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3014"}},{"Add":{"text":"/// AddPathRequest messages to `path`, and hand the single reply back via `done`","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3095"}},{"Add":{"text":"/// (bytes, or an \"error:\" marker). The walk (blocking `std::fs`) runs on the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3173"}},{"Add":{"text":"/// worker, off the OCaml thread; from the DSL's view this resolves like a unary","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3254"}},{"Add":{"text":"/// effect (one terminating reply).","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3290"}},{"Add":{"text":"pub fn add_path(","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3307"}},{"Add":{"text":" path: String,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3325"}},{"Add":{"text":" root: String,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3343"}},{"Add":{"text":" patterns: Vec,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3370"}},{"Add":{"text":" done: impl FnOnce(Vec) + Send + 'static,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3419"}},{"Add":{"text":") {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3423"}},{"Add":{"text":" runtime().spawn(async move {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3456"}},{"Add":{"text":" let reply = match crate::addpath::collect(&root, &patterns) {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3526"}},{"Add":{"text":" Ok(messages) => client_stream(path, messages)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3584"}},{"Add":{"text":" .await","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3607"}},{"Add":{"text":" .unwrap_or_else(|e| format!(\"error:{e}\").into_bytes()),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3679"}},{"Add":{"text":" Err(e) => format!(\"error:{e}\").into_bytes(),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3736"}},{"Add":{"text":" };","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3747"}},{"Add":{"text":" done(reply);","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3768"}},{"Add":{"text":" });","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3776"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3778"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3779"}},{"Add":{"text":"async fn client_stream(path: String, messages: Vec>) -> Result, Status> {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3869"}},{"Add":{"text":" let mut grpc = tonic::client::Grpc::new(channel().clone());","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3933"}},{"Add":{"text":" grpc.ready()","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3950"}},{"Add":{"text":" .await","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:3965"}},{"Add":{"text":" .map_err(|e| Status::unavailable(format!(\"connect: {e}\")))?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4034"}},{"Add":{"text":" let path = http::uri::PathAndQuery::try_from(path)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4089"}},{"Add":{"text":" .map_err(|e| Status::internal(format!(\"bad path: {e}\")))?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4156"}},{"Add":{"text":" let outbound = tonic::codegen::tokio_stream::iter(messages);","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4221"}},{"Add":{"text":" let resp = grpc","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4241"}},{"Add":{"text":" .client_streaming(Request::new(outbound), path, BytesCodec)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4309"}},{"Add":{"text":" .await?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4326"}},{"Add":{"text":" Ok(resp.into_inner())","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4352"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4354"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4355"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":5,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":7527}],"down_context":[{"change":6,"pos":7527}],"flag":"BLOCK","start":4357,"end":4555,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"//! `host_add_path` is the client-streaming leaf: the CWD-confined directory walk","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4438"}},{"Add":{"text":"//! moves to Rust (enumeration is a denied prim in the VM) while the ignore","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4514"}},{"Add":{"text":"//! policy stays in OCaml.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4541"}},{"Add":{"text":"mod addpath;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4554"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":7537}],"down_context":[{"change":6,"pos":7537}],"flag":"BLOCK","start":4556,"end":4567,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"mod proto;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4566"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":75,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":21911}],"down_context":[{"change":4,"pos":1564}],"flag":"BLOCK","start":4568,"end":5621,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"/// `external host_add_path : int -> string -> string -> unit` — walk the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4643"}},{"Add":{"text":"/// CWD-confined directory `root`, client-streaming its contents to the backend's","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4725"}},{"Add":{"text":"/// AddPath for effect `id`; the single DerivationReply arrives later via the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4803"}},{"Add":{"text":"/// bridge (unary-shaped). `ignore` carries the OCaml-resolved ignore patterns","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4882"}},{"Add":{"text":"/// (one per line) — the DSL owns the policy, the host only applies the match","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4962"}},{"Add":{"text":"/// during enumeration.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4986"}},{"Add":{"text":"#[no_mangle]","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:4999"}},{"Add":{"text":"pub extern \"C\" fn host_add_path(id: usize, root: usize, ignore: usize) -> usize {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5081"}},{"Add":{"text":" let id = int_val(id);","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5107"}},{"Add":{"text":" let root = unsafe { CStr::from_ptr(root as *const c_char) }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5171"}},{"Add":{"text":" .to_string_lossy()","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5198"}},{"Add":{"text":" .into_owned();","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5221"}},{"Add":{"text":" let patterns: Vec = unsafe { CStr::from_ptr(ignore as *const c_char) }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5304"}},{"Add":{"text":" .to_string_lossy()","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5331"}},{"Add":{"text":" .lines()","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5348"}},{"Add":{"text":" .filter(|l| !l.is_empty())","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5383"}},{"Add":{"text":" .map(|l| l.to_owned())","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5414"}},{"Add":{"text":" .collect();","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5434"}},{"Add":{"text":" global().begin();","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5456"}},{"Add":{"text":" grpc::add_path(","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5476"}},{"Add":{"text":" \"/elpe.Elpe/AddPath\".to_string(),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5518"}},{"Add":{"text":" root,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5532"}},{"Add":{"text":" patterns,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5550"}},{"Add":{"text":" move |reply| global().complete(id, reply),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5601"}},{"Add":{"text":" );","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5608"}},{"Add":{"text":" UNIT","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5617"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5619"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5620"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":170,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":10045}],"down_context":[{"change":2,"pos":23065}],"flag":"BLOCK","start":5622,"end":5702,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"#[used]","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5629"}},{"Add":{"text":"static K8: extern \"C\" fn(usize, usize, usize) -> usize = host_add_path;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5701"}}]}},{"FileAdd":{"meta":{"basename":"addpath.rs","metadata":0},"context":[{"change":2,"pos":20854}],"contents":[{"Add":{"text":"//! The `add_path` effect leaf: a CWD-confined recursive directory walk that","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5815"}},{"Add":{"text":"//! encodes the `AddPathRequest` client-stream the backend expects. This is the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5895"}},{"Add":{"text":"//! Rust half of what `elpe.ml`'s `walk_dir_rec`/`add_path` did with `Lwt_unix`","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:5975"}},{"Add":{"text":"//! (opendir/readdir/lstat/openfile/read) — all denied primitives in the sandbox","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6058"}},{"Add":{"text":"//! VM, so the enumeration itself must live in the host. What stays in OCaml: the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6140"}},{"Add":{"text":"//! ignore *policy* (`default_src_ignores` + parsed `.ignore`), handed to us as a","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6222"}},{"Add":{"text":"//! resolved pattern set; we only apply the match here.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6278"}},{"Add":{"text":"use crate::proto::elpe::add_path_request::{Directory, File, FileContents, Request};","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6362"}},{"Add":{"text":"use crate::proto::elpe::AddPathRequest;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6402"}},{"Add":{"text":"use prost::Message;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6422"}},{"Add":{"text":"use std::os::unix::fs::PermissionsExt;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6461"}},{"Add":{"text":"use std::path::Path;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6482"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6483"}},{"Add":{"text":"const CHUNK: usize = 4096;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6510"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6511"}},{"Add":{"text":"/// Reject anything that escapes CWD, matching the `read_source` path policy (the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6593"}},{"Add":{"text":"/// bytecode may name a path but the host decides what it may read).","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6662"}},{"Add":{"text":"fn confined(root: &str) -> Result<(), String> {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6710"}},{"Add":{"text":" if root.starts_with('/') || root.split('/').any(|c| c == \"..\") {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6779"}},{"Add":{"text":" return Err(format!(","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6807"}},{"Add":{"text":" \"add_path: '{root}' is outside the project (CWD only)\"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6874"}},{"Add":{"text":" ));","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6886"}},{"Add":{"text":" }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6892"}},{"Add":{"text":" Ok(())","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6903"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6905"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6906"}},{"Add":{"text":"/// Match one gitignore pattern with a single `*` wildcard against `s`.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:6978"}},{"Add":{"text":"fn glob1(pat: &str, s: &str) -> bool {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7017"}},{"Add":{"text":" match pat.split_once('*') {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7049"}},{"Add":{"text":" Some((pre, suf)) => {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7079"}},{"Add":{"text":" s.len() >= pre.len() + suf.len() && s.starts_with(pre) && s.ends_with(suf)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7166"}},{"Add":{"text":" }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7176"}},{"Add":{"text":" None => pat == s,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7202"}},{"Add":{"text":" }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7208"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7210"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7211"}},{"Add":{"text":"/// Apply the OCaml-resolved ignore patterns (policy stays in OCaml; only the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7289"}},{"Add":{"text":"/// per-entry match runs here). Covers `default_src_ignores` (`elpe.*.lock`,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7366"}},{"Add":{"text":"/// `*.cmi`/`*.cmo`/`*.cmx`/`*.o`): a pattern matches the basename or the full","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7445"}},{"Add":{"text":"/// relative path. The full gitignore grammar in `elpe.ml` is pure OCaml and can","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7526"}},{"Add":{"text":"/// be layered on later if a project needs it.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7573"}},{"Add":{"text":"fn is_ignored(patterns: &[String], rel: &str) -> bool {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7629"}},{"Add":{"text":" let base = rel.rsplit('/').next().unwrap_or(rel);","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7683"}},{"Add":{"text":" patterns.iter().any(|p| glob1(p, base) || glob1(p, rel))","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7744"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7746"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7747"}},{"Add":{"text":"fn encode(req: AddPathRequest) -> Vec {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7791"}},{"Add":{"text":" let mut buf = Vec::with_capacity(req.encoded_len());","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7848"}},{"Add":{"text":" req.encode(&mut buf).expect(\"encode AddPathRequest\");","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7906"}},{"Add":{"text":" buf","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7914"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7916"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7917"}},{"Add":{"text":"/// Walk `root` and return the ordered, encoded `AddPathRequest` messages to","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:7994"}},{"Add":{"text":"/// client-stream: a `Directory` per (non-ignored) directory followed by its","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8071"}},{"Add":{"text":"/// contents, and a `File` + one-or-more `FileContents` chunks per regular file.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8152"}},{"Add":{"text":"/// Symlinks and other kinds are skipped (as in the OCaml walk). The walk is","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8229"}},{"Add":{"text":"/// synchronous `std::fs` — it runs on a worker off the OCaml thread.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8301"}},{"Add":{"text":"pub fn collect(root: &str, patterns: &[String]) -> Result>, String> {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8383"}},{"Add":{"text":" confined(root)?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8404"}},{"Add":{"text":" let mut out = Vec::new();","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8434"}},{"Add":{"text":" walk(Path::new(root), \"\", patterns, &mut out)?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8486"}},{"Add":{"text":" Ok(out)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8498"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8500"}},{"Add":{"text":"","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8501"}},{"Add":{"text":"fn walk(","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8510"}},{"Add":{"text":" dir: &Path,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8526"}},{"Add":{"text":" rel_prefix: &str,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8548"}},{"Add":{"text":" patterns: &[String],","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8573"}},{"Add":{"text":" out: &mut Vec>,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8601"}},{"Add":{"text":") -> Result<(), String> {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8627"}},{"Add":{"text":" let entries =","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8645"}},{"Add":{"text":" std::fs::read_dir(dir).map_err(|e| format!(\"add_path: read_dir {}: {e}\", dir.display()))?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8744"}},{"Add":{"text":" for entry in entries {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8771"}},{"Add":{"text":" let entry = entry.map_err(|e| format!(\"add_path: entry in {}: {e}\", dir.display()))?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8865"}},{"Add":{"text":" let name = entry.file_name().to_string_lossy().into_owned();","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8934"}},{"Add":{"text":" let rel = if rel_prefix.is_empty() {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:8979"}},{"Add":{"text":" name.clone()","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9004"}},{"Add":{"text":" } else {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9021"}},{"Add":{"text":" format!(\"{rel_prefix}/{name}\")","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9064"}},{"Add":{"text":" };","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9075"}},{"Add":{"text":" // file_type() comes from the dir entry (lstat, no symlink follow).","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9151"}},{"Add":{"text":" let ft = entry","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9174"}},{"Add":{"text":" .file_type()","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9199"}},{"Add":{"text":" .map_err(|e| format!(\"add_path: file_type {rel}: {e}\"))?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9269"}},{"Add":{"text":" let perms = |p: &Path| -> i32 {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9309"}},{"Add":{"text":" std::fs::metadata(p)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9342"}},{"Add":{"text":" .map(|m| (m.permissions().mode() & 0o7777) as i32)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9409"}},{"Add":{"text":" .unwrap_or(0o644)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9443"}},{"Add":{"text":" };","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9454"}},{"Add":{"text":" if ft.is_dir() {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9479"}},{"Add":{"text":" if is_ignored(patterns, &rel) {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9523"}},{"Add":{"text":" continue;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9549"}},{"Add":{"text":" }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9563"}},{"Add":{"text":" out.push(encode(AddPathRequest {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9608"}},{"Add":{"text":" request: Some(Request::Directory(Directory {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9669"}},{"Add":{"text":" name: rel.clone(),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9708"}},{"Add":{"text":" permissions: perms(&entry.path()),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9763"}},{"Add":{"text":" })),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9784"}},{"Add":{"text":" }));","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9801"}},{"Add":{"text":" walk(&entry.path(), &rel, patterns, out)?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9856"}},{"Add":{"text":" } else if ft.is_file() {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9889"}},{"Add":{"text":" if is_ignored(patterns, &rel) {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9933"}},{"Add":{"text":" continue;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9959"}},{"Add":{"text":" }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:9973"}},{"Add":{"text":" let path = entry.path();","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10010"}},{"Add":{"text":" let bytes = std::fs::read(&path).map_err(|e| format!(\"add_path: read {rel}: {e}\"))?;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10107"}},{"Add":{"text":" out.push(encode(AddPathRequest {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10152"}},{"Add":{"text":" request: Some(Request::File(File {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10203"}},{"Add":{"text":" name: rel.clone(),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10242"}},{"Add":{"text":" length: bytes.len() as i64,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10290"}},{"Add":{"text":" permissions: perms(&path),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10337"}},{"Add":{"text":" })),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10358"}},{"Add":{"text":" }));","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10375"}},{"Add":{"text":" let mut start = 0i64;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10409"}},{"Add":{"text":" for chunk in bytes.chunks(CHUNK) {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10456"}},{"Add":{"text":" out.push(encode(AddPathRequest {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10505"}},{"Add":{"text":" request: Some(Request::Contents(FileContents {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10572"}},{"Add":{"text":" start,","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10603"}},{"Add":{"text":" content: chunk.to_vec(),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10652"}},{"Add":{"text":" })),","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10677"}},{"Add":{"text":" }));","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10698"}},{"Add":{"text":" start += chunk.len() as i64;","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10743"}},{"Add":{"text":" }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10757"}},{"Add":{"text":" }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10767"}},{"Add":{"text":" // other kinds (symlinks, sockets, ...) are skipped, as in elpe.ml.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10843"}},{"Add":{"text":" }","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10849"}},{"Add":{"text":" Ok(())","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10860"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10862"}}]}},{"FileAdd":{"meta":{"basename":"proto.rs","metadata":0},"context":[{"change":2,"pos":20854}],"contents":[{"Add":{"text":"//! prost-generated Elpe wire messages (structs only; the service travels over","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:10976"}},{"Add":{"text":"//! the generic `BytesCodec`). We use these ONLY to encode the `AddPathRequest`","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11056"}},{"Add":{"text":"//! messages the Rust-side directory walk client-streams to the backend. The","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11133"}},{"Add":{"text":"//! walk is the effect leaf — filesystem enumeration (`readdir`/`lstat`/`read`)","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11215"}},{"Add":{"text":"//! is a denied primitive in the sandbox VM — while the ignore *policy* stays in","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11298"}},{"Add":{"text":"//! OCaml and is handed to us already resolved. Same `.proto`, same wire as the","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11378"}},{"Add":{"text":"//! ocaml-protoc types that run inside the VM.","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11425"}},{"Add":{"text":"pub mod elpe {","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11440"}},{"Add":{"text":" include!(concat!(env!(\"OUT_DIR\"), \"/elpe.rs\"));","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11492"}},{"Add":{"text":"}","pos":"GCBZLA6JBPK4FMG55WKTAXVGBLZDSKQIFDTN3R2EHSVIGQZZ7L5AC:11494"}}]}}],"owner":"pmeunier","repo":"elpe","token":"3PBQ5RfQqq5OsEAjVCvcD5bRAyIaJpJwDKaA7uOhw4Q=","login":null}

…

Dependencies

Change contents

Review