Module: Croner

Defined in:
lib/croner.rb,
lib/croner/railtie.rb,
lib/croner/version.rb

Defined Under Namespace

Classes: Railtie

Constant Summary collapse

VERSION = 
'0.1.2'

Class Method Summary collapse

Class Method Details

.run ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/croner.rb', line 6

def self.run
  return {status: false, message: "couldn't found cron setting file"} unless File.exist?(Rails.root.join('config', 'croner', 'hosts', `hostname`.delete("\n")))

  # get cron contents
  insert_rows = File.read(Rails.root.join('config', 'croner', 'hosts', `hostname`.delete("\n"))).split("\n")

  # backup current cron contents
  `crontab -l > cron_#{Time.current.strftime('%Y%m%d%H%M%S')}.bak`

  # get current cron contents
  cron_rows = `crontab -l`.split("\n")

  application_name = Rails.application.class.parent_name
  cron_start_row   = "# ==================== START #{application_name} CronJobs by Croner ===================="
  cron_end_row     = "# ====================  END  #{application_name} CronJobs by Croner ===================="

  start_index = cron_rows.index(cron_start_row)
  end_index   = cron_rows.index(cron_end_row)

  return ArgumentError.new('current cron contents has unvalid settings by Croner!') unless ((start_index.present? && end_index.present?) || (start_index.blank? && end_index.blank?))

  if start_index.present? && end_index.present?
    cron_rows.slice!((start_index + 1)..(end_index - 1))
  else
    start_index = cron_rows.count
    cron_rows << cron_start_row
    cron_rows << cron_end_row
  end

  cron_rows.insert(start_index + 1, *insert_rows)

  File.open("cron_tmp", "w") do |f| 
    cron_rows.each{|row| f.puts(row)}
  end

  stdout, stderror, status = Open3.capture3("crontab cron_tmp")

  File.delete("cron_tmp")

  if status.success?
    return {status: true}
  else
    return {status: false, message: stderror}
  end
end