2 * ========================LICENSE_START=================================
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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===================================
21 package org.onap.ccsdk.oran.a1policymanagementservice.configuration;
23 import java.util.ArrayList;
24 import java.util.Collection;
25 import java.util.HashMap;
28 import javax.validation.constraints.NotEmpty;
32 import org.onap.ccsdk.oran.a1policymanagementservice.configuration.WebClientConfig.HttpProxyConfig;
33 import org.onap.ccsdk.oran.a1policymanagementservice.exceptions.ServiceException;
34 import org.springframework.beans.factory.annotation.Value;
35 import org.springframework.boot.context.properties.EnableConfigurationProperties;
37 import reactor.core.publisher.Flux;
38 import reactor.netty.transport.ProxyProvider;
40 @EnableConfigurationProperties
41 public class ApplicationConfig {
44 @Value("${app.filepath}")
45 private String localConfigurationFilePath;
48 @Value("${app.config-file-schema-path:}")
49 private String configurationFileSchemaPath;
52 @Value("${app.vardata-directory:null}")
53 private String vardataDirectory;
55 @Value("${server.ssl.key-store-type}")
56 private String sslKeyStoreType = "";
58 @Value("${server.ssl.key-store-password}")
59 private String sslKeyStorePassword = "";
61 @Value("${server.ssl.key-store}")
62 private String sslKeyStore = "";
64 @Value("${server.ssl.key-password}")
65 private String sslKeyPassword = "";
67 @Value("${app.webclient.trust-store-used}")
68 private boolean sslTrustStoreUsed = false;
70 @Value("${app.webclient.trust-store-password}")
71 private String sslTrustStorePassword = "";
73 @Value("${app.webclient.trust-store}")
74 private String sslTrustStore = "";
76 @Value("${app.webclient.http.proxy-host:}")
77 private String httpProxyHost = "";
79 @Value("${app.webclient.http.proxy-port:0}")
80 private int httpProxyPort = 0;
82 @Value("${app.webclient.http.proxy-type:HTTP}")
83 private String httpProxyType = "HTTP";
85 private Map<String, RicConfig> ricConfigs = new HashMap<>();
88 private String dmaapConsumerTopicUrl;
91 private String dmaapProducerTopicUrl;
93 private Map<String, ControllerConfig> controllerConfigs = new HashMap<>();
95 private WebClientConfig webClientConfig = null;
97 public synchronized Collection<RicConfig> getRicConfigs() {
98 return this.ricConfigs.values();
101 public WebClientConfig getWebClientConfig() {
102 if (this.webClientConfig == null) {
103 HttpProxyConfig httpProxyConfig = ImmutableHttpProxyConfig.builder() //
104 .httpProxyHost(this.httpProxyHost) //
105 .httpProxyPort(this.httpProxyPort) //
106 .httpProxyType(ProxyProvider.Proxy.valueOf(this.httpProxyType)) //
109 this.webClientConfig = ImmutableWebClientConfig.builder() //
110 .keyStoreType(this.sslKeyStoreType) //
111 .keyStorePassword(this.sslKeyStorePassword) //
112 .keyStore(this.sslKeyStore) //
113 .keyPassword(this.sslKeyPassword) //
114 .isTrustStoreUsed(this.sslTrustStoreUsed) //
115 .trustStore(this.sslTrustStore) //
116 .trustStorePassword(this.sslTrustStorePassword) //
117 .httpProxyConfig(httpProxyConfig) //
120 return this.webClientConfig;
123 public synchronized ControllerConfig getControllerConfig(String name) throws ServiceException {
124 ControllerConfig controllerConfig = this.controllerConfigs.get(name);
125 if (controllerConfig == null) {
126 throw new ServiceException("Could not find controller config: " + name);
128 return controllerConfig;
131 public synchronized RicConfig getRic(String ricId) throws ServiceException {
132 RicConfig ricConfig = this.ricConfigs.get(ricId);
133 if (ricConfig == null) {
134 throw new ServiceException("Could not find ric configuration: " + ricId);
139 public static class RicConfigUpdate {
141 ADDED, CHANGED, REMOVED
145 private final RicConfig ricConfig;
147 private final Type type;
149 public RicConfigUpdate(RicConfig config, Type event) {
150 this.ricConfig = config;
155 public synchronized Flux<RicConfigUpdate> setConfiguration(
156 ApplicationConfigParser.ConfigParserResult parserResult) {
158 Collection<RicConfigUpdate> modifications = new ArrayList<>();
159 this.controllerConfigs = parserResult.controllerConfigs();
161 this.dmaapConsumerTopicUrl = parserResult.dmaapConsumerTopicUrl();
162 this.dmaapProducerTopicUrl = parserResult.dmaapProducerTopicUrl();
164 Map<String, RicConfig> newRicConfigs = new HashMap<>();
165 for (RicConfig newConfig : parserResult.ricConfigs()) {
166 RicConfig oldConfig = this.ricConfigs.get(newConfig.ricId());
167 this.ricConfigs.remove(newConfig.ricId());
168 if (oldConfig == null) {
169 newRicConfigs.put(newConfig.ricId(), newConfig);
170 modifications.add(new RicConfigUpdate(newConfig, RicConfigUpdate.Type.ADDED));
171 } else if (!newConfig.equals(oldConfig)) {
172 modifications.add(new RicConfigUpdate(newConfig, RicConfigUpdate.Type.CHANGED));
173 newRicConfigs.put(newConfig.ricId(), newConfig);
175 newRicConfigs.put(oldConfig.ricId(), oldConfig);
178 for (RicConfig deletedConfig : this.ricConfigs.values()) {
179 modifications.add(new RicConfigUpdate(deletedConfig, RicConfigUpdate.Type.REMOVED));
181 this.ricConfigs = newRicConfigs;
183 return Flux.fromIterable(modifications);