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