AgileWebs/Core.Thalos.DAL.API
6
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Uncomment the cache settings

Browse Source
This commit is contained in:
Oscar Morales
2025-06-10 23:12:43 -06:00
parent 8207048c25
commit 6cb0aea1a0
9 changed files with 95 additions and 88 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
Core.Thalos.Provider/Providers/Onboarding/PermissionProvider.cs
View File

@@ -3,15 +3,16 @@
// AgileWebs
// </copyright>
// ***********************************************************************
using Core.Thalos.Adapters;
using Core.Blueprint.Caching.Adapters;
using Core.Blueprint.Caching.Contracts;
using Core.Blueprint.Caching.Helpers;
using Core.Blueprint.Mongo;
//using Core.Blueprint.Redis;
//using Core.Blueprint.Redis.Helpers;
using Core.Thalos.Adapters;
using Core.Thalos.Domain.Contexts.Onboarding.Request;
using Core.Thalos.Provider.Contracts;
using Mapster;
using Microsoft.Extensions.Options;
using MongoDB.Driver;
using Core.Thalos.Provider.Contracts;
using Core.Thalos.Domain.Contexts.Onboarding.Request;
namespace Core.Thalos.Provider.Providers.Onboarding
{
@@ -21,18 +22,18 @@ namespace Core.Thalos.Provider.Providers.Onboarding
public class PermissionProvider : IPermissionProvider
{
private readonly CollectionRepository<PermissionAdapter> repository;
//private readonly CacheSettings cacheSettings;
//private readonly IRedisCacheProvider cacheProvider;
private readonly CacheSettings cacheSettings;
private readonly ICacheProvider cacheProvider;
public PermissionProvider(CollectionRepository<PermissionAdapter> repository
//IRedisCacheProvider cacheProvider,
//IOptions<CacheSettings> cacheSettings
public PermissionProvider(CollectionRepository<PermissionAdapter> repository,
ICacheProvider cacheProvider,
IOptions<CacheSettings> cacheSettings
)
{
this.repository = repository;
this.repository.CollectionInitialization();
//this.cacheSettings = cacheSettings.Value;
//this.cacheProvider = cacheProvider;
this.cacheSettings = cacheSettings.Value;
this.cacheProvider = cacheProvider;
}
/// <summary>
@@ -58,14 +59,14 @@ namespace Core.Thalos.Provider.Providers.Onboarding
/// the asynchronous execution of the service.</returns>0
public async ValueTask<PermissionAdapter> GetPermissionById(string _id, CancellationToken cancellationToken)
{
//var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetPermissionById", _id);
//var cachedData = await cacheProvider.GetAsync<PermissionAdapter>(cacheKey);
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetPermissionById", _id);
var cachedData = await cacheProvider.GetAsync<PermissionAdapter>(cacheKey);
//if (cachedData is not null) { return cachedData; }
var permission = await repository.FindByIdAsync(_id);
//await cacheProvider.SetAsync(cacheKey, permission);
await cacheProvider.SetAsync(cacheKey, permission);
return permission;
}
@@ -77,14 +78,14 @@ namespace Core.Thalos.Provider.Providers.Onboarding
/// the asynchronous execution of the service.</returns>
public async ValueTask<IEnumerable<PermissionAdapter>> GetAllPermissions(CancellationToken cancellationToken)
{
//var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllPermissions");
//var cachedData = await cacheProvider.GetAsync<IEnumerable<PermissionAdapter>>(cacheKey) ?? [];
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllPermissions");
var cachedData = await cacheProvider.GetAsync<IEnumerable<PermissionAdapter>>(cacheKey) ?? [];
//if (cachedData.Any()) return cachedData;
if (cachedData.Any()) return cachedData;
var permissions = await repository.AsQueryable();
//await cacheProvider.SetAsync(cacheKey, permissions);
await cacheProvider.SetAsync(cacheKey, permissions);
return permissions;
}
@@ -97,25 +98,25 @@ namespace Core.Thalos.Provider.Providers.Onboarding
/// the asynchronous execution of the service.</returns>
public async ValueTask<IEnumerable<PermissionAdapter>> GetAllPermissionsByList(string[] permissions, CancellationToken cancellationToken)
{
//var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllPermissionsByList", permissions);
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllPermissionsByList", permissions);
//var cachedData = await cacheProvider.GetAsync<IEnumerable<PermissionAdapter>>(cacheKey) ?? [];
var cachedData = await cacheProvider.GetAsync<IEnumerable<PermissionAdapter>>(cacheKey) ?? [];
//if (cachedData.Any()) return cachedData;
if (cachedData.Any()) return cachedData;
var builder = Builders<PermissionAdapter>.Filter;
var filters = new List<FilterDefinition<PermissionAdapter>>();
if (permissions == null || !permissions.Any())
if (permissions != null || !permissions.Any())
{
filters.Add(builder.In(x => x.Id, permissions));
filters.Add(builder.In(x => x._Id, permissions));
}
var finalFilter = filters.Any() ? builder.And(filters) : builder.Empty;
var permissionsList = await repository.FilterByMongoFilterAsync(finalFilter);
//await cacheProvider.SetAsync(cacheKey, permissionsList);
await cacheProvider.SetAsync(cacheKey, permissionsList);
return permissionsList;
}