Merge "Remove code smell and bug"
[nonrtric.git] / policy-agent / src / main / java / org / oransc / policyagent / tasks / EnvironmentProcessor.java
1 /*-
2  * ========================LICENSE_START=================================
3  * O-RAN-SC
4  * %%
5  * Copyright (C) 2019 Nordix Foundation
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.oransc.policyagent.tasks;
22
23 import java.util.Optional;
24 import java.util.Properties;
25
26 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.EnvProperties;
27 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.ImmutableEnvProperties;
28 import org.oransc.policyagent.exceptions.EnvironmentLoaderException;
29 import org.slf4j.Logger;
30 import org.slf4j.LoggerFactory;
31 import reactor.core.publisher.Mono;
32
33 class EnvironmentProcessor {
34
35     private static final int DEFAULT_CONSUL_PORT = 8500;
36     private static final Logger logger = LoggerFactory.getLogger(EnvironmentProcessor.class);
37
38     private EnvironmentProcessor() {
39     }
40
41     static Mono<EnvProperties> readEnvironmentVariables(Properties systemEnvironment) {
42
43         EnvProperties envProperties;
44         try {
45             envProperties = ImmutableEnvProperties.builder() //
46                 .consulHost(getConsulHost(systemEnvironment)) //
47                 .consulPort(getConsultPort(systemEnvironment)) //
48                 .cbsName(getConfigBindingService(systemEnvironment)) //
49                 .appName(getService(systemEnvironment)) //
50                 .build();
51         } catch (EnvironmentLoaderException e) {
52             return Mono.error(e);
53         }
54         logger.trace("Evaluated environment system variables {}", envProperties);
55         return Mono.just(envProperties);
56     }
57
58     private static String getConsulHost(Properties systemEnvironments) throws EnvironmentLoaderException {
59         return Optional.ofNullable(systemEnvironments.getProperty("CONSUL_HOST"))
60             .orElseThrow(() -> new EnvironmentLoaderException("$CONSUL_HOST environment has not been defined"));
61     }
62
63     private static Integer getConsultPort(Properties systemEnvironments) {
64         return Optional.ofNullable(systemEnvironments.getProperty("CONSUL_PORT")) //
65             .map(Integer::valueOf) //
66             .orElseGet(EnvironmentProcessor::getDefaultPortOfConsul);
67     }
68
69     private static String getConfigBindingService(Properties systemEnvironments) throws EnvironmentLoaderException {
70         return Optional.ofNullable(systemEnvironments.getProperty("CONFIG_BINDING_SERVICE")) //
71             .orElseThrow(
72                 () -> new EnvironmentLoaderException("$CONFIG_BINDING_SERVICE environment has not been defined"));
73     }
74
75     private static String getService(Properties systemEnvironments) throws EnvironmentLoaderException {
76         return Optional
77             .ofNullable(Optional.ofNullable(systemEnvironments.getProperty("HOSTNAME"))
78                 .orElse(systemEnvironments.getProperty("SERVICE_NAME")))
79             .orElseThrow(() -> new EnvironmentLoaderException(
80                 "Neither $HOSTNAME/$SERVICE_NAME have not been defined as system environment"));
81     }
82
83     private static Integer getDefaultPortOfConsul() {
84         logger.warn("$CONSUL_PORT variable will be set to default port {}", DEFAULT_CONSUL_PORT);
85         return DEFAULT_CONSUL_PORT;
86     }
87 }