Cache Invalidation

public static class CacheTags
{
    // Spec'teki sabitten türetilir — spec ve handler aynı değeri görür.
    public const string Faqs = PublicFaqsPagedSpecification.CacheTag;   // "faqs"
}

public sealed class InvalidateFaqCacheDomainEventHandler
    : INotificationHandler<FaqCreatedDomainEvent>
{
    private readonly IHybridRequestCache _cache;
    private readonly ILogger<InvalidateFaqCacheDomainEventHandler> _logger;

    public InvalidateFaqCacheDomainEventHandler(
        IHybridRequestCache cache,
        ILogger<InvalidateFaqCacheDomainEventHandler> logger)
    {
        _cache  = cache;
        _logger = logger;
    }

    public async Task Handle(FaqCreatedDomainEvent e, CancellationToken ct)
    {
        try
        {
            await _cache.RemoveByTagAsync(CacheTags.Faqs, ct);
            _logger.LogDebug("[CacheInvalidate] FaqCreated → {Tag} dropped (faqId={FaqId})", CacheTags.Faqs, e.FaqId);
        }
        catch (Exception ex)
        {
            // Cache hatası ana akışı durdurmaz: defansif try/catch + warn log.
            _logger.LogWarning(ex, "[CacheInvalidate] FaqCreated failed: faqId={FaqId}", e.FaqId);
        }
    }
}

public async ValueTask RemoveByTagAsync(string tag, CancellationToken ct = default)
{
    await _cache.RemoveByTagAsync(tag, ct);   // local L1 + L2

    if (_options.CurrentValue.BroadcastTagInvalidation)
        // Diğer node'ların L1'i için broadcast (best-effort; fail olsa runtime kırılmaz).
        await _broadcaster.BroadcastInvalidationAsync(new[] { tag }, ct);
}

// Broadcast'ten geldiği için tekrar broadcast YAPMAZ — loop önleme.
public ValueTask RemoveByTagLocallyAsync(string tag, CancellationToken ct = default)
    => _cache.RemoveByTagAsync(tag, ct);