Marten项目中的聚合删除事件与RaiseSideEffects问题解析

问题背景

在Marten这个.NET平台上的事件溯源和文档数据库库中，开发人员发现了一个关于聚合删除事件处理的重要问题。当使用TrackedSingleStreamProjection进行投影处理时，如果聚合文档被删除，RaiseSideEffects方法不会被触发执行。

技术细节分析

Marten的投影机制允许开发人员定义如何处理事件流并更新相应的文档状态。TrackedSingleStreamProjection是一个基类，提供了对单个流事件的处理能力。RaiseSideEffects方法是其中一个关键扩展点，允许开发人员在处理事件后执行额外的操作，如发布通知消息等。

在当前的实现中，当处理删除事件时（通过DeleteEvent方法配置），虽然聚合文档会被正确删除，但RaiseSideEffects方法却被跳过不执行。这与开发人员的预期不符，特别是当他们需要在删除操作后执行一些清理或通知逻辑时。

影响范围

这个问题会影响所有需要以下功能的场景：

1. 在聚合删除后需要发布通知消息
2. 需要记录删除操作的审计日志
3. 需要触发与删除相关的后续业务流程
4. 需要清理与已删除聚合相关的其他资源

解决方案

Marten团队已经修复了这个问题，现在RaiseSideEffects方法会在删除事件处理后正常触发。开发人员可以像处理其他事件类型一样，在删除事件后执行必要的副作用操作。

最佳实践

基于这个问题的解决，建议开发人员在使用TrackedSingleStreamProjection时：

1. 明确区分业务逻辑和副作用操作，将副作用集中在RaiseSideEffects方法中
2. 对于删除操作，确保所有必要的清理逻辑都在RaiseSideEffects中实现
3. 考虑使用消息模式来解耦删除操作和后续处理
4. 在测试中特别验证删除场景下的副作用是否按预期执行

实现示例

修复后的代码可以这样使用：

[RegisterAsAsyncProjection]
public class EntityAssociationStateProjection : TrackedSingleStreamProjection<EntityAssociationState>
{
    public EntityAssociationStateProjection()
    {
        this.DeleteEvent<EntityUnassignedEvent>();
    }

    public override ValueTask RaiseSideEffects(IDocumentOperations operations, IEventSlice<EntityAssociationState> slice)
    {
        // 现在无论是创建、更新还是删除事件，都会执行到这里
        var tenantId = operations.TenantId;
        
        // 可以检查slice.Aggregate是否存在来判断是否是删除操作
        if(slice.Aggregate == null)
        {
            // 处理删除后的逻辑
        }
        
        // 发布通知消息
        slice.PublishMessage(new EntityAssociationSubscriptionMessageDto
        {
            EntityAssociationId = slice.Aggregate?.Id, // 注意null检查
            TenantId = tenantId,
            Kind = slice.Aggregate == null ? EventKind.Deleted : EventKind.Updated,
        });

        return ValueTask.CompletedTask;
    }
}

总结

Marten对删除事件处理的这一改进，使得事件溯源系统在处理聚合生命周期完整事件时更加一致和可靠。开发人员现在可以放心地在RaiseSideEffects中实现所有必要的后续处理逻辑，而不必担心删除事件被特殊对待。这一变化也体现了Marten项目对开发者体验的持续关注和改进。