Sha256: eab13e9dcc38ed6b8d03580a8decf9ab2f68d45de00f29bfd79dafdcf743a7e7
Contents?: true
Size: 1.99 KB
Versions: 11
Compression:
Stored size: 1.99 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.class if klazz.is_a?(Sidekiq::Worker) # sidekiq v6.x
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
#
# Returns the default worker options from Sidekiq
#
#
# @return [Hash<Symbol, Object>]
#
def default_worker_options
Sidekiq.default_worker_options
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems