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> { private readonly ISortingExpressionProvider _sortingExpressionProvider; private readonly ITenantRepository _tenantRepository; public GetAllTenantsQueryHandler( ITenantRepository tenantRepository, ISortingExpressionProvider sortingExpressionProvider) { _tenantRepository = tenantRepository; _sortingExpressionProvider = sortingExpressionProvider; } public async Task> Handle( GetAllTenantsQuery request, CancellationToken cancellationToken) { var tenantsQuery = _tenantRepository .GetAllNoTracking() .Include(x => x.Users) .Where(x => request.IncludeDeleted || !x.Deleted); 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( totalCount, tenants, request.Query.Page, request.Query.PageSize); } }