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

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