Class: Graphiti::Query

Inherits:
Object show all
Defined in:
lib/graphiti/query.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(resource, params, association_name = nil, nested_include = nil, parents = [], action = nil) ⇒ Query

Returns a new instance of Query.



5
6
7
8
9
10
11
12
13
14
15
 
# File 'lib/graphiti/query.rb', line 5

def initialize(resource, params, association_name = nil, nested_include = nil, parents = [], action = nil)
  @resource = resource
  @association_name = association_name
  @params = params
  @params = @params.permit! if @params.respond_to?(:permit!)
  @params = @params.to_h if @params.respond_to?(:to_h)
  @params = @params.deep_symbolize_keys
  @include_param = nested_include || @params[:include]
  @parents = parents
  @action = parse_action(action)
end

Instance Attribute Details

#action ⇒ Object (readonly)

Returns the value of attribute action.



3
4
5
 
# File 'lib/graphiti/query.rb', line 3

def action
  @action
end

#association_name ⇒ Object (readonly)

Returns the value of attribute association_name.



3
4
5
 
# File 'lib/graphiti/query.rb', line 3

def association_name
  @association_name
end

#params ⇒ Object (readonly)

Returns the value of attribute params.



3
4
5
 
# File 'lib/graphiti/query.rb', line 3

def params
  @params
end

#resource ⇒ Object (readonly)

Returns the value of attribute resource.



3
4
5
 
# File 'lib/graphiti/query.rb', line 3

def resource
  @resource
end

Instance Method Details

#association? ⇒ Boolean

Returns:

  • (Boolean) 


17
18
19
 
# File 'lib/graphiti/query.rb', line 17

def association?
  !!@association_name
end

#debug_requested? ⇒ Boolean

Returns:

  • (Boolean) 


42
43
44
 
# File 'lib/graphiti/query.rb', line 42

def debug_requested?
  !!@params[:debug]
end

#extra_fields ⇒ Object 



122
123
124
 
# File 'lib/graphiti/query.rb', line 122

def extra_fields
  @extra_fields ||= parse_fieldset(@params[:extra_fields] || {})
end

#fields ⇒ Object 



112
113
114
115
116
117
118
119
120
 
# File 'lib/graphiti/query.rb', line 112

def fields
  @fields ||= begin
    hash = parse_fieldset(@params[:fields] || {})
    hash.each_pair do |type, fields|
      hash[type] += extra_fields[type] if extra_fields[type]
    end
    hash
  end
end

#filters ⇒ Object 



126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
 
# File 'lib/graphiti/query.rb', line 126

def filters
  @filters ||= begin
    {}.tap do |hash|
      (@params[:filter] || {}).each_pair do |name, value|
        name = name.to_sym

        if legacy_nested?(name)
          value.keys.each do |key|
            filter_name = key.to_sym
            filter_value = value[key]

            if @resource.get_attr!(filter_name, :filterable, request: true)
              hash[filter_name] = filter_value
            end
          end
        elsif nested?(name)
          name = name.to_s.split(".").last.to_sym
          validate!(name, :filterable)
          hash[name] = value
        elsif top_level? && validate!(name, :filterable)
          hash[name] = value
        end
      end
    end
  end
end

#hash ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/graphiti/query.rb', line 46

def hash
  @hash ||= {}.tap do |h|
    h[:filter] = filters
    h[:sort] = sorts
    h[:page] = pagination
    if association?
      resource_type = @resource.class.type
      h[:extra_fields] = {resource_type => extra_fields[resource_type]} if extra_fields.key?(resource_type)
    else
      h[:fields] = fields
      h[:extra_fields] = extra_fields
    end
    h[:stats] = stats
    h[:include] = sideload_hash
  end.reject { |_, value| value.empty? }
end

#include_hash ⇒ Object 



193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
 
# File 'lib/graphiti/query.rb', line 193

def include_hash
  @include_hash ||= begin
    requested = include_directive.to_hash

    allowlist = nil
    if @resource.context&.respond_to?(:sideload_allowlist)
      allowlist = @resource.context.sideload_allowlist
      allowlist = allowlist[@resource.context_namespace] if allowlist
    end

    allowlist ? Util::IncludeParams.scrub(requested, allowlist) : requested
  end

  @include_hash
end

#links? ⇒ Boolean

Returns:

  • (Boolean) 


25
26
27
28
29
30
31
32
 
# File 'lib/graphiti/query.rb', line 25

def links?
  return false if [:json, :xml, "json", "xml"].include?(params[:format])
  if Graphiti.config.links_on_demand
    [true, "true"].include?(@params[:links])
  else
    true
  end
end

#paginate? ⇒ Boolean

Returns:

  • (Boolean) 


224
225
226
 
# File 'lib/graphiti/query.rb', line 224

def paginate?
  ![false, "false"].include?(@params[:paginate])
end

#pagination ⇒ Object 



175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
 
# File 'lib/graphiti/query.rb', line 175

def pagination
  @pagination ||= begin
    {}.tap do |hash|
      (@params[:page] || {}).each_pair do |name, value|
        if legacy_nested?(name)
          value.each_pair do |k, v|
            hash[k.to_sym] = v.to_i
          end
        elsif nested?(name)
          hash[name.to_s.split(".").last.to_sym] = value
        elsif top_level? && [:number, :size].include?(name.to_sym)
          hash[name.to_sym] = value.to_i
        end
      end
    end
  end
end

#pagination_links? ⇒ Boolean

Returns:

  • (Boolean) 


34
35
36
37
38
39
40
 
# File 'lib/graphiti/query.rb', line 34

def pagination_links?
  if Graphiti.config.pagination_links_on_demand
    [true, "true"].include?(@params[:pagination_links])
  else
    Graphiti.config.pagination_links
  end
end

#parents ⇒ Object 



108
109
110
 
# File 'lib/graphiti/query.rb', line 108

def parents
  @parents ||= []
end

#resource_for_sideload(sideload) ⇒ Object 



79
80
81
82
83
84
85
86
87
 
# File 'lib/graphiti/query.rb', line 79

def resource_for_sideload(sideload)
  if @resource.remote?
    Class.new(Graphiti::Resource) {
      self.remote = "_remote_sideload_"
    }.new
  else
    sideload.resource
  end
end

#sideload_hash ⇒ Object 



69
70
71
72
73
74
75
76
77
 
# File 'lib/graphiti/query.rb', line 69

def sideload_hash
  @sideload_hash = begin
    {}.tap do |hash|
      sideloads.each_pair do |key, value|
        hash[key] = sideloads[key].hash
      end
    end
  end
end

#sideloads ⇒ Object 



89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
 
# File 'lib/graphiti/query.rb', line 89

def sideloads
  @sideloads ||= begin
    {}.tap do |hash|
      include_hash.each_pair do |key, sub_hash|
        sideload = @resource.class.sideload(key)

        if sideload || @resource.remote?
          sl_resource = resource_for_sideload(sideload)
          query_parents = parents + [self]
          sub_hash = sub_hash[:include] if sub_hash.key?(:include)
          hash[key] = Query.new(sl_resource, @params, key, sub_hash, query_parents, :all)
        else
          handle_missing_sideload(key)
        end
      end
    end
  end
end

#sorts ⇒ Object 



153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
 
# File 'lib/graphiti/query.rb', line 153

def sorts
  @sorts ||= begin
    return @params[:sort] if @params[:sort].is_a?(Array)
    return [] if @params[:sort].nil?

    [].tap do |arr|
      sort_hashes do |key, value, type|
        if legacy_nested?(type)
          unless @resource.remote?
            @resource.get_attr!(key, :sortable, request: true)
          end
          arr << {key => value}
        elsif !type && top_level? && validate!(key, :sortable)
          arr << {key => value}
        elsif nested?("#{type}.#{key}")
          arr << {key => value}
        end
      end
    end
  end
end

#stats ⇒ Object 



209
210
211
212
213
214
215
216
217
218
219
220
221
222
 
# File 'lib/graphiti/query.rb', line 209

def stats
  @stats ||= begin
    {}.tap do |hash|
      (@params[:stats] || {}).each_pair do |k, v|
        if legacy_nested?(k)
          raise NotImplementedError.new("Association statistics are not currently supported")
        elsif top_level?
          v = v.split(",") if v.is_a?(String)
          hash[k.to_sym] = Array(v).flatten.map(&:to_sym)
        end
      end
    end
  end
end

#top_level? ⇒ Boolean

Returns:

  • (Boolean) 


21
22
23
 
# File 'lib/graphiti/query.rb', line 21

def top_level?
  !association?
end

#zero_results? ⇒ Boolean

Returns:

  • (Boolean) 


63
64
65
66
67
 
# File 'lib/graphiti/query.rb', line 63

def zero_results?
  !@params[:page].nil? &&
    !@params[:page][:size].nil? &&
    @params[:page][:size].to_i == 0
end