diff options
Diffstat (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration')
2 files changed, 44 insertions, 33 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/Config.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/Config.java index 613e9a83..d26fbd81 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/Config.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/Config.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * PNF-REGISTRATION-HANDLER * ================================================================================ - * Copyright (C) 2018 NOKIA Intellectual Property. All rights reserved. + * Copyright (C) 2018-2019 NOKIA Intellectual Property. 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. @@ -23,12 +23,15 @@ package org.onap.dcaegen2.services.prh.configuration; import org.onap.dcaegen2.services.sdk.rest.services.aai.client.config.AaiClientConfiguration; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.DmaapConsumerConfiguration; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.DmaapPublisherConfiguration; +import org.springframework.core.io.Resource; /** * @author <a href="mailto:przemyslaw.wasala@nokia.com">Przemysław Wąsala</a> on 4/25/18 */ public interface Config { + Resource getGitInfo(); + DmaapConsumerConfiguration getDmaapConsumerConfiguration(); AaiClientConfiguration getAaiClientConfiguration(); diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/PrhAppConfig.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/PrhAppConfig.java index 612fab48..85f7e983 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/PrhAppConfig.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/configuration/PrhAppConfig.java @@ -2,7 +2,7 @@ * ============LICENSE_START======================================================= * PNF-REGISTRATION-HANDLER * ================================================================================ - * Copyright (C) 2018 NOKIA Intellectual Property. All rights reserved. + * Copyright (C) 2018-2019 NOKIA Intellectual Property. 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. @@ -20,18 +20,8 @@ package org.onap.dcaegen2.services.prh.configuration; -import com.google.gson.GsonBuilder; -import com.google.gson.JsonElement; -import com.google.gson.JsonObject; -import com.google.gson.JsonParser; -import com.google.gson.JsonSyntaxException; -import com.google.gson.TypeAdapterFactory; -import java.io.IOException; -import java.io.InputStream; -import java.io.InputStreamReader; -import java.nio.charset.StandardCharsets; -import java.util.ServiceLoader; -import javax.validation.constraints.NotNull; +import com.google.common.annotations.VisibleForTesting; +import com.google.gson.*; import org.onap.dcaegen2.services.sdk.rest.services.aai.client.config.AaiClientConfiguration; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.DmaapConsumerConfiguration; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.config.DmaapPublisherConfiguration; @@ -42,6 +32,14 @@ import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.Resource; +import org.springframework.util.StreamUtils; + +import javax.annotation.PostConstruct; +import javax.validation.constraints.NotNull; +import java.io.*; +import java.nio.charset.Charset; +import java.nio.charset.StandardCharsets; +import java.util.ServiceLoader; /** * @author <a href="mailto:przemyslaw.wasala@nokia.com">Przemysław Wąsala</a> on 4/9/18 @@ -50,6 +48,7 @@ import org.springframework.core.io.Resource; @EnableConfigurationProperties @ConfigurationProperties("app") public abstract class PrhAppConfig implements Config { + private static final Logger LOGGER = LoggerFactory.getLogger(PrhAppConfig.class); private static final String CONFIG = "configs"; private static final String AAI = "aai"; @@ -59,8 +58,6 @@ public abstract class PrhAppConfig implements Config { private static final String DMAAP_CONSUMER = "dmaapConsumerConfiguration"; private static final String SECURITY = "security"; - private static final Logger LOGGER = LoggerFactory.getLogger(PrhAppConfig.class); - AaiClientConfiguration aaiClientConfiguration; DmaapConsumerConfiguration dmaapConsumerConfiguration; @@ -68,7 +65,20 @@ public abstract class PrhAppConfig implements Config { DmaapPublisherConfiguration dmaapPublisherConfiguration; @Value("classpath:prh_endpoints.json") - private Resource resourceFile; + private Resource prhEndpoints; + + @Value("classpath:git_info.json") + private Resource gitInfo; + + @PostConstruct + private void printGitInfo() throws IOException { + LOGGER.debug("Git info={}", StreamUtils.copyToString(gitInfo.getInputStream(), Charset.defaultCharset())); + } + + @Override + public Resource getGitInfo() { + return gitInfo; + } @Override public DmaapConsumerConfiguration getDmaapConsumerConfiguration() { @@ -87,21 +97,19 @@ public abstract class PrhAppConfig implements Config { @Override public void initFileStreamReader() { - GsonBuilder gsonBuilder = new GsonBuilder(); ServiceLoader.load(TypeAdapterFactory.class).forEach(gsonBuilder::registerTypeAdapterFactory); JsonParser parser = new JsonParser(); - try (InputStream inputStream = resourceFile.getInputStream()) { + try (InputStream inputStream = prhEndpoints.getInputStream()) { JsonElement rootElement = getJsonElement(parser, inputStream); if (rootElement.isJsonObject()) { deserializeAaiConfiguration(gsonBuilder, rootElement); deserializeDmaapConsumerConfiguration(gsonBuilder, rootElement); deserializeDmaapPublisherConfiguration(gsonBuilder, rootElement); } - } - catch (IOException e) { - LOGGER.warn("Problem with file loading, file ", e); + } catch (IOException e) { + LOGGER.warn("Failed to load/parse file", e); } } @@ -109,8 +117,8 @@ public abstract class PrhAppConfig implements Config { dmaapPublisherConfiguration = deserializeType(gsonBuilder, concatenateJsonObjects( rootElement.getAsJsonObject().getAsJsonObject(CONFIG).getAsJsonObject(DMAAP) .getAsJsonObject(DMAAP_PRODUCER), - rootElement.getAsJsonObject().getAsJsonObject(CONFIG).getAsJsonObject(SECURITY)), - DmaapPublisherConfiguration.class); + rootElement.getAsJsonObject().getAsJsonObject(CONFIG).getAsJsonObject(SECURITY)), + DmaapPublisherConfiguration.class); } private void deserializeDmaapConsumerConfiguration(GsonBuilder gsonBuilder, JsonElement rootElement) { @@ -118,7 +126,7 @@ public abstract class PrhAppConfig implements Config { rootElement.getAsJsonObject().getAsJsonObject(CONFIG).getAsJsonObject(DMAAP) .getAsJsonObject(DMAAP_CONSUMER), rootElement.getAsJsonObject().getAsJsonObject(CONFIG).getAsJsonObject(SECURITY)), - DmaapConsumerConfiguration.class); + DmaapConsumerConfiguration.class); } private void deserializeAaiConfiguration(GsonBuilder gsonBuilder, JsonElement rootElement) { @@ -134,22 +142,22 @@ public abstract class PrhAppConfig implements Config { private JsonObject concatenateJsonObjects(JsonObject target, JsonObject source) { source.entrySet() - .forEach(entry -> target.add(entry.getKey(), entry.getValue())); + .forEach(entry -> target.add(entry.getKey(), entry.getValue())); return target; } private <T> T deserializeType(@NotNull GsonBuilder gsonBuilder, @NotNull JsonObject jsonObject, - @NotNull Class<T> type) { + @NotNull Class<T> type) { try { return gsonBuilder.create().fromJson(jsonObject, type); - } catch (JsonSyntaxException e) { - LOGGER.warn("Problem with Json deserialization", e); + } catch (JsonSyntaxException e) { + LOGGER.warn("Failed to parse JSON={}", jsonObject, e); return null; } } - void setResourceFile(Resource resourceFile) { - this.resourceFile = resourceFile; + @VisibleForTesting + void setPrhEndpoints(Resource prhEndpoints) { + this.prhEndpoints = prhEndpoints; } - -}
\ No newline at end of file +} |