GeneralBots/botserver
2
1
Fork 0
Code Issues Pull requests Projects Releases 323 Packages Wiki Activity Actions

Fix: Wait for send_task to be ready before executing start.bas so TALK messages work
Some checks failed
BotServer CI / build (push) Failing after 8m56s
Details

Browse source
This commit is contained in:
Rodrigo Rodriguez (Pragmatismo) 2026-03-18 14:18:05 -03:00
parent 1a9208b88e
commit 8f073a15fd
1 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/core/bot/mod.rs
View file

@ -1374,8 +1374,11 @@ async fn handle_websocket(
let state_for_start = state.clone(); let state_for_start = state.clone();
let _tx_for_start = tx.clone(); let _tx_for_start = tx.clone();
let mut send_ready_rx = send_ready_rx;
tokio::spawn(async move { tokio::spawn(async move {
let _ = send_ready_rx.recv().await;
let session_result = { let session_result = {
let mut sm = state_for_start.session_manager.lock().await; let mut sm = state_for_start.session_manager.lock().await;
let by_id = sm.get_session_by_id(session_id); let by_id = sm.get_session_by_id(session_id);
@ -1442,6 +1445,8 @@ async fn handle_websocket(
} }
} }
let (send_ready_tx, mut send_ready_rx) = tokio::sync::mpsc::channel::<()>(1);
let mut send_task = tokio::spawn(async move { let mut send_task = tokio::spawn(async move {
while let Some(response) = rx.recv().await { while let Some(response) = rx.recv().await {
if let Ok(json_str) = serde_json::to_string(&response) { if let Ok(json_str) = serde_json::to_string(&response) {
@ -1452,6 +1457,8 @@ async fn handle_websocket(
} }
}); });
let _ = send_ready_tx.send(()).await;
let state_clone = state.clone(); let state_clone = state.clone();
let mut recv_task = tokio::spawn(async move { let mut recv_task = tokio::spawn(async move {
while let Some(Ok(msg)) = receiver.next().await { while let Some(Ok(msg)) = receiver.next().await {