gerrit.onap Code Review - policy/clamp.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2021-2023 Nordix Foundation.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.policy.clamp.models.acm.persistence.provider;
  22
  23 import static org.assertj.core.api.Assertions.assertThat;
  24 import static org.assertj.core.api.Assertions.assertThatThrownBy;
  25 import static org.mockito.ArgumentMatchers.any;
  26 import static org.mockito.Mockito.mock;
  27 import static org.mockito.Mockito.verify;
  28 import static org.mockito.Mockito.when;
  29
  30 import java.util.HashMap;
  31 import java.util.List;
  32 import java.util.Map;
  33 import java.util.Optional;
  34 import java.util.UUID;
  35 import org.junit.jupiter.api.BeforeAll;
  36 import org.junit.jupiter.api.Test;
  37 import org.mockito.Mockito;
  38 import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
  39 import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionDefinition;
  40 import org.onap.policy.clamp.models.acm.concepts.NodeTemplateState;
  41 import org.onap.policy.clamp.models.acm.document.concepts.DocToscaServiceTemplate;
  42 import org.onap.policy.clamp.models.acm.persistence.concepts.JpaAutomationCompositionDefinition;
  43 import org.onap.policy.clamp.models.acm.persistence.repository.AutomationCompositionDefinitionRepository;
  44 import org.onap.policy.clamp.models.acm.utils.CommonTestData;
  45 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  46 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
  47 import org.springframework.data.domain.Example;
  48
  49 class AcDefinitionProviderTest {
  50
  51     private static final String TOSCA_SERVICE_TEMPLATE_YAML = "clamp/acm/pmsh/funtional-pmsh-usecase.yaml";
  52     private static final String TOSCA_SERVICE_TEMPLATE_YAML_PROP =
  53             "clamp/acm/test/tosca-template-additional-properties.yaml";
  54
  55     private static final String ELEMENT_NAME = "org.onap.policy.clamp.acm.AutomationCompositionElement";
  56     private static final String NODE_TYPE = "org.onap.policy.clamp.acm.AutomationComposition";
  57
  58     private static ToscaServiceTemplate inputServiceTemplate;
  59
  60     @BeforeAll
  61     static void loadServiceTemplate() {
  62         inputServiceTemplate = CommonTestData.getToscaServiceTemplate(TOSCA_SERVICE_TEMPLATE_YAML);
  63     }
  64
  65     @Test
  66     void testDocCopyCompare() {
  67
  68         var inputServiceTemplateProperties = CommonTestData.getToscaServiceTemplate(TOSCA_SERVICE_TEMPLATE_YAML_PROP);
  69         var docServiceTemplate = new DocToscaServiceTemplate(inputServiceTemplateProperties);
  70         var docServiceTemplateCopy = new DocToscaServiceTemplate(docServiceTemplate);
  71
  72         assertThat(docServiceTemplate.compareTo(docServiceTemplateCopy)).isEqualByComparingTo(0);
  73         assertThat(docServiceTemplate.compareToWithoutEntities(docServiceTemplateCopy)).isZero();
  74
  75         var acmDefinition = getAcDefinition(docServiceTemplate);
  76         var acmDefinitionCopy = getAcDefinition(docServiceTemplateCopy);
  77
  78         assertThat(acmDefinition.getServiceTemplate().getName())
  79                 .isEqualTo(acmDefinitionCopy.getServiceTemplate().getName());
  80
  81     }
  82
  83     @Test
  84     void testCreateServiceTemplate() {
  85         var docServiceTemplate = new DocToscaServiceTemplate(inputServiceTemplate);
  86         var acmDefinition = getAcDefinition(docServiceTemplate);
  87
  88         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
  89         when(acmDefinitionRepository.save(any(JpaAutomationCompositionDefinition.class)))
  90                 .thenReturn(new JpaAutomationCompositionDefinition(acmDefinition));
  91
  92         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
  93         var result = acDefinitionProvider
  94                 .createAutomationCompositionDefinition(inputServiceTemplate, ELEMENT_NAME, NODE_TYPE);
  95
  96         assertThat(result.getServiceTemplate()).isEqualTo(docServiceTemplate.toAuthorative());
  97         assertThat(result.getServiceTemplate().getMetadata()).isNotNull();
  98     }
  99
 100     @Test
 101     void testCreateServiceTemplateWithMetadata() {
 102         inputServiceTemplate.setMetadata(new HashMap<>());
 103         var docServiceTemplate = new DocToscaServiceTemplate(inputServiceTemplate);
 104         var acmDefinition = getAcDefinition(docServiceTemplate);
 105
 106         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 107         when(acmDefinitionRepository.save(any(JpaAutomationCompositionDefinition.class)))
 108             .thenReturn(new JpaAutomationCompositionDefinition(acmDefinition));
 109
 110         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 111         inputServiceTemplate.setMetadata(new HashMap<>());
 112         var result = acDefinitionProvider
 113                 .createAutomationCompositionDefinition(inputServiceTemplate, ELEMENT_NAME, NODE_TYPE);
 114
 115         assertThat(result.getServiceTemplate()).isEqualTo(docServiceTemplate.toAuthorative());
 116         assertThat(result.getServiceTemplate().getMetadata()).isNotNull();
 117     }
 118
 119     @Test
 120     void testUpdateServiceTemplate() {
 121         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 122         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 123         acDefinitionProvider.updateServiceTemplate(UUID.randomUUID(), inputServiceTemplate, ELEMENT_NAME, NODE_TYPE);
 124         verify(acmDefinitionRepository).save(any(JpaAutomationCompositionDefinition.class));
 125     }
 126
 127     @Test
 128     void testUpdateAcDefinition() {
 129         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 130         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 131         var acmDefinition = getAcDefinition(new DocToscaServiceTemplate(inputServiceTemplate));
 132         acDefinitionProvider.updateAcDefinition(acmDefinition, NODE_TYPE);
 133         verify(acmDefinitionRepository).save(any(JpaAutomationCompositionDefinition.class));
 134     }
 135
 136     @Test
 137     void testGetAcDefinition() {
 138         var jpa = new JpaAutomationCompositionDefinition();
 139         jpa.fromAuthorative(getAcDefinition(new DocToscaServiceTemplate(inputServiceTemplate)));
 140         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 141         when(acmDefinitionRepository.findById(jpa.getCompositionId())).thenReturn(Optional.of(jpa));
 142         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 143         var result = acDefinitionProvider.getAcDefinition(UUID.fromString(jpa.getCompositionId()));
 144         assertThat(result).isNotNull();
 145     }
 146
 147     @Test
 148     void testGetAcDefinitionNotFound() {
 149         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 150         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 151         var compositionId = UUID.randomUUID();
 152         assertThatThrownBy(() -> acDefinitionProvider.getAcDefinition(compositionId))
 153                 .hasMessage("Get serviceTemplate \"" + compositionId + "\" failed, serviceTemplate does not exist");
 154     }
 155
 156     @Test
 157     void testFindAcDefinition() {
 158         var jpa = new JpaAutomationCompositionDefinition();
 159         jpa.fromAuthorative(getAcDefinition(new DocToscaServiceTemplate(inputServiceTemplate)));
 160         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 161         when(acmDefinitionRepository.findById(jpa.getCompositionId())).thenReturn(Optional.of(jpa));
 162         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 163         var result = acDefinitionProvider.findAcDefinition(UUID.fromString(jpa.getCompositionId()));
 164         assertThat(result).isNotNull();
 165     }
 166
 167     @Test
 168     void testGetAllAcDefinitions() {
 169         var jpa = new JpaAutomationCompositionDefinition();
 170         jpa.fromAuthorative(getAcDefinition(new DocToscaServiceTemplate(inputServiceTemplate)));
 171         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 172         when(acmDefinitionRepository.findAll()).thenReturn(List.of(jpa));
 173         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 174         var result = acDefinitionProvider.getAllAcDefinitions();
 175         assertThat(result).hasSize(1);
 176     }
 177
 178     @Test
 179     void testDeleteAcDefintion() {
 180         var docServiceTemplate = new DocToscaServiceTemplate(inputServiceTemplate);
 181         var acmDefinition = getAcDefinition(docServiceTemplate);
 182
 183         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 184         when(acmDefinitionRepository.findById(acmDefinition.getCompositionId().toString()))
 185                 .thenReturn(Optional.of(new JpaAutomationCompositionDefinition(acmDefinition)));
 186
 187         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 188         var result = acDefinitionProvider.deleteAcDefintion(acmDefinition.getCompositionId());
 189
 190         assertThat(result).isEqualTo(docServiceTemplate.toAuthorative());
 191     }
 192
 193     @Test
 194     void testDeleteServiceTemplateEmpty() {
 195         var compositionId = UUID.randomUUID();
 196         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 197         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 198         assertThatThrownBy(() -> acDefinitionProvider.deleteAcDefintion(compositionId))
 199                 .hasMessage("delete of Automation Composition Definition \"" + compositionId
 200                         + "\" failed, Automation Composition Definition does not exist");
 201     }
 202
 203     @Test
 204     void testGetServiceTemplate() {
 205         var docServiceTemplate = new DocToscaServiceTemplate(inputServiceTemplate);
 206         var acmDefinition = getAcDefinition(docServiceTemplate);
 207         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 208         when(acmDefinitionRepository.findAll(Mockito.<Example<JpaAutomationCompositionDefinition>>any()))
 209                 .thenReturn(List.of(new JpaAutomationCompositionDefinition(acmDefinition)));
 210
 211         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 212         var result = acDefinitionProvider.getServiceTemplateList(inputServiceTemplate.getName(),
 213                 inputServiceTemplate.getVersion());
 214
 215         assertThat(result).hasSize(1);
 216         assertThat(result.get(0)).isEqualTo(acmDefinition.getServiceTemplate());
 217     }
 218
 219     @Test
 220     void testGetServiceTemplateNulls() {
 221         var docServiceTemplate = new DocToscaServiceTemplate(inputServiceTemplate);
 222         var acmDefinition = getAcDefinition(docServiceTemplate);
 223         var acmDefinitionRepository = mock(AutomationCompositionDefinitionRepository.class);
 224         when(acmDefinitionRepository.findAll(Mockito.<Example<JpaAutomationCompositionDefinition>>any()))
 225             .thenReturn(List.of(new JpaAutomationCompositionDefinition(acmDefinition)));
 226
 227         var acDefinitionProvider = new AcDefinitionProvider(acmDefinitionRepository);
 228         var result = acDefinitionProvider.getServiceTemplateList(null,
 229             inputServiceTemplate.getVersion());
 230
 231         assertThat(result).hasSize(1);
 232         assertThat(result.get(0)).isEqualTo(acmDefinition.getServiceTemplate());
 233
 234         result = acDefinitionProvider.getServiceTemplateList(inputServiceTemplate.getName(),
 235             null);
 236
 237         assertThat(result).hasSize(1);
 238         assertThat(result.get(0)).isEqualTo(acmDefinition.getServiceTemplate());
 239
 240         result = acDefinitionProvider.getServiceTemplateList(null,
 241             null);
 242
 243         assertThat(result).isEmpty();
 244     }
 245
 246     private AutomationCompositionDefinition getAcDefinition(DocToscaServiceTemplate docServiceTemplate) {
 247         var acmDefinition = new AutomationCompositionDefinition();
 248         acmDefinition.setCompositionId(UUID.randomUUID());
 249         acmDefinition.setState(AcTypeState.COMMISSIONED);
 250         acmDefinition.setServiceTemplate(docServiceTemplate.toAuthorative());
 251         var nodeTemplateState = new NodeTemplateState();
 252         nodeTemplateState.setNodeTemplateStateId(UUID.randomUUID());
 253         nodeTemplateState.setNodeTemplateId(new ToscaConceptIdentifier("name", "1.0.0"));
 254         nodeTemplateState.setState(AcTypeState.COMMISSIONED);
 255         nodeTemplateState.setParticipantId(UUID.randomUUID());
 256         acmDefinition.setElementStateMap(Map.of(nodeTemplateState.getNodeTemplateId().getName(), nodeTemplateState));
 257         return acmDefinition;
 258     }
 259 }