Function openai_messages

atomic-repository/src/ai/tools.rs:470–525

Convert [`ToolMessage`] list into OpenAI's messages array.

(messages: &[ToolMessage])

/// Convert [`ToolMessage`] list into OpenAI's messages array.
fn openai_messages(messages: &[ToolMessage]) -> Vec<serde_json::Value> {
    let mut out = Vec::new();
    for msg in messages {
        match msg {
            ToolMessage::System { content } => {
                out.push(json!({ "role": "system", "content": content }));
            }
            ToolMessage::User { content } => {
                out.push(json!({ "role": "user", "content": content }));
            }
            ToolMessage::Assistant {
                content,
                tool_calls,
            } => {
                if tool_calls.is_empty() {
                    out.push(json!({ "role": "assistant", "content": content }));
                } else {
                    let tcs: Vec<serde_json::Value> = tool_calls
                        .iter()
                        .map(|tc| {
                            json!({
                                "id": tc.id,
                                "type": "function",
                                "function": {
                                    "name": tc.name,
                                    "arguments": serde_json::to_string(&tc.arguments)
                                        .unwrap_or_else(|_| "{}".to_string()),
                                }
                            })
                        })
                        .collect();
                    let mut m = json!({
                        "role": "assistant",
                        "tool_calls": tcs,
                    });
                    if !content.is_empty() {
                        m["content"] = json!(content);
                    }
                    out.push(m);
                }
            }
            ToolMessage::ToolResult {
                tool_call_id,
                content,
                ..
            } => {
                out.push(json!({
                    "role": "tool",
                    "tool_call_id": tool_call_id,
                    "content": content,
                }));
            }
        }
    }
    out
}

// ── Agentic loop ────────────────────────────────────────────────