Contents

# frozen_string_literal: true

module ElasticAPM
  # @api private
  module Spies
    # @api private
    class DelayedJobSpy
      CLASS_SEPARATOR = '.'.freeze
      METHOD_SEPARATOR = '#'.freeze
      TYPE = 'Delayed::Job'.freeze

      def install
        ::Delayed::Backend::Base.class_eval do
          alias invoke_job_without_apm invoke_job

          def invoke_job(*args, &block)
            ::ElasticAPM::Spies::DelayedJobSpy
              .invoke_job(self, *args, &block)
          end
        end
      end

      def self.invoke_job(job, *args, &block)
        job_name = name_from_payload(job.payload_object)
        transaction = ElasticAPM.transaction(job_name, TYPE)
        job.invoke_job_without_apm(*args, &block)
        transaction.submit 'success'
      rescue ::Exception => e
        ElasticAPM.report(e, handled: false)
        transaction.submit 'error'
        raise
      ensure
        transaction.release if transaction
      end

      def self.name_from_payload(payload_object)
        if payload_object.is_a?(::Delayed::PerformableMethod)
          performable_method_name(payload_object)
        else
          payload_object.class.name
        end
      end

      def self.performable_method_name(payload_object)
        class_name = object_name(payload_object)
        separator = name_separator(payload_object)
        method_name = payload_object.method_name
        "#{class_name}#{separator}#{method_name}"
      end

      def self.object_name(payload_object)
        object = payload_object.object
        klass = object.is_a?(Class) ? object : object.class
        klass.name
      end

      def self.name_separator(payload_object)
        payload_object.object.is_a?(Class) ? CLASS_SEPARATOR : METHOD_SEPARATOR
      end
    end

    register(
      'Delayed::Backend::Base',
      'delayed/backend/base',
      DelayedJobSpy.new
    )
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
elastic-apm-1.1.0	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-1.0.2	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-1.0.1	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-1.0.0	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-1.0.0.beta2	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-1.0.0.beta1	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-0.8.0	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-0.7.4	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-0.7.3	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-0.7.2	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-0.7.1	lib/elastic_apm/spies/delayed_job.rb
elastic-apm-0.7.0	lib/elastic_apm/spies/delayed_job.rb