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