Add Notification to User Created

src/Orion.Application.Core/Commands/UserCreate/UserCreateRequestHandler.cs

@@ -1,21 +1,26 @@
 using MediatR;
+using Orion.Application.Core.Notifications.UserCreated;
 using Orion.Domain.Core.Services.Interfaces;
 
 namespace Orion.Application.Core.Commands.UserCreate;
 
 public class UserCreateRequestHandler : IRequestHandler<UserCreateRequest, UserCreateResponse>
 {
     private readonly IUserService _userService;
-
-    public UserCreateRequestHandler(IUserService userService)
+    private readonly IMediator _mediator;
+
+    public UserCreateRequestHandler(IUserService userService, IMediator mediator)
     {
         _userService = userService;
+        _mediator = mediator;
     }
-    
+
     public async Task<UserCreateResponse> Handle(UserCreateRequest request, CancellationToken cancellationToken)
     {
-        var customerCreated = await _userService.AddAsync(request);
+        var userCreated = await _userService.AddAsync(request);
+
+        await _mediator.Publish(new UserCreatedNotification(userCreated), cancellationToken);
 
-        return (UserCreateResponse)customerCreated;
+        return (UserCreateResponse)userCreated;
     }
 }

src/Orion.Application.Core/Notifications/UserCreated/UserCreatedNotification.cs

@@ -0,0 +1,15 @@
+using MediatR;
+using Orion.Domain.Core.Entities;
+
+namespace Orion.Application.Core.Notifications.UserCreated
+{
+    public class UserCreatedNotification : INotification
+    {
+        public UserCreatedNotification(User user)
+        {
+            Entity = user;
+        }
+
+        public User Entity { get; set; }
+    }
+}

src/Orion.Application.Core/Notifications/UserCreated/UserCreatedNotificationHandler.cs

@@ -0,0 +1,25 @@
+using MediatR;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+
+namespace Orion.Application.Core.Notifications.UserCreated
+{
+    public class UserCreatedNotificationHandler : INotificationHandler<UserCreatedNotification>
+    {
+        private readonly ILogger<UserCreatedNotificationHandler> _logger;
+
+        public UserCreatedNotificationHandler(ILogger<UserCreatedNotificationHandler> logger)
+        {
+            _logger = logger;
+        }
+
+        public async Task Handle(UserCreatedNotification notification, CancellationToken cancellationToken)
+        {
+            _logger.LogInformation("A notification {notificationType} has been received. Notification details: {notification}", 
+                nameof(UserCreatedNotification),
+                JsonConvert.SerializeObject(notification, Formatting.Indented));
+
+            await Task.CompletedTask;
+        }
+    }
+}

src/Orion.Application.Core/Orion.Application.Core.csproj

@@ -11,6 +11,9 @@
 
     <ItemGroup>
       <PackageReference Include="FluentValidation" Version="11.5.1" />
+      <PackageReference Include="Microsoft.Extensions.Logging" Version="7.0.0" />
+      <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="7.0.1" />
+      <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
     </ItemGroup>
 
 </Project>