asepharyana
16494d4b1e
- Added tracing instrumentation and improved logging messages in the Pong, Todofinish, and Todowrite tools for better debugging and monitoring. - Enhanced documentation comments for clarity on tool functionalities and workflows. - Implemented tracing in WorkflowRun, NoteFinding, ReadFindings, and HiveMind tools to track execution phases and findings. - Updated TUI overlays (e.g., Bash, Clear Confirm, Editor, Effort Level, Help, Key Input, Learning, Loading, MCP, Model Selector, Plan, Quit Confirm, Rewind, Settings, Todo, Usage) with debug logging to capture rendering details. - Improved the status bar and workflow panel rendering with additional debug information. - Added tracing to various utility functions to facilitate better performance monitoring and error tracking.
73 lines
2.3 KiB
Rust
73 lines
2.3 KiB
Rust
//! Update the shared directory cache by resolving each path against
|
|
//! workspaces and storing the resolved paths in `ctx.dir_cache`.
|
|
//!
|
|
//! The cache is an `Arc<RwLock<DirCache>>` shared with the TUI and
|
|
//! other components so they can read the cached listing without
|
|
//! re-scanning the filesystem.
|
|
|
|
use crate::tools::{resolve_path, ToolCtx};
|
|
use anyhow::Result;
|
|
use serde_json::{json, Value};
|
|
use std::path::PathBuf;
|
|
use tracing::{info, instrument};
|
|
|
|
/// Tool that updates the cached directory listing.
|
|
///
|
|
/// Flow: parse `paths` array → resolve each against workspaces →
|
|
/// persist resolved paths into the shared `DirCache` via an
|
|
/// async write → confirm with the entry count.
|
|
pub struct DirCacheUpdate;
|
|
|
|
impl crate::tools::Tool for DirCacheUpdate {
|
|
fn name(&self) -> &'static str {
|
|
"dir_cache_update"
|
|
}
|
|
|
|
fn description(&self) -> &'static str {
|
|
"Update the cached directory listing"
|
|
}
|
|
|
|
fn parameters(&self) -> Value {
|
|
json!({
|
|
"type": "object",
|
|
"properties": {
|
|
"paths": {
|
|
"type": "array",
|
|
"items": {"type": "string"},
|
|
"description": "New list of paths for the cache"
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
#[instrument(skip(self, ctx, args))]
|
|
fn run(&self, ctx: &ToolCtx, args: &Value) -> Result<String> {
|
|
let paths: Vec<String> = args
|
|
.get("paths")
|
|
.and_then(|v| v.as_array())
|
|
.map(|arr| {
|
|
arr.iter()
|
|
.filter_map(|v| v.as_str().map(String::from))
|
|
.collect()
|
|
})
|
|
.unwrap_or_default();
|
|
|
|
let resolved: Vec<PathBuf> = paths
|
|
.iter()
|
|
.map(|p| resolve_path(&ctx.workspaces, p))
|
|
.collect::<Result<Vec<_>>>()?;
|
|
|
|
let count = resolved.len();
|
|
info!(count, "directory cache update requested");
|
|
|
|
// Persist the resolved paths into the shared DirCache so the TUI
|
|
// and other tools can read the cached listing without re-scanning.
|
|
let dc = ctx.dir_cache.clone();
|
|
let rt = tokio::runtime::Runtime::new()?;
|
|
rt.block_on(async { dc.write().await.set(resolved).await });
|
|
|
|
info!(count, "directory cache updated");
|
|
Ok(format!("Directory cache updated with {} entries", count))
|
|
}
|
|
}
|