diff options
Diffstat (limited to 'participant/participant-intermediary/src/test')
| -rw-r--r-- | participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AcDefinitionHandlerTest.java | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AcDefinitionHandlerTest.java b/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AcDefinitionHandlerTest.java index c6259a28f..d72f5deea 100644 --- a/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AcDefinitionHandlerTest.java +++ b/participant/participant-intermediary/src/test/java/org/onap/policy/clamp/acm/participant/intermediary/handler/AcDefinitionHandlerTest.java @@ -35,6 +35,7 @@ import org.onap.policy.clamp.acm.participant.intermediary.comm.ParticipantMessag import org.onap.policy.clamp.acm.participant.intermediary.main.parameters.CommonTestData; import org.onap.policy.clamp.models.acm.concepts.AcTypeState; import org.onap.policy.clamp.models.acm.concepts.ParticipantDefinition; +import org.onap.policy.clamp.models.acm.concepts.StateChangeResult; import org.onap.policy.clamp.models.acm.messages.kafka.participant.ParticipantPrime; import org.onap.policy.clamp.models.acm.messages.kafka.participant.ParticipantPrimeAck; import org.onap.policy.clamp.models.acm.messages.kafka.participant.ParticipantSync; @@ -110,6 +111,28 @@ class AcDefinitionHandlerTest { } @Test + void syncCompositionDefinitionTimeout() { + var participantSyncMsg = new ParticipantSync(); + participantSyncMsg.setState(AcTypeState.PRIMED); + participantSyncMsg.setStateChangeResult(StateChangeResult.TIMEOUT); + participantSyncMsg.setCompositionId(UUID.randomUUID()); + participantSyncMsg.getParticipantDefinitionUpdates().add(createParticipantDefinition()); + var participantRestartAc = CommonTestData.createParticipantRestartAc(); + participantRestartAc.setStateChangeResult(StateChangeResult.TIMEOUT); + participantSyncMsg.setAutomationcompositionList(List.of(participantRestartAc)); + + var cacheProvider = mock(CacheProvider.class); + var listener = mock(ThreadHandler.class); + var ach = new AcDefinitionHandler(cacheProvider, mock(ParticipantMessagePublisher.class), listener); + ach.handleParticipantSync(participantSyncMsg); + verify(cacheProvider).initializeAutomationComposition(any(UUID.class), any()); + verify(cacheProvider).addElementDefinition(any(), any()); + verify(listener).cleanExecution(participantSyncMsg.getCompositionId(), participantSyncMsg.getMessageId()); + var elementId = participantRestartAc.getAcElementList().get(0).getId(); + verify(listener).cleanExecution(elementId, participantSyncMsg.getMessageId()); + } + + @Test void syncDeleteTest() { var participantSyncMsg = new ParticipantSync(); participantSyncMsg.setState(AcTypeState.COMMISSIONED); |