httpclient

type Header struct {
	HeaderKey string
	Value     string
}

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

type Query struct {
	QueryKey string
	Value    string
}

type Request struct {
	Method  string
	URL     string
	Queries []Query
	Headers []Header
	Body    []byte
}

type Response struct {
	StatusCode int      `json:"statusCode"`
	Body       []byte   `json:"body"`
	Headers    []Header `json:"headers"`
	// URL is the URL the response came from, after any redirects; Redirects is how many
	// redirects were followed to get there.
	URL       string `json:"url,omitempty"`
	Redirects int    `json:"redirects,omitempty"`
	// Stream is set when the response was read as a stream (see SendRequestAndConvertStream).
	Stream *StreamResult `json:"stream,omitempty"`
}

type ResponseVar struct {
	StatusCode int               `json:"status"`
	Body       any               `json:"body"`
	Headers    map[string]string `json:"headers"`
	Duration   int32             `json:"duration"`
	// URL is the final URL after redirects (response.url); Redirects how many were followed
	// (response.redirects).
	URL       string `json:"url"`
	Redirects int    `json:"redirects"`
	// Stream is the streamed response's result; StreamFields exposes it to expressions.
	Stream *StreamResult `json:"-"`
}

type StreamEvent struct {
	Event string `json:"event,omitempty"`
	Data  any    `json:"data"`
	ID    string `json:"id,omitempty"`
}

type StreamOptions struct {
	// Preset assembles the text; "" is raw sse.
	Preset string
	// Timeout is the longest the stream may stay open; 0 is DefaultStreamTimeout.
	Timeout time.Duration
}

type StreamResult struct {
	Preset string `json:"preset"`
	// Text is the message assembled by the preset.
	Text string `json:"text"`
	// Events are the first MaxStreamEvents events; EventCount counts all of them.
	Events     []StreamEvent `json:"events,omitempty"`
	EventCount int           `json:"event_count"`
	// TTFT is the time from sending the request to the first event that added text (raw sse:
	// the first data event). Nil when none did.
	TTFT *time.Duration `json:"ttft,omitempty"`
	// Usage is the token usage the stream reported, merged across events.
	Usage map[string]any `json:"usage,omitempty"`
}