Added Caching Structure

Author: linkdotnet

LinkDotNet.Blog.Infrastructure/Persistence/CachedRepository.cs

@@ -0,0 +1,62 @@
+using System;
+using System.Linq.Expressions;
+using System.Threading.Tasks;
+using LinkDotNet.Blog.Domain;
+using Microsoft.Extensions.Caching.Memory;
+using X.PagedList;
+
+namespace LinkDotNet.Blog.Infrastructure.Persistence
+{
+    public class CachedRepository<T> : IRepository<T>
+        where T : Entity
+    {
+        private readonly IRepository<T> repository;
+        private readonly IMemoryCache memoryCache;
+
+        public CachedRepository(IRepository<T> repository, IMemoryCache memoryCache)
+        {
+            this.repository = repository;
+            this.memoryCache = memoryCache;
+        }
+
+        public async Task<T> GetByIdAsync(string id)
+        {
+            if (memoryCache.TryGetValue(id, out T item))
+            {
+                return item;
+            }
+
+            var fromDb = await repository.GetByIdAsync(id);
+            memoryCache.Set(id, fromDb);
+            return fromDb;
+        }
+
+        public async Task<IPagedList<T>> GetAllAsync(
+            Expression<Func<T, bool>> filter = null,
+            Expression<Func<T, object>> orderBy = null,
+            bool descending = true,
+            int page = 1,
+            int pageSize = int.MaxValue)
+        {
+            var key = $"{page}-{pageSize}";
+            return await memoryCache.GetOrCreate(key, async e =>
+            {
+                e.SetOptions(new MemoryCacheEntryOptions
+                {
+                    AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(1),
+                });
+                return await repository.GetAllAsync(filter, orderBy, descending, page, pageSize);
+            });
+        }
+
+        public async Task StoreAsync(T entity)
+        {
+            await repository.StoreAsync(entity);
+        }
+
+        public async Task DeleteAsync(string id)
+        {
+            await repository.DeleteAsync(id);
+        }
+    }
+}

LinkDotNet.Blog.Web/LinkDotNet.Blog.Web.csproj

@@ -11,6 +11,7 @@
         <PackageReference Include="Microsoft.AspNetCore.Authentication.OpenIdConnect" Version="6.0.0-rc.1.21452.15" />
         <PackageReference Include="Microsoft.EntityFrameworkCore.Sqlite" Version="6.0.0-rc.1.21452.10" />
         <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="6.0.0-rc.1.21452.10" />
+        <PackageReference Include="Scrutor.AspNetCore" Version="3.3.0" />
         <PackageReference Include="SonarAnalyzer.CSharp" Version="8.29.0.36737">
           <PrivateAssets>all</PrivateAssets>
           <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

LinkDotNet.Blog.Web/RegistrationExtensions/StorageProviderExtensions.cs

@@ -1,4 +1,6 @@
-using LinkDotNet.Blog.Infrastructure.Persistence;
+using LinkDotNet.Blog.Domain;
+using LinkDotNet.Blog.Infrastructure.Persistence;
+using LinkDotNet.Blog.Infrastructure.Persistence.Sql;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 
@@ -26,6 +28,9 @@ public static void AddStorageProvider(this IServiceCollection services, IConfigu
             {
                 services.UseSqlAsStorageProvider();
             }
+
+            services.AddScoped<IRepository<BlogPost>, Repository<BlogPost>>();
+            services.Decorate(typeof(IRepository<>), typeof(CachedRepository<>));
         }
     }
 }

LinkDotNet.Blog.sln

@@ -11,9 +11,9 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "LinkDotNet.Blog.Infrastruct
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "LinkDotNet.Blog.UnitTests", "LinkDotNet.Blog.UnitTests\LinkDotNet.Blog.UnitTests.csproj", "{5B868911-7C93-4190-AEE4-3A6694F2FFCE}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "LinkDotNet.Blog.IntegrationTests", "LinkDotNet.Blog.IntegrationTests\LinkDotNet.Blog.IntegrationTests.csproj", "{DEFDA17A-9586-4E50-83FB-8F75AC29D39A}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "LinkDotNet.Blog.IntegrationTests", "LinkDotNet.Blog.IntegrationTests\LinkDotNet.Blog.IntegrationTests.csproj", "{DEFDA17A-9586-4E50-83FB-8F75AC29D39A}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "LinkDotNet.Blog.TestUtilities", "LinkDotNet.Blog.TestUtilities\LinkDotNet.Blog.TestUtilities.csproj", "{310ABEE1-C131-43E6-A759-F2DB75A483DD}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "LinkDotNet.Blog.TestUtilities", "LinkDotNet.Blog.TestUtilities\LinkDotNet.Blog.TestUtilities.csproj", "{310ABEE1-C131-43E6-A759-F2DB75A483DD}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -52,4 +52,4 @@ Global
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {FB9B0642-F1F0-4BD8-9EDD-15C95F082180}
 	EndGlobalSection
-EndGlobal
+EndGlobal