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