Module: Afterparty

Defined in:
lib/afterparty.rb,
lib/afterparty/jobs.rb,
lib/afterparty/queue.rb,
lib/afterparty/engine.rb,
lib/afterparty/worker.rb,
lib/afterparty/version.rb,
lib/afterparty/job_container.rb,
lib/afterparty/queue_helpers.rb,
app/controllers/afterparty/dashboard_controller.rb

Defined Under Namespace

Modules: JobDescribers, QueueHelpers Classes: BasicJob, DashboardController, Engine, JobContainer, MailerJob, Queue, Worker

Constant Summary collapse

VERSION = 
"0.2.0"

Class Method Summary collapse

Class Method Details

.job_valid?(job) ⇒ Boolean

returns true if job has an :execute_at value

Returns:

  • (Boolean) 


15
16
17
 
# File 'lib/afterparty.rb', line 15

def self.job_valid? job
  job.respond_to?(:execute_at) && !job.execute_at.nil?
end

.load(raw) ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/afterparty.rb', line 19

def self.load(raw)
  begin
    begin
      return YAML.load(raw)
    rescue ArgumentError => e
      # lots of yaml load errors are because something that hasn't been
      # required. recursively require on these errors
      # Invoke the autoloader and try again if object's class is undefined
      if e.message =~ /undefined class\/module (.*)$/
        $1.constantize rescue return nil
      end
      return load(raw)
    end
  rescue Exception => e
    return nil
  end
end

.queue_time(job) ⇒ Object

return timestamp of :execute_at or current time



10
11
12
 
# File 'lib/afterparty.rb', line 10

def self.queue_time job
  time = job_valid?(job) ? job.execute_at : DateTime.now
end