Adding support for http report method (#741)

Author: hkotian

worker-sandbox/tests/request.spec.ts

@@ -108,7 +108,7 @@ test("fetch json", async () => {
 
 test("proxy request", async () => {
   const resp = await mf.dispatchFetch(
-    "https://fake.host/proxy_request/https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers/Content-Encoding/contributors.txt"
+    "https://fake.host/proxy_request/https://developer.mozilla.org/en-US/docs/Web/HTTP/Reference/Headers/Content-Encoding/contributors.txt"
   );
   expect(resp.status).toBe(200);
 });

worker/src/http.rs

@@ -25,6 +25,7 @@ pub enum Method {
     Options,
     Connect,
     Trace,
+    Report,
 }
 
 impl Method {
@@ -39,6 +40,7 @@ impl Method {
             Method::Options,
             Method::Connect,
             Method::Trace,
+            Method::Report,
         ]
     }
 }
@@ -54,6 +56,7 @@ impl From<String> for Method {
             "OPTIONS" => Method::Options,
             "CONNECT" => Method::Connect,
             "TRACE" => Method::Trace,
+            "REPORT" => Method::Report,
             _ => Method::Get,
         }
     }
@@ -77,6 +80,7 @@ impl AsRef<str> for Method {
             Method::Connect => "CONNECT",
             Method::Trace => "TRACE",
             Method::Get => "GET",
+            Method::Report => "REPORT",
         }
     }
 }

worker/src/router.rs

@@ -173,6 +173,12 @@ impl<'a, D: 'a> Router<'a, D> {
         self
     }
 
+    /// Register an HTTP handler that will exclusively respond to REPORT requests.
+    pub fn report(mut self, pattern: &str, func: HandlerFn<D>) -> Self {
+        self.add_handler(pattern, Handler::Sync(func), vec![Method::Report]);
+        self
+    }
+
     /// Register an HTTP handler that will respond to any requests.
     pub fn on(mut self, pattern: &str, func: HandlerFn<D>) -> Self {
         self.add_handler(pattern, Handler::Sync(func), Method::all());

worker/src/socket.rs

@@ -1,6 +1,5 @@
 use std::{
     convert::TryFrom,
-    io::ErrorKind,
     pin::Pin,
     task::{Context, Poll},
 };
@@ -150,7 +149,7 @@ fn js_value_to_std_io_error(value: JsValue) -> IoError {
     } else {
         format!("Error interpreting JsError: {:?}", value)
     };
-    IoError::new(ErrorKind::Other, s)
+    IoError::other(s)
 }
 impl AsyncRead for Socket {
     fn poll_read(
@@ -173,10 +172,7 @@ impl AsyncRead for Socket {
                             Ok(value) => value.into(),
                             Err(error) => {
                                 let msg = format!("Unable to interpret field 'done' in ReadableStreamDefaultReader.read(): {:?}", error);
-                                return (
-                                    Reading::None,
-                                    Poll::Ready(Err(IoError::new(ErrorKind::Other, msg))),
-                                );
+                                return (Reading::None, Poll::Ready(Err(IoError::other(msg))));
                             }
                         };
                         if done.is_truthy() {
@@ -189,10 +185,7 @@ impl AsyncRead for Socket {
                                 Ok(value) => value.into(),
                                 Err(error) => {
                                     let msg = format!("Unable to interpret field 'value' in ReadableStreamDefaultReader.read(): {:?}", error);
-                                    return (
-                                        Reading::None,
-                                        Poll::Ready(Err(IoError::new(ErrorKind::Other, msg))),
-                                    );
+                                    return (Reading::None, Poll::Ready(Err(IoError::other(msg))));
                                 }
                             };
                             let data = arr.to_vec();
@@ -214,7 +207,7 @@ impl AsyncRead for Socket {
                                 "Unable to cast JsObject to ReadableStreamDefaultReader: {:?}",
                                 error
                             );
-                            return Poll::Ready(Err(IoError::new(ErrorKind::Other, msg)));
+                            return Poll::Ready(Err(IoError::other(msg)));
                         }
                     };
 
@@ -241,7 +234,7 @@ impl AsyncWrite for Socket {
                     Ok(writer) => writer,
                     Err(error) => {
                         let msg = format!("Could not retrieve Writer: {:?}", error);
-                        return Poll::Ready(Err(IoError::new(ErrorKind::Other, msg)));
+                        return Poll::Ready(Err(IoError::other(msg)));
                     }
                 };
                 Self::handle_write_future(