catalog-be/src/test/java/org/openecomp/sdc/be/components/PathTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * SDC
   4  * ================================================================================
   5  * Copyright (C) 2019 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.be.components;
  22
  23 import com.fasterxml.jackson.databind.ObjectMapper;
  24 import com.google.gson.Gson;
  25 import com.google.gson.GsonBuilder;
  26 import fj.data.Either;
  27 import org.junit.Test;
  28 import org.mockito.Mockito;
  29 import org.openecomp.sdc.be.auditing.impl.AuditingManager;
  30 import org.openecomp.sdc.be.datamodel.ServiceRelations;
  31 import org.openecomp.sdc.be.datatypes.elements.ForwardingPathDataDefinition;
  32 import org.openecomp.sdc.be.datatypes.elements.ForwardingPathElementDataDefinition;
  33 import org.openecomp.sdc.be.datatypes.elements.ListDataDefinition;
  34 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
  35 import org.openecomp.sdc.be.impl.ComponentsUtils;
  36 import org.openecomp.sdc.be.impl.ForwardingPathUtils;
  37 import org.openecomp.sdc.be.model.CapabilityDefinition;
  38 import org.openecomp.sdc.be.model.CapabilityRequirementRelationship;
  39 import org.openecomp.sdc.be.model.ComponentInstance;
  40 import org.openecomp.sdc.be.model.RelationshipImpl;
  41 import org.openecomp.sdc.be.model.RequirementCapabilityRelDef;
  42 import org.openecomp.sdc.be.model.Service;
  43 import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum;
  44 import org.openecomp.sdc.exception.ResponseFormat;
  45
  46 import java.io.IOException;
  47 import java.util.ArrayList;
  48 import java.util.Arrays;
  49 import java.util.HashMap;
  50 import java.util.List;
  51 import java.util.Map;
  52 import java.util.UUID;
  53
  54 import static org.junit.Assert.assertEquals;
  55 import static org.junit.Assert.assertTrue;
  56
  57 public class PathTest extends BaseServiceBusinessLogicTest {
  58     public static final String fromNode = "fromNode";
  59
  60     @Override
  61     protected Service createServiceObject(boolean afterCreate) {
  62         Service service = super.createServiceObject(afterCreate);
  63         ArrayList<RequirementCapabilityRelDef> resourceInstancesRelations = new ArrayList<>();
  64         String toNode = "toNode";
  65         resourceInstancesRelations.add(createRequirementCapabilityRelDef(fromNode, toNode));
  66         String fromNode1 = "fromNode1";
  67         String toNode1 = "toNode1";
  68         resourceInstancesRelations.add(createRequirementCapabilityRelDef(fromNode1, toNode1));
  69         service.setComponentInstances(new java.util.ArrayList<>());
  70         service.getComponentInstances().add(getComponentInstance(fromNode, "fromNode"));
  71         service.getComponentInstances().add(getComponentInstance(fromNode1, "fromNode1"));
  72         service.getComponentInstances().add(getComponentInstance(toNode, toNode));
  73         service.getComponentInstances().add(getComponentInstance(toNode1, toNode1));
  74
  75        service.setComponentInstancesRelations(resourceInstancesRelations);
  76         return service;
  77     }
  78
  79     private ComponentInstance getComponentInstance(String uniquId, String normalizedName) {
  80         ComponentInstance ci = new ComponentInstance();
  81         ci.setUniqueId(uniquId);
  82         ci.setNormalizedName(normalizedName);
  83         ci.setName(normalizedName);
  84         HashMap<String, List<CapabilityDefinition>> capabilities = new HashMap<>();
  85         CapabilityDefinition capabilityDefinition = getCapabilityDefinition(ci);
  86         capabilities.put(capabilityDefinition.getUniqueId(), Arrays.asList(capabilityDefinition));
  87         capabilityDefinition = getCapabilityDefinition(ci);
  88         capabilities.put(capabilityDefinition.getUniqueId(), Arrays.asList(capabilityDefinition));
  89         ci.setCapabilities(capabilities);
  90         return ci;
  91     }
  92
  93     private static int i = 0;
  94
  95     private CapabilityDefinition getCapabilityDefinition(ComponentInstance ci) {
  96         CapabilityDefinition capabilityDefinition = new CapabilityDefinition();
  97         capabilityDefinition.setUniqueId(UUID.randomUUID().toString());
  98         capabilityDefinition.setName("My name " + i++);
  99         capabilityDefinition.setType(ForwardingPathUtils.FORWARDER_CAPABILITY);
 100         capabilityDefinition.setOwnerId(ci.getUniqueId());
 101         return capabilityDefinition;
 102     }
 103
 104
 105     protected RequirementCapabilityRelDef createRequirementCapabilityRelDef(String fromNode, String toNode) {
 106         RequirementCapabilityRelDef requirementCapabilityRelDef = new RequirementCapabilityRelDef();
 107         requirementCapabilityRelDef.setFromNode(fromNode);
 108         requirementCapabilityRelDef.setRelationships(new ArrayList<>());
 109         CapabilityRequirementRelationship capabilityRequirementRelationship = new CapabilityRequirementRelationship();
 110         RelationshipImpl relationship = new RelationshipImpl();
 111         relationship.setType("something.LINK");
 112         requirementCapabilityRelDef.getRelationships().add(capabilityRequirementRelationship);
 113         requirementCapabilityRelDef.setToNode(toNode);
 114         return requirementCapabilityRelDef;
 115     }
 116
 117     @Test
 118     public void validateSerialization() throws IOException {
 119         Service service = new Service();
 120         ForwardingPathDataDefinition forwardingPath = new ForwardingPathDataDefinition("Name");
 121         String protocol = "protocol";
 122         forwardingPath.setProtocol(protocol);
 123         forwardingPath.setDestinationPortNumber("DestinationPortNumber");
 124         ListDataDefinition<ForwardingPathElementDataDefinition> forwardingPathElementListDataDefinition = new ListDataDefinition<>();
 125         String nodeA = "nodeA";
 126         forwardingPathElementListDataDefinition.add(new ForwardingPathElementDataDefinition(nodeA, "nodeB", "nodeAcpType", "nodeBcpType", "nodeDcpName", "nodeBcpName"));
 127         forwardingPathElementListDataDefinition.add(new ForwardingPathElementDataDefinition("nodeB", "nodeC", "nodeBcpType", "nodeCcpType", "nodeDcpName", "nodeBcpName"));
 128         forwardingPathElementListDataDefinition.add(new ForwardingPathElementDataDefinition("nodeC", "nodeD", "nodeCcpType", "nodeDcpType", "nodeDcpName", "nodeBcpName"));
 129         forwardingPath.setPathElements(forwardingPathElementListDataDefinition);
 130         Map<String, ForwardingPathDataDefinition> forwardingPaths = new HashMap<>();
 131         forwardingPaths.put("NEW", forwardingPath);
 132         service.setForwardingPaths(forwardingPaths);
 133         ObjectMapper mapper = new ObjectMapper();
 134         String jsonResult = mapper.writerWithDefaultPrettyPrinter()
 135                 .writeValueAsString(service);
 136         System.out.println(jsonResult);
 137
 138         Either<Service, ResponseFormat> serviceResponseFormatEither = new ComponentsUtils(Mockito.mock(AuditingManager.class)).convertJsonToObjectUsingObjectMapper(jsonResult, user, Service.class, AuditingActionEnum.CREATE_RESOURCE, ComponentTypeEnum.SERVICE);
 139         assertTrue(serviceResponseFormatEither.isLeft());
 140         Map<String, ForwardingPathDataDefinition> paths = serviceResponseFormatEither.left().value().getForwardingPaths();
 141         assertEquals(paths.size(), 1);
 142         ForwardingPathDataDefinition forwardingPathDataDefinition = paths.values().stream().findAny().get();
 143         assertEquals(protocol, forwardingPathDataDefinition.getProtocol());
 144         List<ForwardingPathElementDataDefinition> listToscaDataDefinition = forwardingPathDataDefinition.getPathElements().getListToscaDataDefinition();
 145         assertEquals(3, listToscaDataDefinition.size());
 146         assertEquals(listToscaDataDefinition.get(0).getFromNode(), nodeA);
 147     }
 148
 149     @Test
 150     public void shouldReturnEmptyRelationsObjectsWhenNoComponentInstanceExist() {
 151         ServiceRelations serviceRelations = new ForwardingPathUtils().convertServiceToServiceRelations(super.createServiceObject(false));
 152         assertTrue(serviceRelations.isEmpty());
 153     }
 154
 155     @Test
 156     public void convertServiceToServiceRelations() {
 157         ServiceRelations serviceRelations = new ForwardingPathUtils().convertServiceToServiceRelations(createServiceObject(false));
 158         Gson gson = new GsonBuilder().setPrettyPrinting().create();
 159         String resultString = gson.toJson(serviceRelations);
 160         System.out.println(" RESPONSE BODY: " + resultString);
 161         assertTrue(resultString.contains(fromNode));
 162     }
 163
 164     @Test
 165     public void emptyCapabilitesShouldNotCauseFailure() {
 166         Service serviceObject = createServiceObject(false);
 167         ComponentInstance ci = new ComponentInstance();
 168         ci.setCapabilities(null);
 169         serviceObject.getComponentInstances().add(ci);
 170         ServiceRelations serviceRelations = new ForwardingPathUtils().convertServiceToServiceRelations(
 171             serviceObject);
 172         Gson gson = new GsonBuilder().setPrettyPrinting().create();
 173         String resultString = gson.toJson(serviceRelations);
 174         System.out.println(" RESPONSE BODY: " + resultString);
 175         assertTrue(resultString.contains(fromNode));
 176     }
 177 }