feat(auth): customizable group separator for header authentication

README.md

@@ -625,8 +625,9 @@ akhq:
     # Header configuration (reverse proxy)
     header-auth:
       user-header: x-akhq-user # mandatory (the header name that will contain username)
-      groups-header: x-akhq-group # optional (the header name that will contains groups separated by coma `,`)
-      users: # optional, the users list allow, if empty we only rely on `groups-header`
+      groups-header: x-akhq-group # optional (the header name that will contain groups separated by groups-header-separator)
+      groups-header-separator: , # optional (separator, defaults to ',')
+      users: # optional, the users list to allow, if empty we only rely on `groups-header`
         - username: header-user # username matching the `user-header` value
           groups: # list of group for current users
             - topic-reader
@@ -636,8 +637,9 @@ akhq:
 ```
 
 * The `user-header` is mandatory in order to map the user with `users` list or to display the user on the ui if no `users` is provided.
-* The `groups-header` is optional and can be used in order to inject a list of groups (separated by `,`) for all the users. This list will be merged with `groups` for the current users.
-* The `users` is a list of users allowed.
+* The `groups-header` is optional and can be used in order to inject a list of groups for all the users. This list will be merged with `groups` for the current users.
+* The `groups-header-separator` is optional and can be used to customize group separator used when parsing `groups-header` header, defaults to `,`.
+* The `users` is a list of allowed users.
 
 ### External roles and attributes mapping
 

application.example.yml

@@ -263,8 +263,9 @@ akhq:
     # Header configuration (reverse proxy)
     header-auth:
       user-header: x-akhq-user # mandatory (the header name that will contain username)
-      groups-header: x-akhq-group # optional (the header name that will contains groups separated by coma `,`)
-      users: # optional, the users list allow, if empty we only rely on `groups-header`
+      groups-header: x-akhq-group # optional (the header name that will contain groups separated by groups-header-separator)
+      groups-header-separator: , # optional (separator, defaults to ',')
+      users: # optional, the users list to allow, if empty we only rely on `groups-header`
         - username: header-user # username matching the `user-header` value
           groups: # list of group for current users
             - topic-reader

src/main/java/org/akhq/configs/HeaderAuth.java

@@ -1,9 +1,7 @@
 package org.akhq.configs;
 
 import io.micronaut.context.annotation.ConfigurationProperties;
-import lombok.AllArgsConstructor;
 import lombok.Data;
-import lombok.NoArgsConstructor;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -13,6 +11,7 @@
 public class HeaderAuth {
     String userHeader;
     String groupsHeader;
+    String groupsHeaderSeparator = ",";
     List<Users> users;
 
     @Data
@@ -21,4 +20,3 @@ public static class Users {
         List<String> groups = new ArrayList<>();
     }
 }
-

src/main/java/org/akhq/modules/HeaderAuthenticationFetcher.java

@@ -41,17 +41,18 @@ public class HeaderAuthenticationFetcher implements AuthenticationFetcher {
 
     @Override
     public Publisher<Authentication> fetchAuthentication(HttpRequest<?> request) {
-        Optional<String> userHeaders = request.getHeaders()
-            .get(headerAuth.getUserHeader(), String.class);
-
-        Optional<String> groupHeaders = headerAuth.getGroupsHeader() != null ?
-            request.getHeaders().get(headerAuth.getGroupsHeader(), String.class) :
+        Optional<String> userHeaders = headerAuth.getUserHeader() != null ?
+            request.getHeaders().get(headerAuth.getUserHeader(), String.class) :
             Optional.empty();
 
         if (userHeaders.isEmpty()) {
             return Publishers.empty();
         }
 
+        Optional<String> groupHeaders = headerAuth.getGroupsHeader() != null ?
+            request.getHeaders().get(headerAuth.getGroupsHeader(), String.class) :
+            Optional.empty();
+
         return Flowable
             .fromCallable(() -> {
                 List<String> strings = groupsMapper(userHeaders.get(), groupHeaders);
@@ -111,6 +112,8 @@ private List<String> groupsMapper(String user, Optional<String> groupHeaders) {
     }
 
     private Stream<String> groupsSplit(Optional<String> groupHeaders) {
-        return groupHeaders.stream().flatMap(s -> Arrays.stream(s.split(",")));
+        return groupHeaders
+            .stream()
+            .flatMap(s -> Arrays.stream(s.split(headerAuth.getGroupsHeaderSeparator())));
     }
 }