szhttp

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

type Context interface {
	RequestContext
	Request
	ResponseWriter
	Unwrap() any
	X() *edgepb.ContextExtra

	Render(statusCode int, component templ.Component) error
	RequestBodyStream() io.Reader
	VisitRequestHeaders(visitor func(k, v []byte))
	VisitResponseHeaders(visitor func(k, v []byte))
}

type Option struct {
	CertFile    string
	CertKeyFile string
	TLSConfig   *tls.Config
	ServerName  []byte

	OnStdConnect func(context.Context, net.Conn) context.Context
	StdListener  net.Listener

	OnQuicConnect func(context.Context, *quic.Conn) context.Context
	QuicListener  http3.QUICListener
}

type Request interface {
	Context() context.Context
	Headers() map[string][][]byte
	Queries() map[string][][]byte
	Query(k []byte) []byte
	QueryStr() []byte
	Header(k []byte) []byte
	Path() []byte
	URI() []byte
	Body() []byte
	JA4() string
	TLS() bool
	Method() []byte
	Host() []byte
	StatusCode() int
	Protocol() string
	Scheme() string
	RemoteAddr() []byte
	RequestIP() []byte
	RequestTime() time.Time
	SetHeader(key, value []byte)
	SetQuery(key []byte, values ...[]byte)
	SetPath(p []byte)
	SetURI(u []byte)
	SetBody(b []byte)
	SetStatusCode(code int)
	SetHost(h []byte)
}

type RequestContext interface {
	RequestId() string
	SetRequestId(id string)

	ResourceId() string
	SetResourceId(id string)

	TenantId() string
	SetTenantId(id string)
}

type RequestHandler func(Context) error

type ResponseWriter interface {
	ResponseHeader() map[string][][]byte
	ResponseBody() []byte

	SetResponseHeader(key, value []byte)
	AddResponseHeader(key, value []byte)
	ResetResponse()

	String(statusCode int, msg []byte) error
	JSON(statusCode int, body []byte) error
	File(path string) error
	Flush() error
	Copy(src io.Reader) error
}

type ReverseProxy interface {
	Serve(ctx Context)
}

type Server interface {
	Shutdown(ctx context.Context) error
	ListenAndServe(addr string, opts ...ServerOption) error
	Use(mdw ...func(next RequestHandler) RequestHandler)
	Handle(fn RequestHandler)
	AcceptReverse(target string) (ReverseProxy, error)
}

type ServerOption func(opt *Option)