Contents

# frozen_string_literal: true

require "singleton"

module CronKubernetes
  # A singleton that creates and holds the scheduled commands.
  class Scheduler
    include Singleton
    attr_reader :schedule

    def initialize
      @schedule   = []
      @identifier = CronKubernetes.identifier
    end

    def rake(task, schedule:, name: nil)
      rake_command = "bundle exec rake #{task} --silent"
      rake_command = "RAILS_ENV=#{rails_env} #{rake_command}" if rails_env
      @schedule << new_cron_job(schedule, rake_command, name)
    end

    def runner(ruby_command, schedule:, name: nil)
      env = nil
      env = "-e #{rails_env} " if rails_env
      runner_command = "bin/rails runner #{env}'#{ruby_command}'"
      @schedule << new_cron_job(schedule, runner_command, name)
    end

    def command(command, schedule:, name: nil)
      @schedule << new_cron_job(schedule, command, name)
    end

    private

    def make_command(command)
      CronKubernetes.job_template.map do |arg|
        if arg == ":job"
          "cd #{root} && #{command} #{CronKubernetes.output}"
        else
          arg
        end
      end
    end

    def new_cron_job(schedule, command, name)
      CronJob.new(
        schedule:     schedule,
        command:      make_command(command),
        job_manifest: CronKubernetes.manifest,
        name:         name,
        identifier:   @identifier
      )
    end

    def rails_env
      ENV["RAILS_ENV"]
    end

    def root
      return Rails.root if defined? Rails

      Dir.pwd
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
cron-kubernetes-2.0.0	lib/cron_kubernetes/scheduler.rb