feat: forked from "github.com/ralvarezdev/go-net"

Author: ralvarezdev

decoder/errors.go

@@ -0,0 +1,9 @@
+package decoder
+
+import (
+	"errors"
+)
+
+var (
+	ErrInvalidInstance = errors.New("invalid instance provided to create a reader")
+)

decoder/interfaces.go

@@ -0,0 +1,19 @@
+package decoder
+
+import (
+	"io"
+)
+
+type (
+	// Decoder interface
+	Decoder interface {
+		Decode(
+			body interface{},
+			dest interface{},
+		) error
+		DecodeReader(
+			reader io.Reader,
+			dest interface{},
+		) error
+	}
+)

decoder/json/decoder.go

@@ -0,0 +1,73 @@
+package json
+
+import (
+	"encoding/json"
+	"io"
+
+	gojsondecoder "github.com/ralvarezdev/go-json/decoder"
+)
+
+type (
+	// Decoder struct
+	Decoder struct{}
+)
+
+// NewDecoder creates a new JSON decoder
+//
+// Returns:
+//
+//   - *Decoder: The default decoder
+func NewDecoder() *Decoder {
+	return &Decoder{}
+}
+
+// Decode decodes the JSON body from an any value and stores it in the destination
+//
+// Parameters:
+//
+//   - body: The body to decode
+//   - dest: The destination to store the decoded body
+//
+// Returns:
+//
+//   - error: The error if any
+func (d Decoder) Decode(
+	body interface{},
+	dest interface{},
+) error {
+	// Check the body type
+	reader, err := gojsondecoder.ToReader(body)
+	if err != nil {
+		return err
+	}
+	return d.DecodeReader(reader, dest)
+}
+
+// DecodeReader decodes the JSON body and stores it in the destination
+//
+// Parameters:
+//
+//   - reader: The reader to read the body from
+//   - dest: The destination to store the decoded body
+//
+// Returns:
+//
+//   - error: The error if any
+func (d Decoder) DecodeReader(
+	reader io.Reader,
+	dest interface{},
+) (err error) {
+	// Check the decoder destination
+	if dest == nil {
+		return ErrNilDestination
+	}
+
+	// Get the body of the request
+	body, err := io.ReadAll(reader)
+	if err != nil {
+		return err
+	}
+
+	// Decode JSON body into destination
+	return json.Unmarshal(body, dest)
+}

decoder/json/errors.go

@@ -0,0 +1,14 @@
+package json
+
+import (
+	"errors"
+)
+
+var (
+	ErrCodeNilDestination   string
+	ErrCodeFailedToReadBody string
+)
+
+var (
+	ErrNilDestination = errors.New("json destination is nil")
+)

decoder/json/stream_decoder.go

@@ -0,0 +1,71 @@
+package json
+
+import (
+	"encoding/json"
+	"io"
+
+	gojsondecoder "github.com/ralvarezdev/go-json/decoder"
+)
+
+type (
+	// StreamDecoder is the JSON decoder struct
+	StreamDecoder struct{}
+)
+
+// NewStreamDecoder creates a new JSON decoder
+//
+// Returns:
+//
+//   - *StreamDecoder: The default decoder
+func NewStreamDecoder() *StreamDecoder {
+	return &StreamDecoder{}
+}
+
+// Decode decodes the JSON body from an any value and stores it in the destination
+//
+// Parameters:
+//
+//   - body: The body to decode
+//   - dest: The destination to store the decoded body
+//
+// Returns:
+//
+//   - error: The error if any
+func (s StreamDecoder) Decode(
+	body interface{},
+	dest interface{},
+) error {
+	// Check the body type
+	reader, err := gojsondecoder.ToReader(body)
+	if err != nil {
+		return err
+	}
+	return s.DecodeReader(reader, dest)
+}
+
+// DecodeReader decodes a JSON body from a reader into a destination
+//
+// Parameters:
+//
+//   - reader: The reader to read the body from
+//   - dest: The destination to store the decoded body
+//
+// Returns:
+//
+//   - error: The error if any
+func (s StreamDecoder) DecodeReader(
+	reader io.Reader,
+	dest interface{},
+) error {
+	// Check the decoder destination
+	if dest == nil {
+		return ErrNilDestination
+	}
+
+	// Create the stream decoder
+	decoder := json.NewDecoder(reader)
+	decoder.DisallowUnknownFields()
+
+	// Decode JSON body into destination
+	return decoder.Decode(dest)
+}

decoder/protojson/decoder.go

@@ -0,0 +1,74 @@
+package protojson
+
+import (
+	"io"
+
+	gojsondecoder "github.com/ralvarezdev/go-json/decoder"
+	"google.golang.org/protobuf/encoding/protojson"
+)
+
+type (
+	Decoder struct {
+		unmarshalOptions protojson.UnmarshalOptions
+	}
+)
+
+// NewDecoder creates a new Decoder instance
+//
+// Returns:
+//
+//   - *Decoder: The decoder instance
+func NewDecoder() *Decoder {
+	// Initialize unmarshal options
+	unmarshalOptions := protojson.UnmarshalOptions{
+		DiscardUnknown: true,
+		AllowPartial:   true,
+	}
+
+	return &Decoder{
+		unmarshalOptions: unmarshalOptions,
+	}
+}
+
+// Decode decodes the JSON body from an any value and stores it in the destination
+//
+// Parameters:
+//
+//   - body: The body to decode
+//   - dest: The destination to store the decoded body
+//
+// Returns:
+//
+//   - error: The error if any
+func (d Decoder) Decode(
+	body interface{},
+	dest interface{},
+) error {
+	// Check the body type
+	reader, err := gojsondecoder.ToReader(body)
+	if err != nil {
+		return err
+	}
+	return d.DecodeReader(reader, dest)
+}
+
+// DecodeReader  decodes a JSON body from a reader into a destination
+//
+// Parameters:
+//
+//   - reader: The io.Reader to read the body from
+//   - dest: The destination to decode the body into
+//
+// Returns:
+//
+//   - error: The error if any
+func (d Decoder) DecodeReader(
+	reader io.Reader,
+	dest interface{},
+) error {
+	return UnmarshalByReflection(
+		reader,
+		dest,
+		&d.unmarshalOptions,
+	)
+}