Merge pull request #52 from muzzammilshahid/encode-decode-cbor

Add functions to encode, decode CBOR

serializers/cbor.go

@@ -1,6 +1,7 @@
 package serializers
 
 import (
+	"fmt"
 	"reflect"
 
 	"github.com/fxamacker/cbor/v2"
@@ -42,3 +43,34 @@ func (c *CBORSerializer) Deserialize(payload []byte) (messages.Message, error) {
 func (c *CBORSerializer) Static() bool {
 	return false
 }
+
+func EncodeCBOR(args []any, kwargs map[string]any) ([]byte, int, error) {
+	var payload []any
+	payload = append(payload, args)
+	payload = append(payload, kwargs)
+	payloadData, err := cbor.Marshal(payload)
+	if err != nil {
+		return nil, 0, err
+	}
+
+	return payloadData, CBORSerializerValue, nil
+}
+
+func DecodeCBOR(data []byte) ([]any, map[string]any, error) {
+	var payload []any
+	if err := cborEncoder.Unmarshal(data, &payload); err != nil {
+		return nil, nil, fmt.Errorf("failed to unmarshal cbor payload: %w", err)
+	}
+
+	args, ok := payload[0].([]any)
+	if !ok {
+		return nil, nil, fmt.Errorf("invalid args type: %T", payload[0])
+	}
+
+	kwargs, ok := payload[1].(map[string]any)
+	if !ok {
+		return nil, nil, fmt.Errorf("invalid kwargs type: %T", payload[1])
+	}
+
+	return args, kwargs, nil
+}

serializers/helpers.go

@@ -6,6 +6,13 @@ import (
 	"github.com/xconnio/wampproto-go/messages"
 )
 
+const (
+	JSONSerializerValue     = 1
+	MsgPackSerializerValue  = 2
+	CBORSerializerValue     = 3
+	ProtobufSerializerValue = 16
+)
+
 func ToMessage(wampMsg []any) (messages.Message, error) {
 	messageType, _ := messages.AsInt64(wampMsg[0])
 	var msg messages.Message