Fix wrong URL encoding in watcher HTTP client

The test assumption was calling the wrong method resulting in a URL encoding before returning the data. Closes elastic#44970 (for real this time)
spinscale · Aug 23, 2019 · 6528afa · 6528afa
1 parent eef8235
commit 6528afa
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/.../plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/common/http/HttpClient.java b/.../plugin/watcher/src/main/java/org/elasticsearch/xpack/watcher/common/http/HttpClient.java
@@ -334,12 +334,11 @@ static Tuple<HttpHost, URI> createURI(HttpRequest request) {
                     String part = pathParts[i];
                     boolean isLast = i == pathParts.length - 1;
                     if (Strings.isEmpty(part) == false) {
-                        String appendPart = part;
+                        unescapedPathParts.add(URLDecoder.decode(part, StandardCharsets.UTF_8.name()));
                         boolean appendSlash = isPathEndsWithSlash && isLast;
                         if (appendSlash) {
-                            appendPart += "/";
+                            unescapedPathParts.add("");
                         }
-                        unescapedPathParts.add(URLDecoder.decode(appendPart, StandardCharsets.UTF_8.name()));
                     }
                 }
             }

diff --git a/...in/watcher/src/test/java/org/elasticsearch/xpack/watcher/common/http/HttpClientTests.java b/...in/watcher/src/test/java/org/elasticsearch/xpack/watcher/common/http/HttpClientTests.java
@@ -751,7 +751,7 @@ public void testCreateUri() throws Exception {
     private void assertCreateUri(String uri, String expectedPath) {
         final HttpRequest request = HttpRequest.builder().fromUrl(uri).build();
         final Tuple<HttpHost, URI> tuple = HttpClient.createURI(request);
-        assertThat(tuple.v2().getPath(), is(expectedPath));
+        assertThat(tuple.v2().getRawPath(), is(expectedPath));
     }
 
     public static ClusterService mockClusterService() {