cartaid/shopping-assistant-api
1
0
Fork 0
mirror of https://github.com/Shchoholiev/shopping-assistant-api.git synced 2025-04-11 01:18:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove GlobalUser reference from WishlistRepository

Browse Source
This commit is contained in:
cuqmbr 2023-10-24 07:49:29 +03:00
parent 0d97d552e3
commit 422b6085ce
Signed by: cuqmbr
GPG Key ID: 2D72ED98B6CB200F
3 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ShoppingAssistantApi.Application/IRepositories/IWishlistRepository.cs
View File

@ -8,5 +8,5 @@ public interface IWishlistsRepository : IBaseRepository<Wishlist>
{ {
Task<Wishlist> GetWishlistAsync(Expression<Func<Wishlist, bool>> predicate, CancellationToken cancellationToken); Task<Wishlist> GetWishlistAsync(Expression<Func<Wishlist, bool>> predicate, CancellationToken cancellationToken);
Task<Wishlist> UpdateWishlistNameAsync(ObjectId id, string name, CancellationToken cancellationToken); Task<Wishlist> UpdateWishlistNameAsync(ObjectId id, string name, ObjectId updatedById, CancellationToken cancellationToken);
} }

3
ShoppingAssistantApi.Infrastructure/Services/WishlistsService.cs
View File

@ -94,7 +94,8 @@ public class WishlistsService : IWishlistsService
var openAiMessage = await _openAiService.GetChatCompletion(chatCompletionRequest, cancellationToken); var openAiMessage = await _openAiService.GetChatCompletion(chatCompletionRequest, cancellationToken);
wishlist = await _wishlistsRepository.UpdateWishlistNameAsync(wishlist.Id, openAiMessage.Content, cancellationToken); wishlist = await _wishlistsRepository.UpdateWishlistNameAsync(wishlist.Id,
openAiMessage.Content, (ObjectId) GlobalUser.Id, cancellationToken);
return _mapper.Map<WishlistDto>(wishlist); return _mapper.Map<WishlistDto>(wishlist);
} }

6
ShoppingAssistantApi.Persistance/Repositories/WishlistsRepository.cs
View File

@ -1,7 +1,6 @@
using System.Linq.Expressions; using System.Linq.Expressions;
using MongoDB.Bson; using MongoDB.Bson;
using MongoDB.Driver; using MongoDB.Driver;
using ShoppingAssistantApi.Application.GlobalInstances;
using ShoppingAssistantApi.Application.IRepositories; using ShoppingAssistantApi.Application.IRepositories;
using ShoppingAssistantApi.Domain.Entities; using ShoppingAssistantApi.Domain.Entities;
using ShoppingAssistantApi.Persistance.Database; using ShoppingAssistantApi.Persistance.Database;
@ -17,14 +16,15 @@ public class WishlistsRepository : BaseRepository<Wishlist>, IWishlistsRepositor
return await (await _collection.FindAsync(predicate)).FirstOrDefaultAsync(cancellationToken); return await (await _collection.FindAsync(predicate)).FirstOrDefaultAsync(cancellationToken);
} }
public async Task<Wishlist> UpdateWishlistNameAsync(ObjectId wishlistId, string newName, CancellationToken cancellationToken) public async Task<Wishlist> UpdateWishlistNameAsync(ObjectId wishlistId, string newName,
ObjectId updatedById, CancellationToken cancellationToken)
{ {
var filterDefinition = Builders<Wishlist>.Filter.Eq(w => w.Id, wishlistId); var filterDefinition = Builders<Wishlist>.Filter.Eq(w => w.Id, wishlistId);
var updateDefinition = Builders<Wishlist>.Update var updateDefinition = Builders<Wishlist>.Update
.Set(w => w.Name, newName) .Set(w => w.Name, newName)
.Set(w => w.LastModifiedDateUtc, DateTime.UtcNow) .Set(w => w.LastModifiedDateUtc, DateTime.UtcNow)
.Set(w => w.LastModifiedById, GlobalUser.Id); .Set(w => w.LastModifiedById, updatedById);
var options = new FindOneAndUpdateOptions<Wishlist> var options = new FindOneAndUpdateOptions<Wishlist>
{ {