chat

type Client interface {
	// StreamSnapshots sends the conversation to the Chat API and streams normalized snapshots.
	// Each snapshot includes scoped progress metadata (conversation/turn/seq/status).
	StreamSnapshots(ctx context.Context, req Request, onSnapshot func(StreamSnapshot)) (*StreamResult, error)

	// Stream sends the conversation to the Chat API and streams the response.
	// The onMessage callback is called each time the message is updated with new content.
	// The returned StreamResult contains the final message and any metadata.
	Stream(ctx context.Context, req Request, onMessage func(*domain.Message)) (*StreamResult, error)

	// SetAccountID sets the account ID for requests.
	SetAccountID(accountID domain.AccountID)
	// WithAccountID returns a new client scoped to accountID.
	WithAccountID(accountID domain.AccountID) Client
}

type EventType string

type HTTPDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

type Items struct {
	Type  string `json:"type,omitempty"`
	Items *Items `json:"items,omitempty"`
}

type Property struct {
	Type        string   `json:"type,omitempty"`
	Description string   `json:"description,omitempty"`
	Enum        []string `json:"enum,omitempty"`
	Items       *Items   `json:"items,omitempty"`
}

type Request struct {
	ConversationID string                 `json:"conversation_id"`
	Messages       []domain.Message       `json:"messages"`
	Context        []domain.ContextEntity `json:"context,omitempty"`
	Tools          []Tool                 `json:"tools"`
}

type Schema struct {
	Type       string              `json:"type"`
	Properties map[string]Property `json:"properties"` // Always required by Anthropic API
	Required   []string            `json:"required,omitempty"`
}

type StreamErrorClass string

type StreamMetadata struct {
	Title         string // AI-generated conversation title, set after first exchange
	ContextWindow int    // Model's max token capacity (from message_start)
	InputTokens   int    // Tokens consumed by input this turn (from message_stop)
	OutputTokens  int    // Tokens generated by output this turn (from message_stop)
}

type StreamResult struct {
	Message  *domain.Message
	Metadata *StreamMetadata // nil if no metadata_update event was received
}

type StreamSnapshot struct {
	ConversationID string
	TurnID         string
	Seq            int
	Status         StreamStatus
	AbortReason    string
	Done           bool
	Message        *domain.Message
	Metadata       *StreamMetadata
}

type StreamStatus string

type Tool struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	InputSchema Schema `json:"input_schema"`
}