types

type BodyCodec struct {
	Transforms  []string `json:"transforms,omitempty" msgpack:"tr,omitempty"`
	ContentType string   `json:"content_type,omitempty" msgpack:"ct,omitempty"`
}

type CertSpec struct {
	DNSNames    []string
	IPAddresses []net.IP
	URIs        []*url.URL
	Emails      []string
	CommonName  string // upstream/declared CN; added as a SAN, not the leaf Subject.CN
}

type ChunkFrame struct {
	// SizeLine is the raw size line without terminator, preserving extensions (e.g. "4;foo=bar") and hex casing.
	SizeLine []byte `json:"size_line,omitempty" msgpack:"sl,omitempty"`

	// SizeEnding is the terminator after the size line.
	SizeEnding LineEnding `json:"size_ending,omitempty" msgpack:"se,omitempty"`

	// Size is the chunk payload length in bytes (0 for final terminator chunk).
	Size int `json:"size,omitempty" msgpack:"sz,omitempty"`

	// DataEnding is the terminator after the chunk data. On the final 0-chunk it
	// is the trailer block's closing blank-line terminator, or EndingNone if truncated.
	DataEnding LineEnding `json:"data_ending,omitempty" msgpack:"de,omitempty"`

	// Malformed marks the trailing frame after a bad hex size; SizeLine holds
	// the raw bytes verbatim and the parser does not read past it.
	Malformed bool `json:"malformed,omitempty" msgpack:"mf,omitempty"`
}

type Flow struct {
	// FlowID is the unique identifier, minted at Store time.
	FlowID string `json:"flow_id" msgpack:"fid"`

	// Adapter is the name of the adapter that emitted the flow.
	Adapter string `json:"adapter" msgpack:"ad"`

	// ProtocolTag is the protocol identifier within the adapter
	// (e.g. "http/1.1", "http/2", "websocket", "websocket.frame").
	ProtocolTag string `json:"protocol_tag" msgpack:"pr"`

	// Direction orients a one-way message: client_to_server, server_to_client,
	// or bidirectional. Empty for two-sided request/response flows.
	Direction string `json:"direction,omitempty" msgpack:"dir,omitempty"`

	// ParentFlowID links a child flow to its parent (e.g. a frame to its handshake).
	ParentFlowID string `json:"parent_flow_id,omitempty" msgpack:"pid,omitempty"`

	// Scheme is the captured request scheme ("http" or "https").
	Scheme string `json:"scheme,omitempty" msgpack:"sc,omitempty"`
	// Port is the captured upstream port.
	Port int `json:"port,omitempty" msgpack:"po,omitempty"`

	// Request and/or Response sides of the exchange.
	Request  *Message `json:"request,omitempty" msgpack:"rq,omitempty"`
	Response *Message `json:"response,omitempty" msgpack:"rs,omitempty"`

	// InterimResponses holds 1xx responses received before the final Response.
	InterimResponses []*Message `json:"interim_responses,omitempty" msgpack:"ir,omitempty"`

	// Timing metadata.
	StartedAt   time.Time `json:"started_at" msgpack:"ts"`
	CompletedAt time.Time `json:"completed_at,omitempty" msgpack:"ca,omitempty"`

	// Annotations is open-ended, exclusively sidecar-authored metadata.
	Annotations map[string]any `json:"annotations,omitempty" msgpack:"an,omitempty"`

	// InvokedBy names the sidecar that originated a cross-adapter message.
	InvokedBy string `json:"invoked_by,omitempty" msgpack:"ib,omitempty"`
	// SidecarInstanceID attributes a sidecar-emitted flow.
	SidecarInstanceID string `json:"sidecar_instance_id,omitempty" msgpack:"si,omitempty"`
}

type Header struct {
	// Name preserves original casing and whitespace anomalies
	// (e.g., "Content-Type", "content-type", or "Header " with trailing space)
	Name string `json:"name" msgpack:"n"`

	// Value is the header value with leading/trailing whitespace trimmed
	Value string `json:"value" msgpack:"v"`

	// RawLine contains the original wire bytes for this header (excluding line ending).
	// Used by SerializeRaw() to preserve exact wire format including obs-fold.
	// nil when header was programmatically created or Wire format not tracked.
	RawLine []byte `json:"raw_line,omitempty" msgpack:"rl,omitempty"`

	// LineEnding is the terminator observed for this header's final physical line.
	LineEnding LineEnding `json:"line_ending,omitempty" msgpack:"le,omitempty"`
}

type Headers []Header

type HistoryMeta struct {
	FlowID       string `msgpack:"fid"`
	Protocol     string `msgpack:"pr"`
	Adapter      string `msgpack:"ad,omitempty"`
	ParentFlowID string `msgpack:"pid,omitempty"`

	Scheme      string        `msgpack:"sc,omitempty"`
	Port        int           `msgpack:"po,omitempty"`
	Method      string        `msgpack:"m"`
	Host        string        `msgpack:"h"`
	Path        string        `msgpack:"p"` // includes query string
	Status      int           `msgpack:"s"`
	ContentType string        `msgpack:"ct"`
	RespLen     int           `msgpack:"rl"`
	Timestamp   time.Time     `msgpack:"ts"`
	Duration    time.Duration `msgpack:"d"`

	// Annotations carries the flow's sidecar-authored metadata.
	Annotations map[string]any `msgpack:"an,omitempty"`

	InvokedBy         string `msgpack:"ib,omitempty"`
	SidecarInstanceID string `msgpack:"si,omitempty"`
}

type LineEnding uint8

type Message struct {
	// Request-line fields (request side)
	Method string `json:"method,omitempty" msgpack:"m,omitempty"`
	Path   string `json:"path,omitempty" msgpack:"p,omitempty"`
	Query  string `json:"query,omitempty" msgpack:"q,omitempty"`

	// Version is "HTTP/1.1" / "HTTP/1.0" on either side.
	Version string `json:"version,omitempty" msgpack:"v,omitempty"`

	// Status-line fields (response side)
	StatusCode int    `json:"status_code,omitempty" msgpack:"sc,omitempty"`
	StatusText string `json:"status_text,omitempty" msgpack:"st,omitempty"`

	// Headers preserves order and original name casing/whitespace.
	Headers Headers `json:"headers" msgpack:"h"`

	// Body is the message body (decoded if chunked, raw otherwise).
	Body []byte `json:"body,omitempty" msgpack:"b,omitempty"`

	// BodyRaw holds the original wire bytes, set by an adapter only when they
	// differ from a decoded logical Body (protobuf, custom framing). nil
	// whenever Body already is the wire payload (HTTP and most flows). Replayed
	// verbatim when Body is unmutated.
	BodyRaw []byte `json:"body_raw,omitempty" msgpack:"br,omitempty"`

	// BodyCodec is the transform chain and logical content-type mapping BodyRaw
	// to Body, used to re-encode a mutated Body on replay. Set only with BodyRaw.
	BodyCodec *BodyCodec `json:"body_codec,omitempty" msgpack:"bc,omitempty"`

	// Trailers for chunked encoding (raw bytes).
	Trailers []byte `json:"trailers,omitempty" msgpack:"t,omitempty"`

	// Chunks preserves per-chunk wire framing for chunked messages.
	Chunks []ChunkFrame `json:"chunks,omitempty" msgpack:"ck,omitempty"`

	// FirstLineEnding is the terminator on the request-line or status-line.
	FirstLineEnding LineEnding `json:"first_line_ending,omitempty" msgpack:"fle,omitempty"`

	// HeaderBlockEnding is the terminator on the blank line ending the header block.
	HeaderBlockEnding LineEnding `json:"header_block_ending,omitempty" msgpack:"hbe,omitempty"`

	// Wire contains metadata about the original wire encoding.
	Wire *WireFormat `json:"wire,omitempty" msgpack:"w,omitempty"`

	// CloseDelimited indicates a response body framed by connection close.
	CloseDelimited bool `json:"-" msgpack:"-"`
}

type RawHTTP1Request struct {
	// Request line components
	Method  string `json:"method" msgpack:"m"`                    // "GET", "POST", etc.
	Path    string `json:"path" msgpack:"p"`                      // path without query string, e.g., "/path"
	Query   string `json:"query,omitempty" msgpack:"q,omitempty"` // query string without leading ?, e.g., "foo=bar"
	Version string `json:"version" msgpack:"v"`                   // "HTTP/1.1" or "HTTP/1.0"

	// Headers preserves order and original name casing/whitespace
	Headers Headers `json:"headers" msgpack:"h"`

	// Body is the request body (decoded if chunked, raw otherwise)
	// For chunked encoding, this contains the reassembled body without chunk framing
	Body []byte `json:"body,omitempty" msgpack:"b,omitempty"`

	// Trailers for chunked encoding (raw bytes, rare but must preserve)
	// TODO - FUTURE - Parse trailers into []Header if trailer rules are needed
	Trailers []byte `json:"trailers,omitempty" msgpack:"t,omitempty"`

	// Chunks preserves per-chunk wire framing for chunked messages.
	// When body is mutated, callers must set to nil to avoid stale state being re-emitted.
	Chunks []ChunkFrame `json:"chunks,omitempty" msgpack:"ck,omitempty"`

	// Protocol metadata for replay fidelity
	Protocol string `json:"protocol" msgpack:"pr"` // "http/1.1" - stored for history/replay

	// RequestLineEnding is the terminator observed on the request line.
	RequestLineEnding LineEnding `json:"request_line_ending,omitempty" msgpack:"rle,omitempty"`

	// HeaderBlockEnding is the terminator observed on the blank line that ends the header block.
	HeaderBlockEnding LineEnding `json:"header_block_ending,omitempty" msgpack:"hbe,omitempty"`

	// Wire contains metadata about the original wire encoding.
	// Used by SerializeRaw() to preserve exact wire format.
	Wire *WireFormat `json:"wire,omitempty" msgpack:"w,omitempty"`
}

type RawHTTP1Response struct {
	// Status line components
	Version    string `json:"version" msgpack:"v"`                          // "HTTP/1.1" or "HTTP/1.0"
	StatusCode int    `json:"status_code" msgpack:"sc"`                     // 200, 404, etc.
	StatusText string `json:"status_text,omitempty" msgpack:"st,omitempty"` // "OK", "Not Found", etc.

	// Headers preserves order and original name casing
	Headers Headers `json:"headers" msgpack:"h"`

	// Body is the response body (decoded if chunked, raw otherwise)
	Body []byte `json:"body,omitempty" msgpack:"b,omitempty"`

	// Trailers for chunked encoding (raw bytes)
	// TODO - FUTURE - Parse trailers into []Header if trailer rules are needed
	Trailers []byte `json:"trailers,omitempty" msgpack:"t,omitempty"`

	// Chunks preserves per-chunk wire framing for chunked messages.
	// When body is mutated, callers must set to nil to avoid stale state being re-emitted.
	Chunks []ChunkFrame `json:"chunks,omitempty" msgpack:"ck,omitempty"`

	// StatusLineEnding is the terminator observed on the status line.
	StatusLineEnding LineEnding `json:"status_line_ending,omitempty" msgpack:"sle,omitempty"`

	// HeaderBlockEnding is the terminator observed on the blank line that ends the header block.
	HeaderBlockEnding LineEnding `json:"header_block_ending,omitempty" msgpack:"hbe,omitempty"`

	// Wire contains metadata about the original wire encoding.
	// Used by SerializeRaw() to preserve exact wire format.
	Wire *WireFormat `json:"wire,omitempty" msgpack:"w,omitempty"`

	// CloseDelimited indicates the body was framed by connection close (no Content-Length, not chunked).
	CloseDelimited bool `json:"-" msgpack:"-"`
}

type RuleApplier interface {
	// ApplyRequestRules applies request header and body rules.
	// Returns the modified request (may be same instance if no changes).
	ApplyRequestRules(req *RawHTTP1Request) *RawHTTP1Request

	// ApplyResponseRules applies response header and body rules.
	// Handles decompression/recompression for body rules.
	ApplyResponseRules(resp *RawHTTP1Response) *RawHTTP1Response

	// ApplyRequestBodyOnlyRules applies only body rules to a request body.
	// Used by HTTP/2 where headers are sent separately before body.
	// Requires headers for Content-Encoding detection (compression-aware).
	// Does not apply header rules.
	// Returns error if recompression fails (caller should reset stream).
	ApplyRequestBodyOnlyRules(body []byte, headers Headers) ([]byte, error)

	// ApplyResponseBodyOnlyRules applies only body rules to a response body.
	// Used by HTTP/2 where headers are sent separately before body.
	// Requires headers for Content-Encoding detection (compression-aware).
	// Does not apply header rules.
	ApplyResponseBodyOnlyRules(body []byte, headers Headers) []byte

	// ApplyWSRules applies WebSocket rules to frame payload.
	// direction is "ws:to-server" or "ws:to-client".
	ApplyWSRules(payload []byte, direction string) []byte

	// HasBodyRules returns true if there are body rules for request or response.
	// Used by HTTP/2 handler to decide whether to buffer full bodies.
	// isRequest=true checks for request_body rules, false checks for response_body rules.
	HasBodyRules(isRequest bool) bool
}

type Target struct {
	Hostname  string
	Port      int
	UsesHTTPS bool
}

type WireFormat struct {
	// WasChunked indicates chunked transfer encoding was received.
	WasChunked bool `json:"was_chunked,omitempty" msgpack:"wc,omitempty"`

	// UsedBareLF is true when any line used bare LF (\n) as terminator.
	UsedBareLF bool `json:"used_bare_lf,omitempty" msgpack:"lf,omitempty"`

	// UsedBareCR is true when any line used bare CR (\r) as terminator.
	UsedBareCR bool `json:"used_bare_cr,omitempty" msgpack:"cr,omitempty"`
}