Sha256: 714f46742c6c1a6613c8a3e933cb2fbe8f1c87f22015f6faa2abafda79455eb7
Contents?: true
Size: 1.22 KB
Versions: 8
Compression:
Stored size: 1.22 KB
Contents
# -*- coding: utf-8 -*-
module XapianDb
module IndexWriters
# Worker to update the Xapian index; the worker will be called by sidekiq
# and uses the DirectWriter to do the real work
# @author Michael Stämpfli and John Bradley
class SidekiqWorker
extend XapianDb::Utilities
APPROVED_TASKS = [:index, :delete_doc, :reindex_class]
def perform(task, options)
self.class.send(task, options) if APPROVED_TASKS.include?(task.to_sym)
end
class << self
def queue
XapianDb::Config.sidekiq_queue
end
def perform(task, options)
send(task, options) if APPROVED_TASKS.include?(task.to_sym)
end
def index(options)
klass = constantize options['class']
obj = klass.respond_to?('get') ? klass.get(options['id']) : klass.find(options['id'])
DirectWriter.index obj, true, changed_attrs: options[:changed_attrs]
end
def delete_doc(options)
DirectWriter.delete_doc_with options['xapian_id']
end
def reindex_class(options)
klass = constantize options['class']
DirectWriter.reindex_class klass, :verbose => false
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems