// Code generated by ogen, DO NOT EDIT. package rest import ( "fmt" "io" "mime" "net/http" "github.com/go-faster/errors" "github.com/go-faster/jx" "github.com/ogen-go/ogen/ogenerrors" "github.com/ogen-go/ogen/validate" ) func decodeCancelDatasetJobResponse(resp *http.Response) (res *CancelDatasetJobNoContent, _ error) { switch resp.StatusCode { case 204: // Code 204. return &CancelDatasetJobNoContent{}, nil } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeCancelPredictionJobResponse(resp *http.Response) (res *CancelPredictionJobNoContent, _ error) { switch resp.StatusCode { case 204: // Code 204. return &CancelPredictionJobNoContent{}, nil } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeCreatePredictionJobResponse(resp *http.Response) (res *PredictionJob, _ error) { switch resp.StatusCode { case 202: // Code 202. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response PredictionJob if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if err := response.Validate(); err != nil { return err } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeDeleteDatasetResponse(resp *http.Response) (res *DeleteDatasetNoContent, _ error) { switch resp.StatusCode { case 204: // Code 204. return &DeleteDatasetNoContent{}, nil } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeGetDatasetJobResponse(resp *http.Response) (res *DownloadJob, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response DownloadJob if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if err := response.Validate(); err != nil { return err } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeGetPredictionJobResponse(resp *http.Response) (res *PredictionJob, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response PredictionJob if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if err := response.Validate(); err != nil { return err } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeGetServiceStatusResponse(resp *http.Response) (res *StatusResponse, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response StatusResponse if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeGetWindFieldResponse(resp *http.Response) (res []WindComponent, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response []WindComponent if err := func() error { response = make([]WindComponent, 0) if err := d.Arr(func(d *jx.Decoder) error { var elem WindComponent if err := elem.Decode(d); err != nil { return err } response = append(response, elem) return nil }); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if response == nil { return errors.New("nil is invalid value") } var failures []validate.FieldError for i, elem := range response { if err := func() error { if err := elem.Validate(); err != nil { return err } return nil }(); err != nil { failures = append(failures, validate.FieldError{ Name: fmt.Sprintf("[%d]", i), Error: err, }) } } if len(failures) > 0 { return &validate.Error{Fields: failures} } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeGetWindMetaResponse(resp *http.Response) (res *WindMeta, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response WindMeta if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if err := response.Validate(); err != nil { return err } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeListDatasetJobsResponse(resp *http.Response) (res []DownloadJob, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response []DownloadJob if err := func() error { response = make([]DownloadJob, 0) if err := d.Arr(func(d *jx.Decoder) error { var elem DownloadJob if err := elem.Decode(d); err != nil { return err } response = append(response, elem) return nil }); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if response == nil { return errors.New("nil is invalid value") } var failures []validate.FieldError for i, elem := range response { if err := func() error { if err := elem.Validate(); err != nil { return err } return nil }(); err != nil { failures = append(failures, validate.FieldError{ Name: fmt.Sprintf("[%d]", i), Error: err, }) } } if len(failures) > 0 { return &validate.Error{Fields: failures} } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeListDatasetsResponse(resp *http.Response) (res *DatasetList, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response DatasetList if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if err := response.Validate(); err != nil { return err } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodePerformPredictionResponse(resp *http.Response) (res *PredictionResponse, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response PredictionResponse if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if err := response.Validate(); err != nil { return err } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodePerformPredictionV2Response(resp *http.Response) (res *PredictionV2Response, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response PredictionV2Response if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if err := response.Validate(); err != nil { return err } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeReadinessCheckResponse(resp *http.Response) (res *ReadinessResponse, _ error) { switch resp.StatusCode { case 200: // Code 200. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response ReadinessResponse if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } // Validate response. if err := func() error { if err := response.Validate(); err != nil { return err } return nil }(); err != nil { return res, errors.Wrap(err, "validate") } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") } func decodeTriggerDatasetDownloadResponse(resp *http.Response) (res *DownloadAccepted, _ error) { switch resp.StatusCode { case 202: // Code 202. ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response DownloadAccepted if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &response, nil default: return res, validate.InvalidContentType(ct) } } // Convenient error response. defRes, err := func() (res *DefaultErrorStatusCode, err error) { ct, _, err := mime.ParseMediaType(resp.Header.Get("Content-Type")) if err != nil { return res, errors.Wrap(err, "parse media type") } switch { case ct == "application/json": buf, err := io.ReadAll(resp.Body) if err != nil { return res, err } d := jx.DecodeBytes(buf) var response Error if err := func() error { if err := response.Decode(d); err != nil { return err } if err := d.Skip(); err != io.EOF { return errors.New("unexpected trailing data") } return nil }(); err != nil { err = &ogenerrors.DecodeBodyError{ ContentType: ct, Body: buf, Err: err, } return res, err } return &DefaultErrorStatusCode{ StatusCode: resp.StatusCode, Response: response, }, nil default: return res, validate.InvalidContentType(ct) } }() if err != nil { return res, errors.Wrapf(err, "default (code %d)", resp.StatusCode) } return res, errors.Wrap(defRes, "error") }