Contents

module Ezlog
  module Sidekiq
    class JobContext
      class << self
        def from_job_hash(job_hash)
          return {} if job_hash.nil?
          thread_info.merge(basic_info_from(job_hash)).merge(named_arguments_from(job_hash))
        end

        private

        def thread_info
          { tid: Thread.current['sidekiq_tid'] || (Thread.current.object_id ^ ::Process.pid).to_s(36) }
        end


        def basic_info_from(job)
          h = {
            jid: job['jid'],
            queue: job['queue'],
            worker: job_class(job),
            created_at: job['created_at'],
            enqueued_at: job['enqueued_at'],
            run_count: (job['retry_count'] || -1) + 2
          }
          h[:bid] = job['bid'] if job['bid']
          h[:tags] = job['tags'] if job['tags']
          h
        end

        def named_arguments_from(job)
          {}.tap do |arguments|
            method_parameters_of(job).each_with_index do |(_, param_name), index|
              arguments[param_name] = job['args'][index]
            end
          end
        end

        def method_parameters_of(job)
          Kernel.const_get(job_class(job)).instance_method(:perform).parameters
        end

        def job_class(job)
          job['wrapped'] || job['class']
        end
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
ezlog-0.10.7	lib/ezlog/sidekiq/job_context.rb
ezlog-0.10.5	lib/ezlog/sidekiq/job_context.rb
ezlog-0.10.3	lib/ezlog/sidekiq/job_context.rb
ezlog-0.10.2	lib/ezlog/sidekiq/job_context.rb
ezlog-0.10.1	lib/ezlog/sidekiq/job_context.rb
ezlog-0.10.0	lib/ezlog/sidekiq/job_context.rb
ezlog-0.9.6	lib/ezlog/sidekiq/job_context.rb
ezlog-0.9.5	lib/ezlog/sidekiq/job_context.rb