From f95393623964764655653718d2aa3c2cafbf66c8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Halil=20=C4=B0brahim=20Kalkan?= <hi_kalkan@yahoo.com>
Date: Sat, 16 Oct 2021 12:04:28 +0300
Subject: [PATCH] Use IEventRegistrationRepository in EventRegistrationManager

---
 .../Events/Registrations/EventRegistrationManager.cs | 12 +++++-------
 .../Registrations/IEventRegistrationRepository.cs    |  2 ++
 .../Registrations/EventRegistrationRepository.cs     |  7 +++++++
 3 files changed, 14 insertions(+), 7 deletions(-)

diff --git a/src/EventHub.Domain/Events/Registrations/EventRegistrationManager.cs b/src/EventHub.Domain/Events/Registrations/EventRegistrationManager.cs
index 2938903..152cadc 100644
--- a/src/EventHub.Domain/Events/Registrations/EventRegistrationManager.cs
+++ b/src/EventHub.Domain/Events/Registrations/EventRegistrationManager.cs
@@ -1,7 +1,5 @@
-using System;
-using System.Threading.Tasks;
+using System.Threading.Tasks;
 using Volo.Abp;
-using Volo.Abp.Domain.Repositories;
 using Volo.Abp.Domain.Services;
 using Volo.Abp.Identity;
 
@@ -9,9 +7,9 @@ namespace EventHub.Events.Registrations
 {
     public class EventRegistrationManager : DomainService
     {
-        private readonly IRepository<EventRegistration, Guid> _eventRegistrationRepository;
+        private readonly IEventRegistrationRepository _eventRegistrationRepository;
 
-        public EventRegistrationManager(IRepository<EventRegistration, Guid> eventRegistrationRepository)
+        public EventRegistrationManager(IEventRegistrationRepository eventRegistrationRepository)
         {
             _eventRegistrationRepository = eventRegistrationRepository;
         }
@@ -30,7 +28,7 @@ namespace EventHub.Events.Registrations
                 return;
             }
             
-            var registrationCount = await _eventRegistrationRepository.CountAsync(x => x.EventId == @event.Id);
+            var registrationCount = await _eventRegistrationRepository.GetCountAsync(@event.Id);
 
             if (@event.Capacity != null &&  registrationCount >= @event.Capacity)
             {
@@ -66,7 +64,7 @@ namespace EventHub.Events.Registrations
             IdentityUser user)
         {
             return await _eventRegistrationRepository
-                .AnyAsync(x => x.EventId == @event.Id && x.UserId == user.Id);
+                .ExistsAsync(@event.Id, user.Id);
         }
 
         public bool IsPastEvent(Event @event)
diff --git a/src/EventHub.Domain/Events/Registrations/IEventRegistrationRepository.cs b/src/EventHub.Domain/Events/Registrations/IEventRegistrationRepository.cs
index 6348c29..1593595 100644
--- a/src/EventHub.Domain/Events/Registrations/IEventRegistrationRepository.cs
+++ b/src/EventHub.Domain/Events/Registrations/IEventRegistrationRepository.cs
@@ -17,5 +17,7 @@ namespace EventHub.Events.Registrations
             int maxResultCount = int.MaxValue, 
             CancellationToken cancellationToken = default
         );
+
+        Task<bool> ExistsAsync(Guid eventId, Guid userId);
     }
 }
diff --git a/src/EventHub.EntityFrameworkCore/EntityFrameworkCore/Events/Registrations/EventRegistrationRepository.cs b/src/EventHub.EntityFrameworkCore/EntityFrameworkCore/Events/Registrations/EventRegistrationRepository.cs
index 79807fb..24c1366 100644
--- a/src/EventHub.EntityFrameworkCore/EntityFrameworkCore/Events/Registrations/EventRegistrationRepository.cs
+++ b/src/EventHub.EntityFrameworkCore/EntityFrameworkCore/Events/Registrations/EventRegistrationRepository.cs
@@ -6,6 +6,7 @@ using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.EntityFrameworkCore;
+using Volo.Abp.Domain.Repositories;
 using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
 using Volo.Abp.EntityFrameworkCore;
 using Volo.Abp.Identity;
@@ -57,5 +58,11 @@ namespace EventHub.EntityFrameworkCore.Events.Registrations
 
             return await query.ToListAsync(GetCancellationToken(cancellationToken));
         }
+
+        public async Task<bool> ExistsAsync(Guid eventId, Guid userId)
+        {
+            var dbSet = await GetDbSetAsync();
+            return await dbSet.AnyAsync(x => x.EventId == eventId && x.UserId == userId);
+        }
     }
 }