feat: DTOSS-8352 removed coments

Author: sudipnhs

application/CohortManager/src/Functions/NemsSubscriptionService/ProcessNemsUpdate/ProcessNemsUpdate.cs

@@ -69,7 +69,6 @@ public async Task Run([BlobTrigger("nems-updates/{name}", Connection = "nemsmesh
                 return;
             }
 
-            //Validate NHS Number
             if (!ValidationHelper.ValidateNHSNumber(nhsNumber))
             {
                 throw new InvalidDataException("Invalid NHS Number");
@@ -183,7 +182,6 @@ private async Task ProcessRecord(PdsDemographic pdsDemographic)
 
         // TODO validate all dates in record before enqueuing
 
-        // Check participant exists in Participant Demographic table.
         var existingParticipant = await _participantDemographic.GetSingleByFilter(x => x.NhsNumber == nhsNumberLong);
         if (existingParticipant == null)
         {

tests/UnitTests/NemsSubscriptionServiceTests/ProcessNemsUpdateTests/ProcessNemsUpdateTests.cs

@@ -420,7 +420,6 @@ public async Task Run_NhsNumberFromNemsUpdateFileDoesNotMatchRetrievedPdsRecordN
         _httpClientFunctionMock.Setup(x => x.SendGet("RetrievePdsDemographic", It.IsAny<Dictionary<string, string>>()))
             .ReturnsAsync(JsonSerializer.Serialize(new PdsDemographic() { NhsNumber = supersededNhsNumber }));
 
-        // Mock the participant demographic check to return null (participant doesn't exist)
         _participantDemographicMock.Setup(x => x.GetSingleByFilter(It.IsAny<Expression<Func<ParticipantDemographic, bool>>>()))
             .ReturnsAsync((ParticipantDemographic)null);
 
@@ -431,13 +430,11 @@ public async Task Run_NhsNumberFromNemsUpdateFileDoesNotMatchRetrievedPdsRecordN
         _fhirPatientDemographicMapperMock.Verify(x => x.ParseFhirJsonNhsNumber(It.IsAny<string>()), Times.Once);
         _httpClientFunctionMock.Verify(x => x.SendGet("RetrievePdsDemographic", It.IsAny<Dictionary<string, string>>()), Times.Once);
 
-        //participant demographic check
         _participantDemographicMock.Verify(x => x.GetSingleByFilter(
             It.Is<Expression<Func<ParticipantDemographic, bool>>>(expr =>
                 expr.Compile()(new ParticipantDemographic { NhsNumber = long.Parse(_validNhsNumber) }))),
             Times.Once);
 
-        // Verify logging for new participant case
         _loggerMock.Verify(x => x.Log(
             LogLevel.Warning,
             It.IsAny<EventId>(),
@@ -446,7 +443,6 @@ public async Task Run_NhsNumberFromNemsUpdateFileDoesNotMatchRetrievedPdsRecordN
             It.IsAny<Func<It.IsAnyType, Exception?, string>>()),
         Times.Once);
 
-        // Verify the record type was set to New
         _addBatchToQueueMock.Verify(x => x.ProcessBatch(
             It.Is<ConcurrentQueue<BasicParticipantCsvRecord>>(q =>
                 q.Any(r => r.Participant.RecordType == Actions.New)),
@@ -494,7 +490,6 @@ public async Task Run_NhsNumberFromNemsUpdateFileDoesNotMatchRetrievedPdsRecordN
         _httpClientFunctionMock.Setup(x => x.SendGet("RetrievePdsDemographic", It.IsAny<Dictionary<string, string>>()))
             .ReturnsAsync(JsonSerializer.Serialize(new PdsDemographic() { NhsNumber = supersededNhsNumber }));
 
-        // Mock the participant demographic check to return an existing participant
         var existingParticipant = new ParticipantDemographic { NhsNumber = long.Parse(_validNhsNumber) };
         _participantDemographicMock.Setup(x => x.GetSingleByFilter(It.IsAny<Expression<Func<ParticipantDemographic, bool>>>()))
             .ReturnsAsync(existingParticipant);
@@ -506,13 +501,11 @@ public async Task Run_NhsNumberFromNemsUpdateFileDoesNotMatchRetrievedPdsRecordN
         _fhirPatientDemographicMapperMock.Verify(x => x.ParseFhirJsonNhsNumber(It.IsAny<string>()), Times.Once);
         _httpClientFunctionMock.Verify(x => x.SendGet("RetrievePdsDemographic", It.IsAny<Dictionary<string, string>>()), Times.Once);
 
-        // Verify participant demographic check was called
         _participantDemographicMock.Verify(x => x.GetSingleByFilter(
             It.Is<Expression<Func<ParticipantDemographic, bool>>>(expr =>
                 expr.Compile()(existingParticipant))),
             Times.Once);
 
-        // Verify logging for EXISTING participant case
         _loggerMock.Verify(x => x.Log(
             LogLevel.Warning,
             It.IsAny<EventId>(),
@@ -521,14 +514,12 @@ public async Task Run_NhsNumberFromNemsUpdateFileDoesNotMatchRetrievedPdsRecordN
             It.IsAny<Func<It.IsAnyType, Exception?, string>>()),
         Times.Once);
 
-        // Verify the record type was set to Amended (not New)
         _addBatchToQueueMock.Verify(x => x.ProcessBatch(
             It.Is<ConcurrentQueue<BasicParticipantCsvRecord>>(q =>
                 q.Any(r => r.Participant.RecordType == Actions.Amended)),
             It.IsAny<string>()),
         Times.Once);
 
-        // Verify superseded record processing
         _loggerMock.Verify(x => x.Log(
             LogLevel.Information,
             It.IsAny<EventId>(),
@@ -537,7 +528,6 @@ public async Task Run_NhsNumberFromNemsUpdateFileDoesNotMatchRetrievedPdsRecordN
             It.IsAny<Func<It.IsAnyType, Exception?, string>>()),
         Times.Once);
 
-        // Verify NEMS unsubscribe
         _loggerMock.Verify(x => x.Log(
             LogLevel.Information,
             It.IsAny<EventId>(),
@@ -549,7 +539,6 @@ public async Task Run_NhsNumberFromNemsUpdateFileDoesNotMatchRetrievedPdsRecordN
         _httpClientFunctionMock.Verify(x => x.SendPost("Unsubscribe", It.IsAny<string>()), Times.Once);
         _addBatchToQueueMock.Verify(queue => queue.ProcessBatch(It.IsAny<ConcurrentQueue<BasicParticipantCsvRecord>>(), It.IsAny<string>()), Times.Once);
 
-        // Verify exception handler was called for superseded case
         _exceptionHandlerMock.Verify(
             x => x.CreateTransformExecutedExceptions(
                 It.Is<CohortDistributionParticipant>(p =>