adding getSanitizedQueryString()

sanjeevgour · Sep 18, 2015 · bea994c · bea994c
1 parent 9224295
commit bea994c
Showing 1 changed file with 14 additions and 3 deletions.
diff --git a/zuul-simple-webapp/src/main/groovy/filters/route/SimpleHostRequest.groovy b/zuul-simple-webapp/src/main/groovy/filters/route/SimpleHostRequest.groovy
@@ -220,17 +220,17 @@ class SimpleHostRoutingFilter extends ZuulFilter {
 
         switch (verb) {
             case 'POST':
-                httpRequest = new HttpPost(uri + getQueryString())
+                httpRequest = new HttpPost(uri + getSanitizedQueryString())
                 InputStreamEntity entity = new InputStreamEntity(requestEntity, request.getContentLength())
                 httpRequest.setEntity(entity)
                 break
             case 'PUT':
-                httpRequest = new HttpPut(uri + getQueryString())
+                httpRequest = new HttpPut(uri + getSanitizedQueryString())
                 InputStreamEntity entity = new InputStreamEntity(requestEntity, request.getContentLength())
                 httpRequest.setEntity(entity)
                 break;
             default:
-                httpRequest = new BasicHttpRequest(verb, uri + getQueryString())
+                httpRequest = new BasicHttpRequest(verb, uri + getSanitizedQueryString())
         }
 
         try {
@@ -250,6 +250,17 @@ class SimpleHostRoutingFilter extends ZuulFilter {
         return httpclient.execute(httpHost, httpRequest);
     }
 
+    String getSanitizedQueryString() {
+        String encoding = "UTF-8"
+        String currentQueryString = getQueryString()
+        if (currentQueryString.equals("")) {
+            return ""
+        }
+
+        String decodedQueryString = URLDecoder.decode(currentQueryString, encoding)
+        return new URI(null, null, null, decodedQueryString, null).toString()
+    }
+
     String getQueryString() {
         HttpServletRequest request = RequestContext.currentContext.getRequest();
         String query = request.getQueryString()