Or 2334

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

@@ -6,16 +6,21 @@
 using Grar.AddressMatch;
 using Hosts.Configuration;
 using JasperFx.CodeGeneration;
+using MessageHandling.Postgres.Dubbels;
+using Messages;
 using Serilog;
 using Vereniging;
 using Wolverine;
 using Wolverine.AmazonSqs;
 using Wolverine.ErrorHandling;
+using Wolverine.Postgresql;
 
 public static class WolverineExtensions
 {
     public static void AddWolverine(this WebApplicationBuilder builder)
     {
+        const string AanvaardDubbeleVerenigingQueueName = "aanvaard-dubbele-vereniging-queue";
+
         builder.Host.UseWolverine(
             (context, options) =>
             {
@@ -26,6 +31,8 @@ public static void AddWolverine(this WebApplicationBuilder builder)
                 options.Discovery.IncludeType<TeAdresMatchenLocatieMessageHandler>();
                 options.Discovery.IncludeType<OverkoepelendeGrarConsumerMessage>();
                 options.Discovery.IncludeType<OverkoepelendeGrarConsumerMessageHandler>();
+                options.Discovery.IncludeType<AanvaardDubbeleVerenigingMessage>();
+                options.Discovery.IncludeType<AanvaardDubbeleVerenigingMessageHandler>();
 
                 options.OnException<UnexpectedAggregateVersionDuringSyncException>().RetryWithCooldown(
                     TimeSpan.FromSeconds(1),
@@ -50,12 +57,19 @@ public static void AddWolverine(this WebApplicationBuilder builder)
 
                 ConfigureAddressMatchPublisher(options, grarOptions.Sqs.AddressMatchQueueName);
 
-                ConfiguredAddressMatchListener(options, grarOptions.Sqs.AddressMatchQueueName,
+                ConfigureAddressMatchListener(options, grarOptions.Sqs.AddressMatchQueueName,
                                                grarOptions.Sqs.AddressMatchDeadLetterQueueName);
 
                 ConfigureGrarSyncListener(options, grarOptions.Sqs.GrarSyncQueueName, grarOptions.Sqs.GrarSyncDeadLetterQueueName,
                                           grarOptions.Sqs.GrarSyncQueueListenerEnabled);
 
+                options.PersistMessagesWithPostgresql(context.Configuration.GetPostgreSqlOptionsSection().GetConnectionString());
+
+                options.PublishMessage<AanvaardDubbeleVerenigingMessage>()
+                       .ToPostgresqlQueue(AanvaardDubbeleVerenigingQueueName);
+
+                options.ListenToPostgresqlQueue(AanvaardDubbeleVerenigingQueueName);
+
                 if (grarOptions.Wolverine.AutoProvision)
                     transportConfiguration.AutoProvision();
 
@@ -73,7 +87,7 @@ private static void ConfigureAddressMatchPublisher(WolverineOptions options, str
                .MessageBatchSize(1);
     }
 
-    private static void ConfiguredAddressMatchListener(WolverineOptions options, string sqsQueueName, string sqsDeadLetterQueueName)
+    private static void ConfigureAddressMatchListener(WolverineOptions options, string sqsQueueName, string sqsDeadLetterQueueName)
     {
         options.ListenToSqsQueue(sqsQueueName, configure: configure =>
                 {

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/AanvaardDubbeleVerenigingMessageHandler.cs

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

src/AssociationRegistry.Admin.Api/Verenigingen/Detail/BeheerVerenigingDetailMapper.cs

@@ -79,6 +79,7 @@ private static VerenigingDetail Map(
             Relaties = vereniging.Relaties.Select(relatie => Map(relatie, baseUrl)).ToArray(),
             Lidmaatschappen = vereniging.Lidmaatschappen.Select(lidmaatschap => Map(lidmaatschap, namenVoorLidmaatschapMapper)).ToArray(),
             Bron = vereniging.Bron,
+            IsDubbelVan = vereniging.IsDubbelVan,
         };
     }
 

src/AssociationRegistry.Admin.Api/Verenigingen/Detail/ResponseModels/VerenigingDetail.cs

@@ -102,4 +102,8 @@ public class VerenigingDetail
     /// </summary>
     [DataMember(Name = "Bron")]
     public string Bron { get; set; } = null!;
+
+    /// <summary>De VCode van de vereniging waarvan deze vereniging een dubbel is</summary>
+    [DataMember(Name = "IsDubbelVan")]
+    public string IsDubbelVan { get; set; }
 }

src/AssociationRegistry.Admin.Api/Verenigingen/Dubbels/FeitelijkeVereniging/MarkeerAlsDubbelVan/Examples/MarkeerAlsDubbelVanRequestExamples.cs

@@ -0,0 +1,13 @@
+namespace AssociationRegistry.Admin.Api.Verenigingen.Dubbels.FeitelijkeVereniging.MarkeerAlsDubbelVan.Examples;
+
+using RequestModels;
+using Swashbuckle.AspNetCore.Filters;
+
+public class MarkeerAlsDubbelVanRequestExamples : IExamplesProvider<MarkeerAlsDubbelVanRequest>
+{
+    public MarkeerAlsDubbelVanRequest GetExamples()
+        => new()
+        {
+           IsDubbelVan = "V0001002",
+        };
+}

src/AssociationRegistry.Admin.Api/Verenigingen/Dubbels/FeitelijkeVereniging/MarkeerAlsDubbelVan/MarkeerAlsDubbelVanController.cs

@@ -0,0 +1,87 @@
+namespace AssociationRegistry.Admin.Api.Verenigingen.Dubbels.FeitelijkeVereniging.MarkeerAlsDubbelVan;
+
+using Acties.MarkeerAlsDubbelVan;
+using Asp.Versioning;
+using Be.Vlaanderen.Basisregisters.Api;
+using Be.Vlaanderen.Basisregisters.Api.Exceptions;
+using Examples;
+using FluentValidation;
+using Framework;
+using Hosts.Configuration.ConfigurationBindings;
+using Infrastructure;
+using Infrastructure.Extensions;
+using Infrastructure.Middleware;
+using Infrastructure.Swagger.Annotations;
+using Infrastructure.Swagger.Examples;
+using Infrastructure.Validation;
+using Microsoft.AspNetCore.Mvc;
+using RequestModels;
+using Swashbuckle.AspNetCore.Filters;
+using Vereniging;
+using Wolverine;
+using ProblemDetails = Be.Vlaanderen.Basisregisters.BasicApiProblem.ProblemDetails;
+using ValidationProblemDetails = Be.Vlaanderen.Basisregisters.BasicApiProblem.ValidationProblemDetails;
+
+[ApiVersion("1.0")]
+[AdvertiseApiVersions("1.0")]
+[ApiRoute("verenigingen")]
+[SwaggerGroup.DecentraalBeheer]
+public class MarkeerAlsDubbelVanController : ApiController
+{
+    private readonly IMessageBus _messageBus;
+    private readonly IValidator<MarkeerAlsDubbelVanRequest> _validator;
+    private readonly AppSettings _appSettings;
+
+    public MarkeerAlsDubbelVanController(IMessageBus messageBus, IValidator<MarkeerAlsDubbelVanRequest> validator, AppSettings appSettings)
+    {
+        _messageBus = messageBus;
+        _validator = validator;
+        _appSettings = appSettings;
+    }
+
+    /// <summary>
+    ///     Markeer een vereniging als dubbel van een andere vereniging.
+    /// </summary>
+    /// <remarks>
+    ///     Na het uitvoeren van deze actie wordt een sequentie teruggegeven via de `VR-Sequence` header.
+    ///     Deze waarde kan gebruikt worden in andere endpoints om op te volgen of de aanpassing
+    ///     al is doorgestroomd naar deze endpoints.
+    /// </remarks>
+    /// <param name="vCode">De vCode van de vereniging.</param>
+    /// <param name="request">De gegevens van de andere vereniging waarvan deze een dubbel is.</param>
+    /// <param name="metadataProvider"></param>
+    /// <param name="ifMatch">If-Match header met ETag van de laatst gekende versie van de vereniging.</param>
+    /// <response code="202">De vereniging werd als dubbel gemarkeerd.</response>
+    /// <response code="400">Er was een probleem met de doorgestuurde waarden.</response>
+    /// <response code="412">De gevraagde vereniging heeft niet de verwachte sequentiewaarde.</response>
+    /// <response code="500">Er is een interne fout opgetreden.</response>
+    [HttpPost("{vCode}/dubbelVan")]
+    [ConsumesJson]
+    [ProducesJson]
+    [SwaggerRequestExample(typeof(MarkeerAlsDubbelVanRequest), typeof(MarkeerAlsDubbelVanRequestExamples))]
+    [SwaggerResponseHeader(StatusCodes.Status202Accepted, WellknownHeaderNames.Sequence, type: "string",
+                           description: "Het sequence nummer van deze request.")]
+    [SwaggerResponseHeader(StatusCodes.Status202Accepted, name: "ETag", type: "string",
+                           description: "De versie van de vereniging die als dubbel werd gemarkeerd.")]
+    [SwaggerResponseExample(StatusCodes.Status400BadRequest, typeof(ProblemAndValidationProblemDetailsExamples))]
+    [SwaggerResponseExample(StatusCodes.Status412PreconditionFailed, typeof(PreconditionFailedProblemDetailsExamples))]
+    [SwaggerResponseExample(StatusCodes.Status500InternalServerError, typeof(InternalServerErrorResponseExamples))]
+    [ProducesResponseType(StatusCodes.Status202Accepted)]
+    [ProducesResponseType(typeof(ValidationProblemDetails), StatusCodes.Status400BadRequest)]
+    [ProducesResponseType(typeof(ProblemDetails), StatusCodes.Status412PreconditionFailed)]
+    [ProducesResponseType(typeof(ProblemDetails), StatusCodes.Status500InternalServerError)]
+    public async Task<IActionResult> Post(
+        [FromRoute] string vCode,
+        [FromBody] MarkeerAlsDubbelVanRequest request,
+        [FromServices] ICommandMetadataProvider metadataProvider,
+        [FromHeader(Name = "If-Match")] string? ifMatch = null)
+    {
+        await _validator.NullValidateAndThrowAsync(request);
+
+        var metaData = metadataProvider.GetMetadata(IfMatchParser.ParseIfMatch(ifMatch));
+        var envelope = new CommandEnvelope<MarkeerAlsDubbelVanCommand>(request.ToCommand(vCode), metaData);
+        var commandResult = await _messageBus.InvokeAsync<CommandResult>(envelope);
+
+        return this.AcceptedCommand(_appSettings, commandResult);
+    }
+}

src/AssociationRegistry.Admin.Api/Verenigingen/Dubbels/FeitelijkeVereniging/MarkeerAlsDubbelVan/MarkeerAlsDubbelVanValidator.cs

@@ -0,0 +1,17 @@
+namespace AssociationRegistry.Admin.Api.Verenigingen.Dubbels.FeitelijkeVereniging.MarkeerAlsDubbelVan;
+
+using FluentValidation;
+using Infrastructure.Validation;
+using RequestModels;
+
+// ReSharper disable ConditionIsAlwaysTrueOrFalseAccordingToNullableAPIContract
+public class MarkeerAlsDubbelVanValidator : AbstractValidator<MarkeerAlsDubbelVanRequest>
+{
+    public MarkeerAlsDubbelVanValidator()
+    {
+        RuleFor(r => r.IsDubbelVan)
+           .NotNull()
+           .NotEmpty()
+           .WithVeldIsVerplichtMessage(nameof(MarkeerAlsDubbelVanRequest.IsDubbelVan));
+    }
+}

src/AssociationRegistry.Admin.Api/Verenigingen/Dubbels/FeitelijkeVereniging/MarkeerAlsDubbelVan/RequestModels/MarkeerAlsDubbelVanRequest.cs

@@ -0,0 +1,16 @@
+namespace AssociationRegistry.Admin.Api.Verenigingen.Dubbels.FeitelijkeVereniging.MarkeerAlsDubbelVan.RequestModels;
+
+using Acties.MarkeerAlsDubbelVan;
+using System.Runtime.Serialization;
+using Vereniging;
+
+[DataContract]
+public class MarkeerAlsDubbelVanRequest
+{
+    /// <summary>De VCode van de vereniging waarvan deze vereniging een dubbel is.</summary>
+    [DataMember(Name = "isDubbelVan")]
+    public string IsDubbelVan { get; set; } = null!;
+
+    public MarkeerAlsDubbelVanCommand ToCommand(string vCode)
+        => new(VCode.Create(vCode), VCode.Create(IsDubbelVan));
+}

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.Admin.ProjectionHost/Projections/Detail/BeheerVerenigingDetailProjection.cs

@@ -224,6 +224,12 @@ public async Task Project(IEvent<LidmaatschapWerdGewijzigd> @event, IDocumentOpe
     public async Task Project(IEvent<LidmaatschapWerdVerwijderd> @event, IDocumentOperations ops)
         => await Update(@event, ops, BeheerVerenigingDetailProjector.Apply);
 
+    public async Task Project(IEvent<VerenigingWerdGermarkeerdAlsDubbelVan> @event, IDocumentOperations ops)
+        => await Update(@event, ops, BeheerVerenigingDetailProjector.Apply);
+
+    public async Task Project(IEvent<VerenigingAanvaardeDubbeleVereniging> @event, IDocumentOperations ops)
+        => await Update(@event, ops, BeheerVerenigingDetailProjector.Apply);
+
     private async Task SoftDelete(string? streamKey, IDocumentOperations ops)
         => ops.Delete<BeheerVerenigingDetailDocument>(streamKey);
 

src/AssociationRegistry.Admin.ProjectionHost/Projections/Detail/BeheerVerenigingDetailProjector.cs

@@ -36,6 +36,7 @@ public static BeheerVerenigingDetailDocument Create(IEvent<FeitelijkeVerenigingW
                                                                           .FormatAsBelgianDate(),
             Status = VerenigingStatus.Actief,
             IsUitgeschrevenUitPubliekeDatastroom = feitelijkeVerenigingWerdGeregistreerd.Data.IsUitgeschrevenUitPubliekeDatastroom,
+            IsDubbelVan = "",
             Contactgegevens = feitelijkeVerenigingWerdGeregistreerd.Data.Contactgegevens
                                                                    .Select(c => BeheerVerenigingDetailMapper.MapContactgegeven(
                                                                                c, feitelijkeVerenigingWerdGeregistreerd.Data.Bron,
@@ -90,6 +91,7 @@ public static BeheerVerenigingDetailDocument Create(
             DatumLaatsteAanpassing = verenigingMetRechtspersoonlijkheidWerdGeregistreerd.GetHeaderInstant(MetadataHeaderNames.Tijdstip).FormatAsBelgianDate(),
             Status = VerenigingStatus.Actief,
             IsUitgeschrevenUitPubliekeDatastroom = false,
+            IsDubbelVan = "",
             Contactgegevens = [],
             Locaties = [],
             Vertegenwoordigers = [],
@@ -746,4 +748,19 @@ public static void Apply(IEvent<LidmaatschapWerdVerwijderd> lidmaatschapWerdToeg
                                            .OrderBy(l => l.LidmaatschapId)
                                            .ToArray();
     }
+
+
+    public static void Apply(IEvent<VerenigingWerdGermarkeerdAlsDubbelVan> verenigingWerdGemarkeerdAlsDubbel, BeheerVerenigingDetailDocument document)
+    {
+        document.Status = VerenigingStatus.Dubbel;
+        document.IsDubbelVan = verenigingWerdGemarkeerdAlsDubbel.Data.VCodeAuthentiekeVereniging;
+    }
+
+    public static void Apply(IEvent<VerenigingAanvaardeDubbeleVereniging> verenigingAanvaardeDubbeleVereniging, BeheerVerenigingDetailDocument document)
+    {
+        document.CorresponderendeVCodes =
+            document.CorresponderendeVCodes
+                    .Append(verenigingAanvaardeDubbeleVereniging.Data.VCodeDubbeleVereniging)
+                    .ToArray();
+    }
 }

src/AssociationRegistry.Admin.Schema/Constants/VerenigingStatus.cs

@@ -4,4 +4,5 @@ public static class VerenigingStatus
 {
     public const string Actief = "Actief";
     public const string Gestopt = "Gestopt";
+    public const string Dubbel = "Dubbel";
 }

src/AssociationRegistry.Admin.Schema/Detail/BeheerVerenigingDetailDocument.cs

@@ -38,4 +38,5 @@ public record BeheerVerenigingDetailDocument : IVCode, ISoftDeleted, IMetadata
     [Identity] public string VCode { get; init; } = null!;
     public bool Deleted { get; set; }
     public DateTimeOffset? DeletedAt { get; set; }
+    public string IsDubbelVan { get; set; } = string.Empty;
 }

src/AssociationRegistry/Acties/AanvaardDubbel/AanvaardDubbeleVerenigingCommand.cs

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

src/AssociationRegistry/Acties/AanvaardDubbel/AanvaardDubbeleVerenigingCommandHandler.cs

@@ -0,0 +1,23 @@
+namespace AssociationRegistry.Acties.AanvaardDubbel;
+
+using AssociationRegistry.EventStore;
+using AssociationRegistry.Framework;
+using AssociationRegistry.Vereniging;
+using NodaTime;
+
+public class AanvaardDubbeleVerenigingCommandHandler(IVerenigingsRepository repository)
+{
+    public async Task Handle(AanvaardDubbeleVerenigingCommand command, CancellationToken cancellationToken)
+    {
+        var vereniging = await repository.Load<Vereniging>(command.VCode);
+
+        vereniging.AanvaardDubbeleVereniging(command.VCodeDubbeleVereniging);
+
+        await repository.Save(
+            vereniging,
+            new CommandMetadata(EventStore.DigitaalVlaanderenOvoNumber,
+                                SystemClock.Instance.GetCurrentInstant(),
+                                Guid.NewGuid()),
+            cancellationToken);
+    }
+}

src/AssociationRegistry/Acties/MarkeerAlsDubbelVan/MarkeerAlsDubbelVanCommand.cs

@@ -0,0 +1,5 @@
+namespace AssociationRegistry.Acties.MarkeerAlsDubbelVan;
+
+using Vereniging;
+
+public record MarkeerAlsDubbelVanCommand(VCode VCode, VCode VCodeAuthentiekeVereniging);