using Fengling.Backend.Domain.AggregatesModel.GiftAggregate;

namespace Fengling.Backend.Infrastructure.Repositories;

public interface IGiftRepository : IRepository<Gift, GiftId>
{
    Task<Gift?> GetByIdAsync(GiftId giftId, CancellationToken cancellationToken = default);
    Task<List<Gift>> GetOnShelfGiftsAsync(CancellationToken cancellationToken = default);
    Task<List<Gift>> GetByTypeAsync(GiftType type, CancellationToken cancellationToken = default);
}

public class GiftRepository(ApplicationDbContext context)
    : RepositoryBase<Gift, GiftId, ApplicationDbContext>(context), IGiftRepository
{
    public async Task<Gift?> GetByIdAsync(GiftId giftId, CancellationToken cancellationToken = default)
    {
        return await DbContext.Gifts
            .FirstOrDefaultAsync(x => x.Id == giftId, cancellationToken);
    }

    public async Task<List<Gift>> GetOnShelfGiftsAsync(CancellationToken cancellationToken = default)
    {
        return await DbContext.Gifts
            .Where(x => x.IsOnShelf)
            .OrderBy(x => x.SortOrder)
            .ThenByDescending(x => x.CreatedAt)
            .ToListAsync(cancellationToken);
    }

    public async Task<List<Gift>> GetByTypeAsync(GiftType type, CancellationToken cancellationToken = default)
    {
        return await DbContext.Gifts
            .Where(x => x.Type == type && x.IsOnShelf)
            .OrderBy(x => x.SortOrder)
            .ThenByDescending(x => x.CreatedAt)
            .ToListAsync(cancellationToken);
    }
}