1 files changed, 56 insertions, 0 deletions
diff --git a/pkgs/profpatsch/xdg-open/read-http.rs b/pkgs/profpatsch/xdg-open/read-http.rs
new file mode 100644
index 00000000..9fe8d6a9
--- /dev/null
+++ b/pkgs/profpatsch/xdg-open/read-http.rs
@@ -0,0 +1,56 @@
+extern crate httparse;
+extern crate netencode;
+
+use std::os::unix::io::FromRawFd;
+use std::io::Read;
+use std::io::Write;
+
+use netencode::{encode, U};
+
+fn main() -> std::io::Result<()> {
+
+    fn die<T: std::fmt::Display>(msg: T) {
+        eprintln!("{}", msg);
+        std::process::exit(1);
+    }
+
+    // max header size chosen arbitrarily
+    let mut headers = [httparse::EMPTY_HEADER; 128];
+    let mut resp = httparse::Response::new(&mut headers);
+    let mut buf = vec![];
+    std::io::stdin().read_to_end(&mut buf)?;
+    let res = resp.parse(&mut buf);
+    match res {
+        Err(err) => die(format!("http response error: {:?}", err)),
+        Ok(_start_of_body) => {
+            match resp.code {
+                Some(code) => write_dict(code, resp.reason, resp.headers)?,
+                None => die(format!("no http status"))
+            }
+        }
+    };
+    Ok(())
+}
+
+fn write_dict<'buf>(code: u16, reason: Option<&'buf str>, headers: &mut [httparse::Header<'buf>]) -> std::io::Result<()> {
+    let mut http = vec![
+        ("status", Box::new(U::N6(code as u64))),
+    ];
+
+    if let Some(t) = reason {
+        http.push(("status-text", Box::new(U::Text(t.as_bytes()))))
+    };
+
+    http.push(("headers", Box::new(U::Record(
+        headers.iter_mut().map(
+            |httparse::Header { name, value }|
+            (*name,
+             Box::new(U::Binary(value)))
+        ).collect::<Vec<_>>()
+    ))));
+
+    encode(
+        &mut std::io::stdout(),
+        U::Record(http)
+    )
+}