25.0.0-beta.6 TimeoutSteps

Author: raman-m

src/AcceptanceSteps.cs

@@ -62,6 +62,10 @@ public AcceptanceSteps()
     protected static string DownstreamUrl(int port, string scheme) => $"{scheme ?? Uri.UriSchemeHttp}://localhost:{port}";
     protected static string LoopbackLocalhostUrl(int port, int loopbackIndex = 0) => $"{Uri.UriSchemeHttp}://127.0.0.{++loopbackIndex}:{port}";
 
+    protected virtual bool IsCiCd() => IsRunningInGitHubActions();
+    protected static bool IsRunningInGitHubActions()
+        => Environment.GetEnvironmentVariable("GITHUB_ACTIONS") == "true";
+
     public virtual FileConfiguration GivenConfiguration(params FileRoute[] routes)
     {
         var c = new FileConfiguration();

src/Ocelot.Testing.csproj

@@ -8,7 +8,7 @@
     <IncludeSymbols>True</IncludeSymbols>
     <SymbolPackageFormat>snupkg</SymbolPackageFormat>
     <!--Package properties-->
-    <Version>25.0.0-beta.5</Version>
+    <Version>25.0.0-beta.6</Version>
     <!-- <VersionPrefix>0.0.0-dev</VersionPrefix> -->
     <PackageId>Ocelot.Testing</PackageId>
     <PackageDescription>A shared library for testing the Ocelot core library and its extension packages, including both acceptance and unit tests</PackageDescription>

src/TimeoutSteps.cs

@@ -0,0 +1,50 @@
+using Microsoft.AspNetCore.Http;
+using Ocelot.Configuration.File;
+using Shouldly;
+using System.Diagnostics;
+using System.Net;
+using System.Runtime.CompilerServices;
+
+namespace Ocelot.Testing;
+
+public class TimeoutSteps : AcceptanceSteps
+{
+    public static int Ms(int seconds) => 1000 * seconds;
+
+    public FileConfiguration GivenConfiguration(int port, int? routeTimeout = null, int? globalTimeout = null)
+    {
+        var route = GivenDefaultRoute(port);
+        route.Timeout = routeTimeout;
+        var configuration = GivenConfiguration(route);
+        configuration.GlobalConfiguration.Timeout = globalTimeout;
+        return configuration;
+    }
+
+    public virtual void GivenThereIsAServiceRunningOn(int port, HttpStatusCode statusCode, int timeout,
+        [CallerMemberName] string response = nameof(TimeoutSteps))
+    {
+        async Task MapBodyWithTimeout(HttpContext context)
+        {
+            await Task.Delay(timeout);
+            context.Response.StatusCode = (int)statusCode;
+            await context.Response.WriteAsync(response);
+        }
+        handler.GivenThereIsAServiceRunningOn(port, MapBodyWithTimeout);
+    }
+
+    public async Task<Stopwatch> WatchWhenIGetUrlOnTheApiGateway(string? upstream = null)
+    {
+        var watcher = Stopwatch.StartNew();
+        await WhenIGetUrlOnTheApiGateway(upstream ?? "/");
+        watcher.Stop();
+        return watcher;
+    }
+
+    public static void ThenTimeoutIsInRange(Stopwatch watcher, int lowDurationMs, int highDurationMs)
+    {
+        var expectedLowDuration = TimeSpan.FromMilliseconds(lowDurationMs);
+        var expectedHighDuration = TimeSpan.FromMilliseconds(highDurationMs);
+        watcher.Elapsed.ShouldBeGreaterThan(expectedLowDuration);
+        watcher.Elapsed.ShouldBeLessThan(expectedHighDuration);
+    }
+}