summaryrefslogtreecommitdiff
path: root/vendor/github.com/goccy/go-json/decode_wrapped_string.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/github.com/goccy/go-json/decode_wrapped_string.go')
-rw-r--r--vendor/github.com/goccy/go-json/decode_wrapped_string.go63
1 files changed, 63 insertions, 0 deletions
diff --git a/vendor/github.com/goccy/go-json/decode_wrapped_string.go b/vendor/github.com/goccy/go-json/decode_wrapped_string.go
new file mode 100644
index 000000000..7f63c597c
--- /dev/null
+++ b/vendor/github.com/goccy/go-json/decode_wrapped_string.go
@@ -0,0 +1,63 @@
+package json
+
+import (
+ "reflect"
+ "unsafe"
+)
+
+type wrappedStringDecoder struct {
+ typ *rtype
+ dec decoder
+ stringDecoder *stringDecoder
+ structName string
+ fieldName string
+ isPtrType bool
+}
+
+func newWrappedStringDecoder(typ *rtype, dec decoder, structName, fieldName string) *wrappedStringDecoder {
+ return &wrappedStringDecoder{
+ typ: typ,
+ dec: dec,
+ stringDecoder: newStringDecoder(structName, fieldName),
+ structName: structName,
+ fieldName: fieldName,
+ isPtrType: typ.Kind() == reflect.Ptr,
+ }
+}
+
+func (d *wrappedStringDecoder) decodeStream(s *stream, depth int64, p unsafe.Pointer) error {
+ bytes, err := d.stringDecoder.decodeStreamByte(s)
+ if err != nil {
+ return err
+ }
+ if bytes == nil {
+ if d.isPtrType {
+ *(*unsafe.Pointer)(p) = nil
+ }
+ return nil
+ }
+ b := make([]byte, len(bytes)+1)
+ copy(b, bytes)
+ if _, err := d.dec.decode(b, 0, depth, p); err != nil {
+ return err
+ }
+ return nil
+}
+
+func (d *wrappedStringDecoder) decode(buf []byte, cursor, depth int64, p unsafe.Pointer) (int64, error) {
+ bytes, c, err := d.stringDecoder.decodeByte(buf, cursor)
+ if err != nil {
+ return 0, err
+ }
+ if bytes == nil {
+ if d.isPtrType {
+ *(*unsafe.Pointer)(p) = nil
+ }
+ return c, nil
+ }
+ bytes = append(bytes, nul)
+ if _, err := d.dec.decode(bytes, 0, depth, p); err != nil {
+ return 0, err
+ }
+ return c, nil
+}