Add Polly to Circuit Breaker when we want to add a short code to redis.

Author: mohammadKarimi

src/SwiftLink.Infrastructure/CacheProvider/RedisCacheProvider.cs

@@ -1,12 +1,21 @@
-using Microsoft.Extensions.Caching.Distributed;
+using Microsoft.EntityFrameworkCore.Metadata;
+using Microsoft.EntityFrameworkCore.Metadata.Internal;
+using Microsoft.Extensions.Caching.Distributed;
 using Microsoft.Extensions.Options;
+using Polly;
+using Polly.CircuitBreaker;
+using StackExchange.Redis;
 using System.Text;
 
 namespace SwiftLink.Infrastructure.CacheProvider;
 
 public class RedisCacheService(IDistributedCache cache, IOptions<AppSettings> options)
     : ICacheProvider
 {
+
+    private readonly AsyncCircuitBreakerPolicy<bool> circuitBreakerPolicy = Policy<bool>.HandleResult(false)
+                                                                                        .CircuitBreakerAsync(2, TimeSpan.FromSeconds(30));
+
     private readonly IDistributedCache _cache = cache;
     private readonly AppSettings _options = options.Value;
 
@@ -18,25 +27,37 @@ public async Task<bool> Set(string key, string value)
 
     public async Task<bool> Set(string key, string value, DateTime expirationDate)
     {
-        try
-        {
-            DistributedCacheEntryOptions cacheEntryOptions = new()
+        if (circuitBreakerPolicy.CircuitState is CircuitState.Open)
+            return false;
+        return await circuitBreakerPolicy.ExecuteAsync(async () =>
             {
-                SlidingExpiration = TimeSpan.FromHours(_options.Redis.SlidingExpirationHour),
-                AbsoluteExpiration = expirationDate,
-            };
+                try
+                {
+                    DistributedCacheEntryOptions cacheEntryOptions = new()
+                    {
+                        SlidingExpiration = TimeSpan.FromHours(_options.Redis.SlidingExpirationHour),
+                        AbsoluteExpiration = expirationDate,
+                    };
+                    var dataToCache = Encoding.UTF8.GetBytes(value);
+                    await _cache.SetAsync(key, dataToCache, cacheEntryOptions);
+                }
+                catch (RedisConnectionException)
+                {
+                    return false;
+                }
+                return true;
+            });
+    }
 
-            var dataToCache = Encoding.UTF8.GetBytes(value);
-            await _cache.SetAsync(key, dataToCache, cacheEntryOptions);
-            return true;
+    public async Task<string> Get(string key)
+    {
+        try
+        {
+            return await _cache.GetStringAsync(key);
         }
-        catch (Exception e)
+        catch
         {
-            //Log e
-            return false;
+            return null;
         }
     }
-
-    public async Task<string> Get(string key)
-        => await _cache.GetStringAsync(key);
-}
+}

src/SwiftLink.Infrastructure/SwiftLink.Infrastructure.csproj

@@ -14,6 +14,7 @@
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
     <PackageReference Include="Microsoft.Extensions.Caching.StackExchangeRedis" Version="8.0.0" />
+    <PackageReference Include="Polly" Version="8.2.1" />
   </ItemGroup>
 
   <ItemGroup>