Merge pull request #219 from clickviewapp/QueueHostedService-logscope

Add LogScope to QueueHostedService to add the message id

src/Hosting/Queue/src/MessageContextScope.cs

@@ -0,0 +1,28 @@
+namespace ClickView.GoodStuff.Hosting.Queue;
+
+using System.Collections;
+using Queues.RabbitMq;
+
+internal class MessageContextScope<T>(MessageContext<T> context) : IReadOnlyList<KeyValuePair<string, object>>
+{
+    public IEnumerator<KeyValuePair<string, object>> GetEnumerator()
+    {
+        for (var i = 0; i < Count; ++i)
+        {
+            yield return this[i];
+        }
+    }
+
+    IEnumerator IEnumerable.GetEnumerator()
+    {
+        return GetEnumerator();
+    }
+
+    public int Count => 1;
+
+    public KeyValuePair<string, object> this[int index] => index switch
+    {
+        0 => new KeyValuePair<string, object>("MessageId", context.Id),
+        _ => throw new IndexOutOfRangeException(nameof(index)),
+    };
+}

src/Hosting/Queue/src/QueueHostedService.cs

@@ -47,6 +47,8 @@ protected override Task<SubscriptionContext> SubscribeAsync(IQueueClient queueCl
     /// <param name="cancellationToken"></param>
     private async Task OnMessageAsync(MessageContext<TMessage> messageContext, CancellationToken cancellationToken)
     {
+        using var logScope = Logger.BeginScope(new MessageContextScope<TMessage>(messageContext));
+
         Logger.QueueMessageReceived(messageContext.Id, messageContext.Timestamp);
 
         try