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

Fix cache

Browse Source
This commit is contained in:
Sergio Matias Urquin
2025-09-02 09:32:17 -06:00
parent af51189640
commit b60c6894bc
9 changed files with 24 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Core.Inventory.Provider/Core.Inventory.Provider.csproj
View File

@@ -8,8 +8,8 @@
<ItemGroup>
<PackageReference Include="Core.Adapters.Lib" Version="1.0.0" />
<PackageReference Include="Core.Blueprint.Mongo" Version="1.0.0" />
<PackageReference Include="Core.Blueprint.Redis" Version="1.0.0" />
<PackageReference Include="Core.Blueprint.Mongo" Version="1.0.1" />
<PackageReference Include="Core.Blueprint.Redis" Version="1.0.3" />
<PackageReference Include="Mapster" Version="7.4.0" />
</ItemGroup>

4
Core.Inventory.Provider/Providers/Inventory/FurnitureBaseProvider.cs
View File

@@ -79,7 +79,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
if (cachedData.Any()) return cachedData;
var data = await repository.AsQueryable();
await cacheProvider.SetAsync(cacheKey, data);
await cacheProvider.SetAsync(cacheKey, data, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return data;
}
@@ -97,7 +97,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
if (cached is not null) return cached;
var result = await repository.FindByIdAsync(mongoId);
await cacheProvider.SetAsync(cacheKey, result);
await cacheProvider.SetAsync(cacheKey, result, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return result;
}

8
Core.Inventory.Provider/Providers/Inventory/FurnitureVariantProvider.cs
View File

@@ -84,7 +84,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var variants = await repository.FilterByMongoFilterAsync(filter);
if (variants is not null && variants.Any())
await cacheProvider.SetAsync(cacheKey, variants);
await cacheProvider.SetAsync(cacheKey, variants, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return variants ?? [];
}
@@ -103,7 +103,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
if (cached is not null) return cached;
var result = await repository.FindByIdAsync(mongoId);
await cacheProvider.SetAsync(cacheKey, result);
await cacheProvider.SetAsync(cacheKey, result, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return result;
}
@@ -125,7 +125,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var variants = await repository.FilterByMongoFilterAsync(filter);
if (variants is not null && variants.Any())
await cacheProvider.SetAsync(cacheKey, variants);
await cacheProvider.SetAsync(cacheKey, variants, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return variants ?? [];
}
@@ -157,7 +157,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
if (cachedData.Any()) return cachedData;
var data = await repository.AsQueryable();
await cacheProvider.SetAsync(cacheKey, data);
await cacheProvider.SetAsync(cacheKey, data, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return data;
}

10
Core.Inventory.Provider/Providers/Inventory/ProductProvider.cs
View File

@@ -6,8 +6,8 @@ using Core.Inventory.Domain.Contexts.Inventory.Request;
using Core.Inventory.Provider.Contracts;
using Mapster;
using Microsoft.Extensions.Options;
using MongoDB.Driver;
using MongoDB.Bson;
using MongoDB.Driver;
namespace Core.Inventory.Provider.Providers.Inventory
{
@@ -60,7 +60,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var product = await repository.FindByIdAsync(_id);
await cacheProvider.SetAsync(cacheKey, product);
await cacheProvider.SetAsync(cacheKey, product, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return product;
}
@@ -79,7 +79,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var products = await repository.AsQueryable();
await cacheProvider.SetAsync(cacheKey, products);
await cacheProvider.SetAsync(cacheKey, products, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return products;
}
@@ -110,7 +110,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var productsList = await repository.FilterByMongoFilterAsync(finalFilter);
await cacheProvider.SetAsync(cacheKey, productsList);
await cacheProvider.SetAsync(cacheKey, productsList, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return productsList;
}
@@ -156,7 +156,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
public async ValueTask<ProductAdapter> AddTagToProduct(string productId, string tagId, CancellationToken cancellationToken)
{
var product = await repository.FindByIdAsync(productId);
if (product != null)
{
var objectId = ObjectId.Parse(tagId);

6
Core.Inventory.Provider/Providers/Inventory/TagOverrideProvider.cs
View File

@@ -59,7 +59,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var TagOverride = await repository.FindByIdAsync(_id);
await cacheProvider.SetAsync(cacheKey, TagOverride);
await cacheProvider.SetAsync(cacheKey, TagOverride, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return TagOverride;
}
@@ -78,7 +78,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var TagOverrides = await repository.AsQueryable();
await cacheProvider.SetAsync(cacheKey, TagOverrides);
await cacheProvider.SetAsync(cacheKey, TagOverrides, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return TagOverrides;
}
@@ -109,7 +109,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var TagOverridesList = await repository.FilterByMongoFilterAsync(finalFilter);
await cacheProvider.SetAsync(cacheKey, TagOverridesList);
await cacheProvider.SetAsync(cacheKey, TagOverridesList, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return TagOverridesList;
}

6
Core.Inventory.Provider/Providers/Inventory/TagProvider.cs
View File

@@ -59,7 +59,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var tag = await repository.FindByIdAsync(_id);
await cacheProvider.SetAsync(cacheKey, tag);
await cacheProvider.SetAsync(cacheKey, tag, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return tag;
}
@@ -78,7 +78,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var tags = await repository.AsQueryable();
await cacheProvider.SetAsync(cacheKey, tags);
await cacheProvider.SetAsync(cacheKey, tags, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return tags;
}
@@ -109,7 +109,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var TagsList = await repository.FilterByMongoFilterAsync(finalFilter);
await cacheProvider.SetAsync(cacheKey, TagsList);
await cacheProvider.SetAsync(cacheKey, TagsList, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return TagsList;
}

7
Core.Inventory.Provider/Providers/Inventory/TagTypeProvider.cs
View File

@@ -7,7 +7,6 @@ using Core.Inventory.Provider.Contracts;
using Mapster;
using Microsoft.Extensions.Options;
using MongoDB.Driver;
using System.Security.Cryptography;
namespace Core.Inventory.Provider.Providers.Inventory
{
@@ -60,7 +59,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var tagType = await repository.FindByIdAsync(_id);
await cacheProvider.SetAsync(cacheKey, tagType);
await cacheProvider.SetAsync(cacheKey, tagType, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return tagType;
}
@@ -79,7 +78,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var tagTypes = await repository.AsQueryable();
await cacheProvider.SetAsync(cacheKey, tagTypes);
await cacheProvider.SetAsync(cacheKey, tagTypes, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return tagTypes;
}
@@ -110,7 +109,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
var tagTypesList = await repository.FilterByMongoFilterAsync(finalFilter);
await cacheProvider.SetAsync(cacheKey, tagTypesList);
await cacheProvider.SetAsync(cacheKey, tagTypesList, TimeSpan.FromMinutes(cacheSettings.DefaultCacheDurationInMinutes));
return tagTypesList;
}