sashakoshka/hopp
sashakoshka/hopp
1
0
Fork 0
Code Issues 8 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

message-size-increase #3

Open
sashakoshka wants to merge 209 commits from message-size-increase into main
pull from: message-size-increase
merge into: sashakoshka:main
Conversation 0 Commits 209 Files Changed 41 +24 -8
1 changed files with 24 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 52f0d6932e - Show all commits

32
tape/dynamic.go
View File

@ -99,6 +99,10 @@ func decodeAny(decoder *Decoder, destination reflect.Value, tag Tag) (n int, err
if err != nil { return n, err } if err != nil { return n, err }
case LI: case LI:
// LI: <value: IntN> // LI: <value: IntN>
nn, err := decodeAndSetUint(decoder, destination, tag.CN() + 1)
n += nn; if err != nil { return n, err }
case LSI:
// LSI: <value: IntN>
nn, err := decodeAndSetInt(decoder, destination, tag.CN() + 1) nn, err := decodeAndSetInt(decoder, destination, tag.CN() + 1)
n += nn; if err != nil { return n, err } n += nn; if err != nil { return n, err }
case FP: case FP:
@ -171,13 +175,18 @@ func TagAny(value any) (Tag, error) {
// TODO use reflection for all of this to ignore type names // TODO use reflection for all of this to ignore type names
// primitives // primitives
switch value := value.(type) { switch value := value.(type) {
case int, uint: return LI.WithCN(3), nil case int: return LSI.WithCN(3), nil
case int8, uint8: return LI.WithCN(0), nil case int8: return LSI.WithCN(0), nil
case int16, uint16: return LI.WithCN(1), nil case int16: return LSI.WithCN(1), nil
case int32, uint32: return LI.WithCN(3), nil case int32: return LSI.WithCN(3), nil
case int64, uint64: return LI.WithCN(7), nil case int64: return LSI.WithCN(7), nil
case string: return bufferLenTag(len(value)), nil case uint: return LI.WithCN(3), nil
case []byte: return bufferLenTag(len(value)), nil case uint8: return LI.WithCN(0), nil
case uint16: return LI.WithCN(1), nil
case uint32: return LI.WithCN(3), nil
case uint64: return LI.WithCN(7), nil
case string: return bufferLenTag(len(value)), nil
case []byte: return bufferLenTag(len(value)), nil
} }
// aggregates // aggregates
@ -241,7 +250,7 @@ func encodeAnyMap(encoder *Encoder, value any, tag Tag) (n int, err error) {
} }
// setInt expects a settable destination. // setInt expects a settable destination.
func setInt(destination reflect.Value, value uint64) error { func setInt[T int64 | uint64](destination reflect.Value, value T) error {
switch { switch {
case destination.CanInt(): case destination.CanInt():
destination.Set(reflect.ValueOf(int64(value)).Convert(destination.Type())) destination.Set(reflect.ValueOf(int64(value)).Convert(destination.Type()))
@ -277,6 +286,13 @@ func setByteArray(destination reflect.Value, value []byte) error {
// decodeAndSetInt expects a settable destination. // decodeAndSetInt expects a settable destination.
func decodeAndSetInt(decoder *Decoder, destination reflect.Value, bytes int) (n int, err error) { func decodeAndSetInt(decoder *Decoder, destination reflect.Value, bytes int) (n int, err error) {
value, nn, err := decoder.ReadIntN(bytes)
n += nn; if err != nil { return n, err }
return n, setInt(destination, value)
}
// decodeAndSetUint expects a settable destination.
func decodeAndSetUint(decoder *Decoder, destination reflect.Value, bytes int) (n int, err error) {
value, nn, err := decoder.ReadUintN(bytes) value, nn, err := decoder.ReadUintN(bytes)
n += nn; if err != nil { return n, err } n += nn; if err != nil { return n, err }
return n, setInt(destination, value) return n, setInt(destination, value)