serializer.go

package fauna

import (
	"encoding/base64"
	"encoding/json"
	"fmt"
	"reflect"
	"strconv"
	"strings"
	"time"

	"github.com/mitchellh/mapstructure"
)

const (
	fieldTag = "fauna"

	dateFormat = "2006-01-02"
	timeFormat = "2006-01-02T15:04:05.999999Z"

	maxInt  = 2147483647
	minInt  = -2147483648
	maxLong = 9223372036854775807
	minLong = -9223372036854775808
)

type typeTag string

const (
	typeTagInt    typeTag = "@int"
	typeTagLong   typeTag = "@long"
	typeTagDouble typeTag = "@double"
	typeTagDate   typeTag = "@date"
	typeTagTime   typeTag = "@time"
	typeTagDoc    typeTag = "@doc"
	typeTagRef    typeTag = "@ref"
	typeTagSet    typeTag = "@set"
	typeTagStream typeTag = "@stream"
	typeTagMod    typeTag = "@mod"
	typeTagObject typeTag = "@object"
	typeTagBytes  typeTag = "@bytes"
)

func keyConflicts(key string) bool {
	switch typeTag(key) {
	case typeTagInt, typeTagLong, typeTagDouble,
		typeTagDate, typeTagTime,
		typeTagDoc, typeTagMod, typeTagObject:
		return true
	default:
		return false
	}
}

type Module struct {
	Name string
}

type Document struct {
	ID   string         `fauna:"id"`
	Coll *Module        `fauna:"coll"`
	TS   *time.Time     `fauna:"ts"`
	Data map[string]any `fauna:"-"`
}

type NamedDocument struct {
	Name string         `fauna:"name"`
	Coll *Module        `fauna:"coll"`
	TS   *time.Time     `fauna:"ts"`
	Data map[string]any `fauna:"-"`
}

type NullDocument struct {
	Ref   *Ref   `fauna:"ref"`
	Cause string `fauna:"cause"`
}

type NullNamedDocument struct {
	Ref   *NamedRef `fauna:"ref"`
	Cause string    `fauna:"cause"`
}

type Ref struct {
	ID   string  `fauna:"id"`
	Coll *Module `fauna:"coll"`
}

type NamedRef struct {
	Name string  `fauna:"name"`
	Coll *Module `fauna:"coll"`
}

type Page struct {
	Data  []any  `fauna:"data"`
	After string `fauna:"after"`
}

func (p Page) Unmarshal(into any) error {
	return decodeInto(p.Data, into)
}

type EventSource string

func mapDecoder(into any) (*mapstructure.Decoder, error) {
	return mapstructure.NewDecoder(&mapstructure.DecoderConfig{
		TagName:              "fauna",
		Result:               into,
		IgnoreUntaggedFields: false,
		ErrorUnused:          false,
		ErrorUnset:           false,
		DecodeHook:           unmarshalDoc,
		Squash:               true,
	})
}

func unmarshal(body []byte, into any) error {
	decBody, err := decode(body)
	if err != nil {
		return err
	}
	return decodeInto(decBody, into)
}

func decodeInto(body any, into any) error {
	dec, err := mapDecoder(into)
	if err != nil {
		return err
	}

	return dec.Decode(body)
}

var (
	docType      = reflect.TypeOf(&Document{})
	namedDocType = reflect.TypeOf(&NamedDocument{})
)

func unmarshalDoc(f reflect.Type, t reflect.Type, data any) (any, error) {
	if f != docType && f != namedDocType {
		return data, nil
	}

	var docData map[string]any
	if f == docType {
		doc := data.(*Document)
		docData = doc.Data
		docData["id"] = doc.ID
		docData["coll"] = doc.Coll
		docData["ts"] = doc.TS
	}

	if f == namedDocType {
		doc := data.(*NamedDocument)
		docData = doc.Data
		docData["name"] = doc.Name
		docData["coll"] = doc.Coll
		docData["ts"] = doc.TS
	}

	result := reflect.New(t).Interface()
	dec, err := mapDecoder(result)
	if err != nil {
		return nil, err
	}

	if err := dec.Decode(docData); err != nil {
		return nil, err
	}

	return result, nil
}

func decode(bodyBytes []byte) (any, error) {
	var body any
	if err := json.Unmarshal(bodyBytes, &body); err != nil {
		return nil, err
	}

	return convert(false, body)
}

func convert(escaped bool, body any) (any, error) {
	switch b := body.(type) {
	case map[string]any:
		if escaped {
			return convertMap(b)
		} else {
			return unboxType(b)
		}

	case []any:
		return convertSlice(b)

	default:
		return body, nil
	}
}

func convertMap(body map[string]any) (map[string]any, error) {
	retBody := map[string]any{}
	for k, vRaw := range body {
		if v, err := convert(false, vRaw); err != nil {
			return nil, err
		} else {
			retBody[k] = v
		}
	}
	return retBody, nil
}

func convertSlice(body []any) ([]any, error) {
	for i, vRaw := range body {
		if v, err := convert(false, vRaw); err != nil {
			return nil, err
		} else {
			body[i] = v
		}
	}
	return body, nil
}

func unboxType(body map[string]any) (any, error) {
	if len(body) == 1 {
		for boxedK, v := range body {
			switch typeTag(boxedK) {
			case typeTagInt, typeTagLong:
				return unboxInt(v.(string))
			case typeTagDouble:
				return unboxDouble(v.(string))
			case typeTagDate:
				return unboxDate(v.(string))
			case typeTagTime:
				return unboxTime(v.(string))
			case typeTagMod:
				return unboxMod(v.(string))
			case typeTagRef:
				return unboxRef(v.(map[string]any))
			case typeTagSet:
				return unboxSet(v)
			case typeTagStream:
				return unboxStream(v)
			case typeTagDoc:
				return unboxDoc(v.(map[string]any))
			case typeTagObject:
				return convertMap(v.(map[string]any))
			case typeTagBytes:
				return unboxBytes(v.(string))
			}
		}
	}

	return convertMap(body)
}

func unboxMod(v string) (*Module, error) {
	m := Module{v}
	return &m, nil
}

func getColl(v map[string]any) (*Module, error) {
	if coll, ok := v["coll"]; ok {
		modI, err := convert(false, coll)
		if err != nil {
			return nil, err
		}

		if mod, ok := modI.(*Module); ok {
			return mod, nil
		}
	}
	return nil, nil
}

func getIDorName(v map[string]any) (id string, name string) {
	if idRaw, ok := v["id"]; ok {
		if id, ok := idRaw.(string); ok {
			return id, ""
		}
	}

	if nameRaw, ok := v["name"]; ok {
		if name, ok := nameRaw.(string); ok {
			return "", name
		}
	}

	return
}

func getExistsCause(v map[string]any) (exists bool, cause string) {
	if existsRaw, hasExists := v["exists"]; hasExists {
		if exists = existsRaw.(bool); !exists {
			if causeRaw, hasCause := v["cause"]; hasCause {
				return exists, causeRaw.(string)
			}
		}
	}

	return true, ""
}

func unboxRef(v map[string]any) (any, error) {
	mod, err := getColl(v)
	if err != nil {
		return nil, err
	}

	if mod != nil {
		id, name := getIDorName(v)
		if exists, cause := getExistsCause(v); !exists {
			if id != "" {
				return &NullDocument{
					Ref:   &Ref{id, mod},
					Cause: cause,
				}, nil
			}

			if name != "" {
				return &NullNamedDocument{
					Ref:   &NamedRef{name, mod},
					Cause: cause,
				}, nil
			}
		}

		if id != "" {
			return &Ref{id, mod}, nil
		}

		if name != "" {
			return &NamedRef{name, mod}, nil
		}

	}

	return nil, fmt.Errorf("invalid ref %v", v)
}

func unboxDoc(v map[string]any) (any, error) {
	mod, err := getColl(v)
	if err != nil {
		return nil, err
	}

	var ts *time.Time
	if tsRaw, ok := v["ts"]; ok {
		if tsI, err := convert(false, tsRaw); err != nil {
			return nil, err
		} else {
			if unboxedTS, ok := tsI.(*time.Time); ok {
				ts = unboxedTS
			}
		}
	}

	id, name := getIDorName(v)

	if mod != nil && ts != nil && (id != "" || name != "") {
		delete(v, "id")
		delete(v, "coll")
		delete(v, "ts")

		if id == "" {
			delete(v, "name")
		}

		data, err := convertMap(v)
		if err != nil {
			return nil, err
		}

		if id != "" {
			return &Document{ID: id, Coll: mod, TS: ts, Data: data}, nil
		}

		if name != "" {
			return &NamedDocument{Name: name, Coll: mod, TS: ts, Data: data}, nil
		}
	}

	return nil, fmt.Errorf("invalid doc %v", v)
}

func unboxSet(v any) (any, error) {
	if set, ok := v.(string); ok {
		setC := Page{After: set}
		return &setC, nil
	}

	set := v.(map[string]any)
	if dataI, ok := set["data"]; ok {
		if dataRaw, ok := dataI.([]any); ok {
			data, err := convertSlice(dataRaw)
			if err != nil {
				return nil, err
			}

			setC := Page{Data: data}
			if afterRaw, ok := set["after"]; ok {
				if after, ok := afterRaw.(string); ok {
					setC.After = after
				}
			}

			return &setC, nil
		}
	}

	return nil, fmt.Errorf("invalid set %v", v)
}

func unboxStream(v any) (any, error) {
	if token, ok := v.(string); ok {
		return EventSource(token), nil
	} else {
		return nil, fmt.Errorf("invalid stream %v", v)
	}
}

func unboxTime(v string) (*time.Time, error) {
	if t, err := time.Parse(timeFormat, v); err != nil {
		return nil, err
	} else {
		return &t, nil
	}
}

func unboxDate(v string) (*time.Time, error) {
	if t, err := time.Parse(dateFormat, v); err != nil {
		return nil, err
	} else {
		return &t, nil
	}
}

func unboxInt(v string) (any, error) {
	if i, err := strconv.ParseInt(v, 10, 64); err != nil {
		return nil, err
	} else {
		return i, nil
	}
}

func unboxDouble(v string) (any, error) {
	if i, err := strconv.ParseFloat(v, 64); err != nil {
		return nil, err
	} else {
		return i, nil
	}
}

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
	} else {
		return json.Marshal(enc)
	}
}

func encode(v any, hint string) (any, error) {
	switch vt := v.(type) {
	case *queryFragment:
		return encodeQueryFragment(vt)

	case *Query:
		return encodeQuery(vt)

	case Module:
		return encodeMod(vt)

	case Ref,
		NamedRef:
		return encodeFaunaStruct(typeTagRef, vt)

	case Document,
		NamedDocument:
		return encodeFaunaStruct(typeTagDoc, vt)

	case NullDocument,
		NullNamedDocument:
		return encodeStruct(v)

	case Page:
		return encodeFaunaStruct(typeTagSet, vt)

	case EventSource:
		return map[typeTag]any{typeTagStream: vt}, nil

	case time.Time:
		return encodeTime(vt, hint)

	case queryRequest:
		query, err := encode(vt.Query, hint)
		if err != nil {
			return nil, err
		}

		out := map[string]any{"query": query}
		if len(vt.Arguments) > 0 {
			if args, err := encodeMap(reflect.ValueOf(vt.Arguments)); err != nil {
				return nil, err
			} else {
				out["arguments"] = args
			}
		}
		return out, nil

	case streamRequest:
		out := map[string]any{"token": string(vt.Stream)}
		if vt.StartTS > 0 {
			out["start_ts"] = vt.StartTS
		}
		if len(vt.Cursor) > 0 {
			out["cursor"] = vt.Cursor
		}
		return out, nil

	case feedRequest:
		out := map[string]any{"token": string(vt.Source)}
		if vt.PageSize > 0 {
			out["page_size"] = vt.PageSize
		}
		if vt.StartTS > 0 {
			out["start_ts"] = vt.StartTS
		}
		if len(vt.Cursor) > 0 {
			out["cursor"] = vt.Cursor
		}
		return out, nil

	case []byte:
		return encodeBytes(vt)
	}

	switch value := reflect.ValueOf(v); value.Kind() {
	case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
		if i := value.Int(); i < minLong {
			return nil, fmt.Errorf("numeric value is outside Fauna's type constraints")
		} else {
			return encodeInt(i)
		}

	case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uintptr:
		if i := value.Uint(); i > maxLong {
			return nil, fmt.Errorf("numeric value is outside Fauna's type constraints")
		} else {
			return encodeInt(int64(i))
		}

	case reflect.Float32, reflect.Float64:
		return map[typeTag]any{typeTagDouble: strconv.FormatFloat(value.Float(), 'f', -1, 64)}, nil

	case reflect.Ptr:
		if value.IsNil() {
			return nil, nil
		}
		return encode(reflect.Indirect(value).Interface(), hint)

	case reflect.Struct:
		return encodeStruct(v)

	case reflect.Map:
		return encodeMap(value)

	case reflect.Slice:
		return encodeSlice(value)
	}

	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 {
		tag = typeTagInt
	}
	return map[typeTag]any{tag: strconv.FormatInt(i, 10)}, nil
}

func encodeTime(t time.Time, hint string) (any, error) {
	out := make(map[typeTag]any)
	if hint == "date" {
		out[typeTagDate] = t.Format(dateFormat)
	} else {
		out[typeTagTime] = t.UTC().Format(timeFormat)
	}
	return out, nil
}

func encodeMod(m Module) (any, error) {
	return map[typeTag]string{typeTagMod: m.Name}, nil
}

func encodeFaunaStruct(tag typeTag, s any) (any, error) {
	if doc, err := encodeStruct(s); err != nil {
		return nil, err
	} else {
		return map[typeTag]any{tag: doc}, nil
	}
}

func encodeMap(mv reflect.Value) (any, error) {
	hasConflictingKey := false
	out := make(map[string]any)

	mi := mv.MapRange()
	for i := 0; mi.Next(); i++ {
		if mi.Key().Kind() != reflect.String {
			return mv.Interface(), nil
		}

		if enc, err := encode(mi.Value().Interface(), ""); err != nil {
			return nil, err
		} else {

			key := mi.Key().String()
			if keyConflicts(key) {
				hasConflictingKey = true
			}
			out[key] = enc
		}
	}

	if hasConflictingKey {
		return map[typeTag]any{typeTagObject: out}, nil
	} else {
		return out, nil
	}
}

func encodeSlice(sv reflect.Value) (any, error) {
	sLen := sv.Len()
	out := make([]any, sLen)
	for i := 0; i < sLen; i++ {
		if enc, err := encode(sv.Index(i).Interface(), ""); err != nil {
			return nil, err
		} else {
			out[i] = enc
		}
	}

	return out, nil
}

func encodeStruct(s any) (any, error) {
	hasConflictingKey := false
	isDoc := false
	out := make(map[string]any)

	elem := reflect.ValueOf(s)
	fields := reflect.TypeOf(s).NumField()

	for i := 0; i < fields; i++ {
		structField := elem.Type().Field(i)

		if structField.Anonymous && (structField.Name == "NullDocument") {
			doc := elem.Field(i).Interface().(NullDocument)

			if doc.Ref != nil {
				out["cause"] = doc.Cause

				if ref, err := encode(doc.Ref, ""); err != nil {
					return nil, err
				} else {
					out["ref"] = ref
				}

				continue
			}
		}

		if structField.Anonymous && (structField.Name == "NullNamedDocument") {
			doc := elem.Field(i).Interface().(NullNamedDocument)

			if doc.Ref != nil {
				out["cause"] = doc.Cause

				if ref, err := encode(doc.Ref, ""); err != nil {
					return nil, err
				} else {
					out["ref"] = ref
				}

				continue
			}
		}

		if structField.Anonymous && structField.Name == "Document" {
			doc := elem.Field(i).Interface().(Document)
			// if the relevant fields are present, consider this an @doc and encode it as such
			if doc.ID != "" && doc.Coll != nil && doc.TS != nil {
				out["id"] = doc.ID

				if coll, err := encode(doc.Coll, ""); err != nil {
					return nil, err
				} else {
					out["coll"] = coll
				}

				if ts, err := encode(doc.TS, "time"); err != nil {
					return nil, err
				} else {
					out["ts"] = ts
				}

				isDoc = true
				continue
			}
		}

		if structField.Anonymous && structField.Name == "NamedDocument" {
			doc := elem.Field(i).Interface().(NamedDocument)
			// if the relevant fields are present, consider this an @doc and encode it as such
			if doc.Name != "" && doc.Coll != nil && doc.TS != nil {
				out["name"] = doc.Name

				if coll, err := encode(doc.Coll, ""); err != nil {
					return nil, err
				} else {
					out["coll"] = coll
				}

				if ts, err := encode(doc.TS, "time"); err != nil {
					return nil, err
				} else {
					out["ts"] = ts
				}

				isDoc = true
				continue
			}
		}

		tag := structField.Tag.Get(fieldTag)
		tags := strings.Split(tag, ",")

		if len(tags) > 0 && tags[0] == "-" {
			continue
		}

		typeHint := ""
		if len(tags) > 1 {
			typeHint = tags[1]
		}

		if enc, err := encode(elem.Field(i).Interface(), typeHint); err != nil {
			return nil, err
		} else {
			name := tags[0]
			if name == "" {
				name = structField.Name
			}

			if keyConflicts(name) {
				hasConflictingKey = true
			}
			out[name] = enc
		}
	}

	if isDoc {
		return map[typeTag]any{typeTagDoc: out}, nil
	}

	if hasConflictingKey {
		return map[typeTag]any{typeTagObject: out}, nil
	}

	return out, nil
}

func encodeQuery(q *Query) (any, error) {
	const fqlLabel = "fql"

	rendered := make([]any, len(q.fragments))
	for i, f := range q.fragments {
		if r, err := encode(f, ""); err != nil {
			return nil, err
		} else {
			rendered[i] = r
		}
	}

	return map[string]any{fqlLabel: rendered}, nil
}

func encodeQueryFragment(f *queryFragment) (any, error) {
	if f.literal {
		return f.value, nil
	}

	ret, err := encode(f.value, "")
	if err != nil {
		return nil, err
	}

	if _, ok := f.value.(*Query); ok {
		return ret, nil

	} else {
		const valLabel = "value"
		return map[string]any{valLabel: ret}, nil
	}
}