From a2ebaf710b9fb4704ad6ad4030529f310c3349e5 Mon Sep 17 00:00:00 2001
From: ilitirit <ilitirit@gmail.com>
Date: Wed, 12 Apr 2023 02:12:24 +0200
Subject: [PATCH] Add logging message

---
 Expedience.Api/Consumers/DutyCompletionResultConsumer.cs | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs b/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs
index 6d288d0..d487ff9 100644
--- a/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs
+++ b/Expedience.Api/Consumers/DutyCompletionResultConsumer.cs
@@ -7,17 +7,20 @@ namespace Expedience.Api.Consumers
 {
     public class DutyCompletionResultConsumer : IConsumer<Models.DutyCompletionResult>
     {
+        private readonly ILogger<DutyCompletionResultConsumer> _logger;
         private readonly IServiceScopeFactory _serviceScopeFactory;
 
-        public DutyCompletionResultConsumer(IServiceScopeFactory serviceScopeFactory)
+        public DutyCompletionResultConsumer(ILogger<DutyCompletionResultConsumer> logger,
+            IServiceScopeFactory serviceScopeFactory)
         {
+            _logger = logger;
             _serviceScopeFactory = serviceScopeFactory;
         }
 
         public async Task Consume(ConsumeContext<Models.DutyCompletionResult> context)
         {
             var message = context.Message;
-
+            
             using var scope = _serviceScopeFactory.CreateScope();
             var dbContext = scope.ServiceProvider.GetRequiredService<ExpedienceContext>();
             
@@ -97,6 +100,8 @@ namespace Expedience.Api.Consumers
             dbContext.DutyMembers.AddRange(dutyMembers);
 
             await dbContext.SaveChangesAsync();
+
+            _logger.LogInformation("Consumed message {uploadId} from user {userId}", message.UploadId, userHash);
         }
     }
 }