From e91fd30a57d6a4ccc5c6c0e749bb82abe1ac9684 Mon Sep 17 00:00:00 2001
From: Lee Wright <258036@NTTDATA.COM>
Date: Tue, 2 Jul 2024 16:20:24 -0700
Subject: [PATCH] Change log

---
 backend/DIAMCornetService/Services/CornetService.cs | 13 ++++---------
 1 file changed, 4 insertions(+), 9 deletions(-)

diff --git a/backend/DIAMCornetService/Services/CornetService.cs b/backend/DIAMCornetService/Services/CornetService.cs
index 26fea56b..9da87860 100644
--- a/backend/DIAMCornetService/Services/CornetService.cs
+++ b/backend/DIAMCornetService/Services/CornetService.cs
@@ -6,7 +6,7 @@ namespace DIAMCornetService.Services;
 using DIAMCornetService.Exceptions;
 using DIAMCornetService.Models;
 
-public class CornetService(ILogger logger, IKafkaProducer<string, ParticipantCSNumberModel> producer, DIAMCornetServiceConfiguration cornetServiceConfiguration, ICornetORDSClient cornetORDSClient) : ICornetService
+public class CornetService(IKafkaProducer<string, ParticipantCSNumberModel> producer, DIAMCornetServiceConfiguration cornetServiceConfiguration, ICornetORDSClient cornetORDSClient) : ICornetService
 {
 
     /// <summary>
@@ -62,7 +62,7 @@ public async Task<ParticipantCSNumberModel> GetParticipantCSNumberAsync(string p
                     break;
 
                 default:
-                    logger.LogWarning($"Participant {participantId} unhandled response returned {response.ErrorMessage}");
+                    logger.LogWarning($"Participant {participantId} unhandled response returned {responseModel.ErrorMessage}");
                     responseModel.ErrorMessage = "Participant {participantId} unhandled response returned {response.ErrorMessage}";
                     responseModel.ErrorType = CornetCSNumberErrorType.unknownResponseError;
                     break;
@@ -98,7 +98,7 @@ public async Task<Dictionary<string, string>> PublishCSNumberResponseAsync(strin
 
             if (response.Status != PersistenceStatus.Persisted)
             {
-                CornetServiceLogging.FailedToPublishCSNumberMapping(logger, new DIAMKafkaException($"Failed to publish cs number mapping for {guid.ToString()} Part: {csNumberLookupResponse.ParticipantId} CSNumber: {csNumberLookupResponse.CSNumber}"));
+                logger.LogError($"Failed to publish CS number lookup to topic for {participantId}");
                 throw new DIAMKafkaException($"Failed to publish cs number mapping for {guid.ToString()} Part: {csNumberLookupResponse.ParticipantId} CSNumber: {csNumberLookupResponse.CSNumber}");
             }
             else
@@ -112,7 +112,7 @@ public async Task<Dictionary<string, string>> PublishCSNumberResponseAsync(strin
         }
         catch (Exception ex)
         {
-            CornetLoggingExtensions.FailedToPublishNotification(logger, participantId);
+            logger.LogError($"Failed to publish CS number lookup to topic for {participantId} [{ex.Message}]");
             throw;
         }
     }
@@ -142,8 +142,3 @@ public async Task<int> SubmitNotificationToEServices(string csNumber, string mes
 
 }
 
-public static partial class CornetLoggingExtensions
-{
-    [LoggerMessage(1, LogLevel.Error, "Failed to publish cs number mapping for participant {ParticipantId}", EventName = "PublishError")]
-    public static partial void FailedToPublishNotification(ILogger logger, string ParticipantId);
-}