added core scripts

Author: uu59

Gemfile.lock

@@ -0,0 +1,39 @@
+GEM
+  remote: http://rubygems.org/
+  specs:
+    diff-lcs (1.1.2)
+    git (1.2.5)
+    jeweler (1.5.2)
+      bundler (~> 1.0.0)
+      git (>= 1.2.5)
+      rake
+    rake (0.8.7)
+    rcov (0.9.9)
+    reek (1.2.8)
+      ruby2ruby (~> 1.2)
+      ruby_parser (~> 2.0)
+      sexp_processor (~> 3.0)
+    rspec (2.1.0)
+      rspec-core (~> 2.1.0)
+      rspec-expectations (~> 2.1.0)
+      rspec-mocks (~> 2.1.0)
+    rspec-core (2.1.0)
+    rspec-expectations (2.1.0)
+      diff-lcs (~> 1.1.2)
+    rspec-mocks (2.1.0)
+    ruby2ruby (1.2.5)
+      ruby_parser (~> 2.0)
+      sexp_processor (~> 3.0)
+    ruby_parser (2.0.5)
+      sexp_processor (~> 3.0)
+    sexp_processor (3.0.5)
+
+PLATFORMS
+  ruby
+
+DEPENDENCIES
+  bundler (~> 1.0.0)
+  jeweler (~> 1.5.1)
+  rcov
+  reek (~> 1.2.8)
+  rspec (~> 2.1.0)

Rakefile

@@ -12,8 +12,8 @@ require 'rake'
 require 'jeweler'
 Jeweler::Tasks.new do |gem|
   # gem is a Gem::Specification... see http://docs.rubygems.org/read/chapter/20 for more options
-  gem.name = "crontab-ruby"
-  gem.homepage = "https://github.com/tt25/crontab-ruby"
+  gem.name = "crontab-parser"
+  gem.homepage = "https://github.com/tt25/crontab-parser"
   gem.license = "MIT"
   gem.summary = %Q{TODO: one-line summary of your gem}
   gem.description = %Q{TODO: longer description of your gem}
@@ -51,7 +51,7 @@ Rake::RDocTask.new do |rdoc|
   version = File.exist?('VERSION') ? File.read('VERSION') : ""
 
   rdoc.rdoc_dir = 'rdoc'
-  rdoc.title = "crontab-ruby #{version}"
+  rdoc.title = "crontab-parser#{version}"
   rdoc.rdoc_files.include('README*')
   rdoc.rdoc_files.include('lib/**/*.rb')
 end

benchmark/test.rb

@@ -0,0 +1,57 @@
+# -- coding: utf-8
+
+require File.expand_path(File.dirname(__FILE__) + '/../spec/spec_helper')
+require "benchmark"
+require "ruby-prof"
+
+crontab = <<-CRON
+  # should ignore comment only line and blank line
+
+  #m h d m w cmd
+   * * * * * foo # always run. this comment was ignored
+   3 * * * * bar
+   */1 0-22 * * * baz
+CRON
+crontab *= 64
+range = {
+  0 => 0..59,
+  1 => 0..23,
+  2 => 1..31,
+  3 => 1..12,
+  4 => 0..6,
+}
+
+5000.times{
+  line = ""
+  5.times {|n|
+    ra = range[n].to_a.shuffle
+    line << case rand(10)
+      when 0..7
+        ra.first.to_s
+      when 8
+        x,y = [ra.first, ra.last].sort
+        "#{x}-#{y}"
+      else
+        ra.take(rand(ra.length - 1) + 1).sort.join(",")
+    end
+    if rand(2) == 1
+      line << "/" + (rand(range[n].last) + 1).to_s
+    end
+    line << " "
+  }
+  line << "cmd" + Time.now.to_f.to_s
+  line << "\n"
+  crontab += line
+}
+crontab += "k k k k k"
+File.open('foo.txt', 'w'){|f| f.puts crontab}
+
+now = Time.utc(2010,1,1,0,0,0)
+c = CrontabParser.new("foo.txt")
+
+GC.disable
+RubyProf.start
+puts c.find_all{|row| row.times}.length
+result = RubyProf.stop
+GC.enable
+RubyProf::FlatPrinter.new(result).print

crontab-parser.gemspec

@@ -0,0 +1,69 @@
+# Generated by jeweler
+# DO NOT EDIT THIS FILE DIRECTLY
+# Instead, edit Jeweler::Tasks in Rakefile, and run 'rake gemspec'
+# -*- encoding: utf-8 -*-
+
+Gem::Specification.new do |s|
+  s.name = %q{crontab-parser}
+  s.version = "0.1.0"
+
+  s.required_rubygems_version = Gem::Requirement.new(">= 0") if s.respond_to? :required_rubygems_version=
+  s.authors = ["uu59"]
+  s.date = %q{2011-01-08}
+  s.description = %q{crontab parser for ruby}
+  s.email = %q{a@tt25.org}
+  s.extra_rdoc_files = [
+    "LICENSE.txt",
+    "README.rdoc"
+  ]
+  s.files = [
+    ".document",
+    ".rspec",
+    "Gemfile",
+    "LICENSE.txt",
+    "README.rdoc",
+    "Rakefile",
+    "VERSION",
+    "benchmark/test.rb",
+    "lib/crontab-parser.rb",
+    "lib/crontab-parser/record.rb",
+    "lib/crontab-parser/time_parser.rb",
+    "spec/crontab-ruby_spec.rb",
+    "spec/spec_helper.rb"
+  ]
+  s.homepage = %q{https://github.com/tt25/crontab-parser}
+  s.licenses = ["MIT"]
+  s.require_paths = ["lib"]
+  s.rubygems_version = %q{1.3.7}
+  s.summary = %q{crontab parser for ruby}
+  s.test_files = [
+    "spec/crontab-ruby_spec.rb",
+    "spec/spec_helper.rb"
+  ]
+
+  if s.respond_to? :specification_version then
+    current_version = Gem::Specification::CURRENT_SPECIFICATION_VERSION
+    s.specification_version = 3
+
+    if Gem::Version.new(Gem::VERSION) >= Gem::Version.new('1.2.0') then
+      s.add_development_dependency(%q<rspec>, ["~> 2.1.0"])
+      s.add_development_dependency(%q<bundler>, ["~> 1.0.0"])
+      s.add_development_dependency(%q<jeweler>, ["~> 1.5.1"])
+      s.add_development_dependency(%q<rcov>, [">= 0"])
+      s.add_development_dependency(%q<reek>, ["~> 1.2.8"])
+    else
+      s.add_dependency(%q<rspec>, ["~> 2.1.0"])
+      s.add_dependency(%q<bundler>, ["~> 1.0.0"])
+      s.add_dependency(%q<jeweler>, ["~> 1.5.1"])
+      s.add_dependency(%q<rcov>, [">= 0"])
+      s.add_dependency(%q<reek>, ["~> 1.2.8"])
+    end
+  else
+    s.add_dependency(%q<rspec>, ["~> 2.1.0"])
+    s.add_dependency(%q<bundler>, ["~> 1.0.0"])
+    s.add_dependency(%q<jeweler>, ["~> 1.5.1"])
+    s.add_dependency(%q<rcov>, [">= 0"])
+    s.add_dependency(%q<reek>, ["~> 1.2.8"])
+  end
+end
+

lib/crontab-parser.rb

@@ -0,0 +1,29 @@
+# -- coding: utf-8
+
+require "stringio"
+require "crontab-parser/record.rb"
+require "crontab-parser/time_parser.rb"
+
+class CrontabParser
+  include Enumerable
+
+  def initialize(crontab, options={})
+    @crontab = crontab
+    @options = options
+  end
+
+  def each
+    io = if File.exists?(@crontab)
+      open(@crontab, 'r')
+    else
+      StringIO.new(@crontab)
+    end
+    until io.eof?
+      line = io.gets
+      line.strip!
+      if line.length > 0 && line.index('#') != 0
+        yield Record.new(line, @options) 
+      end
+    end
+  end
+end

lib/crontab-parser/record.rb

@@ -0,0 +1,65 @@
+# -- coding: utf-8
+
+class CrontabParser
+  class Record
+    attr_reader :line
+
+    def initialize(line, options={})
+      @line = line
+      @options = options
+    end
+
+    def cmd
+      times
+      @cmd
+    end
+
+    def to_s
+      @line
+    end
+
+    def should_run?(time)
+      time.utc
+      times[:min].include?(time.min) &&
+        times[:hour].include?(time.hour) &&
+        times[:day].include?(time.day) &&
+        times[:month].include?(time.month) &&
+        times[:week].include?(time.wday)
+    end
+
+    def times
+      @times ||= begin
+        base = @line.strip.gsub(/#.*/, "").gsub(%r!^@(yearly|annually|monthly|weekly|daily|midnight|hourly)!){|m|
+          case $1
+            when 'yearly','annually'
+              '0 0 1 1 *'
+            when 'monthly'
+              '0 0 1 * *'
+            when 'weekly'
+              '0 0 * * 0'
+            when 'daily','midnight'
+              '0 0 * * *'
+            when 'hourly'
+              '0 * * * *'
+          end
+        }.strip
+        min,hour,day,month,week,@cmd = *base.split(/[\t\s]+/, 6)
+        base = [min,hour,day,month,week].join(" ")
+        if week.nil?
+          if @options[:silent]
+            return nil
+          else
+            raise "invalid line #{@line}" 
+          end
+        end
+        {
+          :month => TimeParser.parse(month, 1, 12),
+          :day => TimeParser.parse(day, 1, 31),
+          :hour =>  TimeParser.parse(hour, 0, 23),
+          :min => TimeParser.parse(min, 0, 59),
+          :week => TimeParser.parse(week, 0, 6),
+        }
+      end
+    end
+  end
+end

lib/crontab-parser/time_parser.rb

@@ -0,0 +1,42 @@
+# -- coding: utf-8
+
+class CrontabParser
+  class TimeParser
+    CACHE = {}
+
+    def self.parse(column, first=0, last=59)
+      base = column + "_#{first}-#{last}"
+      if CACHE[base]
+        return CACHE[base]
+      end
+      column = column.gsub(%r!/1$!,"").gsub('*', "#{first}-#{last}")
+      if column.index('/')
+        times,filter = *column.split("/")
+      else
+        times = column
+        filter = nil
+      end
+
+      result = if times.index(',')
+        times.split(',').map{|col| separetor(col)}
+      else
+        separetor(times)
+      end.flatten
+
+      if filter
+        result = result.find_all{|n| n % filter.to_i == 0}
+      end
+
+      CACHE[base] = result
+    end
+
+    def self.separetor(col)
+      if col.index('-')
+        m,n = *col.split("-").map{|n| n.to_i}
+        (m..n).to_a
+      else
+        [col.to_i]
+      end
+    end
+  end
+end