Method StreamChat

api/client.go:644–678

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

func (c *OpenAICompatibleClient) buildMessages(systemPrompt string, messages []map[string]any) []map[string]any {
	converted := convertAnthropicMessagesToOpenAI(messages)
	result := make([]map[string]any, 0, len(converted)+1)

	if systemPrompt != "" {
		result = append(result, map[string]any{
			"role":    "system",
			"content": systemPrompt,
		})
	}

	result = append(result, converted...)
	return result
}

func (c *OpenAICompatibleClient) 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 *OpenAICompatibleClient) 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,
	}))
}