Added Cache invalidation on Delete and Update

Author: ScriptSage001

Shortify.NET.Application/Url/Commands/DeleteUrl/DeleteShortenedUrlByIdCommandHandler.cs

@@ -1,7 +1,10 @@
-using Shortify.NET.Application.Abstractions.Repositories;
+using Shortify.NET.Application.Abstractions;
+using Shortify.NET.Application.Abstractions.Repositories;
+using Shortify.NET.Application.Shared;
 using Shortify.NET.Common.FunctionalTypes;
 using Shortify.NET.Common.Messaging.Abstractions;
 using Shortify.NET.Core;
+using Shortify.NET.Core.Entites;
 using Shortify.NET.Core.Errors;
 
 namespace Shortify.NET.Application.Url.Commands.DeleteUrl;
@@ -11,10 +14,12 @@ namespace Shortify.NET.Application.Url.Commands.DeleteUrl;
 /// </summary>
 internal sealed class DeleteShortenedUrlByIdCommandHandler(
     IShortenedUrlRepository shortenedUrlRepository,
+    ICachingServices cachingServices,
     IUnitOfWork unitOfWork)
     : ICommandHandler<DeleteShortenedUrlByIdCommand>
 {
     private readonly IShortenedUrlRepository _shortenedUrlRepository = shortenedUrlRepository;
+    private readonly ICachingServices _cachingServices = cachingServices;
     private readonly IUnitOfWork _unitOfWork = unitOfWork;
 
     /// <summary>
@@ -29,8 +34,15 @@ public async Task<Result> Handle(DeleteShortenedUrlByIdCommand command, Cancella
         if (url is null) return Result.Failure(DomainErrors.ShortenedUrl.ShortenedUrlNotFound);
 
         _shortenedUrlRepository.Delete(url);
+        await RemoveFromCacheAsync(url, cancellationToken);
         await _unitOfWork.SaveChangesAsync(cancellationToken);
 
         return Result.Success();
     }
+
+    private async Task RemoveFromCacheAsync(ShortenedUrl shortenedUrl, CancellationToken cancellationToken)
+    {
+        var cacheKey = $"{Constant.Cache.Prefixes.OriginalUrls}{shortenedUrl.Code}";
+        await _cachingServices.RemoveAsync(cacheKey, cancellationToken);
+    }
 }

Shortify.NET.Application/Url/Commands/UpdateUrl/UpdateShortenedUrlCommandHandler.cs

@@ -1,4 +1,6 @@
-using Shortify.NET.Application.Abstractions.Repositories;
+using Shortify.NET.Application.Abstractions;
+using Shortify.NET.Application.Abstractions.Repositories;
+using Shortify.NET.Application.Shared;
 using Shortify.NET.Application.Shared.Models;
 using Shortify.NET.Common.FunctionalTypes;
 using Shortify.NET.Common.Messaging.Abstractions;
@@ -9,10 +11,14 @@ namespace Shortify.NET.Application.Url.Commands.UpdateUrl
 {
     internal sealed class UpdateShortenedUrlCommandHandler(
         IShortenedUrlRepository shortenedUrlRepository,
+        ICachingServices cachingServices,
         IUnitOfWork unitOfWork)
         : ICommandHandler<UpdateShortenedUrlCommand, ShortenedUrlDto>
     {
         private readonly IShortenedUrlRepository _shortenedUrlRepository = shortenedUrlRepository;
+
+        private readonly ICachingServices _cachingServices = cachingServices;
+        
         private readonly IUnitOfWork _unitOfWork = unitOfWork;
 
         public async Task<Result<ShortenedUrlDto>> Handle(
@@ -27,7 +33,7 @@ public async Task<Result<ShortenedUrlDto>> Handle(
             _shortenedUrlRepository.Update(url);
             await _unitOfWork.SaveChangesAsync(cancellationToken);
 
-            return new ShortenedUrlDto(
+            var response = new ShortenedUrlDto(
                 Id: url.Id,
                 UserId: url.UserId,
                 OriginalUrl: url.OriginalUrl,
@@ -39,7 +45,23 @@ public async Task<Result<ShortenedUrlDto>> Handle(
                 UpdatedOnUtc: url.UpdatedOnUtc,
                 RowStatus: url.RowStatus
             );
+            await SetCache(response, cancellationToken);
+            
+            return response; 
+        }
+        
+        private async Task SetCache(
+            ShortenedUrlDto cacheItem, 
+            CancellationToken cancellationToken)
+        {
+            var cacheKey = $"{Constant.Cache.Prefixes.OriginalUrls}{cacheItem.Code}";
 
+            await _cachingServices
+                .SetAsync(
+                    cacheKey,
+                    cacheItem, 
+                    cancellationToken: cancellationToken,
+                    slidingExpiration: TimeSpan.FromDays(1));
         }
     }
 }