json.go 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121
  1. /*
  2. Copyright 2015 The Kubernetes Authors.
  3. Licensed under the Apache License, Version 2.0 (the "License");
  4. you may not use this file except in compliance with the License.
  5. You may obtain a copy of the License at
  6. http://www.apache.org/licenses/LICENSE-2.0
  7. Unless required by applicable law or agreed to in writing, software
  8. distributed under the License is distributed on an "AS IS" BASIS,
  9. WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10. See the License for the specific language governing permissions and
  11. limitations under the License.
  12. */
  13. package json
  14. import (
  15. "encoding/json"
  16. "fmt"
  17. "io"
  18. kjson "sigs.k8s.io/json"
  19. )
  20. // NewEncoder delegates to json.NewEncoder
  21. // It is only here so this package can be a drop-in for common encoding/json uses
  22. func NewEncoder(w io.Writer) *json.Encoder {
  23. return json.NewEncoder(w)
  24. }
  25. // Marshal delegates to json.Marshal
  26. // It is only here so this package can be a drop-in for common encoding/json uses
  27. func Marshal(v interface{}) ([]byte, error) {
  28. return json.Marshal(v)
  29. }
  30. // limit recursive depth to prevent stack overflow errors
  31. const maxDepth = 10000
  32. // Unmarshal unmarshals the given data.
  33. // Object keys are case-sensitive.
  34. // Numbers decoded into interface{} fields are converted to int64 or float64.
  35. func Unmarshal(data []byte, v interface{}) error {
  36. return kjson.UnmarshalCaseSensitivePreserveInts(data, v)
  37. }
  38. // ConvertInterfaceNumbers converts any json.Number values to int64 or float64.
  39. // Values which are map[string]interface{} or []interface{} are recursively visited
  40. func ConvertInterfaceNumbers(v *interface{}, depth int) error {
  41. var err error
  42. switch v2 := (*v).(type) {
  43. case json.Number:
  44. *v, err = convertNumber(v2)
  45. case map[string]interface{}:
  46. err = ConvertMapNumbers(v2, depth+1)
  47. case []interface{}:
  48. err = ConvertSliceNumbers(v2, depth+1)
  49. }
  50. return err
  51. }
  52. // ConvertMapNumbers traverses the map, converting any json.Number values to int64 or float64.
  53. // values which are map[string]interface{} or []interface{} are recursively visited
  54. func ConvertMapNumbers(m map[string]interface{}, depth int) error {
  55. if depth > maxDepth {
  56. return fmt.Errorf("exceeded max depth of %d", maxDepth)
  57. }
  58. var err error
  59. for k, v := range m {
  60. switch v := v.(type) {
  61. case json.Number:
  62. m[k], err = convertNumber(v)
  63. case map[string]interface{}:
  64. err = ConvertMapNumbers(v, depth+1)
  65. case []interface{}:
  66. err = ConvertSliceNumbers(v, depth+1)
  67. }
  68. if err != nil {
  69. return err
  70. }
  71. }
  72. return nil
  73. }
  74. // ConvertSliceNumbers traverses the slice, converting any json.Number values to int64 or float64.
  75. // values which are map[string]interface{} or []interface{} are recursively visited
  76. func ConvertSliceNumbers(s []interface{}, depth int) error {
  77. if depth > maxDepth {
  78. return fmt.Errorf("exceeded max depth of %d", maxDepth)
  79. }
  80. var err error
  81. for i, v := range s {
  82. switch v := v.(type) {
  83. case json.Number:
  84. s[i], err = convertNumber(v)
  85. case map[string]interface{}:
  86. err = ConvertMapNumbers(v, depth+1)
  87. case []interface{}:
  88. err = ConvertSliceNumbers(v, depth+1)
  89. }
  90. if err != nil {
  91. return err
  92. }
  93. }
  94. return nil
  95. }
  96. // convertNumber converts a json.Number to an int64 or float64, or returns an error
  97. func convertNumber(n json.Number) (interface{}, error) {
  98. // Attempt to convert to an int64 first
  99. if i, err := n.Int64(); err == nil {
  100. return i, nil
  101. }
  102. // Return a float64 (default json.Decode() behavior)
  103. // An overflow will return an error
  104. return n.Float64()
  105. }