Sha256: e4ba00d8dd19a675cd7dba8e8282e04749de953f632993438a7e8e7b62175362
Contents?: true
Size: 1.8 KB
Versions: 9
Compression:
Stored size: 1.8 KB
Contents
# frozen_string_literal: true
module SidekiqUniqueJobs
# Module with convenience methods for the Sidekiq::Worker class
#
# @author Mikael Henriksson <mikael@zoolutions.se>
module SidekiqWorkerMethods
# Avoids duplicating worker_class.respond_to? in multiple places
# @return [true, false]
def worker_method_defined?(method_sym)
worker_class.respond_to?(method_sym)
end
# Wraps #get_sidekiq_options to always work with a hash
# @return [Hash] of the worker class sidekiq options
def worker_options
return {} unless sidekiq_worker_class?
worker_class.get_sidekiq_options.stringify_keys
end
# Tests that the
# @return [true] if worker_class responds to get_sidekiq_options
# @return [false] if worker_class does not respond to get_sidekiq_options
def sidekiq_worker_class?
worker_method_defined?(:get_sidekiq_options)
end
# The Sidekiq::Worker implementation
# @return [Sidekiq::Worker]
def worker_class
@_worker_class ||= worker_class_constantize # rubocop:disable Naming/MemoizedInstanceVariableName
end
# The hook to call after a successful unlock
# @return [Proc]
def after_unlock_hook
-> { worker_class.after_unlock if worker_method_defined?(:after_unlock) }
end
# Attempt to constantize a string worker_class argument, always
# failing back to the original argument when the constant can't be found
#
# @return [Sidekiq::Worker]
def worker_class_constantize(klazz = @worker_class)
return klazz unless klazz.is_a?(String)
Object.const_get(klazz)
rescue NameError => ex
case ex.message
when /uninitialized constant/
klazz
else
raise
end
end
def default_worker_options
Sidekiq.default_worker_options
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems