# File lib/whenever/job_list.rb, line 3 def initialize(options) @jobs, @env, @set_variables, @pre_set_variables = {}, {}, {}, {} if options.is_a? String options = { :string => options } end pre_set(options[:set]) setup = File.read("#{File.expand_path(File.dirname(__FILE__))}/setup.rb") schedule = if options[:string] options[:string] elsif options[:file] File.read(options[:file]) end instance_eval(setup + schedule, options[:file] || '<eval>') end
# File lib/whenever/job_list.rb, line 31 def env(variable, value) @env[variable.to_s] = value end
# File lib/whenever/job_list.rb, line 35 def every(frequency, options = {}) @current_time_scope = frequency @options = options yield end
# File lib/whenever/job_list.rb, line 58 def generate_cron_output [environment_variables, cron_jobs].compact.join end
# File lib/whenever/job_list.rb, line 41 def job_type(name, template) class_eval do define_method(name) do |task, *args| options = { :task => task, :template => template } options.merge!(args[0]) if args[0].is_a? Hash # :cron_log was an old option for output redirection, it remains for backwards compatibility options[:output] = (options[:cron_log] || @cron_log) if defined?(@cron_log) || options.has_key?(:cron_log) # :output is the newer, more flexible option. options[:output] = @output if defined?(@output) && !options.has_key?(:output) @jobs[@current_time_scope] ||= [] @jobs[@current_time_scope] << Whenever::Job.new(@options.merge(@set_variables).merge(options)) end end end
# File lib/whenever/job_list.rb, line 22 def set(variable, value) variable = variable.to_sym return if @pre_set_variables[variable] instance_variable_set("@#{variable}".to_sym, value) self.class.send(:attr_reader, variable.to_sym) @set_variables[variable] = value end