Cosmos.EventDriven.CritterStack 1.2.2

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.

Regla: nada de EDA in-memory

Todo evento que el servicio publica debe tener una ruta a un broker externo configurada dentro de UseWolverine(...):

• RabbitMQ: opts.HabilitarOutboxParaEventosPublicos(serviceName, contratos) y opts.HabilitarOutboxParaEventosPrivados(serviceName, contratos)
• Azure Service Bus: opts.PublicarEvento<TEvento>(topicName) o opts.PublicarEventosServerless(topicName, contratos)

Por qué: si Wolverine no tiene ruta para un evento, lo despacha a una cola local in-memory dentro del mismo proceso. Por esa cola IMessageContext.TenantId no se propaga, y los handlers que dependen de ITenantResolver fallan silenciosamente — el síntoma aparenta ser un bug del resolver cuando en realidad es esta configuración faltante.

Los servicios consumidores — que solo manejan eventos definidos en el assembly de contratos de otro servicio, suscritos vía SuscribirseAServicio — no necesitan declarar rutas de publicación para esos eventos: la regla aplica únicamente a los eventos que el servicio publica.

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.