log capabilities

Author: williamstein

src/codex_agent.rs

@@ -113,6 +113,13 @@ impl Agent for CodexAgent {
         let protocol_version = V1;
 
         *self.client_capabilities.lock().unwrap() = client_capabilities;
+        {
+            let guard = self.client_capabilities.lock().unwrap();
+            info!(
+                "ACP initialize: client fs.read_text_file={} fs.write_text_file={} terminal={}",
+                guard.fs.read_text_file, guard.fs.write_text_file, guard.terminal
+            );
+        }
 
         let agent_capabilities = AgentCapabilities {
             load_session: false, // Currently only able to do in-memory... which doesn't help us at the moment

src/conversation.rs

@@ -1401,11 +1401,7 @@ impl SessionClient {
         .await;
     }
 
-    async fn send_token_usage(
-        &self,
-        info: TokenUsageInfo,
-        rate_limits: Option<RateLimitSnapshot>,
-    ) {
+    async fn send_token_usage(&self, info: TokenUsageInfo, rate_limits: Option<RateLimitSnapshot>) {
         let mut meta = serde_json::Map::new();
         meta.insert(
             "token_usage".to_string(),

src/local_spawner.rs

@@ -10,6 +10,7 @@ use agent_client_protocol::{
 };
 use codex_apply_patch::StdFs;
 use tokio::sync::mpsc;
+use tracing::warn;
 
 use crate::ACP_CLIENT;
 
@@ -123,6 +124,9 @@ impl AcpFs {
 impl codex_apply_patch::Fs for AcpFs {
     fn read_to_string(&self, path: &std::path::Path) -> std::io::Result<String> {
         if !self.client_capabilities.lock().unwrap().fs.read_text_file {
+            warn!(
+                "ACP FS read_to_string fallback to local fs for {path:?} (read_text_file disabled)"
+            );
             return StdFs.read_to_string(path);
         }
         let (tx, rx) = std::sync::mpsc::channel();
@@ -138,6 +142,7 @@ impl codex_apply_patch::Fs for AcpFs {
 
     fn write(&self, path: &std::path::Path, contents: &[u8]) -> std::io::Result<()> {
         if !self.client_capabilities.lock().unwrap().fs.write_text_file {
+            warn!("ACP FS write fallback to local fs for {path:?} (write_text_file disabled)");
             return StdFs.write(path, contents);
         }
         let (tx, rx) = std::sync::mpsc::channel();
@@ -166,6 +171,7 @@ impl codex_core::codex::Fs for AcpFs {
         >,
     > {
         if !self.client_capabilities.lock().unwrap().fs.read_text_file {
+            warn!("ACP FS file_buffer fallback to local fs for {path:?} (read_text_file disabled)");
             return StdFs.file_buffer(path, limit);
         }
         let (tx, rx) = tokio::sync::oneshot::channel();