main/src/test/java/org/onap/policy/pap/main/rest/e2e/PolicyStatusTest.java

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP PAP
   4  * ================================================================================
   5  * Copyright (C) 2019, 2021 AT&T Intellectual Property. All rights reserved.
   6  * Modifications Copyright (C) 2021-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  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.onap.policy.pap.main.rest.e2e;
  23
  24 import static org.junit.Assert.assertEquals;
  25 import static org.junit.Assert.assertTrue;
  26
  27 import java.util.List;
  28 import javax.ws.rs.client.Invocation;
  29 import javax.ws.rs.core.GenericType;
  30 import javax.ws.rs.core.Response;
  31 import org.junit.Before;
  32 import org.junit.Test;
  33 import org.onap.policy.models.pap.concepts.PolicyStatus;
  34 import org.onap.policy.models.pdp.concepts.PdpPolicyStatus;
  35 import org.onap.policy.models.pdp.concepts.PdpPolicyStatus.State;
  36
  37 public class PolicyStatusTest extends End2EndBase {
  38     private static final String POLICY_NAME = "onap.restart.tca";
  39     private static final String POLICY_TYPE_NAME = "onap.policies.monitoring.cdap.tca.hi.lo.app";
  40     private static final String VERSION = "1.0.0";
  41     private static final String POLICY_STATUS_ENDPOINT = "policies/deployed";
  42     private static final String POLICY_DEPLOYMENT_STATUS_ENDPOINT = "policies/status";
  43
  44     @Override
  45     @Before
  46     public void setUp() throws Exception {
  47         addPdpPolicyStatus("policyStatus.json");
  48         super.setUp();
  49     }
  50
  51     @Test
  52     public void testQueryAllDeployedPolicies() throws Exception {
  53         String uri = POLICY_STATUS_ENDPOINT;
  54
  55         Invocation.Builder invocationBuilder = sendRequest(uri);
  56         Response rawresp = invocationBuilder.get();
  57         assertEquals(Response.Status.OK.getStatusCode(), rawresp.getStatus());
  58
  59         List<PolicyStatus> resp = rawresp.readEntity(new GenericType<List<PolicyStatus>>() {});
  60         assertEquals(1, resp.size());
  61         checkAssertions(resp.get(0));
  62     }
  63
  64     @Test
  65     public void testQueryDeployedPolicies() throws Exception {
  66         String uri = POLICY_STATUS_ENDPOINT + "/onap.restart.tca";
  67
  68         Invocation.Builder invocationBuilder = sendRequest(uri);
  69         Response rawresp = invocationBuilder.get();
  70         assertEquals(Response.Status.OK.getStatusCode(), rawresp.getStatus());
  71
  72         List<PolicyStatus> resp = rawresp.readEntity(new GenericType<List<PolicyStatus>>() {});
  73         assertEquals(1, resp.size());
  74         checkAssertions(resp.get(0));
  75     }
  76
  77     @Test
  78     public void testQueryDeployedPolicy() throws Exception {
  79         String uri = POLICY_STATUS_ENDPOINT + "/onap.restart.tca/1.0.0";
  80
  81         Invocation.Builder invocationBuilder = sendRequest(uri);
  82         Response rawresp = invocationBuilder.get();
  83         assertEquals(Response.Status.OK.getStatusCode(), rawresp.getStatus());
  84
  85         PolicyStatus status = rawresp.readEntity(PolicyStatus.class);
  86         checkAssertions(status);
  87     }
  88
  89     @Test
  90     public void testGetStatusOfAllDeployedPolicies() throws Exception {
  91         String uri = POLICY_DEPLOYMENT_STATUS_ENDPOINT;
  92
  93         Invocation.Builder invocationBuilder = sendRequest(uri);
  94         Response rawresp = invocationBuilder.get();
  95         assertEquals(Response.Status.OK.getStatusCode(), rawresp.getStatus());
  96
  97         List<PdpPolicyStatus> resp = rawresp.readEntity(new GenericType<List<PdpPolicyStatus>>() {});
  98         assertEquals(1, resp.size());
  99         checkAssertionsForDeploymentStatus(resp.get(0));
 100     }
 101
 102     @Test
 103     public void testGetStatusOfDeployedPolicies() throws Exception {
 104         String uri = POLICY_DEPLOYMENT_STATUS_ENDPOINT + "/policyStatus/onap.restart.tca";
 105
 106         Invocation.Builder invocationBuilder = sendRequest(uri);
 107         Response rawresp = invocationBuilder.get();
 108         assertEquals(Response.Status.OK.getStatusCode(), rawresp.getStatus());
 109
 110         List<PdpPolicyStatus> resp = rawresp.readEntity(new GenericType<List<PdpPolicyStatus>>() {});
 111         assertEquals(1, resp.size());
 112         checkAssertionsForDeploymentStatus(resp.get(0));
 113     }
 114
 115     @Test
 116     public void testGetStatusOfDeployedPolicy() throws Exception {
 117         String uri = POLICY_DEPLOYMENT_STATUS_ENDPOINT + "/policyStatus/onap.restart.tca/1.0.0";
 118
 119         Invocation.Builder invocationBuilder = sendRequest(uri);
 120         Response rawresp = invocationBuilder.get();
 121         assertEquals(Response.Status.OK.getStatusCode(), rawresp.getStatus());
 122
 123         PdpPolicyStatus status = rawresp.readEntity(PdpPolicyStatus.class);
 124         checkAssertionsForDeploymentStatus(status);
 125     }
 126
 127
 128     private void checkAssertions(PolicyStatus status) {
 129         assertEquals(POLICY_NAME, status.getPolicyId());
 130         assertEquals(VERSION, status.getPolicyVersion());
 131         assertEquals(POLICY_TYPE_NAME, status.getPolicyTypeId());
 132         assertEquals(VERSION, status.getPolicyTypeVersion());
 133         assertEquals(0, status.getFailureCount());
 134         assertEquals(1, status.getIncompleteCount());
 135         assertEquals(0, status.getSuccessCount());
 136     }
 137
 138     private void checkAssertionsForDeploymentStatus(PdpPolicyStatus status) {
 139         assertEquals(POLICY_NAME, status.getPolicy().getName());
 140         assertEquals(VERSION, status.getPolicy().getVersion());
 141         assertEquals(POLICY_TYPE_NAME, status.getPolicyType().getName());
 142         assertEquals(VERSION, status.getPolicyType().getVersion());
 143         assertEquals("policyStatus", status.getPdpGroup());
 144         assertEquals("pdpB_1", status.getPdpId());
 145         assertEquals("pdpTypeB", status.getPdpType());
 146         assertEquals(State.WAITING, status.getState());
 147         assertTrue(status.isDeploy());
 148     }
 149 }