Update tokio-tungstenite to version 0.26.1 (#28)

* update tokio-tungstenite to version 0.26.1 and improve binary message handling

* fmt code

Author: netsirius

rust/Cargo.toml

@@ -32,7 +32,7 @@ freenet-macros = { path = "../rust-macros", version = "0.1.0-rc1" }
 
 [target.'cfg(any(unix, windows))'.dependencies]
 tokio = { version = "1", optional = true, features = ["macros", "parking_lot", "rt-multi-thread", "sync", "time"] }
-tokio-tungstenite = { version = "0.24", optional = true }
+tokio-tungstenite = { version = "0.26.1", optional = true }
 serde_with = { version = "3" }
 
 [target.'cfg(target_family = "wasm")'.dependencies]

rust/src/client_api/regular.rs

@@ -1,17 +1,16 @@
 use std::{borrow::Cow, task::Poll};
 
+use super::{
+    client_events::{ClientError, ClientRequest, ErrorKind},
+    Error, HostResult,
+};
 use futures::{pin_mut, FutureExt, Sink, SinkExt, Stream, StreamExt};
 use tokio::{
     net::TcpStream,
     sync::mpsc::{self, Receiver, Sender},
 };
 use tokio_tungstenite::{tungstenite::Message, MaybeTlsStream, WebSocketStream};
 
-use super::{
-    client_events::{ClientError, ClientRequest, ErrorKind},
-    Error, HostResult,
-};
-
 type Connection = WebSocketStream<MaybeTlsStream<TcpStream>>;
 
 pub struct WebApi {
@@ -163,7 +162,7 @@ async fn process_request(
     let msg = bincode::serialize(&req)
         .map_err(Into::into)
         .map_err(Error::OtherError)?;
-    conn.send(Message::Binary(msg)).await?;
+    conn.send(Message::Binary(msg.into())).await?;
     Ok(())
 }
 
@@ -183,7 +182,7 @@ async fn process_response(
                 .map_err(|_| Error::ChannelClosed)?;
         }
         Message::Binary(binary) => {
-            let response: HostResult = bincode::deserialize(binary.as_slice())?;
+            let response: HostResult = bincode::deserialize(&binary)?;
             response_tx
                 .send(response)
                 .await
@@ -233,7 +232,7 @@ mod test {
             if !self.recv {
                 let res: HostResult = Ok(HostResponse::Ok);
                 let req = bincode::serialize(&res)?;
-                stream.send(Message::Binary(req)).await?;
+                stream.send(Message::Binary(req.into())).await?;
             }
 
             let Message::Binary(msg) = stream.next().await.ok_or_else(|| "no msg".to_owned())??