class SidekiqUniqueJobs::Middleware::Client::Strategies::Unique

def self.elegible?
  true
end

def self.review(worker_class, item, queue, redis_pool = nil, log_duplicate_payload = false)
  new(worker_class, item, queue, redis_pool, log_duplicate_payload).review { yield }
end

def connection(&block)
  SidekiqUniqueJobs::Connectors.connection(redis_pool, &block)
end

def initialize(worker_class, item, queue, redis_pool = nil, log_duplicate_payload = false)
  @worker_class = SidekiqUniqueJobs.worker_class_constantize(worker_class)
  @item = item
  @queue = queue
  @redis_pool = redis_pool
  @log_duplicate_payload = log_duplicate_payload
  REQUIRE_FILES.call
end

def payload_hash
  SidekiqUniqueJobs::PayloadHelper.get_payload(item['class'], item['queue'], item['args'])
end

def review
  item['unique_hash'] = payload_hash
  unless unique_for_connection?
    if @log_duplicate_payload
      Sidekiq.logger.warn "payload is not unique #{item}"
    end
    return
  end
  yield
end

def unique_for_connection?
  unique = false
  connection do |conn|
    conn.watch(payload_hash)
    if conn.get(payload_hash).to_i == 1 ||
       (conn.get(payload_hash).to_i == 2 && item['at'])
      # if the job is already queued, or is already scheduled and
      # we're trying to schedule again, abort
      conn.unwatch
    else
      # if the job was previously scheduled and is now being queued,
      # or we've never seen it before
      expires_at = unique_job_expiration || SidekiqUniqueJobs.config.default_expiration
      expires_at = ((Time.at(item['at']) - Time.now.utc) + expires_at).to_i if item['at']
      unique = conn.multi do
        # set value of 2 for scheduled jobs, 1 for queued jobs.
        conn.setex(payload_hash, expires_at, item['at'] ? 2 : 1)
      end
    end
  end
  unique
end

def unique_job_expiration
  worker_class.get_sidekiq_options['unique_job_expiration']
end