refactor: introduce IFaqRepository and update FAQ command handlers to use it

Author: ahmed12348

backend/src/CCE.Application/PlatformSettings/Commands/CreateFaq/CreateFaqCommandHandler.cs

@@ -11,17 +11,20 @@ namespace CCE.Application.PlatformSettings.Commands.CreateFaq;
 public sealed class CreateFaqCommandHandler
     : IRequestHandler<CreateFaqCommand, Response<System.Guid>>
 {
+    private readonly IFaqRepository _repo;
     private readonly ICceDbContext _db;
     private readonly MessageFactory _msg;
     private readonly ICurrentUserAccessor _currentUser;
     private readonly ISystemClock _clock;
 
     public CreateFaqCommandHandler(
+        IFaqRepository repo,
         ICceDbContext db,
         MessageFactory msg,
         ICurrentUserAccessor currentUser,
         ISystemClock clock)
     {
+        _repo = repo;
         _db = db;
         _msg = msg;
         _currentUser = currentUser;
@@ -37,7 +40,7 @@ public CreateFaqCommandHandler(
         var answer = LocalizedText.Create(request.AnswerAr, request.AnswerEn);
 
         var faq = Faq.Create(question, answer, request.Order, userId, _clock);
-        _db.Add(faq);
+        _repo.Add(faq);
         await _db.SaveChangesAsync(cancellationToken).ConfigureAwait(false);
 
         return _msg.Ok(faq.Id, "CONTENT_CREATED");

backend/src/CCE.Application/PlatformSettings/Commands/DeleteFaq/DeleteFaqCommandHandler.cs

@@ -2,33 +2,33 @@
 using CCE.Application.Common.Interfaces;
 using CCE.Application.Messages;
 using MediatR;
-using Microsoft.EntityFrameworkCore;
 
 namespace CCE.Application.PlatformSettings.Commands.DeleteFaq;
 
 public sealed class DeleteFaqCommandHandler
     : IRequestHandler<DeleteFaqCommand, Response<VoidData>>
 {
+    private readonly IFaqRepository _repo;
     private readonly ICceDbContext _db;
     private readonly MessageFactory _msg;
 
-    public DeleteFaqCommandHandler(ICceDbContext db, MessageFactory msg)
+    public DeleteFaqCommandHandler(IFaqRepository repo, ICceDbContext db, MessageFactory msg)
     {
+        _repo = repo;
         _db = db;
         _msg = msg;
     }
 
     public async Task<Response<VoidData>> Handle(
         DeleteFaqCommand request, CancellationToken cancellationToken)
     {
-        var faq = await _db.Faqs
-            .FirstOrDefaultAsync(f => f.Id == request.Id, cancellationToken)
+        var faq = await _repo.GetByIdAsync(request.Id, cancellationToken)
             .ConfigureAwait(false);
 
         if (faq is null)
             return _msg.FaqNotFound<VoidData>();
 
-        _db.Delete(faq);
+        _repo.Delete(faq);
         await _db.SaveChangesAsync(cancellationToken).ConfigureAwait(false);
 
         return _msg.Ok("CONTENT_DELETED");

backend/src/CCE.Application/PlatformSettings/Commands/UpdateFaq/UpdateFaqCommandHandler.cs

@@ -5,24 +5,26 @@
 using CCE.Domain.PlatformSettings;
 using CCE.Domain.PlatformSettings.ValueObjects;
 using MediatR;
-using Microsoft.EntityFrameworkCore;
 
 namespace CCE.Application.PlatformSettings.Commands.UpdateFaq;
 
 public sealed class UpdateFaqCommandHandler
     : IRequestHandler<UpdateFaqCommand, Response<System.Guid>>
 {
+    private readonly IFaqRepository _repo;
     private readonly ICceDbContext _db;
     private readonly MessageFactory _msg;
     private readonly ICurrentUserAccessor _currentUser;
     private readonly ISystemClock _clock;
 
     public UpdateFaqCommandHandler(
+        IFaqRepository repo,
         ICceDbContext db,
         MessageFactory msg,
         ICurrentUserAccessor currentUser,
         ISystemClock clock)
     {
+        _repo = repo;
         _db = db;
         _msg = msg;
         _currentUser = currentUser;
@@ -32,8 +34,7 @@ public UpdateFaqCommandHandler(
     public async Task<Response<System.Guid>> Handle(
         UpdateFaqCommand request, CancellationToken cancellationToken)
     {
-        var faq = await _db.Faqs
-            .FirstOrDefaultAsync(f => f.Id == request.Id, cancellationToken)
+        var faq = await _repo.GetByIdAsync(request.Id, cancellationToken)
             .ConfigureAwait(false);
 
         if (faq is null)

backend/src/CCE.Application/PlatformSettings/IFaqRepository.cs

@@ -0,0 +1,11 @@
+using CCE.Domain.PlatformSettings;
+
+namespace CCE.Application.PlatformSettings;
+
+/// <summary>Repository for the standalone FAQ entity.</summary>
+public interface IFaqRepository
+{
+    Task<Faq?> GetByIdAsync(System.Guid id, CancellationToken ct);
+    void Add(Faq faq);
+    void Delete(Faq faq);
+}

backend/src/CCE.Infrastructure/PlatformSettings/FaqRepository.cs

@@ -0,0 +1,22 @@
+using CCE.Application.PlatformSettings;
+using CCE.Domain.PlatformSettings;
+using CCE.Infrastructure.Persistence;
+using Microsoft.EntityFrameworkCore;
+
+namespace CCE.Infrastructure.PlatformSettings;
+
+public sealed class FaqRepository : IFaqRepository
+{
+    private readonly CceDbContext _db;
+
+    public FaqRepository(CceDbContext db) => _db = db;
+
+    public async Task<Faq?> GetByIdAsync(System.Guid id, CancellationToken ct)
+        => await _db.Faqs
+            .FirstOrDefaultAsync(f => f.Id == id, ct)
+            .ConfigureAwait(false);
+
+    public void Add(Faq faq) => _db.Faqs.Add(faq);
+
+    public void Delete(Faq faq) => _db.Faqs.Remove(faq);
+}