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