diff --git a/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/oidc/TokenVerifierImpl.java b/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/oidc/TokenVerifierImpl.java index 0346be1ae6..d490128f9e 100644 --- a/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/oidc/TokenVerifierImpl.java +++ b/data-plane/core/src/main/java/dev/knative/eventing/kafka/broker/core/oidc/TokenVerifierImpl.java @@ -62,11 +62,11 @@ public Future verify(String token, String expectedAudience) { public Future verify(final HttpServerRequest request, String expectedAudience) { String authHeader = request.getHeader("Authorization"); if (authHeader == null || authHeader.isEmpty()) { - return Future.failedFuture("Request didn't contain Authorization header"); // change to exception + return Future.failedFuture("Request didn't contain Authorization header"); } if (!authHeader.startsWith("Bearer ") && authHeader.length() <= "Bearer ".length()) { - return Future.failedFuture("Authorization header didn't contain Bearer token"); // change to exception + return Future.failedFuture("Authorization header didn't contain Bearer token"); } String token = authHeader.substring("Bearer ".length()); diff --git a/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/handler/AuthenticationHandlerTest.java b/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/handler/AuthenticationHandlerTest.java index 0d781106f3..494f9b3814 100644 --- a/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/handler/AuthenticationHandlerTest.java +++ b/data-plane/receiver/src/test/java/dev/knative/eventing/kafka/broker/receiver/impl/handler/AuthenticationHandlerTest.java @@ -82,7 +82,7 @@ public String getAudience() { } @Test - public void shouldContinueWithRequestWhenJWTSucceedsFails() { + public void shouldContinueWithRequestWhenJWTSucceeds() { final HttpServerRequest request = mock(HttpServerRequest.class); final var next = mock(Handler.class); // mockHandler(request);