--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2021 Nordix Foundation.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.clamp.controlloop.participant.intermediary.api.impl;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+
+import java.time.Instant;
+import java.util.UUID;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mockito;
+import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ClElementStatistics;
+import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopOrderedState;
+import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopState;
+import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ParticipantHealthStatus;
+import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ParticipantState;
+import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ParticipantStatistics;
+import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantMessageType;
+import org.onap.policy.clamp.controlloop.participant.intermediary.api.ControlLoopElementListener;
+import org.onap.policy.clamp.controlloop.participant.intermediary.main.parameters.CommonTestData;
+import org.onap.policy.common.utils.coder.CoderException;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
+
+class ParticipantIntermediaryApiImplTest {
+
+ private CommonTestData commonTestData = new CommonTestData();
+ private static final String ID_NAME = "org.onap.PM_CDS_Blueprint";
+ private static final String ID_VERSION = "1.0.1";
+
+ private static final String ID_NAME_E = "org.onap.domain.pmsh.PMSHControlLoopDefinition";
+ private static final String ID_VERSION_E = "1.0.0";
+
+ private static final String ID_NAME_TYPE = "org.onap.dcae.controlloop.DCAEMicroserviceControlLoopParticipant";
+ private static final String ID_VERSION_TYPE = "2.3.4";
+
+ @Test
+ void mockParticipantIntermediaryApiImplTest() throws CoderException {
+ var uuid = UUID.randomUUID();
+ var id = new ToscaConceptIdentifier(ID_NAME, ID_VERSION);
+ var participantHandler = commonTestData.getParticipantHandlerControlLoops();
+ var controlLoopHandler = commonTestData.setTestControlLoopHandler(id, uuid);
+ var apiImpl = new ParticipantIntermediaryApiImpl(participantHandler, controlLoopHandler);
+ var clElementListener = Mockito.mock(ControlLoopElementListener.class);
+ apiImpl.registerControlLoopElementListener(clElementListener);
+
+ assertNotNull(apiImpl.getControlLoops(id.getName(), id.getVersion()));
+ assertThat(apiImpl.getClElementDefinitionCommonProperties(id)).isEmpty();
+
+ var participantStatistics = new ParticipantStatistics();
+ participantStatistics.setParticipantId(id);
+ participantStatistics.setTimeStamp(Instant.ofEpochMilli(123456L));
+ participantStatistics.setState(ParticipantState.PASSIVE);
+ participantStatistics.setHealthStatus(ParticipantHealthStatus.HEALTHY);
+ apiImpl.updateParticipantStatistics(participantStatistics);
+
+ var participants = apiImpl.getParticipants(id.getName(), id.getVersion());
+ assertEquals(ParticipantState.UNKNOWN, participants.get(0).getParticipantState());
+
+ var participant = apiImpl.updateParticipantState(id, ParticipantState.TERMINATED);
+ assertEquals(ParticipantState.TERMINATED, participant.getParticipantState());
+
+ var elements = apiImpl.getControlLoopElements(ID_NAME_E, ID_VERSION_E);
+ assertFalse(elements.containsKey(uuid));
+
+ var element = apiImpl.getControlLoopElement(elements.keySet().iterator().next());
+ var idType = new ToscaConceptIdentifier(ID_NAME_TYPE, ID_VERSION_TYPE);
+ assertEquals(idType, element.getParticipantType());
+
+ var clElementStatistics = new ClElementStatistics();
+ var controlLoopId = new ToscaConceptIdentifier("defName", "0.0.1");
+ clElementStatistics.setParticipantId(controlLoopId);
+ clElementStatistics.setControlLoopState(ControlLoopState.RUNNING);
+ clElementStatistics.setTimeStamp(Instant.now());
+
+ apiImpl.updateControlLoopElementStatistics(uuid, clElementStatistics);
+ var clElement = apiImpl.updateControlLoopElementState(id, uuid, ControlLoopOrderedState.UNINITIALISED,
+ ControlLoopState.PASSIVE, ParticipantMessageType.CONTROLLOOP_STATECHANGE_ACK);
+ assertEquals(ControlLoopOrderedState.UNINITIALISED, clElement.getOrderedState());
+ assertEquals(uuid, clElement.getId());
+
+ }
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2021 Nordix Foundation.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.clamp.controlloop.participant.intermediary.comm;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+import java.util.Collections;
+import java.util.List;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mockito;
+import org.onap.policy.clamp.controlloop.common.exception.ControlLoopRuntimeException;
+import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ControlLoopAck;
+import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantDeregister;
+import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantMessageType;
+import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantRegister;
+import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantStatus;
+import org.onap.policy.clamp.controlloop.participant.intermediary.main.parameters.CommonTestData;
+import org.onap.policy.common.endpoints.event.comm.TopicSink;
+import org.onap.policy.common.utils.coder.CoderException;
+
+class ParticipantCommTest {
+
+ private CommonTestData commonTestData = new CommonTestData();
+
+ @Test
+ void participantReqTest() throws CoderException {
+ var participantHandler = commonTestData.getParticipantHandlerControlLoops();
+
+ var participantRegisterAckListener = new ParticipantRegisterAckListener(participantHandler);
+ assertEquals(ParticipantMessageType.PARTICIPANT_REGISTER_ACK.name(),
+ participantRegisterAckListener.getType());
+
+ var participantStatusReqListener = new ParticipantStatusReqListener(participantHandler);
+ assertEquals(ParticipantMessageType.PARTICIPANT_STATUS_REQ.name(),
+ participantStatusReqListener.getType());
+
+ var participantDeregisterAckListener = new ParticipantDeregisterAckListener(participantHandler);
+ assertEquals(ParticipantMessageType.PARTICIPANT_DEREGISTER_ACK.name(),
+ participantDeregisterAckListener.getType());
+
+ var participantUpdateListener = new ParticipantUpdateListener(participantHandler);
+ assertEquals(ParticipantMessageType.PARTICIPANT_UPDATE.name(),
+ participantUpdateListener.getType());
+
+ var controlLoopUpdateListener = new ControlLoopUpdateListener(participantHandler);
+ assertEquals(ParticipantMessageType.CONTROL_LOOP_UPDATE.name(),
+ controlLoopUpdateListener.getType());
+
+ var controlLoopStateChangeListener = new ControlLoopStateChangeListener(participantHandler);
+ assertEquals(ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE.name(),
+ controlLoopStateChangeListener.getType());
+ }
+
+ @Test
+ void participantMessagePublisherExceptionsTest() {
+ var participantMessagePublisher = new ParticipantMessagePublisher();
+
+ var participantStatus = Mockito.mock(ParticipantStatus.class);
+ assertThrows(ControlLoopRuntimeException.class, () -> {
+ participantMessagePublisher.sendParticipantStatus(participantStatus);
+ });
+ assertThrows(ControlLoopRuntimeException.class, () -> {
+ participantMessagePublisher.sendHeartbeat(participantStatus);
+ });
+
+ var participantRegister = Mockito.mock(ParticipantRegister.class);
+ assertThrows(ControlLoopRuntimeException.class, () -> {
+ participantMessagePublisher.sendParticipantRegister(participantRegister);
+ });
+
+ var participantDeregister = Mockito.mock(ParticipantDeregister.class);
+ assertThrows(ControlLoopRuntimeException.class, () -> {
+ participantMessagePublisher.sendParticipantDeregister(participantDeregister);
+ });
+
+ var controlLoopAck = Mockito.mock(ControlLoopAck.class);
+ assertThrows(ControlLoopRuntimeException.class, () -> {
+ participantMessagePublisher.sendControlLoopAck(controlLoopAck);
+ });
+
+ List<TopicSink> emptyList = Collections.emptyList();
+ assertThrows(IllegalArgumentException.class, () -> {
+ participantMessagePublisher.active(emptyList);
+ });
+
+ participantMessagePublisher.stop();
+ }
+
+ @Test
+ void messageSenderTest() throws CoderException {
+ var participantHandler = commonTestData.getParticipantHandlerControlLoops();
+ var participantParameters = CommonTestData.getParticipantParameters();
+ var messageSender = new MessageSender(participantHandler, participantParameters);
+ messageSender.run();
+ assertFalse(messageSender.makeTimerPool().isTerminated());
+ messageSender.close();
+ }
+
+}
var uuid = UUID.randomUUID();
var id = CommonTestData.getParticipantId();
- var clh = setTestControlLoopHandler(id, uuid);
+ var clh = commonTestData.setTestControlLoopHandler(id, uuid);
var key = clh.getElementsOnThisParticipant().keySet().iterator().next();
var value = clh.getElementsOnThisParticipant().get(key);
assertEquals(ControlLoopState.UNINITIALISED, value.getState());
var uuid = UUID.randomUUID();
var id = CommonTestData.getParticipantId();
- var stateChange = new ControlLoopStateChange();
- stateChange.setControlLoopId(id);
- stateChange.setParticipantId(id);
- stateChange.setMessageId(uuid);
- stateChange.setOrderedState(ControlLoopOrderedState.RUNNING);
- stateChange.setCurrentState(ControlLoopState.UNINITIALISED);
- stateChange.setTimestamp(Instant.ofEpochMilli(3000));
+ var stateChange = getStateChange(id, uuid, ControlLoopOrderedState.RUNNING);
- var clh = setTestControlLoopHandler(id, uuid);
+ var clh = commonTestData.setTestControlLoopHandler(id, uuid);
clh.handleControlLoopStateChange(stateChange, List.of());
var newid = new ToscaConceptIdentifier("id", "1.2.3");
stateChange.setControlLoopId(newid);
assertDoesNotThrow(() -> clh.handleControlLoopUpdate(updateMsg, clElementDefinitions));
updateMsg.setStartPhase(1);
assertDoesNotThrow(() -> clh.handleControlLoopUpdate(updateMsg, clElementDefinitions));
+ assertThat(clh.getClElementInstanceProperties(uuid)).isEmpty();
}
- private ControlLoopHandler setTestControlLoopHandler(ToscaConceptIdentifier id, UUID uuid) throws CoderException {
- var clh = commonTestData.getMockControlLoopHandler();
+ @Test
+ void controlLoopStateChangeUninitialisedTest() throws CoderException {
+ var uuid = UUID.randomUUID();
+ var id = CommonTestData.getParticipantId();
- var key = commonTestData.getTestControlLoopMap().keySet().iterator().next();
- var value = commonTestData.getTestControlLoopMap().get(key);
- clh.getControlLoopMap().put(key, value);
+ var stateChangeUninitialised = getStateChange(id, uuid, ControlLoopOrderedState.UNINITIALISED);
- var keyElem = commonTestData.setControlLoopElementTest(uuid, id).keySet().iterator().next();
- var valueElem = commonTestData.setControlLoopElementTest(uuid, id).get(keyElem);
- clh.getElementsOnThisParticipant().put(keyElem, valueElem);
+ var clh = commonTestData.setTestControlLoopHandler(id, uuid);
+ clh.handleControlLoopStateChange(stateChangeUninitialised, List.of());
+ var newid = new ToscaConceptIdentifier("id", "1.2.3");
+ stateChangeUninitialised.setControlLoopId(newid);
+ stateChangeUninitialised.setParticipantId(newid);
+ assertDoesNotThrow(() -> clh.handleControlLoopStateChange(stateChangeUninitialised, List.of()));
+ }
- return clh;
+ @Test
+ void controlLoopStateChangePassiveTest() throws CoderException {
+ var uuid = UUID.randomUUID();
+ var id = CommonTestData.getParticipantId();
+
+ var stateChangePassive = getStateChange(id, uuid, ControlLoopOrderedState.PASSIVE);
+
+ var clh = commonTestData.setTestControlLoopHandler(id, uuid);
+ clh.handleControlLoopStateChange(stateChangePassive, List.of());
+ var newid = new ToscaConceptIdentifier("id", "1.2.3");
+ stateChangePassive.setControlLoopId(newid);
+ stateChangePassive.setParticipantId(newid);
+ assertDoesNotThrow(() -> clh.handleControlLoopStateChange(stateChangePassive, List.of()));
+ }
+
+
+ private ControlLoopStateChange getStateChange(ToscaConceptIdentifier id, UUID uuid, ControlLoopOrderedState state) {
+ var stateChange = new ControlLoopStateChange();
+ stateChange.setControlLoopId(id);
+ stateChange.setParticipantId(id);
+ stateChange.setMessageId(uuid);
+ stateChange.setOrderedState(state);
+ stateChange.setCurrentState(ControlLoopState.UNINITIALISED);
+ stateChange.setTimestamp(Instant.ofEpochMilli(3000));
+ return stateChange;
}
}
return elementsOnThisParticipant;
}
+ /**
+ * Returns a ControlLoopHandler with elements on the id,uuid.
+ *
+ * @param id ToscaConceptIdentifier and uuid UUID
+ * @return a ControlLoopHander with elements
+ */
+ public ControlLoopHandler setTestControlLoopHandler(ToscaConceptIdentifier id, UUID uuid) throws CoderException {
+ var clh = getMockControlLoopHandler();
+
+ var key = getTestControlLoopMap().keySet().iterator().next();
+ var value = getTestControlLoopMap().get(key);
+ clh.getControlLoopMap().put(key, value);
+
+ var keyElem = setControlLoopElementTest(uuid, id).keySet().iterator().next();
+ var valueElem = setControlLoopElementTest(uuid, id).get(keyElem);
+ clh.getElementsOnThisParticipant().put(keyElem, valueElem);
+
+ return clh;
+ }
+
}
Code Review / policy / clamp.git / commitdiff