8911801772

Committed 01 May 2024 04:09PM UTC coverage: 57.379% (-1.8%) from 59.163%

Build # 8911801772

Build Type

push

github

Committed by

pwelter34

Commit Message

tweak build

Run Details

342 of 700 branches covered (48.86%)

Branch coverage included in aggregate %.

1011 of 1658 relevant lines covered (60.98%)

18.48 hits per line

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

83.33

/src/MediatR.CommandQuery/Behaviors/EntityChangeNotificationBehavior.cs

using MediatR.CommandQuery.Commands;
using MediatR.CommandQuery.Notifications;

using Microsoft.Extensions.Logging;

namespace MediatR.CommandQuery.Behaviors;

public class EntityChangeNotificationBehavior<TKey, TEntityModel, TResponse>
    : PipelineBehaviorBase<PrincipalCommandBase<TResponse>, TResponse>
    where TEntityModel : class
{
    private readonly IMediator _mediator;

    public EntityChangeNotificationBehavior(ILoggerFactory loggerFactory, IMediator mediator) : base(loggerFactory)
    {
        _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));
    }

    protected override async Task<TResponse> Process(
        PrincipalCommandBase<TResponse> request,
        RequestHandlerDelegate<TResponse> next,
        CancellationToken cancellationToken)
    {
        if (request is null)
            throw new ArgumentNullException(nameof(request));

        if (next is null)
            throw new ArgumentNullException(nameof(next));

        var response = await next().ConfigureAwait(false);

        await SendNotification(request, response, cancellationToken);

        return response;
    }

    private async Task SendNotification(
        PrincipalCommandBase<TResponse> request,
        TResponse response,
        CancellationToken cancellationToken)
    {
        var operation = request switch
        {
            EntityCreateCommand<TEntityModel, TResponse> _ => EntityChangeOperation.Created,
            EntityDeleteCommand<TKey, TResponse> _ => EntityChangeOperation.Deleted,
            _ => EntityChangeOperation.Updated
        };

        var notification = new EntityChangeNotification<TResponse>(response, operation);
        await _mediator.Publish(notification, cancellationToken);
    }
}

1	using MediatR.CommandQuery.Commands;
2	using MediatR.CommandQuery.Notifications;
3
4	using Microsoft.Extensions.Logging;
5
6	namespace MediatR.CommandQuery.Behaviors;
7
8	public class EntityChangeNotificationBehavior<TKey, TEntityModel, TResponse>
9	: PipelineBehaviorBase<PrincipalCommandBase<TResponse>, TResponse>
10	where TEntityModel : class
11	{
12	private readonly IMediator _mediator;
13
14	public EntityChangeNotificationBehavior(ILoggerFactory loggerFactory, IMediator mediator) : base(loggerFactory)	56✔
15	{
16	_mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));	56!
17	}	56✔
18
19	protected override async Task<TResponse> Process(
20	PrincipalCommandBase<TResponse> request,
21	RequestHandlerDelegate<TResponse> next,
22	CancellationToken cancellationToken)
23	{
24	if (request is null)	52!
25	throw new ArgumentNullException(nameof(request));	×
26
27	if (next is null)	52!
28	throw new ArgumentNullException(nameof(next));	×
29
30	var response = await next().ConfigureAwait(false);	52✔
31
32	await SendNotification(request, response, cancellationToken);	52✔
33
34	return response;	52✔
35	}	52✔
36
37	private async Task SendNotification(
38	PrincipalCommandBase<TResponse> request,
39	TResponse response,
40	CancellationToken cancellationToken)
41	{
42	var operation = request switch	52✔
43	{	52✔
44	EntityCreateCommand<TEntityModel, TResponse> _ => EntityChangeOperation.Created,	12✔
45	EntityDeleteCommand<TKey, TResponse> _ => EntityChangeOperation.Deleted,	8✔
46	_ => EntityChangeOperation.Updated	32✔
47	};	52✔
48
49	var notification = new EntityChangeNotification<TResponse>(response, operation);	52✔
50	await _mediator.Publish(notification, cancellationToken);	52✔
51	}	52✔
52	}

loresoft / MediatR.CommandQuery / 8911801772

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