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

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2024 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.acm.participant.intermediary.api.impl;
  22
  23 import static org.mockito.ArgumentMatchers.any;
  24 import static org.mockito.Mockito.clearInvocations;
  25 import static org.mockito.Mockito.mock;
  26 import static org.mockito.Mockito.verify;
  27
  28 import java.util.Map;
  29 import java.util.UUID;
  30 import org.junit.jupiter.api.Test;
  31 import org.mockito.Answers;
  32 import org.onap.policy.clamp.acm.participant.intermediary.api.CompositionDto;
  33 import org.onap.policy.clamp.acm.participant.intermediary.api.CompositionElementDto;
  34 import org.onap.policy.clamp.acm.participant.intermediary.api.InstanceElementDto;
  35 import org.onap.policy.clamp.acm.participant.intermediary.api.ParticipantIntermediaryApi;
  36 import org.onap.policy.clamp.models.acm.concepts.AcElementDeploy;
  37 import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
  38 import org.onap.policy.clamp.models.acm.concepts.DeployState;
  39 import org.onap.policy.clamp.models.acm.concepts.LockState;
  40 import org.onap.policy.clamp.models.acm.concepts.StateChangeResult;
  41 import org.onap.policy.models.base.PfModelException;
  42 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  43
  44 class AcElementListenerV1Test {
  45
  46     @Test
  47     void deployTest() throws PfModelException {
  48         var acElementListenerV1 = mock(AcElementListenerV1.class, Answers.CALLS_REAL_METHODS);
  49         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
  50             Map.of(), Map.of());
  51         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), null, Map.of(), Map.of());
  52         acElementListenerV1.deploy(compositionElement, instanceElement);
  53         verify(acElementListenerV1).deploy(any(), any(), any());
  54
  55         clearInvocations(acElementListenerV1);
  56         acElementListenerV1.handleRestartInstance(compositionElement, instanceElement,
  57             DeployState.DEPLOYING, LockState.NONE);
  58         verify(acElementListenerV1).deploy(any(), any(), any());
  59     }
  60
  61     @Test
  62     void undeployTest() throws PfModelException {
  63         var acElementListenerV1 = mock(AcElementListenerV1.class, Answers.CALLS_REAL_METHODS);
  64         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
  65             Map.of(), Map.of());
  66         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), null, Map.of(), Map.of());
  67         acElementListenerV1.undeploy(compositionElement, instanceElement);
  68         verify(acElementListenerV1).undeploy(instanceElement.instanceId(), instanceElement.elementId());
  69
  70         clearInvocations(acElementListenerV1);
  71         acElementListenerV1.handleRestartInstance(compositionElement, instanceElement,
  72             DeployState.UNDEPLOYING, LockState.NONE);
  73         verify(acElementListenerV1).undeploy(instanceElement.instanceId(), instanceElement.elementId());
  74     }
  75
  76     @Test
  77     void lockTest() throws PfModelException {
  78         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
  79         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
  80         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
  81             Map.of(), Map.of());
  82         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), null, Map.of(), Map.of());
  83         acElementListenerV1.lock(compositionElement, instanceElement);
  84         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
  85             instanceElement.elementId(), null, LockState.LOCKED, StateChangeResult.NO_ERROR, "Locked");
  86     }
  87
  88     @Test
  89     void deleteTest() throws PfModelException {
  90         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
  91         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
  92         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
  93             Map.of(), Map.of());
  94         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), null, Map.of(), Map.of());
  95         acElementListenerV1.delete(compositionElement, instanceElement);
  96         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
  97             instanceElement.elementId(), DeployState.DELETED, null, StateChangeResult.NO_ERROR, "Deleted");
  98     }
  99
 100     @Test
 101     void updateTest() throws PfModelException {
 102         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 103         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
 104         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 105             Map.of(), Map.of());
 106         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), null, Map.of(), Map.of());
 107         acElementListenerV1.update(compositionElement, instanceElement, instanceElement);
 108         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 109             instanceElement.elementId(), DeployState.DEPLOYED, null,
 110             StateChangeResult.NO_ERROR, "Update not supported");
 111     }
 112
 113     @Test
 114     void unlockTest() throws PfModelException {
 115         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 116         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
 117         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 118             Map.of(), Map.of());
 119         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), null, Map.of(), Map.of());
 120         acElementListenerV1.unlock(compositionElement, instanceElement);
 121         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 122             instanceElement.elementId(), null, LockState.UNLOCKED, StateChangeResult.NO_ERROR, "Unlocked");
 123     }
 124
 125     @Test
 126     void primeTest() throws PfModelException {
 127         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 128         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
 129         var compositionId = UUID.randomUUID();
 130         var toscaConceptIdentifier = new ToscaConceptIdentifier();
 131         var composition = new CompositionDto(compositionId, Map.of(toscaConceptIdentifier, Map.of()), Map.of());
 132         acElementListenerV1.prime(composition);
 133         verify(intermediaryApi)
 134             .updateCompositionState(compositionId, AcTypeState.PRIMED, StateChangeResult.NO_ERROR, "Primed");
 135     }
 136
 137     @Test
 138     void deprimeTest() throws PfModelException {
 139         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 140         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
 141         var compositionId = UUID.randomUUID();
 142         var toscaConceptIdentifier = new ToscaConceptIdentifier();
 143         var composition = new CompositionDto(compositionId, Map.of(toscaConceptIdentifier, Map.of()), Map.of());
 144         acElementListenerV1.deprime(composition);
 145         verify(intermediaryApi)
 146             .updateCompositionState(compositionId, AcTypeState.COMMISSIONED, StateChangeResult.NO_ERROR, "Deprimed");
 147     }
 148
 149     @Test
 150     void handleRestartComposition() throws PfModelException {
 151         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 152         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
 153         var compositionId = UUID.randomUUID();
 154         var toscaConceptIdentifier = new ToscaConceptIdentifier();
 155         var composition = new CompositionDto(compositionId, Map.of(toscaConceptIdentifier, Map.of()), Map.of());
 156
 157         acElementListenerV1.handleRestartComposition(composition, AcTypeState.PRIMED);
 158         verify(intermediaryApi)
 159             .updateCompositionState(compositionId, AcTypeState.PRIMED, StateChangeResult.NO_ERROR, "Restarted");
 160
 161         clearInvocations(intermediaryApi);
 162         acElementListenerV1.handleRestartComposition(composition, AcTypeState.PRIMING);
 163         verify(intermediaryApi)
 164             .updateCompositionState(compositionId, AcTypeState.PRIMED, StateChangeResult.NO_ERROR, "Primed");
 165
 166         clearInvocations(intermediaryApi);
 167         acElementListenerV1.handleRestartComposition(composition, AcTypeState.DEPRIMING);
 168         verify(intermediaryApi)
 169             .updateCompositionState(compositionId, AcTypeState.COMMISSIONED, StateChangeResult.NO_ERROR, "Deprimed");
 170     }
 171
 172     @Test
 173     void handleRestartInstance() throws PfModelException {
 174         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 175         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
 176         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 177             Map.of(), Map.of());
 178         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), null, Map.of(), Map.of());
 179
 180         acElementListenerV1.handleRestartInstance(compositionElement, instanceElement,
 181             DeployState.DEPLOYED, LockState.LOCKED);
 182         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 183             instanceElement.elementId(), DeployState.DEPLOYED, LockState.LOCKED,
 184             StateChangeResult.NO_ERROR, "Restarted");
 185
 186         clearInvocations(intermediaryApi);
 187         acElementListenerV1.handleRestartInstance(compositionElement, instanceElement,
 188             DeployState.DEPLOYED, LockState.LOCKING);
 189         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 190             instanceElement.elementId(), null, LockState.LOCKED, StateChangeResult.NO_ERROR, "Locked");
 191
 192         clearInvocations(intermediaryApi);
 193         acElementListenerV1.handleRestartInstance(compositionElement, instanceElement,
 194             DeployState.DEPLOYED, LockState.UNLOCKING);
 195         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 196             instanceElement.elementId(), null, LockState.UNLOCKED, StateChangeResult.NO_ERROR, "Unlocked");
 197
 198         clearInvocations(intermediaryApi);
 199         acElementListenerV1.handleRestartInstance(compositionElement, instanceElement,
 200             DeployState.UPDATING, LockState.LOCKED);
 201         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 202             instanceElement.elementId(), DeployState.DEPLOYED, null,
 203             StateChangeResult.NO_ERROR, "Update not supported");
 204
 205         clearInvocations(intermediaryApi);
 206         acElementListenerV1.handleRestartInstance(compositionElement, instanceElement,
 207             DeployState.DELETING, LockState.NONE);
 208         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 209             instanceElement.elementId(), DeployState.DELETED, null, StateChangeResult.NO_ERROR, "Deleted");
 210     }
 211
 212     @Test
 213     void migrateTest() throws PfModelException {
 214         var intermediaryApi = mock(ParticipantIntermediaryApi.class);
 215         var acElementListenerV1 = createAcElementListenerV1(intermediaryApi);
 216         var compositionElement = new CompositionElementDto(UUID.randomUUID(), new ToscaConceptIdentifier(),
 217             Map.of(), Map.of());
 218         var instanceElement = new InstanceElementDto(UUID.randomUUID(), UUID.randomUUID(), null, Map.of(), Map.of());
 219         acElementListenerV1.migrate(compositionElement, compositionElement, instanceElement, instanceElement);
 220         verify(intermediaryApi).updateAutomationCompositionElementState(instanceElement.instanceId(),
 221             instanceElement.elementId(), DeployState.DEPLOYED, null,
 222             StateChangeResult.NO_ERROR, "Migrated");
 223     }
 224
 225     private AcElementListenerV1 createAcElementListenerV1(ParticipantIntermediaryApi intermediaryApi) {
 226         return new AcElementListenerV1(intermediaryApi) {
 227             @Override
 228             public void deploy(UUID instanceId, AcElementDeploy element, Map<String, Object> properties)
 229                 throws PfModelException {
 230
 231             }
 232
 233             @Override
 234             public void undeploy(UUID instanceId, UUID elementId) throws PfModelException {
 235
 236             }
 237         };
 238     }
 239 }