aboutsummaryrefslogtreecommitdiffstats
path: root/models/src/test/java/org
diff options
context:
space:
mode:
authorsaul.gill <saul.gill@est.tech>2023-01-27 14:58:05 +0000
committersaul.gill <saul.gill@est.tech>2023-01-31 09:58:41 +0000
commit777a186248a2bcef1ab9ffc8b16a7190860302e2 (patch)
tree19adf958820a36d45aadc1850b1dd7d720086ab2 /models/src/test/java/org
parent934f7bd443225a6945b0542fa5cb7c043deac426 (diff)
Add element and definition map to ppnt endpoints
Add element instance map Add node template state map Issue-ID: POLICY-4540 Change-Id: I6e7c2b27db78a090b0a1303c49e57d8675316f9b Signed-off-by: saul.gill <saul.gill@est.tech>
Diffstat (limited to 'models/src/test/java/org')
-rw-r--r--models/src/test/java/org/onap/policy/clamp/models/acm/concepts/ParticipantInformationTest.java45
-rw-r--r--models/src/test/java/org/onap/policy/clamp/models/acm/persistence/provider/ParticipantProviderTest.java130
2 files changed, 170 insertions, 5 deletions
diff --git a/models/src/test/java/org/onap/policy/clamp/models/acm/concepts/ParticipantInformationTest.java b/models/src/test/java/org/onap/policy/clamp/models/acm/concepts/ParticipantInformationTest.java
new file mode 100644
index 000000000..4c01f659c
--- /dev/null
+++ b/models/src/test/java/org/onap/policy/clamp/models/acm/concepts/ParticipantInformationTest.java
@@ -0,0 +1,45 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * Copyright (C) 2023 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.models.acm.concepts;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+import java.util.HashMap;
+import java.util.UUID;
+import org.junit.jupiter.api.Test;
+
+public class ParticipantInformationTest {
+
+ @Test
+ void testCopyConstructor() {
+ var participant = new Participant();
+ participant.setParticipantId(UUID.randomUUID());
+ participant.setParticipantState(ParticipantState.ON_LINE);
+ participant.setParticipantSupportedElementTypes(new HashMap<>());
+ var participantInfo1 = new ParticipantInformation();
+ participantInfo1.setParticipant(participant);
+ participantInfo1.setAcElementInstanceMap(new HashMap<>());
+ participantInfo1.setAcNodeTemplateStateDefinitionMap(new HashMap<>());
+
+ var participantInfo2 = new ParticipantInformation(participantInfo1);
+ assertEquals(participantInfo1, participantInfo2);
+ }
+}
diff --git a/models/src/test/java/org/onap/policy/clamp/models/acm/persistence/provider/ParticipantProviderTest.java b/models/src/test/java/org/onap/policy/clamp/models/acm/persistence/provider/ParticipantProviderTest.java
index 0c5137824..3e100df18 100644
--- a/models/src/test/java/org/onap/policy/clamp/models/acm/persistence/provider/ParticipantProviderTest.java
+++ b/models/src/test/java/org/onap/policy/clamp/models/acm/persistence/provider/ParticipantProviderTest.java
@@ -22,6 +22,7 @@ package org.onap.policy.clamp.models.acm.persistence.provider;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
@@ -30,19 +31,33 @@ import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.UUID;
+import java.util.stream.Collectors;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
+import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
+import org.onap.policy.clamp.models.acm.concepts.AutomationCompositions;
+import org.onap.policy.clamp.models.acm.concepts.NodeTemplateState;
import org.onap.policy.clamp.models.acm.concepts.Participant;
+import org.onap.policy.clamp.models.acm.persistence.concepts.JpaAutomationComposition;
+import org.onap.policy.clamp.models.acm.persistence.concepts.JpaNodeTemplateState;
import org.onap.policy.clamp.models.acm.persistence.concepts.JpaParticipant;
+import org.onap.policy.clamp.models.acm.persistence.repository.AutomationCompositionElementRepository;
+import org.onap.policy.clamp.models.acm.persistence.repository.NodeTemplateStateRepository;
import org.onap.policy.clamp.models.acm.persistence.repository.ParticipantRepository;
import org.onap.policy.common.utils.coder.Coder;
import org.onap.policy.common.utils.coder.StandardCoder;
import org.onap.policy.common.utils.resources.ResourceUtils;
+import org.onap.policy.models.base.PfModelRuntimeException;
class ParticipantProviderTest {
private static final Coder CODER = new StandardCoder();
private static final String PARTICIPANT_JSON = "src/test/resources/providers/TestParticipant.json";
+
+ private static final String AUTOMATION_COMPOSITION_JSON =
+ "src/test/resources/providers/TestAutomationCompositions.json";
+
+ private static final String NODE_TEMPLATE_STATE_JSON = "src/test/resources/providers/NodeTemplateState.json";
private static final String LIST_IS_NULL = ".*. is marked .*ull but is null";
private static final UUID INVALID_ID = UUID.randomUUID();
@@ -50,20 +65,43 @@ class ParticipantProviderTest {
private List<JpaParticipant> jpaParticipantList;
private final String originalJson = ResourceUtils.getResourceAsString(PARTICIPANT_JSON);
+ private AutomationCompositions inputAutomationCompositions;
+ private List<JpaAutomationComposition> inputAutomationCompositionsJpa;
+ private final String originalAcJson = ResourceUtils.getResourceAsString(AUTOMATION_COMPOSITION_JSON);
+
+ private final String nodeTemplateStatesJson = ResourceUtils.getResourceAsString(NODE_TEMPLATE_STATE_JSON);
+
+ private List<NodeTemplateState> nodeTemplateStateList = new ArrayList<>();
+ private List<JpaNodeTemplateState> jpaNodeTemplateStateList;
+
@BeforeEach
void beforeSetup() throws Exception {
inputParticipants.add(CODER.decode(originalJson, Participant.class));
jpaParticipantList = ProviderUtils.getJpaAndValidateList(inputParticipants, JpaParticipant::new, "participant");
+
+ inputAutomationCompositions = CODER.decode(originalAcJson, AutomationCompositions.class);
+ inputAutomationCompositionsJpa =
+ ProviderUtils.getJpaAndValidateList(inputAutomationCompositions.getAutomationCompositionList(),
+ JpaAutomationComposition::new, "automation compositions");
+
+ nodeTemplateStateList.add(CODER.decode(nodeTemplateStatesJson, NodeTemplateState.class));
+ nodeTemplateStateList.get(0).setState(AcTypeState.COMMISSIONED);
+ jpaNodeTemplateStateList = ProviderUtils.getJpaAndValidateList(nodeTemplateStateList,
+ JpaNodeTemplateState::new, "node template state");
}
@Test
void testParticipantSave() {
var participantRepository = mock(ParticipantRepository.class);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
+
for (var participant : jpaParticipantList) {
when(participantRepository.getById(participant.getParticipantId()))
.thenReturn(participant);
}
- var participantProvider = new ParticipantProvider(participantRepository);
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
assertThatThrownBy(() -> participantProvider.saveParticipant(null)).hasMessageMatching(LIST_IS_NULL);
@@ -78,11 +116,14 @@ class ParticipantProviderTest {
@Test
void testParticipantUpdate() {
var participantRepository = mock(ParticipantRepository.class);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
for (var participant : jpaParticipantList) {
when(participantRepository.getById(participant.getParticipantId()))
.thenReturn(participant);
}
- var participantProvider = new ParticipantProvider(participantRepository);
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
assertThatThrownBy(() -> participantProvider.updateParticipant(null))
.hasMessageMatching(LIST_IS_NULL);
@@ -97,7 +138,11 @@ class ParticipantProviderTest {
@Test
void testGetAutomationCompositions() {
var participantRepository = mock(ParticipantRepository.class);
- var participantProvider = new ParticipantProvider(participantRepository);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
+
assertThat(participantProvider.findParticipant(INVALID_ID)).isEmpty();
@@ -117,9 +162,24 @@ class ParticipantProviderTest {
}
@Test
+ void testEmptyParticipant() {
+ var participantRepository = mock(ParticipantRepository.class);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
+
+ assertThatThrownBy(() -> participantProvider.getParticipantById(INVALID_ID)).isInstanceOf(
+ PfModelRuntimeException.class).hasMessageMatching("Participant Not Found with ID:.*.");
+ }
+
+ @Test
void testDeleteParticipant() {
var participantRepository = mock(ParticipantRepository.class);
- var participantProvider = new ParticipantProvider(participantRepository);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
var participantId = inputParticipants.get(0).getParticipantId();
assertThatThrownBy(() -> participantProvider.deleteParticipant(participantId))
@@ -133,10 +193,70 @@ class ParticipantProviderTest {
}
@Test
+ void testGetAutomationCompositionElements() {
+ var participantRepository = mock(ParticipantRepository.class);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
+
+ var acElementList = inputAutomationCompositionsJpa
+ .stream().map(c -> c.getElements()).collect(Collectors.toList());
+
+ when(automationCompositionElementRepository.findByParticipantId(any())).thenReturn(acElementList.get(0));
+
+ var listOfAcElements = participantProvider.getAutomationCompositionElements(UUID.randomUUID());
+
+ assertThat(acElementList.get(0).equals(listOfAcElements));
+
+
+ }
+
+ @Test
+ void testGetAcNodeTemplateState() {
+ var participantRepository = mock(ParticipantRepository.class);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
+ when(nodeTemplateStateRepository.findByParticipantId(any())).thenReturn(jpaNodeTemplateStateList);
+
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
+
+ var listOfNodeTemplateState = participantProvider.getAcNodeTemplateStates(
+ UUID.fromString(jpaParticipantList.get(0).getParticipantId()));
+
+ assertThat(listOfNodeTemplateState.equals(nodeTemplateStateList));
+
+ }
+
+ @Test
+ void testNotNullExceptions() {
+ var participantRepository = mock(ParticipantRepository.class);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
+
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
+
+ assertThrows(NullPointerException.class, () -> participantProvider.getParticipantById(null));
+ assertThrows(NullPointerException.class, () -> participantProvider.findParticipant(null));
+ assertThrows(NullPointerException.class, () -> participantProvider.saveParticipant(null));
+ assertThrows(NullPointerException.class, () -> participantProvider.updateParticipant(null));
+ assertThrows(NullPointerException.class, () -> participantProvider.deleteParticipant(null));
+ assertThrows(NullPointerException.class, () -> participantProvider.getAutomationCompositionElements(null));
+ assertThrows(NullPointerException.class, () -> participantProvider.getAcNodeTemplateStates(null));
+
+
+ }
+
+ @Test
void testGetSupportedElementMap() {
var participantRepository = mock(ParticipantRepository.class);
+ var automationCompositionElementRepository = mock(AutomationCompositionElementRepository.class);
+ var nodeTemplateStateRepository = mock(NodeTemplateStateRepository.class);
when(participantRepository.findAll()).thenReturn(jpaParticipantList);
- var participantProvider = new ParticipantProvider(participantRepository);
+ var participantProvider = new ParticipantProvider(participantRepository,
+ automationCompositionElementRepository, nodeTemplateStateRepository);
var result = participantProvider.getSupportedElementMap();
assertThat(result).hasSize(2);