diff --git a/src/ui_server/mod.rs b/src/ui_server/mod.rs index ccdb815..477774d 100644 --- a/src/ui_server/mod.rs +++ b/src/ui_server/mod.rs @@ -770,7 +770,9 @@ fn create_api_router() -> Router { #[derive(Debug, Deserialize)] struct WsQuery { + #[allow(dead_code)] session_id: String, + #[allow(dead_code)] user_id: String, bot_name: Option, } @@ -1092,69 +1094,6 @@ async fn handle_task_progress_ws_proxy( } } -async fn forward_client_to_backend( - client_rx: &mut futures_util::stream::SplitStream, - backend_tx: &mut futures_util::stream::SplitSink>, TungsteniteMessage>, -) { - while let Some(msg) = client_rx.next().await { - match msg { - Ok(AxumMessage::Text(text)) => { - if backend_tx.send(TungsteniteMessage::Text(text)).await.is_err() { - break; - } - } - Ok(AxumMessage::Binary(data)) => { - if backend_tx.send(TungsteniteMessage::Binary(data)).await.is_err() { - break; - } - } - Ok(AxumMessage::Ping(data)) => { - if backend_tx.send(TungsteniteMessage::Ping(data)).await.is_err() { - break; - } - } - Ok(AxumMessage::Pong(data)) => { - if backend_tx.send(TungsteniteMessage::Pong(data)).await.is_err() { - break; - } - } - Ok(AxumMessage::Close(_)) | Err(_) => break, - } - } -} - -async fn forward_backend_to_client( - backend_rx: &mut futures_util::stream::SplitStream>>, - client_tx: &mut futures_util::stream::SplitSink, -) { - while let Some(msg) = backend_rx.next().await { - match msg { - Ok(TungsteniteMessage::Text(text)) => { - if client_tx.send(AxumMessage::Text(text)).await.is_err() { - break; - } - } - Ok(TungsteniteMessage::Binary(data)) => { - if client_tx.send(AxumMessage::Binary(data)).await.is_err() { - break; - } - } - Ok(TungsteniteMessage::Ping(data)) => { - if client_tx.send(AxumMessage::Ping(data)).await.is_err() { - break; - } - } - Ok(TungsteniteMessage::Pong(data)) => { - if client_tx.send(AxumMessage::Pong(data)).await.is_err() { - break; - } - } - Ok(TungsteniteMessage::Close(_)) | Err(_) => break, - Ok(_) => {} - } - } -} - fn create_ws_router() -> Router { Router::new() .route("/task-progress", get(ws_task_progress_proxy)) diff --git a/ui/suite/campaigns/campaigns.html b/ui/suite/campaigns/campaigns.html index 4c9ce2e..5e515c2 100644 --- a/ui/suite/campaigns/campaigns.html +++ b/ui/suite/campaigns/campaigns.html @@ -11,6 +11,8 @@

Campaigns