Method chat_with_tools_openai

atomic-repository/src/ai/tools.rs:312–409

(
        &self,
        messages: &[ToolMessage],
        tools: &[ToolDefinition],
        max_tokens: u32,
    )

    // ── OpenAI ──────────────────────────────────────────────────

    async fn chat_with_tools_openai(
        &self,
        messages: &[ToolMessage],
        tools: &[ToolDefinition],
        max_tokens: u32,
    ) -> Result<ToolAwareResponse, AiError> {
        let url = format!("{}/chat/completions", self.base_url);

        let api_messages = openai_messages(messages);

        let api_tools: Vec<serde_json::Value> = tools
            .iter()
            .map(|t| {
                json!({
                    "type": "function",
                    "function": {
                        "name": t.name,
                        "description": t.description,
                        "parameters": t.parameters,
                    }
                })
            })
            .collect();

        let mut body = json!({
            "model": self.model,
            "max_tokens": max_tokens,
            "messages": api_messages,
        });

        if !api_tools.is_empty() {
            body["tools"] = json!(api_tools);
        }

        let client = reqwest::Client::new();
        let resp = client
            .post(&url)
            .header("Authorization", format!("Bearer {}", self.api_key))
            .header("content-type", "application/json")
            .json(&body)
            .send()
            .await
            .map_err(|e| AiError::Http(e.to_string()))?;

        if !resp.status().is_success() {
            let status = resp.status().as_u16();
            let text = resp.text().await.unwrap_or_default();
            return Err(AiError::ApiError { status, body: text });
        }

        let json: serde_json::Value = resp
            .json()
            .await
            .map_err(|e| AiError::Http(e.to_string()))?;

        let choice = &json["choices"][0];
        let msg = &choice["message"];