Domain Event'ler

public class UserCreatedDomainEvent : DomainEvent, INotification
{
    public Guid UserId { get; }
    public FullName? FullName { get; }
    public Phone? Phone { get; }
    public Email? Email { get; }

    public UserCreatedDomainEvent(Guid userId, FullName? fullName, Phone? phone, Email? email)
    {
        UserId = userId; FullName = fullName; Phone = phone; Email = email;
    }
}

public void AddOtpChallenge(OtpCode code, OtpType type)
{
    if (CanRequestOtp == false)
        throw new DomainException("Kullanıcı durumu giriş yapmaya uygun değil.");

    var challenge = new UserOtpChallenge(this, GuidFactory.New(), code, type,
                                         DateTime.UtcNow.AddMinutes(type == OtpType.Sms ? 1 : 2));
    OtpChallenges.Add(challenge);

    AddDomainEvent(new UserOtpGeneratedDomainEvent(this, code, type, this.Phone, this.Email));
}

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

    public Task Handle(UserOtpGeneratedDomainEvent e, CancellationToken ct)
        => SendIfSmsAsync(e.Phone, e.Code, e.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 sealed class InvalidateFaqCacheDomainEventHandler : INotificationHandler<FaqCreatedDomainEvent>
{
    private readonly IHybridRequestCache _cache;

    public async Task Handle(FaqCreatedDomainEvent e, CancellationToken ct)
    {
        try { await _cache.RemoveByTagAsync(CacheTags.Faqs, ct); }
        catch (Exception ex) { /* warn log — cache hatası ana akışı durdurmaz */ }
    }
}

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

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

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