refactor: or-2334 make distinction between messages and commands

src/AssociationRegistry.Admin.Api/AssociationRegistry.Admin.Api.csproj

@@ -67,6 +67,7 @@
   <ItemGroup>
     <Folder Include="GrarConsumer\Handlers\Fusies\" />
     <Folder Include="Infrastructure\ConfigurationBindings\" />
+    <Folder Include="MessageHandling\Postgres\" />
     <Folder Include="Verenigingen\Contactgegevens\FeitelijkeVereniging\" />
     <Folder Include="Verenigingen\Vertegenwoordigers\FeitelijkeVereniging\" />
   </ItemGroup>

src/AssociationRegistry.Admin.Api/Infrastructure/Extensions/WolverineExtensions.cs

@@ -2,7 +2,6 @@
 
 using Acties.GrarConsumer;
 using Amazon.Runtime;
-using Dubbels;
 using EventStore;
 using Grar.AddressMatch;
 using Hosts.Configuration;
@@ -13,6 +12,8 @@
 using Wolverine.AmazonSqs;
 using Wolverine.ErrorHandling;
 using Wolverine.Postgresql;
+using VoegDubbelToeMessage = Messages.VoegDubbelToeMessage;
+using VoegDubbelToeMessageHandler = MessageHandling.Postgres.Dubbels.VoegDubbelToeMessageHandler;
 
 public static class WolverineExtensions
 {

src/AssociationRegistry.Admin.Api/Infrastructure/ResponseWriter/ResponseWriter.cs

@@ -1,6 +1,6 @@
 namespace AssociationRegistry.Admin.Api.Infrastructure.ResponseWriter;
 
-using AssociationRegistry.Admin.Api.Infrastructure.Extensions;
+using Extensions;
 using Be.Vlaanderen.Basisregisters.Api.Exceptions;
 using Microsoft.AspNetCore.Mvc;
 

src/AssociationRegistry.Admin.Api/Infrastructure/Sequence/SequenceGuarder.cs

@@ -1,8 +1,8 @@
 namespace AssociationRegistry.Admin.Api.Infrastructure.Sequence;
 
-using AssociationRegistry.Admin.Api.Infrastructure.Extensions;
-using AssociationRegistry.Admin.Schema.Detail;
-using AssociationRegistry.EventStore;
+using Extensions;
+using Schema.Detail;
+using EventStore;
 using Marten;
 
 public class SequenceGuarder : ISequenceGuarder

src/AssociationRegistry.Admin.Api/Infrastructure/Validation/FluentValidatorExtensions.cs

@@ -1,6 +1,6 @@
 namespace AssociationRegistry.Admin.Api.Infrastructure.Validation;
 
-using AssociationRegistry.Admin.Api.Infrastructure.ExceptionHandlers;
+using ExceptionHandlers;
 using FluentValidation;
 using System.Diagnostics.CodeAnalysis;
 

src/AssociationRegistry.Admin.Api/MessageHandling/Postgres/Dubbels/VoegDubbelToeMessageHandler.cs

@@ -0,0 +1,14 @@
+namespace AssociationRegistry.Admin.Api.MessageHandling.Postgres.Dubbels;
+
+using Messages;
+using Wolverine;
+
+public class VoegDubbelToeMessageHandler(IMessageBus messageBus)
+{
+    public async Task Handle(VoegDubbelToeMessage message, CancellationToken cancellationToken)
+    {
+        var command = message.ToCommand();
+
+        await messageBus.InvokeAsync(command, cancellationToken);
+    }
+}

src/AssociationRegistry.Admin.Api/Verenigingen/Registreer/MetRechtspersoonlijkheid/RequestModels/RegistreerVerenigingUitKboRequestValidator.cs

@@ -1,7 +1,7 @@
 // ReSharper disable ConditionIsAlwaysTrueOrFalseAccordingToNullableAPIContract
 namespace AssociationRegistry.Admin.Api.Verenigingen.Registreer.MetRechtspersoonlijkheid.RequestModels;
 
-using AssociationRegistry.Admin.Api.Infrastructure.Validation;
+using Infrastructure.Validation;
 using FluentValidation;
 
 public class RegistreerVerenigingUitKboRequestValidator : AbstractValidator<RegistreerVerenigingUitKboRequest>

src/AssociationRegistry/Acties/MarkeerAlsDubbelVan/MarkeerAlsDubbelVanCommandHandler.cs

@@ -1,8 +1,8 @@
 namespace AssociationRegistry.Acties.MarkeerAlsDubbelVan;
 
-using Dubbels;
 using Framework;
 using Marten;
+using Messages;
 using Vereniging;
 using Vereniging.Exceptions;
 using Wolverine.Marten;

src/AssociationRegistry/Acties/VoegDubbelToe/VoegDubbelToeCommand.cs

@@ -0,0 +1,5 @@
+namespace AssociationRegistry.Acties.VoegDubbelToe;
+
+using Vereniging;
+
+public record VoegDubbelToeCommand(VCode VCode, VCode VCodeDubbeleVereniging);

src/AssociationRegistry/Dubbels/VoegDubbelToeMessageHandler.cs → src/AssociationRegistry/Acties/VoegDubbelToe/VoegDubbelToeCommandHandler.cs

@@ -1,17 +1,17 @@
-namespace AssociationRegistry.Dubbels;
+namespace AssociationRegistry.Acties.VoegDubbelToe;
 
-using AssociationRegistry.EventStore;
-using AssociationRegistry.Framework;
-using NodaTime;
+using EventStore;
+using Framework;
 using Vereniging;
+using NodaTime;
 
-public class VoegDubbelToeMessageHandler(IVerenigingsRepository repository)
+public class VoegDubbelToeCommandHandler(IVerenigingsRepository repository)
 {
-    public async Task Handle(VoegDubbelToeMessage message, CancellationToken cancellationToken)
+    public async Task Handle(VoegDubbelToeCommand command, CancellationToken cancellationToken)
     {
-        var vereniging = await repository.Load<Vereniging>(message.VCode);
+        var vereniging = await repository.Load<Vereniging>(command.VCode);
 
-        vereniging.VoegDubbeleVerenigingToe(message.VCodeDubbeleVereniging);
+        vereniging.VoegDubbeleVerenigingToe(command.VCodeDubbeleVereniging);
 
         await repository.Save(
             vereniging,

src/AssociationRegistry/Messages/VoegDubbelToeMessage.cs

@@ -0,0 +1,10 @@
+namespace AssociationRegistry.Messages;
+
+using AssociationRegistry.Acties.VoegDubbelToe;
+using AssociationRegistry.Vereniging;
+
+public record VoegDubbelToeMessage(VCode VCode, VCode VCodeDubbeleVereniging)
+{
+    public VoegDubbelToeCommand ToCommand()
+        => new(VCode, VCodeDubbeleVereniging);
+}

test/AssociationRegistry.Test.Admin.Api/Commands/FeitelijkeVereniging/When_MarkeerAlsDubbelVan/CommandHandling/Given_A_Vereniging.cs

@@ -6,14 +6,13 @@ namespace AssociationRegistry.Test.Admin.Api.Commands.FeitelijkeVereniging.When_
 using Common.AutoFixture;
 using Common.Framework;
 using Common.Scenarios.CommandHandling;
-using Dubbels;
 using Events;
 using FluentAssertions;
 using GrarConsumer.FusieEvents.When_Consuming_Merger_Events;
 using Marten;
+using Messages;
 using Moq;
 using Vereniging;
-using Wolverine;
 using Wolverine.Marten;
 using Xunit;
 using Xunit.Categories;

test/AssociationRegistry.Test/WhenVoegDubbelToe/Given_VCode_And_VCodeDubbeleVereniging_Are_The_Same.cs

@@ -1,10 +1,10 @@
 namespace AssociationRegistry.Test.WhenVoegDubbelToe;
 
+using Acties.VoegDubbelToe;
 using AutoFixture;
 using Common.AutoFixture;
 using Common.Framework;
 using Common.Scenarios.CommandHandling;
-using Dubbels;
 using Vereniging;
 using Vereniging.Exceptions;
 using Xunit;
@@ -18,14 +18,14 @@ public async Task Then_Throws_InvalidOperationVerenigingKanGeenDubbelWordenVanZi
         var scenario = new FeitelijkeVerenigingWerdGeregistreerdScenario();
         var repositoryMock = new VerenigingRepositoryMock(scenario.GetVerenigingState());
         var vCode = fixture.Create<VCode>();
-        var message = fixture.Create<VoegDubbelToeMessage>() with
+        var command = fixture.Create<VoegDubbelToeCommand>() with
         {
             VCode = scenario.VCode,
             VCodeDubbeleVereniging = scenario.VCode,
         };
-        var sut = new VoegDubbelToeMessageHandler(repositoryMock);
+        var sut = new VoegDubbelToeCommandHandler(repositoryMock);
 
         await Assert.ThrowsAsync<InvalidOperationVerenigingKanGeenDubbelWordenVanZichzelf>(
-            async () => await sut.Handle(message, CancellationToken.None));
+            async () => await sut.Handle(command, CancellationToken.None));
     }
 }

test/AssociationRegistry.Test/WhenVoegDubbelToe/Given_Valid_VoegDubbelToeMessage.cs → test/AssociationRegistry.Test/WhenVoegDubbelToe/Given_Valid_VoegDubbelToeCommand.cs

@@ -1,30 +1,30 @@
 namespace AssociationRegistry.Test.WhenVoegDubbelToe;
 
+using Acties.VoegDubbelToe;
 using AutoFixture;
 using Common.AutoFixture;
 using Common.Framework;
 using Common.Scenarios.CommandHandling;
-using Dubbels;
 using Events;
 using Xunit;
 
-public class Given_Valid_VoegDubbelToeMessage
+public class Given_Valid_VoegDubbelToeCommand
 {
     [Fact]
     public async Task Then_Throws_InvalidOperationVerenigingKanGeenDubbelWordenVanZichzelf()
     {
         var fixture = new Fixture().CustomizeDomain();
         var scenario = new FeitelijkeVerenigingWerdGeregistreerdScenario();
         var repositoryMock = new VerenigingRepositoryMock(scenario.GetVerenigingState());
-        var message = fixture.Create<VoegDubbelToeMessage>()
+        var command = fixture.Create<VoegDubbelToeCommand>()
             with
             {
                 VCode = scenario.VCode,
             };
-        var sut = new VoegDubbelToeMessageHandler(repositoryMock);
+        var sut = new VoegDubbelToeCommandHandler(repositoryMock);
 
-         await sut.Handle(message, CancellationToken.None);
+         await sut.Handle(command, CancellationToken.None);
 
-         repositoryMock.ShouldHaveSaved(new VerenigingWerdToegevoegdAlsDubbel(scenario.VCode, message.VCodeDubbeleVereniging));
+         repositoryMock.ShouldHaveSaved(new VerenigingWerdToegevoegdAlsDubbel(scenario.VCode, command.VCodeDubbeleVereniging));
     }
 }