Class: QueryBatchRequest

Inherits:
Object
  • Object
show all
Defined in:
lib/query_batch_request.rb

Overview

Facilitate Batch updates using the pattern of

filter_query -> objects to update
stub object -> attributes/params to update

!! Should say nothing about how to update the objects.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(params) ⇒ QueryBatchRequest

Returns a new instance of QueryBatchRequest.



52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/query_batch_request.rb', line 52

def initialize(params)
  @async = params[:async]
  @async_cutoff = params[:async_cutoff]
  @cap = params[:cap]
  @cap_reason = params[:cap_reason]
  @klass = params[:klass] # || infer_class(params)
  @object_filter_params = params[:object_filter_params]
  @object_params = params[:object_params]
  @preview = params[:preview]
  @project_id = params[:project_id]
  @user_id = params[:user_id]

  @mode = params[:mode]
end

Instance Attribute Details

#async ⇒ Object

Returns Boolean whether to run the job asyncronously.

Returns:

  • Boolean whether to run the job asyncronously



24
25
26
 
# File 'lib/query_batch_request.rb', line 24

def async
  @async
end

#async_cutoff ⇒ Object

Number of records at which process is automatically made async



27
28
29
 
# File 'lib/query_batch_request.rb', line 27

def async_cutoff
  @async_cutoff
end

#cap ⇒ Object

Returns nil, Integer the max allowed records.

Returns:

  • nil, Integer the max allowed records



31
32
33
 
# File 'lib/query_batch_request.rb', line 31

def cap
  @cap
end

#cap_reason ⇒ Object

Returns String, nil the reason the cap is why it is (not required).

Returns:

  • String, nil the reason the cap is why it is (not required)



35
36
37
 
# File 'lib/query_batch_request.rb', line 35

def cap_reason
  @cap_reason
end

#filter ⇒ Object

Returns a Queries::<<klass>>::Filter instance.

Returns:

  • a Queries::<<klass>>::Filter instance



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

def filter
  @filter
end

#klass ⇒ Object

Returns String defines the Filter/Model to act on.

Returns:

  • String defines the Filter/Model to act on



39
40
41
 
# File 'lib/query_batch_request.rb', line 39

def klass
  @klass
end

#object_filter_params ⇒ Object

Parameters:

  • object_filter_params (Hash) —

    The params to parameterize a Queries::*::Filter. Defines the objects to be updated



16
17
18
 
# File 'lib/query_batch_request.rb', line 16

def object_filter_params
  @object_filter_params
end

#object_params ⇒ Object

Parameters:

  • object_params (Hash) —

    update the records to these attributes



11
12
13
 
# File 'lib/query_batch_request.rb', line 11

def object_params
  @object_params
end

#preview ⇒ Object

Returns Boolean true - rollback changes, can not be used with async.

Returns:

  • Boolean true - rollback changes, can not be used with async



20
21
22
 
# File 'lib/query_batch_request.rb', line 20

def preview
  @preview
end

#project_id ⇒ Object

Returns the value of attribute project_id.



48
49
50
 
# File 'lib/query_batch_request.rb', line 48

def project_id
  @project_id
end

#total_attempted ⇒ Object

Count of the records retured in filter.

Not used in async



46
47
48
 
# File 'lib/query_batch_request.rb', line 46

def total_attempted
  @total_attempted
end

#user_id ⇒ Object

Returns the value of attribute user_id.



50
51
52
 
# File 'lib/query_batch_request.rb', line 50

def user_id
  @user_id
end

Instance Method Details

#capped? ⇒ Boolean

Returns:

  • (Boolean) 


108
109
110
111
112
113
114
115
 
# File 'lib/query_batch_request.rb', line 108

def capped?
  if total_attempted > cap
    @cap_reason = "Update to more objects than allowed (#{cap}) requested." if cap_reason.blank?
    return true
  else
    false
  end
end

#infer_class(params) ⇒ Object 



67
68
69
70
 
# File 'lib/query_batch_request.rb', line 67

def infer_class(params)
  f = Queries::Query::Filter.base_filter(params)
  @klass = f.referenced_class.name.to_s
end

#response_params ⇒ Object 



92
93
94
95
96
97
98
99
100
101
102
 
# File 'lib/query_batch_request.rb', line 92

def response_params
  {
    klass:,
    async:,
    async_cutoff:,
    preview:,
    cap:,
    cap_reason:,
    total_attempted:
  }
end

#run_async? ⇒ Boolean

Returns:

  • (Boolean) 


117
118
119
120
121
 
# File 'lib/query_batch_request.rb', line 117

def run_async?
  if async_cutoff
    return total_attempted > async_cutoff
  end
end

#stub_response ⇒ Object 



104
105
106
 
# File 'lib/query_batch_request.rb', line 104

def stub_response
  BatchResponse.new(response_params)
end

#unprocessable? ⇒ Boolean

Returns:

  • (Boolean) 


76
77
78
 
# File 'lib/query_batch_request.rb', line 76

def unprocessable?
  object_filter_params.blank? || object_params.blank? || (run_async? && preview)
end