50 lines
2.6 KiB
C#
50 lines
2.6 KiB
C#
|
using Microsoft.EntityFrameworkCore;
|
|||
|
|
using Microsoft.EntityFrameworkCore.Storage;
|
|||
|
|
using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Abstractions;
|
|||
|
|
using Microsoft.eShopOnContainers.BuildingBlocks.EventBus.Events;
|
|||
|
|
using Microsoft.eShopOnContainers.BuildingBlocks.IntegrationEventLogEF.Services;
|
|||
|
|
using Microsoft.eShopOnContainers.BuildingBlocks.IntegrationEventLogEF.Utilities;
|
|||
|
|
using Microsoft.eShopOnContainers.Services.Ordering.Domain.AggregatesModel.OrderAggregate;
|
|||
|
|
using Microsoft.eShopOnContainers.Services.Ordering.Infrastructure;
|
|||
|
|
using System;
|
|||
|
|
using System.Data.Common;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
|
|||
|
|
namespace Ordering.API.IntegrationEvents
|
|||
|
|
{
|
|||
|
|
public class OrderingIntegrationEventService : IOrderingIntegrationEventService
|
|||
|
|
{
|
|||
|
|
private readonly Func<DbConnection, IIntegrationEventLogService> _integrationEventLogServiceFactory;
|
|||
|
|
private readonly IEventBus _eventBus;
|
|||
|
|
private readonly OrderingContext _orderingContext;
|
|||
|
|
private readonly IIntegrationEventLogService _eventLogService;
|
|||
|
|
|
|||
|
|
public OrderingIntegrationEventService (IEventBus eventBus, OrderingContext orderingContext,
|
|||
|
|
Func<DbConnection, IIntegrationEventLogService> integrationEventLogServiceFactory)
|
|||
|
|
{
|
|||
|
|
_orderingContext = orderingContext ?? throw new ArgumentNullException(nameof(orderingContext));
|
|||
|
|
_integrationEventLogServiceFactory = integrationEventLogServiceFactory ?? throw new ArgumentNullException(nameof(integrationEventLogServiceFactory));
|
|||
|
|
_eventBus = eventBus ?? throw new ArgumentNullException(nameof(eventBus));
|
|||
|
|
_eventLogService = _integrationEventLogServiceFactory(_orderingContext.Database.GetDbConnection());
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task PublishAsync(IntegrationEvent evt)
|
|||
|
|
{
|
|||
|
|
_eventBus.Publish(evt);
|
|||
|
|
await _eventLogService.MarkEventAsPublishedAsync(evt);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task SaveEventAsync(IntegrationEvent evt)
|
|||
|
|
{
|
|||
|
|
//Use of an EF Core resiliency strategy when using multiple DbContexts within an explicit BeginTransaction():
|
|||
|
|
//See: https://docs.microsoft.com/en-us/ef/core/miscellaneous/connection-resiliency
|
|||
|
|
await ResilientTransaction.New(_orderingContext)
|
|||
|
|
.ExecuteAsync(async () => {
|
|||
|
|
// Achieving atomicity between original ordering database operation and the IntegrationEventLog thanks to a local transaction
|
|||
|
|
await _orderingContext.SaveChangesAsync();
|
|||
|
|
await _eventLogService.SaveEventAsync(evt, _orderingContext.Database.CurrentTransaction.GetDbTransaction());
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|