Checkpointing: have a chat UI setup.

Author: rohitkulshreshtha

Cargo.lock

@@ -59,7 +59,7 @@ serde_json = "1.0.115"
 slotmap = "1.0.0"
 smallvec = "1.6.1"
 tokio-stream = { version = "0.1.3", default-features = false, features = [ "time", "io-util", "sync" ] }
-tokio-tungstenite = "0.23.1"
+tokio-tungstenite = { version = "0.23.1", optional = true }
 tracing = "0.1.37"
 variadics = { path = "../variadics", version = "^0.0.6" }
 web-time = "1.0.0"
@@ -74,6 +74,7 @@ tokio-util = { version = "0.7.5", features = [ "net", "codec" ] }
 [target.'cfg(target_arch = "wasm32")'.dependencies]
 tokio = { version = "1.29.0", features = [ "rt" , "sync", "macros", "io-util", "time" ] }
 tokio-util = { version = "0.7.5", features = [ "codec" ] }
+wasm-bindgen-futures = "0.4.43"
 # We depend on getrandom transitively through rand. To compile getrandom to
 # WASM, we need to enable its "js" feature. However, rand does not expose a
 # passthrough to enable "js" on getrandom. As a workaround, we enable the

hydroflow/Cargo.toml

@@ -190,6 +190,7 @@ impl Context {
         for task in self.tasks_to_spawn.drain(..) {
             self.task_join_handles.push(tokio::task::spawn_local(task));
         }
+
     }
 
     /// Aborts all tasks spawned with [`Self::spawn_tasks`].

hydroflow/src/scheduled/context.rs

@@ -29,7 +29,10 @@ pub use socket::*;
 
 #[cfg(feature = "deploy_integration")]
 pub mod deploy;
+
+#[cfg(not(target_arch = "wasm32"))]
 mod websocket;
+#[cfg(not(target_arch = "wasm32"))]
 pub use websocket::*;
 
 use std::io::Read;

hydroflow/src/util/mod.rs

@@ -10,6 +10,7 @@ use tokio_tungstenite::tungstenite::{Error, Message};
 use crate::util::unsync::mpsc::{Receiver, Sender};
 use crate::util::unsync_channel;
 
+
 pub async fn bind_websocket(endpoint: SocketAddr) -> Result<(Sender<(Message, SocketAddr)>, Receiver<Result<(Message, SocketAddr), Error>>, SocketAddr), std::io::Error>{
     let listener = TcpListener::bind(endpoint).await.unwrap();
 

hydroflow/src/util/websocket.rs

@@ -8,16 +8,18 @@ edition = "2018"
 crate-type = ["cdylib", "rlib"]
 
 [dependencies]
+gloo = {  version = "0.11.0", features = ["futures"] }
 hydroflow = { path = "../hydroflow" }
 wasm-bindgen = "0.2.84"
 wasm-bindgen-futures = "0.4.43"
-web-sys = { version = "0.3.51", features = [ "console" ] }
+web-sys = { version = "0.3.51", features = [ "console", "Window", "Document", "Element", "HtmlElement", "HtmlInputElement", "EventTarget"] }
 
 # The `console_error_panic_hook` crate provides better debugging of panics by
 # logging them with `console.error`. This is great for development, but requires
 # all the `std::fmt` and `std::panicking` infrastructure, so isn't great for
 # code size when deploying.
 console_error_panic_hook = "0.1.7"
+futures = "0.3.30"
 
 [dev-dependencies]
 wasm-bindgen-test = "0.3.34"