contract

type AuthorizationOptions interface {
	Bearer() string

	SetBearer(bearer string)

	Basic() BasicAuthorizationOptions

	SetBasic(basic BasicAuthorizationOptions)
}

type BasicAuthorizationOptions interface {
	Username() string

	SetUsername(username string)

	Password() string

	SetPassword(password string)
}

type Client interface {
	Get(urlString string, options ...RequestOption) (Response, error)

	Post(urlString string, body any, options ...RequestOption) (Response, error)

	Put(urlString string, body any, options ...RequestOption) (Response, error)

	Patch(urlString string, body any, options ...RequestOption) (Response, error)

	Delete(urlString string, options ...RequestOption) (Response, error)

	Request(method string, urlString string, options ...RequestOption) (Response, error)

	/* RequestStream hands back a response whose body is still open. The caller closes it on every path — the streaming path carries no whole-request deadline, so a stream left unclosed holds its connection for the life of the process. */
	RequestStream(method string, urlString string, options ...RequestOption) (StreamResponse, error)
}

type RequestOption func(RequestOptions)

type RequestOptions interface {
	Headers() map[string]string

	Query() map[string]string

	Body() any

	ContentType() string

	Timeout() time.Duration

	Authorization() AuthorizationOptions

	MaxResponseBodyBytes() int

	SetMaxResponseBodyBytes(maxResponseBodyBytes int)

	SetHeader(key string, value string)

	SetHeaders(headers map[string]string)

	SetQuery(key string, value string)

	SetQueryParams(parameters map[string]string)

	SetBody(body any)

	SetJson(data any)

	SetTimeout(timeout time.Duration)

	SetBearerToken(token string)

	SetBasicAuth(username string, password string)
}

type Response interface {
	StatusCode() int

	Status() string

	Headers() nethttp.Header

	Body() []byte

	Request() *nethttp.Request

	Json(target any) error

	String() string

	IsSuccess() bool

	IsClientError() bool

	IsServerError() bool
}

type StreamResponse interface {
	StatusCode() int

	Headers() nethttp.Header

	/* Body is the live body. After Close it reads as a failure rather than a nil reader, so a consumer racing a watchdog gets an error instead of a nil dereference. */
	Body() io.ReadCloser

	Close() error
}