More logging

Author: bording

src/ServiceControl.MultiInstance.AcceptanceTests/Recoverability/WhenRetryingSameMessageMultipleTimes.cs

@@ -36,24 +36,34 @@ await Define<MyContext>()
                 {
                     if (c.RetryCount >= retryTypes.Length) // Are all retries done?
                     {
-                        Console.WriteLine("first");
+                        Console.WriteLine($"first {c.RetryCount}");
 
-                        return !(await GetAllFailedMessage(ServiceControlInstanceName, FailedMessageStatus.Unresolved))
-                            .HasResult; // Should return true if all failed messages are no longer unresolved
+                        var result = await GetAllFailedMessage(ServiceControlInstanceName, FailedMessageStatus.Unresolved);
+
+                        if (result.HasResult)
+                        {
+                            Console.WriteLine($"Has items: {result.Items.Count}");
+
+                            foreach (var item in result.Items)
+                            {
+                                Console.WriteLine($"    MessageId {item.Id}");
+                            }
+                        }
+
+                        return !result.HasResult;
                     }
 
                     if (retryTypes[c.RetryCount] == RetryType.Edit)
                     {
-                        Console.WriteLine("second");
+                        Console.WriteLine($"second {c.RetryCount}");
 
-                        var results = await GetAllFailedMessage(ServiceControlInstanceName,
-                            FailedMessageStatus.Unresolved);
+                        var results = await GetAllFailedMessage(ServiceControlInstanceName, FailedMessageStatus.Unresolved);
                         if (!results.HasResult)
                         {
                             return false; // No failed messages yet
                         }
 
-                        Console.WriteLine("third");
+                        Console.WriteLine($"third {c.RetryCount}");
 
                         var result = results.Items.Single();
 
@@ -63,13 +73,13 @@ await Define<MyContext>()
                     var failedMessage = await GetFailedMessage(c.UniqueMessageId, ServiceControlInstanceName, FailedMessageStatus.Unresolved);
                     if (!failedMessage.HasResult)
                     {
-                        Console.WriteLine("fourth");
+                        Console.WriteLine($"fourth {c.RetryCount}");
                         return false; // No failed message yet
                     }
 
                     if (retryTypes[c.RetryCount] == RetryType.Edit)
                     {
-                        Console.WriteLine("fifth");
+                        Console.WriteLine($"fifth {c.RetryCount} Post edit id: {failedMessage.Item.UniqueMessageId}");
 
                         await this.Post<object>($"/api/edit/{failedMessage.Item.UniqueMessageId}",
                             new
@@ -81,13 +91,12 @@ await this.Post<object>($"/api/edit/{failedMessage.Item.UniqueMessageId}",
                     }
                     else
                     {
-                        Console.WriteLine("sixth");
+                        Console.WriteLine($"sixth {c.RetryCount} post retry id: {failedMessage.Item.UniqueMessageId}");
 
-                        await this.Post<object>($"/api/errors/{failedMessage.Item.UniqueMessageId}/retry", null, null,
-                            ServiceControlInstanceName);
+                        await this.Post<object>($"/api/errors/{failedMessage.Item.UniqueMessageId}/retry", null, null, ServiceControlInstanceName);
                     }
 
-                    Console.WriteLine("seventh");
+                    Console.WriteLine($"seventh {c.RetryCount}");
                     c.RetryCount++;
 
                     return false;
@@ -100,8 +109,7 @@ class FailureEndpoint : EndpointConfigurationBuilder
         {
             public FailureEndpoint() => EndpointSetup<DefaultServerWithoutAudit>(c => { c.NoRetries(); });
 
-            public class MyMessageHandler(MyContext testContext, IReadOnlySettings settings)
-                : IHandleMessages<MyMessage>
+            public class MyMessageHandler(MyContext testContext, IReadOnlySettings settings) : IHandleMessages<MyMessage>
             {
                 public Task Handle(MyMessage message, IMessageHandlerContext context)
                 {
@@ -133,6 +141,7 @@ class MyContext : ScenarioContext
             public string EndpointNameOfReceivingEndpoint { get; set; }
 
             public string UniqueMessageId => DeterministicGuid.MakeId(MessageId, EndpointNameOfReceivingEndpoint).ToString();
+
             public int RetryCount { get; set; }
         }
     }