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

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