Contents

module Sunspot
  module SessionProxy
    class DelayedJobSessionProxy < ::Sunspot::SessionProxy::AbstractSessionProxy
      attr_reader :session

      delegate :config, :delete_dirty?, :dirty?, :more_like_this, :new_more_like_this, :new_search,
               :optimize, :search,
               :to => :session

      def initialize(session)
        @session = session
      end

      def batch(&block)
        enqueue(:batch, &block)
      end

      def commit
        enqueue(:commit)
      end

      def commit_if_delete_dirty
        commit if @session.delete_dirty?
      end

      def commit_if_dirty
        commit if @session.dirty?
      end

      def index(*objects)
        enqueue(:index, *objects)
      end

      def index!(*objects)
        index(*objects)
        commit
      end

      def remove(*objects, &block)
        enqueue(:remove, *objects, &block)
      end

      def remove!(*objects)
        remove(*objects)
        commit
      end

      def remove_all(*classes)
        enqueue(:remove_all, *classes)
      end

      def remove_all!(*classes)
        remove_all(*classes)
        commit
      end

      def remove_by_id(clazz, id)
        enqueue(:remove_by_id, clazz, id)
      end

      def remove_by_id!(clazz, id)
        remove_by_id(clazz, id)
        commit
      end

      private
      def enqueue(method, *args, &block)
        Delayed::Job.enqueue(DelayedSunspot::DelayedJob::SunspotJob.new(self, method, *args, &block))
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
delayed_sunspot-0.1.0	lib/delayed_sunspot/sunspot/session_proxy/delayed_job_session_proxy.rb