Module: Arask

Defined in:
lib/arask.rb,
lib/arask/setup.rb,
lib/arask/railtie.rb,
lib/arask/version.rb,
lib/arask/run_jobs.rb,
lib/arask/arask_job.rb

Defined Under Namespace

Classes: AraskJob, InstallGenerator, Railtie, RunJobs, Setup

Constant Summary collapse

VERSION = 
'1.2.4'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.exception_block ⇒ Object

Returns the value of attribute exception_block.



8
9
10
 
# File 'lib/arask.rb', line 8

def exception_block
  @exception_block
end

.exception_email ⇒ Object

Returns the value of attribute exception_email.



8
9
10
 
# File 'lib/arask.rb', line 8

def exception_email
  @exception_email
end

.exception_email_from ⇒ Object

Returns the value of attribute exception_email_from.



8
9
10
 
# File 'lib/arask.rb', line 8

def exception_email_from
  @exception_email_from
end

.jobs_block ⇒ Object

Returns the value of attribute jobs_block.



8
9
10
 
# File 'lib/arask.rb', line 8

def jobs_block
  @jobs_block
end

.jobs_touched ⇒ Object

Returns the value of attribute jobs_touched.



8
9
10
 
# File 'lib/arask.rb', line 8

def jobs_touched
  @jobs_touched
end

Class Method Details

.init_jobs ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/arask.rb', line 18

def self.init_jobs
  Arask.jobs_touched = []
  Arask.jobs_block.call(Setup)
  Arask.jobs_block = nil
  begin
    AraskJob.all.where.not(id: Arask.jobs_touched).delete_all
    Arask.jobs_touched = nil
    Arask.queue_self
  rescue
  end
end

.queue_self ⇒ Object 



30
31
32
33
34
35
36
37
38
 
# File 'lib/arask.rb', line 30

def self.queue_self
  begin
    next_job_run = AraskJob.order(execute_at: :asc).first.try(:execute_at)
    # At least check database for jobs every day
    next_job_run = 1.day.from_now if next_job_run.nil? or (next_job_run - DateTime.now)/60/60 > 24
    RunJobs.set(wait_until: next_job_run).perform_later
  rescue
  end
end

.setup(force_run = false, &block) ⇒ Object 



10
11
12
13
14
15
16
 
# File 'lib/arask.rb', line 10

def self.setup(force_run = false, &block)
  Arask.jobs_block = block
  # Make sure we only run setup now if we are testing.
  # Else we would run them at every cli execution.
  # railtie.rb inits the jobs when the server is ready
  Arask.init_jobs if force_run
end