diff --git a/ShoppingAssistantApi.Infrastructure/Services/Identity/UserManager.cs b/ShoppingAssistantApi.Infrastructure/Services/Identity/UserManager.cs index 7b9024f..22cba2c 100644 --- a/ShoppingAssistantApi.Infrastructure/Services/Identity/UserManager.cs +++ b/ShoppingAssistantApi.Infrastructure/Services/Identity/UserManager.cs @@ -54,8 +54,8 @@ public class UserManager : ServiceBase, IUserManager _logger.LogInformation($"Logging in user with email: {login.Email} and phone: {login.Phone}."); var user = string.IsNullOrEmpty(login.Phone) - ? await this._usersRepository.GetUserAsync(u => u.Email == login.Email && u.IsDeleted == false, cancellationToken) - : await this._usersRepository.GetUserAsync(u => u.Phone == login.Phone && u.IsDeleted == false, cancellationToken); + ? await this._usersRepository.GetUserAsync(u => u.Email == login.Email, cancellationToken) + : await this._usersRepository.GetUserAsync(u => u.Phone == login.Phone, cancellationToken); if (user == null) { throw new EntityNotFoundException(); @@ -79,11 +79,11 @@ public class UserManager : ServiceBase, IUserManager { _logger.LogInformation($"Logging in / Registering guest with guest id: {guest.GuestId}."); - var user = await this._usersRepository.GetUserAsync(x => x.GuestId == guest.GuestId && x.IsDeleted == false, cancellationToken); + var user = await this._usersRepository.GetUserAsync(x => x.GuestId == guest.GuestId, cancellationToken); if (user == null) { - var role = await this._rolesRepository.GetRoleAsync(r => r.Name == "Guest" && r.IsDeleted == false, cancellationToken); + var role = await this._rolesRepository.GetRoleAsync(r => r.Name == "Guest", cancellationToken); user = new User { GuestId = guest.GuestId, @@ -116,7 +116,7 @@ public class UserManager : ServiceBase, IUserManager .GetOneAsync(r => r.Token == tokensModel.RefreshToken && r.CreatedById == userId - && r.IsDeleted == false, cancellationToken); + , cancellationToken); if (refreshTokenModel == null || refreshTokenModel.ExpiryDateUTC < DateTime.UtcNow) { throw new SecurityTokenExpiredException(); @@ -148,7 +148,7 @@ public class UserManager : ServiceBase, IUserManager { _logger.LogInformation($"Adding Role: {roleName} to User with Id: {userId}."); - var role = await this._rolesRepository.GetRoleAsync(r => r.Name == roleName && r.IsDeleted == false, cancellationToken); + var role = await this._rolesRepository.GetRoleAsync(r => r.Name == roleName, cancellationToken); if (role == null) { throw new EntityNotFoundException(); @@ -174,7 +174,7 @@ public class UserManager : ServiceBase, IUserManager { _logger.LogInformation($"Removing Role: {roleName} from User with Id: {userId}."); - var role = await this._rolesRepository.GetRoleAsync(r => r.Name == roleName && r.IsDeleted == false, cancellationToken); + var role = await this._rolesRepository.GetRoleAsync(r => r.Name == roleName, cancellationToken); if (role == null) { throw new EntityNotFoundException(); @@ -202,7 +202,7 @@ public class UserManager : ServiceBase, IUserManager { _logger.LogInformation($"Updating user with id: {GlobalUser.Id}."); - var user = await this._usersRepository.GetUserAsync(x => x.Id == GlobalUser.Id && x.IsDeleted == false, cancellationToken); + var user = await this._usersRepository.GetUserAsync(x => x.Id == GlobalUser.Id, cancellationToken); if (user == null) { throw new EntityNotFoundException(); @@ -314,7 +314,7 @@ public class UserManager : ServiceBase, IUserManager { if (!string.IsNullOrEmpty(user.PasswordHash) && (!string.IsNullOrEmpty(user.Email) || !string.IsNullOrEmpty(user.Phone))) { - var role = await this._rolesRepository.GetRoleAsync(x => x.Name == "User" && x.IsDeleted == false, cancellationToken); + var role = await this._rolesRepository.GetRoleAsync(x => x.Name == "User", cancellationToken); user.Roles.Add(role); } } @@ -326,7 +326,7 @@ public class UserManager : ServiceBase, IUserManager { ValidateEmail(userDto.Email); if (userDto.Email != user.Email - && await this._usersRepository.ExistsAsync(x => x.Email == userDto.Email && x.IsDeleted == false, cancellationToken)) + && await this._usersRepository.ExistsAsync(x => x.Email == userDto.Email, cancellationToken)) { throw new EntityAlreadyExistsException("email", userDto.Email); } @@ -336,7 +336,7 @@ public class UserManager : ServiceBase, IUserManager { ValidatePhone(userDto.Phone); if (userDto.Phone != user.Phone - && await this._usersRepository.ExistsAsync(x => x.Phone == userDto.Phone && x.IsDeleted == false, cancellationToken)) + && await this._usersRepository.ExistsAsync(x => x.Phone == userDto.Phone, cancellationToken)) { throw new EntityAlreadyExistsException("phone", userDto.Phone); } diff --git a/ShoppingAssistantApi.Infrastructure/Services/ProductService.cs b/ShoppingAssistantApi.Infrastructure/Services/ProductService.cs index 532e023..82d6476 100644 --- a/ShoppingAssistantApi.Infrastructure/Services/ProductService.cs +++ b/ShoppingAssistantApi.Infrastructure/Services/ProductService.cs @@ -38,7 +38,7 @@ public class ProductService : IProductService "\n[Products] - return semicolon separated product names"; var countOfMessage = await _messagesRepository - .GetCountAsync(message=>message.WishlistId==ObjectId.Parse((wishlistId)) && message.IsDeleted == false, cancellationToken); + .GetCountAsync(message=>message.WishlistId == ObjectId.Parse((wishlistId)), cancellationToken); var previousMessages = await _wishlistsService .GetMessagesPageFromPersonalWishlistAsync(wishlistId, 1, countOfMessage, cancellationToken); diff --git a/ShoppingAssistantApi.Infrastructure/Services/RolesService.cs b/ShoppingAssistantApi.Infrastructure/Services/RolesService.cs index 31c664c..d30bc3b 100644 --- a/ShoppingAssistantApi.Infrastructure/Services/RolesService.cs +++ b/ShoppingAssistantApi.Infrastructure/Services/RolesService.cs @@ -24,7 +24,7 @@ public class RolesService : IRolesService public async Task AddRoleAsync(RoleCreateDto dto, CancellationToken cancellationToken) { - var role = await this._repository.GetRoleAsync(r => r.Name == dto.Name && r.IsDeleted == false, cancellationToken); + var role = await this._repository.GetRoleAsync(r => r.Name == dto.Name, cancellationToken); if (role != null) { throw new EntityAlreadyExistsException(); diff --git a/ShoppingAssistantApi.Infrastructure/Services/WishlistsService.cs b/ShoppingAssistantApi.Infrastructure/Services/WishlistsService.cs index c1473de..837d991 100644 --- a/ShoppingAssistantApi.Infrastructure/Services/WishlistsService.cs +++ b/ShoppingAssistantApi.Infrastructure/Services/WishlistsService.cs @@ -74,7 +74,7 @@ public class WishlistsService : IWishlistsService var wishlist = await TryGetPersonalWishlist(wishlistObjectId, cancellationToken); var firstUserMessage = - (await _messagesRepository.GetPageAsync(1, 1, x => x.WishlistId == wishlistObjectId && x.Role == MessageRoles.User.ToString() && x.IsDeleted == false, cancellationToken)).First(); + (await _messagesRepository.GetPageAsync(1, 1, x => x.WishlistId == wishlistObjectId && x.Role == MessageRoles.User.ToString(), cancellationToken)).First(); var chatCompletionRequest = new ChatCompletionRequest { @@ -124,7 +124,7 @@ public class WishlistsService : IWishlistsService public async Task> GetPersonalWishlistsPageAsync(int pageNumber, int pageSize, CancellationToken cancellationToken) { - var entities = await _wishlistsRepository.GetPageAsync(pageNumber, pageSize, x => x.CreatedById == GlobalUser.Id && x.IsDeleted == false, cancellationToken); + var entities = await _wishlistsRepository.GetPageAsync(pageNumber, pageSize, x => x.CreatedById == GlobalUser.Id, cancellationToken); var dtos = _mapper.Map>(entities); var count = await _wishlistsRepository.GetTotalCountAsync(); return new PagedList(dtos, pageNumber, pageSize, count); @@ -151,10 +151,10 @@ public class WishlistsService : IWishlistsService await TryGetPersonalWishlist(wishlistObjectId, cancellationToken); - var entities = await _messagesRepository.GetPageStartingFromEndAsync(pageNumber, pageSize, x => x.WishlistId == wishlistObjectId && x.IsDeleted == false, cancellationToken); + var entities = await _messagesRepository.GetPageStartingFromEndAsync(pageNumber, pageSize, x => x.WishlistId == wishlistObjectId, cancellationToken); var dtos = _mapper.Map>(entities); - var count = await _messagesRepository.GetCountAsync(x => x.WishlistId == wishlistObjectId && x.IsDeleted == false, cancellationToken); + var count = await _messagesRepository.GetCountAsync(x => x.WishlistId == wishlistObjectId, cancellationToken); return new PagedList(dtos, pageNumber, pageSize, count); } @@ -187,10 +187,10 @@ public class WishlistsService : IWishlistsService await TryGetPersonalWishlist(wishlistObjectId, cancellationToken); - var entities = await _productsRepository.GetPageAsync(pageNumber, pageSize, x => x.WishlistId == wishlistObjectId && x.IsDeleted == false, cancellationToken); + var entities = await _productsRepository.GetPageAsync(pageNumber, pageSize, x => x.WishlistId == wishlistObjectId, cancellationToken); var dtos = _mapper.Map>(entities); - var count = await _productsRepository.GetCountAsync(x => x.WishlistId == wishlistObjectId && x.IsDeleted == false, cancellationToken); + var count = await _productsRepository.GetCountAsync(x => x.WishlistId == wishlistObjectId, cancellationToken); return new PagedList(dtos, pageNumber, pageSize, count); } @@ -213,7 +213,7 @@ public class WishlistsService : IWishlistsService private async Task TryGetPersonalWishlist(ObjectId wishlistId, CancellationToken cancellationToken) { - var entity = await _wishlistsRepository.GetWishlistAsync(x => x.Id == wishlistId && x.IsDeleted == false, cancellationToken); + var entity = await _wishlistsRepository.GetWishlistAsync(x => x.Id == wishlistId, cancellationToken); if (entity.CreatedById != GlobalUser.Id) { diff --git a/ShoppingAssistantApi.Persistance/PersistanceExtentions/DbInitialaizer.cs b/ShoppingAssistantApi.Persistance/PersistanceExtentions/DbInitialaizer.cs index 0025134..98425a6 100644 --- a/ShoppingAssistantApi.Persistance/PersistanceExtentions/DbInitialaizer.cs +++ b/ShoppingAssistantApi.Persistance/PersistanceExtentions/DbInitialaizer.cs @@ -41,9 +41,9 @@ public class DbInitialaizer public async Task AddUsers(CancellationToken cancellationToken) { - var userRole = await (await _roleCollection.FindAsync(x => x.Name.Equals("User") && x.IsDeleted == false)).FirstAsync(); - var guestRole = await (await _roleCollection.FindAsync(x => x.Name.Equals("Guest") && x.IsDeleted == false)).FirstAsync(); - var adminRole = await (await _roleCollection.FindAsync(x => x.Name.Equals("Admin") && x.IsDeleted == false)).FirstAsync(); + var userRole = await (await _roleCollection.FindAsync(x => x.Name.Equals("User"))).FirstAsync(); + var guestRole = await (await _roleCollection.FindAsync(x => x.Name.Equals("Guest"))).FirstAsync(); + var adminRole = await (await _roleCollection.FindAsync(x => x.Name.Equals("Admin"))).FirstAsync(); var users = new User[] { @@ -179,8 +179,8 @@ public class DbInitialaizer public async Task AddWishlistsWithMessages(CancellationToken cancellationToken) { - var user1 = await (await _userCollection.FindAsync(x => x.Email.Equals("shopping.assistant.team@gmail.com") && x.IsDeleted == false)).FirstAsync(); - var user2 = await (await _userCollection.FindAsync(x => x.Email.Equals("mykhailo.bilodid@nure.ua") && x.IsDeleted == false)).FirstAsync(); + var user1 = await (await _userCollection.FindAsync(x => x.Email.Equals("shopping.assistant.team@gmail.com"))).FirstAsync(); + var user2 = await (await _userCollection.FindAsync(x => x.Email.Equals("mykhailo.bilodid@nure.ua"))).FirstAsync(); var wishlists = new Wishlist[] { diff --git a/ShoppingAssistantApi.Persistance/Repositories/BaseRepository.cs b/ShoppingAssistantApi.Persistance/Repositories/BaseRepository.cs index 7e50eac..e222f77 100644 --- a/ShoppingAssistantApi.Persistance/Repositories/BaseRepository.cs +++ b/ShoppingAssistantApi.Persistance/Repositories/BaseRepository.cs @@ -3,6 +3,7 @@ using MongoDB.Driver; using ShoppingAssistantApi.Application.IRepositories; using ShoppingAssistantApi.Domain.Common; using ShoppingAssistantApi.Persistance.Database; +using System; using System.Linq.Expressions; namespace ShoppingAssistantApi.Persistance.Repositories; @@ -26,7 +27,8 @@ public abstract class BaseRepository : IBaseRepository where T public async Task GetOneAsync(Expression> predicate, CancellationToken cancellationToken) { - return await this._collection.Find(predicate).FirstOrDefaultAsync(cancellationToken); + return await this._collection.Find(Builders.Filter.Where(predicate) & Builders.Filter.Where(x => !x.IsDeleted)) + .FirstOrDefaultAsync(cancellationToken); } public async Task AddAsync(TEntity entity, CancellationToken cancellationToken) @@ -37,7 +39,7 @@ public abstract class BaseRepository : IBaseRepository where T public async Task> GetPageAsync(int pageNumber, int pageSize, CancellationToken cancellationToken) { - return await this._collection.Find(Builders.Filter.Empty) + return await this._collection.Find(Builders.Filter.Where(x => !x.IsDeleted)) .Skip((pageNumber - 1) * pageSize) .Limit(pageSize) .ToListAsync(cancellationToken); @@ -45,7 +47,7 @@ public abstract class BaseRepository : IBaseRepository where T public async Task> GetPageAsync(int pageNumber, int pageSize, Expression> predicate, CancellationToken cancellationToken) { - return await this._collection.Find(predicate) + return await this._collection.Find(Builders.Filter.Where(predicate) & Builders.Filter.Where(x => !x.IsDeleted)) .Skip((pageNumber - 1) * pageSize) .Limit(pageSize) .ToListAsync(cancellationToken); @@ -58,12 +60,12 @@ public abstract class BaseRepository : IBaseRepository where T public async Task GetCountAsync(Expression> predicate, CancellationToken cancellationToken) { - return (int)(await this._collection.CountDocumentsAsync(predicate, cancellationToken: cancellationToken)); + return (int)(await this._collection.CountDocumentsAsync(Builders.Filter.Where(predicate) & Builders.Filter.Where(x => !x.IsDeleted), cancellationToken: cancellationToken)); } public async Task ExistsAsync(Expression> predicate, CancellationToken cancellationToken) { - return await this._collection.Find(predicate).AnyAsync(cancellationToken); + return await this._collection.Find(Builders.Filter.Where(predicate) & Builders.Filter.Where(x => !x.IsDeleted)).AnyAsync(cancellationToken); } public async Task DeleteAsync(TEntity entity, CancellationToken cancellationToken) diff --git a/ShoppingAssistantApi.Persistance/Repositories/MessagesRepository.cs b/ShoppingAssistantApi.Persistance/Repositories/MessagesRepository.cs index 55734c9..1c6368e 100644 --- a/ShoppingAssistantApi.Persistance/Repositories/MessagesRepository.cs +++ b/ShoppingAssistantApi.Persistance/Repositories/MessagesRepository.cs @@ -12,7 +12,7 @@ public class MessagesRepository : BaseRepository, IMessagesRepository public async Task> GetPageStartingFromEndAsync(int pageNumber, int pageSize, Expression> predicate, CancellationToken cancellationToken) { - return await _collection.Find(predicate) + return await _collection.Find(Builders.Filter.Where(predicate) & Builders.Filter.Where(x => !x.IsDeleted)) .SortByDescending(x => x.CreatedDateUtc) .Skip((pageNumber - 1) * pageSize) .Limit(pageSize) diff --git a/ShoppingAssistantApi.Persistance/Repositories/RolesRepository.cs b/ShoppingAssistantApi.Persistance/Repositories/RolesRepository.cs index fae93c2..480a368 100644 --- a/ShoppingAssistantApi.Persistance/Repositories/RolesRepository.cs +++ b/ShoppingAssistantApi.Persistance/Repositories/RolesRepository.cs @@ -18,6 +18,6 @@ public class RolesRepository : BaseRepository, IRolesRepository public async Task GetRoleAsync(Expression> predicate, CancellationToken cancellationToken) { - return await (await this._collection.FindAsync(predicate)).FirstOrDefaultAsync(cancellationToken); + return await (await this._collection.FindAsync(Builders.Filter.Where(predicate) & Builders.Filter.Where(x => !x.IsDeleted))).FirstOrDefaultAsync(cancellationToken); } } \ No newline at end of file diff --git a/ShoppingAssistantApi.Persistance/Repositories/UsersRepository.cs b/ShoppingAssistantApi.Persistance/Repositories/UsersRepository.cs index 07a77f0..459cccd 100644 --- a/ShoppingAssistantApi.Persistance/Repositories/UsersRepository.cs +++ b/ShoppingAssistantApi.Persistance/Repositories/UsersRepository.cs @@ -19,7 +19,7 @@ public class UsersRepository : BaseRepository, IUsersRepository public async Task GetUserAsync(Expression> predicate, CancellationToken cancellationToken) { - return await (await this._collection.FindAsync(predicate)).FirstOrDefaultAsync(cancellationToken); + return await (await this._collection.FindAsync(Builders.Filter.Where(predicate) & Builders.Filter.Where(x => !x.IsDeleted))).FirstOrDefaultAsync(cancellationToken); } public async Task UpdateUserAsync(User user, CancellationToken cancellationToken) @@ -39,6 +39,6 @@ public class UsersRepository : BaseRepository, IUsersRepository }; return await this._collection.FindOneAndUpdateAsync( - Builders.Filter.Eq(u => u.Id, user.Id), updateDefinition, options, cancellationToken); + Builders.Filter.Eq(u => u.Id, user.Id) & Builders.Filter.Where(x => !x.IsDeleted), updateDefinition, options, cancellationToken); } } diff --git a/ShoppingAssistantApi.Persistance/Repositories/WishlistsRepository.cs b/ShoppingAssistantApi.Persistance/Repositories/WishlistsRepository.cs index d015cf8..ec760ba 100644 --- a/ShoppingAssistantApi.Persistance/Repositories/WishlistsRepository.cs +++ b/ShoppingAssistantApi.Persistance/Repositories/WishlistsRepository.cs @@ -13,13 +13,13 @@ public class WishlistsRepository : BaseRepository, IWishlistsRepositor public async Task GetWishlistAsync(Expression> predicate, CancellationToken cancellationToken) { - return await (await _collection.FindAsync(predicate)).FirstOrDefaultAsync(cancellationToken); + return await (await _collection.FindAsync(Builders.Filter.Where(predicate) & Builders.Filter.Where(x => !x.IsDeleted))).FirstOrDefaultAsync(cancellationToken); } public async Task UpdateWishlistNameAsync(ObjectId wishlistId, string newName, ObjectId updatedById, CancellationToken cancellationToken) { - var filterDefinition = Builders.Filter.Eq(w => w.Id, wishlistId); + var filterDefinition = Builders.Filter.Eq(w => w.Id, wishlistId) & Builders.Filter.Where(x => !x.IsDeleted); var updateDefinition = Builders.Update .Set(w => w.Name, newName)