From 9880caaf315effe46f34c7d298a1554970fe6e3d Mon Sep 17 00:00:00 2001
From: ngfrolov <ng.frolov@autodrilling.ru>
Date: Fri, 10 Jun 2022 17:32:05 +0500
Subject: [PATCH] Add shorthand to get cache by using default values of
 obsolescence and tag

---
 .../EfCache/EfCacheDictionaryExtensions.cs    | 81 +++++++++++++++++++
 .../EfCache/EfCacheExtensions.cs              | 32 ++++++++
 2 files changed, 113 insertions(+)

diff --git a/AsbCloudInfrastructure/EfCache/EfCacheDictionaryExtensions.cs b/AsbCloudInfrastructure/EfCache/EfCacheDictionaryExtensions.cs
index 21a672f7..b4f45b3e 100644
--- a/AsbCloudInfrastructure/EfCache/EfCacheDictionaryExtensions.cs
+++ b/AsbCloudInfrastructure/EfCache/EfCacheDictionaryExtensions.cs
@@ -19,6 +19,7 @@ namespace AsbCloudInfrastructure.EfCache
         private static readonly TimeSpan semaphoreTimeout = TimeSpan.FromSeconds(25);
         private static readonly SemaphoreSlim semaphore = new(1);
         private static readonly TimeSpan minCacheTime = TimeSpan.FromSeconds(2);
+        private static readonly TimeSpan defaultObsolescence = TimeSpan.FromMinutes(4);
 
         private class CacheItem
         {
@@ -241,6 +242,38 @@ namespace AsbCloudInfrastructure.EfCache
             return cache;
         }
 
+        /// <summary>
+        /// Кешировать запрос в Dictionary&lt;<typeparamref name="TKey"/>, <typeparamref name="TEntity"/>&gt;. С тегом typeof(TEntity).Name и ключом int Id
+        /// </summary>
+        /// <typeparam name="TEntity"></typeparam>
+        /// <param name="query"></param>
+        /// <returns></returns>
+        public static Dictionary<int, TEntity> FromCacheDictionary<TEntity>(
+            this IQueryable<TEntity> query)
+            where TEntity : class, AsbCloudDb.Model.IId
+        {
+            var tag = typeof(TEntity).Name;
+            return FromCacheDictionary(query, tag, defaultObsolescence, e => e.Id);
+        }
+
+        /// <summary>
+        /// Кешировать запрос в Dictionary&lt;<typeparamref name="TKey"/>, <typeparamref name="TEntity"/>&gt;. С тегом typeof(TEntity).Name
+        /// </summary>
+        /// <typeparam name="TKey"></typeparam>
+        /// <typeparam name="TEntity"></typeparam>
+        /// <param name="query"></param>
+        /// <param name="keySelector">Делегат получения ключа из записи</param>
+        /// <returns></returns>
+        public static Dictionary<TKey, TEntity> FromCacheDictionary<TKey, TEntity>(
+            this IQueryable<TEntity> query,
+            Func<TEntity, TKey> keySelector)
+            where TEntity : class
+            where TKey : notnull
+        {
+            var tag = typeof(TEntity).Name;
+            return FromCacheDictionary(query, tag, defaultObsolescence, keySelector);
+        }
+
         /// <summary>
         /// Кешировать запрос в Dictionary&lt;<typeparamref name="TKey"/>, <typeparamref name="TEntity"/>&gt;.
         /// </summary>
@@ -293,6 +326,43 @@ namespace AsbCloudInfrastructure.EfCache
             return cache.GetData<TKey, TEntity, TModel>(convert);
         }
 
+        /// <summary>
+        /// Асинхронно кешировать запрос в Dictionary&lt;<typeparamref name="TKey"/>, <typeparamref name="TEntity"/>&gt;. С тегом typeof(TEntity).Name и ключом int Id
+        /// </summary>
+        /// <typeparam name="TEntity"></typeparam>
+        /// <param name="query"></param>
+        /// <param name="token"></param>
+        /// <returns></returns>
+        public static Task<Dictionary<int, TEntity>> FromCacheDictionaryAsync<TEntity>(
+            this IQueryable<TEntity> query,
+            CancellationToken token = default)
+            where TEntity : class, AsbCloudDb.Model.IId
+        {
+            var tag = typeof(TEntity).Name;
+            return FromCacheDictionaryAsync(query, tag, defaultObsolescence, e => e.Id, token);
+        }
+
+        /// <summary>
+        /// Асинхронно кешировать запрос в Dictionary&lt;<typeparamref name="TKey"/>, <typeparamref name="TEntity"/>&gt;. С тегом typeof(TEntity).Name
+        /// </summary>
+        /// <typeparam name="TKey"></typeparam>
+        /// <typeparam name="TEntity"></typeparam>
+        /// <param name="query"></param>
+        /// <param name="keySelector">Делегат получения ключа из записи</param>
+        /// <param name="token"></param>
+        /// <returns></returns>
+        public static Task<Dictionary<TKey, TEntity>> FromCacheDictionaryAsync<TKey, TEntity>(
+            this IQueryable<TEntity> query,
+            Func<TEntity, TKey> keySelector,
+            CancellationToken token = default)
+            where TEntity : class
+            where TKey : notnull
+        {
+            var tag = typeof(TEntity).Name;
+            return FromCacheDictionaryAsync(query, tag, defaultObsolescence, keySelector, token);
+        }
+
+
         /// <summary>
         /// Асинхронно кешировать запрос в Dictionary&lt;<typeparamref name="TKey"/>, <typeparamref name="TEntity"/>&gt;.
         /// </summary>
@@ -343,6 +413,17 @@ namespace AsbCloudInfrastructure.EfCache
             return cache.GetData<TKey, TEntity, TModel>(convert);
         }
 
+        /// <summary>
+        /// drops cache with tag = typeof(T).Name
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="query"></param>
+        public static void DropCacheDictionary<T>(this IQueryable<T> query)
+        {
+            var tag = typeof(T).Name;
+            DropCacheDictionary<T>(query, tag);
+        }
+
         /// <summary>
         /// Очистить кеш
         /// </summary>
diff --git a/AsbCloudInfrastructure/EfCache/EfCacheExtensions.cs b/AsbCloudInfrastructure/EfCache/EfCacheExtensions.cs
index b1a9e382..2c9c953f 100644
--- a/AsbCloudInfrastructure/EfCache/EfCacheExtensions.cs
+++ b/AsbCloudInfrastructure/EfCache/EfCacheExtensions.cs
@@ -19,6 +19,7 @@ namespace AsbCloudInfrastructure.EfCache
         private static readonly TimeSpan semaphoreTimeout = TimeSpan.FromSeconds(25);
         private static readonly SemaphoreSlim semaphore = new(1);
         private static readonly TimeSpan minCacheTime = TimeSpan.FromSeconds(2);
+        private static readonly TimeSpan defaultObsolescence = TimeSpan.FromMinutes(4);
 
         private class CacheItem
         {
@@ -237,6 +238,19 @@ namespace AsbCloudInfrastructure.EfCache
             return cache;
         }
 
+        /// <summary>
+        /// Кешировать запрос в List&lt;<typeparamref name="TEntity"/>&gt;. Кеш tag = typeof(TEntity).Name
+        /// </summary>
+        /// <typeparam name="TEntity"></typeparam>
+        /// <param name="query"></param>
+        /// <returns></returns>
+        public static IEnumerable<TEntity> FromCache<TEntity>(this IQueryable<TEntity> query)
+            where TEntity : class
+        {
+            var tag = typeof(TEntity).Name;
+            return FromCache(query, tag, defaultObsolescence);
+        }
+
         /// <summary>
         /// Кешировать запрос в List&lt;<typeparamref name="TEntity"/>&gt;.
         /// </summary>
@@ -272,6 +286,13 @@ namespace AsbCloudInfrastructure.EfCache
             return cache.GetData(convert);
         }
 
+        public static Task<IEnumerable<TEntity>> FromCacheAsync<TEntity>(this IQueryable<TEntity> query, CancellationToken token = default)
+            where TEntity : class
+        {
+            var tag = typeof(TEntity).Name;
+            return FromCacheAsync(query, tag, defaultObsolescence, token);
+        }
+
         /// <summary>
         /// Асинхронно кешировать запрос в List&lt;<typeparamref name="TEntity"/>&gt;.<br/>
         /// </summary>
@@ -311,6 +332,17 @@ namespace AsbCloudInfrastructure.EfCache
             return cache.GetData(convert);
         }
 
+        /// <summary>
+        /// drops cache with tag = typeof(T).Name
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="query"></param>
+        public static void DropCache<T>(this IQueryable<T> query)
+        {
+            var tag = typeof(T).Name;
+            DropCache(query, tag);
+        }
+
         /// <summary>
         /// Очистить кеш
         /// </summary>