Aggiunti metodi per utilizzo cache tramite REDIS

Author: AngeloDotNet

src/NET6CustomLibrary/GlobalUsings.cs

@@ -19,6 +19,7 @@
 global using Microsoft.AspNetCore.Routing;
 global using Microsoft.Data.SqlClient;
 global using Microsoft.EntityFrameworkCore;
+global using Microsoft.Extensions.Caching.Distributed;
 global using Microsoft.Extensions.Configuration;
 global using Microsoft.Extensions.DependencyInjection;
 global using Microsoft.Extensions.Diagnostics.HealthChecks;
@@ -42,8 +43,9 @@
 global using NET6CustomLibrary.RabbitMQ.Abstractions;
 global using NET6CustomLibrary.Serilog.Models;
 global using NET6CustomLibrary.Serilog.Services;
+global using Newtonsoft.Json;
 global using Npgsql;
 global using RabbitMQ.Client;
 global using RabbitMQ.Client.Events;
 global using Serilog;
-global using Swashbuckle.AspNetCore.SwaggerGen;
+global using Swashbuckle.AspNetCore.SwaggerGen;

src/NET6CustomLibrary/RedisCache/CacheService.cs

@@ -0,0 +1,54 @@
+namespace NET6CustomLibrary.RedisCache;
+
+public class CacheService : ICacheService
+{
+    private readonly IDistributedCache _cache;
+
+    public CacheService(IDistributedCache cache)
+    {
+        _cache = cache;
+    }
+
+    /// <summary>
+    /// Get the values from the cache
+    /// </summary>
+    /// <typeparam name="T"></typeparam>
+    /// <param name="key"></param>
+    /// <returns></returns>
+    public T Get<T>(string key)
+    {
+        var value = _cache.GetString(key);
+
+        if (value != null)
+        {
+            return JsonConvert.DeserializeObject<T>(value);
+        }
+
+        return default;
+    }
+
+    /// <summary>
+    /// Set the values in the cache
+    /// </summary>
+    /// <typeparam name="T"></typeparam>
+    /// <param name="key"></param>
+    /// <param name="value"></param>
+    /// <param name="absoluteExpireTime"></param>
+    /// <param name="slidingExpireTime"></param>
+    /// <returns></returns>
+    public T Set<T>(string key, T value, TimeSpan? absoluteExpireTime = null, TimeSpan? slidingExpireTime = null)
+    {
+        var options = new DistributedCacheEntryOptions
+        {
+            // Imposta l'ora in cui la cache scadrà a partire dall'ora di inserimento (che rappresenta l'adesso)
+            AbsoluteExpirationRelativeToNow = absoluteExpireTime,
+
+            // Tempo fino al quale la voce della cache è valida, prima del quale se si verifica un hit il tempo deve essere esteso ulteriormente.
+            SlidingExpiration = slidingExpireTime
+        };
+
+        _cache.SetString(key, JsonConvert.SerializeObject(value), options);
+
+        return value;
+    }
+}

src/NET6CustomLibrary/RedisCache/ICacheService.cs

@@ -0,0 +1,7 @@
+namespace NET6CustomLibrary.RedisCache;
+
+public interface ICacheService
+{
+    T Get<T>(string key);
+    T Set<T>(string key, T value, TimeSpan? absoluteExpireTime = null, TimeSpan? slidingExpireTime = null);
+}