chore: Update StackExchange.Redis package version to 2.10.1 across multiple projects and enhance Redis command options for better performance

nickna · nickna · commit 6ac8cc3533dc · 2025-11-20T18:53:35.000-08:00
diff --git a/Services/ConduitLLM.Http/ConduitLLM.Http.csproj b/Services/ConduitLLM.Http/ConduitLLM.Http.csproj
@@ -60,7 +60,7 @@
     <PackageReference Include="Microsoft.Extensions.Http.Polly" Version="10.0.0" />
     <PackageReference Include="Polly" Version="8.6.4" />
     <PackageReference Include="Polly.Extensions.Http" Version="3.0.0" />
-    <PackageReference Include="StackExchange.Redis" Version="2.9.32" />
+    <PackageReference Include="StackExchange.Redis" Version="2.10.1" />
   </ItemGroup>
 
 </Project>
diff --git a/Services/ConduitLLM.Http/Services/BatchOperationIdempotencyService.cs b/Services/ConduitLLM.Http/Services/BatchOperationIdempotencyService.cs
@@ -96,7 +96,7 @@ public async Task StoreOperationResultAsync(
                 var serialized = JsonSerializer.Serialize(result, _jsonOptions);
                 var expiry = ttl ?? DefaultTtl;
 
-                await db.StringSetAsync(key, serialized, expiry);
+                await db.StringSetAsync(key, serialized, expiry, false, When.Always, CommandFlags.None);
 
                 _logger.LogInformation(
                     "Stored idempotency result for token {Token} with TTL {TTL}",
diff --git a/Services/ConduitLLM.Http/Services/DistributedAlertManagementService.cs b/Services/ConduitLLM.Http/Services/DistributedAlertManagementService.cs
@@ -158,7 +158,7 @@ public async Task TriggerAlertAsync(HealthAlert alert)
             
             // Use distributed lock to prevent duplicate alerts from multiple instances
             var lockValue = Guid.NewGuid().ToString();
-            var lockAcquired = await _database.StringSetAsync(lockKey, lockValue, TimeSpan.FromMinutes(5), When.NotExists);
+            var lockAcquired = await _database.StringSetAsync(lockKey, lockValue, TimeSpan.FromMinutes(5), false, When.NotExists, CommandFlags.None);
             
             if (!lockAcquired)
             {
diff --git a/Services/ConduitLLM.Http/Services/RedisBatchOperations.cs b/Services/ConduitLLM.Http/Services/RedisBatchOperations.cs
@@ -219,7 +219,7 @@ public async Task<BatchSetResult> BatchSetAsync<T>(Dictionary<string, T> keyValu
                 foreach (var kvp in keyValuePairs)
                 {
                     var serialized = JsonSerializer.Serialize(kvp.Value, _jsonOptions);
-                    setTasks.Add(batch.StringSetAsync(kvp.Key, serialized, expiry));
+                    setTasks.Add(batch.StringSetAsync(kvp.Key, serialized, expiry, false, When.Always, CommandFlags.None));
                 }
 
                 // Execute batch
diff --git a/Services/ConduitLLM.Http/Services/SignalRAcknowledgmentService.cs b/Services/ConduitLLM.Http/Services/SignalRAcknowledgmentService.cs
@@ -147,7 +147,7 @@ public async Task<PendingAcknowledgment> RegisterMessageAsync(
                 var pendingData = JsonSerializer.Serialize(pending);
                 var key = $"{_pendingAcknowledgmentsKey}:{message.MessageId}";
                 
-                var wasSet = await _redis.StringSetAsync(key, pendingData, effectiveTimeout, When.NotExists);
+                var wasSet = await _redis.StringSetAsync(key, pendingData, effectiveTimeout, false, When.NotExists, CommandFlags.None);
                 if (!wasSet)
                 {
                     _logger.LogWarning("Message {MessageId} already registered for acknowledgment", message.MessageId);
diff --git a/Shared/ConduitLLM.Security/ConduitLLM.Security.csproj b/Shared/ConduitLLM.Security/ConduitLLM.Security.csproj
@@ -14,7 +14,7 @@
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="10.0.0" />
     <PackageReference Include="Microsoft.Extensions.Options" Version="10.0.0" />
     <PackageReference Include="MassTransit" Version="8.5.5" />
-    <PackageReference Include="StackExchange.Redis" Version="2.9.32" />
+    <PackageReference Include="StackExchange.Redis" Version="2.10.1" />
   </ItemGroup>
 
   <ItemGroup>

Original file line number	Diff line number	Diff line change
`@@ -158,7 +158,7 @@ public async Task TriggerAlertAsync(HealthAlert alert)`
`158`	`158`
`159`	`159`	`// Use distributed lock to prevent duplicate alerts from multiple instances`
`160`	`160`	`var lockValue = Guid.NewGuid().ToString();`
`161`		`- var lockAcquired = await _database.StringSetAsync(lockKey, lockValue, TimeSpan.FromMinutes(5), When.NotExists);`
	`161`	`+ var lockAcquired = await _database.StringSetAsync(lockKey, lockValue, TimeSpan.FromMinutes(5), false, When.NotExists, CommandFlags.None);`
`162`	`162`
`163`	`163`	`if (!lockAcquired)`
`164`	`164`	`{`
Original file line number	Diff line number	Diff line change
`@@ -219,7 +219,7 @@ public async Task<BatchSetResult> BatchSetAsync<T>(Dictionary<string, T> keyValu`
`219`	`219`	`foreach (var kvp in keyValuePairs)`
`220`	`220`	`{`
`221`	`221`	`var serialized = JsonSerializer.Serialize(kvp.Value, _jsonOptions);`
`222`		`- setTasks.Add(batch.StringSetAsync(kvp.Key, serialized, expiry));`
	`222`	`+ setTasks.Add(batch.StringSetAsync(kvp.Key, serialized, expiry, false, When.Always, CommandFlags.None));`
`223`	`223`	`}`
`224`	`224`
`225`	`225`	`// Execute batch`
Original file line number	Diff line number	Diff line change
`@@ -147,7 +147,7 @@ public async Task<PendingAcknowledgment> RegisterMessageAsync(`
`147`	`147`	`var pendingData = JsonSerializer.Serialize(pending);`
`148`	`148`	`var key = $"{_pendingAcknowledgmentsKey}:{message.MessageId}";`
`149`	`149`
`150`		`- var wasSet = await _redis.StringSetAsync(key, pendingData, effectiveTimeout, When.NotExists);`
	`150`	`+ var wasSet = await _redis.StringSetAsync(key, pendingData, effectiveTimeout, false, When.NotExists, CommandFlags.None);`
`151`	`151`	`if (!wasSet)`
`152`	`152`	`{`
`153`	`153`	`_logger.LogWarning("Message {MessageId} already registered for acknowledgment", message.MessageId);`