28702836619

Committed 04 Jul 2026 10:06AM UTC coverage: 17.028% (+0.8%) from 16.207%

Build # 28702836619

Build Type

Pull #254

github

Committed by

web-flow

Commit Message

Merge bff19f2e6 into ed20d3c08

Pull Request Pull Request #254: feat: :sparkles: add inbox, outbox and internal processor by wolverine

Coverage Stats

379 of 3330 branches covered (11.38%)

Branch coverage included in aggregate %.

19 of 61 new or added lines in 12 files covered. (31.15%)

29 existing lines in 5 files now uncovered.

1398 of 7106 relevant lines covered (19.67%)

0.41 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/BuildingBlocks/BuildingBlocks.Core/Commands/AsyncCommandBus.cs

using BuildingBlocks.Abstractions.Commands;
using BuildingBlocks.Abstractions.Messages;
using BuildingBlocks.Abstractions.Messages.MessagePersistence;
using BuildingBlocks.Core.Messages;

namespace BuildingBlocks.Core.Commands;

public class AsyncCommandBus(IServiceProvider serviceProvider, IMessageMetadataAccessor messageMetadataAccessor)
    : IAsyncCommandBus
{
    public Task SendExternalAsync<TCommand>(TCommand command, CancellationToken cancellationToken = default)
        where TCommand : class, IAsyncCommand
    {
        var correlationId = messageMetadataAccessor.GetCorrelationId();
        var cautionId = command.MessageId;
        var eventEnvelope = MessageEnvelopeFactory.From(command, correlationId, cautionId);

        var messagePersistenceService = serviceProvider.GetRequiredService<IMessagePersistenceService>();
        return messagePersistenceService.AddPublishMessageAsync(eventEnvelope, cancellationToken);
    }
}

1	using BuildingBlocks.Abstractions.Commands;
2	using BuildingBlocks.Abstractions.Messages;
3	using BuildingBlocks.Abstractions.Messages.MessagePersistence;
4	using BuildingBlocks.Core.Messages;
5
6	namespace BuildingBlocks.Core.Commands;
7
UNCOV 8	public class AsyncCommandBus(IServiceProvider serviceProvider, IMessageMetadataAccessor messageMetadataAccessor)	×
9	: IAsyncCommandBus
10	{
11	public Task SendExternalAsync<TCommand>(TCommand command, CancellationToken cancellationToken = default)
12	where TCommand : class, IAsyncCommand
13	{
14	var correlationId = messageMetadataAccessor.GetCorrelationId();	×
15	var cautionId = command.MessageId;	×
16	var eventEnvelope = MessageEnvelopeFactory.From(command, correlationId, cautionId);	×
17
18	var messagePersistenceService = serviceProvider.GetRequiredService<IMessagePersistenceService>();	×
19	return messagePersistenceService.AddPublishMessageAsync(eventEnvelope, cancellationToken);	×
20	}
21	}

mehdihadeli / food-delivery-microservices / 28702836619

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous