gerrit.onap Code Review - ccsdk/oran.git/blob

   1 /*-
   2  * ========================LICENSE_START=================================
   3  * ONAP : ccsdk oran
   4  * ======================================================================
   5  * Copyright (C) 2024 OpenInfra Foundation Europe. All rights reserved.
   6  * ======================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ========================LICENSE_END===================================
  19  */
  20
  21 package org.onap.ccsdk.oran.a1policymanagementservice.controllers.v3;
  22
  23 import com.google.gson.Gson;
  24 import org.junit.jupiter.api.*;
  25 import org.onap.ccsdk.oran.a1policymanagementservice.clients.SecurityContext;
  26 import org.onap.ccsdk.oran.a1policymanagementservice.config.TestConfig;
  27 import org.onap.ccsdk.oran.a1policymanagementservice.configuration.ApplicationConfig;
  28 import org.onap.ccsdk.oran.a1policymanagementservice.controllers.OpenPolicyAgentSimulatorController;
  29 import org.onap.ccsdk.oran.a1policymanagementservice.controllers.v2.RappSimulatorController;
  30 import org.onap.ccsdk.oran.a1policymanagementservice.models.v3.PolicyObjectInformation;
  31 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Policies;
  32 import org.onap.ccsdk.oran.a1policymanagementservice.repository.PolicyTypes;
  33 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Rics;
  34 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Services;
  35 import org.onap.ccsdk.oran.a1policymanagementservice.util.v3.Helper;
  36 import org.onap.ccsdk.oran.a1policymanagementservice.utils.v3.TestHelper;
  37 import org.onap.ccsdk.oran.a1policymanagementservice.utils.MockA1ClientFactory;
  38 import org.slf4j.Logger;
  39 import org.slf4j.LoggerFactory;
  40 import org.springframework.beans.factory.annotation.Autowired;
  41 import org.springframework.boot.test.context.SpringBootTest;
  42 import org.springframework.boot.test.mock.mockito.SpyBean;
  43 import org.springframework.boot.test.web.server.LocalServerPort;
  44 import org.springframework.http.HttpStatus;
  45 import org.springframework.http.ResponseEntity;
  46 import org.springframework.test.context.ContextConfiguration;
  47 import org.springframework.test.context.TestPropertySource;
  48 import org.springframework.util.FileSystemUtils;
  49 import reactor.core.publisher.Mono;
  50
  51 import java.lang.invoke.MethodHandles;
  52 import java.nio.file.Path;
  53 import java.util.Objects;
  54
  55 import static org.mockito.ArgumentMatchers.any;
  56 import static org.mockito.Mockito.when;
  57
  58 @TestMethodOrder(MethodOrderer.MethodName.class)
  59 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  60 @ContextConfiguration(classes = TestConfig.class)
  61 @TestPropertySource(properties = { //
  62         "server.ssl.key-store=./config/keystore.jks", //
  63         "app.webclient.trust-store=./config/truststore.jks", //
  64         "app.webclient.trust-store-used=true", //
  65         "app.vardata-directory=/tmp/pmstestv3", //
  66         "app.filepath=", //
  67         "app.s3.bucket=" // If this is set, S3 will be used to store data.
  68 })
  69 public class PolicyControllerTest {
  70     private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
  71
  72     @Autowired
  73     private ApplicationConfig applicationConfig;
  74
  75     @Autowired
  76     private TestHelper testHelper;
  77
  78     @Autowired
  79     private Rics rics;
  80
  81     @Autowired
  82     private Policies policies;
  83
  84     @Autowired
  85     private PolicyTypes policyTypes;
  86
  87     @Autowired
  88     private Services services;
  89
  90     @Autowired
  91     private MockA1ClientFactory a1ClientFactory;
  92
  93     @Autowired
  94     private RappSimulatorController rAppSimulator;
  95
  96     @Autowired
  97     private SecurityContext securityContext;
  98
  99     @Autowired
 100     private OpenPolicyAgentSimulatorController openPolicyAgentSimulatorController;
 101
 102     @Autowired
 103     private Gson gson;
 104
 105     @LocalServerPort
 106     private int port;
 107
 108     @SpyBean
 109     private Helper helper;
 110
 111     @BeforeEach
 112     void init() {
 113         testHelper.port = port;
 114         this.applicationConfig.setAuthProviderUrl(testHelper.baseUrl() + OpenPolicyAgentSimulatorController.ACCESS_CONTROL_URL);
 115     }
 116
 117     @AfterEach
 118     void reset() {
 119         rics.clear();
 120         policies.clear();
 121         policyTypes.clear();
 122         services.clear();
 123         a1ClientFactory.reset();
 124         this.rAppSimulator.getTestResults().clear();
 125         this.a1ClientFactory.setPolicyTypes(policyTypes); // Default same types in RIC and in this app
 126         this.securityContext.setAuthTokenFilePath(null);
 127         this.openPolicyAgentSimulatorController.getTestResults().reset();
 128     }
 129
 130     @AfterAll
 131     static void clearTestDir() {
 132         try {
 133             FileSystemUtils.deleteRecursively(Path.of("/tmp/pmstestv3"));
 134         } catch (Exception e) {
 135             logger.warn("Could test directory : {}", e.getMessage());
 136         }
 137     }
 138
 139     @Test
 140     @DisplayName("test Create Policy")
 141     void testPostPolicy() throws Exception {
 142         String nonRtRicId = "ric.1";
 143         String policyTypeName = "type1_1.2.3";
 144         String url = "/policies";
 145         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 146         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName);
 147         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 148         testHelper.testSuccessResponse(responseMono, HttpStatus.CREATED, responseBody ->
 149                 responseBody.contains("{\"scope\":{\"ueId\":\"ue5100\",\"qosId\":\"qos5100\"},\"qosObjectives\":{\"priorityLevel\":5100.0}}"));
 150         testHelper.testSuccessHeader(responseMono, "location", headerValue -> headerValue.contains("https://localhost:" + port + "/a1policymanagement/v1/policies/"));
 151     }
 152
 153     @Test
 154     @DisplayName("test delete Policy")
 155     void testDeletePolicy() throws Exception {
 156         String nonRtRicId = "ric.1";
 157         String policyTypeName = "type1_1.2.3";
 158         String url = "/policies";
 159         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 160         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName);
 161         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 162         String []locationHeader = Objects.requireNonNull(Objects.requireNonNull(responseMono.block()).getHeaders()
 163                 .get("location")).get(0).split("/");
 164         String policyID = locationHeader[(locationHeader.length) - 1];
 165         Mono<ResponseEntity<String>> responseMonoDelete = testHelper.restClientV3().deleteForEntity(url+"/" +policyID);
 166         testHelper.testSuccessResponse(responseMonoDelete, HttpStatus.NO_CONTENT, responseBody -> true);
 167     }
 168
 169     @Test
 170     @DisplayName("test Create Policy schema validation fail case")
 171     void testPolicySchemaValidationFail() throws Exception {
 172         String nonRtRicId = "ric.1";
 173         String policyTypeName = "type1_1.2.3";
 174         String url = "/policies";
 175         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 176         when(helper.jsonSchemaValidation(any())).thenReturn(Boolean.FALSE);
 177         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName);
 178         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 179         testHelper.testErrorCode(responseMono, HttpStatus.BAD_REQUEST, " Schema validation failed");
 180     }
 181
 182     @Test
 183     @DisplayName("test Create Policy No Ric fail case")
 184     void testCreatePolicyNoRic() throws Exception {
 185         String policyTypeName = "type1_1.2.3";
 186         String url = "/policies";
 187         testHelper.addPolicyType(policyTypeName, " ");
 188         when(helper.jsonSchemaValidation(any())).thenReturn(Boolean.TRUE);
 189         String policyBody = testHelper.postPolicyBody("noRic", policyTypeName);
 190         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 191         testHelper.testErrorCode(responseMono, HttpStatus.NOT_FOUND, " Could not find ric: noRic");
 192     }
 193
 194     @Test
 195     @DisplayName("test Create Policy with No Policy Type fail case")
 196     void testCreatePolicyNoPolicyType() throws Exception {
 197         String policyTypeName = "type1_1.2.3";
 198         String nonRtRicId = "ricOne";
 199         String url = "/policies";
 200         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 201         when(helper.jsonSchemaValidation(any())).thenReturn(Boolean.TRUE);
 202         String policyBody = testHelper.postPolicyBody(nonRtRicId, "noPolicyType");
 203         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 204         testHelper.testErrorCode(responseMono, HttpStatus.NOT_FOUND, "Could not find type: noPolicyType");
 205     }
 206
 207     @Test
 208     public void testGetPolicyTypesNoRicFound() throws Exception{
 209         String policyTypeName = "type1_1.2.3";
 210         String nonRtRicId = "ricOne";
 211         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 212         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().getForEntity("/policyTypes" + "?nearRtRicId=\"noRic\"");
 213         testHelper.testErrorCode(responseMono, HttpStatus.NOT_FOUND, "Near-RT RIC not Found using ID:");
 214     }
 215
 216     @Test
 217     @DisplayName("test get Policy")
 218     void testGetPolicy() throws Exception {
 219         String nonRtRicId = "ric.1";
 220         String policyTypeName = "type1_1.2.3";
 221         String url = "/policies";
 222         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 223         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName);
 224         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 225         String []locationHeader = Objects.requireNonNull(Objects.requireNonNull(responseMono.block()).getHeaders()
 226                 .get("location")).get(0).split("/");
 227         String policyID = locationHeader[(locationHeader.length) - 1];
 228         Mono<ResponseEntity<String>> responseMonoGet = testHelper.restClientV3().getForEntity(url+"/" +policyID);
 229         testHelper.testSuccessResponse(responseMonoGet, HttpStatus.OK, responseBody ->
 230                 responseBody.contains("{\"scope\":{\"ueId\":\"ue5100\",\"qosId\":\"qos5100\"},\"qosObjectives\":{\"priorityLevel\":5100.0}}"));
 231     }
 232 }