From 5943ad452d4aabbfc2386c9ef6f9724db2190bb8 Mon Sep 17 00:00:00 2001 From: "Rodrigo Rodriguez (Pragmatismo)" Date: Sun, 15 Mar 2026 16:01:50 -0300 Subject: [PATCH] UI updates --- src/ui_server/mod.rs | 65 +-- ui/suite/campaigns/campaigns.html | 61 ++- ui/suite/crm/crm.html | 49 +-- ui/suite/sheet/sheet.css | 19 + ui/suite/sheet/sheet.html | 25 ++ ui/suite/sheet/sheet.js | 704 +++++++++++++++++++++++++++++- 6 files changed, 810 insertions(+), 113 deletions(-) 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