refactor: added some errors and nil checkers

Author: ralvarezdev

decoder/errors.go

@@ -6,4 +6,8 @@ import (
 
 var (
 	ErrInvalidInstance = errors.New("invalid instance provided to create a reader")
+	ErrNilBody         = errors.New("body cannot be nil")
+	ErrNilReader       = errors.New("reader cannot be nil")
+	ErrNilDestination  = errors.New("destination cannot be nil")
+	ErrNilDecoder      = errors.New("decoder is nil")
 )

decoder/json/decoder.go

@@ -35,6 +35,11 @@ func (d Decoder) Decode(
 	body interface{},
 	dest interface{},
 ) error {
+	// Check the body
+	if body == nil {
+		return gojsondecoder.ErrNilBody
+	}
+
 	// Check the body type
 	reader, err := gojsondecoder.ToReader(body)
 	if err != nil {
@@ -57,9 +62,14 @@ func (d Decoder) DecodeReader(
 	reader io.Reader,
 	dest interface{},
 ) (err error) {
+	// Check the reader
+	if reader == nil {
+		return gojsondecoder.ErrNilReader
+	}
+
 	// Check the decoder destination
 	if dest == nil {
-		return ErrNilDestination
+		return gojsondecoder.ErrNilDestination
 	}
 
 	// Get the body of the request

decoder/json/errors.go

@@ -35,6 +35,11 @@ func (s StreamDecoder) Decode(
 	body interface{},
 	dest interface{},
 ) error {
+	// Check the body
+	if body == nil {
+		return gojsondecoder.ErrNilBody
+	}
+
 	// Check the body type
 	reader, err := gojsondecoder.ToReader(body)
 	if err != nil {
@@ -57,9 +62,14 @@ func (s StreamDecoder) DecodeReader(
 	reader io.Reader,
 	dest interface{},
 ) error {
+	// Check the reader
+	if reader == nil {
+		return gojsondecoder.ErrNilReader
+	}
+
 	// Check the decoder destination
 	if dest == nil {
-		return ErrNilDestination
+		return gojsondecoder.ErrNilDestination
 	}
 
 	// Create the stream decoder

decoder/json/stream_decoder.go

@@ -44,6 +44,11 @@ func (d Decoder) Decode(
 	body interface{},
 	dest interface{},
 ) error {
+	// Check the body
+	if body == nil {
+		return gojsondecoder.ErrNilBody
+	}
+
 	// Check the body type
 	reader, err := gojsondecoder.ToReader(body)
 	if err != nil {
@@ -66,6 +71,16 @@ func (d Decoder) DecodeReader(
 	reader io.Reader,
 	dest interface{},
 ) error {
+	// Check the reader
+	if reader == nil {
+		return gojsondecoder.ErrNilReader
+	}
+
+	// Check the decoder destination
+	if dest == nil {
+		return gojsondecoder.ErrNilDestination
+	}
+
 	return UnmarshalByReflection(
 		reader,
 		dest,

decoder/protojson/decoder.go

@@ -0,0 +1,11 @@
+package encoder
+
+import (
+	"errors"
+)
+
+var (
+	ErrNilWriter  = errors.New("writer is nil")
+	ErrNilBody    = errors.New("body cannot be nil")
+	ErrNilEncoder = errors.New("encoder is nil")
+)

encoder/errors.go

@@ -3,6 +3,8 @@ package json
 import (
 	"encoding/json"
 	"io"
+
+	gojsonencoder "github.com/ralvarezdev/go-json/encoder"
 )
 
 type (
@@ -32,6 +34,12 @@ func NewEncoder() *Encoder {
 func (e Encoder) Encode(
 	body interface{},
 ) ([]byte, error) {
+	// Check if body is nil
+	if body == nil {
+		return nil, gojsonencoder.ErrNilBody
+	}
+
+	// Marshal the body into JSON
 	jsonBody, err := json.Marshal(body)
 	if err != nil {
 		return nil, err
@@ -55,6 +63,11 @@ func (e Encoder) EncodeAndWrite(
 	beforeWriteFn func() error,
 	body interface{},
 ) error {
+	// Check if the writer is nil
+	if writer == nil {
+		return gojsonencoder.ErrNilWriter
+	}
+
 	// Encode the body into JSON
 	jsonBody, err := e.Encode(body)
 	if err != nil {

encoder/json/encoder.go

@@ -5,6 +5,8 @@ import (
 	"bytes"
 	"encoding/json"
 	"io"
+
+	gojsonencoder "github.com/ralvarezdev/go-json/encoder"
 )
 
 type (
@@ -34,6 +36,11 @@ func NewStreamEncoder() *StreamEncoder {
 func (s StreamEncoder) Encode(
 	body interface{},
 ) ([]byte, error) {
+	// Check if body is nil
+	if body == nil {
+		return nil, gojsonencoder.ErrNilBody
+	}
+
 	// Create a buffer to write to
 	buffer := new(bytes.Buffer)
 
@@ -69,6 +76,11 @@ func (s StreamEncoder) EncodeAndWrite(
 	beforeWriteFn func() error,
 	body interface{},
 ) (err error) {
+	// Check if the writer is nil
+	if writer == nil {
+		return gojsonencoder.ErrNilWriter
+	}
+
 	// Call the before write function if provided
 	if beforeWriteFn != nil {
 		if err = beforeWriteFn(); err != nil {

encoder/json/stream_encoder.go

@@ -4,6 +4,7 @@ import (
 	"io"
 	"reflect"
 
+	gojsonencoder "github.com/ralvarezdev/go-json/encoder"
 	gojsonencoderjson "github.com/ralvarezdev/go-json/encoder/json"
 	"google.golang.org/protobuf/encoding/protojson"
 )
@@ -74,6 +75,11 @@ func (e Encoder) PrecomputeMarshal(
 func (e Encoder) Encode(
 	body interface{},
 ) ([]byte, error) {
+	// Check if body is nil
+	if body == nil {
+		return nil, gojsonencoder.ErrNilBody
+	}
+
 	// Marshal the instance to get the precomputed body
 	precomputedMarshal, err := e.PrecomputeMarshal(body)
 	if err != nil {
@@ -98,6 +104,11 @@ func (e Encoder) EncodeAndWrite(
 	beforeWriteFn func() error,
 	body interface{},
 ) error {
+	// Check if the writer is nil
+	if writer == nil {
+		return gojsonencoder.ErrNilWriter
+	}
+
 	// Marshal the instance to get the precomputed body
 	precomputedMarshal, err := e.PrecomputeMarshal(body)
 	if err != nil {