fix(auth): get all values from auth header in header auth (#1277)

tchiotludo · Apr 4, 2023 · 2372776 · 2372776
1 parent cc20b74
commit 2372776
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/src/main/java/org/akhq/modules/HeaderAuthenticationFetcher.java b/src/main/java/org/akhq/modules/HeaderAuthenticationFetcher.java
@@ -19,6 +19,7 @@
 
 import java.net.InetSocketAddress;
 import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
 import java.util.Optional;
 import java.util.regex.Pattern;
@@ -86,17 +87,19 @@ public Publisher<Authentication> fetchAuthentication(HttpRequest<?> request) {
             log.debug("One or more of the IP patterns matched the host address [{}]. Continuing request processing.", hostAddress);
         }
 
-        Optional<String> groupHeaders = headerAuth.getGroupsHeader() != null ?
-            request.getHeaders().get(headerAuth.getGroupsHeader(), String.class) :
-            Optional.empty();
+        List<String> groupsHeader = headerAuth.getGroupsHeader() != null ?
+            request.getHeaders().getAll(headerAuth.getGroupsHeader()) :
+            Collections.emptyList();
 
         return Flowable
             .fromCallable(() -> {
-                List<String> groups = groupHeaders
+                List<String> groups = groupsHeader
                     .stream()
                     .flatMap(s -> Arrays.stream(s.split(headerAuth.getGroupsHeaderSeparator())))
                     .collect(Collectors.toList());
 
+                log.debug("Got groups [{}] from groupsHeader [{}] and separator [{}]", groups, groupsHeader, headerAuth.getGroupsHeaderSeparator());
+
                 ClaimRequest claim =
                     ClaimRequest.builder()
                         .providerType(ClaimProviderType.HEADER)