Merge pull request #1889 from eclipse-ditto/bugfix/fix-wrong-cache-in…

…validation-search-policy fix wrongly done invalidation of non-existing cached policy entry in search
eclipse-ditto · Feb 2, 2024 · 023f931 · 023f931
2 parents 8077e73 + ce54bb3
commit 023f931
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: <{}>",