Tests.cs


// ReSharper disable ArrangeObjectCreationWhenTypeNotEvident
// ReSharper disable MethodSupportsCancellation

public class Tests
{
    #region HandlerTest

    [Fact]
    public async Task HandlerTest()
    {
        var context = new RecordingCommandProcessor();
        var handler = new Handler(context);
        await handler.HandleAsync(new Message("value"));
        await Verify(context);
    }

    #endregion

    [Fact]
    public async Task AllTest()
    {
        var context = new RecordingCommandProcessor();
        var handler = new AllHandler(context);
        await handler.HandleAsync(new Message("value"));
        await Verify(context);
    }
}

#region Handler

public class Handler(IAmACommandProcessor processor) :
    RequestHandlerAsync<Message>
{
    public override async Task<Message> HandleAsync(
        Message message,
        Cancel cancel = default)
    {
        await processor.SendAsync(new MyCommand("Some data"));
        await processor.PublishAsync(new MyEvent("Some other data"));

        return await base.HandleAsync(message);
    }
}

#endregion

public class AllHandler(RecordingCommandProcessor processor) :
    RequestHandlerAsync<Message>
{
    public override Task<Message> HandleAsync(Message message, Cancel cancel = default)
    {
        processor.Send(new Response("Send Value"));
        processor.Post(new Response("Post Value"));
        processor.Publish(new Response("Publish Value"));
        processor.DepositPost(new Response("Publish Value"));
        processor.ClearOutbox([]);
        processor.Call<Call, Response>(new Call(), null, TimeSpan.FromHours(1));
        return base.HandleAsync(message);
    }
}

public class Call :
    ICall
{
    public Id? CorrelationId { get; set; }
    public Id Id { get; set; } = Id.Random();
    public Activity Span { get; set; } = null!;
    public ReplyAddress ReplyAddress { get; } = null!;
}