Contents

# -*- coding: utf-8 -*-
module XapianDb
  module IndexWriters
    # Worker to update the Xapian index; the worker will be called by resque
    # and uses the DirectWriter to do the real work
    # @author Michael Stämpfli
    class ResqueWorker

      extend XapianDb::Utilities

      APPROVED_TASKS = [:index, :delete_doc, :reindex_class]

      class << self
        def queue
          XapianDb::Config.resque_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
        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

28 entries across 28 versions & 1 rubygems

Version	Path
xapian_db-1.2.4	lib/xapian_db/index_writers/resque_worker.rb
xapian_db-1.2.3	lib/xapian_db/index_writers/resque_worker.rb
xapian_db-1.2.2.2	lib/xapian_db/index_writers/resque_worker.rb
xapian_db-1.2.2.1	lib/xapian_db/index_writers/resque_worker.rb
xapian_db-1.2.2	lib/xapian_db/index_writers/resque_worker.rb
xapian_db-1.2.1.1	lib/xapian_db/index_writers/resque_worker.rb
xapian_db-1.2.1	lib/xapian_db/index_writers/resque_worker.rb
xapian_db-1.2.0	lib/xapian_db/index_writers/resque_worker.rb