Added test to show off issue with DeleteByPrefix not respecting cache…

… scopes
FoundatioFx · Sep 27, 2024 · b2c9566 · b2c9566
1 parent 40f70a8
commit b2c9566
Show file tree

Hide file tree

Showing 4 changed files with 74 additions and 0 deletions.
diff --git a/src/Foundatio.TestHarness/Caching/CacheClientTestsBase.cs b/src/Foundatio.TestHarness/Caching/CacheClientTestsBase.cs
@@ -384,6 +384,62 @@ public virtual async Task CanRemoveByPrefixAsync()
         }
     }
 
+    public virtual async Task CanRemoveByPrefixWithScopedCachesAsync()
+    {
+        var cache = GetCacheClient();
+        if (cache == null)
+            return;
+
+        using (cache)
+        {
+            await cache.RemoveAllAsync();
+            var scopedCache1 = new ScopedCacheClient(cache, "scoped1");
+
+            const string cacheKey = "key";
+            await cache.SetAsync(cacheKey, 1);
+            await scopedCache1.SetAsync(cacheKey, 1);
+            Assert.Equal(1, (await cache.GetAsync<int>(cacheKey)).Value);
+            Assert.Equal(1, (await scopedCache1.GetAsync<int>(cacheKey)).Value);
+
+            // Remove by prefix should only remove the unscoped cache.
+            Assert.Equal(1, await cache.RemoveByPrefixAsync(cacheKey));
+            Assert.False(await cache.ExistsAsync(cacheKey));
+            Assert.True(await scopedCache1.ExistsAsync(cacheKey));
+            Assert.Equal(1, (await scopedCache1.GetAsync<int>(cacheKey)).Value);
+
+            // Add the unscoped cache value back.
+            await cache.SetAsync(cacheKey, 1);
+
+            // Remove by empty key.
+            Assert.Equal(1, await scopedCache1.RemoveByPrefixAsync(String.Empty));
+            Assert.True(await cache.ExistsAsync(cacheKey));
+            Assert.False(await scopedCache1.ExistsAsync(cacheKey));
+
+            // Add the scoped cache value back.
+            await scopedCache1.SetAsync(cacheKey, 1);
+
+            Assert.Equal(2, await cache.RemoveByPrefixAsync(String.Empty));
+            Assert.False(await cache.ExistsAsync(cacheKey));
+            Assert.False(await scopedCache1.ExistsAsync(cacheKey));
+
+            // Reset client values
+            await cache.SetAsync(cacheKey, 1);
+            await scopedCache1.SetAsync(cacheKey, 1);
+
+            // Remove by *.
+            Assert.Equal(1, await scopedCache1.RemoveByPrefixAsync("*"));
+            Assert.True(await cache.ExistsAsync(cacheKey));
+            Assert.False(await scopedCache1.ExistsAsync(cacheKey));
+
+            // Reset client values
+            await scopedCache1.SetAsync(cacheKey, 1);
+
+            Assert.Equal(2, await cache.RemoveByPrefixAsync("*"));
+            Assert.False(await cache.ExistsAsync(cacheKey));
+            Assert.False(await scopedCache1.ExistsAsync(cacheKey));
+        }
+    }
+
     public virtual async Task CanRemoveByPrefixMultipleEntriesAsync(int count)
     {
         var cache = GetCacheClient();

diff --git a/src/Foundatio.TestHarness/Caching/HybridCacheClientTests.cs b/src/Foundatio.TestHarness/Caching/HybridCacheClientTests.cs
@@ -87,6 +87,12 @@ public override Task CanRemoveByPrefixAsync()
         return base.CanRemoveByPrefixAsync();
     }
 
+    [Fact]
+    public override Task CanRemoveByPrefixWithScopedCachesAsync()
+    {
+        return base.CanRemoveByPrefixWithScopedCachesAsync();
+    }
+
     [Theory]
     [InlineData(50)]
     [InlineData(500)]

diff --git a/tests/Foundatio.Tests/Caching/InMemoryCacheClientTests.cs b/tests/Foundatio.Tests/Caching/InMemoryCacheClientTests.cs
@@ -83,6 +83,12 @@ public override Task CanRemoveByPrefixAsync()
         return base.CanRemoveByPrefixAsync();
     }
 
+    [Fact]
+    public override Task CanRemoveByPrefixWithScopedCachesAsync()
+    {
+        return base.CanRemoveByPrefixWithScopedCachesAsync();
+    }
+
     [Theory]
     [InlineData(50)]
     [InlineData(500)]

diff --git a/tests/Foundatio.Tests/Caching/InMemoryHybridCacheClientTests.cs b/tests/Foundatio.Tests/Caching/InMemoryHybridCacheClientTests.cs
@@ -40,6 +40,12 @@ public override Task CanRemoveByPrefixAsync()
         return base.CanRemoveByPrefixAsync();
     }
 
+    [Fact]
+    public override Task CanRemoveByPrefixWithScopedCachesAsync()
+    {
+        return base.CanRemoveByPrefixWithScopedCachesAsync();
+    }
+
     [Theory]
     [InlineData(50)]
     [InlineData(500)]