Contents

require 'delayed_cron/jobs'
require 'delayed_cron/scheduling'
require 'delayed_cron/railtie'

module DelayedCron

  mattr_accessor :default_interval, :cron_jobs

  class << self

    include DelayedCron::Scheduling

    def setup
      yield self
      define_cron_jobs
    end

    def define_cron_jobs
      return false unless cron_jobs.present?
      cron_jobs.each do |job|
        obj         = job
        job_is_hash = job.is_a?(Hash)
        job         = job_is_hash ? obj[:job] : job
        interval    = job_is_hash ? obj[:interval] : default_interval
        options_at  = job_is_hash ? obj[:at] : nil
        klass, name = job.split(".")
        # TODO: raise error if interval is not set
        options     = timing_opts(interval, options_at)
        DelayedCron.schedule(klass, name, options)
      end
    end

    def processor
      return DelayedCron::Jobs::DelayedJob  if defined? ::Delayed::Job
      return DelayedCron::Jobs::Resque      if defined? ::Resque
      return DelayedCron::Jobs::Sidekiq     if defined? ::Sidekiq
      return DelayedCron::Jobs::SuckerPunch if defined? ::SuckerPunch
    end

    def process_job(klass, method_name, options)
      # TODO: add ability to send args to klass method
      klass.constantize.send(method_name)
      schedule(klass, method_name, options)
    end

  end

  module Glue
    def self.included(base)
      base.extend(ClassMethods)
    end
  end

  module ClassMethods

    def cron_job(name, options = { interval: DelayedCron.default_interval })
      return false if options.delete(:if) == false
      DelayedCron.schedule(self.name.to_s, name, options)
    end

  end

end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
delayed_cron-0.2.8	lib/delayed_cron.rb
delayed_cron-0.2.7	lib/delayed_cron.rb