protocol

type Adapter interface {
	// ValidateEvent checks whether event can be encoded for this protocol.
	ValidateEvent(chat.Event) error
	// Response builds a non-streaming response body for result.
	Response(chat.Request, execution.Result, Meta) (any, error)
	// Stream returns an SSE encoder for the given response writer.
	// meta is retained for the stream lifetime so terminal Response
	// updates are visible to Complete.
	Stream(http.ResponseWriter, ParsedRequest, *Meta, chat.Limits) StreamEncoder
}

type Kind uint8

type Meta struct {
	Response chat.Response // identity, status, output, and retrieval fields
	Activity bool          // when true, Responses may encode EventActivity frames
}

type ParsedRequest struct {
	Kind         Kind              // wire protocol that parsed the request
	Request      chat.Request      // canonical execution request for Agent.Run
	Turn         []chat.Item       // items submitted in this HTTP request only
	Previous     *string           // prior response ID for continuation
	Store        *bool             // wire store flag; nil when omitted
	Metadata     map[string]string // application metadata for the response
	Retain       bool              // effective retention after StoreDefault
	Stream       bool              // whether the client requested streaming
	IncludeUsage bool              // Chat Completions stream_options.include_usage only
}

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

type StreamEncoder interface {
	// Event encodes one canonical agent event into protocol SSE frames.
	Event(chat.Event) error
	// Complete emits terminal stream events and closes the SSE lifecycle.
	Complete(chat.Outcome, []chat.Item) error
	// Fail writes a protocol-specific error response for the stream.
	Fail(error) error
	// Started reports whether SSE output has begun.
	Started() bool
}