adapters/mso-openstack-adapters/src/test/java/org/onap/so/adapters/audit/HeatStackAuditTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017-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.onap.so.adapters.audit;
  22
  23 import static com.shazam.shazamcrest.MatcherAssert.assertThat;
  24 import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
  25 import static org.junit.Assert.assertEquals;
  26 import static org.mockito.Mockito.doReturn;
  27 import java.io.File;
  28 import java.io.IOException;
  29 import java.nio.file.Files;
  30 import java.nio.file.Paths;
  31 import java.util.ArrayList;
  32 import java.util.HashSet;
  33 import java.util.List;
  34 import java.util.Optional;
  35 import java.util.Set;
  36 import java.util.stream.Collectors;
  37 import org.junit.Before;
  38 import org.junit.Test;
  39 import org.junit.runner.RunWith;
  40 import org.mockito.InjectMocks;
  41 import org.mockito.Mock;
  42 import org.mockito.junit.MockitoJUnitRunner;
  43 import org.onap.aai.domain.yang.LInterface;
  44 import org.onap.aai.domain.yang.LInterfaces;
  45 import org.onap.aai.domain.yang.Vserver;
  46 import org.onap.so.openstack.utils.MsoHeatUtils;
  47 import org.onap.so.openstack.utils.MsoNeutronUtils;
  48 import org.skyscreamer.jsonassert.JSONAssert;
  49 import com.fasterxml.jackson.annotation.JsonInclude.Include;
  50 import com.fasterxml.jackson.databind.DeserializationFeature;
  51 import com.fasterxml.jackson.databind.ObjectMapper;
  52 import com.woorea.openstack.heat.model.Resource;
  53 import com.woorea.openstack.heat.model.Resources;
  54 import com.woorea.openstack.heat.model.Stack;
  55 import com.woorea.openstack.quantum.model.Port;
  56
  57
  58 @RunWith(MockitoJUnitRunner.Silent.class)
  59 public class HeatStackAuditTest extends HeatStackAudit {
  60
  61     @InjectMocks
  62     private HeatStackAudit heatStackAudit = new HeatStackAudit();
  63
  64     @Mock
  65     private MsoHeatUtils msoHeatUtilsMock;
  66
  67     @Mock
  68     private MsoNeutronUtils neutronUtilsMock;
  69
  70     @Mock
  71     private AuditVServer auditVserver;
  72
  73     private static final String cloudRegion = "cloudRegion";
  74     private static final String tenantId = "tenantId";
  75
  76     private Resources resources = new Resources();
  77
  78     private ObjectMapper objectMapper =
  79             new ObjectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
  80                     .setSerializationInclusion(Include.NON_NULL);
  81
  82     private ObjectMapper stackObjectMapper = new ObjectMapper()
  83             .configure(DeserializationFeature.UNWRAP_ROOT_VALUE, true).setSerializationInclusion(Include.NON_NULL);
  84
  85     private List<Optional<Port>> portList = new ArrayList<>();
  86
  87     @Before
  88     public void setup() throws Exception {
  89         resources = objectMapper.readValue(new File("src/test/resources/GetResources.json"), Resources.class);
  90         Port neutronPort1 = stackObjectMapper.readValue(new File("src/test/resources/NeutronPort1.json"), Port.class);
  91         doReturn(Optional.of(neutronPort1)).when(neutronUtilsMock)
  92                 .getNeutronPort("7ee06d9d-3d18-411c-9d3e-aec930f70413", cloudRegion, tenantId);
  93         Port neutronPort2 = stackObjectMapper.readValue(new File("src/test/resources/NeutronPort2.json"), Port.class);
  94         doReturn(Optional.of(neutronPort2)).when(neutronUtilsMock)
  95                 .getNeutronPort("27391d94-33af-474a-927d-d409249e8fd3", cloudRegion, tenantId);
  96         Port neutronPort3 = stackObjectMapper.readValue(new File("src/test/resources/NeutronPort3.json"), Port.class);
  97         doReturn(Optional.of(neutronPort3)).when(neutronUtilsMock)
  98                 .getNeutronPort("fdeedf37-c01e-4ab0-bdd6-8d5fc4913943", cloudRegion, tenantId);
  99         Port neutronPort4 = stackObjectMapper.readValue(new File("src/test/resources/NeutronPort4.json"), Port.class);
 100         doReturn(Optional.of(neutronPort4)).when(neutronUtilsMock)
 101                 .getNeutronPort("8d93f63e-e972-48c7-ad98-b2122da47315", cloudRegion, tenantId);
 102         Port neutronPort5 = stackObjectMapper.readValue(new File("src/test/resources/NeutronPort5.json"), Port.class);
 103         doReturn(Optional.of(neutronPort5)).when(neutronUtilsMock)
 104                 .getNeutronPort("0594a2f2-7ea4-42eb-abc2-48ea49677fca", cloudRegion, tenantId);
 105         Port neutronPort6 = stackObjectMapper.readValue(new File("src/test/resources/NeutronPort6.json"), Port.class);
 106         doReturn(Optional.of(neutronPort6)).when(neutronUtilsMock)
 107                 .getNeutronPort("00bb8407-650e-48b5-b919-33b88d6f8fe3", cloudRegion, tenantId);
 108
 109
 110         portList.add(Optional.empty());
 111         portList.add(Optional.of(neutronPort1));
 112         portList.add(Optional.of(neutronPort2));
 113         portList.add(Optional.of(neutronPort3));
 114         portList.add(Optional.of(neutronPort4));
 115         portList.add(Optional.of(neutronPort5));
 116         portList.add(Optional.of(neutronPort6));
 117     }
 118
 119     @Test
 120     public void extract_proper_path_Test() {
 121         Optional<String> actualResult = extractStackPathFromHref(
 122                 "https://orchestration.com:8004/v1/stacks/test_stack/f711be16-2654-4a09-b89d-0511fda20e81");
 123         assertEquals("/stacks/test_stack/f711be16-2654-4a09-b89d-0511fda20e81", actualResult.get());
 124     }
 125
 126     @Test
 127     public void extract_proper_resources_path_Test() {
 128         Optional<String> actualResult = extractResourcePathFromHref(
 129                 "https://orchestration.com:8004/v1/stacks/test_stack/f711be16-2654-4a09-b89d-0511fda20e81");
 130         assertEquals("/stacks/test_stack/f711be16-2654-4a09-b89d-0511fda20e81/resources", actualResult.get());
 131     }
 132
 133     @Test
 134     public void extract_invalid_uri_Test() {
 135         Optional<String> actualResult = extractStackPathFromHref(
 136                 "orchestrn.com:8004/v18b44d60a6f94bdcb2738f9e//stacks/test_stack/f711be16-2654-4a09-b89d-0511fda20e81");
 137         assertEquals(false, actualResult.isPresent());
 138     }
 139
 140     @Test
 141     public void createVserverSet_Test() throws Exception {
 142         List<Resource> novaResources = resources.getList().stream().filter(p -> "OS::Nova::Server".equals(p.getType()))
 143                 .collect(Collectors.toList());
 144
 145         List<Resource> resourceGroups = resources.getList().stream()
 146                 .filter(p -> "OS::Heat::ResourceGroup".equals(p.getType())).collect(Collectors.toList());
 147
 148         Resources service1QueryResponse = objectMapper
 149                 .readValue(new File("src/test/resources/Service1ResourceGroupResponse.json"), Resources.class);
 150         doReturn(service1QueryResponse).when(msoHeatUtilsMock).executeHeatClientRequest(
 151                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service1_port_0_subinterfaces-dtmxjmny7yjz/31d0647a-6043-49a4-81b6-ccab29380672/resources",
 152                 cloudRegion, tenantId, Resources.class);
 153
 154         Resources service2QueryResponse = objectMapper
 155                 .readValue(new File("src/test/resources/Service2ResourceGroupResponse.json"), Resources.class);
 156         doReturn(service2QueryResponse).when(msoHeatUtilsMock).executeHeatClientRequest(
 157                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service2_port_0_subinterfaces-hlzdigtimzst/447a9b41-714e-434b-b1d0-6cce8d9f0f0c/resources",
 158                 cloudRegion, tenantId, Resources.class);
 159
 160
 161         Stack service2StackQuerySubInt =
 162                 stackObjectMapper.readValue(new File("src/test/resources/Service2SubInterface0.json"), Stack.class);
 163         doReturn(service2StackQuerySubInt).when(msoHeatUtilsMock).executeHeatClientRequest(
 164                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service2_port_0_subinterfaces-hlzdigtimzst-0-upfi5nhurk7y/f711be16-2654-4a09-b89d-0511fda20e81",
 165                 cloudRegion, tenantId, Stack.class);
 166         Resources service2ResourceQuerySubInt = objectMapper
 167                 .readValue(new File("src/test/resources/Service2SubInterface1Resources.json"), Resources.class);
 168         doReturn(service2ResourceQuerySubInt).when(msoHeatUtilsMock).executeHeatClientRequest(
 169                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service2_port_0_subinterfaces-hlzdigtimzst-0-upfi5nhurk7y/f711be16-2654-4a09-b89d-0511fda20e81/resources",
 170                 cloudRegion, tenantId, Resources.class);
 171
 172         Stack service1StackQuerySubInt1 =
 173                 stackObjectMapper.readValue(new File("src/test/resources/Service1SubInterface0.json"), Stack.class);
 174         doReturn(service1StackQuerySubInt1).when(msoHeatUtilsMock).executeHeatClientRequest(
 175                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service1_port_0_subinterfaces-dtmxjmny7yjz-1-fmn5laetg5cs/0d9cd813-2ae1-46c0-9ebb-48081f6cffbb",
 176                 cloudRegion, tenantId, Stack.class);
 177         Resources service1ResourceQuerySubInt1 = objectMapper
 178                 .readValue(new File("src/test/resources/Service1SubInterface0Resources.json"), Resources.class);
 179         doReturn(service1ResourceQuerySubInt1).when(msoHeatUtilsMock).executeHeatClientRequest(
 180                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service1_port_0_subinterfaces-dtmxjmny7yjz-1-fmn5laetg5cs/0d9cd813-2ae1-46c0-9ebb-48081f6cffbb/resources",
 181                 cloudRegion, tenantId, Resources.class);
 182
 183
 184         Stack service1StackQuerySubInt2 =
 185                 stackObjectMapper.readValue(new File("src/test/resources/Service1SubInterface1.json"), Stack.class);
 186         doReturn(service1StackQuerySubInt2).when(msoHeatUtilsMock).executeHeatClientRequest(
 187                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service1_port_0_subinterfaces-dtmxjmny7yjz-0-yghihziaf36m/b7019dd0-2ee9-4447-bdef-ac25676b205a",
 188                 cloudRegion, tenantId, Stack.class);
 189         Resources service1ResourceQuerySubInt2 = objectMapper
 190                 .readValue(new File("src/test/resources/Service1SubInterface1Resources.json"), Resources.class);
 191         doReturn(service1ResourceQuerySubInt2).when(msoHeatUtilsMock).executeHeatClientRequest(
 192                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service1_port_0_subinterfaces-dtmxjmny7yjz-0-yghihziaf36m/b7019dd0-2ee9-4447-bdef-ac25676b205a/resources",
 193                 cloudRegion, tenantId, Resources.class);
 194
 195         Stack service1StackQuerySubInt3 =
 196                 stackObjectMapper.readValue(new File("src/test/resources/Service1SubInterface2.json"), Stack.class);
 197         doReturn(service1StackQuerySubInt3).when(msoHeatUtilsMock).executeHeatClientRequest(
 198                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service1_port_0_subinterfaces-dtmxjmny7yjz-2-y3ndsavmsymv/bd0fc728-cbde-4301-a581-db56f494675c",
 199                 cloudRegion, tenantId, Stack.class);
 200         Resources service1ResourceQuerySubInt3 = objectMapper
 201                 .readValue(new File("src/test/resources/Service1SubInterface2Resources.json"), Resources.class);
 202         doReturn(service1ResourceQuerySubInt3).when(msoHeatUtilsMock).executeHeatClientRequest(
 203                 "/stacks/tsbc0005vm002ssc001-ssc_1_subint_service1_port_0_subinterfaces-dtmxjmny7yjz-2-y3ndsavmsymv/bd0fc728-cbde-4301-a581-db56f494675c/resources",
 204                 cloudRegion, tenantId, Resources.class);
 205
 206         Set<Vserver> vServersToAudit = heatStackAudit.createVserverSet(resources, novaResources, portList);
 207         Set<Vserver> vserversWithSubInterfaces =
 208                 heatStackAudit.processSubInterfaces(cloudRegion, tenantId, resourceGroups, vServersToAudit);
 209
 210         String actualValue = objectMapper.writeValueAsString(vserversWithSubInterfaces);
 211         String expectedValue = getJson("ExpectedVserversToAudit.json");
 212         JSONAssert.assertEquals(expectedValue, actualValue, false);
 213     }
 214
 215     @Test
 216     public void auditHeatStackNoServers_Test() throws Exception {
 217         Resources getResource = objectMapper
 218                 .readValue(new File("src/test/resources/Service1ResourceGroupResponse.json"), Resources.class);
 219         doReturn(getResource).when(msoHeatUtilsMock).queryStackResources(cloudRegion, tenantId, "heatStackName", 3);
 220
 221         Optional<AAIObjectAuditList> actual =
 222                 heatStackAudit.auditHeatStack(cloudRegion, "cloudOwner", tenantId, "heatStackName");
 223         assertEquals(true, actual.get().getAuditList().isEmpty());
 224     }
 225
 226     @Test
 227     public void auditHeatStackNestedServers_Test() throws Exception {
 228         Resources getResource =
 229                 objectMapper.readValue(new File("src/test/resources/GetNestedResources.json"), Resources.class);
 230         List<Resource> novaResources = getResource.getList().stream()
 231                 .filter(p -> "OS::Nova::Server".equals(p.getType())).collect(Collectors.toList());
 232         List<Resource> resourceGroups = getResource.getList().stream()
 233                 .filter(p -> "OS::Heat::ResourceGroup".equals(p.getType())).collect(Collectors.toList());
 234
 235         doReturn(getResource).when(msoHeatUtilsMock).queryStackResources(cloudRegion, tenantId, "heatStackName", 3);
 236         Set<Vserver> vServersToAudit = heatStackAudit.createVserverSet(resources, novaResources, portList);
 237         Set<Vserver> vserversWithSubInterfaces =
 238                 heatStackAudit.processSubInterfaces(cloudRegion, tenantId, resourceGroups, vServersToAudit);
 239         String actualValue = objectMapper.writeValueAsString(vserversWithSubInterfaces);
 240         String expectedValue = getJson("NestedExpectedValue.json");
 241         JSONAssert.assertEquals(expectedValue, actualValue, false);
 242     }
 243
 244
 245     @Test
 246     public void findInterfaceInformation_Test() {
 247         List<Resource> novaResources = resources.getList().stream().filter(p -> "OS::Nova::Server".equals(p.getType()))
 248                 .collect(Collectors.toList());
 249         Set<Vserver> expectedVservers = new HashSet<>();
 250         Vserver vServer1 = new Vserver();
 251         vServer1.setVserverId("92272b67-d23f-42ca-87fa-7b06a9ec81f3");
 252         LInterfaces vServer1Linterfaces = new LInterfaces();
 253         vServer1.setLInterfaces(vServer1Linterfaces);
 254
 255         LInterface ssc_1_trusted_port_0 = new LInterface();
 256         ssc_1_trusted_port_0.setInterfaceId("7ee06d9d-3d18-411c-9d3e-aec930f70413");
 257         ssc_1_trusted_port_0.setInterfaceName("ibcx0026v_ibcx0026vm003_untrusted_port");
 258         vServer1.getLInterfaces().getLInterface().add(ssc_1_trusted_port_0);
 259
 260         LInterface ssc_1_svc2_port_0 = new LInterface();
 261         ssc_1_svc2_port_0.setInterfaceId("27391d94-33af-474a-927d-d409249e8fd3");
 262         ssc_1_svc2_port_0.setInterfaceName("ibcx0026v_ibcx0026vm003_untrusted_port");
 263         vServer1.getLInterfaces().getLInterface().add(ssc_1_svc2_port_0);
 264
 265         LInterface ssc_1_mgmt_port_1 = new LInterface();
 266         ssc_1_mgmt_port_1.setInterfaceId("fdeedf37-c01e-4ab0-bdd6-8d5fc4913943");
 267         ssc_1_mgmt_port_1.setInterfaceName("ibcx0026v_ibcx0026vm003_untrusted_port");
 268         vServer1.getLInterfaces().getLInterface().add(ssc_1_mgmt_port_1);
 269
 270         LInterface ssc_1_mgmt_port_0 = new LInterface();
 271         ssc_1_mgmt_port_0.setInterfaceId("8d93f63e-e972-48c7-ad98-b2122da47315");
 272         ssc_1_mgmt_port_0.setInterfaceName("ibcx0026v_ibcx0026vm003_untrusted_port");
 273         vServer1.getLInterfaces().getLInterface().add(ssc_1_mgmt_port_0);
 274
 275         LInterface ssc_1_svc1_port_0 = new LInterface();
 276         ssc_1_svc1_port_0.setInterfaceId("0594a2f2-7ea4-42eb-abc2-48ea49677fca");
 277         ssc_1_svc1_port_0.setInterfaceName("ibcx0026v_ibcx0026vm003_untrusted_port");
 278         vServer1.getLInterfaces().getLInterface().add(ssc_1_svc1_port_0);
 279
 280         LInterface ssc_1_int_ha_port_0 = new LInterface();
 281         ssc_1_int_ha_port_0.setInterfaceId("00bb8407-650e-48b5-b919-33b88d6f8fe3");
 282         ssc_1_int_ha_port_0.setInterfaceName("ibcx0026v_ibcx0026vm003_untrusted_port");
 283         vServer1.getLInterfaces().getLInterface().add(ssc_1_int_ha_port_0);
 284
 285         expectedVservers.add(vServer1);
 286
 287         Set<Vserver> actualVservers = heatStackAudit.createVserverSet(resources, novaResources, portList);
 288
 289         assertThat(actualVservers, sameBeanAs(expectedVservers));
 290     }
 291
 292     private String getJson(String filename) throws IOException {
 293         return new String(Files.readAllBytes(Paths.get("src/test/resources/" + filename)));
 294     }
 295 }