This is an automated email from the ASF dual-hosted git repository. adutra pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/polaris.git
The following commit(s) were added to refs/heads/main by this push: new ca99c53b9 Remove CallContext.getAuthenticatedPrincipal() (#1400) ca99c53b9 is described below commit ca99c53b9c5be9022b3f4960b0d998a0cc9a4b84 Author: Alexandre Dutra <adu...@users.noreply.github.com> AuthorDate: Fri Apr 18 22:17:30 2025 +0200 Remove CallContext.getAuthenticatedPrincipal() (#1400) --- .../main/java/org/apache/polaris/core/context/CallContext.java | 9 --------- .../apache/polaris/service/auth/BasePolarisAuthenticator.java | 2 -- 2 files changed, 11 deletions(-) diff --git a/polaris-core/src/main/java/org/apache/polaris/core/context/CallContext.java b/polaris-core/src/main/java/org/apache/polaris/core/context/CallContext.java index 71c457720..6cd56bc30 100644 --- a/polaris-core/src/main/java/org/apache/polaris/core/context/CallContext.java +++ b/polaris-core/src/main/java/org/apache/polaris/core/context/CallContext.java @@ -26,7 +26,6 @@ import java.util.stream.Collectors; import org.apache.iceberg.io.CloseableGroup; import org.apache.polaris.core.PolarisCallContext; import org.apache.polaris.core.PolarisDiagnostics; -import org.apache.polaris.core.auth.AuthenticatedPolarisPrincipal; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -45,9 +44,6 @@ public interface CallContext extends AutoCloseable { // created, scoped to the current call context. String REQUEST_PATH_CATALOG_INSTANCE_KEY = "REQUEST_PATH_CATALOG_INSTANCE"; - // Authenticator filters should populate this field alongside resolving a SecurityContext. - // Value type: AuthenticatedPolarisPrincipal - String AUTHENTICATED_PRINCIPAL = "AUTHENTICATED_PRINCIPAL"; String CLOSEABLES = "closeables"; static CallContext setCurrentContext(CallContext context) { @@ -63,11 +59,6 @@ public interface CallContext extends AutoCloseable { return CURRENT_CONTEXT.get().getPolarisCallContext().getDiagServices(); } - static AuthenticatedPolarisPrincipal getAuthenticatedPrincipal() { - return (AuthenticatedPolarisPrincipal) - CallContext.getCurrentContext().contextVariables().get(CallContext.AUTHENTICATED_PRINCIPAL); - } - static void unsetCurrentContext() { CURRENT_CONTEXT.remove(); } diff --git a/service/common/src/main/java/org/apache/polaris/service/auth/BasePolarisAuthenticator.java b/service/common/src/main/java/org/apache/polaris/service/auth/BasePolarisAuthenticator.java index 5c284a934..ad2f9da4c 100644 --- a/service/common/src/main/java/org/apache/polaris/service/auth/BasePolarisAuthenticator.java +++ b/service/common/src/main/java/org/apache/polaris/service/auth/BasePolarisAuthenticator.java @@ -111,8 +111,6 @@ public abstract class BasePolarisAuthenticator AuthenticatedPolarisPrincipal authenticatedPrincipal = new AuthenticatedPolarisPrincipal(new PrincipalEntity(principal), activatedPrincipalRoles); - LOGGER.debug("Populating authenticatedPrincipal into CallContext: {}", authenticatedPrincipal); - callContext.contextVariables().put(CallContext.AUTHENTICATED_PRINCIPAL, authenticatedPrincipal); return Optional.of(authenticatedPrincipal); } }