Module: Xeno::Schedules

Defined in:
lib/xeno/schedules.rb

Overview

Compiles agent/schedules/*.md into Solid Queue recurring entries — compile-to-the-queue's-native-scheduler, not a dispatcher. No polling dispatcher: the queue's own recurring machinery fires ScheduleJob.

Only keys under the managed prefix are touched; hand-written recurring entries survive a sync. Dev servers never fire user schedules on cadence — those are written for every environment section EXCEPT development, where the dispatch endpoint triggers by name. The REAPER entry is different: it's runtime infrastructure (turns with no live owner), so it goes into every section including development.

Constant Summary collapse

MANAGED_PREFIX = 
"xeno_".freeze
REAPER_KEY = 
"#{MANAGED_PREFIX}runtime_reaper".freeze

Class Method Summary collapse

Class Method Details

.reaper_entry ⇒ Object 



45
46
47
 
# File 'lib/xeno/schedules.rb', line 45

def reaper_entry
  { "class" => "Xeno::ReaperJob", "schedule" => "every minute" }
end

.sync!(definition: Xeno.definition, path: Rails.root.join("config", "recurring.yml")) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/xeno/schedules.rb', line 20

def sync!(definition: Xeno.definition, path: Rails.root.join("config", "recurring.yml"))
  existing = File.exist?(path) ? (YAML.safe_load_file(path) || {}) : {}
  environments = (existing.keys.presence || %w[production]) | %w[development]

  environments.each do |env|
    section = (existing[env] ||= {})
    section.delete_if { |key, _| key.start_with?(MANAGED_PREFIX) }

    unless env == "development"
      definition.schedules.each do |name, schedule|
        section["#{MANAGED_PREFIX}#{name}"] = {
          "class" => "Xeno::ScheduleJob",
          "args" => [ name ],
          "schedule" => schedule.cron
        }
      end
    end

    section[REAPER_KEY] = reaper_entry
  end

  File.write(path, YAML.dump(existing))
  existing
end