converter

type AnthropicContentBlock struct {
	Type      string `json:"type"`
	Thinking  string `json:"thinking,omitempty"`
	Text      string `json:"text,omitempty"`
	ID        string `json:"id,omitempty"`
	Name      string `json:"name,omitempty"`
	Input     any    `json:"input,omitempty"`
	ToolUseID string `json:"tool_use_id,omitempty"`
	Content   any    `json:"content,omitempty"`
}

type AnthropicMessage struct {
	Role    string `json:"role"`
	Content any    `json:"content"` // string or []AnthropicContentBlock
}

type AnthropicRequest struct {
	Model       string             `json:"model"`
	Messages    []AnthropicMessage `json:"messages"`
	System      any                `json:"system,omitempty"` // string or []AnthropicSystemBlock
	MaxTokens   int                `json:"max_tokens,omitempty"`
	Temperature float64            `json:"temperature,omitempty"`
	TopP        float64            `json:"top_p,omitempty"`
	Stream      bool               `json:"stream,omitempty"`
	Metadata    map[string]any     `json:"metadata,omitempty"`
	Tools       []AnthropicTool    `json:"tools,omitempty"`
	ToolChoice  any                `json:"tool_choice,omitempty"`
}

type AnthropicResponse struct {
	ID         string                  `json:"id"`
	Type       string                  `json:"type"`
	Role       string                  `json:"role"`
	Content    []AnthropicContentBlock `json:"content"`
	Model      string                  `json:"model"`
	StopReason string                  `json:"stop_reason"`
	Usage      AnthropicUsage          `json:"usage"`
}

type AnthropicStreamState struct {
	MessageID         string
	Model             string
	BlockIndex        int
	ContentSent       bool
	AccText           string
	InputTokens       int
	OutputTokens      int
	CacheCreateTokens int
	CacheReadTokens   int
	ThinkTag          string
	TagState          ThinkTagState
	FinishReason      string
	DeltaSent         bool
	TextBlockClosed   bool
	TextBlockStarted  bool
	TextBlockIdx      int
	ReasoningStarted  bool
	ReasoningClosed   bool
	ToolBlocks        map[int]*toolBlockState
	SawToolCall       bool
}

type AnthropicSystemBlock struct {
	Type string `json:"type"`
	Text string `json:"text"`
}

type AnthropicToChatState struct {
	ID                string
	Model             string
	Created           int64
	AccText           string
	StopReason        string
	InputTokens       int
	OutputTokens      int
	CacheCreateTokens int
	CacheReadTokens   int
	Started           bool

	// Tool use tracking: Anthropic block index → tool block info
	ToolBlocks      map[int]*anthropicToolBlock
	ToolCallCounter int
}

type AnthropicToResponsesState struct {
	ResponseID        string
	ItemID            string
	Model             string
	Created           int64
	AccText           string
	CreatedSent       bool
	ItemSent          bool
	CompletedSent     bool
	SeqNum            int
	InputTokens       int
	OutputTokens      int
	CacheCreateTokens int
	CacheReadTokens   int
	ThinkTag          string
	TagState          ThinkTagState

	// Tool use tracking
	CurrentBlockType string
	CurrentBlockIdx  int
	FuncArgsBuf      map[int]*strings.Builder
	FuncNames        map[int]string
	FuncCallIDs      map[int]string
	TextItemID       string
	TextDoneSent     bool
	OutputIndex      int
}

type AnthropicTool struct {
	Name        string         `json:"name"`
	Description string         `json:"description,omitempty"`
	InputSchema map[string]any `json:"input_schema,omitempty"`
}

type AnthropicUsage struct {
	InputTokens              int `json:"input_tokens"`
	OutputTokens             int `json:"output_tokens"`
	CacheCreationInputTokens int `json:"cache_creation_input_tokens,omitempty"`
	CacheReadInputTokens     int `json:"cache_read_input_tokens,omitempty"`
}

type ConvertedRequest struct {
	UpstreamBody []byte
	Model        string
	IsStreaming  bool
}

type Converter struct{}

type GeminiCandidate struct {
	Content      *GeminiContent `json:"content,omitempty"`
	FinishReason string         `json:"finishReason,omitempty"`
}

type GeminiContent struct {
	Role  string       `json:"role,omitempty"`
	Parts []GeminiPart `json:"parts"`
}

type GeminiFuncCall struct {
	Name string         `json:"name"`
	Args map[string]any `json:"args,omitempty"`
}

type GeminiFuncCallingConfig struct {
	Mode string `json:"mode,omitempty"`
}

type GeminiFuncDecl struct {
	Name        string         `json:"name"`
	Description string         `json:"description,omitempty"`
	Parameters  map[string]any `json:"parameters,omitempty"`
}

type GeminiFuncResp struct {
	Name     string         `json:"name"`
	Response map[string]any `json:"response,omitempty"`
}

type GeminiGenerationConfig struct {
	MaxOutputTokens int     `json:"maxOutputTokens,omitempty"`
	Temperature     float64 `json:"temperature,omitempty"`
	TopP            float64 `json:"topP,omitempty"`
}

type GeminiPart struct {
	Text         string          `json:"text,omitempty"`
	FunctionCall *GeminiFuncCall `json:"functionCall,omitempty"`
	FunctionResp *GeminiFuncResp `json:"functionResponse,omitempty"`
}

type GeminiRequest struct {
	Contents          []GeminiContent         `json:"contents,omitempty"`
	SystemInstruction *GeminiContent          `json:"system_instruction,omitempty"`
	Tools             []GeminiToolDeclaration `json:"tools,omitempty"`
	ToolConfig        *GeminiToolConfig       `json:"tool_config,omitempty"`
	GenerationConfig  *GeminiGenerationConfig `json:"generationConfig,omitempty"`
}

type GeminiResponse struct {
	Candidates    []GeminiCandidate `json:"candidates,omitempty"`
	UsageMetadata *GeminiUsageMeta  `json:"usageMetadata,omitempty"`
	ModelVersion  string            `json:"modelVersion,omitempty"`
}

type GeminiStreamState struct {
	Model        string
	InputTokens  int
	OutputTokens int
	Started      bool
	Done         bool
	// Tool call accumulation for Gemini → Chat: index → accumulated args
	ToolCallArgs map[int]*strings.Builder
	ToolCallIDs  map[int]string
	ToolCallSeq  int
	AccText      string
}

type GeminiToAnthropicState struct {
	MessageID         string
	Model             string
	BlockIndex        int
	ContentSent       bool
	InputTokens       int
	OutputTokens      int
	CacheCreateTokens int
	CacheReadTokens   int
	ThinkTag          string
	TagState          ThinkTagState
	HasToolUse        bool
	AccText           string
}

type GeminiToChatState struct {
	ID           string
	Model        string
	Created      int64
	Started      bool
	InputTokens  int
	OutputTokens int
	AccText      string
	HasToolCalls bool
	ToolCallSeq  int
	// contains filtered or unexported fields
}

type GeminiToResponsesState struct {
	ResponseID    string
	ItemID        string
	Model         string
	Created       int64
	SeqNum        int
	CreatedSent   bool
	ItemSent      bool
	InputTokens   int
	OutputTokens  int
	AccText       string
	ThinkTag      string
	TagState      ThinkTagState
	TextOutputIdx int
	FuncOutputIdx int
}

type GeminiToolConfig struct {
	FunctionCallingConfig *GeminiFuncCallingConfig `json:"function_calling_config,omitempty"`
}

type GeminiToolDeclaration struct {
	FunctionDeclarations []GeminiFuncDecl `json:"functionDeclarations,omitempty"`
}

type GeminiUsageMeta struct {
	PromptTokenCount     int `json:"promptTokenCount,omitempty"`
	CandidatesTokenCount int `json:"candidatesTokenCount,omitempty"`
	TotalTokenCount      int `json:"totalTokenCount,omitempty"`
}

type ResponsesStreamState struct {
	ResponseID        string
	Created           int64
	OutputIndex       int
	ContentIndex      int
	ItemID            string
	CreatedSent       bool
	AccText           string
	SeqNum            int
	Model             string
	InputTokens       int
	OutputTokens      int
	CacheCreateTokens int
	CacheReadTokens   int
	ThinkTag          string
	TagState          ThinkTagState

	// Tool call tracking for Chat→Responses streaming
	ToolCalls     map[int]*chatToolCallState
	TextDoneSent  bool
	TextItemID    string
	FuncOutputIdx int
}

type ResponsesToAnthropicState struct {
	MessageID         string
	Model             string
	InputTokens       int
	OutputTokens      int
	CacheCreateTokens int
	CacheReadTokens   int
	AccText           string
	ContentSent       bool
	MessageStarted    bool
	CurrentBlockIdx   int
	HasToolUse        bool
}

type ResponsesToChatState struct {
	ID                string
	Model             string
	Created           int64
	AccText           string
	Started           bool
	InputTokens       int
	OutputTokens      int
	CacheCreateTokens int
	CacheReadTokens   int
	HasToolCalls      bool

	// Tool call tracking: item_id -> call info
	ToolCallItems map[string]*responsesToChatTC
	ToolCallSeq   int
}

type SSEWriter interface {
	WriteEvent(eventType string, data any)
}

type ThinkTagState struct {
	// contains filtered or unexported fields
}