1 files changed, 92 insertions, 0 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParser.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParser.java
new file mode 100644
index 00000000..e2d9816e
--- /dev/null
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/service/DmaapConsumerJsonParser.java
@@ -0,0 +1,92 @@
+/*
+ * ============LICENSE_START=======================================================
+ * PNF-REGISTRATION-HANDLER
+ * ================================================================================
+ * Copyright (C) 2018 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.
+ * 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.dcaegen2.services.prh.service;
+
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+import java.util.Optional;
+import org.onap.dcaegen2.services.prh.exceptions.DmaapNotFoundException;
+import org.onap.dcaegen2.services.prh.model.ConsumerDmaapModel;
+import org.onap.dcaegen2.services.prh.model.ImmutableConsumerDmaapModel;
+
+/**
+ * @author <a href="mailto:przemyslaw.wasala@nokia.com">Przemysław Wąsala</a> on 5/8/18
+ */
+public class DmaapConsumerJsonParser {
+
+    private static final String EVENT = "event";
+    private static final String OTHER_FIELDS = "otherFields";
+    private static final String PNF_OAM_IPV_4_ADDRESS = "pnfOamIpv4Address";
+    private static final String PNF_OAM_IPV_6_ADDRESS = "pnfOamIpv6Address";
+    private static final String PNF_VENDOR_NAME = "pnfVendorName";
+    private static final String PNF_SERIAL_NUMBER = "pnfSerialNumber";
+
+
+    private DmaapConsumerJsonParser() {
+    }
+
+    public static ConsumerDmaapModel getJsonObject(String message) throws DmaapNotFoundException {
+        JsonElement jsonElement = new JsonParser().parse(message);
+        JsonObject jsonObject = jsonElement.getAsJsonObject();
+        return create(jsonObject);
+    }
+
+    private static ConsumerDmaapModel create(JsonObject jsonObject) throws DmaapNotFoundException {
+        if (containsHeader(jsonObject)) {
+            jsonObject = jsonObject.getAsJsonObject(EVENT).getAsJsonObject(OTHER_FIELDS);
+            String pnfVendorName = getValueFromJson(jsonObject, PNF_VENDOR_NAME);
+            String pnfSerialNumber = getValueFromJson(jsonObject, PNF_SERIAL_NUMBER);
+            String pnfOamIpv4Address = getValueFromJson(jsonObject, PNF_OAM_IPV_4_ADDRESS);
+            String pnfOamIpv6Address = getValueFromJson(jsonObject, PNF_OAM_IPV_6_ADDRESS);
+            if (isVendorAndSerialNotEmpty(pnfSerialNumber, pnfVendorName) && isIpPropertiesNotEmpty(pnfOamIpv4Address,
+                pnfOamIpv6Address)) {
+                String correlationID = pnfVendorName.substring(0, Math.min(pnfVendorName.length(), 3)).toUpperCase()
+                    .concat(pnfSerialNumber);
+                return ImmutableConsumerDmaapModel.builder().pnfName(correlationID).ipv4(pnfOamIpv4Address)
+                    .ipv6(pnfOamIpv6Address).build();
+            }
+            throw new DmaapNotFoundException("IPV4 and IPV6 are empty");
+        }
+        throw new DmaapNotFoundException("Incorrect JsonObject");
+    }
+
+    private static String getValueFromJson(JsonObject jsonObject, String jsonKey) {
+        if (jsonObject.has(jsonKey)) {
+            return jsonObject.get(jsonKey).getAsString();
+        }
+        return "";
+    }
+
+    private static boolean isVendorAndSerialNotEmpty(String pnfSerialNumber, String pnfVendorName) {
+        return ((pnfSerialNumber != null && !pnfSerialNumber.isEmpty()) && (pnfVendorName != null && !pnfVendorName
+            .isEmpty()));
+    }
+
+    private static boolean isIpPropertiesNotEmpty(String ipv4, String ipv6) {
+        return (ipv4 != null && !ipv4.isEmpty()) || (ipv6 != null
+            && !ipv6.isEmpty());
+    }
+
+    private static boolean containsHeader(JsonObject jsonObject) {
+        return jsonObject.has(EVENT) && jsonObject.getAsJsonObject(EVENT).has(OTHER_FIELDS);
+    }
+
+}