Refactoring RedisCache

Author: AngeloDotNet

src/NET6CustomLibrary/NET6CustomLibrary.csproj

@@ -48,6 +48,7 @@
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>
         <PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="6.0.2" />
+        <PackageReference Include="StackExchange.Redis" Version="2.6.111" />
         <PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="6.5.0" />
         <PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="6.5.0" />
         <PackageReference Include="System.Text.Json" Version="6.0.7" />

src/NET6CustomLibrary/RedisCache/Options/RedisOptions.cs

@@ -2,7 +2,8 @@
 
 public class RedisOptions
 {
+    public string Hostname { get; set; }
     public string InstanceName { get; set; }
-    public int AbsoluteExpireTime { get; set; }
-    public int SlidingExpireTime { get; set; }
+    public TimeSpan AbsoluteExpireTime { get; set; }
+    public TimeSpan SlidingExpireTime { get; set; }
 }

src/NET6CustomLibrary/RedisCache/Services/CacheService.cs

@@ -11,44 +11,30 @@ public CacheService(IDistributedCache cache, IOptionsMonitor<RedisOptions> redis
         this.redisOptionsMonitor = redisOptionsMonitor;
     }
 
-    /// <summary>
-    /// Get the values from the cache
-    /// </summary>
-    /// <typeparam name="T"></typeparam>
-    /// <param name="key"></param>
-    /// <returns>Return the values from the cache</returns>
-    public T GetCache<T>(string key)
+    public async Task<T> GetCacheAsync<T>(string key)
     {
-        var value = cache.GetString(key);
+        var jsonData = await cache.GetStringAsync(key);
 
-        if (value != null)
+        if (jsonData is null)
         {
-            return JsonConvert.DeserializeObject<T>(value);
+            return default;
         }
 
-        return default;
+        return System.Text.Json.JsonSerializer.Deserialize<T>(jsonData);
     }
 
-    /// <summary>
-    /// Set the values in the cache
-    /// </summary>
-    /// <typeparam name="T"></typeparam>
-    /// <param name="key"></param>
-    /// <param name="value"></param>
-    /// <returns>Return the values after set the values in the cache</returns>
-    public T SetCache<T>(string key, T value)
+    public async Task<T> SetCacheAsync<T>(string key, T value)
     {
-        var options = redisOptionsMonitor.CurrentValue;
-        var redisOptions = new DistributedCacheEntryOptions
+        var optionsCache = redisOptionsMonitor.CurrentValue;
+        var options = new DistributedCacheEntryOptions
         {
-            //Set the time the cache will expire from the time of entry (representing now)
-            AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(options.AbsoluteExpireTime),
-
-            //Time until the cache entry is valid, before which if a hit occurs the time must be extended further.
-            SlidingExpiration = TimeSpan.FromMinutes(options.SlidingExpireTime)
+            AbsoluteExpirationRelativeToNow = optionsCache.AbsoluteExpireTime,
+            SlidingExpiration = optionsCache.SlidingExpireTime
         };
 
-        cache.SetString(key, JsonConvert.SerializeObject(value), redisOptions);
+        var jsonData = System.Text.Json.JsonSerializer.Serialize(value);
+
+        await cache.SetStringAsync(key, jsonData, options);
 
         return value;
     }

src/NET6CustomLibrary/RedisCache/Services/ICacheService.cs

@@ -2,6 +2,6 @@
 
 public interface ICacheService
 {
-    T GetCache<T>(string key);
-    T SetCache<T>(string key, T value);
+    Task<T> GetCacheAsync<T>(string key);
+    Task<T> SetCacheAsync<T>(string key, T value);
 }