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

fix(websocket): force start.bas execution on connection to restore chat on page reload while preventing duplicate execution
All checks were successful
BotServer CI / build (push) Successful in 4m14s
Details

Browse source
This commit is contained in:
Rodrigo Rodriguez (Pragmatismo) 2026-03-21 16:38:03 -03:00
parent 363c056bab
commit 622f1222dc
1 changed files with 4 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -1353,21 +1353,10 @@ async fn handle_websocket(
); );
if let Some(bot_name) = bot_name_result { if let Some(bot_name) = bot_name_result {
// Check if start.bas has already been executed for this session // Web clients expect start.bas to execute their first screen every time they connect/reload.
// We always run it, but we SET the start_bas_key flag right after so stream_response skips execution.
let start_bas_key = format!("start_bas_executed:{}:{}", server_epoch(), session_id); let start_bas_key = format!("start_bas_executed:{}:{}", server_epoch(), session_id);
let should_execute_start_bas = if let Some(cache) = &state.cache { let should_execute_start_bas = true;
if let Ok(mut conn) = cache.get_multiplexed_async_connection().await {
let executed: Result<Option<String>, redis::RedisError> = redis::cmd("GET")
.arg(&start_bas_key)
.query_async(&mut conn)
.await;
matches!(executed, Ok(None))
} else {
true // If cache fails, try to execute
}
} else {
true // If no cache, try to execute
};
if should_execute_start_bas { if should_execute_start_bas {
let data_dir = "/opt/gbo/data"; let data_dir = "/opt/gbo/data";
@ -1473,19 +1462,7 @@ async fn handle_websocket(
}; };
let _ = tx_for_start.send(response).await; let _ = tx_for_start.send(response).await;
// Clear suggestions and start_bas_executed key to allow re-run on next page load
if let Some(cache) = &state_for_redis.cache {
if let Ok(mut conn) = cache.get_multiplexed_async_connection().await {
let suggestions_key = format!("suggestions:{}:{}", bot_id_str, session_id_str);
let start_bas_key = format!("start_bas_executed:{}:{}", server_epoch(), session_id_str);
let _: Result<(), redis::RedisError> = redis::cmd("DEL")
.arg(&suggestions_key)
.arg(&start_bas_key)
.query_async(&mut conn)
.await;
info!("Cleared suggestions and start_bas_executed from Redis for session {}", session_id);
}
}
} }
} }
Ok(Err(e)) => { Ok(Err(e)) => {