MediatR 和 CQRS 测试。如何验证调用了该处理程序？

Question

我目前正在尝试在我的项目中实施MediatR，并进行测试。我想介绍一下在发送请求时是否调用了处理程序的Handle。

我有这个问题

public class GetUnitsQuery : IRequest<List<UnitResponse>>
{
}

处理程序：

public class GetUnitsHandler : IRequestHandler<GetUnitsQuery, List<UnitResponse>>
{
    readonly IUnitRepository UnitRepository;
    readonly IMapper Mapper;

    public GetUnitsHandler(IUnitRepository unitRepository, IMapper mapper)
    {
        this.UnitRepository = unitRepository;
        Mapper = mapper;
    }

    public async Task<List<UnitResponse>> Handle(GetUnitsQuery request, CancellationToken cancellationToken)
    {
        return Mapper.Map<List<UnitResponse>>(UnitRepository.GetUnits());
    }
}

从控制器发送请求：

var result = await Mediator.Send(query);

任何想法如何测试Handler 在使用MoQ 指定特定Query 时是否被调用？

Answer 1

我没有使用 MoQ 来检查接收到的对特定处理程序的调用。但是，如果我使用 Nsubsitute 和 SpecFlow，我会在测试中执行类似的操作。

        var handler = ServiceLocator.Current.GetInstance<IRequestHandler<GetUnitsQuery, List<UnitResponse>>>();
        handler.Received().Handle(Arg.Any<GetUnitsQuery>(), Arg.Any<CancellationToken>());

Answer 2

就像其他人在 cmets 中所说的那样，您不需要测试 Mediator 的内部。

你的测试边界就是你的应用程序，所以假设一个控制器是这样的：

public class MyController : Controller 
{
    private readonly IMediator _mediator;

    public MyController(IMediator mediator)
    {
        _mediator = mediator;
    }

    public async IActionResult Index()
    {
        var query = new GetUnitsQuery();

        var result = await Mediator.Send(query);

        return Ok(result);
    }
}

我会验证 Mediator 是这样调用的：

public class MyControllerTests 
{
    [SetUp]
    public void SetUp()
    {
        _mockMediator = new Mock<IMediator>();
        _myController = new MyController(_mockMediator.Object)
    }

    [Test]
    public async void CallsMediator()
    {
        // Arranged
        _mockMediator.SetUp(x=> x.Send(It.IsAny<GetUnitsQuery>()))
            .Returns (new List<UnitResponse>());

        // Act
        await _myController.Index();

        // Assert
        _mockMediator.Verify(x=> x.Send(It.IsAny<GetUnitsQuery>()), Times.Once);
    }
}