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

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 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.intermediary.handler;
  22
  23 import static org.assertj.core.api.Assertions.assertThat;
  24 import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
  25 import static org.mockito.ArgumentMatchers.any;
  26 import static org.mockito.Mockito.mock;
  27 import static org.mockito.Mockito.times;
  28 import static org.mockito.Mockito.verify;
  29 import static org.mockito.Mockito.when;
  30
  31 import java.util.Map;
  32 import java.util.UUID;
  33 import org.junit.jupiter.api.Test;
  34 import org.onap.policy.clamp.acm.participant.intermediary.comm.ParticipantMessagePublisher;
  35 import org.onap.policy.clamp.acm.participant.intermediary.main.parameters.CommonTestData;
  36 import org.onap.policy.clamp.models.acm.concepts.AcTypeState;
  37 import org.onap.policy.clamp.models.acm.concepts.AutomationCompositionElementDefinition;
  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.clamp.models.acm.messages.dmaap.participant.AutomationCompositionDeployAck;
  42 import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantPrimeAck;
  43 import org.onap.policy.clamp.models.acm.messages.dmaap.participant.ParticipantStatus;
  44 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  45
  46 class AutomationCompositionOutHandlerTest {
  47
  48     @Test
  49     void updateAutomationCompositionElementStateNullTest() {
  50         var cacheProvider = mock(CacheProvider.class);
  51         var acOutHandler = new AutomationCompositionOutHandler(mock(ParticipantMessagePublisher.class), cacheProvider);
  52
  53         assertDoesNotThrow(
  54                 () -> acOutHandler.updateAutomationCompositionElementState(null, null, null, null, null, null));
  55
  56         assertDoesNotThrow(() -> acOutHandler.updateAutomationCompositionElementState(UUID.randomUUID(),
  57                 UUID.randomUUID(), null, null, null, null));
  58
  59         assertDoesNotThrow(() -> acOutHandler.updateAutomationCompositionElementState(UUID.randomUUID(),
  60                 UUID.randomUUID(), DeployState.DEPLOYED, null, null, null));
  61
  62         var automationComposition = CommonTestData.getTestAutomationCompositionMap().values().iterator().next();
  63         when(cacheProvider.getAutomationComposition(automationComposition.getInstanceId()))
  64                 .thenReturn(automationComposition);
  65         assertDoesNotThrow(() -> acOutHandler.updateAutomationCompositionElementState(
  66                 automationComposition.getInstanceId(), UUID.randomUUID(), DeployState.DEPLOYED, null, null, null));
  67
  68         var elementId = automationComposition.getElements().values().iterator().next().getId();
  69         assertDoesNotThrow(() -> acOutHandler.updateAutomationCompositionElementState(
  70                 automationComposition.getInstanceId(), elementId, null, null, null, null));
  71     }
  72
  73     @Test
  74     void updateAutomationCompositionElementStateDeployedTest() {
  75         var publisher = mock(ParticipantMessagePublisher.class);
  76         var cacheProvider = mock(CacheProvider.class);
  77         var acOutHandler = new AutomationCompositionOutHandler(publisher, cacheProvider);
  78
  79         var automationComposition = CommonTestData.getTestAutomationCompositionMap().values().iterator().next();
  80         when(cacheProvider.getAutomationComposition(automationComposition.getInstanceId()))
  81                 .thenReturn(automationComposition);
  82         var elementId = automationComposition.getElements().values().iterator().next().getId();
  83         acOutHandler.updateAutomationCompositionElementState(automationComposition.getInstanceId(), elementId,
  84                 DeployState.DEPLOYED, null, StateChangeResult.NO_ERROR, "Deployed");
  85         verify(publisher).sendAutomationCompositionAck(any(AutomationCompositionDeployAck.class));
  86     }
  87
  88     @Test
  89     void updateAutomationCompositionElementStateLockTest() {
  90         var publisher = mock(ParticipantMessagePublisher.class);
  91         var cacheProvider = mock(CacheProvider.class);
  92         var acOutHandler = new AutomationCompositionOutHandler(publisher, cacheProvider);
  93
  94         var automationComposition = CommonTestData.getTestAutomationCompositionMap().values().iterator().next();
  95         when(cacheProvider.getAutomationComposition(automationComposition.getInstanceId()))
  96                 .thenReturn(automationComposition);
  97         var elementId = automationComposition.getElements().values().iterator().next().getId();
  98         acOutHandler.updateAutomationCompositionElementState(automationComposition.getInstanceId(), elementId, null,
  99                 LockState.LOCKED, StateChangeResult.NO_ERROR, "Locked");
 100         verify(publisher).sendAutomationCompositionAck(any(AutomationCompositionDeployAck.class));
 101     }
 102
 103     @Test
 104     void updateAutomationCompositionElementStateRestartedTest() {
 105         var publisher = mock(ParticipantMessagePublisher.class);
 106         var cacheProvider = mock(CacheProvider.class);
 107         var acOutHandler = new AutomationCompositionOutHandler(publisher, cacheProvider);
 108
 109         var automationComposition = CommonTestData.getTestAutomationCompositionMap().values().iterator().next();
 110         when(cacheProvider.getAutomationComposition(automationComposition.getInstanceId()))
 111                 .thenReturn(automationComposition);
 112         var element = automationComposition.getElements().values().iterator().next();
 113         element.setRestarting(true);
 114         acOutHandler.updateAutomationCompositionElementState(automationComposition.getInstanceId(), element.getId(),
 115                 DeployState.DEPLOYED, LockState.LOCKED, StateChangeResult.NO_ERROR, "Restarted");
 116         verify(publisher).sendAutomationCompositionAck(any(AutomationCompositionDeployAck.class));
 117         assertThat(element.getRestarting()).isNull();
 118     }
 119
 120     @Test
 121     void updateAutomationCompositionElementStateDeleteTest() {
 122         var publisher = mock(ParticipantMessagePublisher.class);
 123         var cacheProvider = mock(CacheProvider.class);
 124         var acOutHandler = new AutomationCompositionOutHandler(publisher, cacheProvider);
 125
 126         var automationComposition = CommonTestData.getTestAutomationCompositionMap().values().iterator().next();
 127         when(cacheProvider.getAutomationComposition(automationComposition.getInstanceId()))
 128                 .thenReturn(automationComposition);
 129         for (var element : automationComposition.getElements().values()) {
 130             acOutHandler.updateAutomationCompositionElementState(automationComposition.getInstanceId(), element.getId(),
 131                     DeployState.DELETED, null, StateChangeResult.NO_ERROR, "Deleted");
 132         }
 133         verify(publisher, times(automationComposition.getElements().size()))
 134                 .sendAutomationCompositionAck(any(AutomationCompositionDeployAck.class));
 135         verify(cacheProvider).removeAutomationComposition(automationComposition.getInstanceId());
 136     }
 137
 138     @Test
 139     void sendAcElementInfoTestNull() {
 140         var publisher = mock(ParticipantMessagePublisher.class);
 141         var cacheProvider = mock(CacheProvider.class);
 142         var acOutHandler = new AutomationCompositionOutHandler(publisher, cacheProvider);
 143
 144         assertDoesNotThrow(() -> acOutHandler.sendAcElementInfo(null, null, null, null, null));
 145         assertDoesNotThrow(() -> acOutHandler.sendAcElementInfo(UUID.randomUUID(), null, null, null, null));
 146         assertDoesNotThrow(
 147                 () -> acOutHandler.sendAcElementInfo(UUID.randomUUID(), UUID.randomUUID(), null, null, null));
 148
 149         var automationComposition = CommonTestData.getTestAutomationCompositionMap().values().iterator().next();
 150         when(cacheProvider.getAutomationComposition(automationComposition.getInstanceId()))
 151                 .thenReturn(automationComposition);
 152         assertDoesNotThrow(() -> acOutHandler.sendAcElementInfo(automationComposition.getInstanceId(),
 153                 UUID.randomUUID(), null, null, null));
 154     }
 155
 156     @Test
 157     void sendAcElementInfoTest() {
 158         var publisher = mock(ParticipantMessagePublisher.class);
 159         var cacheProvider = mock(CacheProvider.class);
 160         var acOutHandler = new AutomationCompositionOutHandler(publisher, cacheProvider);
 161
 162         var automationComposition = CommonTestData.getTestAutomationCompositionMap().values().iterator().next();
 163         when(cacheProvider.getAutomationComposition(automationComposition.getInstanceId()))
 164                 .thenReturn(automationComposition);
 165         var elementId = automationComposition.getElements().values().iterator().next().getId();
 166         acOutHandler.sendAcElementInfo(automationComposition.getInstanceId(), elementId, "", "", Map.of());
 167         verify(publisher).sendParticipantStatus(any(ParticipantStatus.class));
 168     }
 169
 170     @Test
 171     void updateCompositionStateTest() {
 172         var cacheProvider = mock(CacheProvider.class);
 173         when(cacheProvider.getParticipantId()).thenReturn(UUID.randomUUID());
 174         var publisher = mock(ParticipantMessagePublisher.class);
 175         var acOutHandler = new AutomationCompositionOutHandler(publisher, cacheProvider);
 176         acOutHandler.updateCompositionState(UUID.randomUUID(), AcTypeState.PRIMED, StateChangeResult.NO_ERROR,
 177                 "Primed");
 178         verify(publisher).sendParticipantPrimeAck(any(ParticipantPrimeAck.class));
 179     }
 180
 181     @Test
 182     void sendAcDefinitionInfoTest() {
 183         var cacheProvider = mock(CacheProvider.class);
 184         when(cacheProvider.getParticipantId()).thenReturn(UUID.randomUUID());
 185         var compositionId = UUID.randomUUID();
 186         var elementId = new ToscaConceptIdentifier("code", "1.0.0");
 187         var mapAcElementsDefinitions =
 188                 Map.of(compositionId, Map.of(elementId, new AutomationCompositionElementDefinition()));
 189         when(cacheProvider.getAcElementsDefinitions()).thenReturn(mapAcElementsDefinitions);
 190         var publisher = mock(ParticipantMessagePublisher.class);
 191         var acOutHandler = new AutomationCompositionOutHandler(publisher, cacheProvider);
 192
 193         acOutHandler.sendAcDefinitionInfo(null, null, Map.of());
 194         verify(publisher, times(0)).sendHeartbeat(any(ParticipantStatus.class));
 195
 196         acOutHandler.sendAcDefinitionInfo(UUID.randomUUID(), null, Map.of());
 197         verify(publisher, times(0)).sendHeartbeat(any(ParticipantStatus.class));
 198
 199         acOutHandler.sendAcDefinitionInfo(compositionId, new ToscaConceptIdentifier("wrong", "1.0.0"), Map.of());
 200         verify(publisher, times(0)).sendHeartbeat(any(ParticipantStatus.class));
 201
 202         acOutHandler.sendAcDefinitionInfo(compositionId, elementId, Map.of());
 203         verify(publisher).sendHeartbeat(any(ParticipantStatus.class));
 204     }
 205 }