Method chat_with_tools_anthropic

atomic-repository/src/ai/tools.rs:180–308

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

    // ── Anthropic ───────────────────────────────────────────────

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

        // Extract system prompt (Anthropic uses a top-level field).
        let system_text: String = messages
            .iter()
            .filter_map(|m| match m {
                ToolMessage::System { content } => Some(content.as_str()),
                _ => None,
            })
            .collect::<Vec<_>>()
            .join("\n\n");

        // Build message array (skip System messages).
        let api_messages = anthropic_messages(messages);

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

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

        if !system_text.is_empty() {
            // Use content block format with cache_control for prompt caching.
            // The system prompt + tools are static across turns — caching them
            // means turns 2+ pay ~0 for the system prompt.
            body["system"] = json!([
                {
                    "type": "text",
                    "text": system_text,
                    "cache_control": { "type": "ephemeral" }
                }
            ]);
        }
        if !api_tools.is_empty() {
            body["tools"] = json!(api_tools);
        }

        let client = reqwest::Client::new();
        let resp = client
            .post(&url)