json.go 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  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. "bytes"
  16. "encoding/json"
  17. "io"
  18. )
  19. // NewEncoder delegates to json.NewEncoder
  20. // It is only here so this package can be a drop-in for common encoding/json uses
  21. func NewEncoder(w io.Writer) *json.Encoder {
  22. return json.NewEncoder(w)
  23. }
  24. // Marshal delegates to json.Marshal
  25. // It is only here so this package can be a drop-in for common encoding/json uses
  26. func Marshal(v interface{}) ([]byte, error) {
  27. return json.Marshal(v)
  28. }
  29. // Unmarshal unmarshals the given data
  30. // If v is a *map[string]interface{}, numbers are converted to int64 or float64
  31. func Unmarshal(data []byte, v interface{}) error {
  32. switch v := v.(type) {
  33. case *map[string]interface{}:
  34. // Build a decoder from the given data
  35. decoder := json.NewDecoder(bytes.NewBuffer(data))
  36. // Preserve numbers, rather than casting to float64 automatically
  37. decoder.UseNumber()
  38. // Run the decode
  39. if err := decoder.Decode(v); err != nil {
  40. return err
  41. }
  42. // If the decode succeeds, post-process the map to convert json.Number objects to int64 or float64
  43. return convertMapNumbers(*v)
  44. default:
  45. return json.Unmarshal(data, v)
  46. }
  47. }
  48. // convertMapNumbers traverses the map, converting any json.Number values to int64 or float64.
  49. // values which are map[string]interface{} or []interface{} are recursively visited
  50. func convertMapNumbers(m map[string]interface{}) error {
  51. var err error
  52. for k, v := range m {
  53. switch v := v.(type) {
  54. case json.Number:
  55. m[k], err = convertNumber(v)
  56. case map[string]interface{}:
  57. err = convertMapNumbers(v)
  58. case []interface{}:
  59. err = convertSliceNumbers(v)
  60. }
  61. if err != nil {
  62. return err
  63. }
  64. }
  65. return nil
  66. }
  67. // convertSliceNumbers traverses the slice, converting any json.Number values to int64 or float64.
  68. // values which are map[string]interface{} or []interface{} are recursively visited
  69. func convertSliceNumbers(s []interface{}) error {
  70. var err error
  71. for i, v := range s {
  72. switch v := v.(type) {
  73. case json.Number:
  74. s[i], err = convertNumber(v)
  75. case map[string]interface{}:
  76. err = convertMapNumbers(v)
  77. case []interface{}:
  78. err = convertSliceNumbers(v)
  79. }
  80. if err != nil {
  81. return err
  82. }
  83. }
  84. return nil
  85. }
  86. // convertNumber converts a json.Number to an int64 or float64, or returns an error
  87. func convertNumber(n json.Number) (interface{}, error) {
  88. // Attempt to convert to an int64 first
  89. if i, err := n.Int64(); err == nil {
  90. return i, nil
  91. }
  92. // Return a float64 (default json.Decode() behavior)
  93. // An overflow will return an error
  94. return n.Float64()
  95. }