Logging

atlanhq · Jan 25, 2024 · 1f682eb · 1f682eb
1 parent eb12487
commit 1f682eb
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/repository/src/main/java/org/apache/atlas/authorizer/store/PoliciesStore.java b/repository/src/main/java/org/apache/atlas/authorizer/store/PoliciesStore.java
@@ -85,11 +85,12 @@ public static List<RangerPolicy> getRelevantPolicies(String persona, String purp
             policies = getAbacPolicies();
         }
 
-
+        List<RangerPolicy> filteredPolicies = null;
         if (CollectionUtils.isNotEmpty(policies)) {
-            policies = getFilteredPoliciesForQualifiedName(policies, policyQualifiedNamePrefix);
-            policies = getFilteredPoliciesForActions(policies, actions, policyType);
-            LOG.info("getFilteredPoliciesForActions {}", policies.stream().map(x -> x.getGuid()).collect(Collectors.toList()));
+            filteredPolicies = new ArrayList<>(policies);
+            filteredPolicies = getFilteredPoliciesForQualifiedName(filteredPolicies, policyQualifiedNamePrefix);
+            filteredPolicies = getFilteredPoliciesForActions(filteredPolicies, actions, policyType);
+            LOG.info("getFilteredPoliciesForActions {}", filteredPolicies.stream().map(x -> x.getGuid()).collect(Collectors.toList()));
 
             if (!ignoreUser) {
                 String user = AuthorizerCommon.getCurrentUserName();
@@ -102,14 +103,16 @@ public static List<RangerPolicy> getRelevantPolicies(String persona, String purp
                 List<String> roles = UsersStore.getRolesForUser(user, allRoles);
                 roles.addAll(UsersStore.getNestedRolesForUser(roles, allRoles));
 
-                policies = getFilteredPoliciesForUser(policies, user, groups, roles, policyType);
-                LOG.info("getFilteredPoliciesForUser {}", policies.stream().map(x -> x.getGuid()).collect(Collectors.toList()));
+                filteredPolicies = getFilteredPoliciesForUser(filteredPolicies, user, groups, roles, policyType);
+                LOG.info("getFilteredPoliciesForUser {}", filteredPolicies.stream().map(x -> x.getGuid()).collect(Collectors.toList()));
             }
+        } else {
+            filteredPolicies = new ArrayList<>(0);
         }
 
         RequestContext.get().endMetricRecord(recorder);
-        LOG.info("final filtered policies {}: {}", serviceName, policies.size());
-        return policies;
+        LOG.info("final filtered policies {}: {}", serviceName, filteredPolicies.size());
+        return filteredPolicies;
     }
 
     static List<RangerPolicy> getFilteredPoliciesForQualifiedName(List<RangerPolicy> policies, String qualifiedNamePrefix) {