Add conversation summarization, unique agent IDs, and local event storage (v0.4.1)

Features:
- Conversation Summarization:
  - Automatic AI-generated summaries at conversation completion
  - Configurable summary agent (default: Gemini)
  - --no-summary flag and config option to disable
  - --summary-agent flag to override configured agent
  - Summary metadata includes agent type, model, tokens, cost, duration
  - Summary tokens and cost factored into conversation totals

- Unique Agent IDs:
  - Agent IDs now unique per instance: {agentType}-{index}
  - Supports multiple agents of same type in single conversation
  - AgentID included in all bridge streaming events
  - AgentID in conversation.started participants list
  - AgentID in all message.created events

- Local Event Storage:
  - Events saved to ~/.agentpipe/events/ directory
  - One JSON Lines file per conversation
  - Non-blocking async operation

Changes:
- Enhanced ConversationCompletedData with SummaryMetadata struct
- Added SummaryConfig to configuration
- Updated EmitMessageCreated signature to include agentID
- Added EventStore for local event persistence
- Updated all call sites and tests

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: kevinelliott

CHANGELOG.md

@@ -7,6 +7,66 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [v0.4.1] - 2025-10-22
+
+### Added
+- **Conversation Summarization**: Automatic AI-generated summaries at conversation completion
+  - Configurable summary agent (default: Gemini, supports all agent types)
+  - `--no-summary` flag to disable summaries
+  - `--summary-agent` flag to override configured agent
+  - Summary configuration in YAML config file
+  - Summary metadata includes agent type, model, tokens, cost, and duration
+  - Summary tokens and cost factored into conversation totals
+  - Smart prompt design avoiding meta-commentary
+
+- **Unique Agent IDs**: Enhanced agent identification for multiple agents of same type
+  - Agent IDs now unique per instance: `{agentType}-{index}` (e.g., `claude-0`, `claude-1`)
+  - AgentID included in all bridge streaming events
+  - Allows tracking of multiple agents with same type in single conversation
+  - AgentID in conversation.started participants list
+  - AgentID in all message.created events
+
+- **Event Store**: Local event persistence
+  - Events saved to `~/.agentpipe/events/` directory
+  - One JSON Lines file per conversation
+  - Non-blocking async operation
+  - Debug logging for storage errors
+
+### Changed
+- **Bridge Events**: Enhanced ConversationCompletedData structure
+  - Summary field now contains full SummaryMetadata (instead of plain string)
+  - Includes summary agent type, model, tokens, cost, duration
+  - Total tokens and cost now include summary metrics
+  - Duration does not include summary generation time
+
+- **Streaming Protocol**: Updated message event structure
+  - EmitMessageCreated now requires agentID as first parameter
+  - MessageCreatedData includes agent_id field
+  - AgentParticipant includes agent_id field
+
+### Fixed
+- Agent identification for conversations with multiple agents of same type
+- Cost tracking to include summary generation costs in totals
+- Thread-safe access to bridge emitter in orchestrator
+
+## [v0.4.0] - 2025-10-21
+
+### Added
+- **Bridge Connection Events**: Automatic connection announcement
+  - Emit bridge.connected event on emitter initialization
+  - System info included in connection event
+  - Synchronous sending ensures reliability
+
+- **Cancellation Detection**: Detect and report conversation interruption
+  - Emit conversation.completed with status="interrupted" on Ctrl+C
+  - Distinguish between normal completion and cancellation
+  - Proper error propagation in orchestrator
+
+### Changed
+- **Event Reliability**: Improved critical event delivery
+  - Use synchronous SendEvent for completion and error events
+  - Prevent truncated JSON payloads on program exit
+
 ## [v0.3.0] - 2025-10-21
 
 ### Added

README.md

@@ -92,33 +92,35 @@ All agents now use a **standardized interaction pattern** with structured three-
 
 See [CHANGELOG.md](CHANGELOG.md) for detailed version history and release notes.
 
-**Latest Release**: v0.3.0 - Real-time conversation streaming to AgentPipe Web
-
-**What's New in v0.3.0**:
-
-🌐 **Major New Feature - Streaming Bridge:**
-- **Real-Time Conversation Streaming**: Stream live conversations to AgentPipe Web for browser viewing
-  - Four event types: conversation.started, message.created, conversation.completed, conversation.error
-  - Non-blocking async implementation that never interrupts conversations
-  - Rich metrics: agent participants, CLI versions, tokens, costs, duration, system info
-  - Privacy-first: disabled by default, API keys never logged
-- **Bridge CLI Commands**: Easy configuration and management
-  - `agentpipe bridge setup` - Interactive wizard
-  - `agentpipe bridge status` - View config (with `--json` support)
-  - `agentpipe bridge test` - Test connection
-  - `agentpipe bridge disable` - Disable streaming
-- **Production Ready**: Retry logic with exponential backoff, >80% test coverage
-
-⚠️ **Breaking Changes:**
-- Extended Agent interface with `GetCLIVersion()` method
-  - All built-in adapters updated
-  - Custom agent implementations must implement this new method
-
-⚡ **Improvements:**
-- Added BridgeConfig to support streaming configuration
-- Thread-safe orchestrator with RWMutex for concurrent bridge access
-- Environment variable overrides for bridge settings
-
+**Latest Release**: v0.4.1 - Conversation summarization & unique agent IDs
+
+**What's New in v0.4.1**:
+
+📝 **Conversation Summarization**:
+- **AI-Generated Summaries**: Automatic summaries at conversation completion
+  - Configurable summary agent (default: Gemini, supports all agent types)
+  - `--no-summary` flag to disable summaries
+  - `--summary-agent` flag to override configured agent
+  - Summary metadata includes agent type, model, tokens, cost, duration
+  - Summary tokens and cost factored into conversation totals
+  - Smart prompt design avoiding meta-commentary
+
+👥 **Unique Agent IDs**:
+- **Enhanced Agent Identification**: Support multiple agents of the same type
+  - Agent IDs now unique per instance: `claude-0`, `claude-1`, etc.
+  - AgentID included in all bridge streaming events
+  - Track individual agents in conversations with multiple agents of same type
+  - AgentID in conversation.started participants list
+  - AgentID in all message.created events
+
+💾 **Local Event Storage**:
+- **Event Persistence**: Events saved to `~/.agentpipe/events/`
+  - One JSON Lines file per conversation
+  - Non-blocking async operation
+  - Debug logging for storage errors
+
+**Previous Release - v0.4.0**: Bridge connection events and cancellation detection
+**Previous Release - v0.3.0**: Real-time conversation streaming to AgentPipe Web
 **Previous Release - v0.2.2**: JSON output support for agents list command
 **Previous Release - v0.2.1**: OpenCode agent and improved package management
 **Previous Release - v0.2.0**: Agent upgrade command and automated version detection

cmd/run.go

@@ -12,6 +12,7 @@ import (
 	"time"
 
 	"github.com/spf13/cobra"
+	"github.com/spf13/pflag"
 	"github.com/spf13/viper"
 
 	"github.com/kevinelliott/agentpipe/internal/bridge"
@@ -44,6 +45,8 @@ var (
 	stateFile          string
 	streamEnabled      bool
 	noStream           bool
+	noSummary          bool
+	summaryAgent       string
 )
 
 var runCmd = &cobra.Command{
@@ -75,6 +78,8 @@ func init() {
 	runCmd.Flags().StringVar(&stateFile, "state-file", "", "Specific file path to save conversation state")
 	runCmd.Flags().BoolVar(&streamEnabled, "stream", false, "Enable streaming to AgentPipe Web for this run (overrides config)")
 	runCmd.Flags().BoolVar(&noStream, "no-stream", false, "Disable streaming to AgentPipe Web for this run (overrides config)")
+	runCmd.Flags().BoolVar(&noSummary, "no-summary", false, "Disable conversation summary generation (overrides config)")
+	runCmd.Flags().StringVar(&summaryAgent, "summary-agent", "", "Agent to use for summary generation (default: gemini, overrides config)")
 }
 
 func runConversation(cobraCmd *cobra.Command, args []string) {
@@ -140,6 +145,14 @@ func runConversation(cobraCmd *cobra.Command, args []string) {
 		cfg.Logging.ShowMetrics = true
 	}
 
+	// Apply CLI overrides for summary
+	if noSummary {
+		cfg.Orchestrator.Summary.Enabled = false
+	}
+	if summaryAgent != "" {
+		cfg.Orchestrator.Summary.Agent = summaryAgent
+	}
+
 	if err := startConversation(cobraCmd, cfg); err != nil {
 		fmt.Fprintf(os.Stderr, "Error: %v\n", err)
 		os.Exit(1)
@@ -324,6 +337,7 @@ func startConversation(cmd *cobra.Command, cfg *config.Config) error {
 		MaxTurns:      cfg.Orchestrator.MaxTurns,
 		ResponseDelay: cfg.Orchestrator.ResponseDelay,
 		InitialPrompt: cfg.Orchestrator.InitialPrompt,
+		Summary:       cfg.Orchestrator.Summary,
 	}
 
 	// Create logger if enabled
@@ -350,6 +364,10 @@ func startConversation(cmd *cobra.Command, cfg *config.Config) error {
 		orch.SetLogger(chatLogger)
 	}
 
+	// Capture command information for event tracking
+	commandInfo := buildCommandInfo(cmd, cfg)
+	orch.SetCommandInfo(commandInfo)
+
 	// Set up streaming bridge if enabled
 	shouldStream := determineShouldStream(streamEnabled, noStream)
 	if shouldStream {
@@ -544,3 +562,42 @@ func determineShouldStream(streamEnabled, noStream bool) bool {
 	bridgeConfig := bridge.LoadConfig()
 	return bridgeConfig.Enabled
 }
+
+// buildCommandInfo constructs a CommandInfo struct from the cobra command and config
+func buildCommandInfo(cmd *cobra.Command, cfg *config.Config) *bridge.CommandInfo {
+	// Build the full command string
+	args := os.Args
+	fullCommand := strings.Join(args, " ")
+
+	// Build options map with all relevant flags
+	options := make(map[string]string)
+
+	// Add all flags that were explicitly set
+	cmd.Flags().Visit(func(flag *pflag.Flag) {
+		options[flag.Name] = flag.Value.String()
+	})
+
+	// Build agent list string for readability
+	agentList := make([]string, 0, len(cfg.Agents))
+	for _, agent := range cfg.Agents {
+		agentSpec := fmt.Sprintf("%s:%s", agent.Type, agent.Name)
+		agentList = append(agentList, agentSpec)
+	}
+	if len(agentList) > 0 {
+		options["agents_list"] = strings.Join(agentList, ",")
+	}
+
+	return &bridge.CommandInfo{
+		FullCommand:    fullCommand,
+		Args:           args[1:], // Exclude program name
+		Mode:           cfg.Orchestrator.Mode,
+		MaxTurns:       cfg.Orchestrator.MaxTurns,
+		InitialPrompt:  cfg.Orchestrator.InitialPrompt,
+		ConfigFile:     configPath,
+		TUIEnabled:     useTUI,
+		LoggingEnabled: cfg.Logging.Enabled,
+		ShowMetrics:    showMetrics,
+		Timeout:        int(cfg.Orchestrator.TurnTimeout.Seconds()),
+		Options:        options,
+	}
+}

internal/bridge/client.go

@@ -12,8 +12,9 @@ import (
 
 // Client is an HTTP client for sending streaming events to AgentPipe Web
 type Client struct {
-	config     *Config
-	httpClient *http.Client
+	config           *Config
+	httpClient       *http.Client
+	suppressWarnings bool // Set to true after first failure to avoid spamming warnings
 }
 
 // NewClient creates a new bridge client with the given configuration
@@ -23,6 +24,7 @@ func NewClient(config *Config) *Client {
 		httpClient: &http.Client{
 			Timeout: time.Duration(config.TimeoutMs) * time.Millisecond,
 		},
+		suppressWarnings: false,
 	}
 }
 
@@ -86,8 +88,16 @@ func (c *Client) SendEvent(event *Event) error {
 	}
 
 	// Log error but don't fail the conversation
-	if c.config.LogLevel == "debug" || c.config.LogLevel == "info" {
-		fmt.Fprintf(os.Stderr, "Warning: Failed to stream event after %d attempts: %v\n",
+	if !c.suppressWarnings {
+		// Show a user-friendly warning only once
+		fmt.Fprintln(os.Stderr, "\n⚠️  Bridge streaming unavailable - conversation will continue normally")
+		fmt.Fprintln(os.Stderr, "   (Events will be saved locally and can be uploaded later)")
+		c.suppressWarnings = true
+	}
+
+	// Log detailed error at debug level only
+	if c.config.LogLevel == "debug" {
+		fmt.Fprintf(os.Stderr, "Debug: Failed to stream event after %d attempts: %v\n",
 			c.config.RetryAttempts+1, lastErr)
 	}