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
10 * http://www.apache.org/licenses/LICENSE-2.0
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.
18 * SPDX-License-Identifier: Apache-2.0
19 * ============LICENSE_END=========================================================
22 package org.onap.policy.pdpx.main.rest;
24 import static org.assertj.core.api.Assertions.assertThat;
25 import static org.junit.Assert.assertEquals;
27 import com.google.gson.Gson;
28 import com.google.gson.GsonBuilder;
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;
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;
68 public class TestDecision {
70 private static final Logger LOGGER = LoggerFactory.getLogger(TestDecision.class);
72 private static int port;
73 private static Main main;
74 private static HttpClient client;
75 private static CommonTestData testData = new CommonTestData();
78 public static final TemporaryFolder appsFolder = new TemporaryFolder();
81 * BeforeClass setup environment.
82 * @throws IOException Cannot create temp apps folder
83 * @throws Exception exception if service does not start
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");
90 port = NetworkUtil.allocPort();
93 // Copy test directory over of the application directories
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)));
101 // Get the parameters file correct.
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());
119 main = startXacmlPdpService(fileParams);
120 XacmlPdpActivator.getCurrent().startXacmlRestController();
122 // Make sure it is running
124 if (!NetworkUtil.isTcpPortOpen("localhost", port, 20, 1000L)) {
125 throw new IllegalStateException("Cannot connect to port " + port);
130 client = getNoAuthHttpClient();
134 public static void after() throws PolicyXacmlPdpException {
135 stopXacmlPdpService(main);
140 public void testDecision_UnsupportedAction() throws Exception {
142 LOGGER.info("Running test testDecision_UnsupportedAction");
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);
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");
161 public void testDecision_Guard() throws KeyManagementException, NoSuchAlgorithmException,
162 ClassNotFoundException {
164 LOGGER.info("Running test testDecision_Guard");
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);
176 DecisionResponse response = getDecision(request);
177 LOGGER.info("Response {}", response);
178 assertThat(response.getStatus()).isEqualTo("Permit");
181 private static Main startXacmlPdpService(File params) throws PolicyXacmlPdpException {
182 final String[] XacmlPdpConfigParameters = {"-c", params.getAbsolutePath()};
183 return new Main(XacmlPdpConfigParameters);
186 private static void stopXacmlPdpService(final Main main) throws PolicyXacmlPdpException {
190 private DecisionResponse getDecision(DecisionRequest request) {
192 Entity<DecisionRequest> entityRequest = Entity.entity(request, MediaType.APPLICATION_JSON);
193 Response response = client.post("", entityRequest, Collections.emptyMap());
195 assertEquals(200, response.getStatus());
197 return HttpClient.getBody(response, DecisionResponse.class);
200 private ErrorResponse getErrorDecision(DecisionRequest request) {
202 Entity<DecisionRequest> entityRequest = Entity.entity(request, MediaType.APPLICATION_JSON);
203 Response response = client.post("", entityRequest, Collections.emptyMap());
205 assertEquals(400, response.getStatus());
207 return HttpClient.getBody(response, ErrorResponse.class);
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());
219 private static void copy(Path source, Path dest) {
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);