1 files changed, 40 insertions, 32 deletions

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
+}