Changeset 95d80e4 for src/FinkiChattery/FinkiChattery.Commands/Questioning/AskQuestion/AskQuestionCommand.cs

Timestamp:

10/21/21 19:16:53 (3 years ago)

Author:

Стојков Марко <mst@…>

Branches:

dev

Children:

3b395c5

Parents:

9885bee

Message:

Added unit of work pattern

File:

• src/FinkiChattery/FinkiChattery.Commands/Questioning/AskQuestion/AskQuestionCommand.cs (modified) (3 diffs)

src/FinkiChattery/FinkiChattery.Commands/Questioning/AskQuestion/AskQuestionCommand.cs

@@ -1 +1 @@
 using FinkiChattery.Common.Mediator.Contracs;
 using FinkiChattery.Common.User;
-using FinkiChattery.Persistence.Context;
 using FinkiChattery.Persistence.Models;
-using FinkiChattery.Persistence.Repositories;
+using FinkiChattery.Persistence.UnitOfWork;
 using System;
 using System.Collections.Generic;
@@ -27 +26 @@
     public class AskQuestionHandler : ICommandHandler<AskQuestionCommand, Guid>
     {
-        public AskQuestionHandler(ApplicationDbContext dbContext, ICategoriesRepo categoriesRepo, IStudentRepo studentRepo, ICurrentUser currentUser)
+        public AskQuestionHandler(IUnitOfWork unitOfWork, ICurrentUser currentUser)
         {
-            DbContext = dbContext;
-            CategoriesRepo = categoriesRepo;
-            StudentRepo = studentRepo;
+            UnitOfWork = unitOfWork;
             CurrentUser = currentUser;
         }
 
-        public ApplicationDbContext DbContext { get; }
-        public ICategoriesRepo CategoriesRepo { get; }
-        public IStudentRepo StudentRepo { get; }
+        public IUnitOfWork UnitOfWork { get; }
         public ICurrentUser CurrentUser { get; }
 
         public async Task<Guid> Handle(AskQuestionCommand request, CancellationToken cancellationToken)
         {
-            var questionCategories = await CategoriesRepo.GetCategories(request.Categories);
-            var currentStudent = await StudentRepo.GetStudent(CurrentUser.Id);
+            var questionCategories = await UnitOfWork.Categories.GetCategories(request.Categories);
+            var currentStudent = await UnitOfWork.Students.GetStudent(CurrentUser.Id);
 
             var questionDatabaseEntity = new Question()
@@ -60 +55 @@
             }
 
-            DbContext.Questions.Add(questionDatabaseEntity);
-            await DbContext.SaveChangesAsync();
+            UnitOfWork.Questions.Add(questionDatabaseEntity);
+            await UnitOfWork.SaveAsync();
             return questionDatabaseEntity.Uid;
         }