Netmash.Extensions.Caching refactoring

src/extensions/caching/Netmash.Extensions.Caching/Extensions/DistributedCacheExtensions.cs

@@ -3,14 +3,14 @@ using Newtonsoft.Json;
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace Netmash.Extensions.Caching
+namespace Netmash.Extensions.Caching.Extensions
 {
-    internal static class DistributedCachingExtensions
+    internal static class IDistributedCacheExtensions
     {
         public static async Task SetAsync<T>(this IDistributedCache distributedCache, string key, T value, DistributedCacheEntryOptions options, CancellationToken token = default) where T : class
         {
-            var v = JsonConvert.SerializeObject(value);
+            var valueString = JsonConvert.SerializeObject(value);
-            await distributedCache.SetStringAsync(key, v, options, token);
+            await distributedCache.SetStringAsync(key, valueString, options, token);
         }
 
         public static async Task<T> GetAsync<T>(this IDistributedCache distributedCache, string key, CancellationToken token = default) where T : class

src/extensions/caching/Netmash.Extensions.Caching/Services/CacheService.cs

@@ -1,7 +1,7 @@
 using Microsoft.Extensions.Caching.Distributed;
+using Netmash.Extensions.Caching.Extensions;
 using System;
 using System.Collections.Concurrent;
-using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 
@@ -10,7 +10,7 @@ namespace Netmash.Extensions.Caching.Services
     internal class CacheService : ICacheService
     {
         private readonly IDistributedCache _cache;
-        private static readonly ConcurrentDictionary<string, string> _keys = new ConcurrentDictionary<string, string>();
+        private static readonly ConcurrentBag<string> _keys = new();
 
         const int expirationTimeFromNow = 24;
 
@@ -19,27 +19,24 @@ namespace Netmash.Extensions.Caching.Services
             _cache = cache;
         }
 
-        public async Task<T> GetAsync<T>(string key, CancellationToken token = default(CancellationToken)) where T : class
+        public async Task<T> GetAsync<T>(string key, CancellationToken token = default) where T : class
         {
             var result = await _cache.GetAsync<T>(key, token);
             return result;
         }
 
-        public async Task SetApplicationDataAsync<T>(string key, T value, CancellationToken token = default(CancellationToken)) where T : class
+        public async Task SetAsync<T>(string key, T value, CancellationToken token = default) where T : class
         {
-            _keys.TryAdd(key, string.Empty);
+            _keys.Add(key);
-            await _cache.SetAsync<T>(key, value, new DistributedCacheEntryOptions() { AbsoluteExpirationRelativeToNow = TimeSpan.FromHours(expirationTimeFromNow) }, token);
+            await _cache.SetAsync(key, value, new DistributedCacheEntryOptions() { AbsoluteExpirationRelativeToNow = TimeSpan.FromHours(expirationTimeFromNow) }, token);
         }
 
         public void Reset()
         {
             lock (_keys)
             {
-                var list = _keys.Keys.ToList();
+                foreach (var key in _keys)
-                foreach (var s in list)
+                    _cache.Remove(key);
-                {
-                    _cache.Remove(s);
-                }
                 _keys.Clear();
             }
         }

src/extensions/caching/Netmash.Extensions.Caching/Services/ICacheService.cs

@@ -6,7 +6,7 @@ namespace Netmash.Extensions.Caching.Services
     public interface ICacheService
     {
         Task<T> GetAsync<T>(string key, CancellationToken token = default) where T : class;
-        Task SetApplicationDataAsync<T>(string key, T value, CancellationToken token = default) where T : class;
+        Task SetAsync<T>(string key, T value, CancellationToken token = default) where T : class;
         void Reset();
     }
 }