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-2021 AT&T Intellectual Property. All rights reserved.
   5  *  Modifications Copyright (C) 2019-2020,2022 Nordix Foundation.
   6  *  Modifications Copyright (C) 2020-2022 Bell Canada. All rights reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  *
  20  * SPDX-License-Identifier: Apache-2.0
  21  * ============LICENSE_END=========================================================
  22  */
  23
  24 package org.onap.policy.api.main.rest;
  25
  26 import static org.assertj.core.api.Assertions.assertThat;
  27 import static org.junit.Assert.assertEquals;
  28 import static org.junit.Assert.assertFalse;
  29 import static org.junit.Assert.assertNotNull;
  30 import static org.junit.Assert.assertNull;
  31
  32 import java.io.File;
  33 import java.io.IOException;
  34 import java.util.List;
  35 import java.util.Map;
  36 import javax.ws.rs.client.Invocation;
  37 import javax.ws.rs.core.Response;
  38 import javax.ws.rs.core.Response.Status;
  39 import org.junit.BeforeClass;
  40 import org.junit.Test;
  41 import org.junit.runner.RunWith;
  42 import org.onap.policy.api.main.PolicyApiApplication;
  43 import org.onap.policy.api.main.rest.provider.statistics.ApiStatisticsManager;
  44 import org.onap.policy.api.main.rest.provider.statistics.StatisticsReport;
  45 import org.onap.policy.api.main.rest.utils.CommonTestRestController;
  46 import org.onap.policy.common.endpoints.report.HealthCheckReport;
  47 import org.onap.policy.common.utils.coder.StandardCoder;
  48 import org.onap.policy.common.utils.coder.StandardYamlCoder;
  49 import org.onap.policy.common.utils.network.NetworkUtil;
  50 import org.onap.policy.common.utils.resources.ResourceUtils;
  51 import org.onap.policy.common.utils.resources.TextFileUtils;
  52 import org.onap.policy.common.utils.security.SelfSignedKeyStore;
  53 import org.onap.policy.models.errors.concepts.ErrorResponse;
  54 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
  55 import org.springframework.beans.factory.annotation.Autowired;
  56 import org.springframework.boot.test.context.SpringBootTest;
  57 import org.springframework.boot.web.server.LocalServerPort;
  58 import org.springframework.test.annotation.DirtiesContext;
  59 import org.springframework.test.annotation.DirtiesContext.ClassMode;
  60 import org.springframework.test.context.ActiveProfiles;
  61 import org.springframework.test.context.DynamicPropertyRegistry;
  62 import org.springframework.test.context.DynamicPropertySource;
  63 import org.springframework.test.context.junit4.SpringRunner;
  64
  65 /**
  66  * Class to perform unit test of {@link ApiRestController}.
  67  *
  68  * @author Chenfei Gao (cgao@research.att.com)
  69  */
  70 @RunWith(SpringRunner.class)
  71 @SpringBootTest(classes = PolicyApiApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  72 @ActiveProfiles("test")
  73 @DirtiesContext(classMode = ClassMode.AFTER_CLASS)
  74 public class TestApiRestServer extends CommonTestRestController {
  75
  76     private static final String ALIVE = "alive";
  77     private static final String SELF = NetworkUtil.getHostname();
  78     private static final String NAME = "Policy API";
  79     private static final String APP_JSON = "application/json";
  80     private static final String APP_YAML = "application/yaml";
  81
  82     private static final String HEALTHCHECK_ENDPOINT = "healthcheck";
  83     private static final String STATISTICS_ENDPOINT = "statistics";
  84
  85     private static final String OP_POLICY_NAME_VCPE = "operational.restart";
  86
  87     private static final String POLICYTYPES = "policytypes";
  88     private static final String POLICYTYPES_TCA = "policytypes/onap.policies.monitoring.tcagen2";
  89     private static final String POLICYTYPES_COLLECTOR =
  90             "policytypes/onap.policies.monitoring.dcaegen2.collectors.datafile.datafile-app-server";
  91     private static final String POLICYTYPES_TCA_VERSION = "policytypes/onap.policies.monitoring.tcagen2/versions/1.0.0";
  92     private static final String POLICYTYPES_TCA_LATEST = "policytypes/onap.policies.monitoring.tcagen2/versions/latest";
  93     private static final String POLICYTYPES_COLLECTOR_VERSION =
  94             "policytypes/onap.policies.monitoring.dcaegen2.collectors.datafile.datafile-app-server/versions/1.0.0";
  95     private static final String POLICYTYPES_COLLECTOR_LATEST =
  96             "policytypes/onap.policies.monitoring.dcaegen2.collectors.datafile.datafile-app-server/versions/latest";
  97
  98     private static final String POLICYTYPES_DROOLS = "policytypes/onap.policies.controlloop.operational.common.Drools";
  99     private static final String POLICYTYPES_DROOLS_VERSION = POLICYTYPES_DROOLS + "/versions/1.0.0";
 100     private static final String POLICYTYPES_DROOLS_VERSION_LATEST = POLICYTYPES_DROOLS + "/versions/latest";
 101
 102     private static final String POLICYTYPES_NAMING_VERSION = POLICYTYPES + "/onap.policies.Naming/versions/1.0.0";
 103
 104     private static final String POLICYTYPES_TCA_POLICIES =
 105             "policytypes/onap.policies.monitoring.tcagen2/versions/1.0.0/policies";
 106     private static final String POLICYTYPES_TCA_POLICIES_VCPE =
 107             "policytypes/onap.policies.monitoring.tcagen2/versions/1.0.0/policies/onap.restart.tca";
 108     private static final String POLICYTYPES_TCA_POLICIES_VCPE_VERSION1 =
 109             "policytypes/" + "onap.policies.monitoring.tcagen2/versions/1.0.0/policies/onap.restart.tca/versions/1.0.0";
 110     private static final String POLICYTYPES_TCA_POLICIES_VCPE_LATEST = "policytypes/"
 111             + "onap.policies.monitoring.tcagen2/versions/1.0.0/policies/onap.restart.tca/versions/latest";
 112
 113     private static final String POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION =
 114             POLICYTYPES_DROOLS_VERSION + "/policies/" + OP_POLICY_NAME_VCPE + "/versions/1.0.0";
 115
 116     private static final String POLICIES = "policies";
 117
 118     // @formatter:off
 119     private static final String[] TOSCA_POLICY_RESOURCE_NAMES = {"policies/vCPE.policy.monitoring.input.tosca.json",
 120         "policies/vCPE.policy.monitoring.input.tosca.yaml", "policies/vDNS.policy.monitoring.input.tosca.json",
 121         "policies/vDNS.policy.monitoring.input.tosca.v2.yaml"};
 122
 123     private static final String[] TOSCA_POLICIES_RESOURCE_NAMES = {
 124         "policies/vCPE.policies.optimization.input.tosca.json", "policies/vCPE.policies.optimization.input.tosca.yaml"};
 125
 126     private static final String TOSCA_POLICYTYPE_OP_RESOURCE =
 127         "policytypes/onap.policies.controlloop.operational.Common.yaml";
 128
 129     private static final String[] TOSCA_POLICYTYPE_RESOURCE_NAMES = {
 130         "policytypes/onap.policies.monitoring.tcagen2.yaml",
 131         "policytypes/onap.policies.monitoring.dcaegen2.collectors.datafile.datafile-app-server.yaml",
 132         "policytypes/onap.policies.controlloop.operational.common.Drools.yaml",
 133         "policytypes/onap.policies.controlloop.guard.Common.yaml",
 134         "policytypes/onap.policies.controlloop.guard.common.Blacklist.yaml",
 135         "policytypes/onap.policies.controlloop.guard.common.FrequencyLimiter.yaml",
 136         "policytypes/onap.policies.controlloop.guard.common.MinMax.yaml",
 137         "policytypes/onap.policies.controlloop.guard.coordination.FirstBlocksSecond.yaml",
 138         "policytypes/onap.policies.optimization.resource.AffinityPolicy.yaml",
 139         "policytypes/onap.policies.optimization.resource.DistancePolicy.yaml",
 140         "policytypes/onap.policies.optimization.resource.HpaPolicy.yaml",
 141         "policytypes/onap.policies.optimization.resource.OptimizationPolicy.yaml",
 142         "policytypes/onap.policies.optimization.resource.PciPolicy.yaml",
 143         "policytypes/onap.policies.optimization.service.QueryPolicy.yaml",
 144         "policytypes/onap.policies.optimization.service.SubscriberPolicy.yaml",
 145         "policytypes/onap.policies.optimization.resource.Vim_fit.yaml",
 146         "policytypes/onap.policies.optimization.resource.VnfPolicy.yaml"};
 147
 148     private static final String TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_JSON =
 149         "policies/vCPE.policy.operational.input.tosca.json";
 150
 151     private static final String TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_YAML =
 152         "policies/vCPE.policy.operational.input.tosca.yaml";
 153
 154     private static final String POLICIES_VCPE_VERSION1 = "policies/onap.restart.tca/versions/1.0.0";
 155     // @formatter:on
 156
 157     private static final StandardCoder standardCoder = new StandardCoder();
 158     private static StandardYamlCoder standardYamlCoder = new StandardYamlCoder();
 159     private static SelfSignedKeyStore keystore;
 160
 161     @LocalServerPort
 162     private int apiPort;
 163
 164     @Autowired
 165     private ApiStatisticsManager mgr;
 166
 167     /**
 168      * Initializes parameters and set up test environment.
 169      *
 170      * @throws IOException on I/O exceptions
 171      * @throws InterruptedException if interrupted
 172      */
 173     @BeforeClass
 174     public static void setupParameters() throws IOException, InterruptedException {
 175         keystore = new SelfSignedKeyStore();
 176     }
 177
 178     @DynamicPropertySource
 179     static void registerPgProperties(DynamicPropertyRegistry registry) {
 180         registry.add("server.ssl.enabled", () -> "true");
 181         registry.add("server.ssl.key-store", () -> keystore.getKeystoreName());
 182         registry.add("server.ssl.key-store-password", () -> SelfSignedKeyStore.KEYSTORE_PASSWORD);
 183         registry.add("server.ssl.key-store-type", () -> "PKCS12");
 184         registry.add("server.ssl.key-alias", () -> "policy@policy.onap.org");
 185         registry.add("server.ssl.key-password", () -> SelfSignedKeyStore.PRIVATE_KEY_PASSWORD);
 186     }
 187
 188     @Test
 189     public void testCreatePolicyTypes() throws Exception {
 190         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 191             Response rawResponse = createResource(POLICYTYPES, resrcName, apiPort);
 192             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 193             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 194             assertNotNull(response);
 195             assertFalse(response.getPolicyTypes().isEmpty());
 196         }
 197
 198         // Send a policy type with a null value to trigger an error
 199         Response rawResponse = readResource(POLICYTYPES, APP_JSON, apiPort);
 200         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 201         ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 202         String firstPolicyType = response.getPolicyTypes().keySet().iterator().next();
 203         response.getPolicyTypes().put(firstPolicyType, null);
 204         Response rawResponse2 = createResource(POLICYTYPES, standardCoder.encode(response), apiPort);
 205         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse2.getStatus());
 206         ErrorResponse errorResponse = rawResponse2.readEntity(ErrorResponse.class);
 207         assertEquals("no policy types specified on service template", errorResponse.getErrorMessage());
 208     }
 209
 210     @Test
 211     public void testCreatePolicies() throws Exception {
 212         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 213             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName, apiPort);
 214             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 215         }
 216
 217         new File("src/test/resources/policies/BadTestPolicy.yaml").deleteOnExit();
 218
 219         // Send a policy with no policy type trigger an error
 220         String toscaPolicy = ResourceUtils
 221                 .getResourceAsString(TOSCA_POLICY_RESOURCE_NAMES[TOSCA_POLICIES_RESOURCE_NAMES.length - 1]);
 222
 223         toscaPolicy = toscaPolicy.replaceAll("onap.policies.monitoring.tcagen2", "IDontExist");
 224         TextFileUtils.putStringAsTextFile(toscaPolicy, "src/test/resources/policies/BadTestPolicy.yaml");
 225
 226         Response rawResponse2 =
 227                 createResource(POLICYTYPES_TCA_POLICIES,
 228                     "src/test/resources/policies/BadTestPolicy.yaml", apiPort);
 229         assertEquals(Response.Status.NOT_ACCEPTABLE.getStatusCode(), rawResponse2.getStatus());
 230         ErrorResponse errorResponse = rawResponse2.readEntity(ErrorResponse.class);
 231         assertThat(errorResponse.getErrorMessage())
 232                 .contains("item \"entity\" value \"onap.restart.tca:1.0.0\" INVALID, does not equal existing entity");
 233     }
 234
 235     @Test
 236     public void testSimpleCreatePolicies() throws Exception {
 237         for (String resrcName : TOSCA_POLICIES_RESOURCE_NAMES) {
 238             Response rawResponse = createResource(POLICIES, resrcName, apiPort);
 239             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 240         }
 241
 242         new File("src/test/resources/policies/BadTestPolicy.yaml").deleteOnExit();
 243
 244         // Send a policy with no policy type trigger an error
 245         String toscaPolicy = ResourceUtils
 246                 .getResourceAsString(TOSCA_POLICY_RESOURCE_NAMES[TOSCA_POLICIES_RESOURCE_NAMES.length - 1]);
 247
 248         toscaPolicy = toscaPolicy.replaceAll("onap.policies.monitoring.tcagen2", "IDontExist");
 249         toscaPolicy = toscaPolicy.replaceAll("onap.restart.tca", "onap.restart.tca.IDontExist");
 250         TextFileUtils.putStringAsTextFile(toscaPolicy, "src/test/resources/policies/BadTestPolicy.yaml");
 251
 252         Response rawResponse2 =
 253             createResource(POLICIES, "src/test/resources/policies/BadTestPolicy.yaml", apiPort);
 254         ErrorResponse errorResponse = rawResponse2.readEntity(ErrorResponse.class);
 255         assertEquals(Response.Status.NOT_ACCEPTABLE.getStatusCode(), rawResponse2.getStatus());
 256         assertThat(errorResponse.getErrorMessage())
 257                 .contains("item \"policy type\" value \"IDontExist:1.0.0\" INVALID, not found");
 258     }
 259
 260     @SuppressWarnings("unchecked")
 261     @Test
 262     public void testToscaCompliantOpDroolsPolicies() throws Exception {
 263         Response rawResponse = createResource(POLICYTYPES, TOSCA_POLICYTYPE_OP_RESOURCE, apiPort);
 264         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 265
 266         rawResponse = readResource(POLICYTYPES_DROOLS_VERSION, APP_JSON, apiPort);
 267         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 268
 269         rawResponse = createResource(POLICIES, TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_JSON, apiPort);
 270         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 271
 272         rawResponse = createResource(POLICIES, TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_YAML, apiPort);
 273         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 274
 275         rawResponse = readResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_JSON, apiPort);
 276         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 277
 278         rawResponse = deleteResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_JSON, apiPort);
 279         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 280
 281         rawResponse = createResource(POLICIES, TOSCA_POLICY_OP_DROOLS_VCPE_RESOURSE_YAML, apiPort);
 282         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 283
 284         rawResponse = readResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_JSON, apiPort);
 285         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 286
 287         rawResponse = readResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_YAML, apiPort);
 288         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 289
 290         ToscaServiceTemplate toscaVcpeSt = rawResponse.readEntity(ToscaServiceTemplate.class);
 291         assertEquals(1, toscaVcpeSt.getToscaTopologyTemplate().getPolicies().size());
 292         assertEquals(OP_POLICY_NAME_VCPE,
 293                 toscaVcpeSt.getToscaTopologyTemplate().getPolicies().get(0).get(OP_POLICY_NAME_VCPE).getName());
 294
 295         Map<String, Object> props =
 296                 toscaVcpeSt.getToscaTopologyTemplate().getPolicies().get(0).get(OP_POLICY_NAME_VCPE).getProperties();
 297         assertNotNull(props);
 298
 299         List<Object> operations = (List<Object>) props.get("operations");
 300         assertEquals(1, operations.size());
 301         assertEquals(props.get("trigger"), ((Map<String, Object>) operations.get(0)).get("id"));
 302
 303         Map<String, Object> operation =
 304                 (Map<String, Object>) ((Map<String, Object>) operations.get(0)).get("operation");
 305         assertEquals("APPC", operation.get("actor"));
 306         assertEquals("Restart", operation.get("operation"));
 307
 308         rawResponse = deleteResource(POLICYTYPES_DROOLS_POLICIES_VCPE_VERSION, APP_JSON, apiPort);
 309         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 310     }
 311
 312     @Test
 313     public void testHealthCheckSuccessJson() throws Exception {
 314         testHealthCheckSuccess(APP_JSON);
 315     }
 316
 317     @Test
 318     public void testHealthCheckSuccessYaml() throws Exception {
 319         testHealthCheckSuccess(APP_YAML);
 320     }
 321
 322     private void testHealthCheckSuccess(String mediaType) throws Exception {
 323         final Invocation.Builder invocationBuilder = sendHttpsRequest(HEALTHCHECK_ENDPOINT, mediaType, apiPort);
 324         final HealthCheckReport report = invocationBuilder.get(HealthCheckReport.class);
 325         validateHealthCheckReport(NAME, SELF, true, 200, ALIVE, report);
 326     }
 327
 328     @Test
 329     public void testApiStatistics_200_Json() throws Exception {
 330         testApiStatistics_200(APP_JSON);
 331     }
 332
 333     @Test
 334     public void testApiStatistics_200_Yaml() throws Exception {
 335         testApiStatistics_200(APP_YAML);
 336     }
 337
 338     private void testApiStatistics_200(String mediaType) throws Exception {
 339         Invocation.Builder invocationBuilder = sendHttpsRequest(STATISTICS_ENDPOINT, mediaType, apiPort);
 340         StatisticsReport report = invocationBuilder.get(StatisticsReport.class);
 341         validateStatisticsReport(report, 200);
 342         updateApiStatistics();
 343         invocationBuilder = sendHttpsRequest(STATISTICS_ENDPOINT, mediaType, apiPort);
 344         report = invocationBuilder.get(StatisticsReport.class);
 345         validateStatisticsReport(report, 200);
 346         // ApiStatisticsManager.resetAllStatistics();
 347     }
 348
 349     @Test
 350     public void testReadPolicyTypesJson() throws Exception {
 351         testReadPolicyTypes(APP_JSON);
 352     }
 353
 354     @Test
 355     public void testReadPolicyTypesYaml() throws Exception {
 356         testReadPolicyTypes(APP_YAML);
 357     }
 358
 359     private void testReadPolicyTypes(String mediaType) throws Exception {
 360         Response rawResponse =
 361             readResource("policytypes/onap.policies.optimization.resource.HpaPolicy", mediaType,
 362                 apiPort);
 363         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 364         ToscaServiceTemplate namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 365         assertNotNull(namingServiceTemplate);
 366         assertEquals(3, namingServiceTemplate.getPolicyTypesAsMap().size());
 367         assertEquals(5, namingServiceTemplate.getDataTypesAsMap().size());
 368
 369         rawResponse = readResource(POLICYTYPES, mediaType, apiPort);
 370         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 371         ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 372         assertFalse(response.getPolicyTypes().isEmpty());
 373
 374         rawResponse = readResource(POLICYTYPES_TCA, mediaType, apiPort);
 375         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 376
 377         rawResponse = readResource(POLICYTYPES_TCA_VERSION, mediaType, apiPort);
 378         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 379
 380         rawResponse = readResource(POLICYTYPES_TCA_LATEST, mediaType, apiPort);
 381         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 382
 383         rawResponse = readResource(POLICYTYPES_COLLECTOR, mediaType, apiPort);
 384         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 385
 386         rawResponse = readResource(POLICYTYPES_COLLECTOR_VERSION, mediaType, apiPort);
 387         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 388
 389         rawResponse = readResource(POLICYTYPES_COLLECTOR_LATEST, mediaType, apiPort);
 390         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 391
 392         rawResponse = readResource(POLICYTYPES_DROOLS, mediaType, apiPort);
 393         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 394
 395         rawResponse = readResource(POLICYTYPES_DROOLS_VERSION, mediaType, apiPort);
 396         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 397
 398         rawResponse = readResource(POLICYTYPES_DROOLS_VERSION_LATEST, mediaType, apiPort);
 399         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 400
 401         rawResponse = readResource(POLICYTYPES_NAMING_VERSION, mediaType, apiPort);
 402         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 403     }
 404
 405     @Test
 406     public void testDeletePolicyTypeJson() throws Exception {
 407         testDeletePolicyType(APP_JSON);
 408     }
 409
 410     @Test
 411     public void testDeletePolicyTypeYaml() throws Exception {
 412         testDeletePolicyType(APP_YAML);
 413     }
 414
 415     private void testDeletePolicyType(String mediaType) throws Exception {
 416         Response rawResponse = deleteResource("policytypes/onap.policies.IDoNotExist/versions/1.0.0",
 417             mediaType, apiPort);
 418         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 419
 420         rawResponse = createResource(POLICYTYPES, "policytypes/onap.policies.Test.yaml", apiPort);
 421         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 422
 423         rawResponse =
 424             readResource("policytypes/onap.policies.Test/versions/1.0.0", mediaType, apiPort);
 425         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 426
 427         rawResponse =
 428             deleteResource("policytypes/onap.policies.Test/versions/1.0.0", mediaType, apiPort);
 429         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 430
 431         rawResponse =
 432             readResource("policytypes/onap.policies.Test/versions/1.0.0", mediaType, apiPort);
 433         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 434     }
 435
 436     @Test
 437     public void testReadPoliciesJson() throws Exception {
 438         testReadPolicies(APP_JSON);
 439     }
 440
 441     @Test
 442     public void testReadPoliciesYaml() throws Exception {
 443         testReadPolicies(APP_YAML);
 444     }
 445
 446     private void testReadPolicies(String mediaType) throws Exception {
 447         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 448             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName, apiPort);
 449             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 450         }
 451
 452         Response rawResponse = readResource(POLICYTYPES_TCA_POLICIES, mediaType, apiPort);
 453         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 454
 455         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE, mediaType, apiPort);
 456         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 457
 458         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType, apiPort);
 459         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 460
 461         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE_LATEST, mediaType, apiPort);
 462         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 463
 464         rawResponse = deleteResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType, apiPort);
 465         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 466
 467     }
 468
 469     @Test
 470     public void testNamingPolicyGet() throws Exception {
 471
 472         Response rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 473                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/1.0.0", APP_JSON, apiPort);
 474         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 475
 476         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 477                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/1.0.0?mode=referenced", APP_JSON, apiPort);
 478         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 479
 480         ToscaServiceTemplate namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 481         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 482         assertEquals(1, namingServiceTemplate.getPolicyTypesAsMap().size());
 483         assertEquals(3, namingServiceTemplate.getDataTypesAsMap().size());
 484
 485         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 486                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/latest?mode=referenced", APP_JSON, apiPort);
 487         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 488
 489         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 490         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 491         assertEquals(1, namingServiceTemplate.getPolicyTypesAsMap().size());
 492         assertEquals(3, namingServiceTemplate.getDataTypesAsMap().size());
 493
 494         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/policies"
 495                 + "?mode=referenced", APP_JSON, apiPort);
 496         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 497
 498         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 499         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 500         assertEquals(1, namingServiceTemplate.getPolicyTypesAsMap().size());
 501         assertEquals(3, namingServiceTemplate.getDataTypesAsMap().size());
 502
 503         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 504                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/1.0.0", APP_JSON, apiPort);
 505         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 506
 507         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 508
 509         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 510         assertNull(namingServiceTemplate.getPolicyTypes());
 511         assertNull(namingServiceTemplate.getDataTypes());
 512
 513         rawResponse = readResource("policytypes/onap.policies.Naming/versions/1.0.0/"
 514                 + "policies/SDNC_Policy.ONAP_NF_NAMING_TIMESTAMP/versions/latest", APP_JSON, apiPort);
 515         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 516
 517         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 518         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 519         assertNull(namingServiceTemplate.getPolicyTypes());
 520         assertNull(namingServiceTemplate.getDataTypes());
 521
 522         rawResponse =
 523             readResource("policytypes/onap.policies.Naming/versions/1.0.0/policies", APP_JSON,
 524                 apiPort);
 525         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 526
 527         namingServiceTemplate = rawResponse.readEntity(ToscaServiceTemplate.class);
 528         assertEquals(1, namingServiceTemplate.getToscaTopologyTemplate().getPoliciesAsMap().size());
 529         assertNull(namingServiceTemplate.getPolicyTypes());
 530         assertNull(namingServiceTemplate.getDataTypes());
 531     }
 532
 533     @Test
 534     public void testDeletePoliciesJson() throws Exception {
 535         testDeletePolicies(APP_JSON);
 536     }
 537
 538     @Test
 539     public void testDeletePoliciesYaml() throws Exception {
 540         testDeletePolicies(APP_YAML);
 541     }
 542
 543     private void testDeletePolicies(String mediaType) throws Exception {
 544         Response rawResponse = deleteResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType, apiPort);
 545         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 546         ErrorResponse error = rawResponse.readEntity(ErrorResponse.class);
 547         assertEquals("policy onap.restart.tca:1.0.0 not found", error.getErrorMessage());
 548     }
 549
 550     @Test
 551     public void testDeletePolicyVersionJson() throws Exception {
 552         testDeletePolicyVersion(APP_JSON);
 553     }
 554
 555     @Test
 556     public void testDeletePolicyVersionYaml() throws Exception {
 557         testDeletePolicyVersion(APP_YAML);
 558     }
 559
 560     private void testDeletePolicyVersion(String mediaType) throws Exception {
 561         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 562             Response rawResponse = createResource(POLICYTYPES, resrcName, apiPort);
 563             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 564             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 565             assertNotNull(response);
 566             assertFalse(response.getPolicyTypes().isEmpty());
 567         }
 568         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 569             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName, apiPort);
 570             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 571         }
 572         Response rawResponse = deleteResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType, apiPort);
 573         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 574
 575         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE_VERSION1, mediaType, apiPort);
 576         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 577         ErrorResponse errorResponse = rawResponse.readEntity(ErrorResponse.class);
 578         assertEquals("policies for onap.restart.tca:1.0.0 do not exist", errorResponse.getErrorMessage());
 579
 580         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE, mediaType, apiPort);
 581         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 582         errorResponse = rawResponse.readEntity(ErrorResponse.class);
 583         assertEquals("policies for onap.restart.tca:null do not exist", errorResponse.getErrorMessage());
 584
 585         rawResponse = readResource(POLICYTYPES_TCA_POLICIES_VCPE_LATEST, mediaType, apiPort);
 586         assertEquals(Response.Status.NOT_FOUND.getStatusCode(), rawResponse.getStatus());
 587         errorResponse = rawResponse.readEntity(ErrorResponse.class);
 588         assertEquals("policies for onap.restart.tca:null do not exist", errorResponse.getErrorMessage());
 589     }
 590
 591     @Test
 592     public void testGetAllVersionOfPolicyJson() throws Exception {
 593         testGetAllVersionOfPolicy(APP_JSON);
 594     }
 595
 596     @Test
 597     public void testGetAllVersionOfPolicyYaml() throws Exception {
 598         testGetAllVersionOfPolicy(APP_YAML);
 599     }
 600
 601     private void testGetAllVersionOfPolicy(String mediaType) throws Exception {
 602         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 603             Response rawResponse = createResource(POLICYTYPES, resrcName, apiPort);
 604             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 605             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 606             assertNotNull(response);
 607             assertFalse(response.getPolicyTypes().isEmpty());
 608         }
 609         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 610             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName, apiPort);
 611             assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 612         }
 613         Response rawResponse = readResource(POLICYTYPES_TCA_POLICIES, mediaType, apiPort);
 614         assertEquals(Response.Status.OK.getStatusCode(), rawResponse.getStatus());
 615     }
 616
 617     @Test
 618     public void testGetPoliciesJson() throws Exception {
 619         getPolicies(APP_JSON);
 620     }
 621
 622     @Test
 623     public void testGetPoliciesYaml() throws Exception {
 624         getPolicies(APP_YAML);
 625     }
 626
 627     private void getPolicies(String mediaType) throws Exception {
 628         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 629             Response rawResponse = createResource(POLICYTYPES, resrcName, apiPort);
 630             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 631             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 632             assertThat(response).isNotNull();
 633             assertThat(response.getPolicyTypes()).isNotEmpty();
 634         }
 635         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 636             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName, apiPort);
 637             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 638         }
 639         Response rawResponse = readResource(POLICIES, mediaType, apiPort);
 640         assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 641         ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 642         assertThat(response.getToscaTopologyTemplate().getPolicies()).isNotEmpty();
 643     }
 644
 645     @Test
 646     public void testGetSpecificPolicyJson() throws Exception {
 647         getSpecificPolicy(APP_JSON);
 648     }
 649
 650     @Test
 651     public void testGetSpecificPolicyYaml() throws Exception {
 652         getSpecificPolicy(APP_YAML);
 653     }
 654
 655     private void getSpecificPolicy(String mediaType) throws Exception {
 656         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 657             Response rawResponse = createResource(POLICYTYPES, resrcName, apiPort);
 658             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 659             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 660             assertThat(response).isNotNull();
 661             assertThat(response.getPolicyTypes()).isNotEmpty();
 662         }
 663         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 664             Response rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName, apiPort);
 665             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 666         }
 667         Response rawResponse = readResource(POLICIES_VCPE_VERSION1, mediaType, apiPort);
 668         assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 669         ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 670         assertThat(response.getToscaTopologyTemplate().getPolicies()).hasSize(1);
 671     }
 672
 673     @Test
 674     public void testDeleteSpecificPolicy() throws Exception {
 675         Response rawResponse;
 676         for (String resrcName : TOSCA_POLICYTYPE_RESOURCE_NAMES) {
 677             rawResponse = createResource(POLICYTYPES, resrcName, apiPort);
 678             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 679             ToscaServiceTemplate response = rawResponse.readEntity(ToscaServiceTemplate.class);
 680             assertThat(response).isNotNull();
 681             assertThat(response.getPolicyTypes()).isNotEmpty();
 682         }
 683         for (String resrcName : TOSCA_POLICY_RESOURCE_NAMES) {
 684             rawResponse = createResource(POLICYTYPES_TCA_POLICIES, resrcName, apiPort);
 685             assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 686         }
 687
 688         rawResponse = readResource(POLICIES_VCPE_VERSION1, APP_JSON, apiPort);
 689         assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 690
 691         // delete a particular policy
 692         rawResponse = deleteResource(POLICIES_VCPE_VERSION1, APP_JSON, apiPort);
 693         assertThat(rawResponse.getStatus()).isEqualTo(Response.Status.OK.getStatusCode());
 694
 695         rawResponse = readResource(POLICIES_VCPE_VERSION1, APP_JSON, apiPort);
 696         assertThat(rawResponse.getStatus()).isEqualTo(Status.NOT_FOUND.getStatusCode());
 697
 698         rawResponse = deleteResource(POLICIES_VCPE_VERSION1, APP_JSON, apiPort);
 699         assertThat(rawResponse.getStatus()).isEqualTo(Status.NOT_FOUND.getStatusCode());
 700
 701     }
 702
 703     private void updateApiStatistics() {
 704         mgr.updateTotalApiCallCount();
 705         mgr.updateApiCallSuccessCount();
 706         mgr.updateApiCallFailureCount();
 707         mgr.updateTotalPolicyGetCount();
 708         mgr.updateTotalPolicyPostCount();
 709         mgr.updateTotalPolicyTypeGetCount();
 710         mgr.updateTotalPolicyTypePostCount();
 711         mgr.updatePolicyGetSuccessCount();
 712         mgr.updatePolicyGetFailureCount();
 713         mgr.updatePolicyPostSuccessCount();
 714         mgr.updatePolicyPostFailureCount();
 715         mgr.updatePolicyTypeGetSuccessCount();
 716         mgr.updatePolicyTypeGetFailureCount();
 717         mgr.updatePolicyTypePostSuccessCount();
 718         mgr.updatePolicyTypePostFailureCount();
 719     }
 720
 721     private void validateStatisticsReport(final StatisticsReport report, final int code) {
 722
 723         assertEquals(code, report.getCode());
 724     }
 725
 726     private void validateHealthCheckReport(final String name, final String url, final boolean healthy, final int code,
 727             final String message, final HealthCheckReport report) {
 728
 729         assertEquals(name, report.getName());
 730         assertEquals(url, report.getUrl());
 731         assertEquals(healthy, report.isHealthy());
 732         assertEquals(code, report.getCode());
 733         assertEquals(message, report.getMessage());
 734     }
 735 }