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

   1 /*-
   2  * ========================LICENSE_START=================================
   3  * ONAP : ccsdk oran
   4  * ======================================================================
   5  * Copyright (C) 2019-2020 Nordix Foundation. 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;
  22
  23 import static org.awaitility.Awaitility.await;
  24
  25 import com.google.gson.JsonObject;
  26 import com.google.gson.JsonParser;
  27
  28 import java.io.File;
  29 import java.io.IOException;
  30 import java.net.URL;
  31 import java.nio.file.Files;
  32 import java.time.Instant;
  33
  34 import org.junit.jupiter.api.Test;
  35 import org.junit.jupiter.api.extension.ExtendWith;
  36 import org.onap.ccsdk.oran.a1policymanagementservice.configuration.ApplicationConfig;
  37 import org.onap.ccsdk.oran.a1policymanagementservice.repository.ImmutablePolicy;
  38 import org.onap.ccsdk.oran.a1policymanagementservice.repository.ImmutablePolicyType;
  39 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Policies;
  40 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Policy;
  41 import org.onap.ccsdk.oran.a1policymanagementservice.repository.PolicyType;
  42 import org.onap.ccsdk.oran.a1policymanagementservice.repository.PolicyTypes;
  43 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Ric;
  44 import org.onap.ccsdk.oran.a1policymanagementservice.repository.Rics;
  45 import org.onap.ccsdk.oran.a1policymanagementservice.utils.MockA1ClientFactory;
  46 import org.slf4j.Logger;
  47 import org.slf4j.LoggerFactory;
  48 import org.springframework.beans.factory.annotation.Autowired;
  49 import org.springframework.boot.test.context.SpringBootTest;
  50 import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;
  51 import org.springframework.boot.test.context.TestConfiguration;
  52 import org.springframework.boot.web.server.LocalServerPort;
  53 import org.springframework.context.annotation.Bean;
  54 import org.springframework.test.context.TestPropertySource;
  55 import org.springframework.test.context.junit.jupiter.SpringExtension;
  56 import org.springframework.util.StringUtils;
  57
  58 @ExtendWith(SpringExtension.class)
  59 @SpringBootTest(webEnvironment = WebEnvironment.DEFINED_PORT)
  60 @TestPropertySource(properties = { //
  61         "server.ssl.key-store=./config/keystore.jks", //
  62         "app.webclient.trust-store=./config/truststore.jks"})
  63 @SuppressWarnings("java:S3577") // Class name should start or end with Test. This is not a test class per se, but a mock
  64                                 // of the server.
  65 class MockPolicyManagementService {
  66     private static final Logger logger = LoggerFactory.getLogger(MockPolicyManagementService.class);
  67
  68     @Autowired
  69     Rics rics;
  70
  71     @Autowired
  72     Policies policies;
  73
  74     @Autowired
  75     PolicyTypes policyTypes;
  76
  77     @Autowired
  78     ApplicationConfig applicationConfig;
  79
  80     static class MockApplicationConfig extends ApplicationConfig {
  81         @Override
  82         public String getLocalConfigurationFilePath() {
  83             URL url = MockApplicationConfig.class.getClassLoader().getResource("test_application_configuration.json");
  84             return url.getFile();
  85         }
  86     }
  87
  88     /**
  89      * Overrides the BeanFactory.
  90      */
  91     @TestConfiguration
  92     static class TestBeanFactory {
  93
  94         private final Rics rics = new Rics();
  95         private final Policies policies = new Policies();
  96         private final PolicyTypes policyTypes = new PolicyTypes();
  97
  98         @Bean
  99         public ApplicationConfig getApplicationConfig() {
 100             return new MockApplicationConfig();
 101         }
 102
 103         @Bean
 104         public MockA1ClientFactory getA1ClientFactory() {
 105             PolicyTypes ricTypes = new PolicyTypes();
 106             loadTypes(ricTypes);
 107             return new MockA1ClientFactory(ricTypes);
 108         }
 109
 110         @Bean
 111         public Policies getPolicies() {
 112             return this.policies;
 113         }
 114
 115         @Bean
 116         public PolicyTypes getPolicyTypes() {
 117             return this.policyTypes;
 118         }
 119
 120         @Bean
 121         public Rics getRics() {
 122             return this.rics;
 123         }
 124
 125         private static File[] getResourceFolderFiles(String folder) {
 126             return getFile(folder).listFiles();
 127         }
 128
 129         private static String readFile(File file) throws IOException {
 130             return new String(Files.readAllBytes(file.toPath()));
 131         }
 132
 133         private void loadTypes(PolicyTypes policyTypes) {
 134             File[] files = getResourceFolderFiles("policy_types/");
 135             for (File file : files) {
 136                 try {
 137                     String schema = readFile(file);
 138                     String typeName = title(schema);
 139                     PolicyType type = ImmutablePolicyType.builder().id(typeName).schema(schema).build();
 140                     policyTypes.put(type);
 141                 } catch (Exception e) {
 142                     logger.error("Could not load json schema ", e);
 143                 }
 144             }
 145             policyTypes.put(ImmutablePolicyType.builder().id("").schema("{}").build());
 146         }
 147     }
 148
 149     private static File getFile(String path) {
 150         ClassLoader loader = Thread.currentThread().getContextClassLoader();
 151         URL url = loader.getResource(path);
 152         return new File(url.getPath());
 153     }
 154
 155     @LocalServerPort
 156     private int port;
 157
 158     private void keepServerAlive() throws InterruptedException, IOException {
 159         waitForConfigurationToBeLoaded();
 160         loadInstances();
 161         logger.info("Keeping server alive! Listening on port: {}", port);
 162         synchronized (this) {
 163             this.wait();
 164         }
 165     }
 166
 167     private void waitForConfigurationToBeLoaded() throws IOException {
 168         String json = getConfigJsonFromFile();
 169         try {
 170             int noOfRicsInConfigFile = StringUtils.countOccurrencesOf(json, "baseUrl");
 171             await().until(() -> rics.size() == noOfRicsInConfigFile);
 172         } catch (Exception e) {
 173             logger.info("Loaded rics: {}, and no of rics in config file: {} never matched!", rics.size(),
 174                     StringUtils.countOccurrencesOf(json, "baseUrl"));
 175         }
 176     }
 177
 178     private static String title(String jsonSchema) {
 179         JsonObject parsedSchema = (JsonObject) JsonParser.parseString(jsonSchema);
 180         String title = parsedSchema.get("title").getAsString();
 181         return title;
 182     }
 183
 184     private void loadInstances() throws IOException {
 185         PolicyType unnamedPolicyType = policyTypes.get("");
 186         Ric ric = rics.get("ric1");
 187         String json = getConfigJsonFromFile();
 188
 189         Policy policy = ImmutablePolicy.builder() //
 190                 .id("typelessPolicy") //
 191                 .json(json) //
 192                 .ownerServiceId("MockPolicyManagementService") //
 193                 .ric(ric) //
 194                 .type(unnamedPolicyType) //
 195                 .lastModified(Instant.now()) //
 196                 .isTransient(false) //
 197                 .statusNotificationUri("statusNotificationUri") //
 198                 .build();
 199         this.policies.put(policy);
 200     }
 201
 202     private String getConfigJsonFromFile() throws IOException {
 203         File jsonFile = getFile("test_application_configuration.json");
 204         String json = new String(Files.readAllBytes(jsonFile.toPath()));
 205         return json;
 206     }
 207
 208     @Test
 209     @SuppressWarnings("squid:S2699") // Tests should include assertions. This test is only for keeping the server
 210                                      // alive, so it will only be confusing to add an assertion.
 211     void runMock() throws Exception {
 212         keepServerAlive();
 213     }
 214
 215 }