(#271) Semantic/Vector Search

Author: phongnguyend

src/Monolith/ClassifiedAds.Application/Common/Commands/AddEntityCommand.cs

@@ -28,6 +28,6 @@ public AddEntityCommandHandler(ICrudService<TEntity> crudService)
 
     public async Task HandleAsync(AddEntityCommand<TEntity> command, CancellationToken cancellationToken = default)
     {
-        await _crudService.AddAsync(command.Entity);
+        await _crudService.AddAsync(command.Entity, cancellationToken);
     }
 }

src/Monolith/ClassifiedAds.Application/Common/Commands/AddOrUpdateEntityCommand.cs

@@ -28,6 +28,6 @@ public AddOrUpdateEntityCommandHandler(ICrudService<TEntity> crudService)
 
     public async Task HandleAsync(AddOrUpdateEntityCommand<TEntity> command, CancellationToken cancellationToken = default)
     {
-        await _crudService.AddOrUpdateAsync(command.Entity);
+        await _crudService.AddOrUpdateAsync(command.Entity, cancellationToken);
     }
 }

src/Monolith/ClassifiedAds.Application/Common/Commands/DeleteEntityCommand.cs

@@ -23,6 +23,6 @@ public DeleteEntityCommandHandler(ICrudService<TEntity> crudService)
 
     public async Task HandleAsync(DeleteEntityCommand<TEntity> command, CancellationToken cancellationToken = default)
     {
-        await _crudService.DeleteAsync(command.Entity);
+        await _crudService.DeleteAsync(command.Entity, cancellationToken);
     }
 }

src/Monolith/ClassifiedAds.Application/Common/Commands/UpdateEntityCommand.cs

@@ -28,6 +28,6 @@ public UpdateEntityCommandHandler(ICrudService<TEntity> crudService)
 
     public async Task HandleAsync(UpdateEntityCommand<TEntity> command, CancellationToken cancellationToken = default)
     {
-        await _crudService.UpdateAsync(command.Entity);
+        await _crudService.UpdateAsync(command.Entity, cancellationToken);
     }
 }

src/Monolith/ClassifiedAds.Application/Products/Commands/AddUpdateProductCommand.cs

@@ -25,7 +25,7 @@ public async Task HandleAsync(AddUpdateProductCommand command, CancellationToken
     {
         using (await _unitOfWork.BeginTransactionAsync(System.Data.IsolationLevel.ReadCommitted, cancellationToken))
         {
-            await _productService.AddOrUpdateAsync(command.Product);
+            await _productService.AddOrUpdateAsync(command.Product, cancellationToken);
 
             await _unitOfWork.CommitTransactionAsync(cancellationToken);
         }

src/Monolith/ClassifiedAds.Application/Products/Commands/DeleteProductCommand.cs

@@ -20,6 +20,6 @@ public DeleteProductCommandHandler(ICrudService<Product> productService)
 
     public async Task HandleAsync(DeleteProductCommand command, CancellationToken cancellationToken = default)
     {
-        await _productService.DeleteAsync(command.Product);
+        await _productService.DeleteAsync(command.Product, cancellationToken);
     }
 }

src/Monolith/ClassifiedAds.Application/Roles/Commands/AddClaimCommand.cs

@@ -23,6 +23,6 @@ public AddClaimCommandHandler(IRoleRepository roleRepository)
     public async Task HandleAsync(AddClaimCommand command, CancellationToken cancellationToken = default)
     {
         command.Role.Claims.Add(command.Claim);
-        await _roleRepository.UnitOfWork.SaveChangesAsync();
+        await _roleRepository.UnitOfWork.SaveChangesAsync(cancellationToken);
     }
 }

src/Monolith/ClassifiedAds.Application/Roles/Commands/AddUpdateRoleCommand .cs

@@ -21,7 +21,7 @@ public AddUpdateRoleCommandHandler(IRoleRepository roleRepository)
 
     public async Task HandleAsync(AddUpdateRoleCommand command, CancellationToken cancellationToken = default)
     {
-        await _roleRepository.AddOrUpdateAsync(command.Role);
-        await _roleRepository.UnitOfWork.SaveChangesAsync();
+        await _roleRepository.AddOrUpdateAsync(command.Role, cancellationToken);
+        await _roleRepository.UnitOfWork.SaveChangesAsync(cancellationToken);
     }
 }

src/Monolith/ClassifiedAds.Application/Roles/Commands/DeleteClaimCommand.cs

@@ -23,6 +23,6 @@ public DeleteClaimCommandHandler(IRoleRepository roleRepository)
     public async Task HandleAsync(DeleteClaimCommand command, CancellationToken cancellationToken = default)
     {
         command.Role.Claims.Remove(command.Claim);
-        await _roleRepository.UnitOfWork.SaveChangesAsync();
+        await _roleRepository.UnitOfWork.SaveChangesAsync(cancellationToken);
     }
 }

src/Monolith/ClassifiedAds.Application/Roles/Commands/DeleteRoleCommand.cs

@@ -22,6 +22,6 @@ public DeleteRoleCommandHandler(IRoleRepository roleRepository)
     public async Task HandleAsync(DeleteRoleCommand command, CancellationToken cancellationToken = default)
     {
         _roleRepository.Delete(command.Role);
-        await _roleRepository.UnitOfWork.SaveChangesAsync();
+        await _roleRepository.UnitOfWork.SaveChangesAsync(cancellationToken);
     }
 }