Updated RemoveByPrefix and added tests

FoundatioFx · Sep 27, 2024 · 64e953f · 64e953f
1 parent 0541a55
commit 64e953f
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 1 deletion.
diff --git a/src/Foundatio.Redis/Cache/RedisCacheClient.cs b/src/Foundatio.Redis/Cache/RedisCacheClient.cs
@@ -101,7 +101,8 @@ public async Task<int> RemoveAllAsync(IEnumerable<string> keys = null)
     public async Task<int> RemoveByPrefixAsync(string prefix)
     {
         const int chunkSize = 2500;
-        string regex = $"{prefix}*";
+        string normalizedPrefix = String.IsNullOrWhiteSpace(prefix) ? "*" : prefix.Trim();
+        string regex = normalizedPrefix.Contains("*") ? normalizedPrefix : $"{normalizedPrefix}*";
 
         int total = 0;
         int index = 0;

diff --git a/tests/Foundatio.Redis.Tests/Caching/RedisCacheClientTests.cs b/tests/Foundatio.Redis.Tests/Caching/RedisCacheClientTests.cs
@@ -90,6 +90,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.Redis.Tests/Caching/RedisHybridCacheClientTests.cs b/tests/Foundatio.Redis.Tests/Caching/RedisHybridCacheClientTests.cs
@@ -50,6 +50,12 @@ public override Task CanRemoveByPrefixAsync()
         return base.CanRemoveByPrefixAsync();
     }
 
+    [Fact]
+    public override Task CanRemoveByPrefixWithScopedCachesAsync()
+    {
+        return base.CanRemoveByPrefixWithScopedCachesAsync();
+    }
+
     [Theory]
     [InlineData(50)]
     [InlineData(500)]