8911801772

Committed 01 May 2024 04:09PM CUT 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

72.5

/src/MediatR.CommandQuery.EntityFrameworkCore/Handlers/EntityDeleteCommandHandler.cs

using AutoMapper;

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

using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;

namespace MediatR.CommandQuery.EntityFrameworkCore.Handlers;

public class EntityDeleteCommandHandler<TContext, TEntity, TKey, TReadModel>
    : EntityDataContextHandlerBase<TContext, TEntity, TKey, TReadModel, EntityDeleteCommand<TKey, TReadModel>, TReadModel>
    where TContext : DbContext
    where TEntity : class, IHaveIdentifier<TKey>, new()
{
    public EntityDeleteCommandHandler(ILoggerFactory loggerFactory, TContext dataContext, IMapper mapper)
        : base(loggerFactory, dataContext, mapper)
    {
    }

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

        var dbSet = DataContext
            .Set<TEntity>();

        var keyValue = new object[] { request.Id };

        var entity = await dbSet
            .FindAsync(keyValue, cancellationToken)
            .ConfigureAwait(false);

        if (entity == null)
            return default!;

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

        // entity supports soft delete
        if (entity is ITrackDeleted deleteEntity)
        {
            deleteEntity.IsDeleted = true;
        }
        else
        {
            // when history is tracked, need to update the entity with update metadata before deleting
            if (entity is ITrackHistory and ITrackUpdated)
            {
                await DataContext
                    .SaveChangesAsync(cancellationToken)
                    .ConfigureAwait(false);
            }

            // delete the entity
            dbSet.Remove(entity);
        }

        await DataContext
            .SaveChangesAsync(cancellationToken)
            .ConfigureAwait(false);

        // convert deleted entity to read model
        var model = Mapper.Map<TReadModel>(entity);

        return model;
    }

}

1	using AutoMapper;
2
3	using MediatR.CommandQuery.Commands;
4	using MediatR.CommandQuery.Definitions;
5
6	using Microsoft.EntityFrameworkCore;
7	using Microsoft.Extensions.Logging;
8
9	namespace MediatR.CommandQuery.EntityFrameworkCore.Handlers;
10
11	public class EntityDeleteCommandHandler<TContext, TEntity, TKey, TReadModel>
12	: EntityDataContextHandlerBase<TContext, TEntity, TKey, TReadModel, EntityDeleteCommand<TKey, TReadModel>, TReadModel>
13	where TContext : DbContext
14	where TEntity : class, IHaveIdentifier<TKey>, new()
15	{
16	public EntityDeleteCommandHandler(ILoggerFactory loggerFactory, TContext dataContext, IMapper mapper)
17	: base(loggerFactory, dataContext, mapper)	2✔
18	{
19	}	2✔
20
21	protected override async Task<TReadModel> Process(EntityDeleteCommand<TKey, TReadModel> request, CancellationToken cancellationToken)
22	{
23	if (request is null)	2!
24	throw new ArgumentNullException(nameof(request));	×
25
26	var dbSet = DataContext	2✔
27	.Set<TEntity>();	2✔
28
29	var keyValue = new object[] { request.Id };	2✔
30
31	var entity = await dbSet	2✔
32	.FindAsync(keyValue, cancellationToken)	2✔
33	.ConfigureAwait(false);	2✔
34
35	if (entity == null)	2!
36	return default!;	×
37
38	// apply update metadata
39	if (entity is ITrackUpdated updateEntity)	2✔
40	{
41	updateEntity.UpdatedBy = request.ActivatedBy;	2✔
42	updateEntity.Updated = request.Activated;	2✔
43	}
44
45	// entity supports soft delete
46	if (entity is ITrackDeleted deleteEntity)	2!
47	{
48	deleteEntity.IsDeleted = true;	×
49	}
50	else
51	{
52	// when history is tracked, need to update the entity with update metadata before deleting
53	if (entity is ITrackHistory and ITrackUpdated)	2!
54	{
55	await DataContext	×
56	.SaveChangesAsync(cancellationToken)	×
57	.ConfigureAwait(false);	×
58	}
59
60	// delete the entity
61	dbSet.Remove(entity);	2✔
62	}
63
64	await DataContext	2✔
65	.SaveChangesAsync(cancellationToken)	2✔
66	.ConfigureAwait(false);	2✔
67
68	// convert deleted entity to read model
69	var model = Mapper.Map<TReadModel>(entity);	2✔
70
71	return model;	2✔
72	}	2✔
73
74	}

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