module Tire
  module Model
    module AsyncCallbacks
      def self.included(base)
        if base.respond_to?(:after_commit)
          index_update = lambda {
            case TireAsyncIndex.engine
            when :sidekiq
              SidekiqUpdateIndexWorker.perform_async(base.name, id)
            when :resque
              Resque.enqueue(ResqueUpdateIndexJob, base.name, id)
            else
              tire.update_index
            end

            self
          }

          base.send :after_commit, index_update, on: :create
          base.send :after_commit, index_update, on: :update
          base.send :after_commit, lambda { tire.update_index }, order: :first, on: :destroy
        end

        if base.respond_to?(:before_destroy) && !base.instance_methods.map(&:to_sym).include?(:destroyed?)
          base.class_eval do
            before_destroy  { @destroyed = true }
            def destroyed?; !!@destroyed; end
          end
        end

      end

    end

  end
end