Sha256: 946d3ebeb23bff96627001c43bc7abb668b4082071b85deabfbccaef313773f4
Contents?: true
Size: 1.42 KB
Versions: 7
Compression:
Stored size: 1.42 KB
Contents
# frozen_string_literal: true
module SidekiqUniqueJobs
# Utility class to append uniqueness to the sidekiq job hash
#
# @author Mikael Henriksson <mikael@zoolutions.se>
module Job
extend self
# Adds timeout, expiration, lock_args, lock_prefix and lock_digest to the sidekiq job hash
# @return [Hash] the job hash
def prepare(item)
stringify_on_conflict_hash(item)
add_lock_timeout(item)
add_lock_ttl(item)
add_digest(item)
end
# Adds lock_args, lock_prefix and lock_digest to the sidekiq job hash
# @return [Hash] the job hash
def add_digest(item)
add_lock_prefix(item)
add_lock_args(item)
add_lock_digest(item)
item
end
private
def stringify_on_conflict_hash(item)
on_conflict = item[ON_CONFLICT]
return unless on_conflict.is_a?(Hash)
item[ON_CONFLICT] = on_conflict.deep_stringify_keys
end
def add_lock_ttl(item)
item[LOCK_TTL] = SidekiqUniqueJobs::LockTTL.calculate(item)
end
def add_lock_timeout(item)
item[LOCK_TIMEOUT] = SidekiqUniqueJobs::LockTimeout.calculate(item)
end
def add_lock_args(item)
item[LOCK_ARGS] = SidekiqUniqueJobs::LockArgs.call(item)
end
def add_lock_digest(item)
item[LOCK_DIGEST] = SidekiqUniqueJobs::LockDigest.call(item)
end
def add_lock_prefix(item)
item[LOCK_PREFIX] = SidekiqUniqueJobs.config.unique_prefix
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems