commit 72240aaaa2db19d1782154ba89389bb5243ad366
author Benoit Tellier <btellier@linagora.com> Fri May 07 18:39:37 2021 +0700
committer Tellier Benoit <btellier@linagora.com> Fri May 14 13:42:25 2021 +0700
tree 96f35af01a21bd519b1b5e4399c3b183e4bf54f4
parent 2bc8a96582ef1447dd630fafc4fa6b09007c7e82

[REFACTORING] Wrap blocking calls in JWTAuthenticationStrategy

It was forcing to schedule the whole chain on an elastic scheduler...

server/protocols/jmap/src/main/java/org/apache/james/jmap/jwt/JWTAuthenticationStrategy.java

diff --git a/server/protocols/jmap/src/main/java/org/apache/james/jmap/jwt/JWTAuthenticationStrategy.java b/server/protocols/jmap/src/main/java/org/apache/james/jmap/jwt/JWTAuthenticationStrategy.java
index 4314c31..55352af 100644
--- a/server/protocols/jmap/src/main/java/org/apache/james/jmap/jwt/JWTAuthenticationStrategy.java
+++ b/server/protocols/jmap/src/main/java/org/apache/james/jmap/jwt/JWTAuthenticationStrategy.java
@@ -36,6 +36,7 @@
 import com.google.common.collect.ImmutableMap;
 
 import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
 import reactor.netty.http.server.HttpServerRequest;
 
 public class JWTAuthenticationStrategy implements AuthenticationStrategy {
@@ -61,7 +62,7 @@
         return Mono.fromCallable(() -> authHeaders(httpRequest))
             .filter(header -> header.startsWith(AUTHORIZATION_HEADER_PREFIX))
             .map(header -> header.substring(AUTHORIZATION_HEADER_PREFIX.length()))
-            .map(userJWTToken -> {
+            .flatMap(userJWTToken -> Mono.fromCallable(() -> {
                 if (!tokenManager.verify(userJWTToken)) {
                     throw new UnauthorizedException("Failed Jwt verification");
                 }
@@ -74,7 +75,7 @@
                 }
 
                 return username;
-            })
+            }).subscribeOn(Schedulers.elastic()))
             .map(mailboxManager::createSystemSession);
     }