Contents

# frozen_string_literal: true

module  JuanPelota
module  Middlewares
class   Logging
  # rubocop:disable Lint/RescueException, Metrics/AbcSize, Metrics/MethodLength
  def call(worker, job, _queue)
    start = Time.now

    unless config.filtered_workers.include? worker.class.name
      logger.info(
        'status'   => 'start',
        'jid'      => job['jid'],
        'bid'      => job['bid'],
        'run_time' => nil,
        'class'    => worker.class.to_s,
        'args'     => filtered_arguments(job['args'].try(:first)),
      )
    end

    yield

    unless config.filtered_workers.include? worker.class.name
      logger.info(
        'status'   => 'done',
        'jid'      => job['jid'],
        'bid'      => job['bid'],
        'run_time' => elapsed(start),
        'class'    => worker.class.to_s,
        'args'     => filtered_arguments(job['args'].try(:first)),
      )
    end
  rescue Exception => e
    message = {
      'error_class'     => e.class.name,
      'error_message'   => e.message,
      'error_backtrace' => e.backtrace.first(10),
    }

    logger.info(
      'status'   => 'fail',
      'jid'      => job['jid'],
      'bid'      => job['bid'],
      'run_time' => elapsed(start),
      'class'    => worker.class.to_s,
      'message'  => message,
      'args'     => filtered_arguments(job['args'].try(:first)),
    )

    raise e
  end
  # rubocop:enable Lint/RescueException, Metrics/AbcSize, Metrics/MethodLength

  def elapsed(start)
    (Time.now - start).to_f.round(3)
  end

  def logger
    ::Sidekiq.logger
  end

  def filtered_arguments(args)
    return if args.nil?

    @filtered_arguments ||= args.each_with_object({}) do |(key, value), filtered_hash|
      value               = filtered_arguments(value) if value.is_a? Hash

      filtered_hash[key] = value unless config.filtered_arguments.include? key
    end
  end

  private

  def config
    Configuration.instance
  end
end
end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
juan_pelota-2.1.0	lib/juan_pelota/middlewares/logging.rb
juan_pelota-2.0.1	lib/juan_pelota/middlewares/logging.rb