import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
import org.onap.ccsdk.features.sdnr.wt.common.http.BaseHTTPClient;
import org.onap.ccsdk.features.sdnr.wt.common.http.BaseHTTPResponse;
import org.slf4j.Logger;
public abstract boolean sendNotification(String message);
protected boolean sendNotification(String message, SendMethod method, MessageType messageType) {
- LOG.debug("In sendRequestNotification - {}-{}", method, message);
+ LOG.debug("In sendRequestNotification - {}-{}", method, redactMessage(message));
headerMap.put("Content-Type", "application/".concat(messageType.toString()));
headerMap.put("Accept", "application/".concat(messageType.toString()));
BaseHTTPResponse response;
this.notificationUri = notificationUri;
}
+ private String redactMessage(String message) {
+ String REGEX = "";
+ if (message.contains("<key-id")) {
+ REGEX = "(<key-id.*>)(.*)(<\\/key-id>)";
+ } else if (message.contains("<password")) {
+ REGEX = "(<password.*>)(.*)(<\\/password>)";
+ } else {
+ return message;
+ }
+ Pattern p = Pattern.compile(REGEX, Pattern.MULTILINE);
+ Matcher matcher = p.matcher(message);
+ return matcher.replaceAll("$1*********$3");
+ }
}
package org.onap.ccsdk.features.sdnr.wt.mountpointregistrar.impl;
-import org.eclipse.jdt.annotation.NonNull;
-import org.onap.ccsdk.features.sdnr.wt.common.database.requests.BaseRequest;
-
+import static org.onap.ccsdk.features.sdnr.wt.mountpointregistrar.impl.MessageClient.MessageType.xml;
+import static org.onap.ccsdk.features.sdnr.wt.mountpointregistrar.impl.MessageClient.SendMethod.PUT;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-
-import static org.onap.ccsdk.features.sdnr.wt.mountpointregistrar.impl.MessageClient.MessageType.*;
-import static org.onap.ccsdk.features.sdnr.wt.mountpointregistrar.impl.MessageClient.SendMethod.PUT;
+import org.eclipse.jdt.annotation.NonNull;
+import org.onap.ccsdk.features.sdnr.wt.common.database.requests.BaseRequest;
public class PNFMountPointClient extends MessageClient {
"restconf/config/network-topology:network-topology/topology/topology-netconf/node/";
public static final String DEVICE_NAME = "@device-name@", DEVICE_IP = "@device-ip@", DEVICE_PORT = "@device-port@",
USERNAME = "@username@", PASSWORD = "@password@", KEY_ID = "@key-id@";
- private static final String PROTOCOL = "protocol";
+ private static final String PROTOCOL = "protocol_sec";
public static List<String> REQUIRED_FIELDS_SSH = List.of(PROTOCOL, DEVICE_NAME, DEVICE_IP, DEVICE_PORT, USERNAME, PASSWORD);
public static List<String> REQUIRED_FIELDS_TLS = List.of(PROTOCOL, DEVICE_NAME, DEVICE_IP, DEVICE_PORT, USERNAME, KEY_ID);
testClient = new TestPNFMountPointClient();
testClient.setAuthorization("admin", "admin");
Map<String, String> payloadMap = PNFMountPointClient.createPNFNotificationPayloadMap(
- "TEST 50001", "127.0.0.1", "TLS", "key_id",
- "admin", "admin", "17380");
+ "TEST 50001", "127.0.0.1", "17830", "TLS",
+ "admin", "admin", "key_id");
String msg = testClient.prepareMessageFromPayloadMap(payloadMap);
assertTrue(testClient.sendNotification(msg));