package provider

import (
	"encoding/json"
	"testing"

	"aigw/internal/domain"
)

func TestRewriteRequestForcesOpenAIStreamUsage(t *testing.T) {
	result, err := rewriteRequest([]byte(`{"model":"public/model","stream":true,"stream_options":{"other":true}}`), "upstream/model", domain.ProtocolOpenAI)
	if err != nil {
		t.Fatal(err)
	}
	var body struct {
		Model         string         `json:"model"`
		StreamOptions map[string]any `json:"stream_options"`
	}
	if err := json.Unmarshal(result, &body); err != nil {
		t.Fatal(err)
	}
	if body.Model != "upstream/model" || body.StreamOptions["include_usage"] != true || body.StreamOptions["other"] != true {
		t.Fatalf("unexpected rewritten body: %s", result)
	}
}

func TestRewriteRequestDoesNotAddStreamOptionsToAnthropic(t *testing.T) {
	result, err := rewriteRequest([]byte(`{"model":"public/model","stream":true}`), "upstream/model", domain.ProtocolAnthropic)
	if err != nil {
		t.Fatal(err)
	}
	var body map[string]json.RawMessage
	if err := json.Unmarshal(result, &body); err != nil {
		t.Fatal(err)
	}
	if _, exists := body["stream_options"]; exists {
		t.Fatalf("unexpected OpenAI stream options in Anthropic request: %s", result)
	}
}

func TestResponsesWireAPIUsesResponsesEndpointWithoutChatStreamOptions(t *testing.T) {
	result, err := rewriteRequestWithWireAPI([]byte(`{"model":"public/model","input":"hello","stream":true}`), "gpt-upstream", domain.ProtocolOpenAIResponses, "responses")
	if err != nil {
		t.Fatal(err)
	}
	var body map[string]json.RawMessage
	if err := json.Unmarshal(result, &body); err != nil {
		t.Fatal(err)
	}
	if string(body["model"]) != `"gpt-upstream"` {
		t.Fatalf("model was not rewritten: %s", result)
	}
	if _, exists := body["stream_options"]; exists {
		t.Fatalf("Responses request contains Chat Completions stream options: %s", result)
	}
	provider := domain.Provider{BaseURL: "https://example.test", Protocol: domain.ProtocolOpenAI, WireAPI: "responses"}
	if got := endpointURL(provider, domain.ProtocolOpenAIResponses); got != "https://example.test/responses" {
		t.Fatalf("endpoint URL = %q", got)
	}
}