gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Modifications Copyright 2018 Nokia
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.so.bpmn.common.scripts
  24
  25 import org.camunda.bpm.engine.delegate.BpmnError
  26 import org.camunda.bpm.engine.delegate.DelegateExecution
  27 import org.camunda.bpm.extension.mockito.delegate.DelegateExecutionFake
  28 import org.junit.Before
  29 import org.junit.Test
  30 import org.mockito.Mock
  31 import org.mockito.MockitoAnnotations
  32 import org.onap.aai.domain.yang.RelationshipList
  33 import org.onap.aai.domain.yang.VolumeGroup
  34 import org.onap.so.bpmn.common.scripts.ConfirmVolumeGroupName
  35 import org.onap.so.bpmn.common.scripts.ConfirmVolumeGroupNameFactory
  36 import org.onap.so.bpmn.common.scripts.ExceptionUtil
  37 import org.onap.so.client.aai.AAIObjectType
  38 import org.onap.so.client.aai.AAIResourcesClient
  39 import org.onap.so.client.aai.entities.uri.AAIResourceUri
  40 import org.onap.so.client.aai.entities.uri.AAIUriFactory
  41 import org.onap.so.constants.Defaults
  42 import org.springframework.http.HttpStatus
  43
  44 import javax.ws.rs.core.UriBuilder
  45
  46 import static org.assertj.core.api.Assertions.catchThrowableOfType
  47 import static org.junit.Assert.assertEquals
  48 import static org.junit.Assert.assertFalse
  49 import static org.junit.Assert.assertTrue
  50 import static org.mockito.Mockito.spy
  51 import static org.mockito.Mockito.when
  52
  53 class ConfirmVolumeGroupNameTest {
  54
  55     private static final AAIResourceUri RESOURCE_URI = AAIUriFactory.createResourceFromExistingURI(
  56             AAIObjectType.VOLUME_GROUP, UriBuilder.fromPath('/aai/test/volume-groups/volume-group/testVolumeGroup').build())
  57
  58     private ConfirmVolumeGroupName confirmVolumeGroupName
  59     @Mock
  60     private VolumeGroup volumeGroup
  61     @Mock
  62     private AAIResourcesClient client
  63     private ExceptionUtilFake exceptionUtilFake
  64
  65     private DelegateExecution delegateExecution
  66
  67     @Before
  68     public void init() throws IOException {
  69         exceptionUtilFake = new ExceptionUtilFake()
  70         confirmVolumeGroupName = spy(new ConfirmVolumeGroupName(exceptionUtilFake))
  71         MockitoAnnotations.initMocks(this)
  72         delegateExecution = new DelegateExecutionFake()
  73         volumeGroup = createVolumeGroup()
  74         when(confirmVolumeGroupName.getAAIClient()).thenReturn(client)
  75     }
  76
  77     @Test
  78     public void preProcessRequest_shouldSetUpVariables() {
  79         String volumeGroupId = "volume-group-id-1"
  80         String volumeGroupName = "volume-group-name-1"
  81         String aicCloudRegion = "aic-cloud-region-1"
  82         AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.VOLUME_GROUP, Defaults.CLOUD_OWNER, aicCloudRegion, volumeGroupId)
  83
  84         delegateExecution.setVariable("ConfirmVolumeGroupName_volumeGroupId", volumeGroupId)
  85         delegateExecution.setVariable("ConfirmVolumeGroupName_volumeGroupName", volumeGroupName)
  86         delegateExecution.setVariable("ConfirmVolumeGroupName_aicCloudRegion", aicCloudRegion)
  87         delegateExecution.setVariable("CVGN_volumeGroupGetEndpoint", uri)
  88
  89         confirmVolumeGroupName.preProcessRequest(delegateExecution)
  90
  91         assertEquals(ConfirmVolumeGroupName.Prefix, delegateExecution.getVariable("prefix"))
  92
  93         assertEquals(volumeGroupId, delegateExecution.getVariable("CVGN_volumeGroupId"))
  94         assertEquals(volumeGroupName, delegateExecution.getVariable("CVGN_volumeGroupName"))
  95         assertEquals(aicCloudRegion, delegateExecution.getVariable("CVGN_aicCloudRegion"))
  96     }
  97
  98     @Test
  99     public void queryAAIForVolumeGroupId_shouldSucceed_whenVolumeGroupExists() {
 100         delegateExecution.setVariable("CVGN_queryVolumeGroupResponseCode", HttpStatus.OK)
 101         delegateExecution.setVariable("CVGN_queryVolumeGroupResponse", volumeGroup)
 102         delegateExecution.setVariable("CVGN_volumeGroupGetEndpoint", RESOURCE_URI)
 103         when(client.get(VolumeGroup.class, RESOURCE_URI)).thenReturn(Optional.of(volumeGroup))
 104
 105         confirmVolumeGroupName.queryAAIForVolumeGroupId(delegateExecution)
 106
 107         assertEquals(HttpStatus.OK.value(), delegateExecution.getVariable("CVGN_queryVolumeGroupResponseCode"))
 108         assertEquals(volumeGroup, delegateExecution.getVariable("CVGN_queryVolumeGroupResponse"))
 109     }
 110
 111     @Test
 112     public void queryAAIForVolumeGroupId_shouldFailWith404_whenVolumeGroupDoesNotExist() {
 113         delegateExecution.setVariable("CVGN_volumeGroupGetEndpoint", RESOURCE_URI)
 114         when(client.get(VolumeGroup.class, RESOURCE_URI)).thenReturn(Optional.empty())
 115
 116         confirmVolumeGroupName.queryAAIForVolumeGroupId(delegateExecution)
 117
 118         assertEquals(HttpStatus.NOT_FOUND.value(), delegateExecution.getVariable("CVGN_queryVolumeGroupResponseCode"))
 119         assertEquals("Volume Group not Found!", delegateExecution.getVariable("CVGN_queryVolumeGroupResponse"))
 120     }
 121
 122     @Test
 123     public void queryAAIForVolumeGroupId_shouldThrowWorkflowException_whenRuntimeExceptionIsThrown() throws BpmnError {
 124         delegateExecution.setVariable("CVGN_volumeGroupGetEndpoint", RESOURCE_URI)
 125         delegateExecution.setVariable("testProcessKey", "process-key1")
 126
 127         def errorMsg = "my runtime exception"
 128         when(client.get(VolumeGroup.class, RESOURCE_URI)).thenThrow(new RuntimeException(errorMsg))
 129
 130         def exceptionMsg = "AAI GET Failed"
 131
 132         BpmnError error = catchThrowableOfType(
 133                 { -> confirmVolumeGroupName.queryAAIForVolumeGroupId(delegateExecution) }, BpmnError.class)
 134
 135         assertEquals(String.format("MSOWorkflowException: %s", exceptionMsg), error.getMessage())
 136         assertEquals(HttpStatus.INTERNAL_SERVER_ERROR.value().toString(), error.getErrorCode())
 137
 138         assertEquals(HttpStatus.INTERNAL_SERVER_ERROR.value(), delegateExecution.getVariable("CVGN_queryVolumeGroupResponseCode"))
 139         assertEquals(String.format("AAI GET Failed:%s", errorMsg), delegateExecution.getVariable("CVGN_queryVolumeGroupResponse"))
 140         assertEquals(HttpStatus.INTERNAL_SERVER_ERROR.value(), exceptionUtilFake.getErrorCode())
 141         assertEquals(exceptionMsg, exceptionUtilFake.getErrorMessage())
 142         assertEquals(delegateExecution, exceptionUtilFake.getDelegateExecution())
 143     }
 144
 145     @Test
 146     public void checkAAIQueryResult_shouldSetVolumeGroupNameMatchesToFalse_whenResponseCodeIs404() {
 147         delegateExecution.setVariable("CVGN_queryVolumeGroupResponseCode", HttpStatus.NOT_FOUND)
 148         delegateExecution.setVariable("CVGN_volumeGroupName", "")
 149
 150         confirmVolumeGroupName.checkAAIQueryResult(delegateExecution)
 151
 152         assertFalse(delegateExecution.getVariable("CVGN_volumeGroupNameMatches"))
 153     }
 154
 155     @Test
 156     public void checkAAIQueryResult_shouldSetVolumeGroupNameMatchesToTrue_whenResponseCodeIs200AndVolumeGroupNameExists() {
 157         delegateExecution.setVariable("CVGN_queryVolumeGroupResponseCode", HttpStatus.OK.value())
 158         delegateExecution.setVariable("CVGN_queryVolumeGroupResponse", volumeGroup)
 159         delegateExecution.setVariable("CVGN_volumeGroupName", volumeGroup.getVolumeGroupName())
 160
 161         confirmVolumeGroupName.checkAAIQueryResult(delegateExecution)
 162
 163         assertTrue(delegateExecution.getVariable("CVGN_volumeGroupNameMatches"))
 164     }
 165
 166     @Test
 167     public void handleVolumeGroupNameNoMatch_shouldThrowBpmnErrorException() {
 168         def volumeGroupId = "volume-group-id"
 169         def volumeGroupName = "volume-group-name"
 170
 171         delegateExecution.setVariable("CVGN_volumeGroupId", volumeGroupId)
 172         delegateExecution.setVariable("CVGN_volumeGroupName", volumeGroupName)
 173
 174         def errorMessage = String.format("Error occurred - volume group id %s is not associated with %s",
 175                 delegateExecution.getVariable('CVGN_volumeGroupId'), delegateExecution.getVariable('CVGN_volumeGroupName'))
 176
 177         BpmnError error = catchThrowableOfType(
 178                 { -> confirmVolumeGroupName.handleVolumeGroupNameNoMatch(delegateExecution) }, BpmnError.class)
 179
 180         assertEquals(String.format("MSOWorkflowException: %s", errorMessage), error.getMessage())
 181         assertEquals("1002", error.getErrorCode())
 182
 183         assertEquals(1002, exceptionUtilFake.getErrorCode())
 184         assertEquals(errorMessage, exceptionUtilFake.getErrorMessage())
 185         assertEquals(delegateExecution, exceptionUtilFake.getDelegateExecution())
 186     }
 187
 188     @Test
 189     public void reportSuccess_shouldSetWorkflowResponseToEmptyString() {
 190         confirmVolumeGroupName.reportSuccess(delegateExecution)
 191         assertEquals("", delegateExecution.getVariable("WorkflowResponse"))
 192     }
 193
 194     private VolumeGroup createVolumeGroup() {
 195         VolumeGroup volumeGroup = new VolumeGroup()
 196
 197         volumeGroup.setVolumeGroupId("volume-group-id")
 198         volumeGroup.setVolumeGroupName("volume-group-name")
 199         volumeGroup.setHeatStackId("heat-stack-id")
 200         volumeGroup.setVnfType("vnf-type")
 201         volumeGroup.setOrchestrationStatus("orchestration-status")
 202         volumeGroup.setModelCustomizationId("model-customization-id")
 203         volumeGroup.setVfModuleModelCustomizationId("vf-module-model-customization-id")
 204         volumeGroup.setResourceVersion("resource-version")
 205         volumeGroup.setRelationshipList(new RelationshipList())
 206
 207         return volumeGroup
 208     }
 209
 210     private static class ExceptionUtilFake extends ExceptionUtil {
 211
 212         private int errorCode
 213         private String errorMessage
 214         private DelegateExecution execution
 215
 216         @Override
 217         public void buildAndThrowWorkflowException(DelegateExecution execution, int errorCode, String errorMessage) {
 218             this.errorCode = errorCode
 219             this.errorMessage = errorMessage
 220             this.execution = execution
 221             throw new BpmnError(errorCode.toString(), "MSOWorkflowException: ${errorMessage}")
 222         }
 223
 224         public int getErrorCode() {
 225             return errorCode
 226         }
 227
 228         public String getErrorMessage() {
 229             return errorMessage
 230         }
 231
 232         public DelegateExecution getDelegateExecution() {
 233             return execution
 234         }
 235     }
 236
 237 }