Skip to content

Commit 219a501

Browse files
chiaramapellimtchiaramapellimt
committed
# This is a combination of 2 commits.
# This is the 1st commit message: NIAD-1136 remove lenient and refactor # This is the commit message #2: Restore main for test while I debug docker
1 parent 9a08319 commit 219a501

34 files changed

+1429
-709
lines changed

‎service/build.gradle‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,7 @@ dependencies {
8585
testImplementation 'com.squareup.okhttp3:okhttp:5.3.0'
8686
testImplementation 'com.squareup.okhttp3:mockwebserver3:5.3.0'
8787
testImplementation 'com.adobe.testing:s3mock-testcontainers:4.7.0'
88+
testImplementation 'org.mockito:mockito-inline:4.8.0'
8889

8990
spotbugs 'com.github.spotbugs:spotbugs:4.9.8'
9091
spotbugs 'com.github.spotbugs:spotbugs-annotations:4.9.8'

‎service/src/intTest/java/uk/nhs/adaptors/gp2gp/ehr/IllogicalMessageComponentTest.java‎

Lines changed: 26 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
import static org.assertj.core.api.Assertions.assertThat;
66
import static org.junit.jupiter.api.Assertions.assertFalse;
77
import static org.mockito.ArgumentMatchers.any;
8-
import static org.mockito.Mockito.lenient;
98
import static org.mockito.Mockito.never;
109
import static org.mockito.Mockito.verify;
1110
import static org.mockito.Mockito.when;
@@ -158,17 +157,16 @@ public void When_AcknowledgementReceivedOutOfOrderAcknowledgmentNotSent_Expect_E
158157
@Test
159158
public void When_DuplicateEhrRequestReceived_Expect_SkippedNoDatabaseUpdated() {
160159
var ehrExtractStatus = EhrExtractStatusTestUtils.prepareEhrExtractStatus();
161-
ehrExtractStatusRepository.save(ehrExtractStatus);
162-
163-
String requestPayload = asString(requestResponsePayload);
164-
String requestEbxml = asString(requestResponseEbxml);
165-
166-
mockEhrRequest(requestEbxml, requestPayload, EHR_EXTRACT_REQUEST, ehrExtractStatus.getConversationId());
167160

161+
ehrExtractStatusRepository.save(ehrExtractStatus);
168162
inboundMessageHandler.handle(message);
169-
var firstEhrStatus = ehrExtractStatusRepository.findByConversationId(ehrExtractStatus.getConversationId()).get();
163+
164+
var firstEhrStatus =
165+
ehrExtractStatusRepository.findByConversationId(ehrExtractStatus.getConversationId()).get();
170166
inboundMessageHandler.handle(message);
171-
var secondEhrStatus = ehrExtractStatusRepository.findByConversationId(ehrExtractStatus.getConversationId()).get();
167+
168+
var secondEhrStatus =
169+
ehrExtractStatusRepository.findByConversationId(ehrExtractStatus.getConversationId()).get();
172170

173171
assertThat(firstEhrStatus.getUpdatedAt()).isEqualTo(secondEhrStatus.getUpdatedAt());
174172
verify(taskDispatcher, never()).createTask(any());
@@ -220,9 +218,6 @@ public void When_DuplicateAcknowledgementSentTwice_Expect_SkippedNoDatabaseUpdat
220218
@Test
221219
@SneakyThrows
222220
public void When_UnsupportedMessageSent_Expect_ErrorThrown() {
223-
String incomingMessage = null;
224-
lenient().when(objectMapper.readValue(incomingMessage, InboundMessage.class)).thenReturn(inboundMessage);
225-
226221
assertFalse(inboundMessageHandler.handle(message));
227222

228223
verify(taskDispatcher, never()).createTask(any());
@@ -231,27 +226,27 @@ public void When_UnsupportedMessageSent_Expect_ErrorThrown() {
231226
@SneakyThrows
232227
private void mockEhrRequest(String ebxml, String payload, String interactionId, String conversationId) {
233228
String incomingMessage = null;
234-
lenient().when(objectMapper.readValue(incomingMessage, InboundMessage.class)).thenReturn(inboundMessage);
235-
lenient().when(inboundMessage.getEbXML()).thenReturn(ebxml);
236-
lenient().when(inboundMessage.getPayload()).thenReturn(payload);
229+
when(objectMapper.readValue(incomingMessage, InboundMessage.class)).thenReturn(inboundMessage);
230+
when(inboundMessage.getEbXML()).thenReturn(ebxml);
231+
when(inboundMessage.getPayload()).thenReturn(payload);
237232

238233
var ebxmlDocument = SERVICE.parseDocumentFromXml(ebxml);
239-
lenient().when(xPathService.parseDocumentFromXml(inboundMessage.getEbXML())).thenReturn(ebxmlDocument);
234+
when(xPathService.parseDocumentFromXml(inboundMessage.getEbXML())).thenReturn(ebxmlDocument);
240235
var payloadDocument = SERVICE.parseDocumentFromXml(payload);
241-
lenient().when(xPathService.parseDocumentFromXml(inboundMessage.getPayload())).thenReturn(payloadDocument);
242-
243-
lenient().when(xPathService.getNodeValue(ebxmlDocument, ACTION_PATH)).thenReturn(interactionId);
244-
lenient().when(xPathService.getNodeValue(ebxmlDocument, CONVERSATION_ID_PATH)).thenReturn(conversationId);
245-
246-
lenient().when(xPathService.getNodeValue(payloadDocument, REQUEST_ID_PATH)).thenReturn("123");
247-
lenient().when(xPathService.getNodeValue(payloadDocument, NHS_NUMBER_PATH)).thenReturn("123");
248-
lenient().when(xPathService.getNodeValue(ebxmlDocument, FROM_PARTY_ID_PATH)).thenReturn("123");
249-
lenient().when(xPathService.getNodeValue(ebxmlDocument, TO_PARTY_ID_PATH)).thenReturn("123");
250-
lenient().when(xPathService.getNodeValue(payloadDocument, FROM_ASID_PATH)).thenReturn("123");
251-
lenient().when(xPathService.getNodeValue(payloadDocument, TO_ASID_PATH)).thenReturn("123");
252-
lenient().when(xPathService.getNodeValue(payloadDocument, FROM_ODS_CODE_PATH)).thenReturn("123");
253-
lenient().when(xPathService.getNodeValue(payloadDocument, TO_ODS_CODE_PATH)).thenReturn("123");
254-
lenient().when(xPathService.getNodeValue(ebxmlDocument, MESSAGE_ID_PATH)).thenReturn("123");
236+
when(xPathService.parseDocumentFromXml(inboundMessage.getPayload())).thenReturn(payloadDocument);
237+
238+
when(xPathService.getNodeValue(ebxmlDocument, ACTION_PATH)).thenReturn(interactionId);
239+
when(xPathService.getNodeValue(ebxmlDocument, CONVERSATION_ID_PATH)).thenReturn(conversationId);
240+
241+
when(xPathService.getNodeValue(payloadDocument, REQUEST_ID_PATH)).thenReturn("123");
242+
when(xPathService.getNodeValue(payloadDocument, NHS_NUMBER_PATH)).thenReturn("123");
243+
when(xPathService.getNodeValue(ebxmlDocument, FROM_PARTY_ID_PATH)).thenReturn("123");
244+
when(xPathService.getNodeValue(ebxmlDocument, TO_PARTY_ID_PATH)).thenReturn("123");
245+
when(xPathService.getNodeValue(payloadDocument, FROM_ASID_PATH)).thenReturn("123");
246+
when(xPathService.getNodeValue(payloadDocument, TO_ASID_PATH)).thenReturn("123");
247+
when(xPathService.getNodeValue(payloadDocument, FROM_ODS_CODE_PATH)).thenReturn("123");
248+
when(xPathService.getNodeValue(payloadDocument, TO_ODS_CODE_PATH)).thenReturn("123");
249+
when(xPathService.getNodeValue(ebxmlDocument, MESSAGE_ID_PATH)).thenReturn("123");
255250
}
256251

257252
private static String asString(Resource resource) {
@@ -264,20 +259,11 @@ private static String asString(Resource resource) {
264259

265260
@SneakyThrows
266261
private void mockIncomingMessage(String ebxml, String payload, String interactionId, String conversationId) {
267-
String incomingMessage = null;
268-
lenient().when(objectMapper.readValue(incomingMessage, InboundMessage.class)).thenReturn(inboundMessage);
269-
lenient().when(inboundMessage.getEbXML()).thenReturn(ebxml);
270-
lenient().when(inboundMessage.getPayload()).thenReturn(payload);
271-
272-
var ebxmlDocument = SERVICE.parseDocumentFromXml(ebxml);
273-
lenient().when(xPathService.parseDocumentFromXml(inboundMessage.getEbXML())).thenReturn(ebxmlDocument);
274-
lenient().when(xPathService.getNodeValue(ebxmlDocument, ACTION_PATH)).thenReturn(interactionId);
275-
lenient().when(xPathService.getNodeValue(ebxmlDocument, CONVERSATION_ID_PATH)).thenReturn(conversationId);
262+
SERVICE.parseDocumentFromXml(ebxml);
276263
}
277264

278265
@SneakyThrows
279266
private void mockAcknowledgementMessage(String ebxml, String payload, String interactionId, String conversationId) {
280-
when(xPathService.getNodeValue(any(), any())).thenReturn(ACK_OK_CODE);
281267
mockIncomingMessage(ebxml, payload, interactionId, conversationId);
282268
}
283269
}

‎service/src/intTest/java/uk/nhs/adaptors/gp2gp/ehr/SendAcknowledgementComponentTest.java‎

Lines changed: 53 additions & 53 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@
4040
@ExtendWith({SpringExtension.class, MongoDBExtension.class, ActiveMQExtension.class, MockitoExtension.class})
4141
@DirtiesContext
4242
@SpringBootTest(properties = {
43-
"command.line.runner.enabled=false"})
43+
"command.line.runner.enabled=false"})
4444
public class SendAcknowledgementComponentTest {
4545
private static final String GENERATED_RANDOM_ID = "GENERATED-RANDOM-ID";
4646
private static final String FROM_ASID = "0000222-from-asid";
@@ -113,26 +113,26 @@ public void When_AcknowledgementTaskRunsTwice_Expect_DatabaseOverwritesEhrExtrac
113113
@Test
114114
public void When_NegativeAcknowledgementTaskExecuted_Expect_ValidRequestSentToMhs() {
115115
var taskDefinition =
116-
SendAcknowledgementTaskDefinition.builder()
117-
.fromAsid(FROM_ASID)
118-
.toAsid(TO_ASID)
119-
.fromOdsCode(FROM_ODS_CODE)
120-
.toOdsCode(TO_ODS_CODE)
121-
.ehrRequestMessageId(EHR_REQUEST_MESSAGE_ID)
122-
.reasonCode(REASON_CODE)
123-
.detail(REASON_MESSAGE)
124-
.conversationId(EhrStatusConstants.CONVERSATION_ID)
125-
.taskId(TASK_ID)
126-
.typeCode(NEGATIVE_ACK_TYPE_CODE)
127-
.build();
116+
SendAcknowledgementTaskDefinition.builder()
117+
.fromAsid(FROM_ASID)
118+
.toAsid(TO_ASID)
119+
.fromOdsCode(FROM_ODS_CODE)
120+
.toOdsCode(TO_ODS_CODE)
121+
.ehrRequestMessageId(EHR_REQUEST_MESSAGE_ID)
122+
.reasonCode(REASON_CODE)
123+
.detail(REASON_MESSAGE)
124+
.conversationId(EhrStatusConstants.CONVERSATION_ID)
125+
.taskId(TASK_ID)
126+
.typeCode(NEGATIVE_ACK_TYPE_CODE)
127+
.build();
128128

129129
sendAcknowledgementExecutor.execute(taskDefinition);
130130

131131
verify(mhsRequestBuilder).buildSendAcknowledgementRequest(
132-
asString(expectedNackMessage), FROM_ODS_CODE, EhrStatusConstants.CONVERSATION_ID, GENERATED_RANDOM_ID);
132+
asString(expectedNackMessage), FROM_ODS_CODE, EhrStatusConstants.CONVERSATION_ID, GENERATED_RANDOM_ID);
133133

134134
EhrExtractStatus updatedEhrExtractStatus =
135-
ehrExtractStatusRepository.findByConversationId(EhrStatusConstants.CONVERSATION_ID).get();
135+
ehrExtractStatusRepository.findByConversationId(EhrStatusConstants.CONVERSATION_ID).get();
136136
EhrExtractStatus.AckToRequester ackToRequester = updatedEhrExtractStatus.getAckToRequester();
137137
assertThat(ackToRequester.getTaskId()).isEqualTo(TASK_ID);
138138
assertThat(ackToRequester.getMessageId()).isEqualTo(GENERATED_RANDOM_ID);
@@ -144,24 +144,24 @@ public void When_NegativeAcknowledgementTaskExecuted_Expect_ValidRequestSentToMh
144144
@Test
145145
public void When_PositiveAcknowledgementTaskExecuted_Expect_ValidRequestSentToMhs() {
146146
var taskDefinition =
147-
SendAcknowledgementTaskDefinition.builder()
148-
.fromAsid(FROM_ASID)
149-
.toAsid(TO_ASID)
150-
.fromOdsCode(FROM_ODS_CODE)
151-
.toOdsCode(TO_ODS_CODE)
152-
.ehrRequestMessageId(EHR_REQUEST_MESSAGE_ID)
153-
.conversationId(EhrStatusConstants.CONVERSATION_ID)
154-
.taskId(TASK_ID)
155-
.typeCode(POSITIVE_ACK_TYPE_CODE)
156-
.build();
147+
SendAcknowledgementTaskDefinition.builder()
148+
.fromAsid(FROM_ASID)
149+
.toAsid(TO_ASID)
150+
.fromOdsCode(FROM_ODS_CODE)
151+
.toOdsCode(TO_ODS_CODE)
152+
.ehrRequestMessageId(EHR_REQUEST_MESSAGE_ID)
153+
.conversationId(EhrStatusConstants.CONVERSATION_ID)
154+
.taskId(TASK_ID)
155+
.typeCode(POSITIVE_ACK_TYPE_CODE)
156+
.build();
157157

158158
sendAcknowledgementExecutor.execute(taskDefinition);
159159

160160
verify(mhsRequestBuilder).buildSendAcknowledgementRequest(
161-
asString(expectedAckMessage), FROM_ODS_CODE, EhrStatusConstants.CONVERSATION_ID, GENERATED_RANDOM_ID);
161+
asString(expectedAckMessage), FROM_ODS_CODE, EhrStatusConstants.CONVERSATION_ID, GENERATED_RANDOM_ID);
162162

163163
EhrExtractStatus updatedEhrExtractStatus =
164-
ehrExtractStatusRepository.findByConversationId(EhrStatusConstants.CONVERSATION_ID).get();
164+
ehrExtractStatusRepository.findByConversationId(EhrStatusConstants.CONVERSATION_ID).get();
165165
EhrExtractStatus.AckToRequester ackToRequester = updatedEhrExtractStatus.getAckToRequester();
166166
assertThat(ackToRequester.getTaskId()).isEqualTo(TASK_ID);
167167
assertThat(ackToRequester.getMessageId()).isEqualTo(GENERATED_RANDOM_ID);
@@ -173,51 +173,51 @@ public void When_PositiveAcknowledgementTaskExecuted_Expect_ValidRequestSentToMh
173173
@Test
174174
public void When_SendAckTaskExecuted_WithMhsConnectionException_Expect_ExceptionThrownAndDbNotUpdated() {
175175
var taskDefinition =
176-
SendAcknowledgementTaskDefinition.builder()
177-
.fromAsid(FROM_ASID)
178-
.toAsid(TO_ASID)
179-
.fromOdsCode(FROM_ODS_CODE)
180-
.toOdsCode(TO_ODS_CODE)
181-
.ehrRequestMessageId(EHR_REQUEST_MESSAGE_ID)
182-
.conversationId(EhrStatusConstants.CONVERSATION_ID)
183-
.taskId(TASK_ID)
184-
.typeCode(POSITIVE_ACK_TYPE_CODE)
185-
.build();
176+
SendAcknowledgementTaskDefinition.builder()
177+
.fromAsid(FROM_ASID)
178+
.toAsid(TO_ASID)
179+
.fromOdsCode(FROM_ODS_CODE)
180+
.toOdsCode(TO_ODS_CODE)
181+
.ehrRequestMessageId(EHR_REQUEST_MESSAGE_ID)
182+
.conversationId(EhrStatusConstants.CONVERSATION_ID)
183+
.taskId(TASK_ID)
184+
.typeCode(POSITIVE_ACK_TYPE_CODE)
185+
.build();
186186

187187
doThrow(MhsConnectionException.class).when(mhsClient).sendMessageToMHS(any());
188188

189189
assertThatExceptionOfType(MhsConnectionException.class)
190-
.isThrownBy(() -> sendAcknowledgementExecutor.execute(taskDefinition));
190+
.isThrownBy(() -> sendAcknowledgementExecutor.execute(taskDefinition));
191191

192192
var updatedEhrExtractStatus = ehrExtractStatusRepository
193-
.findByConversationId(EhrStatusConstants.CONVERSATION_ID)
194-
.orElseThrow();
193+
.findByConversationId(EhrStatusConstants.CONVERSATION_ID)
194+
.orElseThrow();
195195

196196
assertThat(updatedEhrExtractStatus.getAckToRequester()).isNull();
197197
}
198198

199199
@Test
200200
public void When_SendAckTaskExecuted_WithMhsServerErrorException_Expect_ExceptionThrownAndDbNotUpdated() {
201201
var taskDefinition =
202-
SendAcknowledgementTaskDefinition.builder()
203-
.fromAsid(FROM_ASID)
204-
.toAsid(TO_ASID)
205-
.fromOdsCode(FROM_ODS_CODE)
206-
.toOdsCode(TO_ODS_CODE)
207-
.ehrRequestMessageId(EHR_REQUEST_MESSAGE_ID)
208-
.conversationId(EhrStatusConstants.CONVERSATION_ID)
209-
.taskId(TASK_ID)
210-
.typeCode(POSITIVE_ACK_TYPE_CODE)
211-
.build();
202+
SendAcknowledgementTaskDefinition.builder()
203+
.fromAsid(FROM_ASID)
204+
.toAsid(TO_ASID)
205+
.fromOdsCode(FROM_ODS_CODE)
206+
.toOdsCode(TO_ODS_CODE)
207+
.ehrRequestMessageId(EHR_REQUEST_MESSAGE_ID)
208+
.conversationId(EhrStatusConstants.CONVERSATION_ID)
209+
.taskId(TASK_ID)
210+
.typeCode(POSITIVE_ACK_TYPE_CODE)
211+
.build();
212212

213213
doThrow(MhsServerErrorException.class).when(mhsClient).sendMessageToMHS(any());
214214

215215
assertThatExceptionOfType(MhsServerErrorException.class)
216-
.isThrownBy(() -> sendAcknowledgementExecutor.execute(taskDefinition));
216+
.isThrownBy(() -> sendAcknowledgementExecutor.execute(taskDefinition));
217217

218218
var updatedEhrExtractStatus = ehrExtractStatusRepository
219-
.findByConversationId(EhrStatusConstants.CONVERSATION_ID)
220-
.orElseThrow();
219+
.findByConversationId(EhrStatusConstants.CONVERSATION_ID)
220+
.orElseThrow();
221221

222222
assertThat(updatedEhrExtractStatus.getAckToRequester()).isNull();
223223
}

‎service/src/intTest/java/uk/nhs/adaptors/gp2gp/ehr/TaskHandlingTest.java‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44
import static org.mockito.ArgumentMatchers.any;
55
import static org.mockito.Mockito.doReturn;
66
import static org.mockito.Mockito.doThrow;
7-
import static org.mockito.Mockito.lenient;
87
import static org.mockito.Mockito.never;
98
import static org.mockito.Mockito.verify;
109
import static org.mockito.Mockito.verifyNoInteractions;
@@ -73,7 +72,7 @@ public class TaskHandlingTest {
7372

7473
@BeforeEach
7574
public void setup() {
76-
lenient().doReturn(taskExecutor).when(taskExecutorFactory).getTaskExecutor(any());
75+
doReturn(taskExecutor).when(taskExecutorFactory).getTaskExecutor(any());
7776
}
7877

7978
@Test

0 commit comments

Comments
 (0)