# frozen_string_literal: true

require 'rush'

module Delayed
  module Workless
    module Scaler
      class Local < Base
        def self.executable_prefix
          if defined? Delayed::Compatibility.executable_prefix
            Delayed::Compatibility.executable_prefix
          else
            'script'
          end
        end

        def self.up
          if workers == 0
            Rush::Box.new[Rails.root].bash("#{executable_prefix}/delayed_job start -i workless", background: true)
            sleep 1
          end
          true
        end

        def self.down
          if workers > 0 && jobs.count == 0
            Rush::Box.new[Rails.root].bash("#{executable_prefix}/delayed_job stop -i workless", background: true)
          end
          true
        end

        def self.workers
          Rush::Box.new.processes.filter(cmdline: /delayed_job start -i workless|delayed_job.workless/).size
        end
      end
    end
  end
end