added cache provider moick

Author: semack

Localization.AspNetCore.EntityFramework/Extensions/ServiceCollectionExtensions.cs

@@ -1,6 +1,7 @@
 using System;
 using Localization.AspNetCore.EntityFramework.Factories;
 using Localization.AspNetCore.EntityFramework.Managers;
+using Localization.AspNetCore.EntityFramework.Providers;
 using Localization.AspNetCore.EntityFramework.Settings;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.DependencyInjection;
@@ -20,6 +21,13 @@ public static IServiceCollection AddLocalization<T>(this IServiceCollection serv
 
             services.AddOptions();
 
+            services.AddMemoryCache();
+
+            services.TryAdd(new ServiceDescriptor(
+                typeof(CacheProvider),
+                typeof(CacheProvider),
+                ServiceLifetime.Singleton));
+            
             services.TryAdd(new ServiceDescriptor(
                 typeof(LocalizationManager<>),
                 typeof(LocalizationManager<>),

Localization.AspNetCore.EntityFramework/Managers/LocalizationManager.cs

@@ -5,6 +5,7 @@
 using Localization.AspNetCore.EntityFramework.Entities;
 using Localization.AspNetCore.EntityFramework.Enums;
 using Localization.AspNetCore.EntityFramework.Extensions;
+using Localization.AspNetCore.EntityFramework.Providers;
 using Localization.AspNetCore.EntityFramework.Settings;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.EntityFrameworkCore;
@@ -19,13 +20,16 @@ internal class LocalizationManager<T> : ILocalizationManager
         private readonly LocalizerOptions _localizerSettings;
         private readonly RequestLocalizationOptions _requestLocalizationSettings;
         private readonly IServiceProvider _serviceProvider;
+        private readonly CacheProvider _cacheProvider;
         private List<LocalizationResource> _cache = new List<LocalizationResource>();
 
         public LocalizationManager(IServiceProvider serviceProvider,
+            CacheProvider cacheProvider,
             IOptions<LocalizerOptions> localizerOptions,
             IOptions<RequestLocalizationOptions> requestLocalizationOptions)
         {
             _serviceProvider = serviceProvider;
+            _cacheProvider = cacheProvider;
             _localizerSettings = localizerOptions == null
                 ? throw new ArgumentNullException(nameof(localizerOptions))
                 : localizerOptions.Value;

Localization.AspNetCore.EntityFramework/Providers/CacheProvider.cs

@@ -0,0 +1,52 @@
+using System;
+using System.Threading;
+using Localization.AspNetCore.EntityFramework.Settings;
+using Microsoft.Extensions.Caching.Memory;
+using Microsoft.Extensions.Options;
+using Microsoft.Extensions.Primitives;
+
+namespace Localization.AspNetCore.EntityFramework.Providers
+{
+    internal class CacheProvider 
+    {
+        private static CancellationTokenSource _resetCacheToken = new CancellationTokenSource();
+        private readonly IMemoryCache _innerCache;
+        private readonly LocalizerOptions _localizerSettings;
+
+        public CacheProvider(IMemoryCache cache, 
+            IOptions<LocalizerOptions> localizerOptions)
+        {
+            _localizerSettings = localizerOptions == null
+                ? throw new ArgumentNullException(nameof(localizerOptions))
+                : localizerOptions.Value;
+            _innerCache = cache;
+        }
+
+        public T Set<T>(object key, T value) 
+        {
+            /* some other code removed for brevity */
+            var options = new MemoryCacheEntryOptions()
+                .SetPriority(CacheItemPriority.Normal)
+                .SetSlidingExpiration(_localizerSettings.CacheExpirationOffset);
+                //.SetAbsoluteExpiration(typeExpiration);
+            
+            options.AddExpirationToken(new CancellationChangeToken(_resetCacheToken.Token));
+
+            _innerCache.Set(key, value, options);
+
+            return value;
+        }
+        
+
+        public void Reset()
+        {
+            if (_resetCacheToken != null && !_resetCacheToken.IsCancellationRequested && _resetCacheToken.Token.CanBeCanceled)
+            {
+                _resetCacheToken.Cancel();
+                _resetCacheToken.Dispose();
+            }
+
+            _resetCacheToken = new CancellationTokenSource();
+        }
+    }
+}

Localization.AspNetCore.EntityFramework/Settings/LocalizerOptions.cs

@@ -1,3 +1,4 @@
+using System;
 using Localization.AspNetCore.EntityFramework.Enums;
 
 namespace Localization.AspNetCore.EntityFramework.Settings
@@ -7,5 +8,6 @@ public class LocalizerOptions
         public FallBackBehaviorEnum FallBackBehavior { get; set; } = FallBackBehaviorEnum.DefaultCulture;
         public NamingConventionEnum NamingConvention { get; set; } = NamingConventionEnum.TypeName;
         public bool CreateMissingTranslationsIfNotFound { get; set; } = true;
+        public TimeSpan CacheExpirationOffset { get; set; } = new TimeSpan(1,0,0);
     }
 }