8953371852

Committed 04 May 2024 09:23PM UTC coverage: 57.083% (-0.3%) from 57.379%

Build # 8953371852

Build Type

push

github

Committed by

pwelter34

Commit Message

wrap exceptions

Run Details

343 of 702 branches covered (48.86%)

Branch coverage included in aggregate %.

4 of 18 new or added lines in 5 files covered. (22.22%)

5 existing lines in 4 files now uncovered.

1011 of 1670 relevant lines covered (60.54%)

18.34 hits per line

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

65.38

/src/MediatR.CommandQuery/Handlers/RequestHandlerBase.cs

using System.Diagnostics;

using Microsoft.Extensions.Logging;

namespace MediatR.CommandQuery.Handlers;

public abstract partial class RequestHandlerBase<TRequest, TResponse> : IRequestHandler<TRequest, TResponse>
    where TRequest : IRequest<TResponse>
{
    private readonly string _name;

    protected RequestHandlerBase(ILoggerFactory loggerFactory)
    {
        if (loggerFactory is null)
            throw new ArgumentNullException(nameof(loggerFactory));

        var type = GetType();

        Logger = loggerFactory.CreateLogger(type);
        _name = type.Name;
    }

    protected ILogger Logger { get; }

    public virtual async Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken)
    {
        if (request is null)
            throw new ArgumentNullException(nameof(request));

        try
        {
            LogStart(Logger, _name, request);
            var watch = Stopwatch.StartNew();

            var response = await Process(request, cancellationToken).ConfigureAwait(false);

            watch.Stop();
            LogFinish(Logger, _name, request, watch.ElapsedMilliseconds);

            return response;
        }
        catch (DomainException)
        {
            throw;
        }
        catch (Exception ex)
        {
            LogError(Logger, _name, request, ex.Message, ex);
            throw new DomainException(ex.Message, ex);
        }
    }

    protected abstract Task<TResponse> Process(TRequest request, CancellationToken cancellationToken);


    [LoggerMessage(1, LogLevel.Trace, "Processing handler '{Handler}' for request '{Request}' ...")]
    static partial void LogStart(ILogger logger, string handler, IRequest<TResponse> request);

    [LoggerMessage(2, LogLevel.Trace, "Processed handler '{Handler}' for request '{Request}': {Elapsed} ms")]
    static partial void LogFinish(ILogger logger, string handler, IRequest<TResponse> request, long elapsed);

    [LoggerMessage(3, LogLevel.Error, "Error processing handler '{Handler}' for request '{Request}': {ErrorMessage}")]
    static partial void LogError(ILogger logger, string handler, IRequest<TResponse> request, string errorMessage, Exception? exception);
}

1	using System.Diagnostics;
2
3	using Microsoft.Extensions.Logging;
4
5	namespace MediatR.CommandQuery.Handlers;
6
7	public abstract partial class RequestHandlerBase<TRequest, TResponse> : IRequestHandler<TRequest, TResponse>
8	where TRequest : IRequest<TResponse>
9	{
10	private readonly string _name;
11
12	protected RequestHandlerBase(ILoggerFactory loggerFactory)	106✔
13	{
14	if (loggerFactory is null)	106!
15	throw new ArgumentNullException(nameof(loggerFactory));	×
16
17	var type = GetType();	106✔
18
19	Logger = loggerFactory.CreateLogger(type);	106✔
20	_name = type.Name;	106✔
21	}	106✔
22
23	protected ILogger Logger { get; }	212✔
24
25	public virtual async Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken)
26	{
27	if (request is null)	106!
28	throw new ArgumentNullException(nameof(request));	×
29
30	try
31	{
32	LogStart(Logger, _name, request);	106✔
33	var watch = Stopwatch.StartNew();	106✔
34
35	var response = await Process(request, cancellationToken).ConfigureAwait(false);	106✔
36
37	watch.Stop();	106✔
38	LogFinish(Logger, _name, request, watch.ElapsedMilliseconds);	106✔
39
40	return response;	106✔
41	}
NEW 42	catch (DomainException)	×
43	{
NEW 44	throw;	×
45	}
UNCOV 46	catch (Exception ex)	×
47	{
48	LogError(Logger, _name, request, ex.Message, ex);	×
NEW 49	throw new DomainException(ex.Message, ex);	×
50	}
51	}	106✔
52
53	protected abstract Task<TResponse> Process(TRequest request, CancellationToken cancellationToken);
54
55
56	[LoggerMessage(1, LogLevel.Trace, "Processing handler '{Handler}' for request '{Request}' ...")]
57	static partial void LogStart(ILogger logger, string handler, IRequest<TResponse> request);
58
59	[LoggerMessage(2, LogLevel.Trace, "Processed handler '{Handler}' for request '{Request}': {Elapsed} ms")]
60	static partial void LogFinish(ILogger logger, string handler, IRequest<TResponse> request, long elapsed);
61
62	[LoggerMessage(3, LogLevel.Error, "Error processing handler '{Handler}' for request '{Request}': {ErrorMessage}")]
63	static partial void LogError(ILogger logger, string handler, IRequest<TResponse> request, string errorMessage, Exception? exception);
64	}

loresoft / MediatR.CommandQuery / 8953371852

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