Contents

module Lev
  module ActiveJob
    class Base < Lev.configuration.job_class
      attr_accessor(:provider_job_id) unless respond_to?(:provider_job_id)

      def perform_later(routine_class, options, *args, **kwargs, &block)
        # Create a new status object
        status = routine_class.create_status

        # Push the routine class name on to the arguments
        # so that we can run the correct routine in `perform`
        args.push(routine_class.to_s)

        # Push the status's ID on to the arguments so that in `perform`
        # it can be used to retrieve the status when the routine is initialized
        args.push(status.id)

        # Set the job_name
        status.set_job_name(routine_class.name)

        # In theory we'd mark as queued right after the call to super, but this messes
        # up when the activejob adapter runs the job right away (inline mode)
        status.queued!

        # Queue up the job and set the provider_job_id
        # For delayed_job, requires either Rails 5 or
        # http://stackoverflow.com/questions/29855768/rails-4-2-get-delayed-job-id-from-active-job
        provider_job_id = self.class.send(:job_or_instantiate, *args, **kwargs, &block)
                                    .enqueue(options)
                                    .provider_job_id
        status.set_provider_job_id(provider_job_id) \
          if provider_job_id.present? && status.respond_to?(:set_provider_job_id)

        # Return the id of the status object
        status.id
      end

      def perform(*args, **kwargs, &block)
        # Pop arguments added by perform_later
        id = args.pop
        routine_class = Kernel.const_get(args.pop)

        routine_instance = routine_class.new(routine_class.find_status(id))

        routine_instance.call(*args, **kwargs, &block)
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
lev-13.0.0	lib/lev/active_job/base.rb
lev-12.1.0	lib/lev/active_job/base.rb