query.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. package encoder
  2. import (
  3. "context"
  4. "fmt"
  5. "reflect"
  6. )
  7. var (
  8. Marshal func(interface{}) ([]byte, error)
  9. Unmarshal func([]byte, interface{}) error
  10. )
  11. type FieldQuery struct {
  12. Name string
  13. Fields []*FieldQuery
  14. hash string
  15. }
  16. func (q *FieldQuery) Hash() string {
  17. if q.hash != "" {
  18. return q.hash
  19. }
  20. b, _ := Marshal(q)
  21. q.hash = string(b)
  22. return q.hash
  23. }
  24. func (q *FieldQuery) MarshalJSON() ([]byte, error) {
  25. if q.Name != "" {
  26. if len(q.Fields) > 0 {
  27. return Marshal(map[string][]*FieldQuery{q.Name: q.Fields})
  28. }
  29. return Marshal(q.Name)
  30. }
  31. return Marshal(q.Fields)
  32. }
  33. func (q *FieldQuery) QueryString() (FieldQueryString, error) {
  34. b, err := Marshal(q)
  35. if err != nil {
  36. return "", err
  37. }
  38. return FieldQueryString(b), nil
  39. }
  40. type FieldQueryString string
  41. func (s FieldQueryString) Build() (*FieldQuery, error) {
  42. var query interface{}
  43. if err := Unmarshal([]byte(s), &query); err != nil {
  44. return nil, err
  45. }
  46. return s.build(reflect.ValueOf(query))
  47. }
  48. func (s FieldQueryString) build(v reflect.Value) (*FieldQuery, error) {
  49. switch v.Type().Kind() {
  50. case reflect.String:
  51. return s.buildString(v)
  52. case reflect.Map:
  53. return s.buildMap(v)
  54. case reflect.Slice:
  55. return s.buildSlice(v)
  56. case reflect.Interface:
  57. return s.build(reflect.ValueOf(v.Interface()))
  58. }
  59. return nil, fmt.Errorf("failed to build field query")
  60. }
  61. func (s FieldQueryString) buildString(v reflect.Value) (*FieldQuery, error) {
  62. b := []byte(v.String())
  63. switch b[0] {
  64. case '[', '{':
  65. var query interface{}
  66. if err := Unmarshal(b, &query); err != nil {
  67. return nil, err
  68. }
  69. if str, ok := query.(string); ok {
  70. return &FieldQuery{Name: str}, nil
  71. }
  72. return s.build(reflect.ValueOf(query))
  73. }
  74. return &FieldQuery{Name: string(b)}, nil
  75. }
  76. func (s FieldQueryString) buildSlice(v reflect.Value) (*FieldQuery, error) {
  77. fields := make([]*FieldQuery, 0, v.Len())
  78. for i := 0; i < v.Len(); i++ {
  79. def, err := s.build(v.Index(i))
  80. if err != nil {
  81. return nil, err
  82. }
  83. fields = append(fields, def)
  84. }
  85. return &FieldQuery{Fields: fields}, nil
  86. }
  87. func (s FieldQueryString) buildMap(v reflect.Value) (*FieldQuery, error) {
  88. keys := v.MapKeys()
  89. if len(keys) != 1 {
  90. return nil, fmt.Errorf("failed to build field query object")
  91. }
  92. key := keys[0]
  93. if key.Type().Kind() != reflect.String {
  94. return nil, fmt.Errorf("failed to build field query. invalid object key type")
  95. }
  96. name := key.String()
  97. def, err := s.build(v.MapIndex(key))
  98. if err != nil {
  99. return nil, err
  100. }
  101. return &FieldQuery{
  102. Name: name,
  103. Fields: def.Fields,
  104. }, nil
  105. }
  106. type queryKey struct{}
  107. func FieldQueryFromContext(ctx context.Context) *FieldQuery {
  108. query := ctx.Value(queryKey{})
  109. if query == nil {
  110. return nil
  111. }
  112. q, ok := query.(*FieldQuery)
  113. if !ok {
  114. return nil
  115. }
  116. return q
  117. }
  118. func SetFieldQueryToContext(ctx context.Context, query *FieldQuery) context.Context {
  119. return context.WithValue(ctx, queryKey{}, query)
  120. }