Contents

# frozen_string_literal: true

module SidekiqUniqueJobs
  module OnConflict
    # Strategy to replace the job on conflict
    #
    # @author Mikael Henriksson <[e-mail]>
    class Replace < OnConflict::Strategy
      attr_reader :queue, :unique_digest

      # @param [Hash] item sidekiq job hash
      def initialize(item)
        super
        @queue         = item[QUEUE_KEY]
        @unique_digest = item[UNIQUE_DIGEST_KEY]
      end

      # Replace the old job in the queue
      # @yield to retry the lock after deleting the old one
      def call(&block)
        return unless delete_job_by_digest
        delete_lock
        block&.call
      end

      # Delete the job from either schedule, retry or the queue
      def delete_job_by_digest
        Scripts.call(:delete_job_by_digest, nil, keys: [queue, unique_digest])
      end

      # Delete the keys belonging to the job
      def delete_lock
        Scripts.call(:delete_by_digest, nil, keys: [UNIQUE_SET, unique_digest])
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sidekiq-unique-jobs-6.0.6	lib/sidekiq_unique_jobs/on_conflict/replace.rb
sidekiq-unique-jobs-6.0.5	lib/sidekiq_unique_jobs/on_conflict/replace.rb
sidekiq-unique-jobs-6.0.4	lib/sidekiq_unique_jobs/on_conflict/replace.rb
sidekiq-unique-jobs-6.0.3	lib/sidekiq_unique_jobs/on_conflict/replace.rb