Rewrite WebSockets code (#4)

* redo websockets

* docs + tests

* remove gloo-console

* fix CI

* Add getters for the underlying WebSocket fields

* better API

* better API part 2 electric boogaloo

Author: ranile

.idea/reqwasm.iml

@@ -23,6 +23,9 @@ anyhow = "1.0"
 thiserror = "1.0"
 futures = "0.3.14"
 
+async-broadcast = "0.3"
+pin-project = "1"
+
 [dependencies.web-sys]
 version = "0.3.4"
 features = [
@@ -42,6 +45,7 @@ features = [
     'Blob',
     'FormData',
     'FileReader',
+    'CloseEvent',
 
     'WebSocket',
     'ErrorEvent',

Cargo.toml

@@ -2,7 +2,7 @@ use std::fmt;
 use thiserror::Error as ThisError;
 use wasm_bindgen::{JsCast, JsValue};
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 #[doc(hidden)]
 pub struct JsError {
     pub name: String,
@@ -35,12 +35,16 @@ pub enum Error {
 }
 
 pub(crate) fn js_to_error(js_value: JsValue) -> Error {
+    Error::JsError(js_to_js_error(js_value))
+}
+
+pub(crate) fn js_to_js_error(js_value: JsValue) -> JsError {
     match js_value.dyn_into::<js_sys::Error>() {
-        Ok(error) => Error::JsError(JsError {
+        Ok(error) => JsError {
             name: String::from(error.name()),
             message: String::from(error.message()),
             js_to_string: String::from(error.to_string()),
-        }),
+        },
         Err(_) => unreachable!("JsValue passed is not an Error type -- this is a bug"),
     }
 }

src/error.rs

@@ -0,0 +1,19 @@
+//! WebSocket Events
+
+/// This is created from [`ErrorEvent`][web_sys::ErrorEvent] received from `onerror` listener of the WebSocket.
+#[derive(Clone, Debug)]
+pub struct ErrorEvent {
+    /// The error message.
+    pub message: String,
+}
+
+/// Data emiited by `onclose` event
+#[derive(Clone, Debug)]
+pub struct CloseEvent {
+    /// Close code
+    pub code: u16,
+    /// Close reason
+    pub reason: String,
+    /// If the websockt was closed cleanly
+    pub was_clean: bool,
+}