Class: TireAsyncIndex::Workers::UpdateIndex

Inherits:
Object
  • Object
show all
Defined in:
lib/tire_async_index/workers/update_index.rb

Overview

Worker for updating ElasticSearch index

Direct Known Subclasses

ResqueUpdateIndex, SidekiqUpdateIndex

Instance Method Summary collapse

Instance Method Details

#find_class_const(class_name) ⇒ Object 



32
33
34
35
36
37
38
39
40
 
# File 'lib/tire_async_index/workers/update_index.rb', line 32

def find_class_const(class_name)
  if defined?(RUBY_VERSION) && RUBY_VERSION.match(/^2\./)
    Kernel.const_get(class_name)
  else
    class_name.split('::').reduce(Object) do |mod, const_name|
      mod.const_get(const_name)
    end
  end
end

#perform(action_type, class_name, id) ⇒ Object

Update or delete ElasticSearch index based on the action_type parameter.

Parameters:

action_type - Determine index direction. (allowed value - Update or Delete)
class_name - Model class name
id - Document id



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/tire_async_index/workers/update_index.rb', line 14

def perform(action_type, class_name, id)
  klass = find_class_const(class_name)

  case action_type.to_sym
    when :update
      object = klass.find(id)

      if object.present? && object.respond_to?(:tire)
        object.tire.update_index
      end
    when :delete

      klass.new.tap do |inst|
        inst.tire.index.remove(inst.tire.document_type, { _id: id })
      end
  end
end