Add external LocalStack detection to prevent container conflicts in CI

Author: NinjaRocks

tests/SourceFlow.Cloud.AWS.Tests/TestHelpers/AwsTestConfiguration.cs

@@ -254,7 +254,9 @@ public async Task<bool> IsLocalStackAvailableAsync(TimeSpan timeout)
             var config = new AmazonSQSConfig
             {
                 ServiceURL = LocalStackEndpoint,
-                RegionEndpoint = Region
+                RegionEndpoint = Region,
+                Timeout = timeout,
+                MaxErrorRetry = 0  // Don't retry, fail fast
             };
 
             var credentials = new BasicAWSCredentials("test", "test");

tests/SourceFlow.Cloud.AWS.Tests/TestHelpers/LocalStackManager.cs

@@ -49,6 +49,15 @@ public async Task StartAsync(LocalStackConfiguration config)
         }
 
         _configuration = config ?? throw new ArgumentNullException(nameof(config));
+        
+        // Check if LocalStack is already running externally (e.g., in GitHub Actions)
+        if (await IsExternalLocalStackAvailableAsync(config.Endpoint))
+        {
+            _logger.LogInformation("Detected existing LocalStack instance at {Endpoint}, using it instead of starting new container", config.Endpoint);
+            // Don't start a new container, just use the existing one
+            return;
+        }
+        
         _logger.LogInformation("Starting LocalStack container with services: {Services}", string.Join(", ", config.EnabledServices));
 
         // Ensure port is available before starting
@@ -358,6 +367,29 @@ public async Task<string> GetLogsAsync(int tail = 100)
         }
     }
 
+    /// <summary>
+    /// Check if an external LocalStack instance is already available
+    /// </summary>
+    /// <param name="endpoint">LocalStack endpoint to check</param>
+    /// <returns>True if external LocalStack is available</returns>
+    private async Task<bool> IsExternalLocalStackAvailableAsync(string endpoint)
+    {
+        try
+        {
+            using var httpClient = new HttpClient();
+            httpClient.Timeout = TimeSpan.FromSeconds(3);
+            
+            var healthUrl = $"{endpoint}/_localstack/health";
+            var response = await httpClient.GetAsync(healthUrl);
+            
+            return response.IsSuccessStatusCode;
+        }
+        catch
+        {
+            return false;
+        }
+    }
+    
     /// <summary>
     /// Find an available port starting from the specified port
     /// </summary>

tests/SourceFlow.Cloud.AWS.Tests/TestHelpers/LocalStackTestFixture.cs

@@ -58,7 +58,18 @@ public async Task InitializeAsync()
         }
 
         // Check if LocalStack is already running (e.g., in GitHub Actions)
-        bool isAlreadyRunning = await _configuration.IsLocalStackAvailableAsync(TimeSpan.FromSeconds(2));
+        // Use a short timeout to avoid hanging
+        bool isAlreadyRunning = false;
+        try
+        {
+            using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3));
+            isAlreadyRunning = await _configuration.IsLocalStackAvailableAsync(TimeSpan.FromSeconds(3));
+        }
+        catch
+        {
+            // If check fails, assume not running
+            isAlreadyRunning = false;
+        }
 
         if (!isAlreadyRunning)
         {