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

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP PAP
   4  * ================================================================================
   5  * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
   6  * Modifications Copyright (C) 2021, 2023 Nordix Foundation.
   7  * Modifications Copyright (C) 2022 Bell Canada. All rights reserved.
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.policy.pap.main.rest.e2e;
  24
  25 import static org.junit.jupiter.api.Assertions.assertEquals;
  26 import static org.junit.jupiter.api.Assertions.assertTrue;
  27
  28 import jakarta.ws.rs.client.Invocation;
  29 import jakarta.ws.rs.core.Response;
  30 import java.util.LinkedHashMap;
  31 import java.util.List;
  32 import java.util.Map;
  33 import java.util.function.Function;
  34 import java.util.function.Predicate;
  35 import java.util.stream.Collectors;
  36 import org.junit.jupiter.api.BeforeEach;
  37 import org.junit.jupiter.api.Test;
  38 import org.onap.policy.models.pdp.concepts.Pdp;
  39 import org.onap.policy.models.pdp.concepts.PdpGroup;
  40 import org.onap.policy.models.pdp.concepts.PdpGroups;
  41 import org.onap.policy.models.pdp.concepts.PdpSubGroup;
  42 import org.onap.policy.models.pdp.enums.PdpHealthStatus;
  43 import org.onap.policy.models.pdp.enums.PdpState;
  44 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  45
  46 class PdpGroupQueryTest extends End2EndBase {
  47     private static final String GROUP_ENDPOINT = "pdps";
  48
  49     /**
  50      * Sets up.
  51      *
  52      * @throws Exception the exception
  53      */
  54     @Override
  55     @BeforeEach
  56     public void setUp() throws Exception {
  57
  58         addToscaPolicyTypes("monitoring.policy-type.yaml");
  59         addToscaPolicies("monitoring.policy.yaml");
  60
  61         addGroups("queryGroup.json");
  62         super.setUp();
  63     }
  64
  65     @Test
  66     void test() throws Exception {
  67         Invocation.Builder invocationBuilder = sendRequest(GROUP_ENDPOINT);
  68         Response rawresp = invocationBuilder.get();
  69         PdpGroups resp = rawresp.readEntity(PdpGroups.class);
  70         assertEquals(Response.Status.OK.getStatusCode(), rawresp.getStatus());
  71
  72         assertEquals("[queryGroup1, queryGroup2]", mapList(resp.getGroups(), PdpGroup::getName).toString());
  73
  74         checkGroup1(resp.getGroups().get(0));
  75         checkGroup2(resp.getGroups().get(1));
  76     }
  77
  78     private void checkGroup1(PdpGroup group) {
  79         assertEquals("[pdpTypeA, pdpTypeB]", mapList(group.getPdpSubgroups(), PdpSubGroup::getPdpType).toString());
  80
  81         assertEquals("my description", group.getDescription());
  82         assertEquals(PdpState.PASSIVE, group.getPdpGroupState());
  83
  84         Map<String, Object> props = new LinkedHashMap<>();
  85         props.put("abc", "def");
  86         assertEquals(props.toString(), group.getProperties().toString());
  87
  88         checkSubGroup11(group.getPdpSubgroups().get(0));
  89     }
  90
  91     private void checkSubGroup11(PdpSubGroup subgrp) {
  92         assertEquals(3, subgrp.getCurrentInstanceCount());
  93         assertEquals(2, subgrp.getDesiredInstanceCount());
  94         assertEquals("[pdpAA_1, pdpAA_2]", mapList(subgrp.getPdpInstances(), Pdp::getInstanceId).toString());
  95         assertEquals(2, filterList(subgrp.getPdpInstances(), pdp -> pdp.getPdpState() == PdpState.PASSIVE).size());
  96         assertEquals(2, filterList(subgrp.getPdpInstances(), pdp -> pdp.getHealthy() == PdpHealthStatus.HEALTHY)
  97                         .size());
  98         assertEquals("pdpTypeA", subgrp.getPdpType());
  99         assertEquals("[onap.restart.tca]", mapList(subgrp.getPolicies(), ToscaConceptIdentifier::getName).toString());
 100         assertEquals("[1.0.0]", mapList(subgrp.getPolicies(), ToscaConceptIdentifier::getVersion).toString());
 101
 102         Map<String, Object> props = new LinkedHashMap<>();
 103         props.put("ten", 10);
 104         assertEquals(props.toString(), subgrp.getProperties().toString());
 105
 106         assertEquals("[onap.policies.monitoring.cdap.tca.hi.lo.app]",
 107                         mapList(subgrp.getSupportedPolicyTypes(), ToscaConceptIdentifier::getName).toString());
 108         assertEquals("[1.0.0]",
 109                         mapList(subgrp.getSupportedPolicyTypes(), ToscaConceptIdentifier::getVersion).toString());
 110     }
 111
 112     private void checkGroup2(PdpGroup group) {
 113         assertEquals("[pdpTypeA]", mapList(group.getPdpSubgroups(), PdpSubGroup::getPdpType).toString());
 114
 115         assertEquals(PdpState.ACTIVE, group.getPdpGroupState());
 116         assertTrue(group.getProperties() == null || group.getProperties().isEmpty());
 117     }
 118
 119     private <T, R> List<R> mapList(List<T> list, Function<T, R> mapFunc) {
 120         return list.stream().map(mapFunc).collect(Collectors.toList());
 121     }
 122
 123     private <T> List<T> filterList(List<T> list, Predicate<T> pred) {
 124         return list.stream().filter(pred).collect(Collectors.toList());
 125     }
 126 }