Added long-running stress test

Author: stidsborg

Stores/StressTests/Program.cs

@@ -12,6 +12,7 @@ private static async Task<int> Main(string[] args)
             {
                 Console.WriteLine("Usage: StressTests <all, mariadb, postgres, sqlserver>");
                 Console.WriteLine("       StressTests recreate_dbs");
+                Console.WriteLine("       StressTests long_running <mariadb, postgres, sqlserver>");
                 return 1;
             }
 
@@ -26,11 +27,31 @@ private static async Task<int> Main(string[] args)
                 await new SqlServerEngine().RecreateDatabase();
                 return 0;
             }
+
+            if (args[0].ToLower() == "long_running")
+            {
+                IEngine? engine = args[1].ToLower() switch
+                {
+                    "mariadb" => new MariaDBEngine(),
+                    "postgres" => new PostgreSqlEngine(),
+                    "sqlserver" => new SqlServerEngine(),
+                    _ => null
+                };
+                if (engine == null)
+                {
+                    Console.WriteLine("Usage: StressTests long_running <mariadb, postgres, sqlserver>");
+                    return 1;
+                }
+
+                Console.WriteLine("Press enter to stop test");
+                await LongRunningStressfulTest.Perform(engine);
+                return 0;
+            }
 
             var engines = new List<IEngine>();
 
             if (args.Any(arg => arg.ToLower() == "all"))
-                args = new[] { "mariadb", "postgres", "sqlserver" };
+                args = ["mariadb", "postgres", "sqlserver"];
 
             foreach (var arg in args)
             {

Stores/StressTests/StressTests/LongRunningStressfulTest.cs

@@ -0,0 +1,60 @@
+using System.Diagnostics;
+using Cleipnir.ResilientFunctions.Domain;
+using Cleipnir.ResilientFunctions.StressTests.Engines;
+
+namespace Cleipnir.ResilientFunctions.StressTests.StressTests;
+
+public static class LongRunningStressfulTest
+{
+    public static async Task Perform(IEngine helper)
+    {
+        const int testSize = 1_000;
+
+        await helper.InitializeDatabaseAndInitializeAndTruncateTable();
+        var store = await helper.CreateFunctionStore();
+        
+        var stopWatch = new Stopwatch();
+        stopWatch.Start();
+
+        {
+            using var functionsRegistry1 = new FunctionsRegistry(
+                store,
+                new Settings(unhandledExceptionHandler: e =>
+                {
+                    Console.WriteLine(e);
+                    Environment.Exit(1);
+                }, leaseLength: TimeSpan.FromSeconds(2), maxParallelRetryInvocations: testSize * 2)
+            );
+            var actionRegistration = functionsRegistry1.RegisterParamless(
+                "LongRunningStressfulTest",
+                async Task (workflow) =>
+                {
+                    Console.WriteLine(workflow.FlowId + " started");
+                    var effect = workflow.Effect;
+                    while (true)
+                    {
+                        for (var i = 0; i < 100; i++)
+                        {
+                            _ = await effect.Capture($"{i}", () => i);
+                            await Task.Delay(10);
+                        }
+                    
+                        for (var i = 0; i < 100; i++)
+                        {
+                            await effect.Clear($"{i}");
+                            await Task.Delay(10);
+                        }
+                    }
+                });
+        
+            Console.WriteLine("LONGRUNNING_TEST: Initializing");
+            await actionRegistration.BulkSchedule(
+                Enumerable.Range(1, testSize).Select(i => i.ToString().ToFlowInstance())
+            );            
+            
+            Console.WriteLine("LONGRUNNING_TEST: Intiailization completed");
+            Console.ReadLine();
+        }
+        
+    }
+}