Add RabbitMQ and MassTransit dependencies. Configure Continent and Co…

…untry consumers

src/Ace.Geograpi.Infrastructure/Ace.Geograpi.Infrastructure.csproj

@@ -11,6 +11,7 @@
   <ItemGroup>
     <PackageReference Include="AceCSharp.StructuredAutoMapper" Version="3.0.0" />
     <PackageReference Include="CatNip.Infrastructure" Version="3.0.0" />
+    <PackageReference Include="MassTransit.RabbitMQ" Version="8.3.3" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.0">
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>

src/Ace.Geograpi.Infrastructure/DependencyInjection.cs

@@ -5,6 +5,8 @@
 using Ace.Geograpi.Infrastructure.Mappers;
 using Ace.Geograpi.Infrastructure.Mappers.Root;
 using Ace.Geograpi.Infrastructure.Mappers.Traceable;
+using Ace.Geograpi.Infrastructure.MessageBus.Consumers.Continents;
+using Ace.Geograpi.Infrastructure.MessageBus.Consumers.Countries;
 using Ace.Geograpi.Infrastructure.Repositories;
 
 namespace Ace.Geograpi.Infrastructure;
@@ -16,6 +18,24 @@ public static void AddInfrastructure(this IHostApplicationBuilder builder)
         builder.Services.AddDatabase(builder.Configuration, builder.Environment);
         builder.Services.AddMappers();
         builder.Services.AddRepositories();
+
+        builder.Services.AddMassTransit(config =>
+        {
+            config.AddConsumer<ContinentCreatedEventConsumer, ContinentCreatedEventConsumerDefinition>();
+            config.AddConsumer<ContinentUpdatedEventConsumer, ContinentUpdatedEventConsumerDefinition>();
+            config.AddConsumer<ContinentDeletedEventConsumer, ContinentDeletedEventConsumerDefinition>();
+
+            config.AddConsumer<CountryCreatedEventConsumer, CountryCreatedEventConsumerDefinition>();
+            config.AddConsumer<CountryUpdatedEventConsumer, CountryUpdatedEventConsumerDefinition>();
+            config.AddConsumer<CountryDeletedEventConsumer, CountryDeletedEventConsumerDefinition>();
+
+            config.UsingRabbitMq((context, configure) =>
+            {
+                configure.Host(builder.Configuration.GetConnectionString("RabbitMQ"));
+
+                configure.ConfigureEndpoints(context);
+            });
+        });
     }
 
     internal static void AddDatabase(

src/Ace.Geograpi.Infrastructure/GlobalUsings.cs

@@ -1,5 +1,6 @@
 global using Ace.CSharp.StructuredAutoMapper;
 global using AutoMapper;
+global using MassTransit;
 global using Microsoft.EntityFrameworkCore;
 global using Microsoft.EntityFrameworkCore.Metadata.Builders;
 global using Microsoft.Extensions.Configuration;

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Continents/ContinentCreatedEventConsumer.cs

@@ -0,0 +1,11 @@
+using Ace.Geograpi.Domain.Events.Continents;
+
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Continents;
+
+internal sealed class ContinentCreatedEventConsumer : IConsumer<ContinentCreatedEvent>
+{
+    public Task Consume(ConsumeContext<ContinentCreatedEvent> context)
+    {
+        throw new NotImplementedException();
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Continents/ContinentCreatedEventConsumerDefinition.cs

@@ -0,0 +1,10 @@
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Continents;
+
+internal sealed class ContinentCreatedEventConsumerDefinition
+    : ConsumerDefinition<ContinentCreatedEventConsumer>
+{
+    public ContinentCreatedEventConsumerDefinition()
+    {
+        EndpointName = "geograpi-continent-created";
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Continents/ContinentDeletedEventConsumer.cs

@@ -0,0 +1,11 @@
+using Ace.Geograpi.Domain.Events.Continents;
+
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Continents;
+
+internal sealed class ContinentDeletedEventConsumer : IConsumer<ContinentDeletedEvent>
+{
+    public Task Consume(ConsumeContext<ContinentDeletedEvent> context)
+    {
+        throw new NotImplementedException();
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Continents/ContinentDeletedEventConsumerDefinition.cs

@@ -0,0 +1,10 @@
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Continents;
+
+internal sealed class ContinentDeletedEventConsumerDefinition
+    : ConsumerDefinition<ContinentDeletedEventConsumer>
+{
+    public ContinentDeletedEventConsumerDefinition()
+    {
+        EndpointName = "geograpi-continent-deleted";
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Continents/ContinentUpdatedEventConsumer.cs

@@ -0,0 +1,11 @@
+using Ace.Geograpi.Domain.Events.Continents;
+
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Continents;
+
+internal sealed class ContinentUpdatedEventConsumer : IConsumer<ContinentUpdatedEvent>
+{
+    public Task Consume(ConsumeContext<ContinentUpdatedEvent> context)
+    {
+        throw new NotImplementedException();
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Continents/ContinentUpdatedEventConsumerDefinition.cs

@@ -0,0 +1,10 @@
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Continents;
+
+internal sealed class ContinentUpdatedEventConsumerDefinition
+    : ConsumerDefinition<ContinentUpdatedEventConsumer>
+{
+    public ContinentUpdatedEventConsumerDefinition()
+    {
+        EndpointName = "geograpi-continent-updated";
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Countries/CountryCreatedEventConsumer.cs

@@ -0,0 +1,11 @@
+using Ace.Geograpi.Domain.Events.Countries;
+
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Countries;
+
+internal sealed class CountryCreatedEventConsumer : IConsumer<CountryCreatedEvent>
+{
+    public Task Consume(ConsumeContext<CountryCreatedEvent> context)
+    {
+        throw new NotImplementedException();
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Countries/CountryCreatedEventConsumerDefinition.cs

@@ -0,0 +1,10 @@
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Countries;
+
+internal sealed class CountryCreatedEventConsumerDefinition
+    : ConsumerDefinition<CountryCreatedEventConsumer>
+{
+    public CountryCreatedEventConsumerDefinition()
+    {
+        EndpointName = "geograpi-country-created";
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Countries/CountryDeletedEventConsumer.cs

@@ -0,0 +1,11 @@
+using Ace.Geograpi.Domain.Events.Countries;
+
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Countries;
+
+internal sealed class CountryDeletedEventConsumer : IConsumer<CountryDeletedEvent>
+{
+    public Task Consume(ConsumeContext<CountryDeletedEvent> context)
+    {
+        throw new NotImplementedException();
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Countries/CountryDeletedEventConsumerDefinition.cs

@@ -0,0 +1,10 @@
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Countries;
+
+internal sealed class CountryDeletedEventConsumerDefinition
+    : ConsumerDefinition<CountryDeletedEventConsumer>
+{
+    public CountryDeletedEventConsumerDefinition()
+    {
+        EndpointName = "geograpi-country-deleted";
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Countries/CountryUpdatedEventConsumer.cs

@@ -0,0 +1,11 @@
+using Ace.Geograpi.Domain.Events.Countries;
+
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Countries;
+
+internal sealed class CountryUpdatedEventConsumer : IConsumer<CountryUpdatedEvent>
+{
+    public Task Consume(ConsumeContext<CountryUpdatedEvent> context)
+    {
+        throw new NotImplementedException();
+    }
+}

src/Ace.Geograpi.Infrastructure/MessageBus/Consumers/Countries/CountryUpdatedEventConsumerDefinition.cs

@@ -0,0 +1,10 @@
+namespace Ace.Geograpi.Infrastructure.MessageBus.Consumers.Countries;
+
+internal sealed class CountryUpdatedEventConsumerDefinition
+    : ConsumerDefinition<CountryUpdatedEventConsumer>
+{
+    public CountryUpdatedEventConsumerDefinition()
+    {
+        EndpointName = "geograpi-country-updated";
+    }
+}

src/Ace.Geograpi.Web/appsettings.Development.json

@@ -1,6 +1,7 @@
 {
   "ConnectionStrings": {
-    "Database": "Host=localhost;Port=5432;Database=geograpi;Username=postgres;Password=postgres"
+    "Database": "Host=localhost;Port=5432;Database=geograpi;Username=postgres;Password=postgres",
+    "RabbitMQ": "amqp://guest:guest@localhost:5672"
   },
   "Serilog": {
     "Using": [ "Serilog.Sinks.Console", "Serilog.Sinks.File" ],

src/Ace.Geograpi.Web/appsettings.Docker.json

@@ -1,7 +1,8 @@
 {
   "ConnectionStrings": {
     "Database": "Host=ace.geograpi.db;Port=5432;Database=geograpi;Username=postgres;Password=postgres",
-    "_Database": "Host=localhost;Port=5432;Database=geograpi;Username=postgres;Password=postgres"
+    "_Database": "Host=localhost;Port=5432;Database=geograpi;Username=postgres;Password=postgres",
+    "RabbitMQ": "amqp://guest:[email protected]:5672"
   },
   "Serilog": {
     "Using": [ "Serilog.Sinks.Console", "Serilog.Sinks.File" ],

src/Ace.Geograpi.Web/appsettings.json

@@ -1,6 +1,7 @@
 {
   "ConnectionStrings": {
-    "Database": ""
+    "Database": "",
+    "RabbitMQ": ""
   },
   "Serilog": {
     "Using": [ "Serilog.Sinks.Console", "Serilog.Sinks.File" ],