main/src/test/java/org/onap/policy/pap/main/service/PolicyStatusServiceTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2022-2023 Bell Canada. All rights reserved.
   4  *  Modifications Copyright (C) 2022-2023 Nordix Foundation.
   5  * ================================================================================
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  * SPDX-License-Identifier: Apache-2.0
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.onap.policy.pap.main.service;
  23
  24 import static org.assertj.core.api.Assertions.assertThat;
  25 import static org.assertj.core.api.Assertions.assertThatCode;
  26 import static org.assertj.core.api.Assertions.assertThatThrownBy;
  27
  28 import java.util.List;
  29 import org.junit.jupiter.api.BeforeEach;
  30 import org.junit.jupiter.api.Test;
  31 import org.onap.policy.models.base.PfModelRuntimeException;
  32 import org.onap.policy.models.pdp.concepts.PdpPolicyStatus;
  33 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  34 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifierOptVersion;
  35 import org.onap.policy.pap.main.rest.CommonPapRestServer;
  36 import org.springframework.beans.factory.annotation.Autowired;
  37 import org.springframework.test.context.ActiveProfiles;
  38
  39 @ActiveProfiles("test")
  40 class PolicyStatusServiceTest extends CommonPapRestServer {
  41
  42     private static final String GROUP_A = "groupA";
  43     private static final String GROUP_B = "groupB";
  44     private static final ToscaConceptIdentifier MY_POLICY = new ToscaConceptIdentifier("MyPolicy", "1.2.3");
  45     private static final ToscaConceptIdentifier MY_POLICY2 = new ToscaConceptIdentifier("MyPolicyB", "2.3.4");
  46
  47     @Autowired
  48     private PolicyStatusService policyStatusService;
  49
  50     private PdpPolicyStatus.PdpPolicyStatusBuilder statusBuilder;
  51
  52     /**
  53      * Setup before tests.
  54      *
  55      * @throws Exception the exception
  56      */
  57     @Override
  58     @BeforeEach
  59     public void setUp() throws Exception {
  60         super.setUp();
  61         ToscaConceptIdentifier policyType = new ToscaConceptIdentifier("MyPolicyType", "1.2.4");
  62
  63         statusBuilder = PdpPolicyStatus.builder().deploy(true).pdpType("MyPdpType").policy(MY_POLICY)
  64             .policyType(policyType).state(PdpPolicyStatus.State.SUCCESS);
  65     }
  66
  67     @Test
  68     void testGetAllPolicyStatus() {
  69         assertThat(policyStatusService.getAllPolicyStatus()).isEmpty();
  70
  71         var statusList = createStatusList();
  72         policyStatusService.cudPolicyStatus(statusList, null, null);
  73         assertThat(policyStatusService.getAllPolicyStatus()).hasSize(5);
  74         policyStatusService.cudPolicyStatus(null, null, statusList);
  75     }
  76
  77     @Test
  78     void testGetAllPolicyStatusPfDaoToscaConceptIdentifierOptVersion() {
  79
  80         assertThatThrownBy(() -> policyStatusService.getAllPolicyStatus(null)).hasMessageContaining("policy")
  81             .hasMessageContaining("null");
  82
  83         assertThat(policyStatusService.getAllPolicyStatus(new ToscaConceptIdentifierOptVersion("somePdp", null)))
  84             .isEmpty();
  85
  86         var statusList = createStatusList();
  87         policyStatusService.cudPolicyStatus(statusList, null, null);
  88
  89         assertThat(policyStatusService.getAllPolicyStatus(new ToscaConceptIdentifierOptVersion(MY_POLICY))).hasSize(2);
  90         assertThat(
  91             policyStatusService.getAllPolicyStatus(new ToscaConceptIdentifierOptVersion(MY_POLICY.getName(), null)))
  92                 .hasSize(3);
  93         policyStatusService.cudPolicyStatus(null, null, statusList);
  94     }
  95
  96     @Test
  97     void testGetGroupPolicyStatus() {
  98
  99         assertThatThrownBy(() -> policyStatusService.getGroupPolicyStatus(null))
 100             .hasMessage("pdpGroup is marked non-null but is null");
 101
 102         assertThat(policyStatusService.getGroupPolicyStatus("PdpGroup0")).isEmpty();
 103
 104         var statusList = createStatusList();
 105         policyStatusService.cudPolicyStatus(statusList, null, null);
 106         assertThat(policyStatusService.getGroupPolicyStatus(GROUP_A)).hasSize(3);
 107         policyStatusService.cudPolicyStatus(null, null, statusList);
 108     }
 109
 110     @Test
 111     void testCudPolicyStatus() {
 112         assertThatCode(() -> policyStatusService.cudPolicyStatus(null, null, null))
 113             .doesNotThrowAnyException();
 114
 115         var listOfNew = List.of(new PdpPolicyStatus());
 116         assertThatThrownBy(() -> policyStatusService.cudPolicyStatus(listOfNew, null, null))
 117             .isInstanceOf(PfModelRuntimeException.class);
 118
 119         var invalidStatusList = List.of(statusBuilder.state(PdpPolicyStatus.State.WAITING).deploy(false).pdpGroup(null)
 120             .pdpId("pdp1").policy(MY_POLICY).build());
 121         assertThatThrownBy(() -> policyStatusService.cudPolicyStatus(invalidStatusList, null, null))
 122             .isInstanceOf(PfModelRuntimeException.class)
 123             .hasMessageContaining("item \"pdpGroup\" value \"null\" INVALID, is null");
 124
 125         // Test create
 126         PdpPolicyStatus status = statusBuilder.state(PdpPolicyStatus.State.WAITING).deploy(false).pdpGroup(GROUP_A)
 127             .pdpId("pdp1").policy(MY_POLICY).build();
 128         policyStatusService.cudPolicyStatus(List.of(status), null, null);
 129         List<PdpPolicyStatus> createdStatusList = policyStatusService.getAllPolicyStatus();
 130         assertThat(createdStatusList).hasSize(1);
 131         assertThat(createdStatusList.get(0).getState()).isEqualTo(PdpPolicyStatus.State.WAITING);
 132
 133         // Test update
 134         status.setDeploy(true);
 135         status.setState(PdpPolicyStatus.State.SUCCESS);
 136         policyStatusService.cudPolicyStatus(null, List.of(status), null);
 137         createdStatusList = policyStatusService.getAllPolicyStatus();
 138         assertThat(createdStatusList).hasSize(1);
 139         assertThat(createdStatusList.get(0).getState()).isEqualTo(PdpPolicyStatus.State.SUCCESS);
 140
 141         // Test delete
 142         policyStatusService.cudPolicyStatus(null, null, List.of(status));
 143         assertThat(policyStatusService.getAllPolicyStatus()).isEmpty();
 144     }
 145
 146     private List<PdpPolicyStatus> createStatusList() {
 147         // same name, different version
 148         final ToscaConceptIdentifier policy3 = new ToscaConceptIdentifier(MY_POLICY.getName(), "10.20.30");
 149
 150         PdpPolicyStatus id1 = statusBuilder.pdpGroup(GROUP_A).pdpId("pdp1").policy(MY_POLICY).build();
 151         PdpPolicyStatus id2 = statusBuilder.pdpGroup(GROUP_A).pdpId("pdp2").policy(MY_POLICY2).build();
 152         PdpPolicyStatus id3 = statusBuilder.pdpGroup(GROUP_A).pdpId("pdp3").policy(policy3).build();
 153         PdpPolicyStatus id4 = statusBuilder.pdpGroup(GROUP_B).pdpId("pdp4").policy(MY_POLICY).build();
 154         PdpPolicyStatus id5 = statusBuilder.pdpGroup(GROUP_B).pdpId("pdp5").policy(MY_POLICY2).build();
 155         return List.of(id1, id2, id3, id4, id5);
 156     }
 157 }