8410320720

Committed 24 Mar 2024 03:15PM CUT coverage: 58.562%. Remained the same

Build # 8410320720

Build Type

push

github

Committed by

pwelter34

Commit Message

Update EntityQueryEndpointBase.cs

Run Details

230 of 438 branches covered (52.51%)

Branch coverage included in aggregate %.

560 of 911 relevant lines covered (61.47%)

19.53 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 System;
using System.Threading;
using System.Threading.Tasks;

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

loresoft / MediatR.CommandQuery / 8410320720

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