Sha256: 0a185e6b726a5323c8eaf6ec67ed27c1d6f749f705031a0390310aec4701e84c

Contents?: true

Size: 708 Bytes

Versions: 4

Compression:

Stored size: 708 Bytes

Contents

# frozen_string_literal: true

module Trifle
  module Logger
    module Middleware
      class Sidekiq
        def call(_worker, job, _queue)
          Trifle::Logger.tracer = tracer_for(job: job)
          yield
        rescue => e # rubocop:disable Style/RescueStandardError
          Trifle::Logger.tracer&.trace("Exception: #{e}", state: :error)
          Trifle::Logger.tracer&.fail!
          raise e
        ensure
          Trifle::Logger.tracer&.wrapup
        end

        def tracer_for(job:)
          return nil unless job['logger_key']

          Trifle::Logger.default.tracer_class.new(
            key: job['logger_key'], meta: job['args']
          )
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
trifle-logger-0.4.1 lib/trifle/logger/middleware/sidekiq.rb
trifle-logger-0.4.0 lib/trifle/logger/middleware/sidekiq.rb
trifle-logger-0.3.1 lib/trifle/logger/middleware/sidekiq.rb
trifle-logger-0.3.0 lib/trifle/logger/middleware/sidekiq.rb