module SidekiqUniqueJobs::Middleware

def self.configure
  configure_server
  configure_client
end

def self.configure_client
  Sidekiq.configure_client do |config|
    config.client_middleware do |chain|
      chain.add SidekiqUniqueJobs::Middleware::Client
    end
  end
end

def self.configure_server # rubocop:disable Metrics/MethodLength
  Sidekiq.configure_server do |config|
    config.client_middleware do |chain|
      chain.add SidekiqUniqueJobs::Middleware::Client
    end
    config.server_middleware do |chain|
      chain.add SidekiqUniqueJobs::Middleware::Server
    end
    config.on(:startup) do
      SidekiqUniqueJobs::UpdateVersion.call
      SidekiqUniqueJobs::UpgradeLocks.call
      SidekiqUniqueJobs::Orphans::Manager.start
    end
    config.on(:shutdown) do
      SidekiqUniqueJobs::Orphans::Manager.stop
    end
  end
end

def call(worker_class, item, queue, redis_pool = nil)
  @worker_class = worker_class
  @item         = item
  @queue        = queue
  @redis_pool   = redis_pool
  return yield if unique_disabled?
  SidekiqUniqueJobs::Job.prepare(item) unless item[LOCK_DIGEST]
  with_logging_context do
    super
  end
end