summaryrefslogtreecommitdiff
path: root/vendor/github.com/ugorji/go/codec/cbor.go
diff options
context:
space:
mode:
authorLibravatar kim <grufwub@gmail.com>2025-06-30 15:19:09 +0200
committerLibravatar kim <gruf@noreply.codeberg.org>2025-06-30 15:19:09 +0200
commit8b0ea560279a5bf4479555d3924c763ddeecfcad (patch)
tree005e26d4a658e565594fb259cc17948659195822 /vendor/github.com/ugorji/go/codec/cbor.go
parent[chore] bumps ncruces/go-sqlite3 v0.26.1 => v0.26.3 (#4302) (diff)
downloadgotosocial-8b0ea560279a5bf4479555d3924c763ddeecfcad.tar.xz
[chore] update go dependencies (#4304)
- github.com/KimMachineGun/automemlimit v0.7.2 => v0.7.3 - github.com/gin-contrib/cors v1.7.5 => v1.7.6 - github.com/minio/minio-go/v7 v7.0.92 => v7.0.94 - github.com/spf13/cast v1.8.0 => v1.9.2 - github.com/uptrace/bun{,/*} v1.2.11 => v1.2.14 - golang.org/x/image v0.27.0 => v0.28.0 - golang.org/x/net v0.40.0 => v0.41.0 - code.superseriousbusiness.org/go-swagger v0.31.0-gts-go1.23-fix => v0.32.3-gts-go1.23-fix Reviewed-on: https://codeberg.org/superseriousbusiness/gotosocial/pulls/4304 Co-authored-by: kim <grufwub@gmail.com> Co-committed-by: kim <grufwub@gmail.com>
Diffstat (limited to 'vendor/github.com/ugorji/go/codec/cbor.go')
-rw-r--r--vendor/github.com/ugorji/go/codec/cbor.go909
1 files changed, 469 insertions, 440 deletions
diff --git a/vendor/github.com/ugorji/go/codec/cbor.go b/vendor/github.com/ugorji/go/codec/cbor.go
index 802b1fc1d..2229a2b26 100644
--- a/vendor/github.com/ugorji/go/codec/cbor.go
+++ b/vendor/github.com/ugorji/go/codec/cbor.go
@@ -1,194 +1,92 @@
+//go:build notmono || codec.notmono
+
// Copyright (c) 2012-2020 Ugorji Nwoke. All rights reserved.
// Use of this source code is governed by a MIT license found in the LICENSE file.
package codec
import (
+ "io"
"math"
+ "math/big"
"reflect"
"time"
"unicode/utf8"
)
-// major
-const (
- cborMajorUint byte = iota
- cborMajorNegInt
- cborMajorBytes
- cborMajorString
- cborMajorArray
- cborMajorMap
- cborMajorTag
- cborMajorSimpleOrFloat
-)
-
-// simple
-const (
- cborBdFalse byte = 0xf4 + iota
- cborBdTrue
- cborBdNil
- cborBdUndefined
- cborBdExt
- cborBdFloat16
- cborBdFloat32
- cborBdFloat64
-)
-
-// indefinite
-const (
- cborBdIndefiniteBytes byte = 0x5f
- cborBdIndefiniteString byte = 0x7f
- cborBdIndefiniteArray byte = 0x9f
- cborBdIndefiniteMap byte = 0xbf
- cborBdBreak byte = 0xff
-)
-
-// These define some in-stream descriptors for
-// manual encoding e.g. when doing explicit indefinite-length
-const (
- CborStreamBytes byte = 0x5f
- CborStreamString byte = 0x7f
- CborStreamArray byte = 0x9f
- CborStreamMap byte = 0xbf
- CborStreamBreak byte = 0xff
-)
-
-// base values
-const (
- cborBaseUint byte = 0x00
- cborBaseNegInt byte = 0x20
- cborBaseBytes byte = 0x40
- cborBaseString byte = 0x60
- cborBaseArray byte = 0x80
- cborBaseMap byte = 0xa0
- cborBaseTag byte = 0xc0
- cborBaseSimple byte = 0xe0
-)
-
-// const (
-// cborSelfDesrTag byte = 0xd9
-// cborSelfDesrTag2 byte = 0xd9
-// cborSelfDesrTag3 byte = 0xf7
-// )
-
-var (
- cbordescSimpleNames = map[byte]string{
- cborBdNil: "nil",
- cborBdFalse: "false",
- cborBdTrue: "true",
- cborBdFloat16: "float",
- cborBdFloat32: "float",
- cborBdFloat64: "float",
- cborBdBreak: "break",
- }
- cbordescIndefNames = map[byte]string{
- cborBdIndefiniteBytes: "bytes*",
- cborBdIndefiniteString: "string*",
- cborBdIndefiniteArray: "array*",
- cborBdIndefiniteMap: "map*",
- }
- cbordescMajorNames = map[byte]string{
- cborMajorUint: "(u)int",
- cborMajorNegInt: "int",
- cborMajorBytes: "bytes",
- cborMajorString: "string",
- cborMajorArray: "array",
- cborMajorMap: "map",
- cborMajorTag: "tag",
- cborMajorSimpleOrFloat: "simple",
- }
-)
-
-func cbordesc(bd byte) (s string) {
- bm := bd >> 5
- if bm == cborMajorSimpleOrFloat {
- s = cbordescSimpleNames[bd]
- } else {
- s = cbordescMajorNames[bm]
- if s == "" {
- s = cbordescIndefNames[bd]
- }
- }
- if s == "" {
- s = "unknown"
- }
- return
-}
-
// -------------------
-type cborEncDriver struct {
+type cborEncDriver[T encWriter] struct {
noBuiltInTypes
encDriverNoState
encDriverNoopContainerWriter
- h *CborHandle
+ encDriverContainerNoTrackerT
+
+ h *CborHandle
+ e *encoderBase
+ w T
+ enc encoderI
// scratch buffer for: encode time, numbers, etc
//
// RFC3339Nano uses 35 chars: 2006-01-02T15:04:05.999999999Z07:00
b [40]byte
-
- e Encoder
-}
-
-func (e *cborEncDriver) encoder() *Encoder {
- return &e.e
}
-func (e *cborEncDriver) EncodeNil() {
- e.e.encWr.writen1(cborBdNil)
+func (e *cborEncDriver[T]) EncodeNil() {
+ e.w.writen1(cborBdNil)
}
-func (e *cborEncDriver) EncodeBool(b bool) {
+func (e *cborEncDriver[T]) EncodeBool(b bool) {
if b {
- e.e.encWr.writen1(cborBdTrue)
+ e.w.writen1(cborBdTrue)
} else {
- e.e.encWr.writen1(cborBdFalse)
+ e.w.writen1(cborBdFalse)
}
}
-func (e *cborEncDriver) EncodeFloat32(f float32) {
+func (e *cborEncDriver[T]) EncodeFloat32(f float32) {
b := math.Float32bits(f)
if e.h.OptimumSize {
if h := floatToHalfFloatBits(b); halfFloatToFloatBits(h) == b {
- e.e.encWr.writen1(cborBdFloat16)
- bigen.writeUint16(e.e.w(), h)
+ e.w.writen1(cborBdFloat16)
+ e.w.writen2(bigen.PutUint16(h))
return
}
}
- e.e.encWr.writen1(cborBdFloat32)
- bigen.writeUint32(e.e.w(), b)
+ e.w.writen1(cborBdFloat32)
+ e.w.writen4(bigen.PutUint32(b))
}
-func (e *cborEncDriver) EncodeFloat64(f float64) {
+func (e *cborEncDriver[T]) EncodeFloat64(f float64) {
if e.h.OptimumSize {
if f32 := float32(f); float64(f32) == f {
e.EncodeFloat32(f32)
return
}
}
- e.e.encWr.writen1(cborBdFloat64)
- bigen.writeUint64(e.e.w(), math.Float64bits(f))
+ e.w.writen1(cborBdFloat64)
+ e.w.writen8(bigen.PutUint64(math.Float64bits(f)))
}
-func (e *cborEncDriver) encUint(v uint64, bd byte) {
+func (e *cborEncDriver[T]) encUint(v uint64, bd byte) {
if v <= 0x17 {
- e.e.encWr.writen1(byte(v) + bd)
+ e.w.writen1(byte(v) + bd)
} else if v <= math.MaxUint8 {
- e.e.encWr.writen2(bd+0x18, uint8(v))
+ e.w.writen2(bd+0x18, uint8(v))
} else if v <= math.MaxUint16 {
- e.e.encWr.writen1(bd + 0x19)
- bigen.writeUint16(e.e.w(), uint16(v))
+ e.w.writen1(bd + 0x19)
+ e.w.writen2(bigen.PutUint16(uint16(v)))
} else if v <= math.MaxUint32 {
- e.e.encWr.writen1(bd + 0x1a)
- bigen.writeUint32(e.e.w(), uint32(v))
+ e.w.writen1(bd + 0x1a)
+ e.w.writen4(bigen.PutUint32(uint32(v)))
} else { // if v <= math.MaxUint64 {
- e.e.encWr.writen1(bd + 0x1b)
- bigen.writeUint64(e.e.w(), v)
+ e.w.writen1(bd + 0x1b)
+ e.w.writen8(bigen.PutUint64(v))
}
}
-func (e *cborEncDriver) EncodeInt(v int64) {
+func (e *cborEncDriver[T]) EncodeInt(v int64) {
if v < 0 {
e.encUint(uint64(-1-v), cborBaseNegInt)
} else {
@@ -196,20 +94,20 @@ func (e *cborEncDriver) EncodeInt(v int64) {
}
}
-func (e *cborEncDriver) EncodeUint(v uint64) {
+func (e *cborEncDriver[T]) EncodeUint(v uint64) {
e.encUint(v, cborBaseUint)
}
-func (e *cborEncDriver) encLen(bd byte, length int) {
+func (e *cborEncDriver[T]) encLen(bd byte, length int) {
e.encUint(uint64(length), bd)
}
-func (e *cborEncDriver) EncodeTime(t time.Time) {
+func (e *cborEncDriver[T]) EncodeTime(t time.Time) {
if t.IsZero() {
e.EncodeNil()
} else if e.h.TimeRFC3339 {
e.encUint(0, cborBaseTag)
- e.encStringBytesS(cborBaseString, stringView(fmtTime(t, time.RFC3339Nano, e.b[:0])))
+ e.encStringBytesS(cborBaseString, stringView(t.AppendFormat(e.b[:0], time.RFC3339Nano)))
} else {
e.encUint(1, cborBaseTag)
t = t.UTC().Round(time.Microsecond)
@@ -222,56 +120,75 @@ func (e *cborEncDriver) EncodeTime(t time.Time) {
}
}
-func (e *cborEncDriver) EncodeExt(rv interface{}, basetype reflect.Type, xtag uint64, ext Ext) {
+func (e *cborEncDriver[T]) EncodeExt(rv interface{}, basetype reflect.Type, xtag uint64, ext Ext) {
e.encUint(uint64(xtag), cborBaseTag)
if ext == SelfExt {
- e.e.encodeValue(baseRV(rv), e.h.fnNoExt(basetype))
+ e.enc.encodeAs(rv, basetype, false)
} else if v := ext.ConvertExt(rv); v == nil {
- e.EncodeNil()
+ e.writeNilBytes()
} else {
- e.e.encode(v)
+ e.enc.encodeI(v)
}
}
-func (e *cborEncDriver) EncodeRawExt(re *RawExt) {
+func (e *cborEncDriver[T]) EncodeRawExt(re *RawExt) {
e.encUint(uint64(re.Tag), cborBaseTag)
- // only encodes re.Value (never re.Data)
- if re.Value != nil {
- e.e.encode(re.Value)
+ if re.Data != nil {
+ e.w.writeb(re.Data)
+ } else if re.Value != nil {
+ e.enc.encodeI(re.Value)
} else {
e.EncodeNil()
}
}
-func (e *cborEncDriver) WriteArrayStart(length int) {
+func (e *cborEncDriver[T]) WriteArrayEmpty() {
if e.h.IndefiniteLength {
- e.e.encWr.writen1(cborBdIndefiniteArray)
+ e.w.writen2(cborBdIndefiniteArray, cborBdBreak)
+ } else {
+ e.w.writen1(cborBaseArray)
+ // e.encLen(cborBaseArray, 0)
+ }
+}
+
+func (e *cborEncDriver[T]) WriteMapEmpty() {
+ if e.h.IndefiniteLength {
+ e.w.writen2(cborBdIndefiniteMap, cborBdBreak)
+ } else {
+ e.w.writen1(cborBaseMap)
+ // e.encLen(cborBaseMap, 0)
+ }
+}
+
+func (e *cborEncDriver[T]) WriteArrayStart(length int) {
+ if e.h.IndefiniteLength {
+ e.w.writen1(cborBdIndefiniteArray)
} else {
e.encLen(cborBaseArray, length)
}
}
-func (e *cborEncDriver) WriteMapStart(length int) {
+func (e *cborEncDriver[T]) WriteMapStart(length int) {
if e.h.IndefiniteLength {
- e.e.encWr.writen1(cborBdIndefiniteMap)
+ e.w.writen1(cborBdIndefiniteMap)
} else {
e.encLen(cborBaseMap, length)
}
}
-func (e *cborEncDriver) WriteMapEnd() {
+func (e *cborEncDriver[T]) WriteMapEnd() {
if e.h.IndefiniteLength {
- e.e.encWr.writen1(cborBdBreak)
+ e.w.writen1(cborBdBreak)
}
}
-func (e *cborEncDriver) WriteArrayEnd() {
+func (e *cborEncDriver[T]) WriteArrayEnd() {
if e.h.IndefiniteLength {
- e.e.encWr.writen1(cborBdBreak)
+ e.w.writen1(cborBdBreak)
}
}
-func (e *cborEncDriver) EncodeString(v string) {
+func (e *cborEncDriver[T]) EncodeString(v string) {
bb := cborBaseString
if e.h.StringToRaw {
bb = cborBaseBytes
@@ -279,74 +196,87 @@ func (e *cborEncDriver) EncodeString(v string) {
e.encStringBytesS(bb, v)
}
-func (e *cborEncDriver) EncodeStringBytesRaw(v []byte) {
- if v == nil {
- e.EncodeNil()
- } else {
- e.encStringBytesS(cborBaseBytes, stringView(v))
- }
+func (e *cborEncDriver[T]) EncodeStringNoEscape4Json(v string) { e.EncodeString(v) }
+
+func (e *cborEncDriver[T]) EncodeStringBytesRaw(v []byte) {
+ e.encStringBytesS(cborBaseBytes, stringView(v))
}
-func (e *cborEncDriver) encStringBytesS(bb byte, v string) {
+func (e *cborEncDriver[T]) encStringBytesS(bb byte, v string) {
if e.h.IndefiniteLength {
if bb == cborBaseBytes {
- e.e.encWr.writen1(cborBdIndefiniteBytes)
+ e.w.writen1(cborBdIndefiniteBytes)
} else {
- e.e.encWr.writen1(cborBdIndefiniteString)
- }
- var vlen uint = uint(len(v))
- blen := vlen / 4
- if blen == 0 {
- blen = 64
- } else if blen > 1024 {
- blen = 1024
+ e.w.writen1(cborBdIndefiniteString)
}
+ vlen := uint(len(v))
+ n := max(4, min(vlen/4, 1024))
for i := uint(0); i < vlen; {
- var v2 string
- i2 := i + blen
- if i2 >= i && i2 < vlen {
- v2 = v[i:i2]
- } else {
- v2 = v[i:]
+ i2 := i + n
+ if i2 >= vlen {
+ i2 = vlen
}
+ v2 := v[i:i2]
e.encLen(bb, len(v2))
- e.e.encWr.writestr(v2)
+ e.w.writestr(v2)
i = i2
}
- e.e.encWr.writen1(cborBdBreak)
+ e.w.writen1(cborBdBreak)
} else {
e.encLen(bb, len(v))
- e.e.encWr.writestr(v)
+ e.w.writestr(v)
}
}
-// ----------------------
+func (e *cborEncDriver[T]) EncodeBytes(v []byte) {
+ if v == nil {
+ e.writeNilBytes()
+ return
+ }
+ e.EncodeStringBytesRaw(v)
+}
-type cborDecDriver struct {
- decDriverNoopContainerReader
- decDriverNoopNumberHelper
- h *CborHandle
- bdAndBdread
- st bool // skip tags
- _ bool // found nil
- noBuiltInTypes
- d Decoder
+func (e *cborEncDriver[T]) writeNilOr(v byte) {
+ if !e.h.NilCollectionToZeroLength {
+ v = cborBdNil
+ }
+ e.w.writen1(v)
}
-func (d *cborDecDriver) decoder() *Decoder {
- return &d.d
+func (e *cborEncDriver[T]) writeNilArray() {
+ e.writeNilOr(cborBaseArray)
}
-func (d *cborDecDriver) descBd() string {
- return sprintf("%v (%s)", d.bd, cbordesc(d.bd))
+func (e *cborEncDriver[T]) writeNilMap() {
+ e.writeNilOr(cborBaseMap)
}
-func (d *cborDecDriver) readNextBd() {
- d.bd = d.d.decRd.readn1()
+func (e *cborEncDriver[T]) writeNilBytes() {
+ e.writeNilOr(cborBaseBytes)
+}
+
+// ----------------------
+
+type cborDecDriver[T decReader] struct {
+ decDriverNoopContainerReader
+ // decDriverNoopNumberHelper
+ noBuiltInTypes
+
+ h *CborHandle
+ d *decoderBase
+ r T
+ dec decoderI
+ bdAndBdread
+ // st bool // skip tags
+ // bytes bool
+}
+
+func (d *cborDecDriver[T]) readNextBd() {
+ d.bd = d.r.readn1()
d.bdRead = true
}
-func (d *cborDecDriver) advanceNil() (null bool) {
+func (d *cborDecDriver[T]) advanceNil() (null bool) {
if !d.bdRead {
d.readNextBd()
}
@@ -357,7 +287,7 @@ func (d *cborDecDriver) advanceNil() (null bool) {
return
}
-func (d *cborDecDriver) TryNil() bool {
+func (d *cborDecDriver[T]) TryNil() bool {
return d.advanceNil()
}
@@ -368,18 +298,18 @@ func (d *cborDecDriver) TryNil() bool {
//
// By definition, skipTags should not be called before
// checking for break, or nil or undefined.
-func (d *cborDecDriver) skipTags() {
+func (d *cborDecDriver[T]) skipTags() {
for d.bd>>5 == cborMajorTag {
d.decUint()
- d.bd = d.d.decRd.readn1()
+ d.bd = d.r.readn1()
}
}
-func (d *cborDecDriver) ContainerType() (vt valueType) {
+func (d *cborDecDriver[T]) ContainerType() (vt valueType) {
if !d.bdRead {
d.readNextBd()
}
- if d.st {
+ if d.h.SkipUnexpectedTags {
d.skipTags()
}
if d.bd == cborBdNil {
@@ -399,7 +329,7 @@ func (d *cborDecDriver) ContainerType() (vt valueType) {
return valueTypeUnset
}
-func (d *cborDecDriver) CheckBreak() (v bool) {
+func (d *cborDecDriver[T]) CheckBreak() (v bool) {
if !d.bdRead {
d.readNextBd()
}
@@ -410,72 +340,60 @@ func (d *cborDecDriver) CheckBreak() (v bool) {
return
}
-func (d *cborDecDriver) decUint() (ui uint64) {
+func (d *cborDecDriver[T]) decUint() (ui uint64) {
v := d.bd & 0x1f
if v <= 0x17 {
ui = uint64(v)
} else if v == 0x18 {
- ui = uint64(d.d.decRd.readn1())
+ ui = uint64(d.r.readn1())
} else if v == 0x19 {
- ui = uint64(bigen.Uint16(d.d.decRd.readn2()))
+ ui = uint64(bigen.Uint16(d.r.readn2()))
} else if v == 0x1a {
- ui = uint64(bigen.Uint32(d.d.decRd.readn4()))
+ ui = uint64(bigen.Uint32(d.r.readn4()))
} else if v == 0x1b {
- ui = uint64(bigen.Uint64(d.d.decRd.readn8()))
+ ui = uint64(bigen.Uint64(d.r.readn8()))
} else {
- d.d.errorf("invalid descriptor decoding uint: %x/%s", d.bd, cbordesc(d.bd))
+ halt.errorf("invalid descriptor decoding uint: %x/%s (%x)", d.bd, cbordesc(d.bd), v)
}
return
}
-func (d *cborDecDriver) decLen() int {
+func (d *cborDecDriver[T]) decLen() int {
return int(d.decUint())
}
-func (d *cborDecDriver) decAppendIndefiniteBytes(bs []byte, major byte) []byte {
- d.bdRead = false
- for !d.CheckBreak() {
- chunkMajor := d.bd >> 5
- if chunkMajor != major {
- d.d.errorf("malformed indefinite string/bytes %x (%s); contains chunk with major type %v, expected %v",
- d.bd, cbordesc(d.bd), chunkMajor, major)
- }
- n := uint(d.decLen())
- oldLen := uint(len(bs))
- newLen := oldLen + n
- if newLen > uint(cap(bs)) {
- bs2 := make([]byte, newLen, 2*uint(cap(bs))+n)
- copy(bs2, bs)
- bs = bs2
- } else {
- bs = bs[:newLen]
- }
- d.d.decRd.readb(bs[oldLen:newLen])
- if d.h.ValidateUnicode && major == cborMajorString && !utf8.Valid(bs[oldLen:newLen]) {
- d.d.errorf("indefinite-length text string contains chunk that is not a valid utf-8 sequence: 0x%x", bs[oldLen:newLen])
- }
- d.bdRead = false
- }
- d.bdRead = false
- return bs
-}
-
-func (d *cborDecDriver) decFloat() (f float64, ok bool) {
+func (d *cborDecDriver[T]) decFloat() (f float64, ok bool) {
ok = true
switch d.bd {
case cborBdFloat16:
- f = float64(math.Float32frombits(halfFloatToFloatBits(bigen.Uint16(d.d.decRd.readn2()))))
+ f = float64(math.Float32frombits(halfFloatToFloatBits(bigen.Uint16(d.r.readn2()))))
case cborBdFloat32:
- f = float64(math.Float32frombits(bigen.Uint32(d.d.decRd.readn4())))
+ f = float64(math.Float32frombits(bigen.Uint32(d.r.readn4())))
case cborBdFloat64:
- f = math.Float64frombits(bigen.Uint64(d.d.decRd.readn8()))
+ f = math.Float64frombits(bigen.Uint64(d.r.readn8()))
default:
- ok = false
+ if d.bd>>5 == cborMajorTag {
+ // extension tag for bignum/decimal
+ switch d.bd & 0x1f { // tag
+ case 2:
+ f = d.decTagBigIntAsFloat(false)
+ case 3:
+ f = d.decTagBigIntAsFloat(true)
+ case 4:
+ f = d.decTagBigFloatAsFloat(true)
+ case 5:
+ f = d.decTagBigFloatAsFloat(false)
+ default:
+ ok = false
+ }
+ } else {
+ ok = false
+ }
}
return
}
-func (d *cborDecDriver) decInteger() (ui uint64, neg, ok bool) {
+func (d *cborDecDriver[T]) decInteger() (ui uint64, neg, ok bool) {
ok = true
switch d.bd >> 5 {
case cborMajorUint:
@@ -489,65 +407,67 @@ func (d *cborDecDriver) decInteger() (ui uint64, neg, ok bool) {
return
}
-func (d *cborDecDriver) DecodeInt64() (i int64) {
+func (d *cborDecDriver[T]) DecodeInt64() (i int64) {
if d.advanceNil() {
return
}
- if d.st {
+ if d.h.SkipUnexpectedTags {
d.skipTags()
}
- i = decNegintPosintFloatNumberHelper{&d.d}.int64(d.decInteger())
+ v1, v2, v3 := d.decInteger()
+ i = decNegintPosintFloatNumberHelper{d}.int64(v1, v2, v3, true)
d.bdRead = false
return
}
-func (d *cborDecDriver) DecodeUint64() (ui uint64) {
+func (d *cborDecDriver[T]) DecodeUint64() (ui uint64) {
if d.advanceNil() {
return
}
- if d.st {
+ if d.h.SkipUnexpectedTags {
d.skipTags()
}
- ui = decNegintPosintFloatNumberHelper{&d.d}.uint64(d.decInteger())
+ ui = decNegintPosintFloatNumberHelper{d}.uint64(d.decInteger())
d.bdRead = false
return
}
-func (d *cborDecDriver) DecodeFloat64() (f float64) {
+func (d *cborDecDriver[T]) DecodeFloat64() (f float64) {
if d.advanceNil() {
return
}
- if d.st {
+ if d.h.SkipUnexpectedTags {
d.skipTags()
}
- f = decNegintPosintFloatNumberHelper{&d.d}.float64(d.decFloat())
+ v1, v2 := d.decFloat()
+ f = decNegintPosintFloatNumberHelper{d}.float64(v1, v2, true)
d.bdRead = false
return
}
// bool can be decoded from bool only (single byte).
-func (d *cborDecDriver) DecodeBool() (b bool) {
+func (d *cborDecDriver[T]) DecodeBool() (b bool) {
if d.advanceNil() {
return
}
- if d.st {
+ if d.h.SkipUnexpectedTags {
d.skipTags()
}
if d.bd == cborBdTrue {
b = true
} else if d.bd == cborBdFalse {
} else {
- d.d.errorf("not bool - %s %x/%s", msgBadDesc, d.bd, cbordesc(d.bd))
+ halt.errorf("not bool - %s %x/%s", msgBadDesc, d.bd, cbordesc(d.bd))
}
d.bdRead = false
return
}
-func (d *cborDecDriver) ReadMapStart() (length int) {
+func (d *cborDecDriver[T]) ReadMapStart() (length int) {
if d.advanceNil() {
return containerLenNil
}
- if d.st {
+ if d.h.SkipUnexpectedTags {
d.skipTags()
}
d.bdRead = false
@@ -555,16 +475,16 @@ func (d *cborDecDriver) ReadMapStart() (length int) {
return containerLenUnknown
}
if d.bd>>5 != cborMajorMap {
- d.d.errorf("error reading map; got major type: %x, expected %x/%s", d.bd>>5, cborMajorMap, cbordesc(d.bd))
+ halt.errorf("error reading map; got major type: %x, expected %x/%s", d.bd>>5, cborMajorMap, cbordesc(d.bd))
}
return d.decLen()
}
-func (d *cborDecDriver) ReadArrayStart() (length int) {
+func (d *cborDecDriver[T]) ReadArrayStart() (length int) {
if d.advanceNil() {
return containerLenNil
}
- if d.st {
+ if d.h.SkipUnexpectedTags {
d.skipTags()
}
d.bdRead = false
@@ -572,139 +492,206 @@ func (d *cborDecDriver) ReadArrayStart() (length int) {
return containerLenUnknown
}
if d.bd>>5 != cborMajorArray {
- d.d.errorf("invalid array; got major type: %x, expect: %x/%s", d.bd>>5, cborMajorArray, cbordesc(d.bd))
+ halt.errorf("invalid array; got major type: %x, expect: %x/%s", d.bd>>5, cborMajorArray, cbordesc(d.bd))
}
return d.decLen()
}
-func (d *cborDecDriver) DecodeBytes(bs []byte) (bsOut []byte) {
- d.d.decByteState = decByteStateNone
+// MARKER d.d.buf is ONLY used within DecodeBytes.
+// Safe to use freely here only.
+
+func (d *cborDecDriver[T]) DecodeBytes() (bs []byte, state dBytesAttachState) {
if d.advanceNil() {
return
}
- if d.st {
+ if d.h.SkipUnexpectedTags {
d.skipTags()
}
+ fnEnsureNonNilBytes := func() {
+ // buf is nil at first. Ensure a non-nil value is returned.
+ if bs == nil {
+ bs = zeroByteSlice
+ state = dBytesDetach
+ }
+ }
if d.bd == cborBdIndefiniteBytes || d.bd == cborBdIndefiniteString {
+ major := d.bd >> 5
+ val4str := d.h.ValidateUnicode && major == cborMajorString
+ bs = d.d.buf[:0]
d.bdRead = false
- if bs == nil {
- d.d.decByteState = decByteStateReuseBuf
- return d.decAppendIndefiniteBytes(d.d.b[:0], d.bd>>5)
+ for !d.CheckBreak() {
+ if d.bd>>5 != major {
+ const msg = "malformed indefinite string/bytes %x (%s); " +
+ "contains chunk with major type %v, expected %v"
+ halt.errorf(msg, d.bd, cbordesc(d.bd), d.bd>>5, major)
+ }
+ n := uint(d.decLen())
+ bs = append(bs, d.r.readx(n)...)
+ d.bdRead = false
+ if val4str && !utf8.Valid(bs[len(bs)-int(n):]) {
+ const msg = "indefinite-length text string contains chunk " +
+ "that is not a valid utf-8 sequence: 0x%x"
+ halt.errorf(msg, bs[len(bs)-int(n):])
+ }
}
- return d.decAppendIndefiniteBytes(bs[:0], d.bd>>5)
+ d.bdRead = false
+ d.d.buf = bs
+ state = dBytesAttachBuffer
+ fnEnsureNonNilBytes()
+ return
}
if d.bd == cborBdIndefiniteArray {
d.bdRead = false
- if bs == nil {
- d.d.decByteState = decByteStateReuseBuf
- bs = d.d.b[:0]
- } else {
- bs = bs[:0]
- }
+ bs = d.d.buf[:0]
for !d.CheckBreak() {
bs = append(bs, uint8(chkOvf.UintV(d.DecodeUint64(), 8)))
}
- return bs
+ d.d.buf = bs
+ state = dBytesAttachBuffer
+ fnEnsureNonNilBytes()
+ return
}
+ var cond bool
if d.bd>>5 == cborMajorArray {
d.bdRead = false
- if bs == nil {
- d.d.decByteState = decByteStateReuseBuf
- bs = d.d.b[:]
- }
slen := d.decLen()
- var changed bool
- if bs, changed = usableByteSlice(bs, slen); changed {
- d.d.decByteState = decByteStateNone
- }
+ bs, cond = usableByteSlice(d.d.buf, slen)
for i := 0; i < len(bs); i++ {
bs[i] = uint8(chkOvf.UintV(d.DecodeUint64(), 8))
}
for i := len(bs); i < slen; i++ {
bs = append(bs, uint8(chkOvf.UintV(d.DecodeUint64(), 8)))
}
- return bs
+ if cond {
+ d.d.buf = bs
+ }
+ state = dBytesAttachBuffer
+ fnEnsureNonNilBytes()
+ return
}
clen := d.decLen()
d.bdRead = false
- if d.d.zerocopy() {
- d.d.decByteState = decByteStateZerocopy
- return d.d.decRd.rb.readx(uint(clen))
- }
- if bs == nil {
- d.d.decByteState = decByteStateReuseBuf
- bs = d.d.b[:]
- }
- return decByteSlice(d.d.r(), clen, d.h.MaxInitLen, bs)
+ bs, cond = d.r.readxb(uint(clen))
+ state = d.d.attachState(cond)
+ return
}
-func (d *cborDecDriver) DecodeStringAsBytes() (s []byte) {
- s = d.DecodeBytes(nil)
- if d.h.ValidateUnicode && !utf8.Valid(s) {
- d.d.errorf("DecodeStringAsBytes: invalid UTF-8: %s", s)
+func (d *cborDecDriver[T]) DecodeStringAsBytes() (out []byte, state dBytesAttachState) {
+ out, state = d.DecodeBytes()
+ if d.h.ValidateUnicode && !utf8.Valid(out) {
+ halt.errorf("DecodeStringAsBytes: invalid UTF-8: %s", out)
}
return
}
-func (d *cborDecDriver) DecodeTime() (t time.Time) {
+func (d *cborDecDriver[T]) DecodeTime() (t time.Time) {
if d.advanceNil() {
return
}
if d.bd>>5 != cborMajorTag {
- d.d.errorf("error reading tag; expected major type: %x, got: %x", cborMajorTag, d.bd>>5)
+ halt.errorf("error reading tag; expected major type: %x, got: %x", cborMajorTag, d.bd>>5)
}
xtag := d.decUint()
d.bdRead = false
return d.decodeTime(xtag)
}
-func (d *cborDecDriver) decodeTime(xtag uint64) (t time.Time) {
+func (d *cborDecDriver[T]) decodeTime(xtag uint64) (t time.Time) {
switch xtag {
case 0:
var err error
- t, err = time.Parse(time.RFC3339, stringView(d.DecodeStringAsBytes()))
- d.d.onerror(err)
+ t, err = time.Parse(time.RFC3339, stringView(bytesOKs(d.DecodeStringAsBytes())))
+ halt.onerror(err)
case 1:
f1, f2 := math.Modf(d.DecodeFloat64())
t = time.Unix(int64(f1), int64(f2*1e9))
default:
- d.d.errorf("invalid tag for time.Time - expecting 0 or 1, got 0x%x", xtag)
+ halt.errorf("invalid tag for time.Time - expecting 0 or 1, got 0x%x", xtag)
}
t = t.UTC().Round(time.Microsecond)
return
}
-func (d *cborDecDriver) DecodeExt(rv interface{}, basetype reflect.Type, xtag uint64, ext Ext) {
+func (d *cborDecDriver[T]) preDecodeExt(checkTag bool, xtag uint64) (realxtag uint64, ok bool) {
if d.advanceNil() {
return
}
if d.bd>>5 != cborMajorTag {
- d.d.errorf("error reading tag; expected major type: %x, got: %x", cborMajorTag, d.bd>>5)
+ halt.errorf("error reading tag; expected major type: %x, got: %x", cborMajorTag, d.bd>>5)
}
- realxtag := d.decUint()
+ realxtag = d.decUint()
d.bdRead = false
- if ext == nil {
- re := rv.(*RawExt)
+ if checkTag && xtag != realxtag {
+ halt.errorf("Wrong extension tag. Got %b. Expecting: %v", realxtag, xtag)
+ }
+ ok = true
+ return
+}
+
+func (d *cborDecDriver[T]) DecodeRawExt(re *RawExt) {
+ if realxtag, ok := d.preDecodeExt(false, 0); ok {
re.Tag = realxtag
- d.d.decode(&re.Value)
- } else if xtag != realxtag {
- d.d.errorf("Wrong extension tag. Got %b. Expecting: %v", realxtag, xtag)
- } else if ext == SelfExt {
- d.d.decodeValue(baseRV(rv), d.h.fnNoExt(basetype))
- } else {
- d.d.interfaceExtConvertAndDecode(rv, ext)
+ d.dec.decode(&re.Value)
+ d.bdRead = false
}
- d.bdRead = false
}
-func (d *cborDecDriver) DecodeNaked() {
+func (d *cborDecDriver[T]) DecodeExt(rv interface{}, basetype reflect.Type, xtag uint64, ext Ext) {
+ if _, ok := d.preDecodeExt(true, xtag); ok {
+ if ext == SelfExt {
+ d.dec.decodeAs(rv, basetype, false)
+ } else {
+ d.dec.interfaceExtConvertAndDecode(rv, ext)
+ }
+ d.bdRead = false
+ }
+}
+
+func (d *cborDecDriver[T]) decTagBigIntAsFloat(neg bool) (f float64) {
+ bs, _ := d.DecodeBytes()
+ bi := new(big.Int).SetBytes(bs)
+ if neg { // neg big.Int
+ bi0 := bi
+ bi = new(big.Int).Sub(big.NewInt(-1), bi0)
+ }
+ f, _ = bi.Float64()
+ return
+}
+
+func (d *cborDecDriver[T]) decTagBigFloatAsFloat(decimal bool) (f float64) {
+ if nn := d.r.readn1(); nn != 82 {
+ halt.errorf("(%d) decoding decimal/big.Float: expected 2 numbers", nn)
+ }
+ exp := d.DecodeInt64()
+ mant := d.DecodeInt64()
+ if decimal { // m*(10**e)
+ // MARKER: if precision/other issues crop, consider using big.Float on base 10.
+ // The logic is more convoluted, which is why we leverage readFloatResult for now.
+ rf := readFloatResult{exp: int8(exp)}
+ if mant >= 0 {
+ rf.mantissa = uint64(mant)
+ } else {
+ rf.neg = true
+ rf.mantissa = uint64(-mant)
+ }
+ f, _ = parseFloat64_reader(rf)
+ // f = float64(mant) * math.Pow10(exp)
+ } else { // m*(2**e)
+ // f = float64(mant) * math.Pow(2, exp)
+ bfm := new(big.Float).SetPrec(64).SetInt64(mant)
+ bf := new(big.Float).SetPrec(64).SetMantExp(bfm, int(exp))
+ f, _ = bf.Float64()
+ }
+ return
+}
+
+func (d *cborDecDriver[T]) DecodeNaked() {
if !d.bdRead {
d.readNextBd()
}
n := d.d.naked()
var decodeFurther bool
-
switch d.bd >> 5 {
case cborMajorUint:
if d.h.SignedInteger {
@@ -718,10 +705,10 @@ func (d *cborDecDriver) DecodeNaked() {
n.v = valueTypeInt
n.i = d.DecodeInt64()
case cborMajorBytes:
- d.d.fauxUnionReadRawBytes(false)
+ d.d.fauxUnionReadRawBytes(d, false, d.h.RawToString) //, d.h.ZeroCopy)
case cborMajorString:
n.v = valueTypeString
- n.s = d.d.stringZC(d.DecodeStringAsBytes())
+ n.s = d.d.detach2Str(d.DecodeStringAsBytes())
case cborMajorArray:
n.v = valueTypeArray
decodeFurther = true
@@ -731,17 +718,46 @@ func (d *cborDecDriver) DecodeNaked() {
case cborMajorTag:
n.v = valueTypeExt
n.u = d.decUint()
+ d.bdRead = false
n.l = nil
- if n.u == 0 || n.u == 1 {
- d.bdRead = false
- n.v = valueTypeTime
- n.t = d.decodeTime(n.u)
- } else if d.st && d.h.getExtForTag(n.u) == nil {
- // d.skipTags() // no need to call this - tags already skipped
- d.bdRead = false
- d.DecodeNaked()
- return // return when done (as true recursive function)
+ xx := d.h.getExtForTag(n.u)
+ if xx == nil {
+ switch n.u {
+ case 0, 1:
+ n.v = valueTypeTime
+ n.t = d.decodeTime(n.u)
+ case 2:
+ n.f = d.decTagBigIntAsFloat(false)
+ n.v = valueTypeFloat
+ case 3:
+ n.f = d.decTagBigIntAsFloat(true)
+ n.v = valueTypeFloat
+ case 4:
+ n.f = d.decTagBigFloatAsFloat(true)
+ n.v = valueTypeFloat
+ case 5:
+ n.f = d.decTagBigFloatAsFloat(false)
+ n.v = valueTypeFloat
+ case 55799: // skip
+ d.DecodeNaked()
+ default:
+ if d.h.SkipUnexpectedTags {
+ d.DecodeNaked()
+ }
+ // else we will use standard mode to decode ext e.g. into a RawExt
+ }
+ return
}
+ // if n.u == 0 || n.u == 1 {
+ // d.bdRead = false
+ // n.v = valueTypeTime
+ // n.t = d.decodeTime(n.u)
+ // } else if d.h.SkipUnexpectedTags && d.h.getExtForTag(n.u) == nil {
+ // // d.skipTags() // no need to call this - tags already skipped
+ // d.bdRead = false
+ // d.DecodeNaked()
+ // return // return when done (as true recursive function)
+ // }
case cborMajorSimpleOrFloat:
switch d.bd {
case cborBdNil, cborBdUndefined:
@@ -756,211 +772,224 @@ func (d *cborDecDriver) DecodeNaked() {
n.v = valueTypeFloat
n.f = d.DecodeFloat64()
default:
- d.d.errorf("decodeNaked: Unrecognized d.bd: 0x%x", d.bd)
+ halt.errorf("decodeNaked: Unrecognized d.bd: 0x%x", d.bd)
}
default: // should never happen
- d.d.errorf("decodeNaked: Unrecognized d.bd: 0x%x", d.bd)
+ halt.errorf("decodeNaked: Unrecognized d.bd: 0x%x", d.bd)
}
if !decodeFurther {
d.bdRead = false
}
}
-func (d *cborDecDriver) uintBytes() (v []byte, ui uint64) {
+func (d *cborDecDriver[T]) uintBytes() (v []byte, ui uint64) {
// this is only used by nextValueBytes, so it's ok to
// use readx and bigenstd here.
switch vv := d.bd & 0x1f; vv {
case 0x18:
- v = d.d.decRd.readx(1)
+ v = d.r.readx(1)
ui = uint64(v[0])
case 0x19:
- v = d.d.decRd.readx(2)
+ v = d.r.readx(2)
ui = uint64(bigenstd.Uint16(v))
case 0x1a:
- v = d.d.decRd.readx(4)
+ v = d.r.readx(4)
ui = uint64(bigenstd.Uint32(v))
case 0x1b:
- v = d.d.decRd.readx(8)
+ v = d.r.readx(8)
ui = uint64(bigenstd.Uint64(v))
default:
if vv > 0x1b {
- d.d.errorf("invalid descriptor decoding uint: %x/%s", d.bd, cbordesc(d.bd))
+ halt.errorf("invalid descriptor decoding uint: %x/%s", d.bd, cbordesc(d.bd))
}
ui = uint64(vv)
}
return
}
-func (d *cborDecDriver) nextValueBytes(v0 []byte) (v []byte) {
+func (d *cborDecDriver[T]) nextValueBytes() (v []byte) {
if !d.bdRead {
d.readNextBd()
}
- v = v0
- var h = decNextValueBytesHelper{d: &d.d}
- var cursor = d.d.rb.c - 1
- h.append1(&v, d.bd)
- v = d.nextValueBytesBdReadR(v)
+ d.r.startRecording()
+ d.nextValueBytesBdReadR()
+ v = d.r.stopRecording()
d.bdRead = false
- h.bytesRdV(&v, cursor)
return
}
-func (d *cborDecDriver) nextValueBytesR(v0 []byte) (v []byte) {
- d.readNextBd()
- v = v0
- var h = decNextValueBytesHelper{d: &d.d}
- h.append1(&v, d.bd)
- return d.nextValueBytesBdReadR(v)
-}
+// func (d *cborDecDriver[T]) nextValueBytesR(v0 []byte) (v []byte) {
+// d.readNextBd()
+// v0 = append(v0, d.bd)
+// d.r.startRecording(v0)
+// d.nextValueBytesBdReadR()
+// v = d.r.stopRecording()
+// return
+// }
-func (d *cborDecDriver) nextValueBytesBdReadR(v0 []byte) (v []byte) {
- v = v0
- var h = decNextValueBytesHelper{d: &d.d}
-
- var bs []byte
+func (d *cborDecDriver[T]) nextValueBytesBdReadR() {
+ // var bs []byte
var ui uint64
switch d.bd >> 5 {
case cborMajorUint, cborMajorNegInt:
- bs, _ = d.uintBytes()
- h.appendN(&v, bs...)
+ d.uintBytes()
case cborMajorString, cborMajorBytes:
if d.bd == cborBdIndefiniteBytes || d.bd == cborBdIndefiniteString {
for {
d.readNextBd()
- h.append1(&v, d.bd)
if d.bd == cborBdBreak {
break
}
- bs, ui = d.uintBytes()
- h.appendN(&v, bs...)
- h.appendN(&v, d.d.decRd.readx(uint(ui))...)
+ _, ui = d.uintBytes()
+ d.r.skip(uint(ui))
}
} else {
- bs, ui = d.uintBytes()
- h.appendN(&v, bs...)
- h.appendN(&v, d.d.decRd.readx(uint(ui))...)
+ _, ui = d.uintBytes()
+ d.r.skip(uint(ui))
}
case cborMajorArray:
if d.bd == cborBdIndefiniteArray {
for {
d.readNextBd()
- h.append1(&v, d.bd)
if d.bd == cborBdBreak {
break
}
- v = d.nextValueBytesBdReadR(v)
+ d.nextValueBytesBdReadR()
}
} else {
- bs, ui = d.uintBytes()
- h.appendN(&v, bs...)
+ _, ui = d.uintBytes()
for i := uint64(0); i < ui; i++ {
- v = d.nextValueBytesR(v)
+ d.readNextBd()
+ d.nextValueBytesBdReadR()
}
}
case cborMajorMap:
if d.bd == cborBdIndefiniteMap {
for {
d.readNextBd()
- h.append1(&v, d.bd)
if d.bd == cborBdBreak {
break
}
- v = d.nextValueBytesBdReadR(v)
- v = d.nextValueBytesR(v)
+ d.nextValueBytesBdReadR()
+ d.readNextBd()
+ d.nextValueBytesBdReadR()
}
} else {
- bs, ui = d.uintBytes()
- h.appendN(&v, bs...)
+ _, ui = d.uintBytes()
for i := uint64(0); i < ui; i++ {
- v = d.nextValueBytesR(v)
- v = d.nextValueBytesR(v)
+ d.readNextBd()
+ d.nextValueBytesBdReadR()
+ d.readNextBd()
+ d.nextValueBytesBdReadR()
}
}
case cborMajorTag:
- bs, _ = d.uintBytes()
- h.appendN(&v, bs...)
- v = d.nextValueBytesR(v)
+ d.uintBytes()
+ d.readNextBd()
+ d.nextValueBytesBdReadR()
case cborMajorSimpleOrFloat:
switch d.bd {
case cborBdNil, cborBdUndefined, cborBdFalse, cborBdTrue: // pass
case cborBdFloat16:
- h.appendN(&v, d.d.decRd.readx(2)...)
+ d.r.skip(2)
case cborBdFloat32:
- h.appendN(&v, d.d.decRd.readx(4)...)
+ d.r.skip(4)
case cborBdFloat64:
- h.appendN(&v, d.d.decRd.readx(8)...)
+ d.r.skip(8)
default:
- d.d.errorf("nextValueBytes: Unrecognized d.bd: 0x%x", d.bd)
+ halt.errorf("nextValueBytes: Unrecognized d.bd: 0x%x", d.bd)
}
default: // should never happen
- d.d.errorf("nextValueBytes: Unrecognized d.bd: 0x%x", d.bd)
+ halt.errorf("nextValueBytes: Unrecognized d.bd: 0x%x", d.bd)
}
return
}
-// -------------------------
+func (d *cborDecDriver[T]) reset() {
+ d.bdAndBdread.reset()
+ // d.st = d.h.SkipUnexpectedTags
+}
-// CborHandle is a Handle for the CBOR encoding format,
-// defined at http://tools.ietf.org/html/rfc7049 and documented further at http://cbor.io .
+// ----
//
-// CBOR is comprehensively supported, including support for:
-// - indefinite-length arrays/maps/bytes/strings
-// - (extension) tags in range 0..0xffff (0 .. 65535)
-// - half, single and double-precision floats
-// - all numbers (1, 2, 4 and 8-byte signed and unsigned integers)
-// - nil, true, false, ...
-// - arrays and maps, bytes and text strings
+// The following below are similar across all format files (except for the format name).
//
-// None of the optional extensions (with tags) defined in the spec are supported out-of-the-box.
-// Users can implement them as needed (using SetExt), including spec-documented ones:
-// - timestamp, BigNum, BigFloat, Decimals,
-// - Encoded Text (e.g. URL, regexp, base64, MIME Message), etc.
-type CborHandle struct {
- binaryEncodingType
- // noElemSeparators
- BasicHandle
-
- // IndefiniteLength=true, means that we encode using indefinitelength
- IndefiniteLength bool
-
- // TimeRFC3339 says to encode time.Time using RFC3339 format.
- // If unset, we encode time.Time using seconds past epoch.
- TimeRFC3339 bool
-
- // SkipUnexpectedTags says to skip over any tags for which extensions are
- // not defined. This is in keeping with the cbor spec on "Optional Tagging of Items".
- //
- // Furthermore, this allows the skipping over of the Self Describing Tag 0xd9d9f7.
- SkipUnexpectedTags bool
+// We keep them together here, so that we can easily copy and compare.
+
+// ----
+
+func (d *cborEncDriver[T]) init(hh Handle, shared *encoderBase, enc encoderI) (fp interface{}) {
+ callMake(&d.w)
+ d.h = hh.(*CborHandle)
+ d.e = shared
+ if shared.bytes {
+ fp = cborFpEncBytes
+ } else {
+ fp = cborFpEncIO
+ }
+ // d.w.init()
+ d.init2(enc)
+ return
}
-// Name returns the name of the handle: cbor
-func (h *CborHandle) Name() string { return "cbor" }
+func (e *cborEncDriver[T]) writeBytesAsis(b []byte) { e.w.writeb(b) }
+
+// func (e *cborEncDriver[T]) writeStringAsisDblQuoted(v string) { e.w.writeqstr(v) }
-func (h *CborHandle) desc(bd byte) string { return cbordesc(bd) }
+func (e *cborEncDriver[T]) writerEnd() { e.w.end() }
-func (h *CborHandle) newEncDriver() encDriver {
- var e = &cborEncDriver{h: h}
- e.e.e = e
- e.e.init(h)
- e.reset()
- return e
+func (e *cborEncDriver[T]) resetOutBytes(out *[]byte) {
+ e.w.resetBytes(*out, out)
}
-func (h *CborHandle) newDecDriver() decDriver {
- d := &cborDecDriver{h: h, st: h.SkipUnexpectedTags}
- d.d.d = d
- d.d.cbor = true
- d.d.init(h)
- d.reset()
- return d
+func (e *cborEncDriver[T]) resetOutIO(out io.Writer) {
+ e.w.resetIO(out, e.h.WriterBufferSize, &e.e.blist)
}
-func (d *cborDecDriver) reset() {
- d.bdAndBdread.reset()
- d.st = d.h.SkipUnexpectedTags
+// ----
+
+func (d *cborDecDriver[T]) init(hh Handle, shared *decoderBase, dec decoderI) (fp interface{}) {
+ callMake(&d.r)
+ d.h = hh.(*CborHandle)
+ d.d = shared
+ if shared.bytes {
+ fp = cborFpDecBytes
+ } else {
+ fp = cborFpDecIO
+ }
+ // d.r.init()
+ d.init2(dec)
+ return
+}
+
+func (d *cborDecDriver[T]) NumBytesRead() int {
+ return int(d.r.numread())
+}
+
+func (d *cborDecDriver[T]) resetInBytes(in []byte) {
+ d.r.resetBytes(in)
+}
+
+func (d *cborDecDriver[T]) resetInIO(r io.Reader) {
+ d.r.resetIO(r, d.h.ReaderBufferSize, d.h.MaxInitLen, &d.d.blist)
+}
+
+// ---- (custom stanza)
+
+func (d *cborDecDriver[T]) descBd() string {
+ return sprintf("%v (%s)", d.bd, cbordesc(d.bd))
}
-var _ decDriver = (*cborDecDriver)(nil)
-var _ encDriver = (*cborEncDriver)(nil)
+func (d *cborDecDriver[T]) DecodeFloat32() (f float32) {
+ return float32(chkOvf.Float32V(d.DecodeFloat64()))
+}
+
+func (d *cborEncDriver[T]) init2(enc encoderI) {
+ d.enc = enc
+}
+
+func (d *cborDecDriver[T]) init2(dec decoderI) {
+ d.dec = dec
+ // d.d.cbor = true
+}