adapter

type Adapter interface {
	Head(ctxt context.Context, path string, headers *map[string]string, logger *log.Logger) (Payload, error)
	Get(ctxt context.Context, path string, logger *log.Logger) (Payload, error)
	GetWithHandler(ctxt context.Context, path string, headers *map[string]string, respHandler ResponseHandler, logger *log.Logger) error
	Post(ctxt context.Context, path string, body io.Reader, length int64, headers *map[string]string, logger *log.Logger) (Payload, error)
	PostWithHandler(ctxt context.Context, path string, body io.Reader, length int64, headers *map[string]string, respHandler ResponseHandler, logger *log.Logger) (Payload, error)
	PostForm(ctxt context.Context, path string, data url.Values, headers *map[string]string, logger *log.Logger) (Payload, error)
	Put(ctxt context.Context, path string, body io.Reader, length int64, headers *map[string]string, logger *log.Logger) (Payload, error)
	Patch(ctxt context.Context, path string, body io.Reader, length int64, headers *map[string]string, logger *log.Logger) (Payload, error)
	Delete(ctxt context.Context, path string, logger *log.Logger) (Payload, error)
	GetSSE(ctxt context.Context, path string, lastEventID *string, onEvent func(*sse.Event), headers *map[string]string, logger *log.Logger) error
	SetUrl(url string)
	GetPath(url string) (path string, err error)
}

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

type ApiError struct {
	AdapterError
	StatusCode int
	Payload    Payload
}

type ClientError struct {
	AdapterError
	// contains filtered or unexported fields
}

type ConnectionCtxt struct {
	URL         string
	AccessToken string
	TimeoutSec  int
	Headers     *map[string]string // default headers
}

type IAdapterError interface {
	Error() string
	Path() string
}

type MissingUrlError struct {
	AdapterError
}

type Option func(adpr *restAdapter)

type Payload interface {
	// IsObject() bool
	AsType(r interface{}) error
	AsObject() (map[string]interface{}, error)
	AsArray() ([]interface{}, error)
	AsBytes() []byte
	AsReader() (io.Reader, int64)
	IsEmpty() bool
	Header(key string) string
	ContentType() string
	StatusCode() int
}

type ResourceNotFoundError struct {
	AdapterError
}

type ResponseHandler func(response *http.Response, path string, logger *log.Logger) (err error)

type UnauthorizedError struct {
	AdapterError
}