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

feat: Added Product controller and endpoints

Browse Source 
- updated Core.Adapters.Lib package version
This commit is contained in:
Efra
2025-08-03 17:50:20 -06:00
parent 1f9bae385c
commit a706f96bd8
6 changed files with 535 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

77
Core.Inventory.Provider/Contracts/IProductProvider.cs Normal file
View File

@@ -0,0 +1,77 @@
using Core.Adapters.Lib.Inventory;
using Core.Blueprint.Mongo;
using Core.Inventory.Domain.Contexts.Inventory.Request;
namespace Core.Inventory.Provider.Contracts
{
public interface IProductProvider
{
/// <summary>
/// Creates a new Product.
/// </summary>
/// <param name="entity">The Product to be created.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<ProductAdapter> CreateProduct(ProductRequest newProduct, CancellationToken cancellationToken);
/// <summary>
/// Gets a Product by identifier.
/// </summary>
/// <param name="id">The Product identifier.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<ProductAdapter> GetProductById(string _id, CancellationToken cancellationToken);
/// <summary>
/// Gets all the products.
/// </summary>
/// <returns>A <see cref="{Task{IEnumerable{ProductAdapter}}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<IEnumerable<ProductAdapter>> GetAllProducts(CancellationToken cancellationToken);
/// <summary>
/// Gets all the products by products identifier list.
/// </summary>
/// <param name="products">The list of products identifiers.</param>
/// <returns>A <see cref="Task{IEnumerable{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<IEnumerable<ProductAdapter>> GetAllProductsByList(string[] products, CancellationToken cancellationToken);
/// <summary>
/// Changes the status of the product.
/// </summary>
/// <param name="id">The product identifier.</param>
/// <param name="newStatus">The new status of the product.</param>
/// <returns>The <see cref="ProductAdapter"/> updated entity.</returns>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<ProductAdapter> ChangeProductStatus(string id, ProductStatus newStatus, CancellationToken cancellationToken);
/// <summary>
/// Updates a Product by id.
/// </summary>
/// <param name="entity">The Product to be updated.</param>
/// <param name="id">The Product identifier.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<ProductAdapter> UpdateProduct(ProductAdapter entity, CancellationToken cancellationToken);
/// <summary>
/// Adds a tag to the product.
/// </summary>
/// <param name="productId">The ID of the product.</param>
/// <param name="tagId">The ID of the tag to add.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<ProductAdapter> AddTagToProduct(string productId, string tagId, CancellationToken cancellationToken);
/// <summary>
/// Removes a tag from the product.
/// </summary>
/// <param name="productId">The ID of the product.</param>
/// <param name="tagId">The ID of the tag to remove.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
ValueTask<ProductAdapter> RemoveTagFromProduct(string productId, string tagId, CancellationToken cancellationToken);
}
}

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

@@ -7,7 +7,7 @@
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Adapters.Lib" Version="1.0.10" />
<PackageReference Include="Adapters.Lib" Version="1.0.11" />
<PackageReference Include="Core.Blueprint.Mongo" Version="1.0.0" />
<PackageReference Include="Core.Blueprint.Redis" Version="1.0.2" />
<PackageReference Include="Mapster" Version="7.4.0" />

194
Core.Inventory.Provider/Providers/Inventory/ProductProvider.cs Normal file
View File

@@ -0,0 +1,194 @@
using Core.Adapters.Lib.Inventory;
using Core.Blueprint.Mongo;
using Core.Blueprint.Redis;
using Core.Blueprint.Redis.Helpers;
using Core.Inventory.Domain.Contexts.Inventory.Request;
using Core.Inventory.Provider.Contracts;
using Mapster;
using Microsoft.Extensions.Options;
using MongoDB.Driver;
using MongoDB.Bson;
namespace Core.Inventory.Provider.Providers.Inventory
{
/// <summary>
/// Handles all services and business rules related to <see cref="ProductAdapter"/>.
/// </summary>
public class ProductProvider : IProductProvider
{
private readonly CollectionRepository<ProductAdapter> repository;
private readonly CacheSettings cacheSettings;
private readonly IRedisCacheProvider cacheProvider;
public ProductProvider(CollectionRepository<ProductAdapter> repository,
IRedisCacheProvider cacheProvider,
IOptions<CacheSettings> cacheSettings)
{
this.repository = repository;
this.repository.CollectionInitialization();
this.cacheSettings = cacheSettings.Value;
this.cacheProvider = cacheProvider;
}
/// <summary>
/// Creates a new Product.
/// </summary>
/// <param name="entity">The Product to be created.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<ProductAdapter> CreateProduct(ProductRequest newProduct, CancellationToken cancellationToken)
{
var productCollection = newProduct.Adapt<ProductAdapter>();
await repository.InsertOneAsync(productCollection);
return productCollection;
}
/// <summary>
/// Gets a Product by identifier.
/// </summary>
/// <param name="id">The Product identifier.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<ProductAdapter> GetProductById(string _id, CancellationToken cancellationToken)
{
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetProductById", _id);
var cachedData = await cacheProvider.GetAsync<ProductAdapter>(cacheKey);
if (cachedData is not null) { return cachedData; }
var product = await repository.FindByIdAsync(_id);
await cacheProvider.SetAsync(cacheKey, product);
return product;
}
/// <summary>
/// Gets all the Products.
/// </summary>
/// <returns>A <see cref="{Task{IEnumerable{ProductAdapter}}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<IEnumerable<ProductAdapter>> GetAllProducts(CancellationToken cancellationToken)
{
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetProducts");
var cachedData = await cacheProvider.GetAsync<IEnumerable<ProductAdapter>>(cacheKey) ?? [];
if (cachedData.Any()) return cachedData;
var products = await repository.AsQueryable();
await cacheProvider.SetAsync(cacheKey, products);
return products;
}
/// <summary>
/// Gets all the Products by Products identifier list.
/// </summary>
/// <param name="products">The list of Products identifiers.</param>
/// <returns>A <see cref="Task{IEnumerable{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<IEnumerable<ProductAdapter>> GetAllProductsByList(string[] products, CancellationToken cancellationToken)
{
var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllProductsByList", products);
var cachedData = await cacheProvider.GetAsync<IEnumerable<ProductAdapter>>(cacheKey) ?? [];
if (cachedData.Any()) return cachedData;
var builder = Builders<ProductAdapter>.Filter;
var filters = new List<FilterDefinition<ProductAdapter>>();
if (products != null || !products.Any())
{
filters.Add(builder.In(x => x._Id, products));
}
var finalFilter = filters.Count != 0 ? builder.And(filters) : builder.Empty;
var productsList = await repository.FilterByMongoFilterAsync(finalFilter);
await cacheProvider.SetAsync(cacheKey, productsList);
return productsList;
}
/// <summary>
/// Changes the status of the Product.
/// </summary>
/// <param name="id">The Product identifier.</param>
/// <param name="newStatus">The new status of the Product.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<ProductAdapter> ChangeProductStatus(string id, ProductStatus newStatus, CancellationToken cancellationToken)
{
var entity = await repository.FindByIdAsync(id);
entity.Status = newStatus;
await repository.ReplaceOneAsync(entity);
return entity;
}
/// <summary>
/// Updates a Product by id.
/// </summary>
/// <param name="entity">The Product to be updated.</param>
/// <param name="id">The Product identifier.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<ProductAdapter> UpdateProduct(ProductAdapter entity, CancellationToken cancellationToken)
{
await repository.ReplaceOneAsync(entity);
return entity;
}
/// <summary>
/// Adds a tag to the product.
/// </summary>
/// <param name="productId">The ID of the product.</param>
/// <param name="tagId">The ID of the tag to add.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
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);
if (!product.TagIds.Contains(objectId))
{
product.TagIds.Add(objectId);
await repository.ReplaceOneAsync(product);
}
}
return product;
}
/// <summary>
/// Removes a tag from the product.
/// </summary>
/// <param name="productId">The ID of the product.</param>
/// <param name="tagId">The ID of the tag to remove.</param>
/// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
/// the asynchronous execution of the service.</returns>
public async ValueTask<ProductAdapter> RemoveTagFromProduct(string productId, string tagId, CancellationToken cancellationToken)
{
var product = await repository.FindByIdAsync(productId);
if (product != null)
{
var objectId = ObjectId.Parse(tagId);
product.TagIds.Remove(objectId);
await repository.ReplaceOneAsync(product);
}
return product;
}
}
}

6
Core.Inventory.Provider/ServiceCollectionExtensions.cs
View File

@@ -1,4 +1,5 @@
using Core.Adapters.Lib;
using Core.Adapters.Lib.Inventory;
using Core.Adapters.Lib;
using Core.Blueprint.Mongo;
using Core.Inventory.Provider.Contracts;
using Core.Inventory.Provider.Providers.Inventory;
@@ -23,6 +24,9 @@ namespace Core.Inventory.Provider
services.AddScoped<ITagProvider, TagProvider>();
services.AddScoped<CollectionRepository<TagAdapter>>();
services.AddScoped<IProductProvider, ProductProvider>();
services.AddScoped<CollectionRepository<ProductAdapter>>();
return services;
}