Method StreamChat

api/client.go:324–394

(
	ctx context.Context,
	systemPrompt string,
	messages []map[string]any,
	tools []map[string]any,
	options *LLMRequestOptions,
)

	}

	return false
}

type AnthropicClient struct {
	LLMClientBase
}

var _ LLMClient = (*AnthropicClient)(nil)

func (c *AnthropicClient) buildHeaders() map[string]string {
	headers := map[string]string{"anthropic-version": "2023-06-01", "content-type": "application/json"}
	if isDeepSeekModel(c.Model) || strings.Contains(strings.ToLower(c.BaseURL), "api.deepseek.com") {
		headers["Authorization"] = "Bearer " + c.APIKey
	} else {
		headers["x-api-key"] = c.APIKey
	}
	return headers
}

func (c *AnthropicClient) Complete(
	ctx context.Context,
	systemPrompt string,
	messages []map[string]any,
	opts CompleteOptions,
) (string, error) {
	response, err := collectCompletionStream(c.StreamChat(ctx, systemPrompt, messages, opts.Tools,
		&LLMRequestOptions{MaxTokens: opts.MaxTokens, Temperature: opts.Temperature}))
	if err != nil {
		return "", err
	}
	return response.Text, nil
}

func (c *AnthropicClient) CompleteStructured(
	ctx context.Context,
	systemPrompt string,
	messages []map[string]any,
	opts StructuredCompletionOptions,
) (Response, error) {
	return collectCompletionStream(c.StreamChat(ctx, systemPrompt, messages, opts.Tools, &LLMRequestOptions{
		MaxTokens: opts.MaxTokens, RequiredTool: opts.RequiredTool, DisableThinking: opts.DisableThinking,
		Temperature: opts.Temperature,
	}))
}

func (c *AnthropicClient) StreamChat(
	ctx context.Context,
	systemPrompt string,
	messages []map[string]any,
	tools []map[string]any,
	options *LLMRequestOptions,
) <-chan EventResult {
	url := c.BaseURL + "/v1/messages"
	headers := c.buildHeaders()

	apiTools := make([]map[string]any, 0, len(tools))
	for _, tool := range tools {
		parameters, ok := tool["input_schema"]