Contents

module Clockwork
  class Event
    attr_accessor :job, :last

    def initialize(manager, period, job, block, options={})
      validate_if_option(options[:if])
      @manager = manager
      @period = period
      @job = job
      @at = At.parse(options[:at])
      @last = nil
      @block = block
      @if = options[:if]
      @thread = options.fetch(:thread, @manager.config[:thread])
      @timezone = options.fetch(:tz, @manager.config[:tz])
    end

    def convert_timezone(t)
      @timezone ? t.in_time_zone(@timezone) : t
    end

    def run_now?(t)
      t = convert_timezone(t)
      elapsed_ready(t) and (@at.nil? or @at.ready?(t)) and (@if.nil? or @if.call(t))
    end

    def thread?
      @thread
    end

    def run(t)
      @manager.log "Triggering '#{self}'"
      @last = convert_timezone(t)
      if thread?
        if @manager.thread_available?
          t = Thread.new do
            execute
          end
          t['creator'] = @manager
        else
          @manager.log_error "Threads exhausted; skipping #{self}"
        end
      else
        execute
      end
    end

    def to_s
      job.to_s
    end

    private
    def execute
      @block.call(@job, @last)
    rescue => e
      @manager.log_error e
      @manager.handle_error e
    end

    def elapsed_ready(t)
      @last.nil? || (t - @last.to_i).to_i >= @period
    end

    def validate_if_option(if_option)
      if if_option && !if_option.respond_to?(:call)
        raise ArgumentError.new(':if expects a callable object, but #{if_option} does not respond to call')
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
clockwork-2.0.2	lib/clockwork/event.rb
clockwork-2.0.1	lib/clockwork/event.rb
clockwork-1.3.1	lib/clockwork/event.rb
clockwork-1.3.0	lib/clockwork/event.rb
clockwork-1.2.1	lib/clockwork/event.rb
clockwork-2.0.0	lib/clockwork/event.rb
clockwork-1.2.0	lib/clockwork/event.rb
clockwork-1.1.0	lib/clockwork/event.rb