Support IPv6 address

Mountpoints can be created with IPv6 address from VES PNFRegistration messages

Issue-ID: CCSDK-3257
Signed-off-by: Ravi Pendurty <ravi.pendurty@highstreet-technologies.com>
Change-Id: Ia9cde6db1d76599cfd24d95e987728fc7c39106c
Signed-off-by: Ravi Pendurty <ravi.pendurty@highstreet-technologies.com>

2 files changed, 57 insertions, 19 deletions

diff --git a/sdnr/wt/mountpoint-registrar/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/mountpointregistrar/impl/DMaaPPNFRegVESMsgConsumer.java b/sdnr/wt/mountpoint-registrar/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/mountpointregistrar/impl/DMaaPPNFRegVESMsgConsumer.java
index b64f6c689..1d70077b9 100644
--- a/sdnr/wt/mountpoint-registrar/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/mountpointregistrar/impl/DMaaPPNFRegVESMsgConsumer.java
+++ b/sdnr/wt/mountpoint-registrar/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/mountpointregistrar/impl/DMaaPPNFRegVESMsgConsumer.java
@@ -21,6 +21,7 @@ package org.onap.ccsdk.features.sdnr.wt.mountpointregistrar.impl;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import java.io.IOException;
+import org.eclipse.jdt.annotation.Nullable;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -43,19 +44,25 @@ public class DMaaPPNFRegVESMsgConsumer extends DMaaPVESMsgConsumerImpl {
     @Override
     public void processMsg(String msg) {
         LOG.debug("Message from DMaaP topic is - {} ", msg);
+        @Nullable
         String pnfId;
-        String pnfIPv4Address;
+        String pnfIPAddress;
+        @Nullable
         String pnfCommProtocol;
+        @Nullable
         String pnfCommPort;
+        @Nullable
         String pnfKeyId = null;
+        @Nullable
         String pnfUsername;
+        @Nullable
         String pnfPasswd = null;
         ObjectMapper oMapper = new ObjectMapper();
         JsonNode dmaapMessageRootNode;
         try {
             dmaapMessageRootNode = oMapper.readTree(msg);
             pnfId = dmaapMessageRootNode.at("/event/commonEventHeader/sourceName").textValue();
-            pnfIPv4Address = dmaapMessageRootNode.at("/event/pnfRegistrationFields/oamV4IpAddress").textValue();
+            pnfIPAddress = getPNFIPAddress(dmaapMessageRootNode);
             pnfCommProtocol =
                     dmaapMessageRootNode.at("/event/pnfRegistrationFields/additionalFields/protocol").textValue();
             pnfCommPort = dmaapMessageRootNode.at("/event/pnfRegistrationFields/additionalFields/oamPort").textValue();
@@ -89,8 +96,9 @@ public class DMaaPPNFRegVESMsgConsumer extends DMaaPVESMsgConsumerImpl {
                 pnfPasswd = DEFAULT_PASSWORD;
             }
 
-            LOG.debug("PNF Fields - {} : {} : {} : {} : {} : {} : {}", pnfId, pnfIPv4Address, pnfCommProtocol, pnfKeyId,
-                    pnfUsername, pnfPasswd, pnfCommPort);
+            LOG.debug(
+                    "PNF Fields - ID - {} : IP Address - {} : Protocol - {} : TLS Key ID - {} : User - {} : Port - {}",
+                    pnfId, pnfIPAddress, pnfCommProtocol, pnfKeyId, pnfUsername, pnfCommPort);
 
             String baseUrl = getBaseUrl();
             String sdnrUser = getSDNRUser();
@@ -100,13 +108,16 @@ public class DMaaPPNFRegVESMsgConsumer extends DMaaPVESMsgConsumerImpl {
             LOG.debug("Setting RESTConf Authorization values - {} : {}", sdnrUser, sdnrPasswd);
             mountpointClient.setAuthorization(sdnrUser, sdnrPasswd);
 
-            if ((null != pnfId) && (null != pnfIPv4Address) && (null != pnfCommProtocol) && (null != pnfUsername)
+            if ((null != pnfId) && null != pnfIPAddress && (null != pnfCommProtocol) && (null != pnfUsername)
                     && (null != pnfCommPort)) {
-                mountpointClient.pnfMountPointCreate(pnfId, pnfIPv4Address, pnfCommProtocol, pnfKeyId, pnfUsername,
+                mountpointClient.pnfMountPointCreate(pnfId, pnfIPAddress, pnfCommProtocol, pnfKeyId, pnfUsername,
                         pnfPasswd, pnfCommPort);
             } else {
-                LOG.warn("One of the mandatory fields has a null value - pnfId = {} : pnfIPv4Address = {} : pnfCommProtocol = {} : pnfUsername {} : "
-                        + "pnfCommPort {}", pnfId, pnfIPv4Address, pnfCommProtocol, pnfUsername, pnfCommPort, "- not invoking mountpoint creation");
+                LOG.warn(
+                        "One of the mandatory fields has a null value - pnfId = {} : pnfIPAddress = {} : pnfCommProtocol = {} : pnfUsername {} : "
+                                + "pnfCommPort {}",
+                        pnfId, pnfIPAddress, pnfCommProtocol, pnfUsername, pnfCommPort,
+                        "- not invoking mountpoint creation");
             }
         } catch (IOException e) {
             LOG.info("Cannot parse json object, ignoring the received PNF Registration VES Message. Reason: {}",
@@ -114,6 +125,18 @@ public class DMaaPPNFRegVESMsgConsumer extends DMaaPVESMsgConsumerImpl {
         }
     }
 
+    private String getPNFIPAddress(JsonNode dmaapMessageRootNode) {
+        String ipAddress = dmaapMessageRootNode.at("/event/pnfRegistrationFields/oamV6IpAddress").textValue();
+        if (ipAddress != null && ipAddress != "")
+            return ipAddress;
+
+        ipAddress = dmaapMessageRootNode.at("/event/pnfRegistrationFields/oamV4IpAddress").textValue();
+        if (ipAddress != null && ipAddress != "")
+            return ipAddress;
+
+        return null;
+    }
+
     public String getBaseUrl() {
         return generalConfig.getBaseUrl();
     }
@@ -126,7 +149,7 @@ public class DMaaPPNFRegVESMsgConsumer extends DMaaPVESMsgConsumerImpl {
         return generalConfig.getSDNRPasswd() != null ? generalConfig.getSDNRPasswd() : DEFAULT_SDNRPASSWD;
     }
 
-    public PNFMountPointClient getPNFMountPointClient(String baseUrl) {
+    private PNFMountPointClient getPNFMountPointClient(String baseUrl) {
         return new PNFMountPointClient(baseUrl);
     }
 }
diff --git a/sdnr/wt/mountpoint-registrar/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/mountpointregistrar/impl/PNFMountPointClient.java b/sdnr/wt/mountpoint-registrar/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/mountpointregistrar/impl/PNFMountPointClient.java
index 029ae4c55..b271e8a6d 100644
--- a/sdnr/wt/mountpoint-registrar/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/mountpointregistrar/impl/PNFMountPointClient.java
+++ b/sdnr/wt/mountpoint-registrar/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/mountpointregistrar/impl/PNFMountPointClient.java
@@ -22,6 +22,9 @@ import java.io.IOException;
 import java.util.Base64;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import org.eclipse.jdt.annotation.NonNull;
 import org.onap.ccsdk.features.sdnr.wt.common.database.requests.BaseRequest;
 import org.onap.ccsdk.features.sdnr.wt.common.http.BaseHTTPClient;
 import org.onap.ccsdk.features.sdnr.wt.common.http.BaseHTTPResponse;
@@ -90,35 +93,35 @@ public class PNFMountPointClient extends BaseHTTPClient {
 
     }
 
-    public boolean pnfMountPointCreate(String pnfName, String ipv4Address, String protocol, String keyId,
-            String username, String password, String commPort) {
+    public boolean pnfMountPointCreate(@NonNull String pnfName, @NonNull String ipAddress, @NonNull String protocol, String keyId,
+            String username, String password, @NonNull String commPort) {
         String message = "";
         if (protocol.equals("TLS")) {
-            message = updateTLSPayload(pnfName, ipv4Address, username, keyId, commPort);
+            message = updateTLSPayload(pnfName, ipAddress, username, keyId, commPort);
         } else { //SSH
-            message = updatePayload(pnfName, ipv4Address, username, password, commPort);
-            LOG.debug("Payload after updating values is: {}", message);
+            message = updatePayload(pnfName, ipAddress, username, password, commPort);
         }
+        LOG.debug("Payload after updating values is: {}", redactMessage(message, protocol));
         return pnfRequest(pnfName, "PUT", message) == 200;
 
     }
 
-    private static String updatePayload(String pnfName, String ipv4Address, String username, String password,
+    private static String updatePayload(String pnfName, String ipAddress, String username, String password,
             String portNo) {
         // @formatter:off
         return SSH_PAYLOAD.replace("@device-name@", pnfName)
-                .replace("@device-ip@", ipv4Address)
+                .replace("@device-ip@", ipAddress)
                 .replace("@device-port@", portNo)
                 .replace("@username@", username)
                 .replace("@password@", password);
         // @formatter:on
     }
 
-    private static String updateTLSPayload(String pnfName, String ipv4Address, String username, String keyId,
+    private static String updateTLSPayload(String pnfName, String ipAddress, String username, String keyId,
             String portNo) {
         // @formatter:off
         return TLS_PAYLOAD.replace("@device-name@", pnfName)
-                .replace("@device-ip@", ipv4Address)
+                .replace("@device-ip@", ipAddress)
                 .replace("@username@", username)
                 .replace("@key-id@", keyId)
                 .replace("@device-port@", portNo);
@@ -126,7 +129,7 @@ public class PNFMountPointClient extends BaseHTTPClient {
     }
 
     private int pnfRequest(String pnfName, String method, String message) {
-        LOG.info("In pnfRequest - {} : {} : {}", pnfName, method, message);
+        LOG.info("In pnfRequest - {} : {} ", pnfName, method);
         BaseHTTPResponse response;
         try {
             String uri = MOUNTPOINT_URI + BaseRequest.urlEncodeValue(pnfName);
@@ -139,4 +142,16 @@ public class PNFMountPointClient extends BaseHTTPClient {
         }
     }
 
+    private String redactMessage(String message, String protocol) {
+        String REGEX = "";
+        if (("TLS").equals(protocol)) {
+            REGEX = "(<key-id.*>)(.*)(<\\/key-id>)";
+        } else {
+            REGEX = "(<password.*>)(.*)(<\\/password>)";
+        }
+        Pattern p = Pattern.compile(REGEX, Pattern.MULTILINE);
+        Matcher matcher = p.matcher(message);
+        return matcher.replaceAll("$1*********$3");
+    }
+
 }