main/src/test/java/org/onap/policy/pdpx/main/rest/TestDecision.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
   4  * Modifications Copyright (C) 2019 Nordix Foundation.
   5  * ================================================================================
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  * SPDX-License-Identifier: Apache-2.0
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.onap.policy.pdpx.main.rest;
  23
  24 import static org.assertj.core.api.Assertions.assertThat;
  25 import static org.junit.Assert.assertEquals;
  26
  27 import com.google.gson.Gson;
  28 import com.google.gson.GsonBuilder;
  29 import java.io.File;
  30 import java.io.IOException;
  31 import java.nio.file.Files;
  32 import java.nio.file.Path;
  33 import java.nio.file.Paths;
  34 import java.nio.file.StandardCopyOption;
  35 import java.security.KeyManagementException;
  36 import java.security.NoSuchAlgorithmException;
  37 import java.util.Collections;
  38 import java.util.HashMap;
  39 import java.util.Map;
  40 import javax.ws.rs.client.Entity;
  41 import javax.ws.rs.core.MediaType;
  42 import javax.ws.rs.core.Response;
  43 import javax.ws.rs.core.Response.Status;
  44 import org.junit.AfterClass;
  45 import org.junit.BeforeClass;
  46 import org.junit.ClassRule;
  47 import org.junit.Test;
  48 import org.junit.rules.TemporaryFolder;
  49 import org.onap.policy.common.endpoints.event.comm.bus.internal.BusTopicParams;
  50 import org.onap.policy.common.endpoints.http.client.HttpClient;
  51 import org.onap.policy.common.endpoints.http.client.HttpClientConfigException;
  52 import org.onap.policy.common.endpoints.http.client.HttpClientFactoryInstance;
  53 import org.onap.policy.common.endpoints.parameters.RestServerParameters;
  54 import org.onap.policy.common.endpoints.parameters.TopicParameterGroup;
  55 import org.onap.policy.common.gson.GsonMessageBodyHandler;
  56 import org.onap.policy.common.utils.network.NetworkUtil;
  57 import org.onap.policy.models.decisions.concepts.DecisionRequest;
  58 import org.onap.policy.models.decisions.concepts.DecisionResponse;
  59 import org.onap.policy.models.errors.concepts.ErrorResponse;
  60 import org.onap.policy.pdpx.main.PolicyXacmlPdpException;
  61 import org.onap.policy.pdpx.main.parameters.CommonTestData;
  62 import org.onap.policy.pdpx.main.parameters.XacmlPdpParameterGroup;
  63 import org.onap.policy.pdpx.main.startstop.Main;
  64 import org.onap.policy.pdpx.main.startstop.XacmlPdpActivator;
  65 import org.slf4j.Logger;
  66 import org.slf4j.LoggerFactory;
  67
  68 public class TestDecision {
  69
  70     private static final Logger LOGGER = LoggerFactory.getLogger(TestDecision.class);
  71
  72     private static int port;
  73     private static Main main;
  74     private static HttpClient client;
  75     private static CommonTestData testData = new CommonTestData();
  76
  77     @ClassRule
  78     public static final TemporaryFolder appsFolder = new TemporaryFolder();
  79
  80     /**
  81      * BeforeClass setup environment.
  82      * @throws IOException Cannot create temp apps folder
  83      * @throws Exception exception if service does not start
  84      */
  85     @BeforeClass
  86     public static void beforeClass() throws Exception {
  87         System.setProperty("org.eclipse.jetty.util.log.class", "org.eclipse.jetty.util.log.StdErrLog");
  88         System.setProperty("org.eclipse.jetty.LEVEL", "OFF");
  89
  90         port = NetworkUtil.allocPort();
  91
  92         //
  93         // Copy test directory over of the application directories
  94         //
  95         Path src = Paths.get("src/test/resources/apps");
  96         File apps = appsFolder.newFolder("apps");
  97         Files.walk(src).forEach(source -> {
  98             copy(source, apps.toPath().resolve(src.relativize(source)));
  99         });
 100         //
 101         // Get the parameters file correct.
 102         //
 103         RestServerParameters rest =
 104             testData.toObject(testData.getRestServerParametersMap(port), RestServerParameters.class);
 105         RestServerParameters policyApiParameters =
 106                         testData.toObject(testData.getPolicyApiParametersMap(false), RestServerParameters.class);
 107         TopicParameterGroup topicParameterGroup =
 108                         testData.toObject(testData.getTopicParametersMap(false), TopicParameterGroup.class);
 109         XacmlPdpParameterGroup params = new XacmlPdpParameterGroup("XacmlPdpGroup", rest, policyApiParameters,
 110                         topicParameterGroup, apps.getAbsolutePath());
 111         final Gson gson = new GsonBuilder().create();
 112         File fileParams = appsFolder.newFile("params.json");
 113         String jsonParams = gson.toJson(params);
 114         LOGGER.info("Creating new params: {}", jsonParams);
 115         Files.write(fileParams.toPath(), jsonParams.getBytes());
 116         //
 117         // Start the service
 118         //
 119         main = startXacmlPdpService(fileParams);
 120         XacmlPdpActivator.getCurrent().startXacmlRestController();
 121         //
 122         // Make sure it is running
 123         //
 124         if (!NetworkUtil.isTcpPortOpen("localhost", port, 20, 1000L)) {
 125             throw new IllegalStateException("Cannot connect to port " + port);
 126         }
 127         //
 128         // Create a client
 129         //
 130         client = getNoAuthHttpClient();
 131     }
 132
 133     @AfterClass
 134     public static void after() throws PolicyXacmlPdpException {
 135         stopXacmlPdpService(main);
 136         client.shutdown();
 137     }
 138
 139     @Test
 140     public void testDecision_UnsupportedAction() throws Exception {
 141
 142         LOGGER.info("Running test testDecision_UnsupportedAction");
 143
 144         DecisionRequest request = new DecisionRequest();
 145         request.setOnapName("DROOLS");
 146         request.setAction("foo");
 147         Map<String, Object> guard = new HashMap<String, Object>();
 148         guard.put("actor", "foo");
 149         guard.put("recipe", "bar");
 150         guard.put("target", "somevnf");
 151         guard.put("clname", "phoneyloop");
 152         request.setResource(guard);
 153
 154         ErrorResponse response = getErrorDecision(request);
 155         LOGGER.info("Response {}", response);
 156         assertThat(response.getResponseCode()).isEqualTo(Status.BAD_REQUEST);
 157         assertThat(response.getErrorMessage()).isEqualToIgnoringCase("No application for action foo");
 158     }
 159
 160     @Test
 161     public void testDecision_Guard() throws KeyManagementException, NoSuchAlgorithmException,
 162         ClassNotFoundException {
 163
 164         LOGGER.info("Running test testDecision_Guard");
 165
 166         DecisionRequest request = new DecisionRequest();
 167         request.setOnapName("DROOLS");
 168         request.setAction("guard");
 169         Map<String, Object> guard = new HashMap<String, Object>();
 170         guard.put("actor", "foo");
 171         guard.put("recipe", "bar");
 172         guard.put("target", "somevnf");
 173         guard.put("clname", "phoneyloop");
 174         request.setResource(guard);
 175
 176         DecisionResponse response = getDecision(request);
 177         LOGGER.info("Response {}", response);
 178         assertThat(response.getStatus()).isEqualTo("Permit");
 179     }
 180
 181     private static Main startXacmlPdpService(File params) throws PolicyXacmlPdpException {
 182         final String[] XacmlPdpConfigParameters = {"-c", params.getAbsolutePath()};
 183         return new Main(XacmlPdpConfigParameters);
 184     }
 185
 186     private static void stopXacmlPdpService(final Main main) throws PolicyXacmlPdpException {
 187         main.shutdown();
 188     }
 189
 190     private DecisionResponse getDecision(DecisionRequest request) {
 191
 192         Entity<DecisionRequest> entityRequest = Entity.entity(request, MediaType.APPLICATION_JSON);
 193         Response response = client.post("", entityRequest, Collections.emptyMap());
 194
 195         assertEquals(200, response.getStatus());
 196
 197         return HttpClient.getBody(response, DecisionResponse.class);
 198     }
 199
 200     private ErrorResponse getErrorDecision(DecisionRequest request) {
 201
 202         Entity<DecisionRequest> entityRequest = Entity.entity(request, MediaType.APPLICATION_JSON);
 203         Response response = client.post("", entityRequest, Collections.emptyMap());
 204
 205         assertEquals(400, response.getStatus());
 206
 207         return HttpClient.getBody(response, ErrorResponse.class);
 208     }
 209
 210     private static HttpClient getNoAuthHttpClient() throws HttpClientConfigException {
 211         return HttpClientFactoryInstance.getClientFactory().build(BusTopicParams.builder()
 212                 .clientName("testDecisionClient")
 213                 .serializationProvider(GsonMessageBodyHandler.class.getName())
 214                 .useHttps(false).allowSelfSignedCerts(false).hostname("localhost").port(port)
 215                 .basePath("policy/pdpx/v1/decision")
 216                 .userName("healthcheck").password("zb!XztG34").managed(true).build());
 217     }
 218
 219     private static void copy(Path source, Path dest) {
 220         try {
 221             LOGGER.info("Copying {} to {}", source, dest);
 222             Files.copy(source, dest, StandardCopyOption.REPLACE_EXISTING);
 223         } catch (IOException e) {
 224             LOGGER.error("Failed to copy {} to {}", source, dest);
 225         }
 226     }
 227
 228 }