Contents

class ScheduledTask < ActiveRecord::Base
  module Status
    def status
      return STATUS_DISABLED unless enabled?
      return STATUS_RUNNING if running?
      return STATUS_WAITING if waiting?
      last_fail_status.present? ? last_fail_status : STATUS_FAILED
    end

    def failed?
      [STATUS_FAILED, STATUS_ABORTED, STATUS_TIMEOUT].include?(status)
    end

    def running?
      last_run_start.present?
    end

    def waiting?
      return true if ended?(last_run_successful_end, last_run_unsuccessful_end)
      status_attributes.all? { |a| send(a).blank? }
    end

    private

    def ended?(time, oposite_time)
      !running? && time.present? && (oposite_time.blank? || oposite_time < time)
    end

    def status_on_start
      update_attributes!(last_run_start: Time.zone.now)
    end

    def status_on_end(exception, last_fail_status)
      update_attributes!(
        next_run: calculate_next_run,
        (exception ? :last_run_unsuccessful_start : :last_run_successful_start) => last_run_start,
        (exception ? :last_run_unsuccessful_end : :last_run_successful_end) => Time.zone.now,
        last_run_start: nil,
        pid: nil,
        last_fail_status: exception ? last_fail_status : nil
      )
    end

    def status_attributes
      %w(start successful_start successful_end unsuccessful_start unsuccessful_end).map do |a|
        "last_run_#{a}"
      end
    end

    def status_attributes_values
      status_attributes.map { |a| "#{a}: #{send(a)}" }.join(', ')
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
tasks_scheduler-0.3.0	app/models/scheduled_task/status.rb
tasks_scheduler-0.2.3	app/models/scheduled_task/status.rb
tasks_scheduler-0.2.2	app/models/scheduled_task/status.rb
tasks_scheduler-0.2.1	app/models/scheduled_task/status.rb
tasks_scheduler-0.2.0	app/models/scheduled_task/status.rb