remove tungstenite since tokio-tungstenite exists

Cargo.toml

@@ -51,9 +51,8 @@ tokio-rustls = { version = "0.26", default-features = false, features = [
     "tls12",
     "ring",
 ] }
-tokio-tungstenite = { version = "0.23", features = ["rustls-tls-webpki-roots"] }
+tokio-tungstenite = { version = "0.24", features = ["rustls-tls-webpki-roots"] }
 tokio-util = "0.7"
-tungstenite = { version = "0.23", features = ["rustls-tls-webpki-roots"] }
 url = "2"
 webpki = { package = "rustls-webpki", version = "0.102", features = [
     "alloc",

src/client.rs

@@ -22,14 +22,16 @@ use tokio::{
     net::TcpStream,
 };
 use tokio_rustls::client::TlsStream;
-use tokio_tungstenite::WebSocketStream;
-use tungstenite::{
-    client::IntoClientRequest,
-    handshake::{
-        client::{self, Response},
-        machine::TryParse,
+use tokio_tungstenite::{
+    tungstenite::{
+        client::IntoClientRequest,
+        handshake::{
+            client::{self, Response},
+            machine::TryParse,
+        },
+        protocol::{Message, Role},
     },
-    protocol::{Message, Role},
+    WebSocketStream,
 };
 
 pub async fn run_client<F>(config: &Config, quit: crate::CancellationToken, callback: Option<F>) -> Result<()>
@@ -274,7 +276,7 @@ pub(crate) async fn create_ws_stream<S: AsyncRead + AsyncWrite + Unpin>(
     let response = Response::try_parse(&buf)?.ok_or("response parse failed")?.1;
     let remote_key = response.headers().get("Sec-WebSocket-Accept").ok_or(format!("{:?}", response))?;
 
-    let accept_key = tungstenite::handshake::derive_accept_key(key.as_bytes());
+    let accept_key = tokio_tungstenite::tungstenite::handshake::derive_accept_key(key.as_bytes());
 
     if accept_key.as_str() != remote_key.to_str().map_err(|e| e.to_string())? {
         return Err(Error::from("accept key error"));

src/error.rs

@@ -28,7 +28,7 @@ pub enum Error {
     HeaderToStr(#[from] http::header::ToStrError),
 
     #[error("tungstenite::error::Error {0}")]
-    Tungstenite(#[from] tungstenite::error::Error),
+    Tungstenite(#[from] tokio_tungstenite::tungstenite::error::Error),
 
     #[error("reqwest::Error {0}")]
     Reqwest(#[from] reqwest::Error),

src/server.rs

@@ -20,11 +20,14 @@ use tokio::{
     sync::Mutex,
 };
 use tokio_rustls::{rustls, TlsAcceptor};
-use tokio_tungstenite::{accept_hdr_async, WebSocketStream};
-use tungstenite::{
-    handshake::server::{create_response, ErrorResponse, Request, Response},
-    handshake::{machine::TryParse, server},
-    protocol::{Message, Role},
+use tokio_tungstenite::{
+    accept_hdr_async,
+    tungstenite::{
+        handshake::server::{create_response, ErrorResponse, Request, Response},
+        handshake::{machine::TryParse, server},
+        protocol::{Message, Role},
+    },
+    WebSocketStream,
 };
 
 const WS_HANDSHAKE_LEN: usize = 1024;

src/udprelay.rs

@@ -21,8 +21,7 @@ use tokio::{
     sync::{broadcast, mpsc, Mutex},
     time,
 };
-use tokio_tungstenite::WebSocketStream;
-use tungstenite::protocol::Message;
+use tokio_tungstenite::{tungstenite::protocol::Message, WebSocketStream};
 
 pub(crate) type UdpRequestReceiver = broadcast::Receiver<(Bytes, Address, Address)>;
 pub(crate) type UdpRequestSender = broadcast::Sender<(Bytes, Address, Address)>;

src/weirduri.rs

@@ -1,4 +1,4 @@
-use tungstenite::{
+use tokio_tungstenite::tungstenite::{
     client::IntoClientRequest,
     error::{Error, Result, UrlError},
     handshake::client::{generate_key, Request},