From b200e10bc40433da664d070c232ac80eb8795655 Mon Sep 17 00:00:00 2001 From: Richard Feldman Date: Thu, 4 Dec 2025 11:30:44 -0500 Subject: [PATCH] Clean up debug statements --- crates/extension/src/extension_host_proxy.rs | 2 +- .../src/wasm_host/llm_provider.rs | 54 ++----------------- 2 files changed, 5 insertions(+), 51 deletions(-) diff --git a/crates/extension/src/extension_host_proxy.rs b/crates/extension/src/extension_host_proxy.rs index 6fe9e1f8084cf5074dddaac9263cee666153640c..2a67726f420469e2a0ed7c3362bbca921a5c7b7b 100644 --- a/crates/extension/src/extension_host_proxy.rs +++ b/crates/extension/src/extension_host_proxy.rs @@ -386,7 +386,7 @@ pub trait ExtensionContextServerProxy: Send + Sync + 'static { fn unregister_context_server(&self, server_id: Arc, cx: &mut App); } -/// A boxed function that registers a language model provider with the registry. +/// A function that registers a language model provider with the registry. /// This allows extension_host to create the provider (which requires WasmExtension) /// and pass a registration closure to the language_models crate. pub type LanguageModelProviderRegistration = Box; diff --git a/crates/extension_host/src/wasm_host/llm_provider.rs b/crates/extension_host/src/wasm_host/llm_provider.rs index 6ef02c16a6a34f007a131ba3bcbac17c1864d893..ce80432fd513eebf92202f26d1732011bc227b23 100644 --- a/crates/extension_host/src/wasm_host/llm_provider.rs +++ b/crates/extension_host/src/wasm_host/llm_provider.rs @@ -665,21 +665,10 @@ impl LanguageModel for ExtensionLanguageModel { let provider_id = self.provider_info.id.clone(); let model_id = self.model_info.id.clone(); - eprintln!( - "[EXT LLM DEBUG] stream_completion called for provider={}, model={}", - provider_id, model_id - ); - let wit_request = convert_request_to_wit(request); - eprintln!( - "[EXT LLM DEBUG] Converted request: {} messages, {} tools", - wit_request.messages.len(), - wit_request.tools.len() - ); async move { // Start the stream - eprintln!("[EXT LLM DEBUG] Calling llm_stream_completion_start..."); let stream_id_result = extension .call({ let provider_id = provider_id.clone(); @@ -703,17 +692,10 @@ impl LanguageModel for ExtensionLanguageModel { }) .await; - eprintln!( - "[EXT LLM DEBUG] llm_stream_completion_start result: {:?}", - stream_id_result - ); - let stream_id = stream_id_result .map_err(LanguageModelCompletionError::Other)? .map_err(LanguageModelCompletionError::Other)?; - eprintln!("[EXT LLM DEBUG] Got stream_id: {}", stream_id); - // Create a stream that polls for events let stream = futures::stream::unfold( (extension.clone(), stream_id, false), @@ -741,37 +723,12 @@ impl LanguageModel for ExtensionLanguageModel { match result { Ok(Some(event)) => { - let event_desc = match &event { - LlmCompletionEvent::Started => "Started".to_string(), - LlmCompletionEvent::Text(t) => format!("Text: {:?}", t), - LlmCompletionEvent::Thinking(th) => { - format!("Thinking: {:?}", th.text) - } - LlmCompletionEvent::RedactedThinking(r) => { - format!("RedactedThinking: {:?}", r) - } - LlmCompletionEvent::ToolUse(tu) => { - format!("ToolUse: name={}, input={}", tu.name, tu.input) - } - LlmCompletionEvent::ToolUseJsonParseError(e) => { - format!("ToolUseJsonParseError: {:?}", e.error) - } - LlmCompletionEvent::Stop(r) => format!("Stop({:?})", r), - LlmCompletionEvent::Usage(u) => { - format!("Usage: in={}, out={}", u.input_tokens, u.output_tokens) - } - LlmCompletionEvent::ReasoningDetails(d) => { - format!("ReasoningDetails: {:?}", d) - } - }; - eprintln!("[EXT LLM DEBUG] Got event: {}", event_desc); let converted = convert_completion_event(event); let is_done = matches!(&converted, Ok(LanguageModelCompletionEvent::Stop(_))); Some((converted, (extension, stream_id, is_done))) } Ok(None) => { - eprintln!("[EXT LLM DEBUG] Stream returned None, closing"); // Stream complete, close it let _ = extension .call({ @@ -788,13 +745,10 @@ impl LanguageModel for ExtensionLanguageModel { .await; None } - Err(e) => { - eprintln!("[EXT LLM DEBUG] Stream error: {:?}", e); - Some(( - Err(LanguageModelCompletionError::Other(e)), - (extension, stream_id, true), - )) - } + Err(e) => Some(( + Err(LanguageModelCompletionError::Other(e)), + (extension, stream_id, true), + )), } }, );