diff options
author | saul.gill <saul.gill@est.tech> | 2023-01-27 14:58:05 +0000 |
---|---|---|
committer | saul.gill <saul.gill@est.tech> | 2023-01-31 09:58:41 +0000 |
commit | 777a186248a2bcef1ab9ffc8b16a7190860302e2 (patch) | |
tree | 19adf958820a36d45aadc1850b1dd7d720086ab2 /models/src/test/java | |
parent | 934f7bd443225a6945b0542fa5cb7c043deac426 (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')
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); |