XciD HF Staff commited on
Commit
85d80ab
·
1 Parent(s): 330cf0c

Remove debug logs from responses handler

Browse files
Files changed (1) hide show
  1. src/handlers/responses.rs +5 -31
src/handlers/responses.rs CHANGED
@@ -18,18 +18,9 @@ pub async fn responses(
18
  headers: HeaderMap,
19
  body: String,
20
  ) -> Result<Response, AppError> {
21
- // Log raw body for debugging (first 8000 chars)
22
- eprintln!("=== RAW BODY (first 8000 chars) ===\n{}\n=== END ===", &body[..body.len().min(8000)]);
23
-
24
  let request: CreateResponseRequest = serde_json::from_str(&body)
25
  .map_err(|e| AppError::InvalidRequest(format!("Failed to parse request: {}", e)))?;
26
 
27
- // Debug: log parsed input items
28
- if let crate::types::responses::Input::Messages(items) = &request.input {
29
- for (i, item) in items.iter().enumerate() {
30
- eprintln!("=== INPUT ITEM {} ===\n{:?}\n=== END ===", i, item);
31
- }
32
- }
33
  // Extract API key from incoming request headers
34
  let api_key = headers
35
  .get("x-api-key")
@@ -57,10 +48,6 @@ pub async fn responses(
57
  // Convert Responses API request to OpenRouter/Chat Completions format
58
  let openrouter_request = convert_responses_to_openrouter(&request);
59
 
60
- // Debug: log the converted request
61
- eprintln!("=== OPENROUTER REQUEST ===\n{}\n=== END ===",
62
- serde_json::to_string_pretty(&openrouter_request).unwrap_or_default());
63
-
64
  // Create request to backend
65
  let url = format!("{}/v1/chat/completions", state.openrouter_base_url);
66
 
@@ -127,26 +114,13 @@ pub async fn responses(
127
  }
128
 
129
  if !data.is_empty() {
130
- match serde_json::from_str::<ChatCompletionChunk>(&data) {
131
- Ok(chunk) => {
132
- // Debug: log tool calls if present
133
- if let Some(choice) = chunk.choices.first() {
134
- if let Some(delta) = &choice.delta {
135
- if delta.tool_calls.is_some() {
136
- eprintln!("=== TOOL CALL CHUNK ===\n{}\n=== END ===", &data);
137
- }
138
- }
139
- }
140
- let events = converter.convert_chunk(&chunk);
141
- for event in events {
142
- if tx.send(Ok(event.to_sse_string())).await.is_err() {
143
- return;
144
- }
145
  }
146
  }
147
- Err(e) => {
148
- eprintln!("Failed to parse chunk: {} - data: {}", e, &data[..data.len().min(500)]);
149
- }
150
  }
151
  }
152
  }
 
18
  headers: HeaderMap,
19
  body: String,
20
  ) -> Result<Response, AppError> {
 
 
 
21
  let request: CreateResponseRequest = serde_json::from_str(&body)
22
  .map_err(|e| AppError::InvalidRequest(format!("Failed to parse request: {}", e)))?;
23
 
 
 
 
 
 
 
24
  // Extract API key from incoming request headers
25
  let api_key = headers
26
  .get("x-api-key")
 
48
  // Convert Responses API request to OpenRouter/Chat Completions format
49
  let openrouter_request = convert_responses_to_openrouter(&request);
50
 
 
 
 
 
51
  // Create request to backend
52
  let url = format!("{}/v1/chat/completions", state.openrouter_base_url);
53
 
 
114
  }
115
 
116
  if !data.is_empty() {
117
+ if let Ok(chunk) = serde_json::from_str::<ChatCompletionChunk>(&data) {
118
+ let events = converter.convert_chunk(&chunk);
119
+ for event in events {
120
+ if tx.send(Ok(event.to_sse_string())).await.is_err() {
121
+ return;
 
 
 
 
 
 
 
 
 
 
122
  }
123
  }
 
 
 
124
  }
125
  }
126
  }