require 'thinking_sphinx/deltas/sidekiq_delta'

namespace :thinking_sphinx do
  desc 'Lock all delta indices (Resque will not run indexer or place new jobs on the :ts_delta queue).'
  task :lock_deltas do
    ThinkingSphinx::Deltas::SidekiqDelta::CoreIndex.new.lock_deltas
  end

  desc 'Unlock all delta indices.'
  task :unlock_deltas do
    ThinkingSphinx::Deltas::SidekiqDelta::CoreIndex.new.unlock_deltas
  end

  desc 'Like `rake thinking_sphinx:index`, but locks one index at a time.'
  task :smart_index => :app_env do
    ret = ThinkingSphinx::Deltas::SidekiqDelta::CoreIndex.new.smart_index

    abort("Indexing failed.") if ret != true
  end
end

namespace :ts do
  desc 'Like `rake thinking_sphinx:index`, but locks one index at a time.'
  task :si => 'thinking_sphinx:smart_index'
end

unless Rake::Task.task_defined?('ts:index')
  require 'thinking_sphinx/tasks'
end

# Ensure that indexing does not conflict with ts-resque-delta delta jobs.
# Rake::Task['ts:index'].enhance ['thinking_sphinx:lock_deltas'] do
#   Rake::Task['thinking_sphinx:unlock_deltas'].invoke
# end

# Rake::Task['ts:reindex'].enhance ['thinking_sphinx:lock_deltas'] do
#   Rake::Task['thinking_sphinx:unlock_deltas'].invoke
# end