class Rufus::Scheduler::CronLine


(man 5 crontab) file line.
A ‘cron line’ is a line in the sense of a crontab

def date_match?(date)

def date_match?(date)
  return false unless sub_match?(date, :day, @days)
  return false unless sub_match?(date, :month, @months)
  return false unless sub_match?(date, :wday, @weekdays)
  return false unless monthday_match?(date, @monthdays)
  true
end

def frequency


schedule described by this cronline.
Returns the shortest delta between two potential occurences of the
def frequency
  delta = 366 * DAY_S
  t0 = previous_time(Time.local(2000, 1, 1))
  loop do
    break if delta <= 1
    break if delta <= 60 && @seconds && @seconds.size == 1
    t1 = next_time(t0)
    d = t1 - t0
    delta = d if d < delta
    break if @months == nil && t1.month == 2
    break if t1.year == 2001
    t0 = t1
  end
  delta
end

def initialize(line)

def initialize(line)
  raise ArgumentError.new(
    "not a string: #{line.inspect}"
  ) unless line.is_a?(String)
  @original = line
  items = line.split
  @timezone = (TZInfo::Timezone.get(items.last) rescue nil)
  items.pop if @timezone
  raise ArgumentError.new(
    "not a valid cronline : '#{line}'"
  ) unless items.length == 5 or items.length == 6
  offset = items.length - 5
  @seconds = offset == 1 ? parse_item(items[0], 0, 59) : [ 0 ]
  @minutes = parse_item(items[0 + offset], 0, 59)
  @hours = parse_item(items[1 + offset], 0, 24)
  @days = parse_item(items[2 + offset], 1, 31)
  @months = parse_item(items[3 + offset], 1, 12)
  @weekdays, @monthdays = parse_weekdays(items[4 + offset])
  [ @seconds, @minutes, @hours, @months ].each do |es|
    raise ArgumentError.new(
      "invalid cronline: '#{line}'"
    ) if es && es.find { |e| ! e.is_a?(Fixnum) }
  end
end

def matches?(time)


Returns true if the given time matches this cron line.
def matches?(time)
  time = Time.at(time) unless time.kind_of?(Time)
  time = @timezone.utc_to_local(time.getutc) if @timezone
  return false unless sub_match?(time, :sec, @seconds)
  return false unless sub_match?(time, :min, @minutes)
  return false unless sub_match?(time, :hour, @hours)
  return false unless date_match?(time)
  true
end

def monthday_match?(date, values)

def monthday_match?(date, values)
  return true if values.nil?
  today_values = monthdays(date)
  (today_values & values).any?
end

def monthdays(date)

def monthdays(date)
  pos = 1
  d = date.dup
  loop do
    d = d - WEEK_S
    break if d.month != date.month
    pos = pos + 1
  end
  neg = -1
  d = date.dup
  loop do
    d = d + WEEK_S
    break if d.month != date.month
    neg = neg - 1
  end
  [ "#{WEEKDAYS[date.wday]}##{pos}", "#{WEEKDAYS[date.wday]}##{neg}" ]
end

def next_time(from=Time.now)


(Thanks to K Liu for the note and the examples)

#=> Fri Oct 24 02:30:00 -0500 2008
Time.utc(2008, 10, 24, 7, 29)).localtime
Rufus::CronLine.new('30 7 * * *').next_time(

#=> Fri Oct 24 07:30:00 UTC 2008
Time.utc(2008, 10, 24, 7, 29))
Rufus::CronLine.new('30 7 * * *').next_time(

#=> Fri Oct 24 07:30:00 -0500 2008
Time.mktime(2008, 10, 24, 7, 29))
Rufus::CronLine.new('30 7 * * *').next_time(

Time.now))
be passed if no start time is specified (search start time set to
the given start point Time (thus a result in the local time zone will
Note that the time instance returned will be in the same time zone that

for the 'search'. By default, it's Time.now
This method accepts an optional Time parameter. It's the starting point

(Well, I was wrong, takes 0.001 sec on 1.8.7 and 1.9.1)
This is raw, 3 secs to iterate over 1 year on my macbook :( brutal.

Returns the next time that this cron line is supposed to 'fire'
def next_time(from=Time.now)
  time = @timezone ? @timezone.utc_to_local(from.getutc) : from
  time = time.respond_to?(:round) ? time.round : time - time.usec * 1e-6
    # chop off subseconds (and yes, Ruby 1.8 doesn't have #round)
  time = time + 1
    # start at the next second
  loop do
    unless date_match?(time)
      time += (24 - time.hour) * 3600 - time.min * 60 - time.sec; next
    end
    unless sub_match?(time, :hour, @hours)
      time += (60 - time.min) * 60 - time.sec; next
    end
    unless sub_match?(time, :min, @minutes)
      time += 60 - time.sec; next
    end
    unless sub_match?(time, :sec, @seconds)
      time += 1; next
    end
    break
  end
  if @timezone
    time = @timezone.local_to_utc(time)
    time = time.getlocal unless from.utc?
  end
  time
end

def parse_item(item, min, max)

def parse_item(item, min, max)
  return nil if item == '*'
  r = item.split(',').map { |i| parse_range(i.strip, min, max) }.flatten
  raise ArgumentError.new(
    "found duplicates in #{item.inspect}"
  ) if r.uniq.size < r.size
  r
end

def parse_range(item, min, max)

def parse_range(item, min, max)
  return %w[ L ] if item == 'L'
  item = '*' + item if item.match(/^\//)
  m = item.match(RANGE_REGEX)
  raise ArgumentError.new(
    "cannot parse #{item.inspect}"
  ) unless m
  sta = m[1]
  sta = sta == '*' ? min : sta.to_i
  edn = m[2]
  edn = edn ? edn.to_i : sta
  edn = max if m[1] == '*'
  inc = m[3]
  inc = inc ? inc.to_i : 1
  raise ArgumentError.new(
    "#{item.inspect} is not in range #{min}..#{max}"
  ) if sta < min || edn > max
  r = []
  val = sta
  loop do
    v = val
    v = 0 if max == 24 && v == 24
    r << v
    break if inc == 1 && val == edn
    val += inc
    break if inc > 1 && val > edn
    val = min if val > max
  end
  r.uniq
end

def parse_weekdays(item)

def parse_weekdays(item)
  return nil if item == '*'
  items = item.downcase.split(',')
  weekdays = nil
  monthdays = nil
  items.each do |it|
    if m = it.match(/^(.+)#(l|-?[12345])$/)
      raise ArgumentError.new(
        "ranges are not supported for monthdays (#{it})"
      ) if m[1].index('-')
      expr = it.gsub(/#l/, '#-1')
      (monthdays ||= []) << expr
    else
      expr = it.dup
      WEEKDAYS.each_with_index { |a, i| expr.gsub!(/#{a}/, i.to_s) }
      raise ArgumentError.new(
        "invalid weekday expression (#{it})"
      ) if expr !~ /^0*[0-7](-0*[0-7])?$/
      its = expr.index('-') ? parse_range(expr, 0, 7) : [ Integer(expr) ]
      its = its.collect { |i| i == 7 ? 0 : i }
      (weekdays ||= []).concat(its)
    end
  end
  weekdays = weekdays.uniq if weekdays
  [ weekdays, monthdays ]
end

def previous_time(from=Time.now)


for the past.
Returns the previous the cronline matched. It's like next_time, but
def previous_time(from=Time.now)
  # looks back by slices of two hours,
  #
  # finds for '* * * * sun', '* * 13 * *' and '0 12 13 * *'
  # starting 1970, 1, 1 in 1.8 to 2 seconds (says Rspec)
  start = current = from - 2 * 3600
  result = nil
  loop do
    nex = next_time(current)
    return (result ? result : previous_time(start)) if nex > from
    result = current = nex
  end
  # never reached
end

def sub_match?(time, accessor, values)

def sub_match?(time, accessor, values)
  value = time.send(accessor)
  return true if values.nil?
  return true if values.include?('L') && (time + DAY_S).day == 1
  return true if value == 0 && accessor == :hour && values.include?(24)
  values.include?(value)
end

def to_array


This method is used by the cronline unit tests.
months, weekdays).
Returns an array of 6 arrays (seconds, minutes, hours, days,
def to_array
  [
    @seconds,
    @minutes,
    @hours,
    @days,
    @months,
    @weekdays,
    @monthdays,
    @timezone ? @timezone.name : nil
  ]
end