Cosmos.EventDriven.CritterStack 0.3.1

Cosmos.EventDriven.CritterStack

Implementaciones de Wolverine para IPublicEventSender e IPrivateEventSender en Cosmos EDA con .NET 10.

Descripción

Este paquete provee las implementaciones concretas de los senders de eventos usando Wolverine como bus de mensajería. Separa explícitamente el envío de eventos públicos (inter-servicio) de los eventos privados (intra-servicio, dentro del mismo bounded context).

Características

• WolverinePublicEventSender: Implementación de IPublicEventSender que publica IPublicEvent a través del bus Wolverine hacia brokers externos (RabbitMQ, Azure Service Bus)
• WolverinePrivateEventSender: Implementación de IPrivateEventSender que despacha IPrivateEvent de forma local dentro del mismo proceso
• AgregarWolverineEventSender: Método de extensión para registrar ambos senders en el contenedor de dependencias

Propagación de identidad

Ambos senders resuelven el tenant y el usuario actuales vía ITenantResolver y los adjuntan a cada evento:

• El TenantId se envía en DeliveryOptions.TenantId; Wolverine lo propaga de forma nativa al IMessageContext del handler receptor.
• El UserId no tiene propagación nativa, por lo que se adjunta como el header user_id del envelope. Del otro lado, WolverineMessageContextTenantResolver (de Cosmos.MultiTenancy.CritterStack) lo lee de ese header.

Como el sender re-lee el UserId del resolver en cada publicación, la identidad se re-propaga automáticamente a lo largo de cadenas de handlers anidados. Si el ITenantResolver no puede resolver el UserId, la publicación lanza InvalidOperationException.

Instalación

dotnet add package Cosmos.EventDriven.CritterStack

Uso

Registrar los senders en DI

builder.Services.AgregarWolverineEventSender();

Enviar un evento público

using Cosmos.EventDriven.Abstractions;

public record PedidoCreado(Guid PedidoId, string ClienteId) : IPublicEvent;

public class MiServicio(IPublicEventSender sender)
{
    public async Task CrearPedido(...)
    {
        // ... lógica de negocio
        await sender.PublishAsync(new PedidoCreado(pedidoId, clienteId));
    }
}

Enviar un evento privado

using Cosmos.EventDriven.Abstractions;

public record StockActualizado(Guid ProductoId, int Cantidad) : IPrivateEvent;

public class InventarioServicio(IPrivateEventSender sender)
{
    public async Task ActualizarStock(...)
    {
        // ... lógica de negocio
        await sender.PublishAsync(new StockActualizado(productoId, cantidad));
    }
}

Requisitos

• .NET 10.0 o superior
• Wolverine configurado en el host (UseWolverine)

Licencia

Copyright © Cosmos. Todos los derechos reservados.