add support for @bytes

serializer.go

@@ -1,6 +1,7 @@
 package fauna
 
 import (
+	"encoding/base64"
 	"encoding/json"
 	"fmt"
 	"reflect"
@@ -37,6 +38,7 @@ const (
 	typeTagStream typeTag = "@stream"
 	typeTagMod    typeTag = "@mod"
 	typeTagObject typeTag = "@object"
+	typeTagBytes  typeTag = "@bytes"
 )
 
 func keyConflicts(key string) bool {
@@ -241,6 +243,8 @@ func unboxType(body map[string]any) (any, error) {
 				return unboxDoc(v.(map[string]any))
 			case typeTagObject:
 				return convertMap(v.(map[string]any))
+			case typeTagBytes:
+				return unboxBytes(v.(string))
 			}
 		}
 	}
@@ -445,6 +449,14 @@ func unboxDouble(v string) (any, error) {
 	}
 }
 
+func unboxBytes(v string) (any, error) {
+	if b, err := base64.StdEncoding.DecodeString(v); err != nil {
+		return nil, err
+	} else {
+		return b, nil
+	}
+}
+
 func marshal(v any) ([]byte, error) {
 	if enc, err := encode(v, ""); err != nil {
 		return nil, err
@@ -507,6 +519,9 @@ func encode(v any, hint string) (any, error) {
 			out["start_ts"] = vt.StartTS
 		}
 		return out, nil
+
+	case []byte:
+		return encodeBytes(vt)
 	}
 
 	switch value := reflect.ValueOf(v); value.Kind() {
@@ -546,6 +561,12 @@ func encode(v any, hint string) (any, error) {
 	return v, nil
 }
 
+func encodeBytes(b []byte) (any, error) {
+	return map[typeTag]any{
+		typeTagBytes: base64.StdEncoding.EncodeToString(b),
+	}, nil
+}
+
 func encodeInt(i int64) (any, error) {
 	tag := typeTagLong
 	if i <= maxInt && i >= minInt {

serializer_test.go

@@ -1,6 +1,7 @@
 package fauna
 
 import (
+	"encoding/base64"
 	"reflect"
 	"testing"
 	"time"
@@ -55,6 +56,7 @@ type BusinessObj struct {
 	NamedDocField     NamedDocBusinessObj     `fauna:"named_doc_field"`
 	NullDocField      NullDocBusinessObj      `fauna:"nulldoc_field"`
 	NullNamedDocField NullNamedDocBusinessObj `fauna:"nulldoc_named_field"`
+	BytesField        []byte                  `fauna:"bytes_field"`
 
 	IgnoredField string `fauna:"-"`
 }
@@ -108,7 +110,8 @@ func TestRoundtrip(t *testing.T) {
       "tuple_field": ["one",2,3.0],
       "int_field": 1234,
       "double_field": 1234.567
-    }}
+    }},
+	"bytes_field": {"@bytes":"SGVsbG8sIGZyb20gRmF1bmEh"}
   }`)
 
 	obj := &BusinessObj{}
@@ -185,6 +188,18 @@ func TestEncodingPrimitives(t *testing.T) {
 			assert.Nil(t, decoded)
 		}
 	})
+
+	t.Run("encode bytes", func(t *testing.T) {
+		inputBytes := []byte("This is a test string 🚀 with various characters: !@#$%^&*()_+=-`~[]{}|;:'\\\",./<>?")
+		encoded := base64.StdEncoding.EncodeToString(inputBytes)
+
+		bs := marshalAndCheck(t, inputBytes)
+		if assert.JSONEq(t, `{"@bytes": "`+encoded+`"}`, string(bs)) {
+			var decoded []byte
+			unmarshalAndCheck(t, bs, &decoded)
+			assert.Equal(t, inputBytes, decoded)
+		}
+	})
 }
 
 func TestEncodingTime(t *testing.T) {