Class: Rubino::CLI::JobsCommand

Inherits:
Thor
  • Object
show all
Defined in:
lib/rubino/cli/jobs_command.rb

Overview

Subcommands for managing the job queue

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.exit_on_failure? ⇒ Boolean

Returns:

  • (Boolean) 


12
13
14
 
# File 'lib/rubino/cli/jobs_command.rb', line 12

def self.exit_on_failure?
  true
end

.render_list(jobs, ui:) ⇒ Object

ONE jobs-table rendering for both surfaces (#187): this CLI verb and the in-chat /jobs list (Commands::Executor).



46
47
48
49
50
51
52
 
# File 'lib/rubino/cli/jobs_command.rb', line 46

def self.render_list(jobs, ui:)
  rows = jobs.map do |j|
    [j[:id][0..7], j[:type], j[:status], j[:attempts].to_s, j[:run_at]]
  end

  ui.table(headers: %w[ID Type Status Attempts RunAt], rows: rows)
end

Instance Method Details

#list ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/rubino/cli/jobs_command.rb', line 23

def list
  # A present-but-unusable DB (corrupt image, or the duplicate
  # `schema_info` rows a concurrent first-boot race leaves, #race) must
  # surface a clean error, not a raw `no such table: jobs` backtrace —
  # same guard the sessions/memory read CLIs use (#333/#race).
  if (message = Rubino.database_repair_message)
    raise Thor::Error, message
  end

  Rubino.ensure_database_ready!
  queue = Jobs::Queue.new
  jobs = queue.list(status: options[:status], limit: options[:limit])

  if jobs.empty?
    Rubino.ui.info("No jobs found.")
    return
  end

  self.class.render_list(jobs, ui: Rubino.ui)
end

#process ⇒ Object 



56
57
58
59
60
 
# File 'lib/rubino/cli/jobs_command.rb', line 56

def process
  runner = Jobs::Runner.new
  processed = runner.run_pending(limit: options[:limit])
  Rubino.ui.success("Processed #{processed} job(s)")
end

#worker ⇒ Object 



63
64
65
66
67
68
69
 
# File 'lib/rubino/cli/jobs_command.rb', line 63

def worker
  Rubino.ui.info("Starting job worker (poll every #{Rubino.configuration.jobs_poll_interval}s)...")
  Rubino.ui.info("Press Ctrl+C to stop.")

  worker = Jobs::Worker.new
  worker.start
end