✨ refactoring code

neozhu · Sep 23, 2023 · 74fdbec · 74fdbec
1 parent ddcbb67
commit 74fdbec
Show file tree

Hide file tree

Showing 8 changed files with 36 additions and 37 deletions.
diff --git a/src/Application/DependencyInjection.cs b/src/Application/DependencyInjection.cs
@@ -41,8 +41,8 @@ public static IServiceCollection AddApplicationServices(this IServiceCollection
             service.Initialize();
             return service;
             });
-        services.AddScoped<TenantService>();
-        services.AddScoped<ITenantService>(sp => {
+        services.AddSingleton<TenantService>();
+        services.AddSingleton<ITenantService>(sp => {
             var service = sp.GetRequiredService<TenantService>();
             service.Initialize();
             return service;

diff --git a/src/Application/Features/Tenants/Commands/AddEdit/AddEditTenantCommand.cs b/src/Application/Features/Tenants/Commands/AddEdit/AddEditTenantCommand.cs
@@ -2,6 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 
 
+using CleanArchitecture.Blazor.Application.Common.Interfaces.MultiTenant;
 using CleanArchitecture.Blazor.Application.Features.Tenants.Caching;
 using CleanArchitecture.Blazor.Application.Features.Tenants.DTOs;
 
@@ -30,16 +31,19 @@ public Mapping()
 
 public class AddEditTenantCommandHandler : IRequestHandler<AddEditTenantCommand, Result<string>>
 {
+    private readonly ITenantService _tenantsService;
     private readonly IApplicationDbContext _context;
     private readonly IStringLocalizer<AddEditTenantCommandHandler> _localizer;
     private readonly IMapper _mapper;
 
     public AddEditTenantCommandHandler(
+        ITenantService tenantsService,
         IApplicationDbContext context,
         IStringLocalizer<AddEditTenantCommandHandler> localizer,
         IMapper mapper
     )
     {
+        _tenantsService = tenantsService;
         _context = context;
         _localizer = localizer;
         _mapper = mapper;
@@ -59,6 +63,7 @@ public async Task<Result<string>> Handle(AddEditTenantCommand request, Cancellat
             item = _mapper.Map(request, item);
         }
         await _context.SaveChangesAsync(cancellationToken);
+        await _tenantsService.Refresh();
         return await Result<string>.SuccessAsync(item.Id);
     }
 }
diff --git a/src/Application/Features/Tenants/Commands/Delete/DeleteTenantCommand.cs b/src/Application/Features/Tenants/Commands/Delete/DeleteTenantCommand.cs
@@ -1,6 +1,7 @@
 // Licensed to the .NET Foundation under one or more agreements.
 // The .NET Foundation licenses this file to you under the MIT license.
 
+using CleanArchitecture.Blazor.Application.Common.Interfaces.MultiTenant;
 using CleanArchitecture.Blazor.Application.Features.Tenants.Caching;
 
 namespace CleanArchitecture.Blazor.Application.Features.Tenants.Commands.Delete;
@@ -21,16 +22,19 @@ public class DeleteTenantCommandHandler :
     IRequestHandler<DeleteTenantCommand, Result<int>>
 
 {
+    private readonly ITenantService _tenantsService;
     private readonly IApplicationDbContext _context;
     private readonly IStringLocalizer<DeleteTenantCommandHandler> _localizer;
     private readonly IMapper _mapper;
 
     public DeleteTenantCommandHandler(
+        ITenantService tenantsService,
         IApplicationDbContext context,
         IStringLocalizer<DeleteTenantCommandHandler> localizer,
         IMapper mapper
     )
     {
+        _tenantsService = tenantsService;
         _context = context;
         _localizer = localizer;
         _mapper = mapper;
@@ -45,6 +49,7 @@ public async Task<Result<int>> Handle(DeleteTenantCommand request, CancellationT
         }
 
         var result = await _context.SaveChangesAsync(cancellationToken);
+        await _tenantsService.Refresh();
         return await Result<int>.SuccessAsync(result);
     }
 }
diff --git a/src/Application/Features/Tenants/EventHandlers/TenantChangedEventHandler.cs b/src/Application/Features/Tenants/EventHandlers/TenantChangedEventHandler.cs
diff --git a/src/Application/Services/MultiTenant/TenantService.cs b/src/Application/Services/MultiTenant/TenantService.cs
@@ -1,6 +1,7 @@
 using CleanArchitecture.Blazor.Application.Common.Interfaces.MultiTenant;
 using CleanArchitecture.Blazor.Application.Features.Tenants.Caching;
 using CleanArchitecture.Blazor.Application.Features.Tenants.DTOs;
+using Microsoft.Extensions.DependencyInjection;
 
 namespace CleanArchitecture.Blazor.Application.Services.MultiTenant;
 
@@ -12,10 +13,12 @@ public class TenantService : ITenantService
 
     public TenantService(
         IAppCache cache,
-        IApplicationDbContext context, IMapper mapper)
+        IServiceScopeFactory scopeFactory, 
+        IMapper mapper)
     {
         _cache = cache;
-        _context = context;
+        var scope = scopeFactory.CreateScope();
+        _context = scope.ServiceProvider.GetRequiredService<IApplicationDbContext>();
         _mapper = mapper;
     }
 

diff --git a/src/Blazor.Server.UI/Pages/Identity/Users/Users.razor b/src/Blazor.Server.UI/Pages/Identity/Users/Users.razor
@@ -319,6 +319,8 @@
     [Inject]
     private ITenantService TenantsService { get; set; } = null!;
     [Inject]
+    private IUserDataProvider UserDataProvider { get; set; } = null!;
+    [Inject]
     private IBlazorDownloadFileService BlazorDownloadFileService { get; set; } = null!;
     [Inject]
     private IExcelService ExcelService { get; set; } = null!;
@@ -453,6 +455,7 @@
                     await UserManager.AddToRoleAsync(applicationUser, RoleName.Basic);
                 }
                 Snackbar.Add($"{ConstantString.CreateSuccess}", Severity.Info);
+                await  UserDataProvider.Refresh();
                 await OnRefresh();
             }
             else
@@ -502,6 +505,7 @@
                 }
                 Snackbar.Add($"{ConstantString.UpdateSuccess}", Severity.Info);
                 await OnRefresh();
+                await UserDataProvider.Refresh();
             }
             else
             {
@@ -551,6 +555,7 @@
 
             Snackbar.Add($"{ConstantString.DeleteSuccess}", Severity.Info);
             await OnRefresh();
+            await UserDataProvider.Refresh();
         }
     }
 
@@ -592,6 +597,7 @@
             }
             Snackbar.Add($"{ConstantString.DeleteSuccess}", Severity.Info);
             await OnRefresh();
+            await  UserDataProvider.Refresh();
         }
 
     }

diff --git a/src/Infrastructure/Extensions/AuthenticationServiceCollectionExtensions.cs b/src/Infrastructure/Extensions/AuthenticationServiceCollectionExtensions.cs
@@ -90,8 +90,8 @@ public static IServiceCollection AddAuthenticationService(this IServiceCollectio
                  }); 
 
         services.AddScoped<AccessTokenProvider>();
-        services.AddScoped<UserDataProvider>();
-        services.AddScoped<IUserDataProvider>(sp =>
+        services.AddSingleton<UserDataProvider>();
+        services.AddSingleton<IUserDataProvider>(sp =>
         {
             var service = sp.GetRequiredService<UserDataProvider>();
             service.Initialize();

diff --git a/src/Infrastructure/Services/Identity/UserDataProvider.cs b/src/Infrastructure/Services/Identity/UserDataProvider.cs
@@ -1,40 +1,47 @@
 using AutoMapper;
 using AutoMapper.QueryableExtensions;
 using CleanArchitecture.Blazor.Application.Features.Identity.Dto;
+using LazyCache;
 
 namespace CleanArchitecture.Blazor.Infrastructure.Services.Identity;
 public class UserDataProvider : IUserDataProvider
 {
+    private const string CACHEKEY = "ALL-ApplicationUserDto";
+    private readonly IAppCache _cache;
     private readonly IMapper _mapper;
     private readonly UserManager<ApplicationUser> _userManager;
     public List<ApplicationUserDto> DataSource { get; private set; }
 
     public event Action? OnChange;
 
     public UserDataProvider(
+        IAppCache cache,
         IMapper mapper,
         IServiceScopeFactory scopeFactory)
     {
+        _cache = cache;
         _mapper = mapper;
         var scope = scopeFactory.CreateScope();
         _userManager = scope.ServiceProvider.GetRequiredService<UserManager<ApplicationUser>>();
         DataSource = new List<ApplicationUserDto>();
     }
     public void Initialize()
     {
-        DataSource = _userManager.Users.Include(x => x.UserRoles).ThenInclude(x => x.Role).ProjectTo<ApplicationUserDto>(_mapper.ConfigurationProvider).OrderBy(x=>x.UserName).ToList();
+        DataSource = _cache.GetOrAdd(CACHEKEY,()=>_userManager.Users.Include(x => x.UserRoles).ThenInclude(x => x.Role).ProjectTo<ApplicationUserDto>(_mapper.ConfigurationProvider).OrderBy(x=>x.UserName).ToList());
         OnChange?.Invoke();
     }
 
     public async Task InitializeAsync()
     {
-        DataSource =await _userManager.Users.Include(x => x.UserRoles).ThenInclude(x => x.Role).ProjectTo<ApplicationUserDto>(_mapper.ConfigurationProvider).OrderBy(x => x.UserName).ToListAsync();
+        DataSource =await _cache.GetOrAddAsync(CACHEKEY,()=> _userManager.Users.Include(x => x.UserRoles).ThenInclude(x => x.Role).ProjectTo<ApplicationUserDto>(_mapper.ConfigurationProvider).OrderBy(x => x.UserName).ToListAsync());
         OnChange?.Invoke();
     }
 
-    public Task Refresh()
+    public async Task Refresh()
     {
+        _cache.Remove(CACHEKEY);
+        DataSource = await _cache.GetOrAddAsync(CACHEKEY, () => _userManager.Users.Include(x => x.UserRoles).ThenInclude(x => x.Role).ProjectTo<ApplicationUserDto>(_mapper.ConfigurationProvider).OrderBy(x => x.UserName).ToListAsync());
         OnChange?.Invoke();
-        return Task.CompletedTask;
+
     }
 }