Contents

require "montrose/errors"

module Montrose
  class Clock
    def initialize(opts = {})
      @options = Montrose::Options.merge(opts)
      @time = nil
      @every = @options.fetch(:every) { fail ConfigurationError, "Required option :every not provided" }
      @starts = @options.fetch(:starts)
      @interval = @options.fetch(:interval)
    end

    # Advances time to new unit by increment and sets
    # new time as "current" time for next tick
    #
    def tick
      @time = peek
    end

    def peek
      return @starts if @time.nil?

      @time.advance(step)
    end

    private

    def step
      @step ||= smallest_step or fail ConfigurationError, "No step for #{@options.inspect}"
    end

    def smallest_step
      unit_step(:minute) ||
        unit_step(:hour) ||
        unit_step(:day, :mday, :yday) ||
        unit_step(:week) ||
        unit_step(:month) ||
        unit_step(:year)
    end

    # @private
    #
    # Returns hash representing unit and amount to advance time
    # when options contain given unit as a key or as a value of
    # the key :every in options
    #
    # options = { every: :day, hour: 8.12 }
    # unit_step(:minute)
    # => nil
    # unit_step(:hour)
    # => { hour: 1 }
    #
    # options = { every: :hour, interval: 6 }
    # unit_step(:minute)
    # => nil
    # unit_step(:hour)
    # => { hour: 6 }
    #
    def unit_step(unit, *alternates)
      is_frequency = @every == unit
      if ([unit] + alternates).any? { |u| @options.key?(u) } && !is_frequency
        # smallest unit, increment by 1
        { step_key(unit) => 1 }
      elsif is_frequency
        { step_key(unit) => @interval }
      end
    end

    # @private
    #
    # Change 'unit' to :units
    #
    def step_key(unit)
      "#{unit}s".to_sym
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
montrose-0.2.2	lib/montrose/clock.rb
montrose-0.2.1	lib/montrose/clock.rb
montrose-0.2.0	lib/montrose/clock.rb