Contents

require 'cronjobs/dsl/actions'
require 'cronjobs/proxy'
require 'cronjobs/railtie'
require 'open3'

module Cronjobs
  class << self

    attr_accessor :env, :mailto, :output

    def define(&block)
      Proxy.new(&block)
    end

    def add(time, actions)
      registry << [time, actions]
    end

    def check
      if current_digest != last_digest
        write
      end
    end

    def write
      Open3.popen2(command) do |stdin, stdout, wait_thr|
        if mailto.present?
          stdin << "MAILTO=#{mailto}\n"
        end
        registry.each do |time, actions|
          actions.each do |action|
            stdin << "#{time} "
            if env.present?
              stdin << "#{env} "
            end
            stdin << "bash -lc \"cd #{Rails.root} && #{action} "
            if output.present?
              stdin << ">> #{output} 2>> #{output}"
            else
              stdin << "2>&1"
            end
            stdin << "\"\n"
          end
        end
        stdin.close
        if wait_thr.value.success?
          FileUtils.mkdir_p digest_path.dirname
          File.write digest_path, current_digest
          puts 'Crontab updated'
        else
          warn "Couldn't write crontab"
        end
      end
    end

    private

    def registry
      @registry ||= []
    end

    def command
      'contrab -'
    end

    def definitions_path
      Rails.root.join 'config/cronjobs.rb'
    end

    def digest_path
      Rails.root.join 'tmp/digests/cronjobs'
    end

    def current_digest
      Digest::MD5.file(definitions_path).hexdigest rescue nil
    end

    def last_digest
      File.read digest_path rescue nil
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
cronjobs-0.1.0	lib/cronjobs.rb
cronjobs-0.0.1	lib/cronjobs.rb