测试活动补偿MassTransit

Question

我想在我的Activity中测试补偿逻辑，但我不知道如何启动我的Activity。Compensate 方法的测试。我有一个活动，如果在DB中没有找到东西，就应该抛出一个异常。我已经想好了如何确保活动在这种情况下出现异常，但我想不出补偿的部分。

我的测试类如下。请注意，在 RoutingSlipActivityCompensated 处理者抛出了一个 TaskCanceledException. 如何测试Activity中的补偿部分？

[TestClass]
public class DisableTeamCheckInsActivityTests
{
   Mock<ILogger<DisableTeamCheckInsActivity>> _logger;
   CheckInsDbContext _db;

   InMemoryTestHarness _harness;
   ActivityTestHarness<DisableTeamCheckInsActivity, DisableTeamCheckIns, DisableTeamCheckInsLog> _activity;

   [TestInitialize]
   public async Task Initialize()
   {
      _logger = new Mock<ILogger<DisableTeamCheckInsActivity>>();
      _db = CheckInDbContextFactory.Create();

      _harness = new InMemoryTestHarness
      {
         TestTimeout = TimeSpan.FromSeconds(5)
      };

      _activity = _harness.Activity<DisableTeamCheckInsActivity, DisableTeamCheckIns, DisableTeamCheckInsLog>(
         _ => new DisableTeamCheckInsActivity(_logger.Object, _db),
         _ => new DisableTeamCheckInsActivity(_logger.Object, _db)
      );

      await _db.Database.EnsureCreatedAsync();
      await _harness.Start();
   }

   [TestCleanup]
   public async Task Cleanup()
   {
      await _db.Database.EnsureDeletedAsync();
      await _harness.Stop();
   }

   [TestMethod]
   public async Task Missing_Team_Throws()
   {
      var teamId = Guid.NewGuid();

      var builder = new RoutingSlipBuilder(Guid.NewGuid());
      builder.AddSubscription(_harness.BusAddress, RoutingSlipEvents.All);

      var faulted = _harness.SubscribeHandler<RoutingSlipActivityFaulted>();
      var compensated = _harness.SubscribeHandler<RoutingSlipActivityCompensated>();

      builder.AddActivity(_activity.Name, _activity.ExecuteAddress, new
      {
         TeamId = teamId
      });

      await _harness.Bus.Execute(builder.Build());

      var faultContext = await faulted;
      Assert.AreEqual("System.InvalidOperationException", faultContext?.Message?.ExceptionInfo?.ExceptionType);

      await compensated; // <-- This throws a TaskCanceledException
   }
}

Answer 1

一个带有单个活动的路由滑移将永远不会补偿。如果活动发生故障，路由滑块也会发生故障，但路由滑块中没有任何补偿信息，因为之前没有任何活动。

如果活动完成了，随后的活动发生故障，那么补偿方法就会被调用，ActivityCompensated事件也会被发布。