Change logs in AtlasKeycloakAuthenticationProvider

atlanhq · Nov 9, 2023 · 042c2f6 · 042c2f6
1 parent 23dc215
commit 042c2f6
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/webapp/src/main/java/org/apache/atlas/web/security/AtlasKeycloakAuthenticationProvider.java b/webapp/src/main/java/org/apache/atlas/web/security/AtlasKeycloakAuthenticationProvider.java
@@ -75,8 +75,8 @@ public Authentication authenticate(Authentication authentication) {
         authentication = new KeycloakAuthenticationToken(token.getAccount(), token.isInteractive(), grantedAuthorities);
       }
     }
-    if(authentication.getName().startsWith("service-account-apikey")) {
-      LOG.info("validating request for service-account-apikey: {}", authentication.getName().substring("service-account-".length()));
+    if(authentication.getName().startsWith("service-account")) {
+      LOG.info("Validating request for clientId: {}", authentication.getName().substring("service-account-".length()));
       try{
         KeycloakAuthenticationToken keycloakToken = (KeycloakAuthenticationToken)authentication;
         String bearerToken = keycloakToken.getAccount().getKeycloakSecurityContext().getTokenString();
@@ -96,8 +96,8 @@ public Authentication authenticate(Authentication authentication) {
 
   private void handleInvalidApiKey(Authentication authentication) {
     authentication.setAuthenticated(false);
-    LOG.info("Invalid API Key: {}", authentication.getName().substring("service-account-".length()));
-    throw new KeycloakAuthenticationException("Invalid Api Key");
+    LOG.info("Invalid clientId: {}", authentication.getName().substring("service-account-".length()));
+    throw new KeycloakAuthenticationException("Invalid ClientId");
   }
 
   @Override