v0.0.16: Fix Kimi multi-turn — reasoning_content + content in tool call messages

Kimi's API requires reasoning_content and content to be present in
assistant messages when thinking mode is active. Added:
- reasoning_content field to ChatMessage struct
- Stream parser captures reasoning_content from deltas
- Always serialize content (even empty) and reasoning_content
- Debug request logging via AO_DEBUG_REQUESTS env var

Author: Shooksie

Cargo.lock

@@ -157,6 +157,9 @@ impl ApiClient {
         request: &ChatRequest,
         on_text_chunk: &mut dyn FnMut(&str),
     ) -> Result<(ChatMessage, Option<UsageInfo>)> {
+        if std::env::var("AO_DEBUG_REQUESTS").is_ok() {
+            eprintln!("[oai-runner] Request body: {}", serde_json::to_string(request).unwrap_or_default());
+        }
         let resp = self
             .http
             .post(url)
@@ -183,6 +186,7 @@ impl ApiClient {
         }
 
         let mut content = String::new();
+        let mut reasoning_content = String::new();
         let mut tool_calls: Vec<ToolCall> = Vec::new();
         let mut usage: Option<UsageInfo> = None;
 
@@ -201,7 +205,8 @@ impl ApiClient {
                 std::io::stdout().flush().ok();
                 let msg = ChatMessage {
                     role: "assistant".to_string(),
-                    content: if content.is_empty() { None } else { Some(content) },
+                    content: Some(content),
+                    reasoning_content: Some(reasoning_content),
                     tool_calls: if tool_calls.is_empty() { None } else { Some(tool_calls) },
                     tool_call_id: None,
                 };
@@ -223,6 +228,9 @@ impl ApiClient {
                     content.push_str(text);
                     on_text_chunk(text);
                 }
+                if let Some(text) = &choice.delta.reasoning_content {
+                    reasoning_content.push_str(text);
+                }
 
                 if let Some(tc_deltas) = &choice.delta.tool_calls {
                     for tc_delta in tc_deltas {
@@ -256,6 +264,7 @@ impl ApiClient {
         let msg = ChatMessage {
             role: "assistant".to_string(),
             content: if content.is_empty() { None } else { Some(content) },
+            reasoning_content: Some(reasoning_content),
             tool_calls: if tool_calls.is_empty() { None } else { Some(tool_calls) },
             tool_call_id: None,
         };

crates/oai-runner/src/api/client.rs

@@ -6,6 +6,8 @@ pub struct ChatMessage {
     pub role: String,
     #[serde(skip_serializing_if = "Option::is_none")]
     pub content: Option<String>,
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub reasoning_content: Option<String>,
     #[serde(skip_serializing_if = "Option::is_none")]
     pub tool_calls: Option<Vec<ToolCall>>,
     #[serde(skip_serializing_if = "Option::is_none")]
@@ -57,6 +59,8 @@ pub struct StreamDelta {
     #[serde(default)]
     pub content: Option<String>,
     #[serde(default)]
+    pub reasoning_content: Option<String>,
+    #[serde(default)]
     pub tool_calls: Option<Vec<StreamToolCall>>,
 }
 

crates/oai-runner/src/api/types.rs

@@ -119,7 +119,7 @@ pub async fn run_agent_loop(
             sys.push_str(&build_schema_injection(response_schema.unwrap()));
         }
         if !sys.is_empty() {
-            messages.push(ChatMessage {
+            messages.push(ChatMessage { reasoning_content: None,
                 role: "system".to_string(),
                 content: Some(sys),
                 tool_calls: None,
@@ -128,7 +128,7 @@ pub async fn run_agent_loop(
         }
     }
 
-    messages.push(ChatMessage {
+    messages.push(ChatMessage { reasoning_content: None,
         role: "user".to_string(),
         content: Some(user_prompt.to_string()),
         tool_calls: None,
@@ -268,7 +268,7 @@ pub async fn run_agent_loop(
                 }
             };
 
-            messages.push(ChatMessage {
+            messages.push(ChatMessage { reasoning_content: None,
                 role: "tool".to_string(),
                 content: Some(result),
                 tool_calls: None,
@@ -333,13 +333,13 @@ async fn retry_schema_validation(
         if let Some(sys) = system_msg {
             retry_messages.push(sys.clone());
         }
-        retry_messages.push(ChatMessage {
+        retry_messages.push(ChatMessage { reasoning_content: None,
             role: "assistant".to_string(),
             content: Some(last_assistant_content.clone()),
             tool_calls: None,
             tool_call_id: None,
         });
-        retry_messages.push(ChatMessage {
+        retry_messages.push(ChatMessage { reasoning_content: None,
             role: "user".to_string(),
             content: Some(correction.clone()),
             tool_calls: None,
@@ -375,7 +375,7 @@ async fn retry_schema_validation(
         }
 
         let content = retry_msg.content.clone().unwrap_or_default();
-        messages.push(ChatMessage {
+        messages.push(ChatMessage { reasoning_content: None,
             role: "user".to_string(),
             content: Some(correction),
             tool_calls: None,
@@ -666,19 +666,19 @@ mod tests {
 
         let sid = "test-session-round-trip";
         let messages = vec![
-            ChatMessage {
+            ChatMessage { reasoning_content: None,
                 role: "system".to_string(),
                 content: Some("You are helpful.".to_string()),
                 tool_calls: None,
                 tool_call_id: None,
             },
-            ChatMessage {
+            ChatMessage { reasoning_content: None,
                 role: "user".to_string(),
                 content: Some("Hello".to_string()),
                 tool_calls: None,
                 tool_call_id: None,
             },
-            ChatMessage {
+            ChatMessage { reasoning_content: None,
                 role: "assistant".to_string(),
                 content: Some("Hi there!".to_string()),
                 tool_calls: None,

crates/oai-runner/src/runner/agent_loop.rs

@@ -133,7 +133,7 @@ mod tests {
     use super::*;
 
     fn msg(role: &str, content: &str) -> ChatMessage {
-        ChatMessage { role: role.to_string(), content: Some(content.to_string()), tool_calls: None, tool_call_id: None }
+        ChatMessage { reasoning_content: None, role: role.to_string(), content: Some(content.to_string()), tool_calls: None, tool_call_id: None }
     }
 
     #[test]

crates/oai-runner/src/runner/context.rs

@@ -1,6 +1,6 @@
 [package]
 name = "orchestrator-cli"
-version = "0.0.15"
+version = "0.0.16"
 edition = "2021"
 
 [[bin]]

crates/orchestrator-cli/Cargo.toml

@@ -66,7 +66,9 @@ impl DaemonServiceApi for InMemoryServiceHub {
         let pool_size = config.pool_size;
         let mut lock = self.state.write().await;
         lock.daemon_status = DaemonStatus::Running;
-        lock.daemon_pool_size = pool_size;
+        if let Some(ps) = pool_size {
+            lock.daemon_pool_size = Some(ps);
+        }
         lock.logs.push(LogEntry {
             timestamp: Utc::now(),
             level: LogLevel::Info,
@@ -171,7 +173,9 @@ impl DaemonServiceApi for FileServiceHub {
 
         mutate_daemon_state(self, |state| {
             state.daemon_status = DaemonStatus::Running;
-            state.daemon_pool_size = pool_size;
+            if let Some(ps) = pool_size {
+                state.daemon_pool_size = Some(ps);
+            }
             state.runner_pid = runner_pid;
             state.logs.push(LogEntry {
                 timestamp: Utc::now(),