{"header":{"message":"started work on executors","description":null,"timestamp":"2021-01-17T14:19:13.837397248Z","authors":[{"email":"3611916+oreganoli@users.noreply.github.com","full_name":"oreganoli","name":"oreganoli"}]},"hash":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC","authors":[],"deps":{"hashes":[["TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC","started work on executors"],["AA",null],["H5IHJUKQYZNZZ4FMUCOAPH4XCALZ7TSUYFIVMYBOI2MBRV4GVUVQC","added trace to handle_invocation in core"],["NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC","created an Envelope abstraction and started work on the Wasm executor pool"],["6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC","gateway now parses HTTP requests into invocations"],["WXLXWHPVYBBSZ76TUABERVLQAN26QTZLF6NGZZMB56FUTCLPSB4QC","wrote an abstraction over client/server threads"],["AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC","work on communicating with core"],["WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC","Hyper hello world is up"],["BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC","wrote rudimentary hello-world core"],["QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC","gateway now sees incoming IP addresses"],["Q5GUHJ4O6GNSL23U77Y3HR2WW7V3LTYVHXPKOMJY76JKIZUU5YWQC","initial commit, readme"],["KZMW4JDYUYSQHRZMLNL7EOVWYJWOI7L573QAL3KUMMMG6IWKBS6AC","Created zhur_common crate with reexports"],["DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC","moved Hyper server code out to lib.rs"]],"deps":["H5IHJUKQYZNZZ4FMUCOAPH4XCALZ7TSUYFIVMYBOI2MBRV4GVUVQC","NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC"],"known":["Q5GUHJ4O6GNSL23U77Y3HR2WW7V3LTYVHXPKOMJY76JKIZUU5YWQC","KZMW4JDYUYSQHRZMLNL7EOVWYJWOI7L573QAL3KUMMMG6IWKBS6AC","WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC","DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC","QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC","6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC","WXLXWHPVYBBSZ76TUABERVLQAN26QTZLF6NGZZMB56FUTCLPSB4QC","AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC","BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC"]},"hunks":[{"FileDel":{"deleted_names":[{"basename":"README.md","metadata":511},{"basename":"README.md","metadata":420}],"path":"zhur_invk/README.md","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":3,"start":28,"end":39},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":39},"to":{"change":4,"start":3974,"end":3974},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":4,"start":3962,"end":3973},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":3973},"to":{"change":4,"start":3974,"end":3974},"introduced_by":4}],"inode":{"change":4,"pos":3974}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3974},"to":{"change":4,"start":3975,"end":4032},"introduced_by":4}],"inode":{"change":4,"pos":3974}},"content":[{"Del":{"text":"# zhur_invk","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3986"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3987"}},{"Del":{"text":"Types common to `zhur_core` and `zhur_gate`.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4032"}}]}},{"FileDel":{"deleted_names":[{"basename":"Cargo.toml","metadata":511},{"basename":"Cargo.toml","metadata":436}],"path":"zhur_invk/Cargo.toml","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":3,"start":40,"end":52},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":52},"to":{"change":4,"start":4046,"end":4046},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":4,"start":4033,"end":4045},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":4045},"to":{"change":4,"start":4046,"end":4046},"introduced_by":4}],"inode":{"change":4,"pos":4046}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4046},"to":{"change":4,"start":4047,"end":4390},"introduced_by":4}],"inode":{"change":4,"pos":4046}},"content":[{"Del":{"text":"[package]","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4056"}},{"Del":{"text":"name = \"zhur_invk\"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4075"}},{"Del":{"text":"version = \"0.1.0\"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4093"}},{"Del":{"text":"authors = [\"oreganoli <3611916+oreganoli@users.noreply.github.com>\"]","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4162"}},{"Del":{"text":"edition = \"2018\"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4179"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4180"}},{"Del":{"text":"# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4277"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4278"}},{"Del":{"text":"[dependencies]","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4293"}},{"Del":{"text":"zhur_common = { path = \"../zhur_common\" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4335"}},{"Del":{"text":"serde = { version = \"1.0.118\", features = [\"derive\"] }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4390"}}]}},{"FileDel":{"deleted_names":[{"basename":"lib.rs","metadata":511},{"basename":"lib.rs","metadata":436}],"path":"zhur_invk/src/lib.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":0,"end":8},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":8},"to":{"change":4,"start":29,"end":29},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":20,"end":28},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":28},"to":{"change":4,"start":29,"end":29},"introduced_by":4}],"inode":{"change":4,"pos":29}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":29},"to":{"change":4,"start":30,"end":209},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":209},"to":{"change":4,"start":0,"end":48},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":48},"to":{"change":4,"start":250,"end":474},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":250},"to":{"change":4,"start":250,"end":474},"introduced_by":4}],"inode":{"change":4,"pos":29}},"content":[{"Del":{"text":"use zhur_common::*;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:49"}},{"Del":{"text":"use serde::{Deserialize, Serialize};","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:86"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:87"}},{"Del":{"text":"pub mod err;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:100"}},{"Del":{"text":"pub use err::InvocationError;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:130"}},{"Del":{"text":"pub mod http;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:144"}},{"Del":{"text":"pub use http::*;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:161"}},{"Del":{"text":"/// Struct representing a Zhur app invocation.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:208"}},{"Del":{"text":"#[derive(Clone, Deserialize, Serialize, Debug)]","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:47"}},{"Del":{"text":"pub struct Invocation {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:273"}},{"Del":{"text":" /// The name of the user/org to whom the app belongs.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:331"}},{"Del":{"text":" pub owner: String,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:354"}},{"Del":{"text":" /// The name of the app itself.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:390"}},{"Del":{"text":" pub app_name: String,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:416"}},{"Del":{"text":" /// The input for the app.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:447"}},{"Del":{"text":" pub payload: Vec","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:472"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:474"}}]}},{"FileDel":{"deleted_names":[{"basename":"http.rs","metadata":511},{"basename":"http.rs","metadata":420}],"path":"zhur_invk/src/http.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":9,"end":18},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":18},"to":{"change":4,"start":485,"end":485},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":475,"end":484},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":484},"to":{"change":4,"start":485,"end":485},"introduced_by":4}],"inode":{"change":4,"pos":485}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":485},"to":{"change":4,"start":486,"end":1212},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1212},"to":{"change":4,"start":49,"end":97},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":97},"to":{"change":4,"start":1253,"end":1928},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1253},"to":{"change":4,"start":1253,"end":1928},"introduced_by":4}],"inode":{"change":4,"pos":485}},"content":[{"Del":{"text":"use serde::{Deserialize, Serialize};","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:522"}},{"Del":{"text":"use std::collections::BTreeMap;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:554"}},{"Del":{"text":"#[derive(Debug, Deserialize, Serialize)]","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:595"}},{"Del":{"text":"/// A Serde-friendly representation of a HTTP request.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:650"}},{"Del":{"text":"pub struct HttpReq {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:671"}},{"Del":{"text":" /// The method of the request.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:706"}},{"Del":{"text":" pub method: String,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:730"}},{"Del":{"text":" /// The path of the request.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:763"}},{"Del":{"text":" pub path: String,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:785"}},{"Del":{"text":" /// Headers represented as pairs of `String`s.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:836"}},{"Del":{"text":" pub headers: BTreeMap,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:879"}},{"Del":{"text":" /// Query strings represented as pairs of `String`s.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:936"}},{"Del":{"text":" pub query_params: BTreeMap,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:984"}},{"Del":{"text":" /// Cookies represented as pairs of `String`s.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1035"}},{"Del":{"text":" pub cookies: BTreeMap,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1078"}},{"Del":{"text":" /// The IP address of the requester.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1119"}},{"Del":{"text":" pub ip_addr: String,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1144"}},{"Del":{"text":" /// The body of the request, as bytes.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1187"}},{"Del":{"text":" pub body: Vec","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1209"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1211"}},{"Del":{"text":"#[derive(Clone, Debug, Deserialize, Serialize)]","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:96"}},{"Del":{"text":"/// A Serde-friendly representation of an HTTP response.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1309"}},{"Del":{"text":"pub struct HttpRes {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1330"}},{"Del":{"text":" /// Headers represented as pairs of `String`s.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1381"}},{"Del":{"text":" pub headers: BTreeMap,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1424"}},{"Del":{"text":" /// An optional `Set-Cookie` header. Setting multiple cookies is not supported and additional attributes aren't supported yet either.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1562"}},{"Del":{"text":" pub set_cookie: Option<(String, String)>,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1608"}},{"Del":{"text":" /// The body of the response, as bytes.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1652"}},{"Del":{"text":" pub body: Vec,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1675"}},{"Del":{"text":" /// The status code.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1700"}},{"Del":{"text":" pub status: u16,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1721"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1723"}},{"Del":{"text":"impl Default for HttpRes {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1750"}},{"Del":{"text":" fn default() -> Self {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1777"}},{"Del":{"text":" Self {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1792"}},{"Del":{"text":" headers: BTreeMap::new(),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1830"}},{"Del":{"text":" set_cookie: None,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1860"}},{"Del":{"text":" body: vec![],","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1886"}},{"Del":{"text":" status: 200","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1910"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1920"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1926"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1928"}}]}},{"FileDel":{"deleted_names":[{"basename":"err.rs","metadata":511},{"basename":"err.rs","metadata":420}],"path":"zhur_invk/src/err.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":19,"end":27},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":27},"to":{"change":4,"start":1938,"end":1938},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":1929,"end":1937},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":1937},"to":{"change":4,"start":1938,"end":1938},"introduced_by":4}],"inode":{"change":4,"pos":1938}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1938},"to":{"change":4,"start":1939,"end":2075},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2075},"to":{"change":4,"start":98,"end":146},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":146},"to":{"change":4,"start":2116,"end":2614},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2116},"to":{"change":4,"start":2116,"end":2614},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2614},"to":{"change":4,"start":147,"end":227},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":227},"to":{"change":4,"start":2614,"end":3377},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2614},"to":{"change":4,"start":2614,"end":3377},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3377},"to":{"change":4,"start":228,"end":374},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":374},"to":{"change":4,"start":3518,"end":3627},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3518},"to":{"change":4,"start":3518,"end":3627},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3627},"to":{"change":4,"start":375,"end":477},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":477},"to":{"change":4,"start":3627,"end":3961},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3627},"to":{"change":4,"start":3627,"end":3961},"introduced_by":4}],"inode":{"change":4,"pos":1938}},"content":[{"Del":{"text":"use std::fmt::Display;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1961"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1962"}},{"Del":{"text":"use super::*;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:1976"}},{"Del":{"text":"/// Everything that can go wrong with an invocation. Can be generated by the gateway or the core.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2074"}},{"Del":{"text":"#[derive(Clone, Deserialize, Serialize, Debug)]","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:145"}},{"Del":{"text":"pub enum InvocationError {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2142"}},{"Del":{"text":" // The variants below are gateway-side:","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2186"}},{"Del":{"text":" /// The HTTP request from Hyper could not be converted into a Serde-friendly form.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2273"}},{"Del":{"text":" MalformedRequest,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2295"}},{"Del":{"text":" /// No app was specified.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2325"}},{"Del":{"text":" NoId,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2335"}},{"Del":{"text":" /// No app could be identified with the information given.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2398"}},{"Del":{"text":" MalformedId(String),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2423"}},{"Del":{"text":" /// The gateway can't reach the core.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2465"}},{"Del":{"text":" NoCore,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2477"}},{"Del":{"text":" /// The core did not reply correctly.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2519"}},{"Del":{"text":" MalformedReply,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2539"}},{"Del":{"text":" /// The core did not respond within the timeout period.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2599"}},{"Del":{"text":" TimedOut,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2613"}},{"Del":{"text":" /// The invocation could not be serialized for transport.","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:208"}},{"Del":{"text":" SerializeErr,","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:226"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2614"}},{"Del":{"text":" // The variants below are core-side:","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2655"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2656"}},{"Del":{"text":" /// No app identified by the two ID substrings exists, or it is disabled/hidden.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2741"}},{"Del":{"text":" NoSuchApp(String, String),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2772"}},{"Del":{"text":" /// An internal problem occurred within the core.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2826"}},{"Del":{"text":" OtherInternal","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2844"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2846"}},{"Del":{"text":"impl Display for InvocationError {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2881"}},{"Del":{"text":" fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2954"}},{"Del":{"text":" let text = match self {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:2986"}},{"Del":{"text":" Self::MalformedRequest => \"The HTTP request from Hyper could not be converted into a Serde-friendly form.\".to_owned(),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3117"}},{"Del":{"text":" Self::NoId => \"No app was specified at all.\".to_owned(),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3186"}},{"Del":{"text":" Self::MalformedId(id) => format!(\"The ID \\\"{}\\\" is not a valid Zhur app ID.\", id),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3281"}},{"Del":{"text":" Self::NoCore => \"The Zhur gateway could not connect to the Zhur core.\".to_owned(),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3376"}},{"Del":{"text":" Self::MalformedReply => \"The reply from the Zhur core server could not be properly deserialized as an app's HTTP output.\".to_owned(),","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:373"}},{"Del":{"text":" Self::TimedOut => \"The Zhur core could be reached, but timed out before responding.\".to_owned(),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3626"}},{"Del":{"text":" Self::SerializeErr => \"The invocation could not be serialized for transport.\".to_owned(),","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:476"}},{"Del":{"text":" Self::NoSuchApp(owner, app_name) => format!(\"The Zhur core could not find an app named {}:{}. It may have been disabled.\", owner, app_name),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3779"}},{"Del":{"text":" Self::OtherInternal => \"The core encountered an internal error that prevented it from returning a proper reply.\".to_owned()","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3915"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3926"}},{"Del":{"text":" f.write_str(&text)","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3953"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3959"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:3961"}}]}},{"FileAdd":{"meta":{"basename":"lib.rs","metadata":511},"path":"zhur_invk/src/lib.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use zhur_common::*;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:29"}},{"Add":{"text":"use serde::{Deserialize, Serialize};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:66"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:67"}},{"Add":{"text":"pub mod err;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:80"}},{"Add":{"text":"pub use err::InvocationError;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:110"}},{"Add":{"text":"pub mod http;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:124"}},{"Add":{"text":"pub use http::*;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:141"}},{"Add":{"text":"/// Struct representing a Zhur app invocation.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:188"}},{"Add":{"text":"#[derive(Clone, Deserialize, Serialize, Debug)]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:236"}},{"Add":{"text":"pub struct Invocation {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:260"}},{"Add":{"text":" /// The name of the user/org to whom the app belongs.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:318"}},{"Add":{"text":" pub owner: String,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:341"}},{"Add":{"text":" /// The name of the app itself.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:377"}},{"Add":{"text":" pub app_name: String,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:403"}},{"Add":{"text":" /// The input for the app.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:434"}},{"Add":{"text":" pub payload: Vec","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:459"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:462"}}]}},{"FileAdd":{"meta":{"basename":"http.rs","metadata":511},"path":"zhur_invk/src/http.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use serde::{Deserialize, Serialize};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:511"}},{"Add":{"text":"use std::collections::BTreeMap;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:543"}},{"Add":{"text":"#[derive(Debug, Deserialize, Serialize)]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:584"}},{"Add":{"text":"/// A Serde-friendly representation of a HTTP request.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:639"}},{"Add":{"text":"pub struct HttpReq {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:660"}},{"Add":{"text":" /// The method of the request.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:695"}},{"Add":{"text":" pub method: String,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:719"}},{"Add":{"text":" /// The path of the request.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:752"}},{"Add":{"text":" pub path: String,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:774"}},{"Add":{"text":" /// Headers represented as pairs of `String`s.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:825"}},{"Add":{"text":" pub headers: BTreeMap,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:868"}},{"Add":{"text":" /// Query strings represented as pairs of `String`s.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:925"}},{"Add":{"text":" pub query_params: BTreeMap,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:973"}},{"Add":{"text":" /// Cookies represented as pairs of `String`s.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1024"}},{"Add":{"text":" pub cookies: BTreeMap,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1067"}},{"Add":{"text":" /// The IP address of the requester.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1108"}},{"Add":{"text":" pub ip_addr: String,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1133"}},{"Add":{"text":" /// The body of the request, as bytes.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1176"}},{"Add":{"text":" pub body: Vec","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1198"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1200"}},{"Add":{"text":"#[derive(Clone, Debug, Deserialize, Serialize)]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1248"}},{"Add":{"text":"/// A Serde-friendly representation of an HTTP response.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1305"}},{"Add":{"text":"pub struct HttpRes {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1326"}},{"Add":{"text":" /// Headers represented as pairs of `String`s.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1377"}},{"Add":{"text":" pub headers: BTreeMap,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1420"}},{"Add":{"text":" /// An optional `Set-Cookie` header. Setting multiple cookies is not supported and additional attributes aren't supported yet either.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1558"}},{"Add":{"text":" pub set_cookie: Option<(String, String)>,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1604"}},{"Add":{"text":" /// The body of the response, as bytes.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1648"}},{"Add":{"text":" pub body: Vec,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1671"}},{"Add":{"text":" /// The status code.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1696"}},{"Add":{"text":" pub status: u16,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1717"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1719"}},{"Add":{"text":"impl Default for HttpRes {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1746"}},{"Add":{"text":" fn default() -> Self {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1773"}},{"Add":{"text":" Self {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1788"}},{"Add":{"text":" headers: BTreeMap::new(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1826"}},{"Add":{"text":" set_cookie: None,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1856"}},{"Add":{"text":" body: vec![],","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1882"}},{"Add":{"text":" status: 200","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1906"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1916"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1922"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1925"}}]}},{"FileAdd":{"meta":{"basename":"err.rs","metadata":511},"path":"zhur_invk/src/err.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use std::fmt::Display;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1959"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1960"}},{"Add":{"text":"use super::*;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:1974"}},{"Add":{"text":"/// Everything that can go wrong with an invocation. Can be generated by the gateway or the core.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2072"}},{"Add":{"text":"#[derive(Clone, Deserialize, Serialize, Debug)]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2120"}},{"Add":{"text":"pub enum InvocationError {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2147"}},{"Add":{"text":" // The variants below are gateway-side:","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2191"}},{"Add":{"text":" /// The HTTP request from Hyper could not be converted into a Serde-friendly form.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2278"}},{"Add":{"text":" MalformedRequest,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2300"}},{"Add":{"text":" /// No app was specified.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2330"}},{"Add":{"text":" NoId,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2340"}},{"Add":{"text":" /// No app could be identified with the information given.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2403"}},{"Add":{"text":" MalformedId(String),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2428"}},{"Add":{"text":" /// The gateway can't reach the core.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2470"}},{"Add":{"text":" NoCore,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2482"}},{"Add":{"text":" /// The core did not reply correctly.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2524"}},{"Add":{"text":" MalformedReply,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2544"}},{"Add":{"text":" /// The core did not respond within the timeout period.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2604"}},{"Add":{"text":" TimedOut,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2618"}},{"Add":{"text":" /// The invocation could not be serialized for transport.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2680"}},{"Add":{"text":" SerializeErr,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2698"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2699"}},{"Add":{"text":" // The variants below are core-side:","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2740"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2741"}},{"Add":{"text":" /// No app identified by the two ID substrings exists, or it is disabled/hidden.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2826"}},{"Add":{"text":" NoSuchApp(String, String),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2857"}},{"Add":{"text":" /// An internal problem occurred within the core.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2911"}},{"Add":{"text":" OtherInternal","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2929"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2931"}},{"Add":{"text":"impl Display for InvocationError {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:2966"}},{"Add":{"text":" fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3039"}},{"Add":{"text":" let text = match self {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3071"}},{"Add":{"text":" Self::MalformedRequest => \"The HTTP request from Hyper could not be converted into a Serde-friendly form.\".to_owned(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3202"}},{"Add":{"text":" Self::NoId => \"No app was specified at all.\".to_owned(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3271"}},{"Add":{"text":" Self::MalformedId(id) => format!(\"The ID \\\"{}\\\" is not a valid Zhur app ID.\", id),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3366"}},{"Add":{"text":" Self::NoCore => \"The Zhur gateway could not connect to the Zhur core.\".to_owned(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3461"}},{"Add":{"text":" Self::MalformedReply => \"The reply from the Zhur core server could not be properly deserialized as an app's HTTP output.\".to_owned(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3607"}},{"Add":{"text":" Self::TimedOut => \"The Zhur core could be reached, but timed out before responding.\".to_owned(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3716"}},{"Add":{"text":" Self::SerializeErr => \"The invocation could not be serialized for transport.\".to_owned(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3818"}},{"Add":{"text":" Self::NoSuchApp(owner, app_name) => format!(\"The Zhur core could not find an app named {}:{}. It may have been disabled.\", owner, app_name),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:3971"}},{"Add":{"text":" Self::OtherInternal => \"The core encountered an internal error that prevented it from returning a proper reply.\".to_owned()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4107"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4118"}},{"Add":{"text":" f.write_str(&text)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4145"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4151"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4154"}}]}},{"FileAdd":{"meta":{"basename":"README.md","metadata":511},"path":"zhur_invk/README.md","context":[{"change":4,"pos":12}],"contents":[{"Add":{"text":"# zhur_invk","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4180"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4181"}},{"Add":{"text":"Types common to `zhur_core` and `zhur_gate`.\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4227"}}]}},{"FileAdd":{"meta":{"basename":"Cargo.toml","metadata":511},"path":"zhur_invk/Cargo.toml","context":[{"change":4,"pos":12}],"contents":[{"Add":{"text":"[package]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4252"}},{"Add":{"text":"name = \"zhur_invk\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4271"}},{"Add":{"text":"version = \"0.1.0\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4289"}},{"Add":{"text":"authors = [\"oreganoli <3611916+oreganoli@users.noreply.github.com>\"]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4358"}},{"Add":{"text":"edition = \"2018\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4375"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4376"}},{"Add":{"text":"# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4473"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4474"}},{"Add":{"text":"[dependencies]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4489"}},{"Add":{"text":"zhur_common = { path = \"../zhur_common\" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4531"}},{"Add":{"text":"serde = { version = \"1.0.118\", features = [\"derive\"] }\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4587"}}]}},{"FileDel":{"deleted_names":[{"basename":"README.md","metadata":511},{"basename":"README.md","metadata":420}],"path":"zhur_gate/README.md","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":3,"start":112,"end":123},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":123},"to":{"change":4,"start":1184,"end":1184},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":4,"start":1172,"end":1183},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":1183},"to":{"change":4,"start":1184,"end":1184},"introduced_by":4}],"inode":{"change":4,"pos":1184}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1184},"to":{"change":4,"start":1185,"end":1345},"introduced_by":4}],"inode":{"change":4,"pos":1184}},"content":[{"Del":{"text":"# zhur_gate","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1196"}},{"Del":{"text":"","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1197"}},{"Del":{"text":"This is the HTTP gateway for Zhur. Its task is to receive HTTP requests, transform them into Zhur invocations, and return the appropriate response.","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1345"}}]}},{"FileDel":{"deleted_names":[{"basename":"Cargo.toml","metadata":511},{"basename":"Cargo.toml","metadata":436}],"path":"zhur_gate/Cargo.toml","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":3,"start":124,"end":136},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":136},"to":{"change":4,"start":1359,"end":1359},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":4,"start":1346,"end":1358},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":1358},"to":{"change":4,"start":1359,"end":1359},"introduced_by":4}],"inode":{"change":4,"pos":1359}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1359},"to":{"change":4,"start":1360,"end":1683},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":9956},"to":{"change":4,"start":1683,"end":1735},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1683},"to":{"change":4,"start":1683,"end":1735},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1735},"to":{"change":4,"start":9957,"end":10062},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1683},"to":{"change":4,"start":9889,"end":9956},"introduced_by":4}],"inode":{"change":4,"pos":1359}},"content":[{"Del":{"text":"[package]","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1369"}},{"Del":{"text":"name = \"zhur_gate\"","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1388"}},{"Del":{"text":"description = \"Zhur HTTP gateway\"","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1422"}},{"Del":{"text":"version = \"0.1.0\"","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1440"}},{"Del":{"text":"authors = [\"oreganoli <3611916+oreganoli@users.noreply.github.com>\"]","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1509"}},{"Del":{"text":"edition = \"2018\"","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1526"}},{"Del":{"text":"","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1527"}},{"Del":{"text":"# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1624"}},{"Del":{"text":"","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1625"}},{"Del":{"text":"[dependencies]","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1640"}},{"Del":{"text":"zhur_common = { path = \"../zhur_common\" }","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1682"}},{"Del":{"text":"hyper = { version = \"0.14.2\", features = [\"full\"] }","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1734"}},{"Del":{"text":"tokio = { version = \"1.0.1\", features = [\"full\"] }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:10007"}},{"Del":{"text":"serde = { version = \"1.0.118\", features = [\"derive\"] }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:10062"}},{"Del":{"text":"zhur_invk = { path = \"../zhur_invk\" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9926"}},{"Del":{"text":"http = { version = \"0.2.3\" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9955"}}]}},{"FileDel":{"deleted_names":[{"basename":"main.rs","metadata":511},{"basename":"main.rs","metadata":436}],"path":"zhur_gate/src/main.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":53,"end":62},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":62},"to":{"change":4,"start":30,"end":30},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":20,"end":29},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":29},"to":{"change":4,"start":30,"end":30},"introduced_by":4}],"inode":{"change":4,"pos":30}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":30},"to":{"change":4,"start":478,"end":602},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":602},"to":{"change":4,"start":30,"end":59},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":30},"to":{"change":4,"start":30,"end":59},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":59},"to":{"change":4,"start":402,"end":435},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":402},"to":{"change":4,"start":402,"end":435},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":435},"to":{"change":4,"start":603,"end":888},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":888},"to":{"change":4,"start":60,"end":79},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":435},"to":{"change":4,"start":60,"end":79},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":79},"to":{"change":4,"start":889,"end":921},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":105},"to":{"change":4,"start":1170,"end":1171},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":921},"to":{"change":4,"start":1170,"end":1171},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1170},"to":{"change":4,"start":1170,"end":1171},"introduced_by":4}],"inode":{"change":4,"pos":30}},"content":[{"Del":{"text":"use zhur_common::{init_logger, zmq,","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:513"}},{"Del":{"text":" msg::chan::{","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:530"}},{"Del":{"text":" client_server,","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:553"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:559"}},{"Del":{"text":"};","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:562"}},{"Del":{"text":"use zhur_gate::comms::Gate2CoreServer;","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:601"}},{"Del":{"text":"use zhur_gate::start_server;","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:58"}},{"Del":{"text":"#[tokio::main]","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:416"}},{"Del":{"text":"async fn main() {","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:434"}},{"Del":{"text":" let zmq_ctx = zmq::Context::new();","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:641"}},{"Del":{"text":" let gate_core_server = Gate2CoreServer::new(&zmq_ctx);","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:700"}},{"Del":{"text":" let (client, server) = client_server(gate_core_server);","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:760"}},{"Del":{"text":" std::thread::spawn(move || {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:793"}},{"Del":{"text":" let mut server = server;","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:826"}},{"Del":{"text":" loop {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:841"}},{"Del":{"text":" server.handle()","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:869"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:879"}},{"Del":{"text":" });","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:887"}},{"Del":{"text":" init_logger();","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:78"}},{"Del":{"text":" start_server(client).await;","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:920"}},{"Del":{"text":"}","pos":"WGQH6HZG7HZNKJYKXV6DACDXMPRA6YPXBPA6BOHZDMGVF2DLBQ6QC:1171"}}]}},{"FileDel":{"deleted_names":[{"basename":"lib.rs","metadata":511},{"basename":"lib.rs","metadata":420}],"path":"zhur_gate/src/lib.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":63,"end":71},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":71},"to":{"change":4,"start":115,"end":115},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":106,"end":114},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":114},"to":{"change":4,"start":115,"end":115},"introduced_by":4}],"inode":{"change":4,"pos":115}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":115},"to":{"change":4,"start":116,"end":172},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":172},"to":{"change":4,"start":0,"end":57},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":57},"to":{"change":4,"start":249,"end":293},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":249},"to":{"change":4,"start":249,"end":293},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":293},"to":{"change":4,"start":58,"end":66},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":66},"to":{"change":4,"start":302,"end":329},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":302},"to":{"change":4,"start":302,"end":329},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":329},"to":{"change":4,"start":67,"end":150},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":150},"to":{"change":4,"start":922,"end":1063},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":150},"to":{"change":4,"start":455,"end":486},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1063},"to":{"change":4,"start":455,"end":486},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":455},"to":{"change":4,"start":455,"end":486},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":486},"to":{"change":4,"start":1064,"end":1161},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1161},"to":{"change":4,"start":516,"end":969},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":516},"to":{"change":4,"start":516,"end":969},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":969},"to":{"change":4,"start":151,"end":266},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":266},"to":{"change":4,"start":1162,"end":1203},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1203},"to":{"change":4,"start":266,"end":291},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":266},"to":{"change":4,"start":266,"end":291},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":291},"to":{"change":4,"start":1204,"end":1420},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1420},"to":{"change":4,"start":398,"end":429},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":398},"to":{"change":4,"start":398,"end":429},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":429},"to":{"change":4,"start":1081,"end":1221},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1081},"to":{"change":4,"start":1081,"end":1221},"introduced_by":4}],"inode":{"change":4,"pos":115}},"content":[{"Del":{"text":"use std::convert::Infallible;","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:145"}},{"Del":{"text":"use std::net::SocketAddr;","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:171"}},{"Del":{"text":"use hyper::{Server, server::conn::AddrStream, service::{","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:56"}},{"Del":{"text":" service_fn,","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:268"}},{"Del":{"text":" make_service_fn","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:292"}},{"Del":{"text":" }};","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:65"}},{"Del":{"text":"","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:302"}},{"Del":{"text":"use zhur_common::log::*;","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:327"}},{"Del":{"text":"","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:328"}},{"Del":{"text":"/// HTTP request handling code.","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:98"}},{"Del":{"text":"mod handle;","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:110"}},{"Del":{"text":"use handle::{FullRequest, handle_req};","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:149"}},{"Del":{"text":"/// Communication with the core module.","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:961"}},{"Del":{"text":"pub mod comms;","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:976"}},{"Del":{"text":"use zhur_common::msg::chan::*;","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1007"}},{"Del":{"text":"use zhur_invk::{HttpRes, Invocation, InvocationError};","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1062"}},{"Del":{"text":"","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:455"}},{"Del":{"text":"/// Runs a Hyper HTTP server.","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:485"}},{"Del":{"text":"pub async fn start_server(client: ChannelClient>) {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1160"}},{"Del":{"text":" let port = match std::env::var(\"ZHUR_GATE_PORT\") {","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:570"}},{"Del":{"text":" Ok(v) => match v.parse::() {","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:612"}},{"Del":{"text":" Ok(n) => n,","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:636"}},{"Del":{"text":" _ => {","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:655"}},{"Del":{"text":" error!(\"ZHUR_GATE_PORT set to invalid value \\\"{}\\\", exiting.\", &v);","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:739"}},{"Del":{"text":" return;","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:763"}},{"Del":{"text":" }","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:777"}},{"Del":{"text":" },","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:788"}},{"Del":{"text":" _ => {","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:803"}},{"Del":{"text":" warn!(\"ZHUR_GATE_PORT env var not set. Assuming port 8080.\");","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:877"}},{"Del":{"text":" 8080","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:894"}},{"Del":{"text":" }","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:904"}},{"Del":{"text":" };","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:911"}},{"Del":{"text":" let addr = SocketAddr::from(([127, 0, 0, 1], port));","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:968"}},{"Del":{"text":" let make_svc = make_service_fn(move |conn: &AddrStream| {","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:212"}},{"Del":{"text":" let ip = conn.remote_addr().to_string();","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:265"}},{"Del":{"text":" let client = client.clone();","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1202"}},{"Del":{"text":" async move {","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:290"}},{"Del":{"text":" Ok::<_, Infallible>(service_fn(move |req| handle_req(","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1273"}},{"Del":{"text":" FullRequest{ req, ip: ip.clone() },","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1329"}},{"Del":{"text":" client.clone() // TODO: remove this horrific hack","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1399"}},{"Del":{"text":" )))","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1419"}},{"Del":{"text":" }","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:411"}},{"Del":{"text":" }","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:421"}},{"Del":{"text":" );","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:428"}},{"Del":{"text":" let server = Server::bind(&addr).serve(make_svc);","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:1134"}},{"Del":{"text":" if let Err(e) = server.await {","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:1169"}},{"Del":{"text":" error!(\"HTTP server error: {}\", e);","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:1213"}},{"Del":{"text":" }","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:1219"}},{"Del":{"text":"}","pos":"DIIDKMIXQENUQIOIFHT62KAX4WL5MJWEB5BXHGUYCDSKIPRQVPOAC:1221"}}]}},{"FileDel":{"deleted_names":[{"basename":"handle.rs","metadata":511},{"basename":"handle.rs","metadata":420}],"path":"zhur_gate/src/handle.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":72,"end":83},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":83},"to":{"change":4,"start":442,"end":442},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":430,"end":441},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":441},"to":{"change":4,"start":442,"end":442},"introduced_by":4}],"inode":{"change":4,"pos":442}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":442},"to":{"change":4,"start":443,"end":525},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":525},"to":{"change":4,"start":4391,"end":4409},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4409},"to":{"change":4,"start":1421,"end":1474},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1474},"to":{"change":4,"start":4434,"end":4523},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4434},"to":{"change":4,"start":4434,"end":4523},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4523},"to":{"change":4,"start":602,"end":781},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":602},"to":{"change":4,"start":602,"end":781},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4525},"to":{"change":4,"start":781,"end":835},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":781},"to":{"change":4,"start":781,"end":835},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":835},"to":{"change":4,"start":1475,"end":1682},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1682},"to":{"change":4,"start":4759,"end":4930},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4759},"to":{"change":4,"start":4759,"end":4930},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4930},"to":{"change":4,"start":1683,"end":1697},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1697},"to":{"change":4,"start":4973,"end":5102},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4973},"to":{"change":4,"start":4973,"end":5102},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5102},"to":{"change":4,"start":1698,"end":1786},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1871},"to":{"change":4,"start":1871,"end":2458},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2458},"to":{"change":4,"start":5145,"end":5161},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5145},"to":{"change":4,"start":5145,"end":5161},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":5161},"to":{"change":4,"start":1001,"end":1002},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1001},"to":{"change":4,"start":1001,"end":1002},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1786},"to":{"change":4,"start":1786,"end":1871},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":781},"to":{"change":4,"start":4524,"end":4525},"introduced_by":4}],"inode":{"change":4,"pos":442}},"content":[{"Del":{"text":"use hyper::{","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:455"}},{"Del":{"text":" Body,","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:465"}},{"Del":{"text":" Request,","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:478"}},{"Del":{"text":" Response","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:491"}},{"Del":{"text":"};","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:494"}},{"Del":{"text":"use std::convert::Infallible;","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:524"}},{"Del":{"text":"use zhur_invk::*;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4408"}},{"Del":{"text":"use zhur_common::{log::*, msg::chan::ChannelClient};","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1473"}},{"Del":{"text":"mod conversions;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4450"}},{"Del":{"text":"/// The info we need to produce a Zhur invocation from an HTTP request.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4522"}},{"Del":{"text":"pub struct FullRequest {","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:626"}},{"Del":{"text":" /// The request itself.","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:654"}},{"Del":{"text":" pub req: Request,","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:682"}},{"Del":{"text":" /// The IP address the request is coming from, represented as a string.","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:758"}},{"Del":{"text":" pub ip: String,","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:778"}},{"Del":{"text":"}","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:780"}},{"Del":{"text":"/// Transforms an HTTP request into an HTTP response.","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:834"}},{"Del":{"text":"pub async fn handle_req(req: FullRequest, mut client: ChannelClient>) -> Result, Infallible> {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1629"}},{"Del":{"text":" let invocation = match req.into_invoc().await {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1681"}},{"Del":{"text":" Ok(i) => {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4777"}},{"Del":{"text":" let text = format!(\"Got an OK invocation for {}:{} of length {}\", &i.owner, &i.app_name, &i.payload.len());","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4897"}},{"Del":{"text":" info!(\"{}\", &text);","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4929"}},{"Del":{"text":" i","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1696"}},{"Del":{"text":" },","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4983"}},{"Del":{"text":" Err(e) => {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5003"}},{"Del":{"text":" let text = format!(\"Got an invocation error: {}\", e);","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5069"}},{"Del":{"text":" warn!(\"{}\", &text);","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5101"}},{"Del":{"text":" return Ok(Response::new(text.into())) // TODO: Error pages","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1768"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1778"}},{"Del":{"text":" };","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1785"}},{"Del":{"text":" let reply = client.request(invocation);","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1914"}},{"Del":{"text":" match reply {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1932"}},{"Del":{"text":" Ok(res) => {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1953"}},{"Del":{"text":" info!(\"Got a well-formed HttpRes as an invocation result!\");","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2026"}},{"Del":{"text":" return Ok(Response::new(","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2063"}},{"Del":{"text":" format!(\"Response with body length {}\", res.body.len())","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2135"}},{"Del":{"text":" .into()","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2159"}},{"Del":{"text":" )) // TODO actually handle the damn HttpRes","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2215"}},{"Del":{"text":" },","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2226"}},{"Del":{"text":" Err(e) => {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2246"}},{"Del":{"text":" let text = format!(\"Got an invocation error: {}\", e);","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2312"}},{"Del":{"text":" warn!(\"{}\", &text);","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2344"}},{"Del":{"text":" return Ok(Response::new(text.into())) // TODO: Error pages","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2415"}},{"Del":{"text":" // TODO: Not brazen copypaste","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2457"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5154"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5160"}},{"Del":{"text":"}","pos":"QUPSHDL6MQBVCRQPZ3O7MMG27FJYCASSOWN6LI6X5K3VOL7TCAVAC:1002"}},{"Del":{"text":" // TODO: actually send the invocation to the core and try to get something back.","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:1870"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:4524"}}]}},{"FileDel":{"deleted_names":[{"basename":"comms.rs","metadata":511},{"basename":"comms.rs","metadata":420}],"path":"zhur_gate/src/comms.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":101,"end":111},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":111},"to":{"change":4,"start":2470,"end":2470},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":2459,"end":2469},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":2469},"to":{"change":4,"start":2470,"end":2470},"introduced_by":4}],"inode":{"change":4,"pos":2470}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2470},"to":{"change":4,"start":2471,"end":4367},"introduced_by":4}],"inode":{"change":4,"pos":2470}},"content":[{"Del":{"text":"use bincode::deserialize;","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2496"}},{"Del":{"text":"use zhur_common::{bincode, log::warn, msg::chan::*, zmq};","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2554"}},{"Del":{"text":"use zhur_invk::{HttpRes, Invocation, InvocationError};","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2609"}},{"Del":{"text":"use zmq::{Context, Socket, SocketType};","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2649"}},{"Del":{"text":"/// Struct responsible for relaying requests from the gateway to the core.","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2724"}},{"Del":{"text":"pub struct Gate2CoreServer {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2753"}},{"Del":{"text":" /// ZMQ REQ socket.","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2777"}},{"Del":{"text":" req_socket: Socket,","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2801"}},{"Del":{"text":"}","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2803"}},{"Del":{"text":"impl Gate2CoreServer {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2826"}},{"Del":{"text":" pub fn new(zmq_ctx: &Context) -> Self {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2870"}},{"Del":{"text":" Self {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2885"}},{"Del":{"text":" req_socket: {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2911"}},{"Del":{"text":" let sck = zmq_ctx.socket(SocketType::REQ)","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:2969"}},{"Del":{"text":" .expect(\"Expected to be able to construct a socket.\");","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3040"}},{"Del":{"text":" let endpoint = match std::env::var(\"ZHUR_CORE_REP_URI\") {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3114"}},{"Del":{"text":" Ok(s) => s,","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3146"}},{"Del":{"text":" Err(_) => {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3178"}},{"Del":{"text":" warn!(\"ZHUR_CORE_REP_URI not set - assuming default value of tcp://127.0.0.1:8081!\");","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3288"}},{"Del":{"text":" \"tcp://127.0.0.1:8081\".to_owned()","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3346"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3368"}},{"Del":{"text":" };","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3387"}},{"Del":{"text":" sck.connect(&endpoint)","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3426"}},{"Del":{"text":" .expect(\"Expected to be able to connect a REQ socket from the gateway to the core.\");","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3528"}},{"Del":{"text":" sck","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3548"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3562"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3572"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3578"}},{"Del":{"text":"}","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3580"}},{"Del":{"text":"","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3581"}},{"Del":{"text":"impl HandleRequest> for Gate2CoreServer {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3668"}},{"Del":{"text":" fn handle(&mut self, msg: Invocation) -> Result {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3748"}},{"Del":{"text":" let invoc_bytes = match bincode::serialize(&msg) {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3807"}},{"Del":{"text":" Ok(b) => b,","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3831"}},{"Del":{"text":" Err(_) => return Err(InvocationError::SerializeErr)","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3895"}},{"Del":{"text":" };","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3906"}},{"Del":{"text":" match self.req_socket.send(invoc_bytes, 0) {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3959"}},{"Del":{"text":" Ok(_) => (),","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:3984"}},{"Del":{"text":" Err(_) => return Err(InvocationError::NoCore)","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4042"}},{"Del":{"text":" };","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4053"}},{"Del":{"text":" let response_bytes = match self.req_socket.recv_bytes(0) {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4120"}},{"Del":{"text":" Ok(b) => b,","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4144"}},{"Del":{"text":" Err(_) => return Err(InvocationError::MalformedReply)","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4210"}},{"Del":{"text":" };","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4221"}},{"Del":{"text":" match deserialize(&response_bytes) {","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4266"}},{"Del":{"text":" Ok(r) => r,","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4290"}},{"Del":{"text":" Err(_) => Err(InvocationError::MalformedReply)","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4349"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4359"}},{"Del":{"text":" }","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4365"}},{"Del":{"text":"}","pos":"AGX35J5GL7C33UWYITQZEP6QRYBUTFJV3ANW6YMEMZ6WVWG7ZLXAC:4367"}}]}},{"FileAdd":{"meta":{"basename":"main.rs","metadata":511},"path":"zhur_gate/src/main.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use zhur_common::{init_logger, zmq,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4635"}},{"Add":{"text":" msg::chan::{","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4652"}},{"Add":{"text":" client_server,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4675"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4681"}},{"Add":{"text":"};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4684"}},{"Add":{"text":"use zhur_gate::comms::Gate2CoreServer;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4723"}},{"Add":{"text":"use zhur_gate::start_server;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4752"}},{"Add":{"text":"#[tokio::main]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4767"}},{"Add":{"text":"async fn main() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4785"}},{"Add":{"text":" let zmq_ctx = zmq::Context::new();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4824"}},{"Add":{"text":" let gate_core_server = Gate2CoreServer::new(&zmq_ctx);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4883"}},{"Add":{"text":" let (client, server) = client_server(gate_core_server);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4943"}},{"Add":{"text":" std::thread::spawn(move || {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:4976"}},{"Add":{"text":" let mut server = server;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5009"}},{"Add":{"text":" loop {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5024"}},{"Add":{"text":" server.handle()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5052"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5062"}},{"Add":{"text":" });","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5070"}},{"Add":{"text":" init_logger();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5089"}},{"Add":{"text":" start_server(client).await;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5121"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5124"}}]}},{"FileAdd":{"meta":{"basename":"lib.rs","metadata":511},"path":"zhur_gate/src/lib.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use std::convert::Infallible;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5165"}},{"Add":{"text":"use std::net::SocketAddr;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5191"}},{"Add":{"text":"use hyper::{Server, server::conn::AddrStream, service::{","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5248"}},{"Add":{"text":" service_fn,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5268"}},{"Add":{"text":" make_service_fn","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5292"}},{"Add":{"text":" }};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5300"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5301"}},{"Add":{"text":"use zhur_common::log::*;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5326"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5327"}},{"Add":{"text":"/// HTTP request handling code.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5359"}},{"Add":{"text":"mod handle;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5371"}},{"Add":{"text":"use handle::{FullRequest, handle_req};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5410"}},{"Add":{"text":"/// Communication with the core module.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5450"}},{"Add":{"text":"pub mod comms;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5465"}},{"Add":{"text":"use zhur_common::msg::chan::*;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5496"}},{"Add":{"text":"use zhur_invk::{HttpRes, Invocation, InvocationError};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5551"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5552"}},{"Add":{"text":"/// Runs a Hyper HTTP server.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5582"}},{"Add":{"text":"pub async fn start_server(client: ChannelClient>) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5679"}},{"Add":{"text":" let port = match std::env::var(\"ZHUR_GATE_PORT\") {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5734"}},{"Add":{"text":" Ok(v) => match v.parse::() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5776"}},{"Add":{"text":" Ok(n) => n,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5800"}},{"Add":{"text":" _ => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5819"}},{"Add":{"text":" error!(\"ZHUR_GATE_PORT set to invalid value \\\"{}\\\", exiting.\", &v);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5903"}},{"Add":{"text":" return;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5927"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5941"}},{"Add":{"text":" },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5952"}},{"Add":{"text":" _ => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:5967"}},{"Add":{"text":" warn!(\"ZHUR_GATE_PORT env var not set. Assuming port 8080.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6041"}},{"Add":{"text":" 8080","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6058"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6068"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6075"}},{"Add":{"text":" let addr = SocketAddr::from(([127, 0, 0, 1], port));","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6132"}},{"Add":{"text":" let make_svc = make_service_fn(move |conn: &AddrStream| {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6194"}},{"Add":{"text":" let ip = conn.remote_addr().to_string();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6247"}},{"Add":{"text":" let client = client.clone();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6288"}},{"Add":{"text":" async move {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6313"}},{"Add":{"text":" Ok::<_, Infallible>(service_fn(move |req| handle_req(","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6383"}},{"Add":{"text":" FullRequest{ req, ip: ip.clone() },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6439"}},{"Add":{"text":" client.clone() // TODO: remove this horrific hack","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6509"}},{"Add":{"text":" )))","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6529"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6543"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6553"}},{"Add":{"text":" );","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6560"}},{"Add":{"text":" let server = Server::bind(&addr).serve(make_svc);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6614"}},{"Add":{"text":" if let Err(e) = server.await {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6649"}},{"Add":{"text":" error!(\"HTTP server error: {}\", e);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6693"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6699"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6702"}}]}},{"FileAdd":{"meta":{"basename":"handle.rs","metadata":511},"path":"zhur_gate/src/handle.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use hyper::{","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6729"}},{"Add":{"text":" Body,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6739"}},{"Add":{"text":" Request,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6752"}},{"Add":{"text":" Response","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6765"}},{"Add":{"text":"};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6768"}},{"Add":{"text":"use std::convert::Infallible;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6798"}},{"Add":{"text":"use zhur_invk::*;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6816"}},{"Add":{"text":"use zhur_common::{log::*, msg::chan::ChannelClient};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6869"}},{"Add":{"text":"mod conversions;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6886"}},{"Add":{"text":"/// The info we need to produce a Zhur invocation from an HTTP request.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6958"}},{"Add":{"text":"pub struct FullRequest {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:6983"}},{"Add":{"text":" /// The request itself.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7011"}},{"Add":{"text":" pub req: Request,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7039"}},{"Add":{"text":" /// The IP address the request is coming from, represented as a string.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7115"}},{"Add":{"text":" pub ip: String,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7135"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7137"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7138"}},{"Add":{"text":"/// Transforms an HTTP request into an HTTP response.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7192"}},{"Add":{"text":"pub async fn handle_req(req: FullRequest, mut client: ChannelClient>) -> Result, Infallible> {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7347"}},{"Add":{"text":" let invocation = match req.into_invoc().await {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7399"}},{"Add":{"text":" Ok(i) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7418"}},{"Add":{"text":" let text = format!(\"Got an OK invocation for {}:{} of length {}\", &i.owner, &i.app_name, &i.payload.len());","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7538"}},{"Add":{"text":" info!(\"{}\", &text);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7570"}},{"Add":{"text":" i","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7584"}},{"Add":{"text":" },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7595"}},{"Add":{"text":" Err(e) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7615"}},{"Add":{"text":" let text = format!(\"Got an invocation error: {}\", e);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7681"}},{"Add":{"text":" warn!(\"{}\", &text);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7713"}},{"Add":{"text":" return Ok(Response::new(text.into())) // TODO: Error pages","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7784"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7794"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7801"}},{"Add":{"text":" let reply = client.request(invocation);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7845"}},{"Add":{"text":" match reply {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7863"}},{"Add":{"text":" Ok(res) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7884"}},{"Add":{"text":" info!(\"Got a well-formed HttpRes as an invocation result!\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7957"}},{"Add":{"text":" return Ok(Response::new(","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:7994"}},{"Add":{"text":" format!(\"Response with body length {}\", res.body.len())","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8066"}},{"Add":{"text":" .into()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8090"}},{"Add":{"text":" )) // TODO actually handle the damn HttpRes","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8146"}},{"Add":{"text":" },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8157"}},{"Add":{"text":" Err(e) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8177"}},{"Add":{"text":" let text = format!(\"Got an invocation error: {}\", e);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8243"}},{"Add":{"text":" warn!(\"{}\", &text);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8275"}},{"Add":{"text":" return Ok(Response::new(text.into())) // TODO: Error pages","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8346"}},{"Add":{"text":" // TODO: Not brazen copypaste","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8388"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8398"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8404"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8407"}}]}},{"FileDel":{"deleted_names":[{"basename":"conversions.rs","metadata":511},{"basename":"conversions.rs","metadata":420}],"path":"zhur_gate/src/handle/conversions.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":5171},"to":{"change":3,"start":84,"end":100},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":100},"to":{"change":4,"start":5189,"end":5189},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":5171},"to":{"change":4,"start":5172,"end":5188},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":5188},"to":{"change":4,"start":5189,"end":5189},"introduced_by":4}],"inode":{"change":4,"pos":5189}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5189},"to":{"change":4,"start":5190,"end":9888},"introduced_by":4}],"inode":{"change":4,"pos":5189}},"content":[{"Del":{"text":"use std::collections::BTreeMap;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5221"}},{"Del":{"text":"use super::{FullRequest, HttpReq, InvocationError};","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5273"}},{"Del":{"text":"use zhur_common::log::*;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5298"}},{"Del":{"text":"use zhur_invk::Invocation;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5325"}},{"Del":{"text":"/// Simplifies a `FullRequest` into an `HttpReq` of ours.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5383"}},{"Del":{"text":"pub async fn simplify_req(req: FullRequest) -> Result {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5465"}},{"Del":{"text":" use http::header::COOKIE;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5495"}},{"Del":{"text":" let method = req.req.method().to_string();","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5542"}},{"Del":{"text":" let uri = req.req.uri();","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5571"}},{"Del":{"text":" let path = uri.path().to_owned();","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5609"}},{"Del":{"text":" let query_params = match uri.query() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5652"}},{"Del":{"text":" Some(s) => parse_query_string(s),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5694"}},{"Del":{"text":" None => BTreeMap::new()","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5726"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5733"}},{"Del":{"text":" // dbg!(&query_params);","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5761"}},{"Del":{"text":" let cookie_str = match req.req.headers().get(COOKIE) {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5820"}},{"Del":{"text":" Some(hv) => match hv.to_str() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5860"}},{"Del":{"text":" Ok(s) => Some(s),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5890"}},{"Del":{"text":" Err(_) => {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:5914"}},{"Del":{"text":" warn!(\"Got a Cookie string that is not a valid ASCII string. Discarding.\");","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6006"}},{"Del":{"text":" None","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6027"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6041"}},{"Del":{"text":" },","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6052"}},{"Del":{"text":" None => None","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6073"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6080"}},{"Del":{"text":" let cookies = match cookie_str {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6117"}},{"Del":{"text":" Some(s) => cookie_map(s),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6151"}},{"Del":{"text":" None => BTreeMap::new()","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6183"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6190"}},{"Del":{"text":" let mut headers = BTreeMap::new();","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6229"}},{"Del":{"text":" for (name, val) in req.req.headers().iter() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6279"}},{"Del":{"text":" if name == \"Cookie\" {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6309"}},{"Del":{"text":" continue;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6331"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6341"}},{"Del":{"text":" match val.to_str() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6370"}},{"Del":{"text":" Ok(s) => {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6393"}},{"Del":{"text":" headers.insert(name.to_string(), s.to_owned());","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6457"}},{"Del":{"text":" },","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6472"}},{"Del":{"text":" Err(_) => {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6496"}},{"Del":{"text":" warn!(\"Found a header that could not be parsed as a string. Discarding.\");","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6587"}},{"Del":{"text":" continue;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6613"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6627"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6637"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6643"}},{"Del":{"text":" let body = match hyper::body::to_bytes(req.req.into_body()).await {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6715"}},{"Del":{"text":" Ok(b) => b.to_vec(),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6744"}},{"Del":{"text":" Err(_) => return Err(InvocationError::MalformedRequest)","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6808"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6815"}},{"Del":{"text":" Ok(HttpReq {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6832"}},{"Del":{"text":" body,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6846"}},{"Del":{"text":" path,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6860"}},{"Del":{"text":" method,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6876"}},{"Del":{"text":" cookies,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6893"}},{"Del":{"text":" headers,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6910"}},{"Del":{"text":" query_params,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6932"}},{"Del":{"text":" ip_addr: req.ip.clone()","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6964"}},{"Del":{"text":" })","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6971"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6973"}},{"Del":{"text":"","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6974"}},{"Del":{"text":"impl FullRequest {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:6993"}},{"Del":{"text":" /// Turns a `FullRequest` into an `Invocation`.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7045"}},{"Del":{"text":" pub async fn into_invoc(self) -> Result {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7120"}},{"Del":{"text":" use zhur_common::bincode::serialize;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7165"}},{"Del":{"text":" use http::header::HOST;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7197"}},{"Del":{"text":" let host = match self.req.headers().get(HOST) {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7253"}},{"Del":{"text":" Some(s) => match s.to_str() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7295"}},{"Del":{"text":" Ok(s) => s,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7323"}},{"Del":{"text":" Err(_) => {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7351"}},{"Del":{"text":" warn!(\"Received an HTTP request with a non-UTF-text Host header, returning malformed ID error.\");","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7469"}},{"Del":{"text":" return Err(InvocationError::MalformedId(\"(not valid UTF-8 text)\".into()))","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7563"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7581"}},{"Del":{"text":" },","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7596"}},{"Del":{"text":" None => {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7618"}},{"Del":{"text":" warn!(\"Received an HTTP request with no Host header, returning a no ID error.\");","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7715"}},{"Del":{"text":" return Err(InvocationError::NoId)","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7765"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7779"}},{"Del":{"text":" }.to_owned();","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7801"}},{"Del":{"text":" let segments = host.split('.').collect::>();","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7861"}},{"Del":{"text":" if segments.is_empty() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7894"}},{"Del":{"text":" warn!(\"Received an HTTP request with an empty Host header, returning a no ID error.\");","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:7993"}},{"Del":{"text":" return Err(InvocationError::NoId);","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8040"}},{"Del":{"text":" } else if segments.len() < 2 {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8079"}},{"Del":{"text":" warn!(\"Received an HTTP request with a Host header that could not be transformed into an app ID: \\\"{}\\\"\", host);","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8204"}},{"Del":{"text":" return Err(InvocationError::MalformedId(host.into()));","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8271"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8281"}},{"Del":{"text":" let req_simple = simplify_req(self).await?;","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8333"}},{"Del":{"text":" let req_bytes = match serialize(&req_simple) {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8388"}},{"Del":{"text":" Ok(b) => b,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8412"}},{"Del":{"text":" Err(_) => return Err(InvocationError::MalformedRequest)","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8480"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8491"}},{"Del":{"text":" let result = Invocation {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8525"}},{"Del":{"text":" owner: segments[0].to_owned(),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8568"}},{"Del":{"text":" app_name: segments[1].to_owned(),","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8614"}},{"Del":{"text":" payload: req_bytes","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8645"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8656"}},{"Del":{"text":" Ok(result)","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8675"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8681"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8683"}},{"Del":{"text":"/// Parses a query string of the form \"a=b&c=d\" into params. Note: Hyper takes care of extracting said string out of a URI already, so no need to worry about ?.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8844"}},{"Del":{"text":"fn parse_query_string(s: &str) -> BTreeMap {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8905"}},{"Del":{"text":" let mut output = BTreeMap::new();","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8943"}},{"Del":{"text":" let pairs = s.split(\"&\");","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8973"}},{"Del":{"text":" for pair in pairs {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:8997"}},{"Del":{"text":" let mut param_val = pair.split(\"=\");","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9042"}},{"Del":{"text":" let param = match param_val.next() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9087"}},{"Del":{"text":" Some(p) => p,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9113"}},{"Del":{"text":" None => continue","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9142"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9153"}},{"Del":{"text":" let val = match param_val.next() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9196"}},{"Del":{"text":" Some(v) => v,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9222"}},{"Del":{"text":" None => continue","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9251"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9262"}},{"Del":{"text":" output.insert(param.to_owned(), val.to_owned());","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9319"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9325"}},{"Del":{"text":" output","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9336"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9338"}},{"Del":{"text":"/// Produces a map of cookies to their values given a cookie string.","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9407"}},{"Del":{"text":"fn cookie_map(cookie_str: &str) -> BTreeMap {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9469"}},{"Del":{"text":" let mut output = BTreeMap::new();","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9507"}},{"Del":{"text":" for cookie in cookie_str.split(\"; \") {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9550"}},{"Del":{"text":" let mut name_val = cookie.split(\"=\");","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9596"}},{"Del":{"text":" let name = match name_val.next() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9639"}},{"Del":{"text":" Some(n) => n,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9665"}},{"Del":{"text":" None => continue","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9694"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9705"}},{"Del":{"text":" let val = match name_val.next() {","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9747"}},{"Del":{"text":" Some(v) => v,","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9773"}},{"Del":{"text":" None => continue","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9802"}},{"Del":{"text":" };","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9813"}},{"Del":{"text":" output.insert(name.to_owned(), val.to_owned());","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9869"}},{"Del":{"text":" }","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9875"}},{"Del":{"text":" output","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9886"}},{"Del":{"text":"}","pos":"6LABQWDWWQUEDTXZBKETGLG65FZ66FJLLY5IW3IFCMYJUO65Q4BAC:9888"}}]}},{"FileAdd":{"meta":{"basename":"conversions.rs","metadata":511},"path":"zhur_gate/src/handle/conversions.rs","context":[{"change":4,"pos":5171}],"contents":[{"Add":{"text":"use std::collections::BTreeMap;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8458"}},{"Add":{"text":"use super::{FullRequest, HttpReq, InvocationError};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8510"}},{"Add":{"text":"use zhur_common::log::*;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8535"}},{"Add":{"text":"use zhur_invk::Invocation;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8562"}},{"Add":{"text":"/// Simplifies a `FullRequest` into an `HttpReq` of ours.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8620"}},{"Add":{"text":"pub async fn simplify_req(req: FullRequest) -> Result {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8702"}},{"Add":{"text":" use http::header::COOKIE;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8732"}},{"Add":{"text":" let method = req.req.method().to_string();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8779"}},{"Add":{"text":" let uri = req.req.uri();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8808"}},{"Add":{"text":" let path = uri.path().to_owned();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8846"}},{"Add":{"text":" let query_params = match uri.query() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8889"}},{"Add":{"text":" Some(s) => parse_query_string(s),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8931"}},{"Add":{"text":" None => BTreeMap::new()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8963"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8970"}},{"Add":{"text":" // dbg!(&query_params);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:8998"}},{"Add":{"text":" let cookie_str = match req.req.headers().get(COOKIE) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9057"}},{"Add":{"text":" Some(hv) => match hv.to_str() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9097"}},{"Add":{"text":" Ok(s) => Some(s),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9127"}},{"Add":{"text":" Err(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9151"}},{"Add":{"text":" warn!(\"Got a Cookie string that is not a valid ASCII string. Discarding.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9243"}},{"Add":{"text":" None","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9264"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9278"}},{"Add":{"text":" },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9289"}},{"Add":{"text":" None => None","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9310"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9317"}},{"Add":{"text":" let cookies = match cookie_str {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9354"}},{"Add":{"text":" Some(s) => cookie_map(s),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9388"}},{"Add":{"text":" None => BTreeMap::new()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9420"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9427"}},{"Add":{"text":" let mut headers = BTreeMap::new();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9466"}},{"Add":{"text":" for (name, val) in req.req.headers().iter() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9516"}},{"Add":{"text":" if name == \"Cookie\" {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9546"}},{"Add":{"text":" continue;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9568"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9578"}},{"Add":{"text":" match val.to_str() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9607"}},{"Add":{"text":" Ok(s) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9630"}},{"Add":{"text":" headers.insert(name.to_string(), s.to_owned());","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9694"}},{"Add":{"text":" },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9709"}},{"Add":{"text":" Err(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9733"}},{"Add":{"text":" warn!(\"Found a header that could not be parsed as a string. Discarding.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9824"}},{"Add":{"text":" continue;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9850"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9864"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9874"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9880"}},{"Add":{"text":" let body = match hyper::body::to_bytes(req.req.into_body()).await {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9952"}},{"Add":{"text":" Ok(b) => b.to_vec(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:9981"}},{"Add":{"text":" Err(_) => return Err(InvocationError::MalformedRequest)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10045"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10052"}},{"Add":{"text":" Ok(HttpReq {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10069"}},{"Add":{"text":" body,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10083"}},{"Add":{"text":" path,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10097"}},{"Add":{"text":" method,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10113"}},{"Add":{"text":" cookies,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10130"}},{"Add":{"text":" headers,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10147"}},{"Add":{"text":" query_params,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10169"}},{"Add":{"text":" ip_addr: req.ip.clone()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10201"}},{"Add":{"text":" })","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10208"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10210"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10211"}},{"Add":{"text":"impl FullRequest {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10230"}},{"Add":{"text":" /// Turns a `FullRequest` into an `Invocation`.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10282"}},{"Add":{"text":" pub async fn into_invoc(self) -> Result {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10357"}},{"Add":{"text":" use zhur_common::bincode::serialize;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10402"}},{"Add":{"text":" use http::header::HOST;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10434"}},{"Add":{"text":" let host = match self.req.headers().get(HOST) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10490"}},{"Add":{"text":" Some(s) => match s.to_str() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10532"}},{"Add":{"text":" Ok(s) => s,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10560"}},{"Add":{"text":" Err(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10588"}},{"Add":{"text":" warn!(\"Received an HTTP request with a non-UTF-text Host header, returning malformed ID error.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10706"}},{"Add":{"text":" return Err(InvocationError::MalformedId(\"(not valid UTF-8 text)\".into()))","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10800"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10818"}},{"Add":{"text":" },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10833"}},{"Add":{"text":" None => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10855"}},{"Add":{"text":" warn!(\"Received an HTTP request with no Host header, returning a no ID error.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:10952"}},{"Add":{"text":" return Err(InvocationError::NoId)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11002"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11016"}},{"Add":{"text":" }.to_owned();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11038"}},{"Add":{"text":" let segments = host.split('.').collect::>();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11098"}},{"Add":{"text":" if segments.is_empty() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11131"}},{"Add":{"text":" warn!(\"Received an HTTP request with an empty Host header, returning a no ID error.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11230"}},{"Add":{"text":" return Err(InvocationError::NoId);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11277"}},{"Add":{"text":" } else if segments.len() < 2 {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11316"}},{"Add":{"text":" warn!(\"Received an HTTP request with a Host header that could not be transformed into an app ID: \\\"{}\\\"\", host);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11441"}},{"Add":{"text":" return Err(InvocationError::MalformedId(host.into()));","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11508"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11518"}},{"Add":{"text":" let req_simple = simplify_req(self).await?;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11570"}},{"Add":{"text":" let req_bytes = match serialize(&req_simple) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11625"}},{"Add":{"text":" Ok(b) => b,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11649"}},{"Add":{"text":" Err(_) => return Err(InvocationError::MalformedRequest)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11717"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11728"}},{"Add":{"text":" let result = Invocation {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11762"}},{"Add":{"text":" owner: segments[0].to_owned(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11805"}},{"Add":{"text":" app_name: segments[1].to_owned(),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11851"}},{"Add":{"text":" payload: req_bytes","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11882"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11893"}},{"Add":{"text":" Ok(result)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11912"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11918"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:11920"}},{"Add":{"text":"/// Parses a query string of the form \"a=b&c=d\" into params. Note: Hyper takes care of extracting said string out of a URI already, so no need to worry about ?.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12081"}},{"Add":{"text":"fn parse_query_string(s: &str) -> BTreeMap {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12142"}},{"Add":{"text":" let mut output = BTreeMap::new();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12180"}},{"Add":{"text":" let pairs = s.split(\"&\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12210"}},{"Add":{"text":" for pair in pairs {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12234"}},{"Add":{"text":" let mut param_val = pair.split(\"=\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12279"}},{"Add":{"text":" let param = match param_val.next() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12324"}},{"Add":{"text":" Some(p) => p,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12350"}},{"Add":{"text":" None => continue","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12379"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12390"}},{"Add":{"text":" let val = match param_val.next() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12433"}},{"Add":{"text":" Some(v) => v,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12459"}},{"Add":{"text":" None => continue","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12488"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12499"}},{"Add":{"text":" output.insert(param.to_owned(), val.to_owned());","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12556"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12562"}},{"Add":{"text":" output","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12573"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12575"}},{"Add":{"text":"/// Produces a map of cookies to their values given a cookie string.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12644"}},{"Add":{"text":"fn cookie_map(cookie_str: &str) -> BTreeMap {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12706"}},{"Add":{"text":" let mut output = BTreeMap::new();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12744"}},{"Add":{"text":" for cookie in cookie_str.split(\"; \") {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12787"}},{"Add":{"text":" let mut name_val = cookie.split(\"=\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12833"}},{"Add":{"text":" let name = match name_val.next() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12876"}},{"Add":{"text":" Some(n) => n,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12902"}},{"Add":{"text":" None => continue","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12931"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12942"}},{"Add":{"text":" let val = match name_val.next() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:12984"}},{"Add":{"text":" Some(v) => v,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13010"}},{"Add":{"text":" None => continue","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13039"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13050"}},{"Add":{"text":" output.insert(name.to_owned(), val.to_owned());","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13106"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13112"}},{"Add":{"text":" output","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13123"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13126"}}]}},{"FileAdd":{"meta":{"basename":"comms.rs","metadata":511},"path":"zhur_gate/src/comms.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use bincode::deserialize;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13165"}},{"Add":{"text":"use zhur_common::{bincode, log::warn, msg::chan::*, zmq};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13223"}},{"Add":{"text":"use zhur_invk::{HttpRes, Invocation, InvocationError};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13278"}},{"Add":{"text":"use zmq::{Context, Socket, SocketType};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13318"}},{"Add":{"text":"/// Struct responsible for relaying requests from the gateway to the core.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13393"}},{"Add":{"text":"pub struct Gate2CoreServer {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13422"}},{"Add":{"text":" /// ZMQ REQ socket.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13446"}},{"Add":{"text":" req_socket: Socket,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13470"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13472"}},{"Add":{"text":"impl Gate2CoreServer {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13495"}},{"Add":{"text":" pub fn new(zmq_ctx: &Context) -> Self {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13539"}},{"Add":{"text":" Self {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13554"}},{"Add":{"text":" req_socket: {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13580"}},{"Add":{"text":" let sck = zmq_ctx.socket(SocketType::REQ)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13638"}},{"Add":{"text":" .expect(\"Expected to be able to construct a socket.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13709"}},{"Add":{"text":" let endpoint = match std::env::var(\"ZHUR_CORE_REP_URI\") {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13783"}},{"Add":{"text":" Ok(s) => s,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13815"}},{"Add":{"text":" Err(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13847"}},{"Add":{"text":" warn!(\"ZHUR_CORE_REP_URI not set - assuming default value of tcp://127.0.0.1:8081!\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:13957"}},{"Add":{"text":" \"tcp://127.0.0.1:8081\".to_owned()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14015"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14037"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14056"}},{"Add":{"text":" sck.connect(&endpoint)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14095"}},{"Add":{"text":" .expect(\"Expected to be able to connect a REQ socket from the gateway to the core.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14197"}},{"Add":{"text":" sck","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14217"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14231"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14241"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14247"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14249"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14250"}},{"Add":{"text":"impl HandleRequest> for Gate2CoreServer {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14337"}},{"Add":{"text":" fn handle(&mut self, msg: Invocation) -> Result {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14417"}},{"Add":{"text":" let invoc_bytes = match bincode::serialize(&msg) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14476"}},{"Add":{"text":" Ok(b) => b,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14500"}},{"Add":{"text":" Err(_) => return Err(InvocationError::SerializeErr)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14564"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14575"}},{"Add":{"text":" match self.req_socket.send(invoc_bytes, 0) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14628"}},{"Add":{"text":" Ok(_) => (),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14653"}},{"Add":{"text":" Err(_) => return Err(InvocationError::NoCore)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14711"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14722"}},{"Add":{"text":" let response_bytes = match self.req_socket.recv_bytes(0) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14789"}},{"Add":{"text":" Ok(b) => b,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14813"}},{"Add":{"text":" Err(_) => return Err(InvocationError::MalformedReply)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14879"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14890"}},{"Add":{"text":" match deserialize(&response_bytes) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14935"}},{"Add":{"text":" Ok(r) => r,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:14959"}},{"Add":{"text":" Err(_) => Err(InvocationError::MalformedReply)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15018"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15028"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15034"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15037"}}]}},{"FileAdd":{"meta":{"basename":"README.md","metadata":511},"path":"zhur_gate/README.md","context":[{"change":4,"pos":12}],"contents":[{"Add":{"text":"# zhur_gate","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15063"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15064"}},{"Add":{"text":"This is the HTTP gateway for Zhur. Its task is to receive HTTP requests, transform them into Zhur invocations, and return the appropriate response.\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15213"}}]}},{"FileAdd":{"meta":{"basename":"Cargo.toml","metadata":511},"path":"zhur_gate/Cargo.toml","context":[{"change":4,"pos":12}],"contents":[{"Add":{"text":"[package]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15238"}},{"Add":{"text":"name = \"zhur_gate\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15257"}},{"Add":{"text":"description = \"Zhur HTTP gateway\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15291"}},{"Add":{"text":"version = \"0.1.0\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15309"}},{"Add":{"text":"authors = [\"oreganoli <3611916+oreganoli@users.noreply.github.com>\"]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15378"}},{"Add":{"text":"edition = \"2018\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15395"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15396"}},{"Add":{"text":"# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15493"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15494"}},{"Add":{"text":"[dependencies]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15509"}},{"Add":{"text":"zhur_common = { path = \"../zhur_common\" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15551"}},{"Add":{"text":"zhur_invk = { path = \"../zhur_invk\" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15589"}},{"Add":{"text":"http = { version = \"0.2.3\" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15618"}},{"Add":{"text":"hyper = { version = \"0.14.2\", features = [\"full\"] }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15670"}},{"Add":{"text":"tokio = { version = \"1.0.1\", features = [\"full\"] }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15721"}},{"Add":{"text":"serde = { version = \"1.0.118\", features = [\"derive\"] }\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15777"}}]}},{"FileDel":{"deleted_names":[{"basename":"README.md","metadata":511},{"basename":"README.md","metadata":420}],"path":"zhur_core/README.md","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":3,"start":1092,"end":1103},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":1103},"to":{"change":4,"start":2551,"end":2551},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":4,"start":2539,"end":2550},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":2550},"to":{"change":4,"start":2551,"end":2551},"introduced_by":4}],"inode":{"change":4,"pos":2551}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2551},"to":{"change":4,"start":2552,"end":2663},"introduced_by":4}],"inode":{"change":4,"pos":2551}},"content":[{"Del":{"text":"# zhur_core","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2563"}},{"Del":{"text":"","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2564"}},{"Del":{"text":"The core module of a Zhur installation. Handles incoming invocations with user-uploaded WASM code.","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2663"}}]}},{"FileDel":{"deleted_names":[{"basename":"Cargo.toml","metadata":511},{"basename":"Cargo.toml","metadata":436}],"path":"zhur_core/Cargo.toml","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":3,"start":1104,"end":1116},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":1116},"to":{"change":4,"start":2677,"end":2677},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":12},"to":{"change":4,"start":2664,"end":2676},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":2676},"to":{"change":4,"start":2677,"end":2677},"introduced_by":4}],"inode":{"change":4,"pos":2677}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2677},"to":{"change":4,"start":2678,"end":3004},"introduced_by":4}],"inode":{"change":4,"pos":2677}},"content":[{"Del":{"text":"[package]","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2687"}},{"Del":{"text":"name = \"zhur_core\"","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2706"}},{"Del":{"text":"version = \"0.1.0\"","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2724"}},{"Del":{"text":"authors = [\"oreganoli <3611916+oreganoli@users.noreply.github.com>\"]","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2793"}},{"Del":{"text":"edition = \"2018\"","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2810"}},{"Del":{"text":"","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2811"}},{"Del":{"text":"# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2908"}},{"Del":{"text":"","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2909"}},{"Del":{"text":"[dependencies]","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2924"}},{"Del":{"text":"zhur_common = { path = \"../zhur_common\" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2966"}},{"Del":{"text":"zhur_invk = { path = \"../zhur_invk\" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:3004"}}]}},{"FileDel":{"deleted_names":[{"basename":"main.rs","metadata":511},{"basename":"main.rs","metadata":420}],"path":"zhur_core/src/main.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":1049,"end":1058},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":1058},"to":{"change":4,"start":30,"end":30},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":20,"end":29},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":29},"to":{"change":4,"start":30,"end":30},"introduced_by":4}],"inode":{"change":4,"pos":30}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":30},"to":{"change":4,"start":31,"end":119},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1071},"to":{"change":4,"start":119,"end":271},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":119},"to":{"change":4,"start":119,"end":271},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":119},"to":{"change":3,"start":1059,"end":1060},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1070},"to":{"change":3,"start":1070,"end":1071},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1060},"to":{"change":3,"start":1060,"end":1070},"introduced_by":3}],"inode":{"change":4,"pos":30}},"content":[{"Del":{"text":"use zhur_core::CoreServer;","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:57"}},{"Del":{"text":"use zhur_common::zmq::Context;","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:88"}},{"Del":{"text":"use zhur_common::init_logger;","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:118"}},{"Del":{"text":"fn main() {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:130"}},{"Del":{"text":" init_logger();","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:149"}},{"Del":{"text":" let zmq_ctx = Context::new();","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:183"}},{"Del":{"text":" let server = CoreServer::new(&zmq_ctx);","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:227"}},{"Del":{"text":" loop {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:238"}},{"Del":{"text":" server.handle();","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:263"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:269"}},{"Del":{"text":"}","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:271"}},{"Del":{"text":"","pos":"NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC:1059"}},{"Del":{"text":"","pos":"NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC:1070"}},{"Del":{"text":"mod wasm;","pos":"NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC:1069"}}]}},{"FileDel":{"deleted_names":[{"basename":"lib.rs","metadata":511},{"basename":"lib.rs","metadata":436}],"path":"zhur_core/src/lib.rs","del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":3,"start":1072,"end":1080},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":1080},"to":{"change":4,"start":281,"end":281},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":19},"to":{"change":4,"start":272,"end":280},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":4,"pos":280},"to":{"change":4,"start":281,"end":281},"introduced_by":4}],"inode":{"change":4,"pos":281}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":281},"to":{"change":4,"start":282,"end":467},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1091},"to":{"change":4,"start":467,"end":1755},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":467},"to":{"change":4,"start":467,"end":1755},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1755},"to":{"change":4,"start":1755,"end":2360},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2360},"to":{"change":2,"start":0,"end":141},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":141},"to":{"change":4,"start":2436,"end":2538},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2436},"to":{"change":4,"start":2436,"end":2538},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":467},"to":{"change":3,"start":1081,"end":1091},"introduced_by":3}],"inode":{"change":4,"pos":281}},"content":[{"Del":{"text":"use zhur_common::bincode::{deserialize, serialize};","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:333"}},{"Del":{"text":"use zhur_common::log::*;","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:358"}},{"Del":{"text":"use zhur_common::zmq::{Context, Socket, SocketType};","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:411"}},{"Del":{"text":"use zhur_invk::{HttpRes, Invocation, InvocationError};","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:466"}},{"Del":{"text":"/// The ZMQ server that takes invocations incoming from the gateway and sends back HttpReses or InvocationErrors.","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:580"}},{"Del":{"text":"pub struct CoreServer {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:604"}},{"Del":{"text":" rep_socket: Socket","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:627"}},{"Del":{"text":"}","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:629"}},{"Del":{"text":"impl CoreServer {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:647"}},{"Del":{"text":" pub fn new(zmq_ctx: &Context) -> Self {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:691"}},{"Del":{"text":" Self {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:706"}},{"Del":{"text":" rep_socket: {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:732"}},{"Del":{"text":" let socket = zmq_ctx.socket(SocketType::REP)","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:793"}},{"Del":{"text":" .expect(\"Expected to be able to construct a ZMQ socket.\");","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:868"}},{"Del":{"text":" let endpoint = match std::env::var(\"ZHUR_CORE_REP_URI\") {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:942"}},{"Del":{"text":" Ok(s) => s,","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:974"}},{"Del":{"text":" Err(_) => {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1006"}},{"Del":{"text":" warn!(\"ZHUR_CORE_REP_URI not set - assuming default value of tcp://127.0.0.1:8081!\");","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1116"}},{"Del":{"text":" \"tcp://127.0.0.1:8081\".to_owned()","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1174"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1196"}},{"Del":{"text":" };","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1215"}},{"Del":{"text":" socket.bind(&endpoint)","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1254"}},{"Del":{"text":" .expect(\"Expected to be able to bind the core server socket.\");","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1334"}},{"Del":{"text":" socket","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1357"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1371"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1381"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1387"}},{"Del":{"text":" pub fn handle(&self) {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1414"}},{"Del":{"text":" let bytes = match self.rep_socket.recv_bytes(0) {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1472"}},{"Del":{"text":" Ok(b) => {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1495"}},{"Del":{"text":" trace!(\"CoreServer received some bytes.\");","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1554"}},{"Del":{"text":" b","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1572"}},{"Del":{"text":" },","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1587"}},{"Del":{"text":" Err(_) => {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1611"}},{"Del":{"text":" panic!(\"CoreServer could not receive any bytes.\")","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1677"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1691"}},{"Del":{"text":" };","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1702"}},{"Del":{"text":" let response = handle_invoke_bytes(&bytes);","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1754"}},{"Del":{"text":" let res_bytes = match serialize(&response) {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1807"}},{"Del":{"text":" Ok(b) => b,","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1831"}},{"Del":{"text":" Err(_) => panic!(\"Could not serialize a response.\")","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1895"}},{"Del":{"text":" };","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1906"}},{"Del":{"text":" match self.rep_socket.send(res_bytes, 0) {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1957"}},{"Del":{"text":" Ok(_) => {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:1980"}},{"Del":{"text":" trace!(\"Sent a response!\");","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2024"}},{"Del":{"text":" ()","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2043"}},{"Del":{"text":" },","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2058"}},{"Del":{"text":" Err(_) => panic!(\"Could not send a reply.\")","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2114"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2124"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2130"}},{"Del":{"text":"}","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2132"}},{"Del":{"text":"","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2133"}},{"Del":{"text":"fn handle_invoke_bytes(bytes: &[u8]) -> Result {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2208"}},{"Del":{"text":" match deserialize::(bytes) {","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2253"}},{"Del":{"text":" Ok(i) => handle_invocation(&i),","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2293"}},{"Del":{"text":" Err(_) => Err(InvocationError::MalformedRequest)","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2350"}},{"Del":{"text":" }","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2356"}},{"Del":{"text":"}","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2358"}},{"Del":{"text":"","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2359"}},{"Del":{"text":"fn handle_invocation(i: &Invocation) -> Result {","pos":"H5IHJUKQYZNZZ4FMUCOAPH4XCALZ7TSUYFIVMYBOI2MBRV4GVUVQC:74"}},{"Del":{"text":" trace!(\"Got an invocation for {}:{}\", &i.owner, &i.app_name);","pos":"H5IHJUKQYZNZZ4FMUCOAPH4XCALZ7TSUYFIVMYBOI2MBRV4GVUVQC:140"}},{"Del":{"text":" let mut res = HttpRes::default();","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2473"}},{"Del":{"text":" res.body = b\"Hello world from Zhur!\".to_vec();","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2524"}},{"Del":{"text":" Ok(res)","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2536"}},{"Del":{"text":"}","pos":"BMWVMVJ527SZSVE7VKP5IAAOKNZPAFJ2RKQKXHWU7QTOX4OZUPHQC:2538"}},{"Del":{"text":"mod wasm;","pos":"NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC:1090"}}]}},{"Replacement":{"inode":{"change":3,"pos":147},"path":"zhur_core/src/wasm.rs","line":5,"ins":{"up_context":[{"change":3,"pos":295}],"down_context":[],"flag":"BLOCK","start":15779,"end":15833,"inode":{"change":3,"pos":147}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":295},"to":{"change":3,"start":295,"end":310},"introduced_by":3}],"inode":{"change":3,"pos":147}},"ins_contents":[{"Add":{"text":"pub mod pool;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15792"}},{"Add":{"text":"/// Executor module.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15813"}},{"Add":{"text":"pub mod executor;\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15832"}}],"del_contents":[{"Del":{"text":"pub mod pool;\\","pos":"NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC:309"}}]}},{"Replacement":{"inode":{"change":3,"pos":329},"path":"zhur_core/src/wasm/pool.rs","line":16,"ins":{"up_context":[{"change":3,"pos":1045}],"down_context":[],"flag":"BLOCK","start":15834,"end":15837,"inode":{"change":3,"pos":329}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1045},"to":{"change":3,"start":1045,"end":1048},"introduced_by":3}],"inode":{"change":3,"pos":329}},"ins_contents":[{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15836"}}],"del_contents":[{"Del":{"text":"}\\","pos":"NUXZXM3D64JDAP7TVBAY23Z43RW27JL4XHVOEXFLT5CLDU6CVOOAC:1047"}}]}},{"FileAdd":{"meta":{"basename":"executor.rs","metadata":420},"path":"zhur_core/src/wasm/executor.rs","context":[{"change":3,"pos":318}],"contents":[{"Add":{"text":"use std::thread::JoinHandle;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15881"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15882"}},{"Add":{"text":"use zhur_common::{flume::Sender, log::*, msg::chan::Envelope};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:15945"}},{"Add":{"text":"use zhur_invk::{HttpRes, Invocation, InvocationError};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16000"}},{"Add":{"text":"pub struct Executor {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16022"}},{"Add":{"text":" /// The identifying number of the executor.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16070"}},{"Add":{"text":" pub id: usize,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16089"}},{"Add":{"text":" /// The username of this app's owner.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16131"}},{"Add":{"text":" pub owner: String,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16154"}},{"Add":{"text":" /// The name of the app currently held in the executor.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16214"}},{"Add":{"text":" pub app_name: String,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16240"}},{"Add":{"text":" /// Sender for passing messages to the executor's `inner_thread`.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16310"}},{"Add":{"text":" msg_tx: Sender,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16343"}},{"Add":{"text":" /// The thread that holds the actual code engine.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16397"}},{"Add":{"text":" inner_thread: JoinHandle<()>,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16431"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16433"}},{"Add":{"text":"/// Messages sent by the outer executor to its inner thread.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16494"}},{"Add":{"text":"pub enum ExecutorMsg {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16517"}},{"Add":{"text":" /// Replace the WASM code currently loaded. Issued on app updates or substitutions.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16605"}},{"Add":{"text":" LoadCode(Vec),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16628"}},{"Add":{"text":" /// Self-explanatory.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16654"}},{"Add":{"text":" Invoke(Envelope>),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16722"}},{"Add":{"text":" /// Shut the inner thread down.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16758"}},{"Add":{"text":" Shutdown","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16771"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16773"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16774"}},{"Add":{"text":"impl Executor {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16790"}},{"Add":{"text":" pub fn shutdown(self) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16818"}},{"Add":{"text":" match self.msg_tx.send(ExecutorMsg::Shutdown) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16874"}},{"Add":{"text":" Ok(_) => (),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16899"}},{"Add":{"text":" Err(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:16923"}},{"Add":{"text":" let text = format!(\"Executor #{} could not send a shutdown message to its inner thread!\", self.id);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17039"}},{"Add":{"text":" error!(\"{}\", &text);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17076"}},{"Add":{"text":" panic!(\"{}\", &text);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17113"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17127"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17137"}},{"Add":{"text":" match self.inner_thread.join() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17178"}},{"Add":{"text":" Ok(_) => (),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17203"}},{"Add":{"text":" Err(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17227"}},{"Add":{"text":" let text = format!(\"Executor #{} could not join on its inner thread!\", self.id);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17324"}},{"Add":{"text":" error!(\"{}\", &text);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17361"}},{"Add":{"text":" panic!(\"{}\", &text);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17398"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17412"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17422"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17428"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17431"}}]}},{"FileAdd":{"meta":{"basename":"main.rs","metadata":511},"path":"zhur_core/src/main.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use zhur_core::CoreServer;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17470"}},{"Add":{"text":"use zhur_common::zmq::Context;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17501"}},{"Add":{"text":"use zhur_common::init_logger;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17531"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17532"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17533"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17534"}},{"Add":{"text":"fn main() {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17546"}},{"Add":{"text":" init_logger();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17565"}},{"Add":{"text":" let zmq_ctx = Context::new();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17599"}},{"Add":{"text":" let server = CoreServer::new(&zmq_ctx);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17643"}},{"Add":{"text":" loop {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17654"}},{"Add":{"text":" server.handle();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17679"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17685"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17688"}}]}},{"FileAdd":{"meta":{"basename":"lib.rs","metadata":511},"path":"zhur_core/src/lib.rs","context":[{"change":4,"pos":19}],"contents":[{"Add":{"text":"use zhur_common::bincode::{deserialize, serialize};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17751"}},{"Add":{"text":"use zhur_common::log::*;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17776"}},{"Add":{"text":"use zhur_common::zmq::{Context, Socket, SocketType};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17829"}},{"Add":{"text":"use zhur_invk::{HttpRes, Invocation, InvocationError};","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17884"}},{"Add":{"text":"mod wasm;","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:17894"}},{"Add":{"text":"/// The ZMQ server that takes invocations incoming from the gateway and sends back HttpReses or InvocationErrors.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18008"}},{"Add":{"text":"pub struct CoreServer {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18032"}},{"Add":{"text":" rep_socket: Socket","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18055"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18057"}},{"Add":{"text":"impl CoreServer {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18075"}},{"Add":{"text":" pub fn new(zmq_ctx: &Context) -> Self {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18119"}},{"Add":{"text":" Self {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18134"}},{"Add":{"text":" rep_socket: {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18160"}},{"Add":{"text":" let socket = zmq_ctx.socket(SocketType::REP)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18221"}},{"Add":{"text":" .expect(\"Expected to be able to construct a ZMQ socket.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18296"}},{"Add":{"text":" let endpoint = match std::env::var(\"ZHUR_CORE_REP_URI\") {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18370"}},{"Add":{"text":" Ok(s) => s,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18402"}},{"Add":{"text":" Err(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18434"}},{"Add":{"text":" warn!(\"ZHUR_CORE_REP_URI not set - assuming default value of tcp://127.0.0.1:8081!\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18544"}},{"Add":{"text":" \"tcp://127.0.0.1:8081\".to_owned()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18602"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18624"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18643"}},{"Add":{"text":" socket.bind(&endpoint)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18682"}},{"Add":{"text":" .expect(\"Expected to be able to bind the core server socket.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18762"}},{"Add":{"text":" socket","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18785"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18799"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18809"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18815"}},{"Add":{"text":" pub fn handle(&self) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18842"}},{"Add":{"text":" let bytes = match self.rep_socket.recv_bytes(0) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18900"}},{"Add":{"text":" Ok(b) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18923"}},{"Add":{"text":" trace!(\"CoreServer received some bytes.\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:18982"}},{"Add":{"text":" b","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19000"}},{"Add":{"text":" },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19015"}},{"Add":{"text":" Err(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19039"}},{"Add":{"text":" panic!(\"CoreServer could not receive any bytes.\")","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19105"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19119"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19130"}},{"Add":{"text":" let response = handle_invoke_bytes(&bytes);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19182"}},{"Add":{"text":" // TODO: There is no need to deserialize into HttpReses or InvocationErrors within the core. The gateway does that anyway.","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19313"}},{"Add":{"text":" let res_bytes = match serialize(&response) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19366"}},{"Add":{"text":" Ok(b) => b,","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19390"}},{"Add":{"text":" Err(_) => panic!(\"Could not serialize a response.\")","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19454"}},{"Add":{"text":" };","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19465"}},{"Add":{"text":" match self.rep_socket.send(res_bytes, 0) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19516"}},{"Add":{"text":" Ok(_) => {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19539"}},{"Add":{"text":" trace!(\"Sent a response!\");","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19583"}},{"Add":{"text":" ()","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19602"}},{"Add":{"text":" },","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19617"}},{"Add":{"text":" Err(_) => panic!(\"Could not send a reply.\")","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19673"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19683"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19689"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19691"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19692"}},{"Add":{"text":"fn handle_invoke_bytes(bytes: &[u8]) -> Result {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19767"}},{"Add":{"text":" match deserialize::(bytes) {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19812"}},{"Add":{"text":" Ok(i) => handle_invocation(&i),","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19852"}},{"Add":{"text":" Err(_) => Err(InvocationError::MalformedRequest)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19909"}},{"Add":{"text":" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19915"}},{"Add":{"text":"}","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19917"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19918"}},{"Add":{"text":"fn handle_invocation(i: &Invocation) -> Result {","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:19993"}},{"Add":{"text":" trace!(\"Got an invocation for {}:{}\", &i.owner, &i.app_name);","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20059"}},{"Add":{"text":" let mut res = HttpRes::default();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20097"}},{"Add":{"text":" res.body = b\"Hello world from Zhur!\".to_vec();","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20148"}},{"Add":{"text":" Ok(res)","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20160"}},{"Add":{"text":"}\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20163"}}]}},{"FileAdd":{"meta":{"basename":"README.md","metadata":511},"path":"zhur_core/README.md","context":[{"change":4,"pos":12}],"contents":[{"Add":{"text":"# zhur_core","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20189"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20190"}},{"Add":{"text":"The core module of a Zhur installation. Handles incoming invocations with user-uploaded WASM code.\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20290"}}]}},{"FileAdd":{"meta":{"basename":"Cargo.toml","metadata":511},"path":"zhur_core/Cargo.toml","context":[{"change":4,"pos":12}],"contents":[{"Add":{"text":"[package]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20315"}},{"Add":{"text":"name = \"zhur_core\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20334"}},{"Add":{"text":"version = \"0.1.0\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20352"}},{"Add":{"text":"authors = [\"oreganoli <3611916+oreganoli@users.noreply.github.com>\"]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20421"}},{"Add":{"text":"edition = \"2018\"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20438"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20439"}},{"Add":{"text":"# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20536"}},{"Add":{"text":"","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20537"}},{"Add":{"text":"[dependencies]","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20552"}},{"Add":{"text":"zhur_common = { path = \"../zhur_common\" }","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20594"}},{"Add":{"text":"zhur_invk = { path = \"../zhur_invk\" }\\","pos":"TUZICZZDQKNR7ZJGOEFQ4LJZDA5H4UHG4ATBAQOBXLQNY2R6IO5QC:20633"}}]}},{"FileMove":{"meta":{"basename":"msg.rs","metadata":511},"path":"zhur_common/src/msg.rs","to_path":"msg.rs","old":[{"basename":"msg.rs","metadata":511}],"up":[{"change":4,"pos":21}],"down":[{"change":4,"pos":9}],"show_perms":false}},{"FileMove":{"meta":{"basename":"chan.rs","metadata":511},"path":"zhur_common/src/msg/chan.rs","to_path":"chan.rs","old":[{"basename":"chan.rs","metadata":511}],"up":[{"change":4,"pos":73}],"down":[{"change":4,"pos":84}],"show_perms":false}},{"FileMove":{"meta":{"basename":"lib.rs","metadata":511},"path":"zhur_common/src/lib.rs","to_path":"lib.rs","old":[{"basename":"lib.rs","metadata":511}],"up":[{"change":4,"pos":21}],"down":[{"change":4,"pos":31}],"show_perms":false}},{"FileMove":{"meta":{"basename":"README.md","metadata":511},"path":"zhur_common/README.md","to_path":"README.md","old":[{"basename":"README.md","metadata":511}],"up":[{"change":4,"pos":14}],"down":[{"change":4,"pos":129}],"show_perms":false}},{"FileMove":{"meta":{"basename":"Cargo.toml","metadata":511},"path":"zhur_common/Cargo.toml","to_path":"Cargo.toml","old":[{"basename":"Cargo.toml","metadata":511}],"up":[{"change":4,"pos":14}],"down":[{"change":4,"pos":220}],"show_perms":false}},{"FileMove":{"meta":{"basename":"README.md","metadata":511},"path":"README.md","to_path":"README.md","old":[{"basename":"README.md","metadata":511}],"up":[{"change":1,"pos":0}],"down":[{"change":4,"pos":12}],"show_perms":false}},{"FileMove":{"meta":{"basename":"Cargo.toml","metadata":511},"path":"Cargo.toml","to_path":"Cargo.toml","old":[{"basename":"Cargo.toml","metadata":511}],"up":[{"change":1,"pos":0}],"down":[{"change":4,"pos":689}],"show_perms":false}},{"FileMove":{"meta":{"basename":"Cargo.lock","metadata":511},"path":"Cargo.lock","to_path":"Cargo.lock","old":[{"basename":"Cargo.lock","metadata":511}],"up":[{"change":1,"pos":0}],"down":[{"change":4,"pos":741}],"show_perms":false}}],"owner":"oreganoli","repo":"zhur","login":null}

…

Dependencies

Change contents

Review