30 lines
1.0 KiB
C#
30 lines
1.0 KiB
C#
namespace Basket.API.IntegrationEvents.EventHandling;
|
|
|
|
public class OrderStartedIntegrationEventHandler : IIntegrationEventHandler<OrderStartedIntegrationEvent>
|
|
{
|
|
private readonly IBasketRepository _repository;
|
|
private readonly ILogger<OrderStartedIntegrationEventHandler> _logger;
|
|
|
|
public OrderStartedIntegrationEventHandler(
|
|
IBasketRepository repository,
|
|
ILogger<OrderStartedIntegrationEventHandler> logger)
|
|
{
|
|
_repository = repository ?? throw new ArgumentNullException(nameof(repository));
|
|
_logger = logger ?? throw new ArgumentNullException(nameof(logger));
|
|
}
|
|
|
|
public async Task Handle(OrderStartedIntegrationEvent @event)
|
|
{
|
|
using (_logger.BeginScope(new List<KeyValuePair<string, object>> { new ("IntegrationEventContext", @event.Id) }))
|
|
{
|
|
_logger.LogInformation("Handling integration event: {IntegrationEventId} - ({@IntegrationEvent})", @event.Id, @event);
|
|
|
|
await _repository.DeleteBasketAsync(@event.UserId.ToString());
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|