Method: QueryDam.get_updates

Defined in:
lib/query_dam.rb

.get_updates(key) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/query_dam.rb', line 23

def get_updates(key)
  query_hash = Redis::HashKey.new(key)
  return nil unless query_hash.exists?

  model = query_hash[:model].constantize

  result = {
    model: model,
    updates: model.where(id: updates_set(key).to_a),
    exclusions: exclusions_set(key).to_a.map(&:to_i) }

  updates_set(key).clear
  exclusions_set(key).clear

  result
end