module SidekiqToolbelt

# File lib/sidekiq_toolbelt.rb, line 44
def clear(*jobs, queue: :default)
  loop do
    # update and reuse #kill?
    Sidekiq::Queue.new(:default).each do |job|
      if jobs.include? job.klass
        job.delete
      end
    end
    puts 'clearing...'
    sleep 5
  end
end

# File lib/sidekiq_toolbelt.rb, line 6
def counts(queue: :default)
  counts = {}

  Sidekiq::Queue.new(queue).each do |job|
    if counts[job.klass].nil?
      counts[job.klass] = 1
    else
      counts[job.klass] += 1
    end
  end

  pp counts.sort_by {|k,v| -v}.to_h
end

# File lib/sidekiq_toolbelt.rb, line 20
def kill(job_name, queue: :default)
  Sidekiq::Queue.new(queue).each do |job|
    job.delete if job.klass.starts_with?(job_name)
  end
end

# File lib/sidekiq_toolbelt.rb, line 26
def kill_by_error(error, queue: :default)
  Sidekiq::Queue.new(queue).each do |job|
    job.delete if job.item['error_class'] == error
  end
end

# File lib/sidekiq_toolbelt.rb, line 32
def kill_retries(job_name)
  Sidekiq::RetrySet.new.each do |job|
    job.delete if job.klass.starts_with?(job_name)
  end
end

# File lib/sidekiq_toolbelt.rb, line 38
def kill_retries_by_error(error)
  Sidekiq::RetrySet.new.each do |job|
    job.delete if job.item['error_class'] == error
  end
end