Add CancellationToken to repositories

LeftTwixWand · Jul 22, 2023 · c385ec4 · c385ec4
1 parent 86b6a89
commit c385ec4
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 7 deletions.
diff --git a/src/Inventory.Domain/Products/IProductsRepository.cs b/src/Inventory.Domain/Products/IProductsRepository.cs
@@ -7,4 +7,6 @@ public interface IProductsRepository
     Task<Product?> GetByIdAsync(ProductId id, CancellationToken cancellationToken);
 
     Task DeleteByIdAsync(ProductId id, CancellationToken cancellationToken);
+
+    Task DeleteManyByIdAsync(ProductId productId, CancellationToken cancellationToken);
 }
diff --git a/src/Inventory.Domain/Warehouses/IWarehouseRepository.cs b/src/Inventory.Domain/Warehouses/IWarehouseRepository.cs
@@ -3,7 +3,7 @@
 
 namespace Inventory.Persistence.Database.Repositories;
 
-public interface IWarehouseRepository
+public interface IWarehousesRepository
 {
     Task<Warehouse> GetByIdAsync(ProductId productId, CancellationToken cancellationToken);
 

diff --git a/src/Inventory.Infrastructure/Services/DataAccess/ISnapshotsRepository.cs b/src/Inventory.Infrastructure/Services/DataAccess/ISnapshotsRepository.cs
@@ -5,5 +5,5 @@ namespace Inventory.Infrastructure.Services.DataAccess;
 
 internal interface ISnapshotsRepository
 {
-    Task<Snapshot> GetLatestAsync(ProductId productId);
+    Task<Snapshot> GetLatestAsync(ProductId productId, CancellationToken cancellationToken);
 }
diff --git a/src/Inventory.Infrastructure/Services/Domain/WarehouseAccountant.cs b/src/Inventory.Infrastructure/Services/Domain/WarehouseAccountant.cs
@@ -18,10 +18,10 @@ public WarehouseAccountantService(IWarehouseRepository warehouseRepository, ISna
         _snapshotsRepository = snapshotsRepository;
     }
 
-    public async Task<IWarehouseAccountant> GetActualProductQuantityAccountant(ProductId productId)
+    public async Task<IWarehouseAccountant> GetActualProductQuantityAccountant(ProductId productId, CancellationToken cancellationToken)
     {
-        var snapshot = await _snapshotsRepository.GetLatestAsync(productId);
-        var warehouse = await _warehouseRepository.GetByIdAsync(productId, snapshot);
+        var snapshot = await _snapshotsRepository.GetLatestAsync(productId, cancellationToken);
+        var warehouse = await _warehouseRepository.GetByIdAsync(productId, snapshot, cancellationToken);
 
         return new ActualProductQuantityProjection(warehouse.DomainEvents, snapshot);
     }

diff --git a/src/Persistence/Inventory.Persistence.Database/Repositories/IWarehouseRepository.cs b/src/Persistence/Inventory.Persistence.Database/Repositories/IWarehouseRepository.cs
@@ -6,5 +6,5 @@ namespace Inventory.Persistence.Database.Repositories;
 
 public interface IWarehouseRepository
 {
-    Task<Warehouse> GetByIdAsync(ProductId productId, Snapshot snapshot);
+    Task<Warehouse> GetByIdAsync(ProductId productId, Snapshot snapshot, CancellationToken cancellationToken);
 }
diff --git a/src/Persistence/Inventory.Persistence.Database/Repositories/WarehouseRepository.cs b/src/Persistence/Inventory.Persistence.Database/Repositories/WarehouseRepository.cs
@@ -6,7 +6,7 @@ namespace Inventory.Persistence.Database.Repositories;
 
 internal sealed class WarehouseRepository : IWarehouseRepository
 {
-    public Task<Warehouse> GetByIdAsync(ProductId productId, Snapshot snapshot)
+    public Task<Warehouse> GetByIdAsync(ProductId productId, Snapshot snapshot, CancellationToken cancellationToken)
     {
         throw new NotImplementedException();
     }