feat: frame splitting

Author: filipton

Cargo.lock

@@ -30,7 +30,7 @@ macros = { path = "./macros" }
 nb = "1.1.0"
 embassy-futures = "0.1.1"
 embassy-sync = "0.6.2"
-ws-framer = { version = "=0.2.2", features = ["alloc"] }
+ws-framer = { version = "0.3.0", default-features = false, features = ["alloc", "http", "getrandom02"] }
 embedded-hal-async = "1.0.0"
 portable-atomic = { version = "1.11.0", default-features = false }
 critical-section = "1.2.0"

Cargo.toml

@@ -234,13 +234,18 @@ async fn ws_rw(
         let n = match embassy_futures::select::select(read_fut, write_fut).await {
             embassy_futures::select::Either::First(read_res) => read_res,
             embassy_futures::select::Either::Second(write_frame) => {
-                if write_frame.into_ref().data().len() > WS_BUF_SIZE {
-                    log::error!("Skipping writing frame! Frame is too big! (Maybe split it?)");
-                    continue;
-                }
+                let mut offset = 0;
+                let frame_ref = write_frame.into_ref();
+
+                loop {
+                    let (data, finish) = framer_tx.partial_frame(&frame_ref, &mut offset);
+                    socket.write_all(data).await.map_err(|_| ())?;
+                    if !finish {
+                        break;
+                    }
 
-                let data = framer_tx.frame(write_frame.into_ref());
-                socket.write_all(data).await.map_err(|_| ())?;
+                    log::warn!("Frame splitted!");
+                }
 
                 continue;
             }