From: david.mcweeney Date: Tue, 10 Aug 2021 13:23:28 +0000 (+0100) Subject: DMAAP-DR - Whitelist removal X-Git-Tag: 2.1.9~2 X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F24%2F123224%2F2;p=dmaap%2Fdatarouter.git DMAAP-DR - Whitelist removal Signed-off-by: david.mcweeney Change-Id: I6a12c9ae5f5aaff6045b9b6ee7d5c33274e94dc3 Issue-ID: DMAAP-1624 --- diff --git a/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/NodeServlet.java b/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/NodeServlet.java index 27fa5f3e..aa827de1 100644 --- a/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/NodeServlet.java +++ b/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/NodeServlet.java @@ -253,14 +253,8 @@ public class NodeServlet extends HttpServlet { return; } fileid = fileid.substring(18); - if (req.getHeader("X-DMAAP-DR-PUBLISH-ID") != null && !req.getHeader("X-DMAAP-DR-PUBLISH-ID").matches("^[a-zA-Z0-9_]+$")) { - String reason = "Error validating header"; - eelfLogger.error(reason); - resp.sendError(HttpServletResponse.SC_BAD_REQUEST, reason); - eelfLogger.info(EelfMsgs.EXIT); - return; - } pubid = req.getHeader("X-DMAAP-DR-PUBLISH-ID"); + user = "datartr"; // SP6 : Added usr as datartr to avoid null entries for internal routing targets = config.parseRouting(req.getHeader("X-DMAAP-DR-ROUTING")); } else { diff --git a/datarouter-node/src/test/java/org/onap/dmaap/datarouter/node/NodeServletTest.java b/datarouter-node/src/test/java/org/onap/dmaap/datarouter/node/NodeServletTest.java index ad2fcf5d..4340b018 100644 --- a/datarouter-node/src/test/java/org/onap/dmaap/datarouter/node/NodeServletTest.java +++ b/datarouter-node/src/test/java/org/onap/dmaap/datarouter/node/NodeServletTest.java @@ -204,17 +204,6 @@ public class NodeServletTest { verifyEnteringExitCalled(listAppender); } - @Test - public void Given_Request_Is_HTTP_PUT_And_Internal_Publish_But_Invalid_Header_Then_Bad_Request_Response_Is_Generated() throws Exception { - when(request.getPathInfo()).thenReturn("/internal/publish/1/blah"); - when(request.getRemoteAddr()).thenReturn("1.2.3.4"); - when(config.isAnotherNode(anyString(), anyString())).thenReturn(true); - when(request.getHeader("X-DMAAP-DR-PUBLISH-ID")).thenReturn("User1+"); - nodeServlet.doPut(request, response); - verify(response).sendError(eq(HttpServletResponse.SC_BAD_REQUEST), anyString()); - verifyEnteringExitCalled(listAppender); - } - @Test public void Given_Request_Is_HTTP_PUT_On_Publish_And_Ingress_Node_Is_Provided_Then_Request_Is_Redirected() throws Exception { setNodeConfigManagerToAllowRedirectOnIngressNode();