Added more logging to StartedParentCanWaitForChildActionCompletion-test

Author: stidsborg

Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/FunctionTests/SuspensionTests.cs

@@ -365,8 +365,34 @@ async Task<string> (string param, Workflow workflow) =>
             });
 
         var param = "hello world and universe";
-        var result = await parent.Schedule(parentFunctionId.Instance.Value, param).Completion();
-        result.ShouldBe(param.ToUpper());
+        try
+        {
+            var result = await parent.Schedule(parentFunctionId.Instance.Value, param).Completion();
+            result.ShouldBe(param.ToUpper());
+        }
+        catch (Exception ex)
+        {
+            var parentStatus = await store
+                .GetFunction(parentFunctionId.ToStoredId(parent.StoredType))
+                .SelectAsync(sf => new { Name = "Parent", Status = sf?.Status });
+            var childrenStatus = await param
+                .Split(" ")
+                .Select((_, i) => store
+                    .GetFunction(new StoredId(child.StoredType, $"Child{i}".ToStoredInstance()))
+                    .SelectAsync(sf => new { Name = $"Child{i}", Status = sf?.Status })
+                )
+                .AwaitAll();
+            
+            var statusStr = parentStatus.AsEnumerable()
+                .Concat(childrenStatus)
+                .Select(a => $"{a.Name}: {a.Status}")
+                .JoinStrings(Environment.NewLine);
+            
+            throw new TimeoutException(
+                "FunctionStates: " + Environment.NewLine + statusStr,
+                innerException: ex
+            );
+        }
 
         unhandledExceptionHandler.ShouldNotHaveExceptions();
     }

Core/Cleipnir.ResilientFunctions.Tests/Utils/EnumerableLinq.cs

@@ -0,0 +1,9 @@
+using System.Collections.Generic;
+
+namespace Cleipnir.ResilientFunctions.Tests.Utils;
+
+public static class EnumerableLinq
+{
+    public static IEnumerable<T> AsEnumerable<T>(this T t) => [t];
+    public static string JoinStrings(this IEnumerable<string> strings, string separator) => string.Join(separator, strings);
+}

Core/Cleipnir.ResilientFunctions.Tests/Utils/TaskLinq.cs

@@ -12,6 +12,15 @@ public static Task<TOut> Map<TIn, TOut>(this Task<TIn> task, Func<TIn, TOut> f)
 
     public static Task<List<T>> ToListAsync<T>(this Task<IEnumerable<T>> task)
         => task.ContinueWith(t => t.Result.ToList());
+
+    public static async Task<List<T>> AwaitAll<T>(this IEnumerable<Task<T>> tasks)
+    {
+        var results = new List<T>();
+        foreach (var task in tasks)
+            results.Add(await task);
+        
+        return results;
+    }
 
     public static Task<bool> AnyAsync<T>(this Task<IEnumerable<T>> task) => task.ContinueWith(t => t.Result.Any());
     public static Task<bool> AnyAsync<T>(this Task<IReadOnlyList<T>> task) => task.ContinueWith(t => t.Result.Any());