Source file src/pkg/encoding/json/decode.go
1
2
3
4
5
6
7
8 package json
9
10 import (
11 "encoding/base64"
12 "errors"
13 "fmt"
14 "reflect"
15 "runtime"
16 "strconv"
17 "strings"
18 "unicode"
19 "unicode/utf16"
20 "unicode/utf8"
21 )
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63 func Unmarshal(data []byte, v interface{}) error {
64
65
66
67 var d decodeState
68 err := checkValid(data, &d.scan)
69 if err != nil {
70 return err
71 }
72
73 d.init(data)
74 return d.unmarshal(v)
75 }
76
77
78
79
80
81
82 type Unmarshaler interface {
83 UnmarshalJSON([]byte) error
84 }
85
86
87
88 type UnmarshalTypeError struct {
89 Value string
90 Type reflect.Type
91 }
92
93 func (e *UnmarshalTypeError) Error() string {
94 return "json: cannot unmarshal " + e.Value + " into Go value of type " + e.Type.String()
95 }
96
97
98
99
100 type UnmarshalFieldError struct {
101 Key string
102 Type reflect.Type
103 Field reflect.StructField
104 }
105
106 func (e *UnmarshalFieldError) Error() string {
107 return "json: cannot unmarshal object key " + strconv.Quote(e.Key) + " into unexported field " + e.Field.Name + " of type " + e.Type.String()
108 }
109
110
111
112 type InvalidUnmarshalError struct {
113 Type reflect.Type
114 }
115
116 func (e *InvalidUnmarshalError) Error() string {
117 if e.Type == nil {
118 return "json: Unmarshal(nil)"
119 }
120
121 if e.Type.Kind() != reflect.Ptr {
122 return "json: Unmarshal(non-pointer " + e.Type.String() + ")"
123 }
124 return "json: Unmarshal(nil " + e.Type.String() + ")"
125 }
126
127 func (d *decodeState) unmarshal(v interface{}) (err error) {
128 defer func() {
129 if r := recover(); r != nil {
130 if _, ok := r.(runtime.Error); ok {
131 panic(r)
132 }
133 err = r.(error)
134 }
135 }()
136
137 rv := reflect.ValueOf(v)
138 if rv.Kind() != reflect.Ptr || rv.IsNil() {
139 return &InvalidUnmarshalError{reflect.TypeOf(v)}
140 }
141
142 d.scan.reset()
143
144
145 d.value(rv)
146 return d.savedError
147 }
148
149
150 type Number string
151
152
153 func (n Number) String() string { return string(n) }
154
155
156 func (n Number) Float64() (float64, error) {
157 return strconv.ParseFloat(string(n), 64)
158 }
159
160
161 func (n Number) Int64() (int64, error) {
162 return strconv.ParseInt(string(n), 10, 64)
163 }
164
165
166 type decodeState struct {
167 data []byte
168 off int
169 scan scanner
170 nextscan scanner
171 savedError error
172 tempstr string
173 useNumber bool
174 }
175
176
177
178
179 var errPhase = errors.New("JSON decoder out of sync - data changing underfoot?")
180
181 func (d *decodeState) init(data []byte) *decodeState {
182 d.data = data
183 d.off = 0
184 d.savedError = nil
185 return d
186 }
187
188
189 func (d *decodeState) error(err error) {
190 panic(err)
191 }
192
193
194
195 func (d *decodeState) saveError(err error) {
196 if d.savedError == nil {
197 d.savedError = err
198 }
199 }
200
201
202
203 func (d *decodeState) next() []byte {
204 c := d.data[d.off]
205 item, rest, err := nextValue(d.data[d.off:], &d.nextscan)
206 if err != nil {
207 d.error(err)
208 }
209 d.off = len(d.data) - len(rest)
210
211
212
213
214 if c == '{' {
215 d.scan.step(&d.scan, '}')
216 } else {
217 d.scan.step(&d.scan, ']')
218 }
219
220 return item
221 }
222
223
224
225
226 func (d *decodeState) scanWhile(op int) int {
227 var newOp int
228 for {
229 if d.off >= len(d.data) {
230 newOp = d.scan.eof()
231 d.off = len(d.data) + 1
232 } else {
233 c := int(d.data[d.off])
234 d.off++
235 newOp = d.scan.step(&d.scan, c)
236 }
237 if newOp != op {
238 break
239 }
240 }
241 return newOp
242 }
243
244
245
246 func (d *decodeState) value(v reflect.Value) {
247 if !v.IsValid() {
248 _, rest, err := nextValue(d.data[d.off:], &d.nextscan)
249 if err != nil {
250 d.error(err)
251 }
252 d.off = len(d.data) - len(rest)
253
254
255
256
257 if d.scan.redo {
258
259 d.scan.redo = false
260 d.scan.step = stateBeginValue
261 }
262 d.scan.step(&d.scan, '"')
263 d.scan.step(&d.scan, '"')
264
265 n := len(d.scan.parseState)
266 if n > 0 && d.scan.parseState[n-1] == parseObjectKey {
267
268 d.scan.step(&d.scan, ':')
269 d.scan.step(&d.scan, '"')
270 d.scan.step(&d.scan, '"')
271 d.scan.step(&d.scan, '}')
272 }
273
274 return
275 }
276
277 switch op := d.scanWhile(scanSkipSpace); op {
278 default:
279 d.error(errPhase)
280
281 case scanBeginArray:
282 d.array(v)
283
284 case scanBeginObject:
285 d.object(v)
286
287 case scanBeginLiteral:
288 d.literal(v)
289 }
290 }
291
292
293
294
295
296 func (d *decodeState) indirect(v reflect.Value, decodingNull bool) (Unmarshaler, reflect.Value) {
297
298
299
300 if v.Kind() != reflect.Ptr && v.Type().Name() != "" && v.CanAddr() {
301 v = v.Addr()
302 }
303 for {
304
305
306 if v.Kind() == reflect.Interface && !v.IsNil() {
307 e := v.Elem()
308 if e.Kind() == reflect.Ptr && !e.IsNil() && (!decodingNull || e.Elem().Kind() == reflect.Ptr) {
309 v = e
310 continue
311 }
312 }
313
314 if v.Kind() != reflect.Ptr {
315 break
316 }
317
318 if v.Elem().Kind() != reflect.Ptr && decodingNull && v.CanSet() {
319 break
320 }
321 if v.IsNil() {
322 v.Set(reflect.New(v.Type().Elem()))
323 }
324 if v.Type().NumMethod() > 0 {
325 if unmarshaler, ok := v.Interface().(Unmarshaler); ok {
326 return unmarshaler, reflect.Value{}
327 }
328 }
329 v = v.Elem()
330 }
331 return nil, v
332 }
333
334
335
336 func (d *decodeState) array(v reflect.Value) {
337
338 unmarshaler, pv := d.indirect(v, false)
339 if unmarshaler != nil {
340 d.off--
341 err := unmarshaler.UnmarshalJSON(d.next())
342 if err != nil {
343 d.error(err)
344 }
345 return
346 }
347 v = pv
348
349
350 switch v.Kind() {
351 case reflect.Interface:
352 if v.NumMethod() == 0 {
353
354 v.Set(reflect.ValueOf(d.arrayInterface()))
355 return
356 }
357
358 fallthrough
359 default:
360 d.saveError(&UnmarshalTypeError{"array", v.Type()})
361 d.off--
362 d.next()
363 return
364 case reflect.Array:
365 case reflect.Slice:
366 break
367 }
368
369 i := 0
370 for {
371
372 op := d.scanWhile(scanSkipSpace)
373 if op == scanEndArray {
374 break
375 }
376
377
378 d.off--
379 d.scan.undo(op)
380
381
382 if v.Kind() == reflect.Slice {
383
384 if i >= v.Cap() {
385 newcap := v.Cap() + v.Cap()/2
386 if newcap < 4 {
387 newcap = 4
388 }
389 newv := reflect.MakeSlice(v.Type(), v.Len(), newcap)
390 reflect.Copy(newv, v)
391 v.Set(newv)
392 }
393 if i >= v.Len() {
394 v.SetLen(i + 1)
395 }
396 }
397
398 if i < v.Len() {
399
400 d.value(v.Index(i))
401 } else {
402
403 d.value(reflect.Value{})
404 }
405 i++
406
407
408 op = d.scanWhile(scanSkipSpace)
409 if op == scanEndArray {
410 break
411 }
412 if op != scanArrayValue {
413 d.error(errPhase)
414 }
415 }
416
417 if i < v.Len() {
418 if v.Kind() == reflect.Array {
419
420 z := reflect.Zero(v.Type().Elem())
421 for ; i < v.Len(); i++ {
422 v.Index(i).Set(z)
423 }
424 } else {
425 v.SetLen(i)
426 }
427 }
428 if i == 0 && v.Kind() == reflect.Slice {
429 v.Set(reflect.MakeSlice(v.Type(), 0, 0))
430 }
431 }
432
433
434
435 func (d *decodeState) object(v reflect.Value) {
436
437 unmarshaler, pv := d.indirect(v, false)
438 if unmarshaler != nil {
439 d.off--
440 err := unmarshaler.UnmarshalJSON(d.next())
441 if err != nil {
442 d.error(err)
443 }
444 return
445 }
446 v = pv
447
448
449 if v.Kind() == reflect.Interface && v.NumMethod() == 0 {
450 v.Set(reflect.ValueOf(d.objectInterface()))
451 return
452 }
453
454
455 switch v.Kind() {
456 case reflect.Map:
457
458 t := v.Type()
459 if t.Key().Kind() != reflect.String {
460 d.saveError(&UnmarshalTypeError{"object", v.Type()})
461 break
462 }
463 if v.IsNil() {
464 v.Set(reflect.MakeMap(t))
465 }
466 case reflect.Struct:
467
468 default:
469 d.saveError(&UnmarshalTypeError{"object", v.Type()})
470 d.off--
471 d.next()
472 return
473 }
474
475 var mapElem reflect.Value
476
477 for {
478
479 op := d.scanWhile(scanSkipSpace)
480 if op == scanEndObject {
481
482 break
483 }
484 if op != scanBeginLiteral {
485 d.error(errPhase)
486 }
487
488
489 start := d.off - 1
490 op = d.scanWhile(scanContinue)
491 item := d.data[start : d.off-1]
492 key, ok := unquote(item)
493 if !ok {
494 d.error(errPhase)
495 }
496
497
498 var subv reflect.Value
499 destring := false
500
501 if v.Kind() == reflect.Map {
502 elemType := v.Type().Elem()
503 if !mapElem.IsValid() {
504 mapElem = reflect.New(elemType).Elem()
505 } else {
506 mapElem.Set(reflect.Zero(elemType))
507 }
508 subv = mapElem
509 } else {
510 var f *field
511 fields := cachedTypeFields(v.Type())
512 for i := range fields {
513 ff := &fields[i]
514 if ff.name == key {
515 f = ff
516 break
517 }
518 if f == nil && strings.EqualFold(ff.name, key) {
519 f = ff
520 }
521 }
522 if f != nil {
523 subv = v
524 destring = f.quoted
525 for _, i := range f.index {
526 if subv.Kind() == reflect.Ptr {
527 if subv.IsNil() {
528 subv.Set(reflect.New(subv.Type().Elem()))
529 }
530 subv = subv.Elem()
531 }
532 subv = subv.Field(i)
533 }
534 }
535 }
536
537
538 if op == scanSkipSpace {
539 op = d.scanWhile(scanSkipSpace)
540 }
541 if op != scanObjectKey {
542 d.error(errPhase)
543 }
544
545
546 if destring {
547 d.value(reflect.ValueOf(&d.tempstr))
548 d.literalStore([]byte(d.tempstr), subv, true)
549 } else {
550 d.value(subv)
551 }
552
553
554
555 if v.Kind() == reflect.Map {
556 kv := reflect.ValueOf(key).Convert(v.Type().Key())
557 v.SetMapIndex(kv, subv)
558 }
559
560
561 op = d.scanWhile(scanSkipSpace)
562 if op == scanEndObject {
563 break
564 }
565 if op != scanObjectValue {
566 d.error(errPhase)
567 }
568 }
569 }
570
571
572
573
574 func (d *decodeState) literal(v reflect.Value) {
575
576 start := d.off - 1
577 op := d.scanWhile(scanContinue)
578
579
580 d.off--
581 d.scan.undo(op)
582
583 d.literalStore(d.data[start:d.off], v, false)
584 }
585
586
587
588 func (d *decodeState) convertNumber(s string) (interface{}, error) {
589 if d.useNumber {
590 return Number(s), nil
591 }
592 f, err := strconv.ParseFloat(s, 64)
593 if err != nil {
594 return nil, &UnmarshalTypeError{"number " + s, reflect.TypeOf(0.0)}
595 }
596 return f, nil
597 }
598
599 var numberType = reflect.TypeOf(Number(""))
600
601
602
603
604
605
606 func (d *decodeState) literalStore(item []byte, v reflect.Value, fromQuoted bool) {
607
608 if len(item) == 0 {
609
610 d.saveError(fmt.Errorf("json: invalid use of ,string struct tag, trying to unmarshal %q into %v", item, v.Type()))
611 return
612 }
613 wantptr := item[0] == 'n'
614 unmarshaler, pv := d.indirect(v, wantptr)
615 if unmarshaler != nil {
616 err := unmarshaler.UnmarshalJSON(item)
617 if err != nil {
618 d.error(err)
619 }
620 return
621 }
622 v = pv
623
624 switch c := item[0]; c {
625 case 'n':
626 switch v.Kind() {
627 case reflect.Interface, reflect.Ptr, reflect.Map, reflect.Slice:
628 v.Set(reflect.Zero(v.Type()))
629
630 }
631 case 't', 'f':
632 value := c == 't'
633 switch v.Kind() {
634 default:
635 if fromQuoted {
636 d.saveError(fmt.Errorf("json: invalid use of ,string struct tag, trying to unmarshal %q into %v", item, v.Type()))
637 } else {
638 d.saveError(&UnmarshalTypeError{"bool", v.Type()})
639 }
640 case reflect.Bool:
641 v.SetBool(value)
642 case reflect.Interface:
643 if v.NumMethod() == 0 {
644 v.Set(reflect.ValueOf(value))
645 } else {
646 d.saveError(&UnmarshalTypeError{"bool", v.Type()})
647 }
648 }
649
650 case '"':
651 s, ok := unquoteBytes(item)
652 if !ok {
653 if fromQuoted {
654 d.error(fmt.Errorf("json: invalid use of ,string struct tag, trying to unmarshal %q into %v", item, v.Type()))
655 } else {
656 d.error(errPhase)
657 }
658 }
659 switch v.Kind() {
660 default:
661 d.saveError(&UnmarshalTypeError{"string", v.Type()})
662 case reflect.Slice:
663 if v.Type() != byteSliceType {
664 d.saveError(&UnmarshalTypeError{"string", v.Type()})
665 break
666 }
667 b := make([]byte, base64.StdEncoding.DecodedLen(len(s)))
668 n, err := base64.StdEncoding.Decode(b, s)
669 if err != nil {
670 d.saveError(err)
671 break
672 }
673 v.Set(reflect.ValueOf(b[0:n]))
674 case reflect.String:
675 v.SetString(string(s))
676 case reflect.Interface:
677 if v.NumMethod() == 0 {
678 v.Set(reflect.ValueOf(string(s)))
679 } else {
680 d.saveError(&UnmarshalTypeError{"string", v.Type()})
681 }
682 }
683
684 default:
685 if c != '-' && (c < '0' || c > '9') {
686 if fromQuoted {
687 d.error(fmt.Errorf("json: invalid use of ,string struct tag, trying to unmarshal %q into %v", item, v.Type()))
688 } else {
689 d.error(errPhase)
690 }
691 }
692 s := string(item)
693 switch v.Kind() {
694 default:
695 if v.Kind() == reflect.String && v.Type() == numberType {
696 v.SetString(s)
697 break
698 }
699 if fromQuoted {
700 d.error(fmt.Errorf("json: invalid use of ,string struct tag, trying to unmarshal %q into %v", item, v.Type()))
701 } else {
702 d.error(&UnmarshalTypeError{"number", v.Type()})
703 }
704 case reflect.Interface:
705 n, err := d.convertNumber(s)
706 if err != nil {
707 d.saveError(err)
708 break
709 }
710 if v.NumMethod() != 0 {
711 d.saveError(&UnmarshalTypeError{"number", v.Type()})
712 break
713 }
714 v.Set(reflect.ValueOf(n))
715
716 case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
717 n, err := strconv.ParseInt(s, 10, 64)
718 if err != nil || v.OverflowInt(n) {
719 d.saveError(&UnmarshalTypeError{"number " + s, v.Type()})
720 break
721 }
722 v.SetInt(n)
723
724 case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64, reflect.Uintptr:
725 n, err := strconv.ParseUint(s, 10, 64)
726 if err != nil || v.OverflowUint(n) {
727 d.saveError(&UnmarshalTypeError{"number " + s, v.Type()})
728 break
729 }
730 v.SetUint(n)
731
732 case reflect.Float32, reflect.Float64:
733 n, err := strconv.ParseFloat(s, v.Type().Bits())
734 if err != nil || v.OverflowFloat(n) {
735 d.saveError(&UnmarshalTypeError{"number " + s, v.Type()})
736 break
737 }
738 v.SetFloat(n)
739 }
740 }
741 }
742
743
744
745
746
747
748 func (d *decodeState) valueInterface() interface{} {
749 switch d.scanWhile(scanSkipSpace) {
750 default:
751 d.error(errPhase)
752 panic("unreachable")
753 case scanBeginArray:
754 return d.arrayInterface()
755 case scanBeginObject:
756 return d.objectInterface()
757 case scanBeginLiteral:
758 return d.literalInterface()
759 }
760 }
761
762
763 func (d *decodeState) arrayInterface() []interface{} {
764 var v = make([]interface{}, 0)
765 for {
766
767 op := d.scanWhile(scanSkipSpace)
768 if op == scanEndArray {
769 break
770 }
771
772
773 d.off--
774 d.scan.undo(op)
775
776 v = append(v, d.valueInterface())
777
778
779 op = d.scanWhile(scanSkipSpace)
780 if op == scanEndArray {
781 break
782 }
783 if op != scanArrayValue {
784 d.error(errPhase)
785 }
786 }
787 return v
788 }
789
790
791 func (d *decodeState) objectInterface() map[string]interface{} {
792 m := make(map[string]interface{})
793 for {
794
795 op := d.scanWhile(scanSkipSpace)
796 if op == scanEndObject {
797
798 break
799 }
800 if op != scanBeginLiteral {
801 d.error(errPhase)
802 }
803
804
805 start := d.off - 1
806 op = d.scanWhile(scanContinue)
807 item := d.data[start : d.off-1]
808 key, ok := unquote(item)
809 if !ok {
810 d.error(errPhase)
811 }
812
813
814 if op == scanSkipSpace {
815 op = d.scanWhile(scanSkipSpace)
816 }
817 if op != scanObjectKey {
818 d.error(errPhase)
819 }
820
821
822 m[key] = d.valueInterface()
823
824
825 op = d.scanWhile(scanSkipSpace)
826 if op == scanEndObject {
827 break
828 }
829 if op != scanObjectValue {
830 d.error(errPhase)
831 }
832 }
833 return m
834 }
835
836
837 func (d *decodeState) literalInterface() interface{} {
838
839 start := d.off - 1
840 op := d.scanWhile(scanContinue)
841
842
843 d.off--
844 d.scan.undo(op)
845 item := d.data[start:d.off]
846
847 switch c := item[0]; c {
848 case 'n':
849 return nil
850
851 case 't', 'f':
852 return c == 't'
853
854 case '"':
855 s, ok := unquote(item)
856 if !ok {
857 d.error(errPhase)
858 }
859 return s
860
861 default:
862 if c != '-' && (c < '0' || c > '9') {
863 d.error(errPhase)
864 }
865 n, err := d.convertNumber(string(item))
866 if err != nil {
867 d.saveError(err)
868 }
869 return n
870 }
871 }
872
873
874
875 func getu4(s []byte) rune {
876 if len(s) < 6 || s[0] != '\\' || s[1] != 'u' {
877 return -1
878 }
879 r, err := strconv.ParseUint(string(s[2:6]), 16, 64)
880 if err != nil {
881 return -1
882 }
883 return rune(r)
884 }
885
886
887
888 func unquote(s []byte) (t string, ok bool) {
889 s, ok = unquoteBytes(s)
890 t = string(s)
891 return
892 }
893
894 func unquoteBytes(s []byte) (t []byte, ok bool) {
895 if len(s) < 2 || s[0] != '"' || s[len(s)-1] != '"' {
896 return
897 }
898 s = s[1 : len(s)-1]
899
900
901
902
903 r := 0
904 for r < len(s) {
905 c := s[r]
906 if c == '\\' || c == '"' || c < ' ' {
907 break
908 }
909 if c < utf8.RuneSelf {
910 r++
911 continue
912 }
913 rr, size := utf8.DecodeRune(s[r:])
914 if rr == utf8.RuneError && size == 1 {
915 break
916 }
917 r += size
918 }
919 if r == len(s) {
920 return s, true
921 }
922
923 b := make([]byte, len(s)+2*utf8.UTFMax)
924 w := copy(b, s[0:r])
925 for r < len(s) {
926
927
928
929 if w >= len(b)-2*utf8.UTFMax {
930 nb := make([]byte, (len(b)+utf8.UTFMax)*2)
931 copy(nb, b[0:w])
932 b = nb
933 }
934 switch c := s[r]; {
935 case c == '\\':
936 r++
937 if r >= len(s) {
938 return
939 }
940 switch s[r] {
941 default:
942 return
943 case '"', '\\', '/', '\'':
944 b[w] = s[r]
945 r++
946 w++
947 case 'b':
948 b[w] = '\b'
949 r++
950 w++
951 case 'f':
952 b[w] = '\f'
953 r++
954 w++
955 case 'n':
956 b[w] = '\n'
957 r++
958 w++
959 case 'r':
960 b[w] = '\r'
961 r++
962 w++
963 case 't':
964 b[w] = '\t'
965 r++
966 w++
967 case 'u':
968 r--
969 rr := getu4(s[r:])
970 if rr < 0 {
971 return
972 }
973 r += 6
974 if utf16.IsSurrogate(rr) {
975 rr1 := getu4(s[r:])
976 if dec := utf16.DecodeRune(rr, rr1); dec != unicode.ReplacementChar {
977
978 r += 6
979 w += utf8.EncodeRune(b[w:], dec)
980 break
981 }
982
983 rr = unicode.ReplacementChar
984 }
985 w += utf8.EncodeRune(b[w:], rr)
986 }
987
988
989 case c == '"', c < ' ':
990 return
991
992
993 case c < utf8.RuneSelf:
994 b[w] = c
995 r++
996 w++
997
998
999 default:
1000 rr, size := utf8.DecodeRune(s[r:])
1001 r += size
1002 w += utf8.EncodeRune(b[w:], rr)
1003 }
1004 }
1005 return b[0:w], true
1006 }
View as plain text