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