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.acm.participant.http.handler;
  22
  23 import static org.mockito.ArgumentMatchers.any;
  24 import static org.mockito.Mockito.mock;
  25 import static org.mockito.Mockito.verify;
  26
  27 import java.util.HashMap;
  28 import java.util.List;
  29 import java.util.Map;
  30 import java.util.UUID;
  31 import org.junit.jupiter.api.Test;
  32 import org.onap.policy.clamp.acm.participant.http.main.handler.AutomationCompositionElementHandler;
  33 import org.onap.policy.clamp.acm.participant.http.main.models.ConfigRequest;
  34 import org.onap.policy.clamp.acm.participant.http.main.webclient.AcHttpClient;
  35 import org.onap.policy.clamp.acm.participant.http.utils.CommonTestData;
  36 import org.onap.policy.clamp.acm.participant.http.utils.ToscaUtils;
  37 import org.onap.policy.clamp.acm.participant.intermediary.api.ParticipantIntermediaryApi;
  38 import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
  39 import org.onap.policy.clamp.models.acm.concepts.DeployState;
  40 import org.onap.policy.clamp.models.acm.concepts.LockState;
  41 import org.onap.policy.clamp.models.acm.concepts.StateChangeResult;
  42 import org.onap.policy.models.base.PfModelException;
  43
  44 class AcElementHandlerTest {
  45
  46     private final CommonTestData commonTestData = new CommonTestData();
  47     private static final String HTTP_AUTOMATION_COMPOSITION_ELEMENT =
  48             "org.onap.domain.database.Http_PMSHMicroserviceAutomationCompositionElement";
  49
  50     @Test
  51     void testUndeploy() {
  52         var instanceId = commonTestData.getAutomationCompositionId();
  53         var element = commonTestData.getAutomationCompositionElement();
  54         var acElementId = element.getId();
  55         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
  56
  57         var automationCompositionElementHandler =
  58                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
  59         automationCompositionElementHandler.undeploy(instanceId, acElementId);
  60         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, acElementId,
  61                 DeployState.UNDEPLOYED, null, StateChangeResult.NO_ERROR, "");
  62
  63     }
  64
  65     @Test
  66     void testDeployConstraintViolations() throws PfModelException {
  67         var instanceId = commonTestData.getAutomationCompositionId();
  68         var element = commonTestData.getAutomationCompositionElement();
  69         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
  70
  71         var automationCompositionElementHandler =
  72                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
  73
  74         Map<String, Object> map = new HashMap<>();
  75         automationCompositionElementHandler.deploy(instanceId, element, map);
  76         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, element.getId(),
  77                 DeployState.UNDEPLOYED, null, StateChangeResult.FAILED, "Constraint violations in the config request");
  78     }
  79
  80     @Test
  81     void testDeployError() throws PfModelException {
  82         var instanceId = commonTestData.getAutomationCompositionId();
  83         var element = commonTestData.getAutomationCompositionElement();
  84         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
  85
  86         var automationCompositionElementHandler =
  87                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
  88
  89         Map<String, Object> map = new HashMap<>();
  90         map.put("httpHeaders", 1);
  91         automationCompositionElementHandler.deploy(instanceId, element, map);
  92         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, element.getId(),
  93                 DeployState.UNDEPLOYED, null, StateChangeResult.FAILED, "Error extracting ConfigRequest ");
  94
  95     }
  96
  97     @Test
  98     void testDeploy() throws Exception {
  99         var serviceTemplate = ToscaUtils.readAutomationCompositionFromTosca();
 100         var nodeTemplatesMap = serviceTemplate.getToscaTopologyTemplate().getNodeTemplates();
 101         var map = new HashMap<>(nodeTemplatesMap.get(HTTP_AUTOMATION_COMPOSITION_ELEMENT).getProperties());
 102         var element = commonTestData.getAutomationCompositionElement();
 103         map.putAll(element.getProperties());
 104         var instanceId = commonTestData.getAutomationCompositionId();
 105         var acHttpClient = mock(AcHttpClient.class);
 106         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 107
 108         var automationCompositionElementHandler =
 109                 new AutomationCompositionElementHandler(participantIntermediaryApi, acHttpClient);
 110
 111         automationCompositionElementHandler.deploy(instanceId, element, map);
 112         verify(acHttpClient).run(any(ConfigRequest.class));
 113         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, element.getId(),
 114                 DeployState.DEPLOYED, null, StateChangeResult.NO_ERROR, "Deployed");
 115     }
 116
 117     @Test
 118     void testUpdate() throws PfModelException {
 119         var instanceId = commonTestData.getAutomationCompositionId();
 120         var element = commonTestData.getAutomationCompositionElement();
 121         var acElementId = element.getId();
 122         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 123
 124         var automationCompositionElementHandler =
 125                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 126
 127         automationCompositionElementHandler.update(instanceId, element, Map.of());
 128         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, acElementId,
 129                 DeployState.DEPLOYED, null, StateChangeResult.NO_ERROR, "Update not supported");
 130     }
 131
 132     @Test
 133     void testLock() throws PfModelException {
 134         var instanceId = commonTestData.getAutomationCompositionId();
 135         var acElementId = UUID.randomUUID();
 136         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 137
 138         var automationCompositionElementHandler =
 139                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 140
 141         automationCompositionElementHandler.lock(instanceId, acElementId);
 142         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, acElementId, null,
 143                 LockState.LOCKED, StateChangeResult.NO_ERROR, "Locked");
 144     }
 145
 146     @Test
 147     void testUnlock() throws PfModelException {
 148         var instanceId = commonTestData.getAutomationCompositionId();
 149         var acElementId = UUID.randomUUID();
 150         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 151
 152         var automationCompositionElementHandler =
 153                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 154
 155         automationCompositionElementHandler.unlock(instanceId, acElementId);
 156         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, acElementId, null,
 157                 LockState.UNLOCKED, StateChangeResult.NO_ERROR, "Unlocked");
 158     }
 159
 160     @Test
 161     void testDelete() throws PfModelException {
 162         var instanceId = commonTestData.getAutomationCompositionId();
 163         var acElementId = UUID.randomUUID();
 164         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 165
 166         var automationCompositionElementHandler =
 167                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 168
 169         automationCompositionElementHandler.delete(instanceId, acElementId);
 170         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, acElementId,
 171                 DeployState.DELETED, null, StateChangeResult.NO_ERROR, "Deleted");
 172     }
 173
 174     @Test
 175     void testPrime() throws PfModelException {
 176         var compositionId = UUID.randomUUID();
 177         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 178
 179         var automationCompositionElementHandler =
 180                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 181
 182         automationCompositionElementHandler.prime(compositionId, List.of());
 183         verify(participantIntermediaryApi).updateCompositionState(compositionId, AcTypeState.PRIMED,
 184                 StateChangeResult.NO_ERROR, "Primed");
 185     }
 186
 187     @Test
 188     void testDeprime() throws PfModelException {
 189         var compositionId = UUID.randomUUID();
 190         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 191
 192         var automationCompositionElementHandler =
 193                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 194
 195         automationCompositionElementHandler.deprime(compositionId);
 196         verify(participantIntermediaryApi).updateCompositionState(compositionId, AcTypeState.COMMISSIONED,
 197                 StateChangeResult.NO_ERROR, "Deprimed");
 198     }
 199
 200     @Test
 201     void testHandleRestartComposition() throws PfModelException {
 202         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 203         var automationCompositionElementHandler =
 204                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 205
 206         var compositionId = UUID.randomUUID();
 207         automationCompositionElementHandler.handleRestartComposition(compositionId, List.of(), AcTypeState.PRIMED);
 208         verify(participantIntermediaryApi).updateCompositionState(compositionId, AcTypeState.PRIMED,
 209                 StateChangeResult.NO_ERROR, "Restarted");
 210     }
 211
 212     @Test
 213     void testHandleRestartInstanceDeploying() throws PfModelException {
 214         var serviceTemplate = ToscaUtils.readAutomationCompositionFromTosca();
 215         var nodeTemplatesMap = serviceTemplate.getToscaTopologyTemplate().getNodeTemplates();
 216         var map = new HashMap<>(nodeTemplatesMap.get(HTTP_AUTOMATION_COMPOSITION_ELEMENT).getProperties());
 217         var element = commonTestData.getAutomationCompositionElement();
 218         map.putAll(element.getProperties());
 219         var instanceId = commonTestData.getAutomationCompositionId();
 220         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 221         var automationCompositionElementHandler =
 222                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 223
 224         automationCompositionElementHandler.handleRestartInstance(instanceId, element, map, DeployState.DEPLOYING,
 225                 LockState.NONE);
 226         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, element.getId(),
 227                 DeployState.DEPLOYED, null, StateChangeResult.NO_ERROR, "Deployed");
 228     }
 229
 230     @Test
 231     void testHandleRestartInstanceDeployed() throws PfModelException {
 232         var element = commonTestData.getAutomationCompositionElement();
 233         var instanceId = commonTestData.getAutomationCompositionId();
 234         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 235         var automationCompositionElementHandler =
 236                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 237
 238         automationCompositionElementHandler.handleRestartInstance(instanceId, element, element.getProperties(),
 239                 DeployState.DEPLOYED, LockState.LOCKED);
 240         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, element.getId(),
 241                 DeployState.DEPLOYED, LockState.LOCKED, StateChangeResult.NO_ERROR, "Restarted");
 242     }
 243
 244     @Test
 245     void testMigrate() throws PfModelException {
 246         var instanceId = commonTestData.getAutomationCompositionId();
 247         var element = commonTestData.getAutomationCompositionElement();
 248         var acElementId = element.getId();
 249         var participantIntermediaryApi = mock(ParticipantIntermediaryApi.class);
 250
 251         var automationCompositionElementHandler =
 252                 new AutomationCompositionElementHandler(participantIntermediaryApi, mock(AcHttpClient.class));
 253
 254         automationCompositionElementHandler.migrate(instanceId, element, UUID.randomUUID(), Map.of());
 255         verify(participantIntermediaryApi).updateAutomationCompositionElementState(instanceId, acElementId,
 256                 DeployState.DEPLOYED, null, StateChangeResult.NO_ERROR, "Migrated");
 257     }
 258 }