summaryrefslogtreecommitdiffstats
path: root/participant
diff options
context:
space:
mode:
authorFrancescoFioraEst <francesco.fiora@est.tech>2023-05-22 16:17:17 +0100
committerLiam Fallon <liam.fallon@est.tech>2023-05-23 15:25:19 +0000
commit9fab533cc8dc45a7bc0c7b9afc7eb10f0a3f1aef (patch)
treeb7ec7ee95ea2c19adb7bc8e49f6fc96b69ad3e5b /participant
parent4539ab951ef81839d38641fa09f2cbd490d71a63 (diff)
Refactor failure handling in policy-participant
In the case, a policy-participant fails to deploy an element, it should responds with UNDEPLOYED on a DEPLOY order. Issue-ID: POLICY-4695 Change-Id: I9daca4ab1311d96351bb5db4405e0f280ad4a7c6 Signed-off-by: FrancescoFioraEst <francesco.fiora@est.tech>
Diffstat (limited to 'participant')
-rw-r--r--participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java7
-rw-r--r--participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/endtoend/ParticipantMessagesTest.java41
-rw-r--r--participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java26
3 files changed, 44 insertions, 30 deletions
diff --git a/participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java b/participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java
index 627f79131..5eb997e52 100644
--- a/participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java
+++ b/participant/participant-impl/participant-impl-policy/src/main/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandler.java
@@ -154,7 +154,9 @@ public class AutomationCompositionElementHandler implements AutomationCompositio
var automationCompositionDefinition = element.getToscaServiceTemplateFragment();
if (automationCompositionDefinition.getToscaTopologyTemplate() == null) {
- throw new PfModelException(Status.BAD_REQUEST, "ToscaTopologyTemplate not defined");
+ intermediaryApi.updateAutomationCompositionElementState(automationCompositionId, element.getId(),
+ DeployState.UNDEPLOYED, null, "ToscaTopologyTemplate not defined");
+ return;
}
serviceTemplateMap.put(element.getId(), automationCompositionDefinition);
if (automationCompositionDefinition.getPolicyTypes() != null) {
@@ -174,7 +176,8 @@ public class AutomationCompositionElementHandler implements AutomationCompositio
var policyList = getPolicyList(automationCompositionDefinition);
deployPolicies(policyList, automationCompositionId, element.getId());
} else {
- throw new PfModelException(Status.BAD_REQUEST,
+ intermediaryApi.updateAutomationCompositionElementState(automationCompositionId, element.getId(),
+ DeployState.UNDEPLOYED, null,
"Creation of PolicyTypes/Policies failed. Policies will not be deployed.");
}
}
diff --git a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/endtoend/ParticipantMessagesTest.java b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/endtoend/ParticipantMessagesTest.java
index 5ba598cc8..1111f20b2 100644
--- a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/endtoend/ParticipantMessagesTest.java
+++ b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/endtoend/ParticipantMessagesTest.java
@@ -22,7 +22,6 @@
package org.onap.policy.clamp.acm.participant.policy.endtoend;
import static org.assertj.core.api.Assertions.assertThatCode;
-import static org.junit.jupiter.api.Assertions.assertEquals;
import java.time.Instant;
import java.util.Collections;
@@ -39,11 +38,9 @@ import org.onap.policy.clamp.acm.participant.policy.main.parameters.CommonTestDa
import org.onap.policy.clamp.acm.participant.policy.main.utils.TestListenerUtils;
import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantDeregister;
import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantDeregisterAck;
-import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantPrime;
import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantPrimeAck;
import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantRegister;
import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantRegisterAck;
-import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantStatus;
import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure;
import org.onap.policy.common.endpoints.event.comm.TopicSink;
import org.springframework.beans.factory.annotation.Autowired;
@@ -66,13 +63,12 @@ class ParticipantMessagesTest {
@Test
void testSendParticipantRegisterMessage() {
- final ParticipantRegister participantRegisterMsg = new ParticipantRegister();
+ final var participantRegisterMsg = new ParticipantRegister();
participantRegisterMsg.setParticipantId(CommonTestData.getParticipantId());
participantRegisterMsg.setTimestamp(Instant.now());
synchronized (lockit) {
- ParticipantMessagePublisher participantMessagePublisher =
- new ParticipantMessagePublisher();
+ var participantMessagePublisher = new ParticipantMessagePublisher();
participantMessagePublisher.active(Collections.singletonList(Mockito.mock(TopicSink.class)));
assertThatCode(() -> participantMessagePublisher.sendParticipantRegister(participantRegisterMsg))
.doesNotThrowAnyException();
@@ -81,14 +77,13 @@ class ParticipantMessagesTest {
@Test
void testReceiveParticipantRegisterAckMessage() {
- final ParticipantRegisterAck participantRegisterAckMsg = new ParticipantRegisterAck();
+ final var participantRegisterAckMsg = new ParticipantRegisterAck();
participantRegisterAckMsg.setMessage("ParticipantRegisterAck message");
participantRegisterAckMsg.setResponseTo(UUID.randomUUID());
participantRegisterAckMsg.setResult(true);
synchronized (lockit) {
- ParticipantRegisterAckListener participantRegisterAckListener =
- new ParticipantRegisterAckListener(participantHandler);
+ var participantRegisterAckListener = new ParticipantRegisterAckListener(participantHandler);
assertThatCode(() -> participantRegisterAckListener.onTopicEvent(INFRA, TOPIC, null,
participantRegisterAckMsg)).doesNotThrowAnyException();
}
@@ -96,13 +91,12 @@ class ParticipantMessagesTest {
@Test
void testSendParticipantDeregisterMessage() {
- final ParticipantDeregister participantDeregisterMsg = new ParticipantDeregister();
+ final var participantDeregisterMsg = new ParticipantDeregister();
participantDeregisterMsg.setParticipantId(CommonTestData.getParticipantId());
participantDeregisterMsg.setTimestamp(Instant.now());
synchronized (lockit) {
- ParticipantMessagePublisher participantMessagePublisher =
- new ParticipantMessagePublisher();
+ var participantMessagePublisher = new ParticipantMessagePublisher();
participantMessagePublisher.active(Collections.singletonList(Mockito.mock(TopicSink.class)));
assertThatCode(() -> participantMessagePublisher.sendParticipantDeregister(participantDeregisterMsg))
.doesNotThrowAnyException();
@@ -111,14 +105,13 @@ class ParticipantMessagesTest {
@Test
void testReceiveParticipantDeregisterAckMessage() {
- final ParticipantDeregisterAck participantDeregisterAckMsg = new ParticipantDeregisterAck();
+ final var participantDeregisterAckMsg = new ParticipantDeregisterAck();
participantDeregisterAckMsg.setMessage("ParticipantDeregisterAck message");
participantDeregisterAckMsg.setResponseTo(UUID.randomUUID());
participantDeregisterAckMsg.setResult(true);
synchronized (lockit) {
- ParticipantDeregisterAckListener participantDeregisterAckListener =
- new ParticipantDeregisterAckListener(participantHandler);
+ var participantDeregisterAckListener = new ParticipantDeregisterAckListener(participantHandler);
assertThatCode(() -> participantDeregisterAckListener.onTopicEvent(INFRA, TOPIC, null,
participantDeregisterAckMsg)).doesNotThrowAnyException();
}
@@ -126,26 +119,24 @@ class ParticipantMessagesTest {
@Test
void testReceiveParticipantUpdateMessage() {
- ParticipantPrime participantPrimeMsg = TestListenerUtils.createParticipantPrimeMsg();
+ var participantPrimeMsg = TestListenerUtils.createParticipantPrimeMsg();
synchronized (lockit) {
- ParticipantPrimeListener participantPrimeListener = new ParticipantPrimeListener(participantHandler);
- participantPrimeListener.onTopicEvent(INFRA, TOPIC, null, participantPrimeMsg);
+ var participantPrimeListener = new ParticipantPrimeListener(participantHandler);
+ assertThatCode(() -> participantPrimeListener.onTopicEvent(INFRA, TOPIC, null, participantPrimeMsg))
+ .doesNotThrowAnyException();
}
-
- // Verify the result of GET participants with what is stored
- assertEquals(CommonTestData.getParticipantId(), participantHandler.getParticipantId());
}
@Test
void testSendParticipantPrimeAckMessage() {
- final ParticipantPrimeAck participantPrimeAckMsg = new ParticipantPrimeAck();
+ final var participantPrimeAckMsg = new ParticipantPrimeAck();
participantPrimeAckMsg.setMessage("ParticipantPrimeAck message");
participantPrimeAckMsg.setResponseTo(UUID.randomUUID());
participantPrimeAckMsg.setResult(true);
synchronized (lockit) {
- ParticipantMessagePublisher participantMessagePublisher = new ParticipantMessagePublisher();
+ var participantMessagePublisher = new ParticipantMessagePublisher();
participantMessagePublisher.active(Collections.singletonList(Mockito.mock(TopicSink.class)));
assertThatCode(() -> participantMessagePublisher.sendParticipantPrimeAck(participantPrimeAckMsg))
.doesNotThrowAnyException();
@@ -154,9 +145,9 @@ class ParticipantMessagesTest {
@Test
void testParticipantStatusHeartbeat() {
- final ParticipantStatus heartbeat = participantHandler.makeHeartbeat(true);
+ final var heartbeat = participantHandler.makeHeartbeat(true);
synchronized (lockit) {
- ParticipantMessagePublisher publisher = new ParticipantMessagePublisher();
+ var publisher = new ParticipantMessagePublisher();
publisher.active(Collections.singletonList(Mockito.mock(TopicSink.class)));
assertThatCode(() -> publisher.sendHeartbeat(heartbeat)).doesNotThrowAnyException();
}
diff --git a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java
index d3b27ae10..4cf5a5847 100644
--- a/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java
+++ b/participant/participant-impl/participant-impl-policy/src/test/java/org/onap/policy/clamp/acm/participant/policy/main/handler/AutomationCompositionElementHandlerTest.java
@@ -53,7 +53,7 @@ class AutomationCompositionElementHandlerTest {
private static final ToscaConceptIdentifier DEFINITION = new ToscaConceptIdentifier(ID_NAME, ID_VERSION);
@Test
- void testHandlerUndeploy() throws PfModelException {
+ void testHandlerUndeployNoPolicy() throws PfModelException {
var handler = new AutomationCompositionElementHandler(mock(PolicyApiHttpClient.class),
mock(PolicyPapHttpClient.class));
var intermediaryApi = mock(ParticipantIntermediaryApi.class);
@@ -94,6 +94,24 @@ class AutomationCompositionElementHandlerTest {
handler.deploy(AC_ID, getTestingAcElement(), Map.of());
verify(intermediaryApi).updateAutomationCompositionElementState(AC_ID, automationCompositionElementId,
DeployState.DEPLOYED, null, "Deployed");
+
+ handler.undeploy(AC_ID, automationCompositionElementId);
+ verify(intermediaryApi).updateAutomationCompositionElementState(AC_ID, automationCompositionElementId,
+ DeployState.UNDEPLOYED, null, "Undeployed");
+ }
+
+ @Test
+ void testDeployNoPolicy() throws PfModelException {
+ var handler = new AutomationCompositionElementHandler(mock(PolicyApiHttpClient.class),
+ mock(PolicyPapHttpClient.class));
+ var intermediaryApi = mock(ParticipantIntermediaryApi.class);
+ handler.setIntermediaryApi(intermediaryApi);
+
+ var acElement = getTestingAcElement();
+ acElement.getToscaServiceTemplateFragment().setToscaTopologyTemplate(null);
+ handler.deploy(AC_ID, acElement, Map.of());
+ verify(intermediaryApi).updateAutomationCompositionElementState(AC_ID, automationCompositionElementId,
+ DeployState.UNDEPLOYED, null, "ToscaTopologyTemplate not defined");
}
@Test
@@ -111,8 +129,10 @@ class AutomationCompositionElementHandlerTest {
var element = getTestingAcElement();
// Mock failure in policy type creation
- assertThatThrownBy(() -> handler.deploy(AC_ID, element, Map.of()))
- .hasMessageMatching("Creation of PolicyTypes/Policies failed. Policies will not be deployed.");
+ handler.deploy(AC_ID, element, Map.of());
+ verify(intermediaryApi).updateAutomationCompositionElementState(AC_ID, automationCompositionElementId,
+ DeployState.UNDEPLOYED, null,
+ "Creation of PolicyTypes/Policies failed. Policies will not be deployed.");
}
@Test