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