+
+
package jsrest
+
+import (
+ "encoding/json"
+ "errors"
+ "fmt"
+ "net/http"
+
+ "github.com/go-resty/resty/v2"
+)
+
+var (
+ ErrBadRequest = NewHTTPError(http.StatusBadRequest)
+ ErrUnauthorized = NewHTTPError(http.StatusUnauthorized)
+ ErrPaymentRequired = NewHTTPError(http.StatusPaymentRequired)
+ ErrForbidden = NewHTTPError(http.StatusForbidden)
+ ErrNotFound = NewHTTPError(http.StatusNotFound)
+ ErrMethodNotAllowed = NewHTTPError(http.StatusMethodNotAllowed)
+ ErrNotAcceptable = NewHTTPError(http.StatusNotAcceptable)
+ ErrProxyAuthRequired = NewHTTPError(http.StatusProxyAuthRequired)
+ ErrRequestTimeout = NewHTTPError(http.StatusRequestTimeout)
+ ErrConflict = NewHTTPError(http.StatusConflict)
+ ErrGone = NewHTTPError(http.StatusGone)
+ ErrLengthRequired = NewHTTPError(http.StatusLengthRequired)
+ ErrPreconditionFailed = NewHTTPError(http.StatusPreconditionFailed)
+ ErrRequestEntityTooLarge = NewHTTPError(http.StatusRequestEntityTooLarge)
+ ErrRequestURITooLong = NewHTTPError(http.StatusRequestURITooLong)
+ ErrUnsupportedMediaType = NewHTTPError(http.StatusUnsupportedMediaType)
+ ErrRequestedRangeNotSatisfiable = NewHTTPError(http.StatusRequestedRangeNotSatisfiable)
+ ErrExpectationFailed = NewHTTPError(http.StatusExpectationFailed)
+ ErrTeapot = NewHTTPError(http.StatusTeapot)
+ ErrMisdirectedRequest = NewHTTPError(http.StatusMisdirectedRequest)
+ ErrUnprocessableEntity = NewHTTPError(http.StatusUnprocessableEntity)
+ ErrLocked = NewHTTPError(http.StatusLocked)
+ ErrFailedDependency = NewHTTPError(http.StatusFailedDependency)
+ ErrTooEarly = NewHTTPError(http.StatusTooEarly)
+ ErrUpgradeRequired = NewHTTPError(http.StatusUpgradeRequired)
+ ErrPreconditionRequired = NewHTTPError(http.StatusPreconditionRequired)
+ ErrTooManyRequests = NewHTTPError(http.StatusTooManyRequests)
+ ErrRequestHeaderFieldsTooLarge = NewHTTPError(http.StatusRequestHeaderFieldsTooLarge)
+ ErrUnavailableForLegalReasons = NewHTTPError(http.StatusUnavailableForLegalReasons)
+
+ ErrInternalServerError = NewHTTPError(http.StatusInternalServerError)
+ ErrNotImplemented = NewHTTPError(http.StatusNotImplemented)
+ ErrBadGateway = NewHTTPError(http.StatusBadGateway)
+ ErrServiceUnavailable = NewHTTPError(http.StatusServiceUnavailable)
+ ErrGatewayTimeout = NewHTTPError(http.StatusGatewayTimeout)
+ ErrHTTPVersionNotSupported = NewHTTPError(http.StatusHTTPVersionNotSupported)
+ ErrVariantAlsoNegotiates = NewHTTPError(http.StatusVariantAlsoNegotiates)
+ ErrInsufficientStorage = NewHTTPError(http.StatusInsufficientStorage)
+ ErrLoopDetected = NewHTTPError(http.StatusLoopDetected)
+ ErrNotExtended = NewHTTPError(http.StatusNotExtended)
+ ErrNetworkAuthenticationRequired = NewHTTPError(http.StatusNetworkAuthenticationRequired)
+)
+
+type HTTPError struct {
+ Code int
+ Message string
+}
+
+func NewHTTPError(code int) *HTTPError {
+ return &HTTPError{
+ Code: code,
+ Message: http.StatusText(code),
+ }
+}
+
+func (err *HTTPError) Error() string {
+ return fmt.Sprintf("[%d] %s", err.Code, err.Message)
+}
+
+type SilentJoinError struct {
+ Wraps []error
+}
+
+func SilentJoin(errs ...error) *SilentJoinError {
+ return &SilentJoinError{
+ Wraps: errs,
+ }
+}
+
+func (err *SilentJoinError) Error() string {
+ return err.Wraps[0].Error()
+}
+
+func (err *SilentJoinError) Unwrap() []error {
+ return err.Wraps
+}
+
+func WriteError(w http.ResponseWriter, err error) {
+ je := ToJSONError(err)
+
+ w.Header().Set("Content-Type", "application/json")
+ w.WriteHeader(je.Code)
+
+ enc := json.NewEncoder(w)
+ _ = enc.Encode(je) //nolint:errchkjson
+}
+
+func Errorf(he *HTTPError, format string, a ...any) error {
+ err := fmt.Errorf(format, a...) //nolint:goerr113
+
+ if GetHTTPError(err) != nil {
+ return err
+ }
+
+ return SilentJoin(err, he)
+}
+
+type JSONError struct {
+ Code int `json:"-"`
+ Messages []string `json:"messages"`
+}
+
+func (je *JSONError) Error() string {
+ if len(je.Messages) > 0 {
+ return je.Messages[0]
+ }
+
+ return "no error message"
+}
+
+func (je *JSONError) Unwrap() error {
+ if len(je.Messages) > 1 {
+ return &JSONError{
+ Code: je.Code,
+ Messages: je.Messages[1:],
+ }
+ }
+
+ return nil
+}
+
+func ToJSONError(err error) *JSONError {
+ je := &JSONError{
+ Code: 500,
+ }
+ je.importError(err)
+
+ return je
+}
+
+func ReadError(resp *resty.Response) error {
+ jse := &JSONError{}
+
+ err := json.Unmarshal(resp.Body(), jse)
+ if err == nil {
+ return jse
+ }
+
+ return NewHTTPError(resp.StatusCode())
+}
+
+type singleUnwrap interface {
+ Unwrap() error
+}
+
+type multiUnwrap interface {
+ Unwrap() []error
+}
+
+func GetHTTPError(err error) *HTTPError {
+ hErr := &HTTPError{}
+
+ if errors.As(err, &hErr) {
+ return hErr
+ }
+
+ return nil
+}
+
+func (je *JSONError) importError(err error) {
+ if he, ok := err.(*HTTPError); ok { //nolint:errorlint
+ je.Code = he.Code
+ }
+
+ if _, is := err.(*SilentJoinError); !is { //nolint:errorlint
+ je.Messages = append(je.Messages, err.Error())
+ }
+
+ if unwrap, ok := err.(singleUnwrap); ok { //nolint:errorlint
+ je.importError(unwrap.Unwrap())
+ } else if unwrap, ok := err.(multiUnwrap); ok { //nolint:errorlint
+ for _, sub := range unwrap.Unwrap() {
+ je.importError(sub)
+ }
+ }
+}
+
+
+
package jsrest
+
+import (
+ "encoding/json"
+ "errors"
+ "net/http"
+
+ "github.com/gopatchy/metadata"
+ "github.com/vfaronov/httpheader"
+)
+
+var ErrUnsupportedContentType = errors.New("unsupported Content-Type")
+
+func Read(r *http.Request, obj any) error {
+ contentType, _ := httpheader.ContentType(r.Header)
+
+ switch contentType {
+ case "":
+ fallthrough
+ case "application/json":
+ break
+
+ default:
+ return Errorf(ErrUnsupportedMediaType, "Content-Type: %s", contentType)
+ }
+
+ dec := json.NewDecoder(r.Body)
+ dec.DisallowUnknownFields()
+
+ err := dec.Decode(obj)
+ if err != nil {
+ return Errorf(ErrBadRequest, "decode JSON request body failed (%w)", err)
+ }
+
+ return nil
+}
+
+func Write(w http.ResponseWriter, obj any) error {
+ m := metadata.GetMetadata(obj)
+
+ w.Header().Set("Content-Type", "application/json")
+ httpheader.SetETag(w.Header(), httpheader.EntityTag{Opaque: m.ETag})
+
+ enc := json.NewEncoder(w)
+
+ err := enc.Encode(obj)
+ if err != nil {
+ return Errorf(ErrInternalServerError, "encode JSON response failed (%w)", err)
+ }
+
+ return nil
+}
+
+func WriteList(w http.ResponseWriter, list []any, etag string) error {
+ w.Header().Set("Content-Type", "application/json")
+ httpheader.SetETag(w.Header(), httpheader.EntityTag{Opaque: etag})
+
+ enc := json.NewEncoder(w)
+
+ err := enc.Encode(list)
+ if err != nil {
+ return Errorf(ErrInternalServerError, "encode JSON response failed (%w)", err)
+ }
+
+ return nil
+}
+
+
+