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

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2024-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.mockito.Mockito.mock;
  24 import static org.mockito.Mockito.verify;
  25
  26 import java.util.Map;
  27 import java.util.UUID;
  28 import org.junit.jupiter.api.Test;
  29 import org.onap.policy.clamp.acm.participant.intermediary.api.CompositionDto;
  30 import org.onap.policy.clamp.acm.participant.intermediary.api.CompositionElementDto;
  31 import org.onap.policy.clamp.acm.participant.intermediary.api.InstanceElementDto;
  32 import org.onap.policy.clamp.acm.participant.intermediary.api.ParticipantIntermediaryApi;
  33 import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
  34 import org.onap.policy.clamp.models.acm.concepts.DeployState;
  35 import org.onap.policy.clamp.models.acm.concepts.LockState;
  36 import org.onap.policy.clamp.models.acm.concepts.StateChangeResult;
  37 import org.onap.policy.models.base.PfModelException;
  38 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  39
  40 class AcElementListenerV3Test {
  41
  42     @Test
  43     void lockTest() throws PfModelException {
  44         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
  45         var acElementListenerV2 = createAcElementListenerV3(intermediaryApi);
  46         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
  47             Map.of(), Map.of());
  48         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
  49         acElementListenerV2.lock(compositionElement, instanceElement);
  50         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
  51             instanceElement.elementId(), null, LockState.LOCKED, StateChangeResult.NO_ERROR, "Locked");
  52     }
  53
  54     @Test
  55     void deleteTest() throws PfModelException {
  56         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
  57         var acElementListenerV2 = createAcElementListenerV3(intermediaryApi);
  58         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
  59             Map.of(), Map.of());
  60         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
  61         acElementListenerV2.delete(compositionElement, instanceElement);
  62         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
  63             instanceElement.elementId(), DeployState.DELETED, null, StateChangeResult.NO_ERROR, "Deleted");
  64     }
  65
  66     @Test
  67     void updateTest() throws PfModelException {
  68         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
  69         var acElementListenerV2 = createAcElementListenerV3(intermediaryApi);
  70         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
  71             Map.of(), Map.of());
  72         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
  73         acElementListenerV2.update(compositionElement, instanceElement, instanceElement);
  74         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
  75             instanceElement.elementId(), DeployState.DEPLOYED, null,
  76             StateChangeResult.NO_ERROR, "Update not supported");
  77     }
  78
  79     @Test
  80     void unlockTest() throws PfModelException {
  81         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
  82         var acElementListenerV2 = createAcElementListenerV3(intermediaryApi);
  83         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
  84             Map.of(), Map.of());
  85         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
  86         acElementListenerV2.unlock(compositionElement, instanceElement);
  87         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
  88             instanceElement.elementId(), null, LockState.UNLOCKED, StateChangeResult.NO_ERROR, "Unlocked");
  89     }
  90
  91     @Test
  92     void primeTest() throws PfModelException {
  93         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
  94         var acElementListenerV2 = createAcElementListenerV3(intermediaryApi);
  95         var compositionId = UUID.randomUUID();
  96         var toscaConceptIdentifier = new ToscaConceptIdentifier();
  97         var composition = new CompositionDto(compositionId, Map.of(toscaConceptIdentifier, Map.of()), Map.of());
  98         acElementListenerV2.prime(composition);
  99         verify(intermediaryApi)
 100             .updateCompositionState(compositionId, AcTypeState.PRIMED, StateChangeResult.NO_ERROR, "Primed");
 101     }
 102
 103     @Test
 104     void deprimeTest() throws PfModelException {
 105         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 106         var acElementListenerV2 = createAcElementListenerV3(intermediaryApi);
 107         var compositionId = UUID.randomUUID();
 108         var toscaConceptIdentifier = new ToscaConceptIdentifier();
 109         var composition = new CompositionDto(compositionId, Map.of(toscaConceptIdentifier, Map.of()), Map.of());
 110         acElementListenerV2.deprime(composition);
 111         verify(intermediaryApi)
 112             .updateCompositionState(compositionId, AcTypeState.COMMISSIONED, StateChangeResult.NO_ERROR, "Deprimed");
 113     }
 114
 115     @Test
 116     void migrateTest() throws PfModelException {
 117         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 118         var acElementListenerV2 = createAcElementListenerV3(intermediaryApi);
 119         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 120             Map.of(), Map.of());
 121         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
 122         acElementListenerV2.migrate(compositionElement, compositionElement, instanceElement, instanceElement, 0);
 123         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 124             instanceElement.elementId(), DeployState.DEPLOYED, null,
 125             StateChangeResult.NO_ERROR, "Migrated");
 126     }
 127
 128     @Test
 129     void migratePrecheckTest() throws PfModelException {
 130         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 131         var acElementListenerV1 = createAcElementListenerV3(intermediaryApi);
 132         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 133                 Map.of(), Map.of());
 134         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
 135         acElementListenerV1.migratePrecheck(compositionElement, compositionElement, instanceElement, instanceElement);
 136         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 137                 instanceElement.elementId(), DeployState.DEPLOYED, null,
 138                 StateChangeResult.NO_ERROR, "Migration Precheck completed");
 139     }
 140
 141     @Test
 142     void reviewTest() throws PfModelException {
 143         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 144         var acElementListenerV1 = createAcElementListenerV3(intermediaryApi);
 145         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 146                 Map.of(), Map.of());
 147         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
 148         acElementListenerV1.review(compositionElement, instanceElement);
 149         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 150                 instanceElement.elementId(), DeployState.DEPLOYED, null,
 151                 StateChangeResult.NO_ERROR, "Review completed");
 152     }
 153
 154     @Test
 155     void prepareTest() throws PfModelException {
 156         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 157         var acElementListenerV1 = createAcElementListenerV3(intermediaryApi);
 158         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 159                 Map.of(), Map.of());
 160         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
 161         acElementListenerV1.prepare(compositionElement, instanceElement);
 162         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 163                 instanceElement.elementId(), DeployState.UNDEPLOYED, null,
 164                 StateChangeResult.NO_ERROR, "Prepare completed");
 165     }
 166
 167     @Test
 168     void testRollbackMigration() {
 169         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 170         var acElementListenerV3 = createAcElementListenerV3(intermediaryApi);
 171         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 172             Map.of(), Map.of());
 173         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), Map.of(), Map.of());
 174         acElementListenerV3.rollbackMigration(compositionElement, instanceElement, 1);
 175         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 176             instanceElement.elementId(), DeployState.DEPLOYED, null,
 177             StateChangeResult.NO_ERROR, "Migration rollback done");
 178     }
 179
 180     private AcElementListenerV3 createAcElementListenerV3(ParticipantIntermediaryApi intermediaryApi) {
 181         return new AcElementListenerV3(intermediaryApi) {
 182             @Override
 183             public void deploy(CompositionElementDto compositionElement, InstanceElementDto instanceElement) {
 184                 // dummy implementation
 185             }
 186
 187             @Override
 188             public void undeploy(CompositionElementDto compositionElement, InstanceElementDto instanceElement) {
 189                 // dummy implementation
 190             }
 191         };
 192     }
 193 }