1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
/*-
* ============LICENSE_START=======================================================
* org.onap.dcaegen2.collectors.ves
* ================================================================================
* Copyright (C) 2020 Nokia. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*/
package org.onap.dcae.configuration;
import io.vavr.collection.Map;
import io.vavr.control.Option;
import org.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.nio.file.Path;
public class ConfigUpdater {
private static final Logger log = LoggerFactory.getLogger(ConfigUpdater.class);
private final ConfigFilesFacade configFilesFacade;
private final Runnable applicationRestarter;
private boolean isApplicationRestartNeeded;
public ConfigUpdater(ConfigFilesFacade configFilesFacade, Runnable applicationRestarter) {
this.configFilesFacade = configFilesFacade;
this.applicationRestarter = applicationRestarter;
this.isApplicationRestartNeeded = false;
}
/**
* Set new paths
* @param propertiesFile application property file
* @param dmaapConfigFile dmaap configuration file
*/
public void setPaths(Path propertiesFile, Path dmaapConfigFile){
this.configFilesFacade.setPaths(propertiesFile, dmaapConfigFile);
}
public synchronized void updateConfig(Option<JSONObject> appConfig) {
appConfig.peek(this::handleUpdate).onEmpty(logSkipMessage());
}
private Runnable logSkipMessage() {
return () -> log.info("Skipping dynamic configuration");
}
private void handleUpdate(JSONObject appConfig) {
updatePropertiesIfChanged(appConfig);
updateDmaapConfigIfChanged(appConfig);
restartApplicationIfNeeded();
}
private void updatePropertiesIfChanged(JSONObject appConfig) {
Map<String, String> newProperties = ConfigParsing.getProperties(appConfig);
Map<String, String> oldProperties = configFilesFacade.readCollectorProperties().get();
if (!areCommonPropertiesSame(oldProperties, newProperties)) {
configFilesFacade.writeProperties(newProperties);
isApplicationRestartNeeded = true;
}
}
private boolean areCommonPropertiesSame(Map<String, String> oldProperties, Map<String, String> newProperties) {
Map<String, String> filteredOldProperties = filterIntersectingKeys(oldProperties, newProperties);
return filteredOldProperties.equals(newProperties);
}
private Map<String, String> filterIntersectingKeys(Map<String, String> primaryProperties,
Map<String, String> otherProperties) {
return primaryProperties.filterKeys(key -> containsKey(key, otherProperties));
}
private boolean containsKey(String key, Map<String, String> properties) {
return properties.keySet().contains(key);
}
private void updateDmaapConfigIfChanged(JSONObject appConfig) {
JSONObject oldDmaapConfig = configFilesFacade.readDMaaPConfiguration().get();
JSONObject newDmaapConfig = ConfigParsing.getDMaaPConfig(appConfig).get();
if (!oldDmaapConfig.similar(newDmaapConfig)) {
configFilesFacade.writeDMaaPConfiguration(newDmaapConfig);
isApplicationRestartNeeded = true;
}
}
private void restartApplicationIfNeeded() {
if (isApplicationRestartNeeded) {
applicationRestarter.run();
isApplicationRestartNeeded = false;
}
}
}
|
