Domain Events

public abstract class DomainEvent
{
    public string Type => this.GetType().Name;
    public readonly Guid Id;
    public readonly Guid CorrelationID;
    public readonly DateTime CreatedAt;

    public DomainEvent()
    {
        Id = Guid.CreateVersion7(DateTime.UtcNow);
        CreatedAt = DateTime.UtcNow;
    }
    public DomainEvent(Guid correlationID) : this() => this.CorrelationID = correlationID;
}

// Aggregate metodu (örnek)
public void AssignRole(Role role, Guid by)
{
    // ... domain kuralları, state değişimi ...
    AddDomainEvent(new UserRoleAssignedDomainEvent(Id, role.Id));
}

// DiyanetCleanArchitectureDbContext.SaveEntitiesAsync
public async Task<bool> SaveEntitiesAsync(CancellationToken cancellationToken = default)
{
    int result = await base.SaveChangesAsync(cancellationToken);   // AuditInterceptor burada
    if (result > 0)
        await _mediator.DispatchDomainEventsAsync(this);
    return true;
}

public sealed class SendOtpSmsDomainEventHandler
    : INotificationHandler<UserOtpGeneratedDomainEvent>,
      INotificationHandler<UserOtpResentDomainEvent>
{
    private readonly IOtpSmsService _otpSmsService;

    public Task Handle(UserOtpGeneratedDomainEvent @event, CancellationToken ct)
        => SendIfSmsAsync(@event.Phone, @event.Code, @event.Type);

    private async Task SendIfSmsAsync(Phone? phone, OtpCode code, OtpType type)
    {
        if (phone is null || type != OtpType.Sms) return;   // guard
        await _otpSmsService.SendAsync(code, phone);
    }
}

public class UserCreatedDomainEventHandler : INotificationHandler<UserCreatedDomainEvent>
{
    private readonly IEventBus _eventBus;

    public async Task Handle(UserCreatedDomainEvent notification, CancellationToken ct)
    {
        var integrationEvent = new UserCreatedIntegrationEvent(
            notification.UserId,
            notification.FullName?.Value,
            notification.Phone?.Value ?? string.Empty,
            notification.Email?.Value ?? string.Empty);

        await _eventBus.PublishAsync(integrationEvent);   // → Outbox → RabbitMQ
    }
}