asdc-tests/src/main/java/org/openecomp/sdc/ci/tests/execute/externalapi/DownloadArtifactsTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * SDC
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.openecomp.sdc.ci.tests.execute.externalapi;
  22
  23 import static org.testng.AssertJUnit.assertEquals;
  24 import static org.testng.AssertJUnit.assertNotNull;
  25 import static org.testng.AssertJUnit.assertTrue;
  26
  27 import java.io.IOException;
  28 import java.nio.file.Files;
  29 import java.nio.file.Path;
  30 import java.nio.file.Paths;
  31 import java.util.HashMap;
  32 import java.util.List;
  33 import java.util.Map;
  34
  35 import org.apache.commons.codec.binary.Base64;
  36 import org.junit.Rule;
  37 import org.junit.rules.TestName;
  38 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
  39 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
  40 import org.openecomp.sdc.be.model.ArtifactDefinition;
  41 import org.openecomp.sdc.be.model.Component;
  42 import org.openecomp.sdc.be.model.ComponentInstance;
  43 import org.openecomp.sdc.be.model.Product;
  44 import org.openecomp.sdc.be.model.Resource;
  45 import org.openecomp.sdc.be.model.Service;
  46 import org.openecomp.sdc.be.model.User;
  47 import org.openecomp.sdc.ci.tests.api.ComponentBaseTest;
  48 import org.openecomp.sdc.ci.tests.api.Urls;
  49 import org.openecomp.sdc.ci.tests.datatypes.ArtifactReqDetails;
  50 import org.openecomp.sdc.ci.tests.datatypes.ComponentInstanceReqDetails;
  51 import org.openecomp.sdc.ci.tests.datatypes.ComponentReqDetails;
  52 import org.openecomp.sdc.ci.tests.datatypes.ImportReqDetails;
  53 import org.openecomp.sdc.ci.tests.datatypes.ProductReqDetails;
  54 import org.openecomp.sdc.ci.tests.datatypes.ResourceReqDetails;
  55 import org.openecomp.sdc.ci.tests.datatypes.ServiceReqDetails;
  56 import org.openecomp.sdc.ci.tests.datatypes.enums.ArtifactTypeEnum;
  57 import org.openecomp.sdc.ci.tests.datatypes.enums.LifeCycleStatesEnum;
  58 import org.openecomp.sdc.ci.tests.datatypes.enums.NormativeTypesEnum;
  59 import org.openecomp.sdc.ci.tests.datatypes.enums.ResourceCategoryEnum;
  60 import org.openecomp.sdc.ci.tests.datatypes.enums.ServiceCategoriesEnum;
  61 import org.openecomp.sdc.ci.tests.datatypes.enums.UserRoleEnum;
  62 import org.openecomp.sdc.ci.tests.datatypes.http.HttpHeaderEnum;
  63 import org.openecomp.sdc.ci.tests.datatypes.http.HttpRequest;
  64 import org.openecomp.sdc.ci.tests.datatypes.http.RestResponse;
  65 import org.openecomp.sdc.ci.tests.utils.general.ElementFactory;
  66 import org.openecomp.sdc.ci.tests.utils.rest.ArtifactRestUtils;
  67 import org.openecomp.sdc.ci.tests.utils.rest.BaseRestUtils;
  68 import org.openecomp.sdc.ci.tests.utils.rest.ComponentInstanceRestUtils;
  69 import org.openecomp.sdc.ci.tests.utils.rest.LifecycleRestUtils;
  70 import org.openecomp.sdc.ci.tests.utils.rest.ProductRestUtils;
  71 import org.openecomp.sdc.ci.tests.utils.rest.ResourceRestUtils;
  72 import org.openecomp.sdc.ci.tests.utils.rest.ResponseParser;
  73 import org.openecomp.sdc.ci.tests.utils.rest.ServiceRestUtils;
  74 import org.testng.Assert;
  75 import org.testng.annotations.BeforeMethod;
  76 import org.testng.annotations.Test;
  77
  78 import com.google.gson.Gson;
  79
  80 public class DownloadArtifactsTest extends ComponentBaseTest {
  81         @Rule
  82         public static TestName name = new TestName();
  83
  84         Gson gson = new Gson();
  85
  86         public DownloadArtifactsTest() {
  87                 super(name, DownloadArtifactsTest.class.getName());
  88         }
  89
  90         private User sdncDesignerDetails;
  91         private User sdncAdminDetails;
  92         private ImportReqDetails resourceDetailsVF_01;
  93         private ResourceReqDetails resourceDetailsVF_02;
  94         private ResourceReqDetails resourceDetailsVF_03;
  95         private ResourceReqDetails resourceDetailsCP_01;
  96         private ServiceReqDetails serviceDetails_01;
  97         private ServiceReqDetails serviceDetails_02;
  98         public static String rootPath = System.getProperty("user.dir");
  99
 100         @BeforeMethod(alwaysRun = true)
 101         public void before() throws Exception {
 102                 init();
 103                 createComponents();
 104         }
 105
 106         private void createComponents() throws Exception {
 107                 createAtomicResource(resourceDetailsCP_01);
 108                 importVfWithArtifacts(resourceDetailsVF_01);
 109                 createVF(resourceDetailsVF_03);
 110                 createVF(resourceDetailsVF_02);
 111                 createService(serviceDetails_01);
 112         }
 113
 114         public void init() {
 115                 sdncDesignerDetails = ElementFactory.getDefaultUser(UserRoleEnum.DESIGNER);
 116                 sdncAdminDetails = ElementFactory.getDefaultUser(UserRoleEnum.ADMIN);
 117                 resourceDetailsVF_01 = ElementFactory.getDefaultImportResourceByType("VF100", NormativeTypesEnum.ROOT,
 118                                 ResourceCategoryEnum.GENERIC_INFRASTRUCTURE, sdncDesignerDetails.getUserId(),
 119                                 ResourceTypeEnum.VF.toString());
 120                 resourceDetailsVF_02 = ElementFactory.getDefaultResourceByType("VF200", NormativeTypesEnum.ROOT,
 121                                 ResourceCategoryEnum.GENERIC_INFRASTRUCTURE, sdncDesignerDetails.getUserId(),
 122                                 ResourceTypeEnum.VF.toString());
 123                 resourceDetailsVF_03 = ElementFactory.getDefaultResourceByType("VF300", NormativeTypesEnum.ROOT,
 124                                 ResourceCategoryEnum.GENERIC_INFRASTRUCTURE, sdncDesignerDetails.getUserId(),
 125                                 ResourceTypeEnum.VF.toString());
 126                 resourceDetailsCP_01 = ElementFactory.getDefaultResourceByType("CP100", NormativeTypesEnum.PORT,
 127                                 ResourceCategoryEnum.GENERIC_NETWORK_ELEMENTS, sdncDesignerDetails.getUserId(),
 128                                 ResourceTypeEnum.CP.toString());
 129                 serviceDetails_01 = ElementFactory.getDefaultService("newtestservice1", ServiceCategoriesEnum.MOBILITY,
 130                                 sdncDesignerDetails.getUserId());
 131                 serviceDetails_02 = ElementFactory.getDefaultService("newtestservice2", ServiceCategoriesEnum.MOBILITY,
 132                                 sdncDesignerDetails.getUserId());
 133         }
 134
 135         @Test
 136         public void downloadResourceInstanceArtifactsFromServiceTest() throws Exception {
 137                 Service service = createServiceWithRIsWithArtifacts();
 138                 Map<String, ArtifactDefinition> deploymentArtifacts;
 139                 List<ComponentInstance> resourceInstances = service.getComponentInstances();
 140                 for (ComponentInstance ri : resourceInstances) {
 141                         deploymentArtifacts = ri.getDeploymentArtifacts();
 142                         for (ArtifactDefinition artifact : deploymentArtifacts.values()) {
 143                                 assertNotNull(downloadResourceInstanceArtifact(service, ri, artifact));
 144                         }
 145                 }
 146         }
 147
 148         @Test
 149         public void downloadServiceArtifactsTest() throws Exception {
 150                 Service service = createServiceWithArtifacts();
 151                 Map<String, ArtifactDefinition> deploymentArtifacts = service.getDeploymentArtifacts();
 152                 for (ArtifactDefinition artifact : deploymentArtifacts.values()) {
 153                         assertNotNull(downloadServiceArtifact(service, artifact));
 154                 }
 155
 156         }
 157
 158         private Service createServiceWithArtifacts() throws Exception {
 159
 160                 ArtifactReqDetails otherArtifactDetails = ElementFactory
 161                                 .getDefaultDeploymentArtifactForType(ArtifactTypeEnum.OTHER.getType());
 162
 163                 RestResponse addInformationalArtifactToService = ArtifactRestUtils.addInformationalArtifactToService(
 164                                 otherArtifactDetails, sdncDesignerDetails, serviceDetails_01.getUniqueId());
 165                 assertTrue(
 166                                 "response code is not BaseRestUtils.STATUS_CODE_SUCCESS, returned :"
 167                                                 + addInformationalArtifactToService.getErrorCode(),
 168                                 addInformationalArtifactToService.getErrorCode() == BaseRestUtils.STATUS_CODE_SUCCESS);
 169
 170                 ArtifactReqDetails yangXmlArtifactDetails = ElementFactory
 171                                 .getDefaultDeploymentArtifactForType(ArtifactTypeEnum.YANG_XML.getType());
 172
 173                 addInformationalArtifactToService = ArtifactRestUtils.addInformationalArtifactToService(yangXmlArtifactDetails,
 174                                 sdncDesignerDetails, serviceDetails_01.getUniqueId());
 175                 assertTrue(
 176                                 "response code is not BaseRestUtils.STATUS_CODE_SUCCESS, returned :"
 177                                                 + addInformationalArtifactToService.getErrorCode(),
 178                                 addInformationalArtifactToService.getErrorCode() == BaseRestUtils.STATUS_CODE_SUCCESS);
 179                 RestResponse createServiceResponse = ServiceRestUtils.getService(serviceDetails_01, sdncDesignerDetails);
 180                 return ResponseParser.convertServiceResponseToJavaObject(createServiceResponse.getResponse());
 181         }
 182
 183         private RestResponse downloadResourceInstanceArtifact(Service service, ComponentInstance ri,
 184                         ArtifactDefinition artifact) throws Exception {
 185                 String url = String.format(Urls.GET_DOWNLOAD_SERVICE_RI_ARTIFACT, "localhost", "8080", service.getUUID(),
 186                                 ri.getUniqueId(), artifact.getArtifactUUID());
 187                 String userId = sdncDesignerDetails.getUserId();
 188                 Map<String, String> headersMap = new HashMap<String, String>();
 189                 headersMap.put(HttpHeaderEnum.CONTENT_TYPE.getValue(), "application/json");
 190                 headersMap.put(HttpHeaderEnum.CACHE_CONTROL.getValue(), "no-cache");
 191                 headersMap.put(HttpHeaderEnum.AUTHORIZATION.getValue(), "Basic dGVzdDoxMjM0NTY=");
 192                 headersMap.put("X-ECOMP-InstanceID", "test");
 193                 if (userId != null) {
 194                         headersMap.put(HttpHeaderEnum.USER_ID.getValue(), userId);
 195                 }
 196                 sendAuthorizationRequest();
 197                 HttpRequest http = new HttpRequest();
 198                 RestResponse response = http.httpSendGet(url, headersMap);
 199                 if (response.getErrorCode() != 200 && response.getResponse().getBytes() == null
 200                                 && response.getResponse().getBytes().length == 0) {
 201                         return null;
 202                 }
 203                 return response;
 204         }
 205
 206         private RestResponse downloadServiceArtifact(Service service, ArtifactDefinition artifact) throws Exception {
 207                 String url = String.format(Urls.GET_DOWNLOAD_SERVICE_ARTIFACT, "localhost", "8080", service.getUUID(),
 208                                 artifact.getArtifactUUID());
 209                 String userId = sdncDesignerDetails.getUserId();
 210                 Map<String, String> headersMap = new HashMap<String, String>();
 211                 headersMap.put(HttpHeaderEnum.CONTENT_TYPE.getValue(), "application/json");
 212                 headersMap.put(HttpHeaderEnum.CACHE_CONTROL.getValue(), "no-cache");
 213                 headersMap.put(HttpHeaderEnum.AUTHORIZATION.getValue(), "Basic dGVzdDoxMjM0NTY=");
 214                 headersMap.put("X-ECOMP-InstanceID", "test");
 215                 if (userId != null) {
 216                         headersMap.put(HttpHeaderEnum.USER_ID.getValue(), userId);
 217                 }
 218                 sendAuthorizationRequest();
 219                 HttpRequest http = new HttpRequest();
 220                 RestResponse response = http.httpSendGet(url, headersMap);
 221                 if (response.getErrorCode() != 200 && response.getResponse().getBytes() == null
 222                                 && response.getResponse().getBytes().length == 0) {
 223                         return null;
 224                 }
 225                 return response;
 226
 227         }
 228
 229         private RestResponse sendAuthorizationRequest() throws IOException {
 230                 String url = String.format(Urls.POST_AUTHORIZATION, "localhost", "8080");
 231                 String userId = sdncAdminDetails.getUserId();
 232                 Map<String, String> headersMap = new HashMap<String, String>();
 233                 headersMap.put(HttpHeaderEnum.CONTENT_TYPE.getValue(), "application/json");
 234                 headersMap.put(HttpHeaderEnum.ACCEPT.getValue(), "application/json");
 235                 headersMap.put(HttpHeaderEnum.CACHE_CONTROL.getValue(), "no-cache");
 236                 if (userId != null) {
 237                         headersMap.put(HttpHeaderEnum.USER_ID.getValue(), userId);
 238                 }
 239
 240                 HttpRequest http = new HttpRequest();
 241                 RestResponse response = http.httpSendPost(url,
 242                                 "{\"consumerName\":\"test\",\"consumerPassword\":\"0a0dc557c3bf594b1a48030e3e99227580168b21f44e285c69740b8d5b13e33b\",\"consumerSalt\":\"2a1f887d607d4515d4066fe0f5452a50\"}",
 243                                 headersMap);
 244                 if (response.getErrorCode() != 201) {
 245                         return null;
 246                 }
 247                 return response;
 248         }
 249
 250         private Service createServiceWithRIsWithArtifacts() throws Exception {
 251                 serviceDetails_02.setUniqueId(serviceDetails_01.getUniqueId());
 252                 createTreeCheckedinVFInstances();
 253                 LifecycleRestUtils.changeResourceState(resourceDetailsCP_01, sdncDesignerDetails, "0.1",
 254                                 LifeCycleStatesEnum.CHECKIN);
 255                 createVFInstanceAndAtomicResourceInstanceWithoutCheckin(resourceDetailsVF_01, resourceDetailsCP_01,
 256                                 sdncDesignerDetails);
 257                 RestResponse updateServiceResp = ServiceRestUtils.updateService(serviceDetails_02, sdncDesignerDetails);
 258                 ServiceRestUtils.checkSuccess(updateServiceResp);
 259                 getComponentAndValidateRIs(serviceDetails_01, 5, 0);
 260
 261                 return ResponseParser.convertServiceResponseToJavaObject(updateServiceResp.getResponse());
 262         }
 263
 264         private void createTreeCheckedinVFInstances() throws Exception {
 265                 RestResponse createFirstVFInstResp = createCheckedinVFInstance(serviceDetails_01, resourceDetailsVF_01,
 266                                 sdncDesignerDetails);
 267                 ResourceRestUtils.checkCreateResponse(createFirstVFInstResp);
 268                 RestResponse createSecondVFInstResp = createCheckedinVFInstance(serviceDetails_01, resourceDetailsVF_02,
 269                                 sdncDesignerDetails);
 270                 ResourceRestUtils.checkCreateResponse(createSecondVFInstResp);
 271                 RestResponse createThirdVFInstResp = createCheckedinVFInstance(serviceDetails_01, resourceDetailsVF_03,
 272                                 sdncDesignerDetails);
 273                 ResourceRestUtils.checkCreateResponse(createThirdVFInstResp);
 274         }
 275
 276         private Component getComponentAndValidateRIs(ComponentReqDetails componentDetails, int numberOfRIs,
 277                         int numberOfRelations) throws IOException, Exception {
 278
 279                 RestResponse getResponse = null;
 280                 Component component = null;
 281                 if (componentDetails instanceof ResourceReqDetails) {
 282                         getResponse = ResourceRestUtils.getResource(sdncAdminDetails, componentDetails.getUniqueId());
 283                         component = ResponseParser.parseToObjectUsingMapper(getResponse.getResponse(), Resource.class);
 284                 } else if (componentDetails instanceof ServiceReqDetails) {
 285                         getResponse = ServiceRestUtils.getService((ServiceReqDetails) componentDetails, sdncAdminDetails);
 286                         component = ResponseParser.parseToObjectUsingMapper(getResponse.getResponse(), Service.class);
 287                 } else if (componentDetails instanceof ProductReqDetails) {
 288                         getResponse = ProductRestUtils.getProduct(componentDetails.getUniqueId(), sdncAdminDetails.getUserId());
 289                         component = ResponseParser.parseToObjectUsingMapper(getResponse.getResponse(), Product.class);
 290                 } else {
 291                         Assert.fail("Unsupported type of componentDetails - " + componentDetails.getClass().getSimpleName());
 292                 }
 293                 ResourceRestUtils.checkSuccess(getResponse);
 294                 int numberOfActualRIs = component.getComponentInstances() != null ? component.getComponentInstances().size()
 295                                 : 0;
 296                 int numberOfActualRelations = component.getComponentInstancesRelations() != null
 297                                 ? component.getComponentInstancesRelations().size() : 0;
 298                 assertEquals("Check number of RIs meet the expected number", numberOfRIs, numberOfActualRIs);
 299                 assertEquals("Check number of RI relations meet the expected number", numberOfRelations,
 300                                 numberOfActualRelations);
 301
 302                 return component;
 303         }
 304
 305         private void createVFInstanceAndAtomicResourceInstanceWithoutCheckin(ResourceReqDetails vf,
 306                         ResourceReqDetails atomicResource, User user) throws Exception {
 307                 RestResponse createVFInstance = createVFInstance(serviceDetails_01, vf, user);
 308                 ResourceRestUtils.checkCreateResponse(createVFInstance);
 309                 RestResponse atomicInstanceForService = createAtomicInstanceForService(serviceDetails_01, atomicResource, user);
 310                 ResourceRestUtils.checkCreateResponse(atomicInstanceForService);
 311         }
 312
 313         private RestResponse createCheckedinVFInstance(ServiceReqDetails containerDetails,
 314                         ResourceReqDetails compInstOriginDetails, User modifier) throws Exception {
 315                 changeResourceLifecycleState(compInstOriginDetails, modifier.getUserId(), LifeCycleStatesEnum.CHECKIN);
 316                 return createVFInstance(containerDetails, compInstOriginDetails, modifier);
 317         }
 318
 319         private RestResponse createVFInstance(ServiceReqDetails containerDetails, ResourceReqDetails compInstOriginDetails,
 320                         User modifier) throws Exception {
 321                 return createComponentInstance(containerDetails, compInstOriginDetails, modifier, ComponentTypeEnum.SERVICE,
 322                                 true);
 323         }
 324
 325         private RestResponse createAtomicInstanceForService(ServiceReqDetails containerDetails,
 326                         ResourceReqDetails compInstOriginDetails, User modifier) throws Exception {
 327                 return createComponentInstance(containerDetails, compInstOriginDetails, modifier, ComponentTypeEnum.SERVICE,
 328                                 true);
 329         }
 330
 331         private RestResponse createComponentInstance(ComponentReqDetails containerDetails,
 332                         ComponentReqDetails compInstOriginDetails, User modifier, ComponentTypeEnum containerComponentTypeEnum,
 333                         boolean isHighestLevel) throws IOException, Exception {
 334                 ComponentInstanceReqDetails resourceInstanceReqDetails = ElementFactory
 335                                 .getComponentResourceInstance(compInstOriginDetails);
 336                 RestResponse createResourceInstanceResponse = ComponentInstanceRestUtils.createComponentInstance(
 337                                 resourceInstanceReqDetails, modifier, containerDetails.getUniqueId(), containerComponentTypeEnum);
 338                 return createResourceInstanceResponse;
 339         }
 340
 341         private void changeResourceLifecycleState(ResourceReqDetails resourceDetails, String userUserId,
 342                         LifeCycleStatesEnum lifeCycleStates) throws Exception {
 343                 RestResponse response = LifecycleRestUtils.changeResourceState(resourceDetails, userUserId, lifeCycleStates);
 344                 LifecycleRestUtils.checkLCS_Response(response);
 345         }
 346
 347         private void createAtomicResource(ResourceReqDetails resourceDetails) throws Exception {
 348                 RestResponse createResourceResponse = ResourceRestUtils.createResource(resourceDetails, sdncDesignerDetails);
 349                 ResourceRestUtils.checkCreateResponse(createResourceResponse);
 350
 351         }
 352
 353         private void createVF(ResourceReqDetails resourceDetails) throws Exception {
 354                 createVF(resourceDetails, sdncDesignerDetails);
 355
 356         }
 357
 358         private void createVF(ResourceReqDetails resourceDetails, User sdncModifier) throws Exception {
 359                 RestResponse createVfResponse = ResourceRestUtils.createResource(resourceDetails, sdncModifier);
 360                 ResourceRestUtils.checkCreateResponse(createVfResponse);
 361         }
 362
 363         private void createService(ServiceReqDetails serviceDetails) throws Exception {
 364                 createService(serviceDetails, sdncDesignerDetails);
 365         }
 366
 367         private void createService(ServiceReqDetails serviceDetails, User sdncModifier) throws Exception {
 368                 RestResponse createServiceResponse = ServiceRestUtils.createService(serviceDetails, sdncModifier);
 369                 ResourceRestUtils.checkCreateResponse(createServiceResponse);
 370         }
 371
 372         private void importVfWithArtifacts(ImportReqDetails resourceDetailsVF_01) throws Exception {
 373                 String payloadName = "VF_RI2_G4_withArtifacts.csar";
 374                 Path path = Paths.get(rootPath + "/src/main/resources/ci/VF_RI2_G4_withArtifacts.csar");
 375                 byte[] data = Files.readAllBytes(path);
 376                 String payloadData = Base64.encodeBase64String(data);
 377                 resourceDetailsVF_01.setPayloadData(payloadData);
 378
 379                 resourceDetailsVF_01.setPayloadName(payloadName);
 380                 resourceDetailsVF_01.setResourceType(ResourceTypeEnum.VF.name());
 381                 RestResponse createResource = ResourceRestUtils.createResource(resourceDetailsVF_01, sdncDesignerDetails);
 382                 BaseRestUtils.checkCreateResponse(createResource);
 383         }
 384
 385 }