Merge pull request #24344 from vespa-engine/bratseth/return-ignored-fields

Return X-Vespa-Ignored-Fields if fields were ignored

5 files changed, 33 insertions, 47 deletions

diff --git a/container-core/src/main/java/com/yahoo/container/handler/LogReader.java b/container-core/src/main/java/com/yahoo/container/handler/LogReader.java
index 2890cbfb5ab..fe841bac68e 100644
--- a/container-core/src/main/java/com/yahoo/container/handler/LogReader.java
+++ b/container-core/src/main/java/com/yahoo/container/handler/LogReader.java
@@ -43,13 +43,13 @@ import static java.nio.charset.StandardCharsets.UTF_8;
  * @author jonmv
  */
 class LogReader {
+
     static final Pattern logArchivePathPattern = Pattern.compile("(\\d{4})/(\\d{2})/(\\d{2})/(\\d{2})-\\d+(\\.gz|\\.zst)?");
     static final Pattern vespaLogPathPattern = Pattern.compile("vespa\\.log(?:-(\\d{4})-(\\d{2})-(\\d{2})\\.(\\d{2})-(\\d{2})-(\\d{2})(?:\\.gz|\\.zst)?)?");
 
     private final Path logDirectory;
     private final Pattern logFilePattern;
 
-
     LogReader(String logDirectory, String logFilePattern) {
         this(Paths.get(Defaults.getDefaults().underVespaHome(logDirectory)), Pattern.compile(logFilePattern));
     }
diff --git a/container-core/src/main/java/com/yahoo/container/jdisc/state/StateHandler.java b/container-core/src/main/java/com/yahoo/container/jdisc/state/StateHandler.java
index cfd2244bd70..7a64e14e65e 100644
--- a/container-core/src/main/java/com/yahoo/container/jdisc/state/StateHandler.java
+++ b/container-core/src/main/java/com/yahoo/container/jdisc/state/StateHandler.java
@@ -274,15 +274,11 @@ public class StateHandler extends AbstractRequestHandler {
     }
 
     private static List<Tuple> collapseMetrics(MetricSnapshot snapshot, String consumer) {
-        switch (consumer) {
-            case HEALTH_PATH:
-                return collapseHealthMetrics(snapshot);
-            case "all": // deprecated name
-            case METRICS_PATH:
-                return flattenAllMetrics(snapshot);
-            default:
-                throw new IllegalArgumentException("Unknown consumer '" + consumer + "'.");
-        }
+        return switch (consumer) {
+            case HEALTH_PATH -> collapseHealthMetrics(snapshot); // deprecated name
+            case "all", METRICS_PATH -> flattenAllMetrics(snapshot);
+            default -> throw new IllegalArgumentException("Unknown consumer '" + consumer + "'.");
+        };
     }
 
     private static List<Tuple> collapseHealthMetrics(MetricSnapshot snapshot) {
diff --git a/container-core/src/main/java/com/yahoo/container/logging/AccessLogEntry.java b/container-core/src/main/java/com/yahoo/container/logging/AccessLogEntry.java
index c469c90f6ab..2639239d23f 100644
--- a/container-core/src/main/java/com/yahoo/container/logging/AccessLogEntry.java
+++ b/container-core/src/main/java/com/yahoo/container/logging/AccessLogEntry.java
@@ -65,16 +65,14 @@ public class AccessLogEntry {
                 return null;
             }
 
-            final Map<String, List<String>> newMapWithImmutableValues = mapValues(
+            Map<String, List<String>> newMapWithImmutableValues = mapValues(
                     keyValues.entrySet(),
                     valueList -> Collections.unmodifiableList(new ArrayList<>(valueList)));
             return Collections.unmodifiableMap(newMapWithImmutableValues);
         }
     }
 
-    private static <K, V1, V2> Map<K, V2> mapValues(
-            final Set<Map.Entry<K, V1>> entrySet,
-            final Function<V1, V2> valueConverter) {
+    private static <K, V1, V2> Map<K, V2> mapValues(Set<Map.Entry<K, V1>> entrySet, Function<V1, V2> valueConverter) {
         return entrySet.stream()
                 .collect(toMap(
                         entry -> entry.getKey(),
diff --git a/container-core/src/main/java/com/yahoo/jdisc/http/server/jetty/FormPostRequestHandler.java b/container-core/src/main/java/com/yahoo/jdisc/http/server/jetty/FormPostRequestHandler.java
index 72057563e36..d2dbfaa3514 100644
--- a/container-core/src/main/java/com/yahoo/jdisc/http/server/jetty/FormPostRequestHandler.java
+++ b/container-core/src/main/java/com/yahoo/jdisc/http/server/jetty/FormPostRequestHandler.java
@@ -54,17 +54,14 @@ class FormPostRequestHandler extends AbstractRequestHandler implements ContentCh
      * @param delegateHandler the "real" request handler that this handler wraps
      * @param contentCharsetName name of the charset to use when interpreting the content data
      */
-    public FormPostRequestHandler(
-            final RequestHandler delegateHandler,
-            final String contentCharsetName,
-            final boolean removeBody) {
+    public FormPostRequestHandler(RequestHandler delegateHandler, String contentCharsetName, boolean removeBody) {
         this.delegateHandler = Objects.requireNonNull(delegateHandler);
         this.contentCharsetName = Objects.requireNonNull(contentCharsetName);
         this.removeBody = removeBody;
     }
 
     @Override
-    public ContentChannel handleRequest(final Request request, final ResponseHandler responseHandler) {
+    public ContentChannel handleRequest(Request request, ResponseHandler responseHandler) {
         Preconditions.checkArgument(request instanceof HttpRequest, "Expected HttpRequest, got " + request);
         Objects.requireNonNull(responseHandler, "responseHandler");
 
@@ -77,24 +74,24 @@ class FormPostRequestHandler extends AbstractRequestHandler implements ContentCh
     }
 
     @Override
-    public void write(final ByteBuffer buf, final CompletionHandler completionHandler) {
+    public void write(ByteBuffer buf, CompletionHandler completionHandler) {
         assert buf.hasArray();
         accumulatedRequestContent.write(buf.array(), buf.arrayOffset() + buf.position(), buf.remaining());
         completionHandler.completed();
     }
 
     @Override
-    public void close(final CompletionHandler completionHandler) {
-        try (final ResourceReference ref = requestReference) {
-            final byte[] requestContentBytes = accumulatedRequestContent.toByteArray();
-            final String content = new String(requestContentBytes, contentCharset);
+    public void close(CompletionHandler completionHandler) {
+        try (ResourceReference ref = requestReference) {
+            byte[] requestContentBytes = accumulatedRequestContent.toByteArray();
+            String content = new String(requestContentBytes, contentCharset);
             completionHandler.completed();
-            final Map<String, List<String>> parameterMap = parseFormParameters(content);
+            Map<String, List<String>> parameterMap = parseFormParameters(content);
             mergeParameters(parameterMap, request.parameters());
-            final ContentChannel contentChannel = delegateHandler.handleRequest(request, responseHandler);
+            ContentChannel contentChannel = delegateHandler.handleRequest(request, responseHandler);
             if (contentChannel != null) {
                 if (!removeBody) {
-                    final ByteBuffer byteBuffer = ByteBuffer.wrap(requestContentBytes);
+                    ByteBuffer byteBuffer = ByteBuffer.wrap(requestContentBytes);
                     contentChannel.write(byteBuffer, NOOP_COMPLETION_HANDLER);
                 }
                 contentChannel.close(NOOP_COMPLETION_HANDLER);
@@ -109,14 +106,10 @@ class FormPostRequestHandler extends AbstractRequestHandler implements ContentCh
      * @return a valid Charset for the charset name (never returns null)
      * @throws RequestException if the charset name is invalid or unsupported
      */
-    private static Charset getCharsetByName(final String charsetName) throws RequestException {
+    private static Charset getCharsetByName(String charsetName) throws RequestException {
         try {
-            final Charset charset = Charset.forName(charsetName);
-            if (charset == null) {
-                throw new RequestException(UNSUPPORTED_MEDIA_TYPE, "Unsupported charset " + charsetName);
-            }
-            return charset;
-        } catch (final IllegalCharsetNameException |UnsupportedCharsetException e) {
+            return Charset.forName(charsetName);
+        } catch (IllegalCharsetNameException | UnsupportedCharsetException e) {
             throw new RequestException(UNSUPPORTED_MEDIA_TYPE, "Unsupported charset " + charsetName, e);
         }
     }
@@ -127,17 +120,17 @@ class FormPostRequestHandler extends AbstractRequestHandler implements ContentCh
      * @param formContent raw form content data (body)
      * @return map of decoded parameters
      */
-    private static Map<String, List<String>> parseFormParameters(final String formContent) {
+    private static Map<String, List<String>> parseFormParameters(String formContent) {
         if (formContent.isEmpty()) {
             return Collections.emptyMap();
         }
 
-        final Map<String, List<String>> parameterMap = new HashMap<>();
-        final String[] params = formContent.split("&");
-        for (final String param : params) {
-            final String[] parts = param.split("=");
-            final String paramName = urlDecode(parts[0]);
-            final String paramValue = parts.length > 1 ? urlDecode(parts[1]) : "";
+        Map<String, List<String>> parameterMap = new HashMap<>();
+        String[] params = formContent.split("&");
+        for (String param : params) {
+            String[] parts = param.split("=");
+            String paramName = urlDecode(parts[0]);
+            String paramValue = parts.length > 1 ? urlDecode(parts[1]) : "";
             List<String> currentValues = parameterMap.get(paramName);
             if (currentValues == null) {
                 currentValues = new LinkedList<>();
@@ -159,7 +152,7 @@ class FormPostRequestHandler extends AbstractRequestHandler implements ContentCh
             // Regardless of the charset used to transfer the request body,
             // all percent-escaping of non-ascii characters should use UTF-8 code points.
             return URLDecoder.decode(encoded, StandardCharsets.UTF_8.name());
-        } catch (final UnsupportedEncodingException e) {
+        } catch (UnsupportedEncodingException e) {
             // Unfortunately, there is no URLDecoder.decode() method that takes a Charset, so we have to deal
             // with this exception.
             throw new IllegalStateException("Whoa, JVM doesn't support UTF-8 today.", e);
@@ -172,11 +165,9 @@ class FormPostRequestHandler extends AbstractRequestHandler implements ContentCh
      * @param source containing the parameters to copy into the destination
      * @param destination receiver of parameters, possibly already containing data
      */
-    private static void mergeParameters(
-            final Map<String,List<String>> source,
-            final Map<String,List<String>> destination) {
+    private static void mergeParameters(Map<String,List<String>> source, Map<String,List<String>> destination) {
         for (Map.Entry<String, List<String>> entry : source.entrySet()) {
-            final List<String> destinationValues = destination.get(entry.getKey());
+            List<String> destinationValues = destination.get(entry.getKey());
             if (destinationValues != null) {
                 destinationValues.addAll(entry.getValue());
             } else {
@@ -189,4 +180,5 @@ class FormPostRequestHandler extends AbstractRequestHandler implements ContentCh
     public RequestHandler getDelegate() {
         return delegateHandler;
     }
+
 }
diff --git a/container-core/src/main/java/com/yahoo/processing/handler/AbstractProcessingHandler.java b/container-core/src/main/java/com/yahoo/processing/handler/AbstractProcessingHandler.java
index 2c15c994bb7..f4db1c5085a 100644
--- a/container-core/src/main/java/com/yahoo/processing/handler/AbstractProcessingHandler.java
+++ b/container-core/src/main/java/com/yahoo/processing/handler/AbstractProcessingHandler.java
@@ -187,7 +187,7 @@ public abstract class AbstractProcessingHandler<COMPONENT extends Processor> ext
     private void populate(String prefixName,Map<String,?> parameters,Properties properties) {
         CompoundName prefix = new CompoundName(prefixName);
         for (Map.Entry<String,?> entry : parameters.entrySet())
-            properties.set(prefix.append(entry.getKey()),entry.getValue());
+            properties.set(prefix.append(entry.getKey()), entry.getValue());
     }
 
     private static class FreezeListener implements Runnable, ResponseReceiver {