modelbridge

type CompatibilityWarning struct {
	Code    string
	Message string
}

type ConvertedRequest struct {
	Method   string
	URL      string
	Path     string
	Header   http.Header
	Summary  RequestSummary
	Warnings []CompatibilityWarning
	// Request is the fully constructed upstream HTTP request.
	// Its Body has been read and reset; callers may read it multiple times.
	Request *http.Request
}

type ConvertedResponse struct {
	Status   int
	Header   http.Header
	Body     []byte
	Info     ResponseInfo
	Warnings []CompatibilityWarning
}

type ConvertedStream struct {
	Status   int
	Header   http.Header
	Warnings []CompatibilityWarning
}

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

type Options struct {
	// AnthropicVersion is the fallback anthropic-version header for Claude targets.
	AnthropicVersion string
	// DefaultMaxTokens is used for Claude targets when the inbound request omits max tokens.
	DefaultMaxTokens int
	// AnthropicSendAuthorization also sends Authorization: Bearer <token> to Claude targets.
	AnthropicSendAuthorization bool
	// StreamFrameLimit bounds one upstream SSE/NDJSON frame. Zero uses the safe
	// default; a negative value disables the bound for a trusted endpoint.
	StreamFrameLimit int
}

type RequestConversion struct {
	SourceProtocol string
	TargetProtocol string
	SourcePath     string
	// SourceHeader is the inbound client request header. Claude targets use it
	// to pass through anthropic-version and anthropic-beta when present.
	SourceHeader  http.Header
	Body          []byte
	TargetBaseURL string
	TargetToken   string
	TargetModel   string
}

type RequestSummary struct {
	SourceProtocol     string
	Model              string
	Stream             bool
	InputText          string
	SystemText         string
	MaxOutputTokens    int
	HasMaxOutputTokens bool
	ToolCount          int
	ToolText           string
}

type RequestSummaryConversion struct {
	SourceProtocol string
	SourcePath     string
	SourceHeader   http.Header
	Body           []byte
}

type ResponseConversion struct {
	SourceProtocol string
	TargetProtocol string
	Body           []byte
	Options        ResponseOptions
}

type ResponseInfo struct {
	ID            string
	Model         string
	Text          string
	ReasoningText string
	FinishReason  string
	Usage         *UsageInfo
	// GatewayMetrics carries this bridge's own timing/throughput telemetry
	// for the converted response. It is a pointer so ResponseInfo stays
	// comparable for callers that use it as a map key. It is nil when the
	// caller did not supply telemetry (library conversions that are not part
	// of a timed forward).
	GatewayMetrics *metrics.Sample
}

type ResponseOptions struct {
	// ExposeReasoning controls whether Claude-source responses expose
	// reasoning/thinking content to the downstream Claude client. Integrity
	// blocks accompanying a tool call are retained on same-Claude relays because
	// some compatible upstreams require them on the next turn.
	ExposeReasoning bool
}

type StreamConversion struct {
	SourceProtocol string
	TargetProtocol string
	Options        ResponseOptions

	// OnEvent observes normalized semantic events accepted by the destination
	// writer after ResponseOptions display filtering. Provider Raw carrier frames
	// are omitted; their standard semantic companion events are reported once.
	// The callback is synchronous and should stay lightweight.
	OnEvent func(StreamEventInfo)

	// Response is the upstream streaming response. When set, Body, Header, and
	// StatusCode are read from it.
	Response *http.Response

	// Body is the upstream streaming response body. It is used when Response is
	// nil, and is closed after conversion when it also implements io.Closer.
	Body       io.Reader
	Header     http.Header
	StatusCode int
}

type StreamEventInfo struct {
	Type           StreamEventType
	ID             string
	Model          string
	Index          int
	ChoiceIndex    int
	HasChoiceIndex bool

	TextDelta          string
	ReasoningDelta     string
	ReasoningSignature string
	ToolCall           *ToolCallDeltaInfo
	Usage              *UsageInfo
	FinishReason       string
}

type StreamEventType string

type ToolCallDeltaInfo struct {
	ID        string
	Name      string
	ArgsDelta string
}

type UsageInfo struct {
	InputTokens         int
	OutputTokens        int
	TotalTokens         int
	CacheReadTokens     int
	CacheCreationTokens int
	CacheMissTokens     int
	ReasoningTokens     int
	Extra               map[string]any
	// TokenSource reports whether the counters above came from the upstream
	// or were estimated locally. It mirrors the value exposed in
	// GatewayMetrics and is empty for library conversions that carry no
	// provenance information.
	TokenSource string
}