{"header":{"message":"Upgrade status parsing","description":null,"timestamp":"2023-07-13T10:26:37.095851965Z","authors":[{}]},"hash":"AMTMTTJTF2XHEUC6ACP2PHP7GAFMFZRSJ47VJBKEO22X4ZGFIX7QC","authors":[{"login":"CandyCorvid","key":"2nxySdD32H8TtzYpnH4CSW8jXS2rPVRjW8JNU3HGe7JX"}],"deps":{"hashes":[["AMTMTTJTF2XHEUC6ACP2PHP7GAFMFZRSJ47VJBKEO22X4ZGFIX7QC","Upgrade status parsing"],["AA",null],["DBKKKHC2ER7XAYR6HAFQ6I75M3OLDOSGCB5BTEP7X6XAZRSWKIRAC","Initial commit"]],"deps":["DBKKKHC2ER7XAYR6HAFQ6I75M3OLDOSGCB5BTEP7X6XAZRSWKIRAC"],"known":[]},"hunks":[{"Edit":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":1,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":3665}],"down_context":[{"change":2,"pos":3666}],"flag":"BLOCK","start":0,"end":19,"inode":{"change":2,"pos":3665}}},"contents":[{"Add":"use bstr::ByteVec;"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":4,"ins":{"up_context":[{"change":2,"pos":3712}],"down_context":[{"change":2,"pos":3756}],"flag":"BLOCK","start":20,"end":50,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":3712},"to":{"change":2,"start":3712,"end":3756},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":"use rustls::ClientConnection;"}],"del_contents":[{"Del":"use rustls::{ClientConnection, ServerName};\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":6,"ins":{"up_context":[{"change":2,"pos":3767}],"down_context":[{"change":2,"pos":3807}],"flag":"BLOCK","start":51,"end":105,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":3767},"to":{"change":2,"start":3767,"end":3807},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":" io::{BufReader, Read, Result as ioResult, Write},"}],"del_contents":[{"Del":" io::{self, BufReader, Read, Write},\n"}]}},{"Edit":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":8,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":3827},"to":{"change":2,"start":3827,"end":3842},"introduced_by":2}],"inode":{"change":2,"pos":3665}}},"contents":[{"Del":" sync::Arc,\n"}]}},{"Edit":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":3859}],"down_context":[{"change":2,"pos":3859}],"flag":"BLOCK","start":106,"end":321,"inode":{"change":2,"pos":3665}}},"contents":[{"Add":""},{"Add":"mod danger;"},{"Add":"mod io;"},{"Add":"mod read_until;"},{"Add":"//TODO: refactor and repurpose this"},{"Add":"mod response;"},{"Add":"mod server;"},{"Add":""},{"Add":"mod cl {"},{"Add":" use clap::Parser;"},{"Add":" #[derive(Parser)]"},{"Add":" pub struct App {"},{"Add":" pub url: Option,"},{"Add":" }"},{"Add":"}"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":37,"ins":{"up_context":[{"change":2,"pos":4208}],"down_context":[{"change":2,"pos":4244}],"flag":"BLOCK","start":322,"end":383,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":4208},"to":{"change":2,"start":4208,"end":4244},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":" let mut stream = server::connect::(&url);"}],"del_contents":[{"Del":" let mut stream = connect(&url);\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":48,"ins":{"up_context":[{"change":2,"pos":4504}],"down_context":[{"change":2,"pos":4547}],"flag":"BLOCK","start":384,"end":427,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":4504},"to":{"change":2,"start":4504,"end":4547},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":"// TODO parse from 2-digit response header"}],"del_contents":[{"Del":"// todo parse from 2-digit response header\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":50,"ins":{"up_context":[{"change":2,"pos":4568}],"down_context":[{"change":2,"pos":4586}],"flag":"BLOCK","start":428,"end":446,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":4568},"to":{"change":2,"start":4568,"end":4586},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":"// TODO parse etc"}],"del_contents":[{"Del":"// todo parse etc\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":52,"ins":{"up_context":[{"change":2,"pos":4607}],"down_context":[{"change":2,"pos":4768}],"flag":"BLOCK","start":447,"end":652,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":4607},"to":{"change":2,"start":4607,"end":4768},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":""},{"Add":"fn read_response_header(stream: &mut Stream) -> ioResult {"},{"Add":" let status = io::read_n::<2>(stream)?;"},{"Add":" let status = status.map(|s| s.checked_sub(b'0').expect(\"bad status fragment\"));"}],"del_contents":[{"Del":"fn read_response_header(\n stream: &mut rustls::StreamOwned,\n) -> io::Result<(Code, Meta)> {\n let code = read_n::<2>(stream)?;\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":57,"ins":{"up_context":[{"change":2,"pos":4769}],"down_context":[{"change":2,"pos":4801}],"flag":"BLOCK","start":653,"end":689,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":4769},"to":{"change":2,"start":4769,"end":4801},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":" let c = io::read_byte(stream)?;"}],"del_contents":[{"Del":" let c = read_byte(stream)?;\n"}]}},{"Edit":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":63,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":4929}],"down_context":[{"change":2,"pos":4929}],"flag":"BLOCK","start":690,"end":716,"inode":{"change":2,"pos":3665}}},"contents":[{"Add":" // TODO limit to 1024"}]}},{"Edit":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":66,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":5032}],"down_context":[{"change":2,"pos":5032}],"flag":"BLOCK","start":717,"end":782,"inode":{"change":2,"pos":3665}}},"contents":[{"Add":" // drop last 2"},{"Add":" for _ in 0..2 {"},{"Add":" meta.pop();"},{"Add":" }"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":71,"ins":{"up_context":[{"change":2,"pos":5033}],"down_context":[{"change":2,"pos":5056}],"flag":"BLOCK","start":783,"end":909,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":5033},"to":{"change":2,"start":5033,"end":5056},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":" let meta = meta.into_string().expect(\"Meta was not valid UTF8\");"},{"Add":" let header = response::raw::Header { meta, status };"}],"del_contents":[{"Del":" Ok((code, meta))\n}\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":74,"ins":{"up_context":[{"change":2,"pos":5057}],"down_context":[{"change":2,"pos":5073}],"flag":"BLOCK","start":910,"end":971,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":5057},"to":{"change":2,"start":5057,"end":5073},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":" Ok(header.try_into().expect(\"failed to parse header\"))"},{"Add":"}"}],"del_contents":[{"Del":"mod read_until;\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":77,"ins":{"up_context":[{"change":2,"pos":5074}],"down_context":[{"change":2,"pos":5192}],"flag":"BLOCK","start":972,"end":1039,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":5074},"to":{"change":2,"start":5074,"end":5192},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":"fn read_response_string(stream: &mut Stream) -> ioResult {"}],"del_contents":[{"Del":"fn read_response_string(\n stream: &mut rustls::StreamOwned,\n) -> io::Result {\n"}]}},{"Edit":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":81,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":5278},"to":{"change":2,"start":5278,"end":5633},"introduced_by":2}],"inode":{"change":2,"pos":3665}}},"contents":[{"Del":"}\n\nfn read_byte(\n stream: &mut rustls::StreamOwned,\n) -> Result {\n let [c] = read_n::<1>(stream)?;\n Ok(c)\n}\n\nfn read_n(\n stream: &mut rustls::StreamOwned,\n) -> io::Result<[u8; N]> {\n let mut buf = [0; N];\n stream.read_exact(&mut buf)?;\n Ok(buf)\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":83,"ins":{"up_context":[{"change":2,"pos":5636}],"down_context":[{"change":2,"pos":5727}],"flag":"BLOCK","start":1040,"end":1093,"inode":{"change":2,"pos":3665}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":5636},"to":{"change":2,"start":5636,"end":5727},"introduced_by":2}],"inode":{"change":2,"pos":3665}},"ins_contents":[{"Add":"fn send_request(stream: &mut impl Write, url: Url) {"}],"del_contents":[{"Del":"fn send_request(stream: &mut rustls::StreamOwned, url: Url) {\n"}]}},{"Edit":{"inode":{"change":2,"pos":3665},"path":"src/main.rs","line":87,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":5853},"to":{"change":2,"start":5853,"end":7895},"introduced_by":2}],"inode":{"change":2,"pos":3665}}},"contents":[{"Del":"\nfn connect(url: &Url) -> rustls::StreamOwned {\n let host = url.host().expect(\"\");\n let sn = server(host);\n let stream = {\n let cfg = tls_cfg();\n let conn = {\n let client = ClientConnection::new(cfg, sn).expect(\"could not connect\");\n client\n };\n let addrs = url\n .socket_addrs(|| Some(1965))\n .expect(\"could not get addresses for URL\");\n let addr = addrs.get(0).expect(\"no addresses\");\n let sock = TcpStream::connect(addr).expect(\"failed to connect\");\n let stream = Stream { conn, sock };\n stream\n };\n stream\n}\n\nfn server(host: url::Host<&str>) -> ServerName {\n let url::Host::Domain(s) = host\n else {unreachable!(\"the url is always a string\")};\n let sn = s.try_into().expect(\"this should be a valid DNS name\");\n sn\n}\n\nfn tls_cfg() -> Arc {\n let root_store = rustls::RootCertStore::empty();\n let cfg = {\n let mut cfg = rustls::ClientConfig::builder()\n .with_safe_defaults()\n .with_root_certificates(root_store)\n .with_no_client_auth();\n cfg.dangerous()\n .set_certificate_verifier(Arc::new(danger::Naive {}));\n Arc::new(cfg)\n };\n cfg\n}\n\nmod danger {\n use std::time::SystemTime;\n\n use rustls::{client::ServerCertVerified, Certificate, Error, ServerName};\n\n // unconditionally trusts\n pub struct Naive;\n // trust on first use\n pub struct Tofu {}\n impl rustls::client::ServerCertVerifier for Naive {\n fn verify_server_cert(\n &self,\n _: &Certificate,\n _: &[Certificate],\n _: &ServerName,\n _: &mut dyn Iterator,\n _: &[u8],\n _: SystemTime,\n ) -> Result {\n Ok(ServerCertVerified::assertion())\n }\n }\n}\n\nmod cl {\n use clap::Parser;\n #[derive(Parser)]\n pub struct App {\n pub url: Option,\n }\n}\n"}]}}],"owner":"CandyCorvid","repo":"gemini","token":"amF+FP/NtZiud843vSNw99n1wx2ab3k9oskc/2x3yg8=","login":null}

…

Dependencies

Change contents