From 7b00cedb470aa1875c654126e74ec02d98203b7a Mon Sep 17 00:00:00 2001
From: KharchenkoVV <vv.harchenko@autodrilling.ru>
Date: Fri, 21 May 2021 12:30:25 +0500
Subject: [PATCH] =?UTF-8?q?CS2-11:=20=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=BB?=
 =?UTF-8?q?=D0=B5=D0=BD=D0=BE=20=D0=BE=D0=B1=D0=BD=D0=BE=D0=B2=D0=BB=D0=B5?=
 =?UTF-8?q?=D0=BD=D0=B8=D0=B5=20=D1=83=D1=81=D1=82=D0=B0=D1=80=D0=B5=D0=B2?=
 =?UTF-8?q?=D1=88=D0=B8=D1=85=20CacheTable=20=D0=BF=D1=80=D0=B8=20=D0=B8?=
 =?UTF-8?q?=D1=85=20=D0=B2=D1=8B=D0=B7=D0=BE=D0=B2=D0=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 AsbCloudInfrastructure/Services/Cache/CacheDb.cs | 16 ++++++++++++----
 .../Services/Cache/CacheTable.cs                 |  8 ++++++--
 2 files changed, 18 insertions(+), 6 deletions(-)

diff --git a/AsbCloudInfrastructure/Services/Cache/CacheDb.cs b/AsbCloudInfrastructure/Services/Cache/CacheDb.cs
index ddf34de8..73630000 100644
--- a/AsbCloudInfrastructure/Services/Cache/CacheDb.cs
+++ b/AsbCloudInfrastructure/Services/Cache/CacheDb.cs
@@ -1,4 +1,5 @@
-using Microsoft.EntityFrameworkCore;
+using System;
+using Microsoft.EntityFrameworkCore;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
 
@@ -7,7 +8,8 @@ namespace AsbCloudInfrastructure.Services.Cache
 
     public class CacheDb
     {
-        private readonly ConcurrentDictionary<string, IEnumerable<object>> cache = new ConcurrentDictionary<string, IEnumerable<object>>();
+        private readonly ConcurrentDictionary<string, (DateTime, IEnumerable<object>)> cache = new ConcurrentDictionary<string, (DateTime, IEnumerable<object>)>();
+        private readonly TimeSpan obsolesenceTime = TimeSpan.FromMinutes(15);
 
         public CacheTable<TEntity> GetCachedTable<TEntity>(DbContext context)
             where TEntity : class
@@ -15,9 +17,15 @@ namespace AsbCloudInfrastructure.Services.Cache
             var entityTypeName = typeof(TEntity).FullName;
 
             if (!cache.ContainsKey(entityTypeName))
-                cache[entityTypeName] = new List<TEntity>(8);
+                cache[entityTypeName] = (DateTime.Now, new List<TEntity>(8));
+
+            bool isCachedDataObsolete = DateTime.Now - cache[entityTypeName].Item1 > obsolesenceTime;
+
+            var tableCache = new CacheTable<TEntity>(context, cache[entityTypeName]);
+
+            if (isCachedDataObsolete)
+                tableCache.Refresh();
 
-            var tableCache = new CacheTable<TEntity>(context, (List<TEntity>)cache[entityTypeName]);
             return tableCache;
         }
 
diff --git a/AsbCloudInfrastructure/Services/Cache/CacheTable.cs b/AsbCloudInfrastructure/Services/Cache/CacheTable.cs
index 4f85ea43..0def1e23 100644
--- a/AsbCloudInfrastructure/Services/Cache/CacheTable.cs
+++ b/AsbCloudInfrastructure/Services/Cache/CacheTable.cs
@@ -10,12 +10,14 @@ namespace AsbCloudInfrastructure.Services.Cache
     public class CacheTable<TEntity> where TEntity : class
     {
         private readonly DbContext context;
+        private (DateTime refreshDate, IEnumerable<object> entities) data;
         private readonly List<TEntity> cached;
 
-        internal CacheTable(DbContext context, List<TEntity> entities)
+        internal CacheTable(DbContext context, (DateTime refreshDate, IEnumerable<object> entities) data)
         {
             this.context = context;
-            this.cached = entities;
+            this.data = data;
+            this.cached = (List<TEntity>)data.entities;
         }
 
         public TEntity this[int index] { get => cached.ElementAt(index); }
@@ -25,6 +27,7 @@ namespace AsbCloudInfrastructure.Services.Cache
             cached.Clear();
             var dbEntities = context.Set<TEntity>().ToList();
             cached.AddRange(dbEntities);
+            data.refreshDate = DateTime.Now;
             return cached.Count;
         }
 
@@ -33,6 +36,7 @@ namespace AsbCloudInfrastructure.Services.Cache
             cached.Clear();
             var dbEntities = await context.Set<TEntity>().ToListAsync(token).ConfigureAwait(false);
             cached.AddRange(dbEntities);
+            data.refreshDate = DateTime.Now;
             return cached.Count;
         }