Cosmos.EventSourcing.Linq.Extensions 0.0.5

Cosmos.EventSourcing.Linq.Extensions

Extensiones de LINQ para trabajar con IQueryable de forma asíncrona, optimizadas para Marten.

Descripción

Este paquete proporciona métodos de extensión que permiten realizar operaciones LINQ de manera asíncrona sobre colecciones IQueryable. Es especialmente útil cuando trabajas con proyecciones y consultas en aplicaciones con Event Sourcing usando Marten.

Características

• ToListAsync: Convierte un IQueryable<T> a una lista de forma asíncrona
• AnyAsync: Verifica la existencia de elementos de forma asíncrona
• AnyAsync con predicado: Verifica la existencia de elementos que cumplan una condición
• Compatible con Marten IQueryable
• Soporte para CancellationToken

Instalación

dotnet add package Cosmos.EventSourcing.Linq.Extensions

Uso

ToListAsync

Convierte una consulta en una lista de forma asíncrona:

using Cosmos.EventSourcing.Linq.Extensions;
using Marten;

public class ProductQueryService
{
    private readonly IDocumentSession _session;

    public ProductQueryService(IDocumentSession session)
    {
        _session = session;
    }

    public async Task<IReadOnlyList<Product>> GetActiveProductsAsync(CancellationToken ct)
    {
        var products = await _session
            .Query<Product>()
            .Where(p => p.IsActive)
            .OrderBy(p => p.Name)
            .ToListAsync(ct);

        return products;
    }
}

AnyAsync

Verifica si existen elementos en la consulta:

public async Task<bool> HasActiveProductsAsync(CancellationToken ct)
{
    var hasProducts = await _session
        .Query<Product>()
        .Where(p => p.IsActive)
        .AnyAsync(ct);

    return hasProducts;
}

AnyAsync con Predicado

Verifica si existen elementos que cumplan una condición:

public async Task<bool> HasProductsInCategoryAsync(string categoryId, CancellationToken ct)
{
    var hasProducts = await _session
        .Query<Product>()
        .AnyAsync(p => p.CategoryId == categoryId && p.IsActive, ct);

    return hasProducts;
}

Ejemplo Completo

using Cosmos.EventSourcing.Linq.Extensions;
using Marten;

public class OrderQueryService
{
    private readonly IDocumentSession _session;

    public OrderQueryService(IDocumentSession session)
    {
        _session = session;
    }

    public async Task<IReadOnlyList<Order>> GetPendingOrdersAsync(CancellationToken ct)
    {
        // Verificar si hay órdenes pendientes
        var hasPendingOrders = await _session
            .Query<Order>()
            .AnyAsync(o => o.Status == OrderStatus.Pending, ct);

        if (!hasPendingOrders)
        {
            return Array.Empty<Order>();
        }

        // Obtener todas las órdenes pendientes
        var orders = await _session
            .Query<Order>()
            .Where(o => o.Status == OrderStatus.Pending)
            .OrderBy(o => o.CreatedAt)
            .ToListAsync(ct);

        return orders;
    }

    public async Task<IReadOnlyList<Order>> GetRecentOrdersByCustomerAsync(
        string customerId,
        CancellationToken ct)
    {
        var recentOrders = await _session
            .Query<Order>()
            .Where(o => o.CustomerId == customerId)
            .OrderByDescending(o => o.CreatedAt)
            .Take(10)
            .ToListAsync(ct);

        return recentOrders;
    }
}

Ventajas

• Asincronía: Evita bloquear el thread mientras se ejecutan consultas a la base de datos
• Cancelación: Soporte completo para CancellationToken
• Compatibilidad: Funciona perfectamente con Marten y sus IQueryable
• Simplicidad: API familiar para desarrolladores que conocen LINQ

Compatibilidad con Marten

Este paquete está diseñado para trabajar con Marten, una librería de Document Database y Event Store para PostgreSQL. Las extensiones delegan internamente a las implementaciones de Marten, proporcionando una API más simple y consistente.

Requisitos

• .NET 10.0 o superior

Dependencias

• Marten (v8.16.1)

Licencia

Copyright © Cosmos. Todos los derechos reservados.