diff options
Diffstat (limited to 'sdnr/wt/mountpoint-registrar/provider/src/main')
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"); + } + } |