9307610999

Committed 30 May 2024 06:43PM CUT coverage: 57.741%. Remained the same

Build # 9307610999

Build Type

Pull #513

github

Committed by

web-flow

Commit Message

Merge e90664f48 into 7184530a4

Pull Request Pull Request #513: Bump Microsoft.NET.Test.Sdk from 17.9.0 to 17.10.0

Run Details

348 of 708 branches covered (49.15%)

Branch coverage included in aggregate %.

1032 of 1682 relevant lines covered (61.36%)

19.52 hits per line

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

0.0

/src/MediatR.CommandQuery.Cosmos/Handlers/EntityCreateCommandHandler.cs

using AutoMapper;

using Cosmos.Abstracts;

using MediatR.CommandQuery.Commands;
using MediatR.CommandQuery.Definitions;

using Microsoft.Extensions.Logging;

namespace MediatR.CommandQuery.Cosmos.Handlers;

public class EntityCreateCommandHandler<TRepository, TEntity, TCreateModel, TReadModel>
    : RepositoryHandlerBase<TRepository, TEntity, EntityCreateCommand<TCreateModel, TReadModel>, TReadModel>
    where TRepository : ICosmosRepository<TEntity>
    where TEntity : class, IHaveIdentifier<string>, new()
{
    public EntityCreateCommandHandler(ILoggerFactory loggerFactory, TRepository repository, IMapper mapper)
        : base(loggerFactory, repository, mapper)
    {
    }

    protected override async Task<TReadModel> Process(EntityCreateCommand<TCreateModel, TReadModel> request, CancellationToken cancellationToken)
    {
        if (request is null)
            throw new ArgumentNullException(nameof(request));

        // create new entity from model
        var entity = Mapper.Map<TEntity>(request.Model);

        // apply create metadata
        if (entity is ITrackCreated createdModel)
        {
            createdModel.Created = request.Activated;
            createdModel.CreatedBy = request.ActivatedBy;
        }

        // apply update metadata
        if (entity is ITrackUpdated updateEntity)
        {
            updateEntity.Updated = request.Activated;
            updateEntity.UpdatedBy = request.ActivatedBy;
        }

        var result = await Repository
            .CreateAsync(entity, cancellationToken)
            .ConfigureAwait(false);

        // convert to read model
        return Mapper.Map<TReadModel>(result);
    }
}

1	using AutoMapper;
2
3	using Cosmos.Abstracts;
4
5	using MediatR.CommandQuery.Commands;
6	using MediatR.CommandQuery.Definitions;
7
8	using Microsoft.Extensions.Logging;
9
10	namespace MediatR.CommandQuery.Cosmos.Handlers;
11
12	public class EntityCreateCommandHandler<TRepository, TEntity, TCreateModel, TReadModel>
13	: RepositoryHandlerBase<TRepository, TEntity, EntityCreateCommand<TCreateModel, TReadModel>, TReadModel>
14	where TRepository : ICosmosRepository<TEntity>
15	where TEntity : class, IHaveIdentifier<string>, new()
16	{
17	public EntityCreateCommandHandler(ILoggerFactory loggerFactory, TRepository repository, IMapper mapper)
18	: base(loggerFactory, repository, mapper)	×
19	{
20	}	×
21
22	protected override async Task<TReadModel> Process(EntityCreateCommand<TCreateModel, TReadModel> request, CancellationToken cancellationToken)
23	{
24	if (request is null)	×
25	throw new ArgumentNullException(nameof(request));	×
26
27	// create new entity from model
28	var entity = Mapper.Map<TEntity>(request.Model);	×
29
30	// apply create metadata
31	if (entity is ITrackCreated createdModel)	×
32	{
33	createdModel.Created = request.Activated;	×
34	createdModel.CreatedBy = request.ActivatedBy;	×
35	}
36
37	// apply update metadata
38	if (entity is ITrackUpdated updateEntity)	×
39	{
40	updateEntity.Updated = request.Activated;	×
41	updateEntity.UpdatedBy = request.ActivatedBy;	×
42	}
43
44	var result = await Repository	×
45	.CreateAsync(entity, cancellationToken)	×
46	.ConfigureAwait(false);	×
47
48	// convert to read model
49	return Mapper.Map<TReadModel>(result);	×
50	}	×
51	}

loresoft / MediatR.CommandQuery / 9307610999

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