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.repository.Policies;
  31 import org.onap.ccsdk.oran.a1policymanagementservice.repository.PolicyTypes;
  32 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Rics;
  33 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Services;
  34 import org.onap.ccsdk.oran.a1policymanagementservice.util.v3.Helper;
  35 import org.onap.ccsdk.oran.a1policymanagementservice.utils.MockA1ClientFactory;
  36 import org.onap.ccsdk.oran.a1policymanagementservice.utils.v3.TestHelper;
  37 import org.slf4j.Logger;
  38 import org.slf4j.LoggerFactory;
  39 import org.springframework.beans.factory.annotation.Autowired;
  40 import org.springframework.boot.test.context.SpringBootTest;
  41 import org.springframework.boot.test.mock.mockito.SpyBean;
  42 import org.springframework.boot.test.web.server.LocalServerPort;
  43 import org.springframework.http.HttpStatus;
  44 import org.springframework.http.ResponseEntity;
  45 import org.springframework.test.context.ContextConfiguration;
  46 import org.springframework.test.context.TestPropertySource;
  47 import org.springframework.util.FileSystemUtils;
  48 import reactor.core.publisher.Mono;
  49
  50 import java.lang.invoke.MethodHandles;
  51 import java.nio.file.Path;
  52 import java.util.Objects;
  53
  54 import static org.mockito.ArgumentMatchers.any;
  55 import static org.mockito.Mockito.when;
  56
  57 @TestMethodOrder(MethodOrderer.MethodName.class)
  58 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  59 @ContextConfiguration(classes = TestConfig.class)
  60 @TestPropertySource(properties = { //
  61         "server.ssl.key-store=./config/keystore.jks", //
  62         "app.webclient.trust-store=./config/truststore.jks", //
  63         "app.webclient.trust-store-used=true", //
  64         "app.vardata-directory=/tmp/pmstestv3", //
  65         "app.filepath=", //
  66         "app.s3.bucket=" // If this is set, S3 will be used to store data.
  67 })
  68 class PolicyControllerV3Test {
  69     private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
  70
  71     @Autowired
  72     private ApplicationConfig applicationConfig;
  73
  74     @Autowired
  75     private TestHelper testHelper;
  76
  77     @Autowired
  78     private Rics rics;
  79
  80     @Autowired
  81     private Policies policies;
  82
  83     @Autowired
  84     private PolicyTypes policyTypes;
  85
  86     @Autowired
  87     private Services services;
  88
  89     @Autowired
  90     private MockA1ClientFactory a1ClientFactory;
  91
  92     @Autowired
  93     private RappSimulatorController rAppSimulator;
  94
  95     @Autowired
  96     private SecurityContext securityContext;
  97
  98     @Autowired
  99     private OpenPolicyAgentSimulatorController openPolicyAgentSimulatorController;
 100
 101     @Autowired
 102     private Gson gson;
 103
 104     @LocalServerPort
 105     private int port;
 106
 107     @SpyBean
 108     private Helper helper;
 109
 110     @BeforeEach
 111     void init() {
 112         testHelper.port = port;
 113         this.applicationConfig.setAuthProviderUrl(testHelper.baseUrl() + OpenPolicyAgentSimulatorController.ACCESS_CONTROL_URL);
 114     }
 115
 116     @AfterEach
 117     void reset() {
 118         rics.clear();
 119         policies.clear();
 120         policyTypes.clear();
 121         services.clear();
 122         a1ClientFactory.reset();
 123         this.rAppSimulator.getTestResults().clear();
 124         this.a1ClientFactory.setPolicyTypes(policyTypes); // Default same types in RIC and in this app
 125         this.securityContext.setAuthTokenFilePath(null);
 126         this.openPolicyAgentSimulatorController.getTestResults().reset();
 127     }
 128
 129     @AfterAll
 130     static void clearTestDir() {
 131         try {
 132             FileSystemUtils.deleteRecursively(Path.of("/tmp/pmstestv3"));
 133         } catch (Exception e) {
 134             logger.warn("Could test directory : {}", e.getMessage());
 135         }
 136     }
 137
 138     @Test
 139     @DisplayName("test Create Policy")
 140     void testPostPolicy() throws Exception {
 141         String nonRtRicId = "ric.1";
 142         String policyTypeName = "type1_1.2.3";
 143         String url = "/policies";
 144         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 145         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName, "");
 146         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 147         testHelper.testSuccessResponse(responseMono, HttpStatus.CREATED, responseBody ->
 148                 responseBody.contains("{\"scope\":{\"ueId\":\"ue5100\",\"qosId\":\"qos5100\"},\"qosObjectives\":{\"priorityLevel\":5100.0}}"));
 149         testHelper.testSuccessHeader(responseMono, "location", headerValue -> headerValue.contains("https://localhost:" + port + "/a1-policy-management/v1/policies/"));
 150     }
 151
 152     @Test
 153     @DisplayName("test Create Policy with PolicyID sending")
 154     void testPostPolicyWithPolicyID() throws Exception {
 155         String nonRtRicId = "ric.1";
 156         String policyTypeName = "type1_1.2.3";
 157         String url = "/policies";
 158         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 159         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName, "1");
 160         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 161         testHelper.testSuccessHeader(responseMono, "location", headerValue -> headerValue.contains("https://localhost:" + port + "/a1-policy-management/v1/policies/1"));
 162     }
 163
 164     @Test
 165     @DisplayName("test Create Policy with existing policy id")
 166     void testPostPolicyWithExistingPolicyID() throws Exception {
 167         String nonRtRicId = "ric.1";
 168         String policyTypeName = "type1_1.2.3";
 169         String url = "/policies";
 170         String policyId = "policy_5g";
 171         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 172         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName, policyId);
 173         testHelper.restClientV3().postForEntity(url, policyBody).block();
 174         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 175         testHelper.testErrorCode(responseMono, HttpStatus.CONFLICT, "Policy already created with ID: " +policyId);
 176     }
 177
 178     @Test
 179     @DisplayName("test delete Policy")
 180     void testDeletePolicy() throws Exception {
 181         String nonRtRicId = "ric.1";
 182         String policyTypeName = "type1_1.2.3";
 183         String url = "/policies";
 184         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 185         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName, "");
 186         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 187         String []locationHeader = Objects.requireNonNull(Objects.requireNonNull(responseMono.block()).getHeaders()
 188                 .get("location")).get(0).split("/");
 189         String policyID = locationHeader[(locationHeader.length) - 1];
 190         Mono<ResponseEntity<String>> responseMonoDelete = testHelper.restClientV3().deleteForEntity(url+"/" +policyID);
 191         testHelper.testSuccessResponse(responseMonoDelete, HttpStatus.NO_CONTENT, responseBody -> true);
 192     }
 193
 194     @Test
 195     @DisplayName("test Create Policy schema validation fail case")
 196     void testPolicySchemaValidationFail() throws Exception {
 197         String nonRtRicId = "ric.1";
 198         String policyTypeName = "type1_1.2.3";
 199         String url = "/policies";
 200         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 201         when(helper.jsonSchemaValidation(any())).thenReturn(Boolean.FALSE);
 202         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName, "");
 203         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 204         testHelper.testErrorCode(responseMono, HttpStatus.BAD_REQUEST, " Schema validation failed");
 205     }
 206
 207     @Test
 208     @DisplayName("test Create Policy No Ric fail case")
 209     void testCreatePolicyNoRic() throws Exception {
 210         String policyTypeName = "type1_1.2.3";
 211         String url = "/policies";
 212         testHelper.addPolicyType(policyTypeName, " ");
 213         when(helper.jsonSchemaValidation(any())).thenReturn(Boolean.TRUE);
 214         String policyBody = testHelper.postPolicyBody("noRic", policyTypeName, "");
 215         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 216         testHelper.testErrorCode(responseMono, HttpStatus.NOT_FOUND, " Could not find ric: noRic");
 217     }
 218
 219     @Test
 220     @DisplayName("test Create Policy with No Policy Type fail case")
 221     void testCreatePolicyNoPolicyType() throws Exception {
 222         String policyTypeName = "type1_1.2.3";
 223         String nonRtRicId = "ricOne";
 224         String url = "/policies";
 225         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 226         when(helper.jsonSchemaValidation(any())).thenReturn(Boolean.TRUE);
 227         String policyBody = testHelper.postPolicyBody(nonRtRicId, "noPolicyType", "");
 228         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 229         testHelper.testErrorCode(responseMono, HttpStatus.NOT_FOUND, "Could not find type: noPolicyType");
 230     }
 231
 232     @Test
 233     public void testGetPolicyTypesNoRicFound() throws Exception{
 234         String policyTypeName = "type1_1.2.3";
 235         String nonRtRicId = "ricOne";
 236         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 237         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().getForEntity("/policy-types" + "?nearRtRicId=\"noRic\"");
 238         testHelper.testErrorCode(responseMono, HttpStatus.NOT_FOUND, "Near-RT RIC not Found using ID:");
 239     }
 240
 241     @Test
 242     @DisplayName("test get Policy")
 243     void testGetPolicy() throws Exception {
 244         String nonRtRicId = "ric.1";
 245         String policyTypeName = "type1_1.2.3";
 246         String url = "/policies";
 247         testHelper.addPolicyType(policyTypeName, nonRtRicId);
 248         String policyBody = testHelper.postPolicyBody(nonRtRicId, policyTypeName, "");
 249         Mono<ResponseEntity<String>> responseMono = testHelper.restClientV3().postForEntity(url, policyBody);
 250         String []locationHeader = Objects.requireNonNull(Objects.requireNonNull(responseMono.block()).getHeaders()
 251                 .get("location")).get(0).split("/");
 252         String policyID = locationHeader[(locationHeader.length) - 1];
 253         Mono<ResponseEntity<String>> responseMonoGet = testHelper.restClientV3().getForEntity(url+"/" +policyID);
 254         testHelper.testSuccessResponse(responseMonoGet, HttpStatus.OK, responseBody ->
 255                 responseBody.contains("{\"scope\":{\"ueId\":\"ue5100\",\"qosId\":\"qos5100\"},\"qosObjectives\":{\"priorityLevel\":5100.0}}"));
 256     }
 257 }