TokenVerifier: execute blocking calls in parallel

creydr · Mar 1, 2024 · f3dbde9 · f3dbde9
1 parent 6b14cd9
commit f3dbde9
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 15 deletions.
diff --git a/control-plane/pkg/contract/contract.pb.go b/control-plane/pkg/contract/contract.pb.go
diff --git a/...ane/core/src/main/java/dev/knative/eventing/kafka/broker/core/oidc/TokenVerifierImpl.java b/...ane/core/src/main/java/dev/knative/eventing/kafka/broker/core/oidc/TokenVerifierImpl.java
@@ -40,23 +40,25 @@ public TokenVerifierImpl(Vertx vertx, OIDCDiscoveryConfig oidcDiscoveryConfig) {
     }
 
     public Future<JwtClaims> verify(String token, String expectedAudience) {
-        return this.vertx.<JwtClaims>executeBlocking(promise -> {
-            // execute blocking, as jose .process() is blocking
+        return this.vertx.<JwtClaims>executeBlocking(
+                promise -> {
+                    // execute blocking, as jose .process() is blocking
 
-            JwtConsumer jwtConsumer = new JwtConsumerBuilder()
-                    .setVerificationKeyResolver(this.oidcDiscoveryConfig.getJwksVerificationKeyResolver())
-                    .setExpectedAudience(expectedAudience)
-                    .setExpectedIssuer(this.oidcDiscoveryConfig.getIssuer())
-                    .build();
+                    JwtConsumer jwtConsumer = new JwtConsumerBuilder()
+                            .setVerificationKeyResolver(this.oidcDiscoveryConfig.getJwksVerificationKeyResolver())
+                            .setExpectedAudience(expectedAudience)
+                            .setExpectedIssuer(this.oidcDiscoveryConfig.getIssuer())
+                            .build();
 
-            try {
-                JwtContext jwtContext = jwtConsumer.process(token);
+                    try {
+                        JwtContext jwtContext = jwtConsumer.process(token);
 
-                promise.complete(jwtContext.getJwtClaims());
-            } catch (InvalidJwtException e) {
-                promise.fail(e);
-            }
-        });
+                        promise.complete(jwtContext.getJwtClaims());
+                    } catch (InvalidJwtException e) {
+                        promise.fail(e);
+                    }
+                },
+                false);
     }
 
     public Future<JwtClaims> verify(final HttpServerRequest request, String expectedAudience) {