Contents

module SidekiqUniqueJobs
  module OptionsWithFallback
    def self.included(base)
      base.class_attribute :lock_cache unless base.respond_to?(:lock_cache)
      base.lock_cache ||= {}
    end

    def unique_enabled?
      options[UNIQUE_KEY] || item[UNIQUE_KEY]
    end

    def unique_disabled?
      !unique_enabled?
    end

    def log_duplicate_payload?
      options[LOG_DUPLICATE_KEY] || item[LOG_DUPLICATE_KEY]
    end

    def lock
      @lock = lock_class.new(item)
    end

    def lock_class
      lock_cache[unique_lock.to_sym] ||= "SidekiqUniqueJobs::Lock::#{unique_lock.to_s.classify}".constantize
    end

    def unique_lock
      if options.key?(UNIQUE_KEY) && options[UNIQUE_KEY] == true
        warn('unique: true is no longer valid. Please set it to the type of lock required like: ' \
             '`unique: :until_executed`')
        options[UNIQUE_LOCK_KEY] || SidekiqUniqueJobs.default_lock
      else
        options[UNIQUE_KEY] || item[UNIQUE_KEY] || SidekiqUniqueJobs.default_lock
      end
    end

    def options
      @options ||= worker_class.get_sidekiq_options if worker_class.respond_to?(:get_sidekiq_options)
      @options ||= Sidekiq.default_worker_options
      @options ||= {}
      @options &&= @options.stringify_keys
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
sidekiq-unique-jobs-4.0.12	lib/sidekiq_unique_jobs/options_with_fallback.rb
sidekiq-unique-jobs-4.0.11	lib/sidekiq_unique_jobs/options_with_fallback.rb
sidekiq-unique-jobs-4.0.10	lib/sidekiq_unique_jobs/options_with_fallback.rb
sidekiq-unique-jobs-4.0.9	lib/sidekiq_unique_jobs/options_with_fallback.rb
sidekiq-unique-jobs-4.0.8	lib/sidekiq_unique_jobs/options_with_fallback.rb
sidekiq-unique-jobs-4.0.7	lib/sidekiq_unique_jobs/options_with_fallback.rb