binding.go 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190
  1. package binding
  2. import (
  3. "encoding/json"
  4. "encoding/xml"
  5. "errors"
  6. "net/http"
  7. "reflect"
  8. "strconv"
  9. "strings"
  10. )
  11. type (
  12. Binding interface {
  13. Bind(*http.Request, interface{}) error
  14. }
  15. // JSON binding
  16. jsonBinding struct{}
  17. // XML binding
  18. xmlBinding struct{}
  19. // // form binding
  20. formBinding struct{}
  21. )
  22. var (
  23. JSON = jsonBinding{}
  24. XML = xmlBinding{}
  25. Form = formBinding{} // todo
  26. )
  27. func (_ jsonBinding) Bind(req *http.Request, obj interface{}) error {
  28. decoder := json.NewDecoder(req.Body)
  29. if err := decoder.Decode(obj); err == nil {
  30. return Validate(obj)
  31. } else {
  32. return err
  33. }
  34. }
  35. func (_ xmlBinding) Bind(req *http.Request, obj interface{}) error {
  36. decoder := xml.NewDecoder(req.Body)
  37. if err := decoder.Decode(obj); err == nil {
  38. return Validate(obj)
  39. } else {
  40. return err
  41. }
  42. }
  43. func (_ formBinding) Bind(req *http.Request, obj interface{}) error {
  44. if err := req.ParseForm(); err != nil {
  45. return err
  46. }
  47. if err := mapForm(obj, req.Form); err != nil {
  48. return err
  49. }
  50. return Validate(obj)
  51. }
  52. func mapForm(ptr interface{}, form map[string][]string) error {
  53. typ := reflect.TypeOf(ptr).Elem()
  54. formStruct := reflect.ValueOf(ptr).Elem()
  55. for i := 0; i < typ.NumField(); i++ {
  56. typeField := typ.Field(i)
  57. if inputFieldName := typeField.Tag.Get("form"); inputFieldName != "" {
  58. structField := formStruct.Field(i)
  59. if !structField.CanSet() {
  60. continue
  61. }
  62. inputValue, exists := form[inputFieldName]
  63. if !exists {
  64. continue
  65. }
  66. numElems := len(inputValue)
  67. if structField.Kind() == reflect.Slice && numElems > 0 {
  68. sliceOf := structField.Type().Elem().Kind()
  69. slice := reflect.MakeSlice(structField.Type(), numElems, numElems)
  70. for i := 0; i < numElems; i++ {
  71. if err := setWithProperType(sliceOf, inputValue[i], slice.Index(i)); err != nil {
  72. return err
  73. }
  74. }
  75. formStruct.Elem().Field(i).Set(slice)
  76. } else {
  77. if err := setWithProperType(typeField.Type.Kind(), inputValue[0], structField); err != nil {
  78. return err
  79. }
  80. }
  81. }
  82. }
  83. return nil
  84. }
  85. func setWithProperType(valueKind reflect.Kind, val string, structField reflect.Value) error {
  86. switch valueKind {
  87. case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
  88. if val == "" {
  89. val = "0"
  90. }
  91. intVal, err := strconv.Atoi(val)
  92. if err != nil {
  93. return err
  94. } else {
  95. structField.SetInt(int64(intVal))
  96. }
  97. case reflect.Bool:
  98. if val == "" {
  99. val = "false"
  100. }
  101. boolVal, err := strconv.ParseBool(val)
  102. if err != nil {
  103. return err
  104. } else {
  105. structField.SetBool(boolVal)
  106. }
  107. case reflect.Float32:
  108. if val == "" {
  109. val = "0.0"
  110. }
  111. floatVal, err := strconv.ParseFloat(val, 32)
  112. if err != nil {
  113. return err
  114. } else {
  115. structField.SetFloat(floatVal)
  116. }
  117. case reflect.Float64:
  118. if val == "" {
  119. val = "0.0"
  120. }
  121. floatVal, err := strconv.ParseFloat(val, 64)
  122. if err != nil {
  123. return err
  124. } else {
  125. structField.SetFloat(floatVal)
  126. }
  127. case reflect.String:
  128. structField.SetString(val)
  129. }
  130. return nil
  131. }
  132. // Don't pass in pointers to bind to. Can lead to bugs. See:
  133. // https://github.com/codegangsta/martini-contrib/issues/40
  134. // https://github.com/codegangsta/martini-contrib/pull/34#issuecomment-29683659
  135. func ensureNotPointer(obj interface{}) {
  136. if reflect.TypeOf(obj).Kind() == reflect.Ptr {
  137. panic("Pointers are not accepted as binding models")
  138. }
  139. }
  140. func Validate(obj interface{}) error {
  141. typ := reflect.TypeOf(obj)
  142. val := reflect.ValueOf(obj)
  143. if typ.Kind() == reflect.Ptr {
  144. typ = typ.Elem()
  145. val = val.Elem()
  146. }
  147. for i := 0; i < typ.NumField(); i++ {
  148. field := typ.Field(i)
  149. fieldValue := val.Field(i).Interface()
  150. zero := reflect.Zero(field.Type).Interface()
  151. // Validate nested and embedded structs (if pointer, only do so if not nil)
  152. if field.Type.Kind() == reflect.Struct ||
  153. (field.Type.Kind() == reflect.Ptr && !reflect.DeepEqual(zero, fieldValue)) {
  154. if err := Validate(fieldValue); err != nil {
  155. return err
  156. }
  157. }
  158. if strings.Index(field.Tag.Get("binding"), "required") > -1 {
  159. if reflect.DeepEqual(zero, fieldValue) {
  160. name := field.Name
  161. if j := field.Tag.Get("json"); j != "" {
  162. name = j
  163. } else if f := field.Tag.Get("form"); f != "" {
  164. name = f
  165. }
  166. return errors.New("Required " + name)
  167. }
  168. }
  169. }
  170. return nil
  171. }