Feature/rabbit events

src/Application/Application.csproj

@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
     <PropertyGroup>
         <TargetFramework>net9.0</TargetFramework>
         <RootNamespace>Cfo.Cats.Application</RootNamespace>
@@ -11,6 +11,7 @@
     </PropertyGroup>
     <ItemGroup>
         <PackageReference Include="Humanizer.Core.uk" Version="2.14.1" />
+        <PackageReference Include="MassTransit.Abstractions" Version="8.3.3" />
         <PackageReference Include="Microsoft.AspNetCore.DataProtection.EntityFrameworkCore" Version="9.0.0" />
         <PackageReference Include="Ardalis.Specification" Version="8.0.0" />
         <PackageReference Include="Ardalis.Specification.EntityFrameworkCore" Version="8.0.0" />

src/Application/Common/IntegrationEvents/IntegrationEvent.cs

@@ -0,0 +1,9 @@
+using System.Text.Json.Serialization;
+
+namespace Cfo.Cats.Application.Common.IntegrationEvents;
+
+public abstract record IntegrationEvent
+{
+    [JsonInclude] public Guid Id { get; private init; } = Guid.CreateVersion7();
+    [JsonInclude] public DateTime CreationDate { get; private init; } = DateTime.UtcNow;
+}

src/Application/Features/Participants/Consumers/LogParticipantTransitionConsumer.cs

@@ -0,0 +1,14 @@
+using Cfo.Cats.Application.Features.Participants.IntegrationEvents;
+using MassTransit;
+
+namespace Cfo.Cats.Application.Features.Participants.Consumers;
+
+public class LogParticipantTransitionConsumer(ILogger<LogParticipantTransitionConsumer> logger) : IConsumer<ParticipantTransitionedIntegrationEvent>
+{
+    public Task Consume(ConsumeContext<ParticipantTransitionedIntegrationEvent> context)
+    {
+        var (participantId, from, to) = context.Message;
+        logger.LogInformation($"Participant {participantId} transitioned from {from} to {to}");
+        return Task.CompletedTask;
+    }
+}

src/Application/Features/Participants/EventHandlers/PublishEnrolmentApproval.cs

@@ -0,0 +1,18 @@
+using Cfo.Cats.Application.Features.Participants.IntegrationEvents;
+using Cfo.Cats.Domain.Events;
+using MassTransit;
+
+namespace Cfo.Cats.Application.Features.Participants.EventHandlers;
+
+public class PublishEnrolmentApproval(IBus bus) : INotificationHandler<ParticipantTransitionedDomainEvent>
+{
+    public async Task Handle(ParticipantTransitionedDomainEvent notification, CancellationToken cancellationToken)
+    {
+        var e = new ParticipantTransitionedIntegrationEvent(
+            notification.Item.Id,
+            notification.From.ToString(),
+            notification.To.ToString()
+        );
+        await bus.Publish(e, cancellationToken);
+    }
+}

src/Application/Features/Participants/IntegrationEvents/ParticipantTransitionedIntegrationEvent.cs

@@ -0,0 +1,5 @@
+using Cfo.Cats.Application.Common.IntegrationEvents;
+
+namespace Cfo.Cats.Application.Features.Participants.IntegrationEvents;
+
+public record ParticipantTransitionedIntegrationEvent(string ParticipantId, string From, string To) : IntegrationEvent;

src/Aspire/Aspire.AppHost/Aspire.AppHost.csproj

@@ -12,13 +12,13 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Aspire.Hosting.AppHost" Version="9.0.0" />
-    <PackageReference Include="Aspire.Hosting.Redis" Version="9.0.0" />
-    <PackageReference Include="Aspire.Hosting.SqlServer" Version="9.0.0" />
+      <PackageReference Include="Aspire.Hosting.AppHost" Version="9.0.0" />
+      <PackageReference Include="Aspire.Hosting.RabbitMQ" Version="9.0.0" />
+      <PackageReference Include="Aspire.Hosting.SqlServer" Version="9.0.0" />
   </ItemGroup>
 
   <ItemGroup>
-    <ProjectReference Include="..\..\Server.Ui\Server.Ui.csproj"></ProjectReference>
+      <ProjectReference Include="..\..\Server.Ui\Server.Ui.csproj"></ProjectReference>
   </ItemGroup>
 
 </Project>

src/Aspire/Aspire.AppHost/Program.cs

@@ -1,18 +1,23 @@
 var builder = DistributedApplication.CreateBuilder(args);
 
-var password = builder.AddParameter("password", secret: true);
+var sqlPassword = builder.AddParameter("sqlPassword", secret: true);
+var rabbitUser = builder.AddParameter("rabbitUser", secret: true);
+var rabbitPassword = builder.AddParameter("rabbitPassword", secret: true);
 
-var sqlServer = builder.AddSqlServer("sql", password, 1433)
+var db = builder.AddSqlServer("sql", sqlPassword, 1433)
     .WithDataVolume("cats-aspire-data")
-    .WithLifetime(ContainerLifetime.Persistent);
-
-
-var database = sqlServer.AddDatabase("CatsDb");
+    .WithLifetime(ContainerLifetime.Persistent)
+    .AddDatabase("CatsDb");
 
+var rabbit = builder.AddRabbitMQ("rabbit",
+        userName: rabbitUser,
+        password: rabbitPassword)
+    .WithManagementPlugin()
+    .WithLifetime(ContainerLifetime.Persistent);
 
 builder.AddProject<Projects.Server_Ui>("cats")
-    .WithReference(database)
-    .WaitFor(database);
-
+    .WithReference(db)
+    .WithReference(rabbit)
+    .WaitFor(db);
 
-builder.Build().Run();
+builder.Build().Run();

src/Aspire/Aspire.AppHost/appsettings.json

@@ -7,6 +7,8 @@
     }
   },
   "Parameters": {
-    "password": "P@ssword123!"
+    "sqlPassword": "P@ssword123!",
+    "rabbitUser": "guest",
+    "rabbitPassword": "guest"
   }
-}
+}

src/Infrastructure/DependencyInjection.cs

@@ -3,6 +3,7 @@
 using Cfo.Cats.Application.Common.Interfaces.Locations;
 using Cfo.Cats.Application.Common.Interfaces.MultiTenant;
 using Cfo.Cats.Application.Common.Interfaces.Serialization;
+using Cfo.Cats.Application.Features.Participants.Consumers;
 using Cfo.Cats.Application.Features.Participants.Queries;
 using Cfo.Cats.Application.SecurityConstants;
 using Cfo.Cats.Domain.Identity;
@@ -15,6 +16,7 @@
 using Cfo.Cats.Infrastructure.Services.Locations;
 using Cfo.Cats.Infrastructure.Services.MultiTenant;
 using Cfo.Cats.Infrastructure.Services.Serialization;
+using MassTransit;
 using Microsoft.AspNetCore.DataProtection;
 using Microsoft.AspNetCore.Http;
 using Microsoft.EntityFrameworkCore.Diagnostics;
@@ -70,6 +72,25 @@ IConfiguration configuration
             .AddSingleton<IRightToWorkSettings>(s =>
                 s.GetRequiredService<RightToWorkSettings>()
             );
+
+        services.AddMassTransit(x =>
+        {
+            x.AddConsumer<LogParticipantTransitionConsumer>();
+
+
+            x.AddEntityFrameworkOutbox<ApplicationDbContext>(o =>
+            {
+                o.UseSqlServer(true);
+                o.UseBusOutbox();
+            });
+
+            x.UsingRabbitMq((context, cfg) =>
+            {
+                cfg.Host(configuration.GetConnectionString("rabbit"));
+                cfg.ConfigureEndpoints(context);
+            });
+        });
+
         return services;
     }
 

src/Infrastructure/Infrastructure.csproj

@@ -16,6 +16,8 @@
         <PackageReference Include="AWSSDK.S3" Version="3.7.410.1" />
         <PackageReference Include="GovukNotify" Version="7.2.0" />
         <PackageReference Include="IPAddressRange" Version="6.1.0" />
+        <PackageReference Include="MassTransit.EntityFrameworkCore" Version="8.3.3" />
+        <PackageReference Include="MassTransit.RabbitMQ" Version="8.3.3" />
         <PackageReference Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" Version="9.0.0" />
         <PackageReference Include="Microsoft.AspNetCore.Diagnostics.EntityFrameworkCore" Version="9.0.0" />
         <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.0" />

src/Infrastructure/Persistence/ApplicationDbContext.cs

@@ -11,6 +11,9 @@
 using Cfo.Cats.Domain.Entities.Inductions;
 using Cfo.Cats.Domain.Entities.Notifications;
 using Cfo.Cats.Domain.Entities.Payables;
+using MassTransit;
+using Microsoft.EntityFrameworkCore;
+using MassTransit.EntityFrameworkCoreIntegration;
 
 namespace Cfo.Cats.Infrastructure.Persistence;
 
@@ -92,6 +95,19 @@ protected override void OnModelCreating(ModelBuilder builder)
 
 
         builder.ApplyGlobalFilters<ISoftDelete>(s => s.Deleted == null);
+
+        builder.AddInboxStateEntity();
+        builder.AddOutboxMessageEntity();
+        builder.AddOutboxStateEntity();
+
+        builder.Entity<InboxState>()
+            .ToTable(nameof(InboxState), nameof(MassTransit));
+
+        builder.Entity<OutboxMessage>()
+            .ToTable(nameof(OutboxMessage), nameof(MassTransit));
+
+        builder.Entity<OutboxState>()
+            .ToTable(nameof(OutboxState), nameof(MassTransit));
     }
 
     protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)