Try async middleware testing

Signed-off-by: Hal Spang <[email protected]>

Author: halspang

test/e2e/Apps/BasicDotNetIsolated/Program.cs

@@ -8,7 +8,12 @@
 using System.Diagnostics;
 
 var host = new HostBuilder()
-    .ConfigureFunctionsWebApplication()
+    .ConfigureFunctionsWebApplication(workerApplication =>
+    {
+        // Register async middleware to test the fix for https://github.com/microsoft/durabletask-dotnet/issues/158
+        // This middleware performs async operations that previously caused non-determinism exceptions
+        workerApplication.UseMiddleware<Microsoft.Azure.Durable.Tests.E2E.TestAsyncMiddleware>();
+    })
     .ConfigureServices(services => {
         services.AddApplicationInsightsTelemetryWorkerService();
         services.ConfigureFunctionsApplicationInsights();

test/e2e/Apps/BasicDotNetIsolated/TestAsyncMiddleware.cs

@@ -0,0 +1,33 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using System;
+using System.Threading.Tasks;
+using Microsoft.Azure.Functions.Worker;
+using Microsoft.Azure.Functions.Worker.Middleware;
+
+namespace Microsoft.Azure.Durable.Tests.E2E;
+
+/// <summary>
+/// Test middleware that performs async operations to validate the fix for
+/// https://github.com/microsoft/durabletask-dotnet/issues/158
+/// This middleware simulates async behaviors like App Configuration or logging services.
+/// </summary>
+public class TestAsyncMiddleware : IFunctionsWorkerMiddleware
+{
+    public async Task Invoke(FunctionContext context, FunctionExecutionDelegate next)
+    {
+        // Simulate an async operation like fetching configuration or logging
+        await Task.Delay(1);
+        
+        // Store metadata to verify the middleware ran
+        context.Items["AsyncMiddlewareExecuted"] = true;
+        context.Items["AsyncMiddlewareTimestamp"] = DateTime.UtcNow;
+        
+        // Continue to the next middleware/function
+        await next(context);
+        
+        // Simulate async post-processing
+        await Task.Delay(1);
+    }
+}