diff options
author | Valerij Fredriksen <valerijf@oath.com> | 2018-01-12 09:56:44 +0100 |
---|---|---|
committer | Valerij Fredriksen <valerijf@oath.com> | 2018-01-12 09:56:44 +0100 |
commit | 742eeaf30b7e1ee69fed0b7cc269bd9880c553be (patch) | |
tree | bba4003ada8ebf2822ada3c74f73f32b0fa9a034 /controller-server | |
parent | 7ea1191577121a2751a30599a55508a5440a9f57 (diff) |
ZoneV2 copy method override header
Diffstat (limited to 'controller-server')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java index 379e5c10847..b16fe7943ba 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/proxy/ConfigServerRestExecutorImpl.java @@ -38,7 +38,7 @@ import java.nio.charset.StandardCharsets; import java.security.cert.X509Certificate; import java.time.Duration; import java.util.ArrayList; -import java.util.HashSet; +import java.util.Collections; import java.util.List; import java.util.Map; import java.util.Optional; @@ -54,6 +54,7 @@ import static java.util.Collections.singleton; public class ConfigServerRestExecutorImpl implements ConfigServerRestExecutor { private static final Duration PROXY_REQUEST_TIMEOUT = Duration.ofSeconds(10); + private static final Set<String> HEADERS_TO_COPY = Collections.singleton("X-HTTP-Method-Override"); private final ZoneRegistry zoneRegistry; private final AthenzSslContextProvider sslContextProvider; @@ -125,7 +126,7 @@ public class ConfigServerRestExecutorImpl implements ConfigServerRestExecutor { final HttpRequestBase requestBase = createHttpBaseRequest( proxyRequest.getMethod(), fullUri, proxyRequest.getData()); // Empty list of headers to copy for now, add headers when needed, or rewrite logic. - copyHeaders(proxyRequest.getHeaders(), requestBase, new HashSet<>()); + copyHeaders(proxyRequest.getHeaders(), requestBase); RequestConfig config = RequestConfig.custom() .setConnectTimeout((int) PROXY_REQUEST_TIMEOUT.toMillis()) @@ -193,10 +194,10 @@ public class ConfigServerRestExecutorImpl implements ConfigServerRestExecutor { } } - private void copyHeaders(Map<String, List<String>> headers, HttpRequestBase toRequest, Set<String> headersToCopy) { + private static void copyHeaders(Map<String, List<String>> headers, HttpRequestBase toRequest) { for (Map.Entry<String, List<String>> headerEntry : headers.entrySet()) { - for (String value : headerEntry.getValue()) { - if (headersToCopy.contains(value)) { + if (HEADERS_TO_COPY.contains(headerEntry.getKey())) { + for (String value : headerEntry.getValue()) { toRequest.addHeader(headerEntry.getKey(), value); } } |