[Cache]: Added GetAllExpirationsAsync and SetAllExpirationsAsync. Also refactored tests and improved test coverage.

samples/Foundatio.SampleJobClient/Foundatio.SampleJobClient.csproj

@@ -8,7 +8,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Foundatio.Xunit" Version="12.0.0" />
+    <PackageReference Include="Foundatio.Xunit" Version="12.0.1-alpha.0.22" />
   </ItemGroup>
 
   <ItemGroup>

src/Foundatio.Redis/Cache/RedisHybridCacheClientOptions.cs

@@ -11,7 +11,6 @@ public class RedisHybridCacheClientOptions : RedisCacheClientOptions
 public class RedisHybridCacheClientOptionsBuilder :
     SharedOptionsBuilder<RedisHybridCacheClientOptions, RedisHybridCacheClientOptionsBuilder>
 {
-
     public RedisHybridCacheClientOptionsBuilder ConnectionMultiplexer(IConnectionMultiplexer connectionMultiplexer)
     {
         Target.ConnectionMultiplexer = connectionMultiplexer;

src/Foundatio.Redis/Extensions/EnumerableExtensions.cs

@@ -8,41 +8,6 @@ namespace Foundatio.Redis.Extensions;
 
 internal static class EnumerableExtensions
 {
-    public static IEnumerable<T[]> Batch<T>(
-        this IEnumerable<T> source,
-        int batchSize)
-    {
-        if (source == null) throw new ArgumentNullException(nameof(source));
-        if (batchSize <= 0) throw new ArgumentOutOfRangeException(nameof(batchSize));
-
-        using var e = source.GetEnumerator();
-        while (true)
-        {
-            // allocate one buffer for this batch
-            var buffer = new T[batchSize];
-            int count = 0;
-
-            while (count < batchSize && e.MoveNext())
-                buffer[count++] = e.Current;
-
-            if (count == 0)
-                yield break;
-
-            if (count == batchSize)
-            {
-                yield return buffer;
-            }
-            else
-            {
-                // final partial batch: copy to a right-sized array
-                var tail = new T[count];
-                Array.Copy(buffer, tail, count);
-                yield return tail;
-                yield break;
-            }
-        }
-    }
-
     public static async IAsyncEnumerable<T[]> BatchAsync<T>(
         this IAsyncEnumerable<T> source,
         int batchSize,

src/Foundatio.Redis/Extensions/TypeExtensions.cs

@@ -1,4 +1,4 @@
-using System;
+using System;
 using Foundatio.Utility;
 
 namespace Foundatio.Extensions;
@@ -42,7 +42,6 @@ public static bool IsNumeric(this Type type)
         return false;
     }
 
-
     public static bool IsNullableNumeric(this Type type)
     {
         if (type.IsArray)

src/Foundatio.Redis/Foundatio.Redis.csproj

@@ -1,10 +1,10 @@
 <Project Sdk="Microsoft.NET.Sdk">
   <Import Project="..\..\build\common.props" />
   <ItemGroup>
-    <PackageReference Include="Foundatio" Version="12.0.0" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
+    <PackageReference Include="Foundatio" Version="12.0.1-alpha.0.22" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
     <ProjectReference Include="..\..\..\Foundatio\src\Foundatio\Foundatio.csproj" Condition="'$(ReferenceFoundatioSource)' == 'true'" />
 
-    <PackageReference Include="StackExchange.Redis" Version="2.9.32" />
+    <PackageReference Include="StackExchange.Redis" Version="2.10.1" />
   </ItemGroup>
   <ItemGroup>
     <EmbeddedResource Include="Scripts\*.lua" />

src/Foundatio.Redis/Scripts/GetAllExpiration.lua

@@ -0,0 +1,15 @@
+-- Get expiration times for multiple keys
+-- KEYS: All keys to check expiration for
+-- Returns: Array of TTL values in milliseconds (in same order as KEYS)
+--          Returns -2 for non-existent keys
+--          Returns -1 for keys without expiration
+--          Returns positive number for keys with expiration
+
+local result = {}
+
+for i = 1, #KEYS do
+    local ttl = redis.call('pttl', KEYS[i])
+    table.insert(result, ttl)
+end
+
+return result

src/Foundatio.Redis/Scripts/SetAllExpiration.lua

@@ -0,0 +1,17 @@
+-- Set expiration times for multiple keys
+-- KEYS: All keys to set expiration for
+-- ARGV: TTL values in milliseconds corresponding to each key in KEYS
+--       Use -1 or 0 to remove expiration (persist)
+--       Positive values set the expiration
+
+for i = 1, #KEYS do
+    local ttl = tonumber(ARGV[i])
+
+    if ttl == nil or ttl <= 0 then
+        redis.call('persist', KEYS[i])
+    else
+        redis.call('pexpire', KEYS[i], math.ceil(ttl))
+    end
+end
+
+return true

tests/Directory.Build.props

@@ -9,9 +9,9 @@
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.0.0" />
     <PackageReference Include="xunit" Version="2.9.3" />
     <PackageReference Include="xunit.runner.visualstudio" Version="3.1.5" />
-    <PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" PrivateAssets="All" />
+    <PackageReference Include="GitHubActionsTestLogger" Version="3.0.1" PrivateAssets="All" />
 
-    <PackageReference Include="Foundatio.TestHarness" Version="12.0.0" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
+    <PackageReference Include="Foundatio.TestHarness" Version="12.0.1-alpha.0.22" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
     <ProjectReference Include="..\..\..\Foundatio\src\Foundatio.TestHarness\Foundatio.TestHarness.csproj" Condition="'$(ReferenceFoundatioSource)' == 'true'" />
   </ItemGroup>
 </Project>

tests/Foundatio.Benchmarks/Foundatio.Benchmarks.csproj

@@ -6,6 +6,6 @@
     <ProjectReference Include="..\..\src\Foundatio.Redis\Foundatio.Redis.csproj" />
   </ItemGroup>
   <ItemGroup>
-    <PackageReference Include="BenchmarkDotNet" Version="0.15.4" />
+    <PackageReference Include="BenchmarkDotNet" Version="0.15.6" />
   </ItemGroup>
 </Project>