Contents

module MissionControl::Jobs::JobsHelper
  def job_title(job)
    job.job_class_name
  end

  def job_arguments(job)
    renderable_job_arguments_for(job).join(", ")
  end

  def failed_job_error(job)
    "#{job.last_execution_error.error_class}: #{job.last_execution_error.message}"
  end

  def failed_job_backtrace(job)
    job.last_execution_error.backtrace.join("\n")
  end

  def attribute_names_for_job_status(status)
    case status.to_s
    when "failed"      then [ "Error", "" ]
    when "blocked"     then [ "Queue", "Blocked by", "Block expiry" ]
    when "finished"    then [ "Queue", "Finished" ]
    when "scheduled"   then [ "Queue", "Scheduled" ]
    when "in_progress" then [ "Queue", "Run by", "Running for" ]
    else               []
    end
  end

  private
    def renderable_job_arguments_for(job)
      job.serialized_arguments.collect do |argument|
        as_renderable_argument(argument)
      end
    end

    def as_renderable_argument(argument)
      case argument
      when Hash
        as_renderable_hash(argument)
      when Array
        as_renderable_array(argument)
      else
        ActiveJob::Arguments.deserialize([ argument ])
      end
    rescue ActiveJob::DeserializationError
      argument.to_s
    end

    def as_renderable_hash(argument)
      if argument["_aj_globalid"]
        # don't deserialize as the class might not exist in the host app running the engine
        argument["_aj_globalid"]
      elsif argument["_aj_serialized"] == "ActiveJob::Serializers::ModuleSerializer"
        argument["value"]
      else
        ActiveJob::Arguments.deserialize([ argument ])
      end
    end

    def as_renderable_array(argument)
      "(#{argument.collect { |part| as_renderable_argument(part) }.join(", ")})"
    end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
mission_control-jobs-0.1.1	app/helpers/mission_control/jobs/jobs_helper.rb
mission_control-jobs-0.1.0	app/helpers/mission_control/jobs/jobs_helper.rb