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
}

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 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
}