diff --git a/ethereum/api/src/main/java/org/hyperledger/besu/ethereum/api/jsonrpc/authentication/DefaultAuthenticationService.java b/ethereum/api/src/main/java/org/hyperledger/besu/ethereum/api/jsonrpc/authentication/DefaultAuthenticationService.java index 4cdc96e14af..96a1a2d023f 100644 --- a/ethereum/api/src/main/java/org/hyperledger/besu/ethereum/api/jsonrpc/authentication/DefaultAuthenticationService.java +++ b/ethereum/api/src/main/java/org/hyperledger/besu/ethereum/api/jsonrpc/authentication/DefaultAuthenticationService.java @@ -33,6 +33,9 @@ import io.vertx.ext.auth.JWTOptions; import io.vertx.ext.auth.User; import io.vertx.ext.auth.authentication.AuthenticationProvider; +import io.vertx.ext.auth.authentication.Credentials; +import io.vertx.ext.auth.authentication.TokenCredentials; +import io.vertx.ext.auth.authentication.UsernamePasswordCredentials; import io.vertx.ext.auth.jwt.JWTAuth; import io.vertx.ext.auth.jwt.JWTAuthOptions; import io.vertx.ext.web.RoutingContext; @@ -166,7 +169,7 @@ public void handleLogin(final RoutingContext routingContext) { private void login( final RoutingContext routingContext, final AuthenticationProvider credentialAuthProvider) { - final JsonObject requestBody = routingContext.getBodyAsJson(); + final JsonObject requestBody = routingContext.body().asJsonObject(); if (requestBody == null) { routingContext @@ -181,8 +184,10 @@ private void login( final JsonObject authParams = new JsonObject(); authParams.put(USERNAME, requestBody.getValue(USERNAME)); authParams.put("password", requestBody.getValue("password")); + final Credentials credentials = new UsernamePasswordCredentials(authParams); + credentialAuthProvider.authenticate( - authParams, + credentials, r -> { if (r.failed()) { routingContext @@ -227,7 +232,7 @@ public void authenticate(final String token, final Handler> handl try { getJwtAuthProvider() .authenticate( - new JsonObject().put("token", token), + new TokenCredentials(new JsonObject().put("token", token)), r -> { if (r.succeeded()) { final Optional user = Optional.ofNullable(r.result());