DeepCore.Core.EventBus.EF 2.0.2

Deepcore.Core.EventBus.EF

1. Purpose

• Provide the ability to log all Integration Events into the database via Entity Framework Core (EF Core).
• Once the event is saved into the database via EF Core, the system should dispatch a task to publish all desired Integration Event in the database to the Event Bus.
• Tracking is the main purpose of this package.

2. Migration

        dotnet ef migrations add 'Init' --startup-project services/service1/service1.csproj --context IntegrationEventLogDbContext
        dotnet ef database update --startup-project services/service1/service1.csproj --context IntegrationEventLogDbContext

3. Setup

• Install the latest nuget package from the nuget server or your local nuget repository.

• Use the Mediator Pipeline Behaviour to intercept and process your logic.

• Startup.cs

        // Register db context
        services.AddDbContext<IntegrationEventLogDbContext>(options =>
            {
                options.UseNpgsql(configuration.GetConnectionString("Default"), opts =>
                {
                    // Auto config migration
                    opts.MigrationsAssembly(typeof(Startup).Assembly.FullName);
                });
                options.UseLoggerFactory(LoggerFactory.Create(builder => builder.AddConsole()));
            });
        // Register factory
        services.AddTransient<Func<DbConnection, IIntegrationEventLogService>>(
                sp => (DbConnection c) => new IntegrationEventLogService(c));

• Consumer.cs

        private readonly IIntegrationEventLogService _eventLogService;
        private readonly IntegrationEventLogDbContext _dbContext;
        private readonly Func<DbConnection, IIntegrationEventLogService> _integrationEventLogServiceFactory;
        
        public TestHandler(IEventStoreService<TestAggregateRoot> eventStoreService, IMapper mapper, ICurrentUserService currentUserService, ILoggerService loggerService, IEventBus eventBus, IntegrationEventLogDbContext dbContext, Func<DbConnection, IIntegrationEventLogService> integrationEventLogServiceFactory)
        {
            _eventStoreService = eventStoreService;
            _mapper = mapper;
            _currentUserService = currentUserService;
            _loggerService = loggerService;
            _eventBus = eventBus;
            _dbContext = dbContext;
            _eventLogService = integrationEventLogServiceFactory(_dbContext.Database.GetDbConnection());
           
            _integrationEventLogServiceFactory = integrationEventLogServiceFactory;
        }

• Method call

        await _eventLogService.SaveEventAsync(new SubmittedTestIntegrationEvent("", "", ""), _dbContext.Database.BeginTransaction(), cancellationToken);