main/src/test/java/org/onap/policy/api/main/rest/TestApiRestServer.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2018 Samsung Electronics Co., Ltd. All rights reserved.
   4  *  Copyright (C) 2019-2021 AT&T Intellectual Property. All rights reserved.
   5  *  Modifications Copyright (C) 2019-2020 Nordix Foundation.
   6  *  Modifications Copyright (C) 2020 Bell Canada.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  *
  20  * SPDX-License-Identifier: Apache-2.0
  21  * ============LICENSE_END=========================================================
  22  */
  23
  24 package org.onap.policy.api.main.rest;
  25
  26 import static org.assertj.core.api.Assertions.assertThat;
  27 import static org.junit.Assert.assertEquals;
  28 import static org.junit.Assert.assertFalse;
  29 import static org.junit.Assert.assertNotNull;
  30 import static org.junit.Assert.assertNull;
  31 import static org.junit.Assert.assertTrue;
  32
  33 import java.io.File;
  34 import java.io.IOException;
  35 import java.lang.reflect.Constructor;
  36 import java.lang.reflect.Modifier;
  37 import java.security.SecureRandom;
  38 import java.util.Collections;
  39 import java.util.List;
  40 import java.util.Map;
  41 import java.util.Properties;
  42 import javax.net.ssl.SSLContext;
  43 import javax.net.ssl.TrustManager;
  44 import javax.ws.rs.client.Client;
  45 import javax.ws.rs.client.ClientBuilder;
  46 import javax.ws.rs.client.Entity;
  47 import javax.ws.rs.client.Invocation;
  48 import javax.ws.rs.client.WebTarget;
  49 import javax.ws.rs.core.Response;
  50 import javax.ws.rs.core.Response.Status;
  51 import org.glassfish.jersey.client.ClientProperties;
  52 import org.glassfish.jersey.client.authentication.HttpAuthenticationFeature;
  53 import org.junit.AfterClass;
  54 import org.junit.BeforeClass;
  55 import org.junit.Test;
  56 import org.onap.policy.api.main.parameters.ApiParameterGroup;
  57 import org.onap.policy.api.main.parameters.CommonTestData;
  58 import org.onap.policy.api.main.rest.provider.PolicyProvider;
  59 import org.onap.policy.api.main.rest.provider.PolicyTypeProvider;
  60 import org.onap.policy.api.main.startstop.Main;
  61 import org.onap.policy.common.endpoints.http.server.YamlMessageBodyHandler;
  62 import org.onap.policy.common.endpoints.report.HealthCheckReport;
  63 import org.onap.policy.common.gson.GsonMessageBodyHandler;
  64 import org.onap.policy.common.parameters.ParameterService;
  65 import org.onap.policy.common.utils.coder.StandardCoder;
  66 import org.onap.policy.common.utils.coder.StandardYamlCoder;
  67 import org.onap.policy.common.utils.network.NetworkUtil;
  68 import org.onap.policy.common.utils.resources.ResourceUtils;
  69 import org.onap.policy.common.utils.resources.TextFileUtils;
  70 import org.onap.policy.common.utils.security.SelfSignedKeyStore;
  71 import org.onap.policy.models.base.PfModelException;
  72 import org.onap.policy.models.errors.concepts.ErrorResponse;
  73 import org.onap.policy.models.provider.PolicyModelsProviderParameters;
  74 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
  75
  76 /**
  77  * Class to perform unit test of {@link ApiRestController}.
  78  *
  79  * @author Chenfei Gao (cgao@research.att.com)
  80  */
  81 public class TestApiRestServer {
  82
  83     private static final String ALIVE = "alive";
  84     private static final String SELF = NetworkUtil.getHostname();
  85     private static final String NAME = "Policy API";
  86     private static final String APP_JSON = "application/json";
  87     private static final String APP_YAML = "application/yaml";
  88
  89     private static final String HEALTHCHECK_ENDPOINT = "healthcheck";
  90     private static final String STATISTICS_ENDPOINT = "statistics";
  91
  92     private static final String OP_POLICY_NAME_VCPE = "operational.restart";
  93
  94     private static final String POLICYTYPES = "policytypes";
  95     private static final String POLICYTYPES_TCA = "policytypes/onap.policies.monitoring.tcagen2";
  96     private static final String POLICYTYPES_COLLECTOR =
  97             "policytypes/onap.policies.monitoring.dcaegen2.collectors.datafile.datafile-app-server";
  98     private static final String POLICYTYPES_TCA_VERSION = "policytypes/onap.policies.monitoring.tcagen2/versions/1.0.0";
  99     private static final String POLICYTYPES_TCA_LATEST = "policytypes/onap.policies.monitoring.tcagen2/versions/latest";
 100     private static final String POLICYTYPES_COLLECTOR_VERSION =
 101             "policytypes/onap.policies.monitoring.dcaegen2.collectors.datafile.datafile-app-server/versions/1.0.0";
 102     private static final String POLICYTYPES_COLLECTOR_LATEST =
 103             "policytypes/onap.policies.monitoring.dcaegen2.collectors.datafile.datafile-app-server/versions/latest";
 104
 105     private static final String POLICYTYPES_DROOLS = "policytypes/onap.policies.controlloop.operational.common.Drools";
 106     private static final String POLICYTYPES_DROOLS_VERSION = POLICYTYPES_DROOLS + "/versions/1.0.0";
 107     private static final String POLICYTYPES_DROOLS_VERSION_LATEST = POLICYTYPES_DROOLS + "/versions/latest";
 108
 109     private static final String POLICYTYPES_NAMING_VERSION = POLICYTYPES + "/onap.policies.Naming/versions/1.0.0";
 110
 111     private static final String POLICYTYPES_TCA_POLICIES =
 112             "policytypes/onap.policies.monitoring.tcagen2/versions/1.0.0/policies";
 113     private static final String POLICYTYPES_TCA_POLICIES_VCPE =
 114             "policytypes/onap.policies.monitoring.tcagen2/versions/1.0.0/policies/onap.restart.tca";
 115     private static final String POLICYTYPES_TCA_POLICIES_VCPE_VERSION1 =
 116             "policytypes/" + "onap.policies.monitoring.tcagen2/versions/1.0.0/policies/onap.restart.tca/versions/1.0.0";
 117     private static final String POLICYTYPES_TCA_POLICIES_VCPE_LATEST = "policytypes/"
 118             + "onap.policies.monitoring.tcagen2/versions/1.0.0/policies/onap.restart.tca/versions/latest";
 119
 120     private static final String POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION =
 121             POLICYTYPES_DROOLS_VERSION + "/policies/" + OP_POLICY_NAME_VCPE + "/versions/1.0.0";
 122
 123     private static final String POLICIES = "policies";
 124
 125     // @formatter:off
 126     private static final String[] TOSCA_POLICY_RESOURCE_NAMES = {"policies/vCPE.policy.monitoring.input.tosca.json",
 127         "policies/vCPE.policy.monitoring.input.tosca.yaml", "policies/vDNS.policy.monitoring.input.tosca.json",
 128         "policies/vDNS.policy.monitoring.input.tosca.v2.yaml"};
 129
 130     private static final String[] TOSCA_POLICIES_RESOURCE_NAMES = {
 131         "policies/vCPE.policies.optimization.input.tosca.json", "policies/vCPE.policies.optimization.input.tosca.yaml"};
 132
 133     private static final String TOSCA_POLICYTYPE_OP_RESOURCE =
 134         "policytypes/onap.policies.controlloop.operational.Common.yaml";
 135
 136     private static final String[] TOSCA_POLICYTYPE_RESOURCE_NAMES = {
 137         "policytypes/onap.policies.monitoring.tcagen2.yaml",
 138         "policytypes/onap.policies.monitoring.dcaegen2.collectors.datafile.datafile-app-server.yaml",
 139         "policytypes/onap.policies.controlloop.operational.common.Drools.yaml",
 140         "policytypes/onap.policies.controlloop.guard.Common.yaml",
 141         "policytypes/onap.policies.controlloop.guard.common.Blacklist.yaml",
 142         "policytypes/onap.policies.controlloop.guard.common.FrequencyLimiter.yaml",
 143         "policytypes/onap.policies.controlloop.guard.common.MinMax.yaml",
 144         "policytypes/onap.policies.controlloop.guard.coordination.FirstBlocksSecond.yaml",
 145         "policytypes/onap.policies.optimization.resource.AffinityPolicy.yaml",
 146         "policytypes/onap.policies.optimization.resource.DistancePolicy.yaml",
 147         "policytypes/onap.policies.optimization.resource.HpaPolicy.yaml",
 148         "policytypes/onap.policies.optimization.resource.OptimizationPolicy.yaml",
 149         "policytypes/onap.policies.optimization.resource.PciPolicy.yaml",
 150         "policytypes/onap.policies.optimization.service.QueryPolicy.yaml",
 151         "policytypes/onap.policies.optimization.service.SubscriberPolicy.yaml",
 152         "policytypes/onap.policies.optimization.resource.Vim_fit.yaml",
 153         "policytypes/onap.policies.optimization.resource.VnfPolicy.yaml"};
 154
 155     private static final String TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_JSON =
 156         "policies/vCPE.policy.operational.input.tosca.json";
 157
 158     private static final String TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_YAML =
 159         "policies/vCPE.policy.operational.input.tosca.yaml";
 160
 161     private static final String POLICIES_VCPE_VERSION1 = "policies/onap.restart.tca/versions/1.0.0";
 162
 163     private static PolicyModelsProviderParameters providerParams;
 164     private static ApiParameterGroup apiParamGroup;
 165     private static PolicyProvider policyProvider;
 166     private static PolicyTypeProvider policyTypeProvider;
 167
 168     // @formatter:on
 169
 170     private static final StandardCoder standardCoder = new StandardCoder();
 171
 172     private static int apiPort;
 173     private static Main apiMain;
 174
 175     private static StandardYamlCoder standardYamlCoder = new StandardYamlCoder();
 176
 177     /**
 178      * Initializes parameters and set up test environment.
 179      *
 180      * @throws PfModelException the PfModel parsing exception
 181      * @throws IOException on I/O exceptions
 182      * @throws InterruptedException if interrupted
 183      */
 184     @BeforeClass
 185     public static void setupParameters() throws PfModelException, IOException, InterruptedException {
 186         providerParams = new PolicyModelsProviderParameters();
 187         // H2, use "org.mariadb.jdbc.Driver" and "jdbc:mariadb://localhost:3306/policy" for locally installed MariaDB
 188         providerParams.setDatabaseDriver("org.h2.Driver");
 189         providerParams.setDatabaseUrl("jdbc:h2:mem:testdb");
 190         providerParams.setDatabaseUser("policy");
 191         providerParams.setDatabasePassword("P01icY");
 192         providerParams.setPersistenceUnit("ToscaConceptTest");
 193         apiParamGroup = new ApiParameterGroup("ApiGroup", null, providerParams, Collections.emptyList(),
 194                 Collections.emptyList());
 195         ParameterService.register(apiParamGroup, true);
 196
 197         policyTypeProvider = new PolicyTypeProvider();
 198         policyProvider = new PolicyProvider();
 199
 200         apiPort = NetworkUtil.allocPort();
 201
 202         final String[] apiConfigParameters = new String[2];
 203         final Properties systemProps = System.getProperties();
 204         systemProps.put("javax.net.ssl.keyStore", new SelfSignedKeyStore().getKeystoreName());
 205         systemProps.put("javax.net.ssl.keyStorePassword", SelfSignedKeyStore.KEYSTORE_PASSWORD);
 206         System.setProperties(systemProps);
 207         new CommonTestData().makeParameters("src/test/resources/parameters/ApiConfigParameters_Https.json",
 208                 "src/test/resources/parameters/ApiConfigParameters_HttpsXXX.json", apiPort);
 209         apiConfigParameters[0] = "-c";
 210         apiConfigParameters[1] = "src/test/resources/parameters/ApiConfigParameters_HttpsXXX.json";
 211
 212         apiMain = new Main(apiConfigParameters);
 213     }
 214
 215     /**
 216      * Method for cleanup after each test.
 217      */
 218     @AfterClass
 219     public static void teardown() throws Exception {
 220         policyTypeProvider.close();
 221         policyProvider.close();
 222
 223         if (apiMain != null) {
 224             apiMain.shutdown();
 225         }
 226     }
 227
 228     @Test
 229     public void testApiStatisticsConstructorIsPrivate() {
 230
 231         try {
 232             final Constructor<ApiStatisticsManager> constructor = ApiStatisticsManager.class.getDeclaredConstructor();
 233             assertTrue(Modifier.isPrivate(constructor.getModifiers()));
 234             constructor.setAccessible(true);
 235             constructor.newInstance();
 236
 237         } catch (final Exception exp) {
 238             assertTrue(exp.getCause().toString().contains("Instantiation of the class is not allowed"));
 239         }
 240     }
 241
 242     @Test
 243     public void testCreatePolicyTypes() throws Exception {
 244         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 245             Response rawResponse = createResource(POLICYTYPES, resrcName);
 246             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 247             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 248             assertNotNull(response);
 249             assertFalse(response.getPolicyTypes().isEmpty());
 250         }
 251
 252         // Send a policy type with a null value to trigger an error
 253         Response rawResponse = readResource(POLICYTYPES, APP_JSON);
 254         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 255         ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 256         String firstPolicyType = response.getPolicyTypes().keySet().iterator().next();
 257         response.getPolicyTypes().put(firstPolicyType, null);
 258         Response rawResponse2 = createResource(POLICYTYPES, standardCoder.encode(response));
 259         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse2.getStatus());
 260         ErrorResponse errorResponse = rawResponse2.readEntity(ErrorResponse.class);
 261         assertEquals("no policy types specified on service template", errorResponse.getErrorMessage());
 262     }
 263
 264     @Test
 265     public void testCreatePolicies() throws Exception {
 266         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 267             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName);
 268             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 269         }
 270
 271         new File("src/test/resources/policies/BadTestPolicy.yaml").deleteOnExit();
 272
 273         // Send a policy with no policy type trigger an error
 274         String toscaPolicy = ResourceUtils
 275                 .getResourceAsString(TOSCA_POLICY_RESOURCE_NAMES[TOSCA_POLICIES_RESOURCE_NAMES.length - 1]);
 276
 277         toscaPolicy = toscaPolicy.replaceAll("onap.policies.monitoring.tcagen2", "IDontExist");
 278         TextFileUtils.putStringAsTextFile(toscaPolicy, "src/test/resources/policies/BadTestPolicy.yaml");
 279
 280         Response rawResponse2 =
 281                 createResource(POLICYTYPES_TCA_POLICIES, "src/test/resources/policies/BadTestPolicy.yaml");
 282         assertEquals(Response.Status.NOT_ACCEPTABLE.getStatusCode(), rawResponse2.getStatus());
 283         ErrorResponse errorResponse = rawResponse2.readEntity(ErrorResponse.class);
 284         assertThat(errorResponse.getErrorMessage())
 285                 .contains("item \"entity\" value \"onap.restart.tca:1.0.0\" INVALID, does not equal existing entity");
 286     }
 287
 288     @Test
 289     public void testSimpleCreatePolicies() throws Exception {
 290         for (String resrcName : TOSCA_POLICIES_RESOURCE_NAMES) {
 291             Response rawResponse = createResource(POLICIES, resrcName);
 292             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 293         }
 294
 295         new File("src/test/resources/policies/BadTestPolicy.yaml").deleteOnExit();
 296
 297         // Send a policy with no policy type trigger an error
 298         String toscaPolicy = ResourceUtils
 299                 .getResourceAsString(TOSCA_POLICY_RESOURCE_NAMES[TOSCA_POLICIES_RESOURCE_NAMES.length - 1]);
 300
 301         toscaPolicy = toscaPolicy.replaceAll("onap.policies.monitoring.tcagen2", "IDontExist");
 302         toscaPolicy = toscaPolicy.replaceAll("onap.restart.tca", "onap.restart.tca.IDontExist");
 303         TextFileUtils.putStringAsTextFile(toscaPolicy, "src/test/resources/policies/BadTestPolicy.yaml");
 304
 305         Response rawResponse2 = createResource(POLICIES, "src/test/resources/policies/BadTestPolicy.yaml");
 306         ErrorResponse errorResponse = rawResponse2.readEntity(ErrorResponse.class);
 307         assertEquals(Response.Status.NOT_ACCEPTABLE.getStatusCode(), rawResponse2.getStatus());
 308         assertThat(errorResponse.getErrorMessage())
 309                 .contains("item \"policy type\" value \"IDontExist:1.0.0\" INVALID, not found");
 310     }
 311
 312     @SuppressWarnings("unchecked")
 313     @Test
 314     public void testToscaCompliantOpDroolsPolicies() throws Exception {
 315         Response rawResponse = createResource(POLICYTYPES, TOSCA_POLICYTYPE_OP_RESOURCE);
 316         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 317
 318         rawResponse = readResource(POLICYTYPES_DROOLS_VERSION, APP_JSON);
 319         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 320
 321         rawResponse = createResource(POLICIES, TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_JSON);
 322         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 323
 324         rawResponse = createResource(POLICIES, TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_YAML);
 325         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 326
 327         rawResponse = readResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_JSON);
 328         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 329
 330         rawResponse = deleteResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_JSON);
 331         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 332
 333         rawResponse = createResource(POLICIES, TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_YAML);
 334         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 335
 336         rawResponse = readResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_JSON);
 337         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 338
 339         rawResponse = readResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_YAML);
 340         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 341
 342         ToscaServiceTemplate toscaVcpeSt = rawResponse.readEntity(ToscaServiceTemplate.class);
 343         assertEquals(1, toscaVcpeSt.getToscaTopologyTemplate().getPolicies().size());
 344         assertEquals(OP_POLICY_NAME_VCPE,
 345                 toscaVcpeSt.getToscaTopologyTemplate().getPolicies().get(0).get(OP_POLICY_NAME_VCPE).getName());
 346
 347         Map<String, Object> props =
 348                 toscaVcpeSt.getToscaTopologyTemplate().getPolicies().get(0).get(OP_POLICY_NAME_VCPE).getProperties();
 349         assertNotNull(props);
 350
 351         List<Object> operations = (List<Object>) props.get("operations");
 352         assertEquals(1, operations.size());
 353         assertEquals(props.get("trigger"), ((Map<String, Object>) operations.get(0)).get("id"));
 354
 355         Map<String, Object> operation =
 356                 (Map<String, Object>) ((Map<String, Object>) operations.get(0)).get("operation");
 357         assertEquals("APPC", operation.get("actor"));
 358         assertEquals("Restart", operation.get("operation"));
 359
 360         rawResponse = deleteResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_JSON);
 361         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 362     }
 363
 364     @Test
 365     public void testHealthCheckSuccessJson() throws Exception {
 366         testHealthCheckSuccess(APP_JSON);
 367     }
 368
 369     @Test
 370     public void testHealthCheckSuccessYaml() throws Exception {
 371         testHealthCheckSuccess(APP_YAML);
 372     }
 373
 374     private void testHealthCheckSuccess(String mediaType) throws Exception {
 375         final Invocation.Builder invocationBuilder = sendHttpsRequest(HEALTHCHECK_ENDPOINT, mediaType);
 376         final HealthCheckReport report = invocationBuilder.get(HealthCheckReport.class);
 377         validateHealthCheckReport(NAME, SELF, true, 200, ALIVE, report);
 378     }
 379
 380     @Test
 381     public void testApiStatistics_200_Json() throws Exception {
 382         testApiStatistics_200(APP_JSON);
 383     }
 384
 385     @Test
 386     public void testApiStatistics_200_Yaml() throws Exception {
 387         testApiStatistics_200(APP_YAML);
 388     }
 389
 390     private void testApiStatistics_200(String mediaType) throws Exception {
 391         Invocation.Builder invocationBuilder = sendHttpsRequest(STATISTICS_ENDPOINT, mediaType);
 392         StatisticsReport report = invocationBuilder.get(StatisticsReport.class);
 393         validateStatisticsReport(report, 200);
 394         updateApiStatistics();
 395         invocationBuilder = sendHttpsRequest(STATISTICS_ENDPOINT, mediaType);
 396         report = invocationBuilder.get(StatisticsReport.class);
 397         validateStatisticsReport(report, 200);
 398         ApiStatisticsManager.resetAllStatistics();
 399     }
 400
 401     @Test
 402     public void testReadPolicyTypesJson() throws Exception {
 403         testReadPolicyTypes(APP_JSON);
 404     }
 405
 406     @Test
 407     public void testReadPolicyTypesYaml() throws Exception {
 408         testReadPolicyTypes(APP_YAML);
 409     }
 410
 411     private void testReadPolicyTypes(String mediaType) throws Exception {
 412         Response rawResponse = readResource("policytypes/onap.policies.optimization.resource.HpaPolicy", mediaType);
 413         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 414         ToscaServiceTemplate namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 415         assertNotNull(namingServiceTemplate);
 416         assertEquals(3, namingServiceTemplate.getPolicyTypesAsMap().size());
 417         assertEquals(5, namingServiceTemplate.getDataTypesAsMap().size());
 418
 419         rawResponse = readResource(POLICYTYPES, mediaType);
 420         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 421         ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 422         assertFalse(response.getPolicyTypes().isEmpty());
 423
 424         rawResponse = readResource(POLICYTYPES_TCA, mediaType);
 425         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 426
 427         rawResponse = readResource(POLICYTYPES_TCA_VERSION, mediaType);
 428         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 429
 430         rawResponse = readResource(POLICYTYPES_TCA_LATEST, mediaType);
 431         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 432
 433         rawResponse = readResource(POLICYTYPES_COLLECTOR, mediaType);
 434         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 435
 436         rawResponse = readResource(POLICYTYPES_COLLECTOR_VERSION, mediaType);
 437         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 438
 439         rawResponse = readResource(POLICYTYPES_COLLECTOR_LATEST, mediaType);
 440         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 441
 442         rawResponse = readResource(POLICYTYPES_DROOLS, mediaType);
 443         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 444
 445         rawResponse = readResource(POLICYTYPES_DROOLS_VERSION, mediaType);
 446         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 447
 448         rawResponse = readResource(POLICYTYPES_DROOLS_VERSION_LATEST, mediaType);
 449         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 450
 451         rawResponse = readResource(POLICYTYPES_NAMING_VERSION, mediaType);
 452         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 453     }
 454
 455     @Test
 456     public void testDeletePolicyTypeJson() throws Exception {
 457         testDeletePolicyType(APP_JSON);
 458     }
 459
 460     @Test
 461     public void testDeletePolicyTypeYaml() throws Exception {
 462         testDeletePolicyType(APP_YAML);
 463     }
 464
 465     private void testDeletePolicyType(String mediaType) throws Exception {
 466         Response rawResponse = deleteResource("policytypes/onap.policies.IDoNotExist/versions/1.0.0", mediaType);
 467         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 468
 469         rawResponse = createResource(POLICYTYPES, "policytypes/onap.policies.Test.yaml");
 470         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 471
 472         rawResponse = readResource("policytypes/onap.policies.Test/versions/1.0.0", mediaType);
 473         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 474
 475         rawResponse = deleteResource("policytypes/onap.policies.Test/versions/1.0.0", mediaType);
 476         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 477
 478         rawResponse = readResource("policytypes/onap.policies.Test/versions/1.0.0", mediaType);
 479         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 480     }
 481
 482     @Test
 483     public void testReadPoliciesJson() throws Exception {
 484         testReadPolicies(APP_JSON);
 485     }
 486
 487     @Test
 488     public void testReadPoliciesYaml() throws Exception {
 489         testReadPolicies(APP_YAML);
 490     }
 491
 492     private void testReadPolicies(String mediaType) throws Exception {
 493         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 494             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName);
 495             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 496         }
 497
 498         Response rawResponse = readResource(POLICYTYPES_TCA_POLICIES, mediaType);
 499         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 500
 501         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE, mediaType);
 502         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 503
 504         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType);
 505         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 506
 507         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE_LATEST, mediaType);
 508         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 509
 510         rawResponse = deleteResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType);
 511         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 512
 513     }
 514
 515     @Test
 516     public void testNamingPolicyGet() throws Exception {
 517
 518         Response rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 519                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/1.0.0", APP_JSON);
 520         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 521
 522         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 523                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/1.0.0?mode=referenced", APP_JSON);
 524         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 525
 526         ToscaServiceTemplate namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 527         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 528         assertEquals(1, namingServiceTemplate.getPolicyTypesAsMap().size());
 529         assertEquals(3, namingServiceTemplate.getDataTypesAsMap().size());
 530
 531         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 532                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/latest?mode=referenced", APP_JSON);
 533         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 534
 535         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 536         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 537         assertEquals(1, namingServiceTemplate.getPolicyTypesAsMap().size());
 538         assertEquals(3, namingServiceTemplate.getDataTypesAsMap().size());
 539
 540         rawResponse =
 541                 readResource("policytypes/onap.policies.Naming/versions/1.0.0/policies?mode=referenced", APP_JSON);
 542         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 543
 544         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 545         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 546         assertEquals(1, namingServiceTemplate.getPolicyTypesAsMap().size());
 547         assertEquals(3, namingServiceTemplate.getDataTypesAsMap().size());
 548
 549         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 550                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/1.0.0", APP_JSON);
 551         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 552
 553         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 554
 555         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 556         assertNull(namingServiceTemplate.getPolicyTypes());
 557         assertNull(namingServiceTemplate.getDataTypes());
 558
 559         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 560                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/latest", APP_JSON);
 561         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 562
 563         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 564         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 565         assertNull(namingServiceTemplate.getPolicyTypes());
 566         assertNull(namingServiceTemplate.getDataTypes());
 567
 568         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/policies", APP_JSON);
 569         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 570
 571         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 572         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 573         assertNull(namingServiceTemplate.getPolicyTypes());
 574         assertNull(namingServiceTemplate.getDataTypes());
 575     }
 576
 577     @Test
 578     public void testDeletePoliciesJson() throws Exception {
 579         testDeletePolicies(APP_JSON);
 580     }
 581
 582     @Test
 583     public void testDeletePoliciesYaml() throws Exception {
 584         testDeletePolicies(APP_YAML);
 585     }
 586
 587     private void testDeletePolicies(String mediaType) throws Exception {
 588         Response rawResponse = deleteResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType);
 589         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 590         ErrorResponse error = rawResponse.readEntity(ErrorResponse.class);
 591         assertEquals("policy onap.restart.tca:1.0.0 not found", error.getErrorMessage());
 592     }
 593
 594     @Test
 595     public void testDeletePolicyVersionJson() throws Exception {
 596         testDeletePolicyVersion(APP_JSON);
 597     }
 598
 599     @Test
 600     public void testDeletePolicyVersionYaml() throws Exception {
 601         testDeletePolicyVersion(APP_YAML);
 602     }
 603
 604     private void testDeletePolicyVersion(String mediaType) throws Exception {
 605         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 606             Response rawResponse = createResource(POLICYTYPES, resrcName);
 607             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 608             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 609             assertNotNull(response);
 610             assertFalse(response.getPolicyTypes().isEmpty());
 611         }
 612         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 613             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName);
 614             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 615         }
 616         Response rawResponse = deleteResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType);
 617         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 618
 619         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType);
 620         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 621         ErrorResponse errorResponse = rawResponse.readEntity(ErrorResponse.class);
 622         assertEquals("policies for onap.restart.tca:1.0.0 do not exist", errorResponse.getErrorMessage());
 623
 624         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE, mediaType);
 625         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 626         errorResponse = rawResponse.readEntity(ErrorResponse.class);
 627         assertEquals("policies for onap.restart.tca:null do not exist", errorResponse.getErrorMessage());
 628
 629         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE_LATEST, mediaType);
 630         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 631         errorResponse = rawResponse.readEntity(ErrorResponse.class);
 632         assertEquals("policies for onap.restart.tca:null do not exist", errorResponse.getErrorMessage());
 633     }
 634
 635     @Test
 636     public void testGetAllVersionOfPolicyJson() throws Exception {
 637         testGetAllVersionOfPolicy(APP_JSON);
 638     }
 639
 640     @Test
 641     public void testGetAllVersionOfPolicyYaml() throws Exception {
 642         testGetAllVersionOfPolicy(APP_YAML);
 643     }
 644
 645     private void testGetAllVersionOfPolicy(String mediaType) throws Exception {
 646         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 647             Response rawResponse = createResource(POLICYTYPES, resrcName);
 648             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 649             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 650             assertNotNull(response);
 651             assertFalse(response.getPolicyTypes().isEmpty());
 652         }
 653         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 654             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName);
 655             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 656         }
 657         Response rawResponse = readResource(POLICYTYPES_TCA_POLICIES, mediaType);
 658         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 659     }
 660
 661     @Test
 662     public void testGetPoliciesJson() throws Exception {
 663         getPolicies(APP_JSON);
 664     }
 665
 666     @Test
 667     public void testGetPoliciesYaml() throws Exception {
 668         getPolicies(APP_YAML);
 669     }
 670
 671     private void getPolicies(String mediaType) throws Exception {
 672         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 673             Response rawResponse = createResource(POLICYTYPES, resrcName);
 674             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 675             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 676             assertThat(response).isNotNull();
 677             assertThat(response.getPolicyTypes()).isNotEmpty();
 678         }
 679         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 680             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName);
 681             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 682         }
 683         Response rawResponse = readResource(POLICIES, mediaType);
 684         assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 685         ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 686         assertThat(response.getToscaTopologyTemplate().getPolicies()).isNotEmpty();
 687     }
 688
 689     @Test
 690     public void testGetSpecificPolicyJson() throws Exception {
 691         getSpecificPolicy(APP_JSON);
 692     }
 693
 694     @Test
 695     public void testGetSpecificPolicyYaml() throws Exception {
 696         getSpecificPolicy(APP_YAML);
 697     }
 698
 699     private void getSpecificPolicy(String mediaType) throws Exception {
 700         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 701             Response rawResponse = createResource(POLICYTYPES, resrcName);
 702             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 703             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 704             assertThat(response).isNotNull();
 705             assertThat(response.getPolicyTypes()).isNotEmpty();
 706         }
 707         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 708             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName);
 709             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 710         }
 711         Response rawResponse = readResource(POLICIES_VCPE_VERSION1, mediaType);
 712         assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 713         ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 714         assertThat(response.getToscaTopologyTemplate().getPolicies()).hasSize(1);
 715     }
 716
 717     @Test
 718     public void testDeleteSpecificPolicy() throws Exception {
 719         Response rawResponse;
 720         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 721             rawResponse = createResource(POLICYTYPES, resrcName);
 722             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 723             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 724             assertThat(response).isNotNull();
 725             assertThat(response.getPolicyTypes()).isNotEmpty();
 726         }
 727         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 728             rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName);
 729             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 730         }
 731
 732         rawResponse = readResource(POLICIES_VCPE_VERSION1, APP_JSON);
 733         assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 734
 735         // delete a particular policy
 736         rawResponse = deleteResource(POLICIES_VCPE_VERSION1, APP_JSON);
 737         assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 738
 739         rawResponse = readResource(POLICIES_VCPE_VERSION1, APP_JSON);
 740         assertThat(rawResponse.getStatus()).isEqualTo(Status.NOT_FOUND.getStatusCode());
 741
 742         rawResponse = deleteResource(POLICIES_VCPE_VERSION1, APP_JSON);
 743         assertThat(rawResponse.getStatus()).isEqualTo(Status.NOT_FOUND.getStatusCode());
 744
 745     }
 746
 747
 748     private Response createResource(String endpoint, String resourceName) throws Exception {
 749
 750         String mediaType = APP_JSON; // default media type
 751         ToscaServiceTemplate rawServiceTemplate = new ToscaServiceTemplate();
 752         if (resourceName.endsWith(".json")) {
 753             rawServiceTemplate =
 754                     standardCoder.decode(ResourceUtils.getResourceAsString(resourceName), ToscaServiceTemplate.class);
 755         } else if (resourceName.endsWith(".yaml") || resourceName.endsWith(".yml")) {
 756             mediaType = APP_YAML;
 757             rawServiceTemplate = standardYamlCoder.decode(ResourceUtils.getResourceAsString(resourceName),
 758                     ToscaServiceTemplate.class);
 759         }
 760
 761         final Invocation.Builder invocationBuilder;
 762
 763         invocationBuilder = sendHttpsRequest(endpoint, mediaType);
 764
 765         Entity<ToscaServiceTemplate> entity = Entity.entity(rawServiceTemplate, mediaType);
 766         return invocationBuilder.post(entity);
 767     }
 768
 769     private Response readResource(String endpoint, String mediaType) throws Exception {
 770
 771         final Invocation.Builder invocationBuilder;
 772
 773         invocationBuilder = sendHttpsRequest(endpoint, mediaType);
 774
 775         return invocationBuilder.get();
 776
 777     }
 778
 779     private Response deleteResource(String endpoint, String mediaType) throws Exception {
 780
 781         final Invocation.Builder invocationBuilder;
 782
 783         invocationBuilder = sendHttpsRequest(endpoint, mediaType);
 784
 785         return invocationBuilder.delete();
 786     }
 787
 788     private Invocation.Builder sendHttpsRequest(final String endpoint, String mediaType) throws Exception {
 789
 790         final TrustManager[] noopTrustManager = NetworkUtil.getAlwaysTrustingManager();
 791
 792         final SSLContext sc = SSLContext.getInstance("TLSv1.2");
 793         sc.init(null, noopTrustManager, new SecureRandom());
 794         final ClientBuilder clientBuilder =
 795                 ClientBuilder.newBuilder().sslContext(sc).hostnameVerifier((host, session) -> true);
 796         final Client client = clientBuilder.build();
 797         final HttpAuthenticationFeature feature = HttpAuthenticationFeature.basic("healthcheck", "zb!XztG34");
 798         client.register(feature);
 799
 800         client.property(ClientProperties.METAINF_SERVICES_LOOKUP_DISABLE, "true");
 801         if (APP_JSON.equalsIgnoreCase(mediaType)) {
 802             client.register(GsonMessageBodyHandler.class);
 803         } else if (APP_YAML.equalsIgnoreCase(mediaType)) {
 804             client.register(YamlMessageBodyHandler.class);
 805         }
 806
 807         final WebTarget webTarget = client.target("https://localhost:" + apiPort + "/policy/api/v1/" + endpoint);
 808
 809         final Invocation.Builder invocationBuilder = webTarget.request(mediaType);
 810
 811         if (!NetworkUtil.isTcpPortOpen("localhost", apiPort, 60, 1000L)) {
 812             throw new IllegalStateException("cannot connect to port " + apiPort);
 813         }
 814         return invocationBuilder;
 815     }
 816
 817     private void updateApiStatistics() {
 818
 819         ApiStatisticsManager.updateTotalApiCallCount();
 820         ApiStatisticsManager.updateApiCallSuccessCount();
 821         ApiStatisticsManager.updateApiCallFailureCount();
 822         ApiStatisticsManager.updateTotalPolicyGetCount();
 823         ApiStatisticsManager.updateTotalPolicyPostCount();
 824         ApiStatisticsManager.updateTotalPolicyTypeGetCount();
 825         ApiStatisticsManager.updateTotalPolicyTypePostCount();
 826         ApiStatisticsManager.updatePolicyGetSuccessCount();
 827         ApiStatisticsManager.updatePolicyGetFailureCount();
 828         ApiStatisticsManager.updatePolicyPostSuccessCount();
 829         ApiStatisticsManager.updatePolicyPostFailureCount();
 830         ApiStatisticsManager.updatePolicyTypeGetSuccessCount();
 831         ApiStatisticsManager.updatePolicyTypeGetFailureCount();
 832         ApiStatisticsManager.updatePolicyTypePostSuccessCount();
 833         ApiStatisticsManager.updatePolicyTypePostFailureCount();
 834     }
 835
 836     private void validateStatisticsReport(final StatisticsReport report, final int code) {
 837
 838         assertEquals(code, report.getCode());
 839     }
 840
 841     private void validateHealthCheckReport(final String name, final String url, final boolean healthy, final int code,
 842             final String message, final HealthCheckReport report) {
 843
 844         assertEquals(name, report.getName());
 845         assertEquals(url, report.getUrl());
 846         assertEquals(healthy, report.isHealthy());
 847         assertEquals(code, report.getCode());
 848         assertEquals(message, report.getMessage());
 849     }
 850 }