tap

type Binding struct {
	Env    string // e.g. "ANTHROPIC_BASE_URL"
	Route  string // Route.Name
	Suffix string // appended to the route URL, e.g. "/v1" for OpenAI-style bases
}

type Body struct {
	Text      string `json:"text,omitempty"`
	Size      int64  `json:"size"`
	Encoding  string `json:"encoding,omitempty"`
	Truncated bool   `json:"truncated,omitempty"`
}

type CLI struct {
	Name     string // the command, e.g. "claude"
	Bindings []Binding
	Note     string // limits worth knowing, shown by `acurl tap env --list`
}

type Event struct {
	Exchange *Exchange `json:"exchange,omitempty"`
	// Dropped counts exchanges this viewer missed because it read too slowly.
	Dropped int64 `json:"dropped,omitempty"`
}

type Exchange struct {
	ID         int64         `json:"id"`
	Start      time.Time     `json:"start"`
	Duration   time.Duration `json:"duration_ns"`
	Route      string        `json:"route"`
	Method     string        `json:"method"`
	URL        string        `json:"url"`
	Model      string        `json:"model,omitempty"`
	ReqHeader  http.Header   `json:"request_headers"`
	ReqBody    Body          `json:"request_body"`
	Status     int           `json:"status,omitempty"`
	RespHeader http.Header   `json:"response_headers,omitempty"`
	RespBody   Body          `json:"response_body"`
	Streaming  bool          `json:"streaming,omitempty"`
	Upgrade    string        `json:"upgrade,omitempty"` // e.g. "websocket"; frames are not recorded
	Err        string        `json:"error,omitempty"`
	Canceled   bool          `json:"canceled,omitempty"` // the CLI hung up before the response ended
	Redactions []Redaction   `json:"redactions,omitempty"`
}

type Info struct {
	Name            string `json:"name"` // always "acurl tap"
	Version         string `json:"version"`
	PID             int    `json:"pid"`
	MaxBody         int    `json:"max_body"`
	KeepCredentials bool   `json:"keep_credentials"`
	Viewers         int    `json:"viewers"`
}

type Options struct {
	Routes  []Route // DefaultRoutes when empty
	MaxBody int     // DefaultMaxBody when zero
	// KeepCredentials leaves API keys, tokens and cookies in captures.
	KeepCredentials bool
	// Secrets are extra strings removed from headers, URLs and bodies.
	Secrets []string
	// OnExchange receives every finished exchange, as do viewers connected
	// to EventsPath. It is called from many goroutines at once.
	OnExchange func(*Exchange)
	// OnStop is called when a client asks the proxy to stop through
	// StopPath. Without it, StopPath is refused.
	OnStop func()
	// Version is reported by PingPath.
	Version string
	// Transport sends requests upstream; a clone of http.DefaultTransport
	// when nil.
	Transport http.RoundTripper
}

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

type Redaction struct {
	Where  string `json:"where"`  // e.g. "request.header.x-api-key"
	Reason string `json:"reason"` // "credential" or "user secret"
}

type Route struct {
	Name     string // shown in captures, e.g. "anthropic"
	Prefix   string // path prefix on the proxy, e.g. "/anthropic"
	Upstream string // scheme and host, e.g. "https://api.anthropic.com"
}