Module: ThecoreBackgroundJobs

Defined in:
lib/thecore_background_jobs.rb,
lib/thecore_background_jobs/engine.rb,
lib/thecore_background_jobs/version.rb

Defined Under Namespace

Classes: Engine

Constant Summary collapse

VERSION = 
"#{`git describe --tags $(git rev-list --tags --max-count=1)`.chomp}"

Class Method Summary collapse

Class Method Details

.email_setup ⇒ Object

Your code goes here…



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

def self.email_setup
  delivery_options = { domain: Settings.ns(:smtp).domain, address: Settings.ns(:smtp).address, port: Settings.ns(:smtp).port.to_i, enable_starttls_auto: (Settings.ns(:smtp).enable_starttls_auto == "true")}
  # Other Options
  delivery_options.merge!({user_name: Settings.ns(:smtp).user_name}) unless Settings.ns(:smtp).user_name.blank?
  delivery_options.merge!({password: Settings.ns(:smtp).password}) unless Settings.ns(:smtp).password.blank?
  delivery_options.merge!({authentication: Settings.ns(:smtp).authentication}) unless Settings.ns(:smtp).authentication.blank? 
  delivery_options
end

.update_cron_schedules ⇒ Object 



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
51
52
53
54
55
56
57
58
59
 
# File 'lib/thecore_background_jobs.rb', line 19

def self.update_cron_schedules
  # {
  #  "AlertForLongTermStockJob"=>{"cron"=>"0 0 9 * * *", "queue"=>"notset_default", "description"=>"This job Alerts a reference email for items in stock for too long", "enabled"=>true, "class"=>"AlertForLongTermStockJob"}, 
  #  "ScheduleEmployeeReminderForInStockParcelsJob"=>{"cron"=>"0 0 8,14 * * *", "queue"=>"notset_default", "description"=>"This job checks periodically for new received parcels", "enabled"=>true, "class"=>"ScheduleEmployeeReminderForInStockParcelsJob"}
  # }
  begin
    Sidekiq.get_all_schedules.each_pair do |key, config|
      puts "Key: #{key}, Config: #{config}"
      schedule = "cron_for_#{key.underscore}"
      setting = ThecoreSettings::Setting.where(ns: "schedules", key: schedule).pluck(:raw).first
      puts "Setting is #{schedule} = #{setting}"
      # Installing initial sidekiq.yml configuration if setting is not present
      if setting.blank?
        puts "Setting #{schedule} doesn't exist, creating based on current value: #{config["cron"]}"
        ThecoreSettings::Setting.create(ns: "schedules", key: schedule, raw: config["cron"])
        # Settings.ns("schedules").send("#{schedule}=", config["cron"])
      elsif config["cron"].squeeze(" ").strip != setting.squeeze(" ").strip
        # If we have a setting and is different from the currently loaded, then replace it 
        # in scheduler configuration
        puts "Setting #{schedule} exists: #{setting}"
        Sidekiq.set_schedule(key.underscore, { cron: setting.squeeze(" ").strip, queue: "#{ENV["COMPOSE_PROJECT_NAME"]}_default", class: key })
        puts "Reloading schedules"
        SidekiqScheduler::Scheduler.instance.reload_schedule!
      end
    end 
  rescue => exception
    puts "Thecore Background Jobs: REDIS not reachable:"
    puts exception.message
  end
  # check_in_stock_parcels = ThecoreSettings::Setting.where(ns: "schedules", key: "cron_for_check_in_stock_parcels").pluck(:raw).first
  # unless check_in_stock_parcels.blank?
  #   begin
  #     puts "Setting the schedule during initialization"
  #     Sidekiq.set_schedule('check_in_stock_parcels', { cron: check_in_stock_parcels, queue: "#{ENV["COMPOSE_PROJECT_NAME"]}_default", class: 'ScheduleEmployeeReminderForInStockParcelsJob' })
  #     puts "Reloading schedules during initialization"
  #     SidekiqScheduler::Scheduler.instance.reload_schedule!
  #   rescue => exception
  #     puts exception.message
  #   end
  # end
end