using UserManagement.Data.Dto;
using UserManagement.MediatR.CommandAndQuery;
using UserManagement.Repository;
using MediatR;
using Microsoft.EntityFrameworkCore;
using System.Threading;
using System.Threading.Tasks;
using System;

namespace UserManagement.MediatR.Handlers
{
    public class GetUserNotificationCountQueryHandler : IRequestHandler<GetUserNotificationCountQuery, int>
    {
        private readonly IReminderSchedulerRepository _reminderSchedulerRepository;
        private readonly UserInfoToken _userInfoToken;

        public GetUserNotificationCountQueryHandler(
            IReminderSchedulerRepository reminderSchedulerRepository,
            UserInfoToken userInfoToken)
        {
            _reminderSchedulerRepository = reminderSchedulerRepository;
            _userInfoToken = userInfoToken;
        }
        public async Task<int> Handle(GetUserNotificationCountQuery request, CancellationToken cancellationToken)
        {
            var count = await _reminderSchedulerRepository.All.CountAsync(c => c.UserId == Guid.Parse(_userInfoToken.Id) && !c.IsRead);
            return count;
        }
    }
}