Domain events, как решить проблему?

Использую MediatR, .net 7, EF.
Есть пользователь, у которого на данный момент есть 2 события: AccountPasswordChangedEvent, TokensWasRemovedEvent.
AccountPasswordChangedEvent вызывается в UpdateUserPasswordCommandHandler:

private readonly IAccountService accountService;
private readonly IDomainEventsService eventsService;

public UpdateUserPasswordCommandHandler(IAccountService accountService, IDomainEventsService eventsService)
{
    this.accountService = accountService;
    this.eventsService = eventsService;
}

public async Task<ServiceResult<ResetPasswordResponse>> Handle(UpdateUserPasswordCommand request, CancellationToken cancellationToken)
{
    var (userId, res) = await accountService.ResetPasswordAsync(request, false, cancellationToken);
    if (res.Succeeded)
    {
        await eventsService.PublishAsync(new AccountPasswordChanged(userId));
    }
    return new ServiceResult<ResetPasswordResponse>(res);
}

В свою очередь обработчик AccountPasswordChangedEvent удаляет все токены пользователя:

private readonly IAccountService accountService;

public AccountPasswordChangedHandler(IAccountService accountService)
{
    this.accountService = accountService;
}

public Task Handle(DomainEventNotification<AccountPasswordChangedEvent> notification, CancellationToken cancellationToken)
{
    return accountService.RemoveTokenAsync(new LogoutCommand
    {
        UserId = notification.DomainEvent.UserId,
        RemoveType = RemoveTokenType.All
    }, cancellationToken);
}

TokensWasRemovedEvent вызывается в LogoutCommandHandler:

private readonly IAccountService accountService;
private readonly IDomainEventsService publisher;

public LogoutCommandHandler(IAccountService accountService, IDomainEventsService publisher)
{
    this.accountService = accountService;
    this.publisher = publisher;
}

public async Task<ServiceResult<LogoutResponse>> Handle(LogoutCommand request, CancellationToken cancellationToken)
{
    var result = await accountService.RemoveTokenAsync(request, cancellationToken);
    if (result.Length > 0)
    {
        await publisher.PublishAsync(new TokensWasRemovedEvent(result));
    }
    return new ServiceResult<LogoutResponse>(new LogoutResponse { Count = result.Length });
}

Где обработчик этого события удаляет все удаленные токены из кеша:

private readonly IMemoryCache memoryCache;

public TokenWasRemovedHandler(IMemoryCache memoryCache)
{
    this.memoryCache = memoryCache;
}

public Task Handle(DomainEventNotification<TokensWasRemovedEvent> notification, CancellationToken cancellationToken)
{
    foreach (var item in notification.DomainEvent.Tokens)
    {
        memoryCache.Remove($"apitoken={item}");
    }
    return Task.CompletedTask;
}

Вопрос такой: можно ли пробросить новое событие TokensWasRemovedEvent в обработчике события AccountPasswordChangedHandler? Правильно ли это будет (могут ли события порождать события? Я такого не видел нигде, а если быть точнее, то видел и там было сказано, что это плохо)?

private readonly IAccountService accountService;
private readonly IDomainEventsService publisher;

public AccountPasswordChangedHandler(IAccountService accountService, IDomainEventsService publisher)
{
    this.accountService = accountService;
    this.publisher = publisher;
}

public async Task Handle(DomainEventNotification<AccountPasswordChangedEvent> notification, CancellationToken cancellationToken)
{
    var tokens = await accountService.RemoveTokenAsync(new LogoutCommand
    {
        UserId = notification.DomainEvent.UserId,
        RemoveType = RemoveTokenType.All
    }, cancellationToken);
    if (tokens.Length > 0)
    {
        await publisher.PublishAsync(new TokensWasRemovedEvent(tokens));
    }
}

Сразу отвечаю на вопрос "Почему события добавляются не через DbContext & Entity?" - удаление токенов происходит через ExecuteDeleteAsync (.net 7), который не затрагивает SaveChangesAsync. Смена пароля происходит через UserManager из которого нужно сначала получить ответ, что пароль изменен успешно (может вернуть IdentityError[]).
  • Вопрос задан
  • 177 просмотров
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы