vector.go

package idl

import (
	"bytes"
	"fmt"
	"github.com/aviate-labs/leb128"
	"math/big"
	"reflect"
)

type VectorType struct {
	Type Type
}

func NewVectorType(t Type) *VectorType {
	return &VectorType{
		Type: t,
	}
}

func (vec VectorType) AddTypeDefinition(tdt *TypeDefinitionTable) error {
	if err := vec.Type.AddTypeDefinition(tdt); err != nil {
		return err
	}

	id, err := leb128.EncodeSigned(big.NewInt(vecType))
	if err != nil {
		return err
	}
	v_, err := vec.Type.EncodeType(tdt)
	if err != nil {
		return err
	}
	tdt.Add(vec, concat(id, v_))
	return nil
}

func (vec VectorType) Decode(r *bytes.Reader) (any, error) {
	l, err := leb128.DecodeUnsigned(r)
	if err != nil {
		return nil, err
	}
	var vs []any
	for i := 0; i < int(l.Int64()); i++ {
		v_, err := vec.Type.Decode(r)
		if err != nil {
			return nil, err
		}
		vs = append(vs, v_)
	}
	return vs, nil
}

func (vec VectorType) EncodeType(tdt *TypeDefinitionTable) ([]byte, error) {
	idx, ok := tdt.Indexes[vec.String()]
	if !ok {
		return nil, fmt.Errorf("missing type index for: %s", vec)
	}
	return leb128.EncodeSigned(big.NewInt(int64(idx)))
}

func (vec VectorType) EncodeValue(v any) ([]byte, error) {
	vs_, ok := v.([]any)
	if !ok {
		v_ := reflect.ValueOf(v)
		if v_.Kind() == reflect.Array || v_.Kind() == reflect.Slice {
			for i := 0; i < v_.Len(); i++ {
				vs_ = append(vs_, v_.Index(i).Interface())
			}
		} else {
			return nil, NewEncodeValueError(v, vecType)
		}
	}
	l, err := leb128.EncodeSigned(big.NewInt(int64(len(vs_))))
	if err != nil {
		return nil, err
	}
	var vs []byte
	for _, value := range vs_ {
		v_, err := vec.Type.EncodeValue(value)
		if err != nil {
			return nil, err
		}
		vs = append(vs, v_...)
	}
	return concat(l, vs), nil
}

func (vec VectorType) String() string {
	return fmt.Sprintf("vec %s", vec.Type)
}

func (vec VectorType) UnmarshalGo(raw any, _v any) error {
	v, ok := checkIsPtr(_v)
	if !ok {
		return NewUnmarshalGoError(raw, _v)
	}

	if v.Kind() != reflect.Slice && v.Kind() != reflect.Array {
		return NewUnmarshalGoError(raw, _v)
	}

	if raw == nil {
		// Empty vector/slice.
		v.Set(reflect.Zero(v.Type()))
		return nil
	}

	if v.Kind() == reflect.Slice && v.IsNil() {
		// Create new slice.
		v.Set(reflect.MakeSlice(v.Type(), 0, 0))
	}

	rv := reflect.ValueOf(raw)
	if v.Kind() == reflect.Array {
		// Check if array is big enough.
		if rv.Len() != v.Len() {
			return NewUnmarshalGoError(raw, _v)
		}
	}

	if rv.Kind() != reflect.Slice && rv.Kind() != reflect.Array {
		return NewUnmarshalGoError(raw, _v)
	}

	if v.Len() > rv.Len() {
		// Truncate slice.
		v.Set(v.Slice(0, rv.Len()))
	}
	for i := 0; i < rv.Len(); i++ {
		rv := rv.Index(i).Interface()
		if i < v.Len() {
			// Reuse existing element.
			if err := vec.Type.UnmarshalGo(rv, v.Index(i).Addr().Interface()); err != nil {
				return err
			}
		} else {
			n := reflect.New(v.Type().Elem()) // Create new element.
			if err := vec.Type.UnmarshalGo(rv, n.Interface()); err != nil {
				return err
			}
			// Append new element.
			v.Set(reflect.Append(v, n.Elem()))
		}
	}
	return nil
}