GeneralBots/botserver
2
1
Fork 0
Code Activity Actions

fix: use bucket_name instead of bot_id (UUID) for file_states.json path
All checks were successful
BotServer CI/CD / build (push) Successful in 3m22s
Details

Browse source 
File states were stored under /opt/gbo/work/{UUID}/file_states.json
but should be under /opt/gbo/work/{bucket_name}/file_states.json
like other bot data (e.g. /opt/gbo/work/salesianos.gbai/)

Also fixed file_states_static signature to use bucket_name consistently.
This commit is contained in:
Rodrigo Rodriguez (Pragmatismo) 2026-04-11 20:40:23 -03:00
parent cf4a00e16e
commit e81aee6221
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/drive/drive_monitor/mod.rs
View file

@ -81,7 +81,7 @@ impl DriveMonitor {
/// Get the path to the file states JSON file for this bot
fn file_state_path(&self) -> PathBuf {
self.work_root
.join(format!("{}", self.bot_id))
.join(&self.bucket_name)
.join("file_states.json")
}
@ -133,10 +133,10 @@ impl DriveMonitor {
async fn save_file_states_static(
file_states: &Arc<tokio::sync::RwLock<HashMap<String, FileState>>>,
work_root: &PathBuf,
bot_id: &uuid::Uuid,
bucket_name: &str,
) -> Result<(), Box<dyn Error + Send + Sync>> {
let path = work_root
.join(format!("{}", bot_id))
.join(bucket_name)
.join("file_states.json");
if let Some(parent) = path.parent() {
@ -160,9 +160,9 @@ impl DriveMonitor {
);
} else {
debug!(
"[DRIVE_MONITOR] Saved {} file states to disk for bot {}",
"[DRIVE_MONITOR] Saved {} file states to disk for bucket {}",
states.len(),
bot_id
bucket_name
);
}
}
@ -543,9 +543,9 @@ impl DriveMonitor {
// Use static helper to avoid double Arc (fixes "dispatch failure" error)
let file_states_clone = Arc::clone(&self.file_states);
let work_root_clone = self.work_root.clone();
let bot_id_clone = self.bot_id;
let bucket_name_clone = self.bucket_name.clone();
tokio::spawn(async move {
if let Err(e) = Self::save_file_states_static(&file_states_clone, &work_root_clone, &bot_id_clone).await {
if let Err(e) = Self::save_file_states_static(&file_states_clone, &work_root_clone, &bucket_name_clone).await {
warn!("Failed to save file states: {}", e);
}
});
@ -648,9 +648,9 @@ impl DriveMonitor {
drop(states);
let file_states_clone = Arc::clone(&self.file_states);
let work_root_clone = self.work_root.clone();
let bot_id_clone = self.bot_id;
let bucket_name_clone = self.bucket_name.clone();
tokio::spawn(async move {
if let Err(e) = Self::save_file_states_static(&file_states_clone, &work_root_clone, &bot_id_clone).await {
if let Err(e) = Self::save_file_states_static(&file_states_clone, &work_root_clone, &bucket_name_clone).await {
warn!("Failed to save file states after prompt update: {}", e);
}
});
@ -1381,9 +1381,9 @@ impl DriveMonitor {
// Use static helper to avoid double Arc (fixes "dispatch failure" error)
let file_states_clone = Arc::clone(&self.file_states);
let work_root_clone = self.work_root.clone();
let bot_id_clone = self.bot_id;
let bucket_name_clone = self.bucket_name.clone();
tokio::spawn(async move {
if let Err(e) = Self::save_file_states_static(&file_states_clone, &work_root_clone, &bot_id_clone).await {
if let Err(e) = Self::save_file_states_static(&file_states_clone, &work_root_clone, &bucket_name_clone).await {
warn!("Failed to save file states: {}", e);
}
});