proxycompat

type BufferSource interface {
	Get() *[]byte
	Put(buf *[]byte)
}

type DialFunc func(ctx context.Context, isCONNECT bool, network, addr string) (conn net.Conn, err error)

type MITMInterceptor interface {
	MITM(downstream net.Conn, upstream net.Conn) (newDown net.Conn, newUp net.Conn, success bool, err error)
}

type Opts struct {
	IdleTimeout time.Duration

	BufferSource BufferSource
	Filter       filters.Filter
	OnError      func(cs *filters.ConnectionState, req *http.Request, read bool, err error) *http.Response

	OKWaitsForUpstream  bool
	OKSendsServerTiming bool

	Dial       DialFunc
	ShouldMITM func(req *http.Request, upstreamAddr string) bool
	MITMOpts   *mitm.Opts
	InitMITM   func() (MITMInterceptor, error)
}

type Proxy interface {
	Handle(dialCtx context.Context, in io.Reader, conn net.Conn) error
	Connect(dialCtx context.Context, in io.Reader, conn net.Conn, origin string) error
	Serve(l net.Listener) error
}

type RequestAware interface {
	OnRequest(req *http.Request)
}

type ResponseAware interface {
	OnResponse(req *http.Request, resp *http.Response, err error)
}