Fix DomainEvents

Author: A-Programmer

Samples/BlogApp/Project.Application/Blog/EventHandlers/PostCreatedDomainEventHandler.cs

@@ -0,0 +1,27 @@
+using KSFramework.KSMessaging.Abstraction;
+using Microsoft.Extensions.Logging;
+using Project.Domain.Aggregates.Blog.Events;
+
+namespace Project.Application.Blog.EventHandlers;
+
+public sealed class PostCreatedDomainEventHandler : INotificationHandler<PostCreatedDomainEvent>
+{
+    private readonly ILogger<PostCreatedDomainEventHandler> _logger;
+
+    public PostCreatedDomainEventHandler(ILogger<PostCreatedDomainEventHandler> logger)
+    {
+        _logger = logger;
+    }
+
+    public Task Handle(PostCreatedDomainEvent notification, CancellationToken cancellationToken)
+    {
+        _logger.LogInformation("Post created: {PostId} - {Title}", notification.PostId, notification.Title);
+        
+        // Here you can add additional business logic like:
+        // - Sending notifications
+        // - Updating read models
+        // - Triggering external systems
+        
+        return Task.CompletedTask;
+    }
+}

Samples/BlogApp/Project.Application/Project.Application.csproj

@@ -1,7 +1,7 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net10.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>

Samples/BlogApp/Project.ClientApp/Program.cs

@@ -18,12 +18,11 @@
 
 app.UseAuthorization();
 
-app.MapStaticAssets();
+app.UseStaticFiles();
 
 app.MapControllerRoute(
     name: "default",
-    pattern: "{controller=Home}/{action=Index}/{id?}")
-    .WithStaticAssets();
+    pattern: "{controller=Home}/{action=Index}/{id?}");
 
 
 app.Run();

Samples/BlogApp/Project.ClientApp/Project.ClientApp.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk.Web">
 
   <PropertyGroup>
-    <TargetFramework>net10.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>

Samples/BlogApp/Project.Common/Project.Common.csproj

@@ -1,7 +1,7 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net10.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>

Samples/BlogApp/Project.Domain/Aggregates/Blog/Events/PostCreatedDomainEvent.cs

@@ -0,0 +1,17 @@
+using KSFramework.KSDomain;
+
+namespace Project.Domain.Aggregates.Blog.Events;
+
+public sealed class PostCreatedDomainEvent : IDomainEvent
+{
+    public PostCreatedDomainEvent(Guid postId, string title)
+    {
+        PostId = postId;
+        Title = title;
+        OccurredOn = DateTime.UtcNow;
+    }
+
+    public Guid PostId { get; }
+    public string Title { get; }
+    public DateTime OccurredOn { get; }
+}

Samples/BlogApp/Project.Domain/Aggregates/Blog/Post.cs

@@ -4,6 +4,7 @@
 using KSFramework.Utilities;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using Project.Domain.Aggregates.Blog.Events;
 
 namespace Project.Domain.Aggregates.Blog;
 
@@ -44,6 +45,7 @@ public static Post Create(string title, string content)
             Id = Guid.NewGuid(),
         };
 
+        post.AddDomainEvent(new PostCreatedDomainEvent(post.Id, post.Title));
         return post;
     }
 

Samples/BlogApp/Project.Domain/Project.Domain.csproj

@@ -1,7 +1,7 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net10.0</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>

Samples/BlogApp/Project.Infrastructure/Data/ApplicationDbContext.cs

@@ -2,14 +2,24 @@
 using KSFramework.Utilities;
 using Microsoft.EntityFrameworkCore;
 using Project.Infrastructure.Outbox;
+using Microsoft.Extensions.DependencyInjection;
+using Project.Infrastructure.Services;
+using System.Linq;
 
 namespace Project.Infrastructure.Data;
 
 public class ApplicationDbContext : DbContext
 {
-    public ApplicationDbContext(DbContextOptions<ApplicationDbContext> options)
-        :base(options)
+    private readonly IDomainEventDispatcher _dispatcher;
+    private readonly IServiceProvider _serviceProvider;
+
+    public ApplicationDbContext(
+        DbContextOptions<ApplicationDbContext> options,
+        IServiceProvider serviceProvider)
+        : base(options)
     {
+        _serviceProvider = serviceProvider;
+        _dispatcher = _serviceProvider.GetRequiredService<IDomainEventDispatcher>();
     }
 
     public DbSet<OutboxMessage> OutboxMessages { get; set; }
@@ -48,4 +58,26 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
 
         #endregion
     }
+
+    public override async Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)
+    {
+        var domainEvents = ChangeTracker.Entries<BaseEntity>()
+            .SelectMany(x => x.Entity.DomainEvents)
+            .ToList();
+
+        var result = await base.SaveChangesAsync(cancellationToken);
+
+        if (domainEvents.Any())
+        {
+            await _dispatcher.DispatchEventsAsync(domainEvents, cancellationToken);
+
+            // Clear domain events after dispatching
+            foreach (var entry in ChangeTracker.Entries<BaseEntity>())
+            {
+                entry.Entity.ClearDomainEvents();
+            }
+        }
+
+        return result;
+    }
 }

Samples/BlogApp/Project.Infrastructure/DependencyInjection.cs

@@ -1,4 +1,4 @@
-using KSFramework.GenericRepository;
+using KSFramework.GenericRepository;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
@@ -18,6 +18,8 @@ public static IServiceCollection RegisterInfrastructure(this IServiceCollection
                 x =>
                     x.MigrationsAssembly("Project.Infrastructure"));
         });
+
+        services.AddScoped<KSFramework.KSDomain.IDomainEventDispatcher, KSFramework.KSDomain.DomainEventDispatcher>();
         services.AddScoped<DbContext, ApplicationDbContext>();
         services.AddScoped<IUnitOfWork, UnitOfWork>();
         return services;