Refactored WarehouseProduct

PyroFetes/Endpoints/WareHouseProducts/GetTotalQuantityEndpoint.cs

@@ -2,6 +2,8 @@
 using Microsoft.EntityFrameworkCore;
 using PyroFetes.DTO.WareHouseProduct.Response;
 using PyroFetes.Models;
+using PyroFetes.Repositories;
+using PyroFetes.Specifications.WarehouseProducts;
 
 namespace PyroFetes.Endpoints.WareHouseProducts;
 
@@ -10,7 +12,8 @@ public class GetTotalQuantityRequest
     public int ProductId { get; set; }
 }
 
-public class GetTotalQuantityEndpoint(PyroFetesDbContext database) : Endpoint<GetTotalQuantityRequest, GetTotalQuantityDto>
+public class GetTotalQuantityEndpoint(
+    WarehouseProductsRepository warehouseProductsRepository) : Endpoint<GetTotalQuantityRequest, GetTotalQuantityDto>
 {
     public override void Configure()
     {
@@ -20,8 +23,7 @@ public class GetTotalQuantityEndpoint(PyroFetesDbContext database) : Endpoint<Ge
     
     public override async Task HandleAsync(GetTotalQuantityRequest req, CancellationToken ct)
     {
-        bool exists = await database.WarehouseProducts
-            .AnyAsync(wp => wp.ProductId == req.ProductId, ct);
+        bool exists = await warehouseProductsRepository.AnyAsync(new GetWarehouseProductByProductIdSpec(req.ProductId), ct);
 
         if (!exists)
         {
@@ -29,9 +31,9 @@ public class GetTotalQuantityEndpoint(PyroFetesDbContext database) : Endpoint<Ge
             return;
         }
         
-        int totalQuantity = await database.WarehouseProducts
-            .Where(wp => wp.ProductId == req.ProductId)
-            .SumAsync(wp => wp.Quantity, ct);
+        int totalQuantity =
+            await warehouseProductsRepository.SumAsync(new GetProductTotalQuantitySpec(req.ProductId),
+                wp => wp.Quantity, ct); 
 
         GetTotalQuantityDto responseDto = new()
         {

PyroFetes/Program.cs

@@ -31,6 +31,7 @@ builder.Services.AddScoped<QuotationsRepository>();
 builder.Services.AddScoped<SuppliersRepository>();
 builder.Services.AddScoped<SettingsRepository>();
 builder.Services.AddScoped<UsersRepository>();
+builder.Services.AddScoped<WarehouseProductsRepository>();
 
 MapperConfiguration mappingConfig = new(mc =>
 {

PyroFetes/Repositories/PyrofetesRepository.cs

@@ -59,9 +59,9 @@ public class PyrofetesRepository<T>(DbContext databaseContext, AutoMapper.IMappe
     /// <param name="selector"></param>
     /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    public async Task<decimal> SumAsync(
+    public async Task<int> SumAsync(
         ISpecification<T> specification,
-        Expression<Func<T, decimal>> selector,
+        Expression<Func<T, int>> selector,
         CancellationToken cancellationToken = default)
     {
         return await ApplySpecification(specification).SumAsync(selector, cancellationToken);

PyroFetes/Repositories/WarehouseProductsRepository.cs

@@ -0,0 +1,5 @@
+using PyroFetes.Models;
+
+namespace PyroFetes.Repositories;
+
+public class WarehouseProductsRepository(PyroFetesDbContext pyrofetesContext, AutoMapper.IMapper mapper) : PyrofetesRepository<WarehouseProduct>(pyrofetesContext, mapper);

PyroFetes/Specifications/WarehouseProducts/GetProductTotalQuantitySpec.cs

@@ -0,0 +1,14 @@
+using Ardalis.Specification;
+using PyroFetes.Models;
+
+namespace PyroFetes.Specifications.WarehouseProducts;
+
+public sealed class GetProductTotalQuantitySpec : Specification<WarehouseProduct>
+{
+    public GetProductTotalQuantitySpec(int productId)
+    {
+        Query
+            .Where(wp => wp.ProductId == productId);
+        
+    }
+}

PyroFetes/Specifications/WarehouseProducts/GetWarehouseProductByProductIdSpec.cs

@@ -0,0 +1,13 @@
+using Ardalis.Specification;
+using PyroFetes.Models;
+
+namespace PyroFetes.Specifications.WarehouseProducts;
+
+public sealed class GetWarehouseProductByProductIdSpec : Specification<WarehouseProduct>
+{
+    public GetWarehouseProductByProductIdSpec(int productId)
+    {
+        Query
+            .Where(x => x.ProductId == productId);
+    }
+}