From 9287acf7d269410ff1d981dfab29833cdad7e3ae Mon Sep 17 00:00:00 2001
From: Polianin Nikita <nikitkapolyanin@yandex.ru>
Date: Wed, 29 May 2024 06:08:14 +0300
Subject: [PATCH] feat: add cache implementations depending on the type

---
 .../Security/DistributedCacheService.cs       | 32 +++++++++++++++++
 .../Services/Security/MemoryCacheService.cs   | 34 +++++++++++++++++++
 2 files changed, 66 insertions(+)
 create mode 100644 Endpoint/Common/Services/Security/DistributedCacheService.cs
 create mode 100644 Endpoint/Common/Services/Security/MemoryCacheService.cs

diff --git a/Endpoint/Common/Services/Security/DistributedCacheService.cs b/Endpoint/Common/Services/Security/DistributedCacheService.cs
new file mode 100644
index 0000000..fa4c116
--- /dev/null
+++ b/Endpoint/Common/Services/Security/DistributedCacheService.cs
@@ -0,0 +1,32 @@
+using Microsoft.Extensions.Caching.Distributed;
+using Mirea.Api.Security.Common.Interfaces;
+using System.Text.Json;
+using System.Threading.Tasks;
+using System.Threading;
+using System;
+
+namespace Mirea.Api.Endpoint.Common.Services.Security;
+
+public class DistributedCacheService(IDistributedCache cache) : ICacheService
+{
+    public async Task SetAsync<T>(string key, T value, TimeSpan? absoluteExpirationRelativeToNow = null, TimeSpan? slidingExpiration = null, CancellationToken cancellationToken = default)
+    {
+        var options = new DistributedCacheEntryOptions
+        {
+            AbsoluteExpirationRelativeToNow = absoluteExpirationRelativeToNow,
+            SlidingExpiration = slidingExpiration
+        };
+
+        var serializedValue = JsonSerializer.SerializeToUtf8Bytes(value);
+        await cache.SetAsync(key, serializedValue, options, cancellationToken);
+    }
+
+    public async Task<T?> GetAsync<T>(string key, CancellationToken cancellationToken = default)
+    {
+        var cachedValue = await cache.GetAsync(key, cancellationToken);
+        return cachedValue == null ? default : JsonSerializer.Deserialize<T>(cachedValue);
+    }
+
+    public Task RemoveAsync(string key, CancellationToken cancellationToken = default) =>
+        cache.RemoveAsync(key, cancellationToken);
+}
\ No newline at end of file
diff --git a/Endpoint/Common/Services/Security/MemoryCacheService.cs b/Endpoint/Common/Services/Security/MemoryCacheService.cs
new file mode 100644
index 0000000..08d0a7f
--- /dev/null
+++ b/Endpoint/Common/Services/Security/MemoryCacheService.cs
@@ -0,0 +1,34 @@
+using Microsoft.Extensions.Caching.Memory;
+using Mirea.Api.Security.Common.Interfaces;
+using System.Threading.Tasks;
+using System.Threading;
+using System;
+
+namespace Mirea.Api.Endpoint.Common.Services.Security;
+
+public class MemoryCacheService(IMemoryCache cache) : ICacheService
+{
+    public Task SetAsync<T>(string key, T value, TimeSpan? absoluteExpirationRelativeToNow = null, TimeSpan? slidingExpiration = null, CancellationToken cancellationToken = default)
+    {
+        var options = new MemoryCacheEntryOptions
+        {
+            AbsoluteExpirationRelativeToNow = absoluteExpirationRelativeToNow,
+            SlidingExpiration = slidingExpiration
+        };
+
+        cache.Set(key, value, options);
+        return Task.CompletedTask;
+    }
+
+    public Task<T?> GetAsync<T>(string key, CancellationToken cancellationToken = default)
+    {
+        cache.TryGetValue(key, out T? value);
+        return Task.FromResult(value);
+    }
+
+    public Task RemoveAsync(string key, CancellationToken cancellationToken = default)
+    {
+        cache.Remove(key);
+        return Task.CompletedTask;
+    }
+}
\ No newline at end of file