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.



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

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 



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
50
51
52
53
54
55
 
# File 'lib/aidp/cli/temporal_command.rb', line 24

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 "replay"
    replay_workflow(args)
  when "benchmark"
    benchmark_workflows(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