Class: Aidp::CLI::TemporalCommand

Inherits:
Object
  • Object
show all
Includes:
MessageDisplay
Defined in:
lib/aidp/cli/temporal_command.rb

Overview

CLI commands for Temporal workflow management Provides interface for starting, monitoring, and controlling workflows

Constant Summary

Constants included from MessageDisplay

MessageDisplay::COLOR_MAP, MessageDisplay::CRITICAL_TYPES

Instance Method Summary collapse

Methods included from MessageDisplay

#display_message, included, #message_display_prompt, #quiet_mode?

Constructor Details

#initialize(input: nil, output: nil, prompt: TTY::Prompt.new, project_dir: Dir.pwd) ⇒ TemporalCommand

Returns a new instance of TemporalCommand.



15
16
17
18
19
20
 
# File 'lib/aidp/cli/temporal_command.rb', line 15

def initialize(input: nil, output: nil, prompt: TTY::Prompt.new, project_dir: Dir.pwd)
  @io = TerminalIO.new(input: input, output: output)
  @prompt = prompt
  @pastel = Pastel.new
  @project_dir = project_dir
end

Instance Method Details

#run(subcommand = nil, args = []) ⇒ Object 



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
 
# File 'lib/aidp/cli/temporal_command.rb', line 22

def run(subcommand = nil, args = [])
  # Check if Temporal is configured
  unless temporal_enabled?
    display_message("Temporal is not enabled. Add 'temporal' section to aidp.yml", type: :warning)
    display_message("See: aidp temporal setup", type: :info)
    return
  end

  case subcommand
  when "start", nil
    start_workflow(args)
  when "list"
    list_workflows(args)
  when "status"
    workflow_status(args)
  when "signal"
    signal_workflow(args)
  when "cancel"
    cancel_workflow(args)
  when "worker"
    run_worker(args)
  when "setup"
    setup_temporal
  else
    display_message("Unknown temporal subcommand: #{subcommand}", type: :error)
    show_help
  end
end