Merge pull request #97 from neozhu/fusioncache

Fusioncache
neozhu · Nov 13, 2024 · 787a446 · 787a446
2 parents 0d3ac49 + a67df8f
commit 787a446
Show file tree

Hide file tree

Showing 11 changed files with 25 additions and 55 deletions.
diff --git a/src/Templates/Caching/.cachekey.cs.txt b/src/Templates/Caching/.cachekey.cs.txt
@@ -22,60 +22,23 @@ namespace {namespace};
 /// </summary>
 public static class {itemname}CacheKey
 {
-    // Defines the refresh interval for the cache expiration token
-    private static readonly TimeSpan RefreshInterval = TimeSpan.FromMinutes(30);
-    // Object used for locking to ensure thread safety
-    private static readonly object TokenLock = new();
-    // CancellationTokenSource used for managing cache expiration
-    private static CancellationTokenSource _tokenSource = new (RefreshInterval);
-    /// <summary>
-    /// Gets the memory cache entry options with an expiration token.
-    /// </summary>
-    public static MemoryCacheEntryOptions MemoryCacheEntryOptions =>
-        new MemoryCacheEntryOptions().AddExpirationToken(new CancellationChangeToken(GetOrCreateTokenSource().Token));
-
     public const string GetAllCacheKey = "all-{nameofPlural}";
     public static string GetPaginationCacheKey(string parameters) {
         return $"{itemname}CacheKey:{nameofPlural}WithPaginationQuery,{parameters}";
     }
+    public static string GetExportCacheKey(string parameters) {
+        return $"{itemname}CacheKey:ExportCacheKey,{parameters}";
+    }
     public static string GetByNameCacheKey(string parameters) {
         return $"{itemname}CacheKey:GetByNameCacheKey,{parameters}";
     }
     public static string GetByIdCacheKey(string parameters) {
         return $"{itemname}CacheKey:GetByIdCacheKey,{parameters}";
     }
-
-
-    /// <summary>
-    /// Gets or creates a new <see cref="CancellationTokenSource"/> with the specified refresh interval.
-    /// </summary>
-    /// <returns>The current or new <see cref="CancellationTokenSource"/>.</returns>
-    public static CancellationTokenSource GetOrCreateTokenSource()
-    {
-        lock (TokenLock)
-        {
-            if (_tokenSource.IsCancellationRequested)
-            {
-                _tokenSource.Dispose();
-                _tokenSource = new CancellationTokenSource(RefreshInterval);
-            }
-            return _tokenSource;
-        }
-    }
-    /// <summary>
-    /// Refreshes the cache expiration token by cancelling and recreating the <see cref="CancellationTokenSource"/>.
-    /// </summary>
+    public static IEnumerable<string>? Tags => new string[] { "{itemnamelowercase}" };
     public static void Refresh()
     {
-        lock (TokenLock)
-        {
-            if (!_tokenSource.IsCancellationRequested)
-            {
-                _tokenSource.Cancel();
-                _tokenSource.Dispose();
-                _tokenSource = new CancellationTokenSource(RefreshInterval);
-            }
-        }
+        FusionCacheFactory.RemoveByTags(Tags);
     }
 }
 
diff --git a/src/Templates/Commands/AddEdit/.cs.txt b/src/Templates/Commands/AddEdit/.cs.txt
@@ -35,7 +35,7 @@ public class AddEdit{itemname}Command: ICacheInvalidatorRequest<Result<int>>
       {dtoFieldDefinition}
 
       public string CacheKey => {itemname}CacheKey.GetAllCacheKey;
-      public CancellationTokenSource? SharedExpiryTokenSource => {itemname}CacheKey.GetOrCreateTokenSource();
+      public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
 }
 
 public class AddEdit{itemname}CommandHandler : IRequestHandler<AddEdit{itemname}Command, Result<int>>

diff --git a/src/Templates/Commands/AddEdit/.validator.cs.txt b/src/Templates/Commands/AddEdit/.validator.cs.txt
@@ -20,7 +20,7 @@
 //------------------------------------------------------------------------------
 
 // Usage:
-// This validator enforces constraints on the AddEditContactCommand, such as
+// This validator enforces constraints on the AddEdit{itemname}Command, such as
 // maximum field length for ...
 
 namespace {namespace};

diff --git a/src/Templates/Commands/Create/.cs.txt b/src/Templates/Commands/Create/.cs.txt
@@ -36,7 +36,7 @@ public class Create{itemname}Command: ICacheInvalidatorRequest<Result<int>>
       public int Id { get; set; }
       {dtoFieldDefinition}
       public string CacheKey => {itemname}CacheKey.GetAllCacheKey;
-      public CancellationTokenSource? SharedExpiryTokenSource => {itemname}CacheKey.GetOrCreateTokenSource();
+      public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
 }
 
     public class Create{itemname}CommandHandler : IRequestHandler<Create{itemname}Command, Result<int>>

diff --git a/src/Templates/Commands/Delete/.cs.txt b/src/Templates/Commands/Delete/.cs.txt
@@ -35,7 +35,7 @@ public class Delete{itemname}Command:  ICacheInvalidatorRequest<Result<int>>
 {
   public int[] Id {  get; }
   public string CacheKey => {itemname}CacheKey.GetAllCacheKey;
-  public CancellationTokenSource? SharedExpiryTokenSource => {itemname}CacheKey.GetOrCreateTokenSource();
+  public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
   public Delete{itemname}Command(int[] id)
   {
     Id = id;

diff --git a/src/Templates/Commands/Import/.cs.txt b/src/Templates/Commands/Import/.cs.txt
@@ -37,7 +37,7 @@ namespace {namespace};
         public string FileName { get; set; }
         public byte[] Data { get; set; }
         public string CacheKey => {itemname}CacheKey.GetAllCacheKey;
-        public CancellationTokenSource? SharedExpiryTokenSource => {itemname}CacheKey.GetOrCreateTokenSource();
+        public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
         public Import{nameofPlural}Command(string fileName,byte[] data)
         {
            FileName = fileName;

diff --git a/src/Templates/Commands/Update/.cs.txt b/src/Templates/Commands/Update/.cs.txt
@@ -35,8 +35,8 @@ public class Update{itemname}Command: ICacheInvalidatorRequest<Result<int>>
       [Description("Id")]
       public int Id { get; set; }
         {dtoFieldDefinition}
-        public string CacheKey => {itemname}CacheKey.GetAllCacheKey;
-        public CancellationTokenSource? SharedExpiryTokenSource => {itemname}CacheKey.GetOrCreateTokenSource();
+      public string CacheKey => {itemname}CacheKey.GetAllCacheKey;
+      public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
 
 }
 

diff --git a/src/Templates/Queries/Export/.cs.txt b/src/Templates/Queries/Export/.cs.txt
@@ -16,13 +16,20 @@
 
 using {selectns}.{nameofPlural}.DTOs;
 using {selectns}.{nameofPlural}.Mappers;
+using {selectns}.{nameofPlural}.Caching;
 using {selectns}.{nameofPlural}.Specifications;
 
 namespace {namespace};
 
-public class Export{nameofPlural}Query : {itemname}AdvancedFilter, IRequest<Result<byte[]>>
+public class Export{nameofPlural}Query : {itemname}AdvancedFilter, ICacheableRequest<Result<byte[]>>
 {
       public {itemname}AdvancedSpecification Specification => new {itemname}AdvancedSpecification(this);
+      public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
+    public override string ToString()
+    {
+        return $"Listview:{ListView}:{CurrentUser?.UserId}-{LocalTimezoneOffset.TotalHours}, Search:{Keyword}, {OrderBy}, {SortDirection}";
+    }
+    public string CacheKey => {itemname}CacheKey.GetExportCacheKey($"{this}");
 }
 
 public class Export{nameofPlural}QueryHandler :

diff --git a/src/Templates/Queries/GetAll/.cs.txt b/src/Templates/Queries/GetAll/.cs.txt
@@ -23,7 +23,7 @@ namespace {namespace};
 public class GetAll{nameofPlural}Query : ICacheableRequest<IEnumerable<{itemname}Dto>>
 {
    public string CacheKey => {itemname}CacheKey.GetAllCacheKey;
-   public MemoryCacheEntryOptions? Options => {itemname}CacheKey.MemoryCacheEntryOptions;
+   public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
 }
 
 public class GetAll{nameofPlural}QueryHandler :

diff --git a/src/Templates/Queries/GetById/.cs.txt b/src/Templates/Queries/GetById/.cs.txt
@@ -24,7 +24,7 @@ public class Get{itemname}ByIdQuery : ICacheableRequest<Result<{itemname}Dto>>
 {
    public required int Id { get; set; }
    public string CacheKey => {itemname}CacheKey.GetByIdCacheKey($"{Id}");
-   public MemoryCacheEntryOptions? Options => {itemname}CacheKey.MemoryCacheEntryOptions;
+   public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
 }
 
 public class Get{itemname}ByIdQueryHandler :
@@ -43,6 +43,6 @@ public class Get{itemname}ByIdQueryHandler :
         var data = await _context.{nameofPlural}.ApplySpecification(new {itemname}ByIdSpecification(request.Id))
                                                 .ProjectTo()
                                                 .FirstAsync(cancellationToken);
-        return await Result<ContactDto>.SuccessAsync(data);
+        return await Result<{itemname}Dto>.SuccessAsync(data);
     }
 }
diff --git a/src/Templates/Queries/Pagination/.cs.txt b/src/Templates/Queries/Pagination/.cs.txt
@@ -24,10 +24,10 @@ public class {nameofPlural}WithPaginationQuery : {itemname}AdvancedFilter, ICach
 {
     public override string ToString()
     {
-        return $"Listview:{ListView}-{LocalTimezoneOffset.TotalHours}, Search:{Keyword}, {OrderBy}, {SortDirection}, {PageNumber}, {PageSize}";
+        return $"Listview:{ListView}:{CurrentUser?.UserId}-{LocalTimezoneOffset.TotalHours}, Search:{Keyword}, {OrderBy}, {SortDirection}, {PageNumber}, {PageSize}";
     }
     public string CacheKey => {itemname}CacheKey.GetPaginationCacheKey($"{this}");
-    public MemoryCacheEntryOptions? Options => {itemname}CacheKey.MemoryCacheEntryOptions;
+    public IEnumerable<string>? Tags => {itemname}CacheKey.Tags;
     public {itemname}AdvancedSpecification Specification => new {itemname}AdvancedSpecification(this);
 }