improvements

Author: kevinelliott

README.md

@@ -8,6 +8,12 @@
 
 AgentPipe is a CLI and TUI application that orchestrates conversations between multiple AI agents. It allows different AI CLI tools (like Claude, Gemini, Qwen) to communicate with each other in a shared "room", creating dynamic multi-agent conversations.
 
+## Screenshots
+
+### Enhanced TUI Interface
+![AgentPipe TUI](screenshots/tui/tui1.png)
+*Enhanced TUI with multi-panel layout: agent list with status indicators, conversation view with metrics, statistics panel showing turns and total cost, configuration panel, and user input area*
+
 ## Features
 
 - **Multi-Agent Conversations**: Connect multiple AI agents in a single conversation
@@ -19,9 +25,13 @@ AgentPipe is a CLI and TUI application that orchestrates conversations between m
 - **Enhanced TUI Interface**: 
   - Beautiful panelized layout with agent list, conversation view, and user input
   - Color-coded agent messages with custom badges
+  - Real-time agent activity indicators (green/grey dots)
   - Real-time metrics display (duration, tokens, cost)
   - Modal system for agent details
   - User participation in conversations
+  - Topic panel showing initial prompt
+  - Statistics panel with turn/agent counters
+  - Configuration panel showing active settings
 - **Chat Logging**: Automatic conversation logging to `~/.agentpipe/chats/`
 - **Response Metrics**: Track response time, token usage, and estimated costs
 - **Health Checks**: Automatic agent health verification before conversations
@@ -30,14 +40,20 @@ AgentPipe is a CLI and TUI application that orchestrates conversations between m
 
 ## What's New 🎉
 
-### Latest Features
-- **Enhanced TUI Interface**: Beautiful panelized layout with agent list, conversation view, and user participation
-- **Response Metrics**: Real-time tracking of response duration, token usage, and estimated costs
-- **Chat Logging**: Automatic conversation logging with timestamped files in `~/.agentpipe/chats/`
-- **Codex Support**: Added support for OpenAI's Codex CLI tool
-- **Improved Health Checks**: More robust agent health verification with better timeout handling
-- **Colored Output**: Beautiful color-coded agent messages with custom badges
-- **User Participation**: Join conversations directly through the enhanced TUI
+### Latest Features (v0.0.7)
+- **Enhanced TUI Interface**: 
+  - Beautiful multi-panel layout with dedicated sections for agents, chat, stats, and config
+  - Real-time agent activity indicators showing when agents are thinking/responding
+  - Consolidated message headers (only shown when speaker changes)
+  - Proper multi-paragraph message handling
+  - Topic panel displaying the initial conversation prompt
+  - Statistics showing current/max turns, connected/configured agents, and total cost
+  - Configuration panel showing all active settings including config file path
+- **Response Metrics**: Real-time tracking with inline display in chat (X.Xs, XXX tokens, $X.XXXX)
+- **Improved Message Formatting**: Better handling of multi-line agent responses
+- **Chat Logging**: Dual output support - logs to file while displaying in TUI
+- **Configuration Honoring**: TUI mode now properly respects all config settings
+- **User Participation**: Seamless integration allowing users to join agent conversations
 
 ## Installation
 
@@ -149,8 +165,9 @@ orchestrator:
 
 logging:
   enabled: true          # Enable chat logging
-  path: ~/.agentpipe/chats  # Custom log path (optional)
-  show_metrics: true     # Display response metrics
+  chat_log_dir: ~/.agentpipe/chats  # Custom log path (optional)
+  show_metrics: true     # Display response metrics in TUI
+  log_format: text      # Log format (text or json)
 ```
 
 ### Conversation Modes
@@ -173,8 +190,7 @@ Start a conversation between agents.
 - `--timeout`: Response timeout in seconds (default: 30)
 - `--delay`: Delay between responses in seconds (default: 1)
 - `-p, --prompt`: Initial conversation prompt
-- `-t, --tui`: Use TUI interface
-- `--enhanced-tui`: Use enhanced TUI with panels and user input
+- `-t, --tui`: Use enhanced TUI interface with panels and user input
 - `--log-path`: Custom path for chat logs (default: ~/.agentpipe/chats)
 - `--no-log`: Disable chat logging
 - `--show-metrics`: Display response metrics (duration, tokens, cost)
@@ -229,25 +245,54 @@ agentpipe run \
   -p "How can we make education more engaging?"
 ```
 
-## TUI Controls
+## TUI Interface
+
+The enhanced TUI provides a rich, interactive experience for managing multi-agent conversations:
 
-### Basic TUI (`--tui`)
-- `Ctrl+C` or `Esc`: Quit
-- `Ctrl+S`: Start conversation
-- `Ctrl+P`: Pause/Resume
-- `↑↓`: Scroll through messages
+### Layout
+The TUI is divided into multiple panels:
+- **Agents Panel** (Left): Shows all connected agents with real-time status indicators
+- **Chat Panel** (Center): Displays the conversation with color-coded messages
+- **Topic Panel** (Top Right): Shows the initial conversation prompt
+- **Statistics Panel** (Right): Displays turn count, agent statistics, and total conversation cost
+- **Configuration Panel** (Right): Shows active settings and config file path
+- **User Input Panel** (Bottom): Allows you to participate in the conversation
 
-### Enhanced TUI (`--enhanced-tui`)
-- `Tab`: Switch between panels
+### Visual Features
+- **Agent Status Indicators**: Green dot (🟢) for active/responding, grey dot (⚫) for idle
+- **Color-Coded Messages**: Each agent gets a unique color for easy tracking
+- **Consolidated Headers**: Message headers only appear when the speaker changes
+- **Metrics Display**: Response time (seconds), token count, and cost shown inline when enabled
+- **Multi-Paragraph Support**: Properly formatted multi-line agent responses
+
+### Controls
+- `Tab`: Switch between panels (Agents, Chat, User Input)
 - `↑↓`: Navigate in active panel
-- `Enter`: Select agent or send message
-- `i`: Show agent info modal
-- `u`: Toggle user input panel
+- `Enter`: Send message when in User Input panel
+- `i`: Show agent info modal (when in Agents panel)
 - `Ctrl+C` or `q`: Quit
 - `PageUp/PageDown`: Scroll conversation
+- Active agent indicators: 🟢 (responding) / ⚫ (idle)
 
 ## Development
 
+### Building from Source
+
+```bash
+# Clone the repository
+git clone https://github.com/kevinelliott/agentpipe.git
+cd agentpipe
+
+# Build the binary
+go build -o agentpipe .
+
+# Or build with version information
+VERSION=v0.0.7 make build
+
+# Run tests
+go test ./...
+```
+
 ### Project Structure
 
 ```

cmd/root.go

@@ -24,7 +24,7 @@ Claude, Gemini, and Qwen, allowing them to communicate in a shared "room".`,
 	Run: func(cmd *cobra.Command, args []string) {
 		if showVersion {
 			fmt.Println(version.GetVersionString())
-			
+
 			// Quick update check
 			if hasUpdate, latestVersion, err := version.CheckForUpdate(); err == nil && hasUpdate {
 				fmt.Printf("\n📦 Update available: %s (current: %s)\n", latestVersion, version.GetShortVersion())

cmd/run.go

@@ -151,6 +151,24 @@ func parseAgentSpec(spec string, index int) (agent.AgentConfig, error) {
 }
 
 func startConversation(cmd *cobra.Command, cfg *config.Config) error {
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	sigChan := make(chan os.Signal, 1)
+	signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM)
+	go func() {
+		<-sigChan
+		fmt.Println("\n\nInterrupted. Shutting down...")
+		cancel()
+	}()
+
+	if useTUI {
+		// Use enhanced TUI - agent initialization will happen inside TUI
+		skipHealthCheck, _ := cmd.Flags().GetBool("skip-health-check")
+		return tui.RunEnhanced(ctx, cfg, nil, skipHealthCheck, healthCheckTimeout, configPath)
+	}
+
+	// Non-TUI mode: initialize agents here
 	agentsList := make([]agent.Agent, 0)
 
 	verbose := viper.GetBool("verbose")
@@ -219,22 +237,6 @@ func startConversation(cmd *cobra.Command, cfg *config.Config) error {
 
 	fmt.Printf("✅ All %d agents initialized successfully\n\n", len(agentsList))
 
-	ctx, cancel := context.WithCancel(context.Background())
-	defer cancel()
-
-	sigChan := make(chan os.Signal, 1)
-	signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM)
-	go func() {
-		<-sigChan
-		fmt.Println("\n\nInterrupted. Shutting down...")
-		cancel()
-	}()
-
-	if useTUI {
-		// Use enhanced TUI
-		return tui.RunEnhanced(ctx, cfg, agentsList)
-	}
-
 	orchConfig := orchestrator.OrchestratorConfig{
 		Mode:          orchestrator.ConversationMode(cfg.Orchestrator.Mode),
 		TurnTimeout:   cfg.Orchestrator.TurnTimeout,

cmd/version.go

@@ -30,7 +30,7 @@ func runVersion(cmd *cobra.Command, args []string) {
 	if checkUpdate {
 		fmt.Println("\n🔍 Checking for updates...")
 		hasUpdate, latestVersion, err := version.CheckForUpdate()
-		
+
 		if err != nil {
 			// Only show error if it's not a silent failure
 			if err.Error() != "" {
@@ -52,4 +52,4 @@ func runVersion(cmd *cobra.Command, args []string) {
 			fmt.Printf("   ℹ️  Update check unavailable at this time\n")
 		}
 	}
-}
+}

examples/debate.yaml

@@ -30,4 +30,8 @@ orchestrator:
   max_turns: 9
   turn_timeout: 45s
   response_delay: 3s
-  initial_prompt: "Should humanity pursue artificial general intelligence (AGI) at all costs?"
+  initial_prompt: "Should humanity pursue artificial general intelligence (AGI) at all costs?"
+
+logging:
+  enabled: true
+  show_metrics: true  # Set to true to display response metrics

internal/version/version.go

@@ -12,10 +12,10 @@ var (
 	// Version is the current version of agentpipe
 	// This will be set at build time using -ldflags
 	Version = "dev"
-	
+
 	// CommitHash is the git commit hash
 	CommitHash = "unknown"
-	
+
 	// BuildDate is the build date
 	BuildDate = "unknown"
 )
@@ -69,7 +69,7 @@ func CheckForUpdate() (bool, string, error) {
 	if len(parts) == 0 {
 		return false, "", fmt.Errorf("invalid redirect URL")
 	}
-	
+
 	latestTag := parts[len(parts)-1]
 	latestVersion := strings.TrimPrefix(latestTag, "v")
 	currentVersion := strings.TrimPrefix(Version, "v")
@@ -179,4 +179,4 @@ func GetVersionString() string {
 // GetShortVersion returns just the version number
 func GetShortVersion() string {
 	return Version
-}
+}

pkg/orchestrator/orchestrator.go

@@ -71,10 +71,12 @@ func (o *Orchestrator) AddAgent(a agent.Agent) {
 	}
 	o.messages = append(o.messages, announcement)
 
-	// Log using the logger if available, otherwise use writer
+	// Log using the logger if available
 	if o.logger != nil {
 		o.logger.LogMessage(announcement)
-	} else if o.writer != nil {
+	}
+	// Always write to writer if available (for TUI)
+	if o.writer != nil {
 		fmt.Fprintf(o.writer, "\n[System] %s\n", announcement.Content)
 	}
 }
@@ -99,7 +101,9 @@ func (o *Orchestrator) Start(ctx context.Context) error {
 		// Log using the logger if available
 		if o.logger != nil {
 			o.logger.LogMessage(initialMsg)
-		} else if o.writer != nil {
+		}
+		// Always write to writer if available (for TUI)
+		if o.writer != nil {
 			fmt.Fprintf(o.writer, "\n[System] %s\n", initialMsg.Content)
 		}
 	}
@@ -131,7 +135,8 @@ func (o *Orchestrator) runRoundRobin(ctx context.Context) error {
 			endMsg := "Maximum turns reached. Conversation ended."
 			if o.logger != nil {
 				o.logger.LogSystem(endMsg)
-			} else if o.writer != nil {
+			}
+			if o.writer != nil {
 				fmt.Fprintln(o.writer, "\n[System] "+endMsg)
 			}
 			break
@@ -143,7 +148,8 @@ func (o *Orchestrator) runRoundRobin(ctx context.Context) error {
 			if o.logger != nil {
 				o.logger.LogError(currentAgent.GetName(), err)
 				o.logger.LogSystem("Continuing conversation with remaining agents...")
-			} else if o.writer != nil {
+			}
+			if o.writer != nil {
 				fmt.Fprintf(o.writer, "\n[Error] Agent %s failed: %v\n", currentAgent.GetName(), err)
 				fmt.Fprintf(o.writer, "[Info] Continuing conversation with remaining agents...\n")
 			}
@@ -175,7 +181,8 @@ func (o *Orchestrator) runReactive(ctx context.Context) error {
 			endMsg := "Maximum turns reached. Conversation ended."
 			if o.logger != nil {
 				o.logger.LogSystem(endMsg)
-			} else if o.writer != nil {
+			}
+			if o.writer != nil {
 				fmt.Fprintln(o.writer, "\n[System] "+endMsg)
 			}
 			break
@@ -216,7 +223,8 @@ func (o *Orchestrator) runFreeForm(ctx context.Context) error {
 			endMsg := "Maximum turns reached. Conversation ended."
 			if o.logger != nil {
 				o.logger.LogSystem(endMsg)
-			} else if o.writer != nil {
+			}
+			if o.writer != nil {
 				fmt.Fprintln(o.writer, "\n[System] "+endMsg)
 			}
 			break
@@ -296,8 +304,20 @@ func (o *Orchestrator) getAgentResponse(ctx context.Context, a agent.Agent) erro
 	// Display the response
 	if o.logger != nil {
 		o.logger.LogMessage(msg)
-	} else if o.writer != nil {
-		fmt.Fprintf(o.writer, "\n[%s] %s\n", a.GetName(), response)
+	}
+	// Always write to writer if available (for TUI)
+	if o.writer != nil {
+		// Include metrics in a special format if available
+		if msg.Metrics != nil {
+			fmt.Fprintf(o.writer, "\n[%s|%dms|%dt|%.4f] %s\n",
+				a.GetName(),
+				msg.Metrics.Duration.Milliseconds(),
+				msg.Metrics.TotalTokens,
+				msg.Metrics.Cost,
+				response)
+		} else {
+			fmt.Fprintf(o.writer, "\n[%s] %s\n", a.GetName(), response)
+		}
 	}
 
 	return nil