aboutsummaryrefslogtreecommitdiff
path: root/src/worker_ws.rs
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-05-19 18:22:08 +0200
committermetamuffin <metamuffin@disroot.org>2025-05-19 18:22:08 +0200
commit78ee337ee9a0880146fd663c084e5d3de7f86c76 (patch)
tree661783e09292d82ef6f4c5243dcc9ce726d766da /src/worker_ws.rs
parent51819226e6d4eb122d70b9b1897d6ce935434998 (diff)
downloadisda-78ee337ee9a0880146fd663c084e5d3de7f86c76.tar
isda-78ee337ee9a0880146fd663c084e5d3de7f86c76.tar.bz2
isda-78ee337ee9a0880146fd663c084e5d3de7f86c76.tar.zst
central config + download profiles + filter flags + other stuff
Diffstat (limited to 'src/worker_ws.rs')
-rw-r--r--src/worker_ws.rs8
1 files changed, 8 insertions, 0 deletions
diff --git a/src/worker_ws.rs b/src/worker_ws.rs
index 25ec7b0..f038100 100644
--- a/src/worker_ws.rs
+++ b/src/worker_ws.rs
@@ -56,6 +56,9 @@ pub enum WorkerResponse {
key: String,
data: Map<String, Value>,
},
+ Config {
+ config: Value,
+ },
Error {
message: String,
},
@@ -73,6 +76,11 @@ async fn worker_websocket_inner(ws: WebSocket, state: Arc<RwLock<State>>) {
let worker = {
let mut g = state.write().await;
+ tx.send(WorkerResponse::Config {
+ config: g.config.clone(),
+ })
+ .await
+ .unwrap();
let id = g.worker_id_counter;
g.worker_id_counter += 1;
g.workers.insert(