import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
+import java.util.Optional;
import java.util.Properties;
import java.util.ServiceLoader;
+import java.util.Vector;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.stereotype.Component;
import reactor.core.publisher.Mono;
-@Component
@EnableConfigurationProperties
@ConfigurationProperties("app")
public class ApplicationConfig {
@NotEmpty
private String filepath;
+ private Vector<RicConfig> ricConfigs;
+
@Autowired
public ApplicationConfig() {
}
this.filepath = filepath;
}
- /**
- * Reads the cloud configuration.
- */
+ public Vector<RicConfig> getRicConfigs() {
+ return this.ricConfigs;
+ }
+
+ public Optional<RicConfig> lookupRicConfigForManagedElement(String managedElementId) {
+ for (RicConfig ricConfig : getRicConfigs()) {
+ if (ricConfig.managedElementIds().contains(managedElementId)) {
+ return Optional.of(ricConfig);
+ }
+ }
+ return Optional.empty();
+ }
+
+ public RicConfig getRic(String ricName) throws ServiceException {
+ for (RicConfig ricConfig : getRicConfigs()) {
+ if (ricConfig.name().equals(ricName)) {
+ return ricConfig;
+ }
+ }
+ throw new ServiceException("Could not find ric: " + ricName);
+ }
+
public void initialize() {
- loadConfigurationFromFile();
+ loadConfigurationFromFile(this.filepath);
}
Mono<Environment.Variables> getEnvironment(Properties systemEnvironment) {
/**
* Reads the configuration from file.
*/
- void loadConfigurationFromFile() {
+ protected void loadConfigurationFromFile(String filepath) {
GsonBuilder gsonBuilder = new GsonBuilder();
ServiceLoader.load(TypeAdapterFactory.class).forEach(gsonBuilder::registerTypeAdapterFactory);
}
ApplicationConfigParser appParser = new ApplicationConfigParser();
appParser.parse(rootObject);
+ this.ricConfigs = appParser.getRicConfigs();
logger.info("Local configuration file loaded: {}", filepath);
} catch (JsonSyntaxException | ServiceException | IOException e) {
logger.trace("Local configuration file not loaded: {}", filepath, e);