Improves connection resilience with auto-reconnect

Enhances the CLI's robustness by adding an automatic reconnection feature when the SSE connection is lost.
This includes:
- Exponential backoff strategy for reconnection attempts.
- Limits the number of reconnection attempts to avoid indefinite loops.
- Introduces proper escaping of response body content to prevent markup errors in the console.
- Manual disconnect disables auto-reconnect
- Updates version to 1.0.17

Author: ahmandour

HookReplay.Cli.csproj

@@ -25,7 +25,7 @@
     <TrimMode>link</TrimMode>
 
     <!-- Package metadata for NuGet -->
-    <Version>1.0.8</Version>
+    <Version>1.0.17</Version>
     <Authors>HookReplay</Authors>
     <Company>HookReplay</Company>
     <Description>Debug webhooks locally with HookReplay CLI. Capture, inspect, and replay webhooks to your local development server.</Description>

Program.cs

@@ -39,6 +39,12 @@ internal class Program
     private static CancellationTokenSource? _connectionCts;
     private static Task? _sseListenerTask;
     private static string? _latestVersion;
+    private static string? _currentSseUrl;
+    private static string? _currentApiKey;
+    private static bool _autoReconnectEnabled = true;
+    private static int _reconnectAttempts = 0;
+    private const int MaxReconnectAttempts = 10;
+    private static readonly int[] ReconnectDelaysMs = [1000, 2000, 5000, 10000, 30000];
 
     private static async Task<int> Main(string[] args)
     {
@@ -584,6 +590,12 @@ await AnsiConsole.Status()
                     new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", apiKey);
 
                 _connectionCts = new CancellationTokenSource();
+                
+                // Store connection info for reconnection
+                _currentSseUrl = sseUrl;
+                _currentApiKey = apiKey;
+                _autoReconnectEnabled = true;
+                _reconnectAttempts = 0;
 
                 // Start listening to SSE events in background
                 _sseListenerTask = ListenToSseAsync(sseUrl, _connectionCts.Token);
@@ -664,20 +676,55 @@ private static async Task ListenToSseAsync(string url, CancellationToken cancell
         }
         catch (OperationCanceledException)
         {
-            // Normal disconnection
+            // Normal disconnection - don't auto-reconnect
+            _autoReconnectEnabled = false;
         }
         catch (Exception ex)
         {
             AnsiConsole.WriteLine();
-            AnsiConsole.MarkupLine($"[red]SSE connection error:[/] {ex.Message}");
+            AnsiConsole.MarkupLine($"[red]SSE connection error:[/] {Markup.Escape(ex.Message)}");
         }
         finally
         {
             _isConnected = false;
             AnsiConsole.WriteLine();
+        }
+        
+        // Attempt auto-reconnect if not manually disconnected (moved outside finally)
+        if (_autoReconnectEnabled && !cancellationToken.IsCancellationRequested && _reconnectAttempts < MaxReconnectAttempts)
+        {
+            _reconnectAttempts++;
+            var delayIndex = Math.Min(_reconnectAttempts - 1, ReconnectDelaysMs.Length - 1);
+            var delayMs = ReconnectDelaysMs[delayIndex];
+            
+            AnsiConsole.MarkupLine($"[yellow]Connection lost. Reconnecting in {delayMs / 1000}s (attempt {_reconnectAttempts}/{MaxReconnectAttempts})...[/]");
+            
+            try
+            {
+                await Task.Delay(delayMs, cancellationToken);
+                
+                if (!cancellationToken.IsCancellationRequested && _currentSseUrl != null)
+                {
+                    // Reconnect
+                    await ListenToSseAsync(_currentSseUrl, cancellationToken);
+                    return; // Don't show disconnected message
+                }
+            }
+            catch (OperationCanceledException)
+            {
+                // Cancelled during reconnect delay
+            }
+        }
+        else if (_reconnectAttempts >= MaxReconnectAttempts)
+        {
+            AnsiConsole.MarkupLine("[red]Max reconnection attempts reached. Use 'connect' to reconnect manually.[/]");
+        }
+        else if (!_autoReconnectEnabled || cancellationToken.IsCancellationRequested)
+        {
             AnsiConsole.MarkupLine("[yellow]Disconnected from server.[/]");
-            AnsiConsole.Markup(_isConnected ? "[green]●[/] [green]hookreplay[/]> " : "[red]●[/] [blue]hookreplay[/]> ");
         }
+        
+        AnsiConsole.Markup(_isConnected ? "[green]●[/] [green]hookreplay[/]> " : "[red]●[/] [blue]hookreplay[/]> ");
     }
 
     private static async Task HandleSseEvent(string eventType, string data)
@@ -686,6 +733,7 @@ private static async Task HandleSseEvent(string eventType, string data)
         {
             case "connected":
                 _isConnected = true;
+                _reconnectAttempts = 0; // Reset reconnect counter on successful connection
                 try
                 {
                     var connectedEvent = JsonSerializer.Deserialize(data, CliJsonContext.Default.SseConnectedEvent);
@@ -835,9 +883,12 @@ private static async Task ExecuteRequest(ReplayRequest request, string fullUrl)
 
                 if (displayBody.Length > 500)
                 {
-                    displayBody = displayBody[..500] + "\n[silver]... (truncated)[/]";
+                    displayBody = displayBody[..500] + "... (truncated)";
                 }
 
+                // Escape markup characters to prevent Spectre.Console from interpreting them
+                displayBody = Markup.Escape(displayBody);
+
                 AnsiConsole.Write(new Panel(displayBody)
                     .Header("[silver]Response Body[/]")
                     .Border(BoxBorder.Rounded)
@@ -859,6 +910,9 @@ private static async Task DisconnectAsync()
             return;
         }
 
+        // Disable auto-reconnect for manual disconnect
+        _autoReconnectEnabled = false;
+        
         await _connectionCts?.CancelAsync();
 
         if (_sseListenerTask != null)

README.md

@@ -227,6 +227,35 @@ MIT License - see [LICENSE](LICENSE) for details.
 
 ---
 
+## Changelog
+
+### v1.0.17 (2026-01-23)
+
+#### 🐛 Bug Fixes
+- **Fixed response body display**: HTML/XML responses with `[` and `]` characters no longer crash the CLI with "malformed markup tag" errors
+- **Fixed Spectre.Console markup escaping**: All user-generated content is now properly escaped before rendering
+
+#### ✨ New Features
+- **Auto-reconnect**: CLI now automatically reconnects when the connection drops unexpectedly
+  - Uses exponential backoff: 1s → 2s → 5s → 10s → 30s delays
+  - Attempts up to 10 reconnections before giving up
+  - Manual disconnect (`disconnect` command or Ctrl+C) disables auto-reconnect
+  - Shows clear status messages during reconnection attempts
+
+#### 🔧 Improvements
+- Better error messages with escaped content to prevent display issues
+- Connection state is properly tracked across reconnection attempts
+
+---
+
+### v1.0.16
+
+- Self-update feature: CLI can update itself without npm/dotnet commands
+- Version checking against npm registry on startup
+- Direct binary download from GitHub Releases
+
+---
+
 <p align="center">
   <strong>Stop chasing webhooks. Start catching bugs.</strong>
   <br />