CleanArchitecture/CleanArchitecture.Application/Queries/Tenants/GetAll/GetAllTenantsQueryHandler.cs

using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using CleanArchitecture.Application.Extensions;
using CleanArchitecture.Application.ViewModels;
using CleanArchitecture.Application.ViewModels.Sorting;
using CleanArchitecture.Application.ViewModels.Tenants;
using CleanArchitecture.Domain.Entities;
using CleanArchitecture.Domain.Interfaces.Repositories;
using MediatR;
using Microsoft.EntityFrameworkCore;

namespace CleanArchitecture.Application.Queries.Tenants.GetAll;

public sealed class GetAllTenantsQueryHandler :
    IRequestHandler<GetAllTenantsQuery, PagedResult<TenantViewModel>>
{
    private readonly ISortingExpressionProvider<TenantViewModel, Tenant> _sortingExpressionProvider;
    private readonly ITenantRepository _tenantRepository;

    public GetAllTenantsQueryHandler(
        ITenantRepository tenantRepository,
        ISortingExpressionProvider<TenantViewModel, Tenant> sortingExpressionProvider)
    {
        _tenantRepository = tenantRepository;
        _sortingExpressionProvider = sortingExpressionProvider;
    }

    public async Task<PagedResult<TenantViewModel>> Handle(
        GetAllTenantsQuery request,
        CancellationToken cancellationToken)
    {
        var tenantsQuery = _tenantRepository
            .GetAllNoTracking()
            .IgnoreQueryFilters()
            .Include(x => x.Users.Where(y => request.IncludeDeleted || y.DeletedAt == null))
            .Where(x => request.IncludeDeleted || x.DeletedAt == null );

        if (!string.IsNullOrWhiteSpace(request.SearchTerm))
        {
            tenantsQuery = tenantsQuery.Where(tenant =>
                tenant.Name.Contains(request.SearchTerm));
        }

        var totalCount = await tenantsQuery.CountAsync(cancellationToken);

        tenantsQuery = tenantsQuery.GetOrderedQueryable(request.SortQuery, _sortingExpressionProvider);

        var tenants = await tenantsQuery
            .Skip((request.Query.Page - 1) * request.Query.PageSize)
            .Take(request.Query.PageSize)
            .Select(tenant => TenantViewModel.FromTenant(tenant))
            .ToListAsync(cancellationToken);

        return new PagedResult<TenantViewModel>(
            totalCount, tenants, request.Query.Page, request.Query.PageSize);
    }
}