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/EntityIdentifiersQueryHandler.cs

using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

using AutoMapper;

using Cosmos.Abstracts;
using Cosmos.Abstracts.Extensions;

using MediatR.CommandQuery.Definitions;
using MediatR.CommandQuery.Queries;

using Microsoft.Azure.Cosmos;
using Microsoft.Extensions.Logging;

namespace MediatR.CommandQuery.Cosmos.Handlers;

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

    protected override async Task<IReadOnlyCollection<TReadModel>> Process(EntityIdentifiersQuery<string, TReadModel> request, CancellationToken cancellationToken)
    {
        if (request is null)
            throw new System.ArgumentNullException(nameof(request));

        var keys = new HashSet<string>();
        foreach (var requestId in request.Ids)
        {
            if (CosmosKey.TryDecode(requestId, out var id, out PartitionKey partitionKey))
                keys.Add(id);
        }

        var query = await Repository
            .GetQueryableAsync()
            .ConfigureAwait(false);

        var results = await query
            .Where(p => keys.Contains(p.Id))
            .ToListAsync(cancellationToken)
            .ConfigureAwait(false);

        return Mapper.Map<IList<TEntity>, IReadOnlyCollection<TReadModel>>(results);
    }
}

1	using System.Collections.Generic;
2	using System.Linq;
3	using System.Threading;
4	using System.Threading.Tasks;
5
6	using AutoMapper;
7
8	using Cosmos.Abstracts;
9	using Cosmos.Abstracts.Extensions;
10
11	using MediatR.CommandQuery.Definitions;
12	using MediatR.CommandQuery.Queries;
13
14	using Microsoft.Azure.Cosmos;
15	using Microsoft.Extensions.Logging;
16
17	namespace MediatR.CommandQuery.Cosmos.Handlers;
18
19	public class EntityIdentifiersQueryHandler<TRepository, TEntity, TReadModel>
20	: RepositoryHandlerBase<TRepository, TEntity, EntityIdentifiersQuery<string, TReadModel>, IReadOnlyCollection<TReadModel>>
21	where TRepository : ICosmosRepository<TEntity>
22	where TEntity : class, IHaveIdentifier<string>, new()
23	{
24	public EntityIdentifiersQueryHandler(ILoggerFactory loggerFactory, TRepository repository, IMapper mapper) : base(loggerFactory, repository, mapper)	×
25	{
26	}	×
27
28	protected override async Task<IReadOnlyCollection<TReadModel>> Process(EntityIdentifiersQuery<string, TReadModel> request, CancellationToken cancellationToken)
29	{
30	if (request is null)
31	throw new System.ArgumentNullException(nameof(request));
32
33	var keys = new HashSet<string>();
34	foreach (var requestId in request.Ids)
35	{
36	if (CosmosKey.TryDecode(requestId, out var id, out PartitionKey partitionKey))
37	keys.Add(id);
38	}
39
40	var query = await Repository
41	.GetQueryableAsync()
42	.ConfigureAwait(false);
43
44	var results = await query
45	.Where(p => keys.Contains(p.Id))
46	.ToListAsync(cancellationToken)
47	.ConfigureAwait(false);
48
49	return Mapper.Map<IList<TEntity>, IReadOnlyCollection<TReadModel>>(results);
50	}
51	}

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