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

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2021-2025 OpenInfra Foundation Europe. All rights reserved.
   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.acm.participant.intermediary.api.impl;
  22
  23 import static org.assertj.core.api.Assertions.assertThat;
  24 import static org.junit.jupiter.api.Assertions.assertEquals;
  25 import static org.mockito.Mockito.mock;
  26 import static org.mockito.Mockito.verify;
  27 import static org.mockito.Mockito.when;
  28
  29 import java.util.List;
  30 import java.util.Map;
  31 import java.util.UUID;
  32 import org.junit.jupiter.api.Test;
  33 import org.onap.policy.clamp.acm.participant.intermediary.api.CompositionElementDto;
  34 import org.onap.policy.clamp.acm.participant.intermediary.api.ElementState;
  35 import org.onap.policy.clamp.acm.participant.intermediary.api.InstanceElementDto;
  36 import org.onap.policy.clamp.acm.participant.intermediary.handler.AutomationCompositionOutHandler;
  37 import org.onap.policy.clamp.acm.participant.intermediary.handler.cache.AcDefinition;
  38 import org.onap.policy.clamp.acm.participant.intermediary.handler.cache.CacheProvider;
  39 import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
  40 import org.onap.policy.clamp.models.acm.concepts.AutomationComposition;
  41 import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElement;
  42 import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElementDefinition;
  43 import org.onap.policy.clamp.models.acm.concepts.DeployState;
  44 import org.onap.policy.clamp.models.acm.concepts.LockState;
  45 import org.onap.policy.clamp.models.acm.concepts.StateChangeResult;
  46 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  47 import org.onap.policy.models.tosca.authorative.concepts.ToscaNodeTemplate;
  48 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
  49
  50 class ParticipantIntermediaryApiImplTest {
  51
  52     private static final String USE_STATE = "useState";
  53     private static final String OPERATIONAL_STATE = "operationState";
  54     private static final Map<String, Object> MAP = Map.of("key", 1);
  55     private static final UUID AUTOMATION_COMPOSITION_ID = UUID.randomUUID();
  56     private static final UUID ELEMENT_ID = UUID.randomUUID();
  57     private static final UUID COMPOSITION_ID = UUID.randomUUID();
  58     private static final ToscaConceptIdentifier DEFINITION_ELEMENT_ID = new ToscaConceptIdentifier("code", "0.0.1");
  59     private static final ToscaConceptIdentifier WRONG_DEF_ELEMENT_ID = new ToscaConceptIdentifier("wrong", "0.0.1");
  60
  61     @Test
  62     void testUpdateAutomationCompositionElementState() {
  63         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
  64         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, mock(CacheProvider.class));
  65         apiImpl.updateAutomationCompositionElementState(AUTOMATION_COMPOSITION_ID, ELEMENT_ID, DeployState.UNDEPLOYED,
  66                 LockState.NONE, StateChangeResult.NO_ERROR, null);
  67         verify(automationCompositionHandler).updateAutomationCompositionElementState(AUTOMATION_COMPOSITION_ID,
  68                 ELEMENT_ID, DeployState.UNDEPLOYED, LockState.NONE, StateChangeResult.NO_ERROR, null);
  69     }
  70
  71     @Test
  72     void testUpdateCompositionState() {
  73         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
  74         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, mock(CacheProvider.class));
  75         apiImpl.updateCompositionState(COMPOSITION_ID, AcTypeState.PRIMED, StateChangeResult.NO_ERROR, "");
  76         verify(automationCompositionHandler).updateCompositionState(COMPOSITION_ID, AcTypeState.PRIMED,
  77                 StateChangeResult.NO_ERROR, "");
  78     }
  79
  80     @Test
  81     void testSendAcElementInfo() {
  82         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
  83         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, mock(CacheProvider.class));
  84         apiImpl.sendAcElementInfo(AUTOMATION_COMPOSITION_ID, ELEMENT_ID, USE_STATE, OPERATIONAL_STATE, MAP);
  85         verify(automationCompositionHandler).sendAcElementInfo(AUTOMATION_COMPOSITION_ID, ELEMENT_ID, USE_STATE,
  86                 OPERATIONAL_STATE, MAP);
  87     }
  88
  89     @Test
  90     void testSendAcDefinitionInfo() {
  91         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
  92         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, mock(CacheProvider.class));
  93         apiImpl.sendAcDefinitionInfo(COMPOSITION_ID, DEFINITION_ELEMENT_ID, MAP);
  94         verify(automationCompositionHandler).sendAcDefinitionInfo(COMPOSITION_ID, DEFINITION_ELEMENT_ID, MAP);
  95     }
  96
  97     @Test
  98     void testGetAutomationCompositionElement() {
  99         var automationComposition = new AutomationComposition();
 100         automationComposition.setInstanceId(AUTOMATION_COMPOSITION_ID);
 101         var map = Map.of(AUTOMATION_COMPOSITION_ID, automationComposition);
 102         var cacheProvider = mock(CacheProvider.class);
 103         when(cacheProvider.getAutomationCompositions()).thenReturn(map);
 104         var acElement = new AutomationCompositionElement();
 105         acElement.setId(ELEMENT_ID);
 106         automationComposition.setElements(Map.of(ELEMENT_ID, acElement));
 107
 108         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
 109         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, cacheProvider);
 110         var mapResult = apiImpl.getAutomationCompositions();
 111         assertEquals(map, mapResult);
 112
 113         var result = apiImpl.getAutomationComposition(UUID.randomUUID());
 114         assertThat(result).isNull();
 115
 116         result = apiImpl.getAutomationComposition(AUTOMATION_COMPOSITION_ID);
 117         assertEquals(automationComposition, result);
 118
 119         var element = apiImpl.getAutomationCompositionElement(UUID.randomUUID(), UUID.randomUUID());
 120         assertThat(element).isNull();
 121
 122         element = apiImpl.getAutomationCompositionElement(AUTOMATION_COMPOSITION_ID, UUID.randomUUID());
 123         assertThat(element).isNull();
 124
 125         element = apiImpl.getAutomationCompositionElement(AUTOMATION_COMPOSITION_ID, ELEMENT_ID);
 126         assertEquals(acElement, element);
 127     }
 128
 129     @Test
 130     void testGetAcElementsDefinitions() {
 131         var acElementDefinition = new AutomationCompositionElementDefinition();
 132         acElementDefinition.setAcElementDefinitionId(DEFINITION_ELEMENT_ID);
 133         acElementDefinition.setAutomationCompositionElementToscaNodeTemplate(new ToscaNodeTemplate());
 134         var acDefinition = new AcDefinition();
 135         acDefinition.setCompositionId(COMPOSITION_ID);
 136         acDefinition.getElements().put(DEFINITION_ELEMENT_ID, acElementDefinition);
 137         var map = Map.of(COMPOSITION_ID, acDefinition);
 138         var cacheProvider = mock(CacheProvider.class);
 139         when(cacheProvider.getAcElementsDefinitions()).thenReturn(map);
 140         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
 141         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, cacheProvider);
 142         var mapResult = apiImpl.getAcElementsDefinitions();
 143         assertThat(map).hasSameSizeAs(mapResult);
 144         assertThat(mapResult.get(COMPOSITION_ID)).isNotEmpty();
 145         assertEquals(mapResult.get(COMPOSITION_ID), acDefinition.getElements());
 146
 147         var result = apiImpl.getAcElementsDefinitions(UUID.randomUUID());
 148         assertThat(result).isEmpty();
 149
 150         result = apiImpl.getAcElementsDefinitions(COMPOSITION_ID);
 151         assertEquals(acDefinition.getElements(), result);
 152
 153         var element = apiImpl.getAcElementDefinition(UUID.randomUUID(), WRONG_DEF_ELEMENT_ID);
 154         assertThat(element).isNull();
 155
 156         element = apiImpl.getAcElementDefinition(COMPOSITION_ID, WRONG_DEF_ELEMENT_ID);
 157         assertThat(element).isNull();
 158
 159         element = apiImpl.getAcElementDefinition(COMPOSITION_ID, DEFINITION_ELEMENT_ID);
 160         assertEquals(acElementDefinition, element);
 161     }
 162
 163     @Test
 164     void testInstanceElementDto() {
 165         // test InstanceElementDto with toscaServiceTemplateFragment
 166         var instanceElementDto = new InstanceElementDto(COMPOSITION_ID, ELEMENT_ID, new ToscaServiceTemplate(),
 167                 Map.of(), Map.of());
 168         assertEquals(COMPOSITION_ID, instanceElementDto.instanceId());
 169         assertEquals(ELEMENT_ID, instanceElementDto.elementId());
 170     }
 171
 172     @Test
 173     void testGetInstanceElementDto() {
 174         var automationComposition = new AutomationComposition();
 175         automationComposition.setInstanceId(AUTOMATION_COMPOSITION_ID);
 176         var map = Map.of(AUTOMATION_COMPOSITION_ID, automationComposition);
 177         var cacheProvider = mock(CacheProvider.class);
 178         when(cacheProvider.getAutomationCompositions()).thenReturn(map);
 179         var acElement = new AutomationCompositionElement();
 180         acElement.setId(ELEMENT_ID);
 181         acElement.setProperties(MAP);
 182         acElement.setOutProperties(MAP);
 183         automationComposition.setElements(Map.of(ELEMENT_ID, acElement));
 184
 185         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
 186         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, cacheProvider);
 187         var mapResult = apiImpl.getAutomationCompositions();
 188         assertEquals(map, mapResult);
 189
 190         var rndInstance = UUID.randomUUID();
 191         var rndElementId = UUID.randomUUID();
 192         var element = apiImpl.getInstanceElementDto(rndInstance, rndElementId);
 193         assertThat(element).isNotNull();
 194         assertEquals(rndInstance, element.instanceId());
 195         assertEquals(rndElementId, element.elementId());
 196         assertEquals(ElementState.NOT_PRESENT, element.state());
 197
 198         element = apiImpl.getInstanceElementDto(AUTOMATION_COMPOSITION_ID, rndElementId);
 199         assertThat(element).isNotNull();
 200         assertEquals(AUTOMATION_COMPOSITION_ID, element.instanceId());
 201         assertEquals(rndElementId, element.elementId());
 202         assertEquals(ElementState.NOT_PRESENT, element.state());
 203
 204         element = apiImpl.getInstanceElementDto(AUTOMATION_COMPOSITION_ID, ELEMENT_ID);
 205         assertThat(element).isNotNull();
 206         assertEquals(AUTOMATION_COMPOSITION_ID, element.instanceId());
 207         assertEquals(ELEMENT_ID, element.elementId());
 208         assertEquals(acElement.getProperties(), element.inProperties());
 209         assertEquals(acElement.getOutProperties(), element.outProperties());
 210         assertEquals(ElementState.PRESENT, element.state());
 211     }
 212
 213     @Test
 214     void testGetCompositionElementDto() {
 215         var acElementDefinition = new AutomationCompositionElementDefinition();
 216         acElementDefinition.setAcElementDefinitionId(DEFINITION_ELEMENT_ID);
 217         acElementDefinition.setAutomationCompositionElementToscaNodeTemplate(new ToscaNodeTemplate());
 218         acElementDefinition.getAutomationCompositionElementToscaNodeTemplate().setProperties(MAP);
 219         acElementDefinition.setOutProperties(MAP);
 220         var acDefinition = new AcDefinition();
 221         acDefinition.setCompositionId(COMPOSITION_ID);
 222         acDefinition.getElements().put(DEFINITION_ELEMENT_ID, acElementDefinition);
 223         var cacheProvider = mock(CacheProvider.class);
 224         when(cacheProvider.getAcElementsDefinitions()).thenReturn(Map.of(COMPOSITION_ID, acDefinition));
 225         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
 226         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, cacheProvider);
 227
 228         var rndCompositionId = UUID.randomUUID();
 229         var element = apiImpl.getCompositionElementDto(rndCompositionId, WRONG_DEF_ELEMENT_ID);
 230         assertThat(element).isNotNull();
 231         assertEquals(rndCompositionId, element.compositionId());
 232         assertEquals(WRONG_DEF_ELEMENT_ID, element.elementDefinitionId());
 233         assertEquals(ElementState.NOT_PRESENT, element.state());
 234
 235         element = apiImpl.getCompositionElementDto(COMPOSITION_ID, WRONG_DEF_ELEMENT_ID);
 236         assertThat(element).isNotNull();
 237         assertEquals(COMPOSITION_ID, element.compositionId());
 238         assertEquals(WRONG_DEF_ELEMENT_ID, element.elementDefinitionId());
 239         assertEquals(ElementState.NOT_PRESENT, element.state());
 240
 241         element = apiImpl.getCompositionElementDto(COMPOSITION_ID, DEFINITION_ELEMENT_ID);
 242         assertThat(element).isNotNull();
 243         assertEquals(COMPOSITION_ID, element.compositionId());
 244         assertEquals(DEFINITION_ELEMENT_ID, element.elementDefinitionId());
 245         assertEquals(acElementDefinition.getAutomationCompositionElementToscaNodeTemplate().getProperties(),
 246                 element.inProperties());
 247         assertEquals(acElementDefinition.getOutProperties(), element.outProperties());
 248         assertEquals(ElementState.PRESENT, element.state());
 249     }
 250
 251     @Test
 252     void testGetMigrateNextStage() {
 253         var cacheProvider = mock(CacheProvider.class);
 254         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
 255         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, cacheProvider);
 256         var migrate = Map.of("migrate", List.of(0, 2));
 257         Map<String, Object> stageSet = Map.of("stage", migrate);
 258         var compositionElementTarget = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 259                 stageSet, Map.of());
 260         var result = apiImpl.getMigrateNextStage(compositionElementTarget, 0);
 261         assertEquals(2, result);
 262         result = apiImpl.getMigrateNextStage(compositionElementTarget, 2);
 263         assertEquals(2, result);
 264     }
 265
 266     @Test
 267     void testGetRollbackNextStage() {
 268         var cacheProvider = mock(CacheProvider.class);
 269         var automationCompositionHandler = mock(AutomationCompositionOutHandler.class);
 270         var apiImpl = new ParticipantIntermediaryApiImpl(automationCompositionHandler, cacheProvider);
 271         var migrate = Map.of("migrate", List.of(0, 2));
 272         Map<String, Object> stageSet = Map.of("stage", migrate);
 273         var compositionElementTarget = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 274                 stageSet, Map.of());
 275         var result = apiImpl.getRollbackNextStage(compositionElementTarget, 0);
 276         assertEquals(2, result);
 277         result = apiImpl.getRollbackNextStage(compositionElementTarget, 2);
 278         assertEquals(2, result);
 279     }
 280 }