feat: added bodyDecodeErrorHandler function

Author: ralvarezdev

http/json/body.go

@@ -0,0 +1,60 @@
+package json
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	gonethttpresponse "github.com/ralvarezdev/go-net/http/response"
+	"net/http"
+)
+
+// bodyDecodeErrorHandler handles the error on JSON body decoding
+func bodyDecodeErrorHandler(
+	w http.ResponseWriter,
+	err error,
+	encoder Encoder,
+) error {
+	// Check if the encoder is nil
+	if encoder == nil {
+		return ErrNilEncoder
+	}
+
+	// Check is there is an UnmarshalTypeError
+	var unmarshalTypeError *json.UnmarshalTypeError
+	if errors.As(err, &unmarshalTypeError) {
+		// Check which field failed
+		fieldName := unmarshalTypeError.Field
+		fieldTypeName := unmarshalTypeError.Type.Name()
+		fieldValue := unmarshalTypeError.Value
+
+		// Check if the field name is empty
+		if fieldName != "" {
+			return encoder.Encode(
+				w,
+				gonethttpresponse.NewDebugFailResponse(
+					gonethttpresponse.NewSingleFieldErrorsBodyData(
+						fieldName,
+						fmt.Errorf(
+							ErrFieldInvalidValue,
+							fieldTypeName,
+							fieldValue,
+						),
+					),
+					err,
+					nil,
+					http.StatusBadRequest,
+				),
+			)
+		}
+	}
+
+	return encoder.Encode(
+		w,
+		gonethttpresponse.NewDebugFailResponse(
+			ErrUnmarshalBodyDataFailed,
+			err,
+			nil,
+			http.StatusBadRequest,
+		),
+	)
+}

http/json/data.go

@@ -3,6 +3,7 @@ package json
 import (
 	"encoding/json"
 	goflagsmode "github.com/ralvarezdev/go-flags/mode"
+	gonethttperrors "github.com/ralvarezdev/go-net/http/errors"
 	gonethttpresponse "github.com/ralvarezdev/go-net/http/response"
 	"io"
 	"net/http"
@@ -14,7 +15,7 @@ type (
 		Decode(
 			w http.ResponseWriter,
 			r *http.Request,
-			data interface{},
+			dest interface{},
 		) (err error)
 	}
 
@@ -41,34 +42,28 @@ func NewDefaultDecoder(
 	}, nil
 }
 
-// Decode decodes the JSON data from the request
+// Decode decodes the JSON request body and stores it in the destination
 func (d *DefaultDecoder) Decode(
 	w http.ResponseWriter,
 	r *http.Request,
-	data interface{},
+	dest interface{},
 ) (err error) {
-	// Check the data type
-	if err = checkJSONData(w, data, d.mode, d.encoder); err != nil {
-		return err
-	}
-
-	// Get the body of the request
-	body, err := io.ReadAll(r.Body)
-	if err != nil {
+	// Check the decoder destination
+	if dest == nil {
 		_ = d.encoder.Encode(
-			w,
-			gonethttpresponse.NewErrorResponse(
+			w, gonethttpresponse.NewDebugErrorResponse(
+				gonethttperrors.InternalServerError,
 				err,
 				nil,
 				nil,
-				http.StatusBadRequest,
+				http.StatusInternalServerError,
 			),
 		)
-		return err
 	}
 
-	// Decode JSON data
-	if err = json.Unmarshal(body, data); err != nil {
+	// Get the body of the request
+	body, err := io.ReadAll(r.Body)
+	if err != nil {
 		_ = d.encoder.Encode(
 			w,
 			gonethttpresponse.NewErrorResponse(
@@ -78,6 +73,12 @@ func (d *DefaultDecoder) Decode(
 				http.StatusBadRequest,
 			),
 		)
+		return err
+	}
+
+	// Decode JSON body into destination
+	if err = json.Unmarshal(body, dest); err != nil {
+		_ = bodyDecodeErrorHandler(w, err, d.encoder)
 	}
 	return err
 }

http/json/decoder.go

@@ -28,7 +28,7 @@ func NewDefaultEncoder(mode *mode.Flag) *DefaultEncoder {
 	return &DefaultEncoder{mode: mode}
 }
 
-// Encode encodes the given data to JSON
+// Encode encodes the body into JSON and writes it to the response
 func (d *DefaultEncoder) Encode(
 	w http.ResponseWriter,
 	response *gonethttpresponse.Response,
@@ -37,12 +37,7 @@ func (d *DefaultEncoder) Encode(
 	body := response.GetBody(d.mode)
 	httpStatus := response.GetHTTPStatus()
 
-	// Check the data type
-	if err = checkJSONData(w, body, d.mode, d); err != nil {
-		return err
-	}
-
-	// Encode the data
+	// Encode the JSON body
 	jsonBody, err := json.Marshal(body)
 	if err != nil {
 		return d.Encode(
@@ -52,7 +47,7 @@ func (d *DefaultEncoder) Encode(
 				err,
 				nil,
 				nil,
-				http.StatusBadRequest,
+				http.StatusInternalServerError,
 			),
 		)
 	}

http/json/encoder.go

@@ -5,7 +5,9 @@ import (
 )
 
 var (
-	ErrNilJSONData = errors.New("json data is nil")
-	ErrNilEncoder  = errors.New("json encoder is nil")
-	ErrNilDecoder  = errors.New("json decoder is nil")
+	ErrNilData                 = errors.New("json data is nil")
+	ErrNilEncoder              = errors.New("json encoder is nil")
+	ErrNilDecoder              = errors.New("json decoder is nil")
+	ErrUnmarshalBodyDataFailed = errors.New("failed to unmarshal json body data")
+	ErrFieldInvalidValue       = "field has an invalid value %v, it must be %v"
 )

http/json/errors.go

@@ -3,6 +3,7 @@ package json
 import (
 	"encoding/json"
 	goflagsmode "github.com/ralvarezdev/go-flags/mode"
+	gonethttperrors "github.com/ralvarezdev/go-net/http/errors"
 	gonethttpresponse "github.com/ralvarezdev/go-net/http/response"
 	"net/http"
 )
@@ -31,28 +32,28 @@ func NewDefaultStreamDecoder(
 	}, nil
 }
 
-// Decode decodes the JSON data
+// Decode decodes the JSON request body and stores it in the destination
 func (d *DefaultStreamDecoder) Decode(
 	w http.ResponseWriter,
 	r *http.Request,
-	data interface{},
+	dest interface{},
 ) (err error) {
-	// Check the data type
-	if err = checkJSONData(w, data, d.mode, d.encoder); err != nil {
-		return err
-	}
-
-	// Decode JSON data
-	if err = json.NewDecoder(r.Body).Decode(data); err != nil {
+	// Check the decoder destination
+	if dest == nil {
 		_ = d.encoder.Encode(
-			w,
-			gonethttpresponse.NewErrorResponse(
+			w, gonethttpresponse.NewDebugErrorResponse(
+				gonethttperrors.InternalServerError,
 				err,
 				nil,
 				nil,
 				http.StatusInternalServerError,
 			),
 		)
 	}
+
+	// Decode JSON body into destination
+	if err = json.NewDecoder(r.Body).Decode(dest); err != nil {
+		_ = bodyDecodeErrorHandler(w, err, d.encoder)
+	}
 	return err
 }

http/json/stream_decoder.go

@@ -22,21 +22,16 @@ func NewDefaultStreamEncoder(mode *goflagsmode.Flag) *DefaultStreamEncoder {
 	}
 }
 
-// Encode encodes the data into JSON
+// Encode encodes the body into JSON and writes it to the response
 func (d *DefaultStreamEncoder) Encode(
 	w http.ResponseWriter,
 	response *gonethttpresponse.Response,
 ) (err error) {
-	// Get the data from the response
+	// Get the body and HTTP status from the response
 	body := response.GetBody(d.mode)
 	httpStatus := response.GetHTTPStatus()
 
-	// Check the data type
-	if err = checkJSONData(w, body, d.mode, d); err != nil {
-		return err
-	}
-
-	// Encode JSON data and write it to the response
+	// Encode the JSON body
 	if err = json.NewEncoder(w).Encode(body); err != nil {
 		_ = d.Encode(
 			w,