fix wrongly done invalidation of non-existing cached policy entry in …

…search * that could cause that e.g. a deleted imported policy which is re-added did not cause a reindexing of affected things
eclipse-ditto · Feb 2, 2024 · ce54bb3 · ce54bb3
1 parent 8077e73
commit ce54bb3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...va/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java b/...va/org/eclipse/ditto/thingsearch/service/persistence/write/streaming/EnforcementFlow.java
@@ -342,7 +342,7 @@ private Source<Entry<Pair<Policy, Set<PolicyTag>>>, NotUsed> readCachedEnforcer(
                                             .ifPresent(causingPolicyTag -> {
                                                 final boolean invalidated = policyEnforcerCache.invalidateConditionally(
                                                         new PolicyIdResolvingImports(causingPolicyTag.getEntityId(), false),
-                                                        entry -> entry.exists() &&
+                                                        entry -> !entry.exists() ||
                                                                 entry.getRevision() < causingPolicyTag.getRevision()
                                                 );
                                                 log.debug("Causing policy tag was invalidated conditionally: <{}>",