Informatievlaanderen · janlesage · Dec 20, 2023 · Dec 13, 2023 · Dec 19, 2023 · Dec 20, 2023
@@ -20,14 +20,20 @@
         _documentStore = documentStore;
     }
 
-    public async Task<StreamActionResult> Save(string aggregateId, CommandMetadata metadata, CancellationToken cancellationToken = default, params IEvent[] events)
+    public async Task<StreamActionResult> Save(
+        string aggregateId,
+        CommandMetadata metadata,
+        CancellationToken cancellationToken = default,
+        params IEvent[] events)
     {
         await using var session = _documentStore.OpenSession();
 
         try
         {
             SetHeaders(metadata, session);
 
+            TryLockForKboNumber(aggregateId, session, events.FirstOrDefault());
+
             var streamAction = AppendEvents(session, aggregateId, events, metadata.ExpectedVersion);
 
             await session.SaveChangesAsync(cancellationToken);
@@ -40,6 +46,12 @@
         }
     }
 
+    private static void TryLockForKboNumber(string vCode, IDocumentSession session, IEvent? registreerEvent)
+    {
+        if (registreerEvent is VerenigingMetRechtspersoonlijkheidWerdGeregistreerd evnt)
+            session.Events.StartStream<KboNummer>(evnt.KboNummer, new { VCode = vCode });
+    }
+
     private static StreamAction AppendEvents(IDocumentSession session, string aggregateId, IReadOnlyCollection<IEvent> events, long? expectedVersion)
     {
         if (expectedVersion is not null)
@@ -65,7 +77,7 @@

    public async Task<T> Load<T>(string id) where T : class, IHasVersion, new()
    {
        await using var session = _documentStore.OpenSession();

        return await session.Events.AggregateStreamAsync<T>(id) ??
               throw new AggregateNotFoundException(id, typeof(T));
@@ -73,7 +85,7 @@

    public async Task<T?> Load<T>(KboNummer kboNummer) where T : class, IHasVersion, new()
    {
        await using var session = _documentStore.OpenSession();

        var id = (await session.Events.QueryRawEventDataOnly<VerenigingMetRechtspersoonlijkheidWerdGeregistreerd>()
                               .Where(geregistreerd => geregistreerd.KboNummer == kboNummer)

@@ -31,7 +31,7 @@ public V029_VerenigingMetRechtspersoonlijkheidWerdGeregistreerd_With_All_Data()
             VCode = VCode,
             Naam = Naam,
             KorteNaam = "RDZ",
-            KboNummer = "7981199887",
+            KboNummer = "7981199829",
             Rechtsvorm = Verenigingstype.VZW.Code,
         };
 

@@ -29,7 +29,7 @@ public V030_VerenigingeMetRechtspersoonlijkheidWerdGeregistreerd_With_Invalid_Da
             VCode = VCode,
             Naam = Naam,
             KorteNaam = "RDZ",
-            KboNummer = "7981199887",
+            KboNummer = "7981199830",
         };
 
         MaatschappelijkeZetelKonNietOvergenomenWordenUitKbo = new MaatschappelijkeZetelKonNietOvergenomenWordenUitKbo(

@@ -25,7 +25,7 @@ public V045_VerenigingMetRechtspersoonlijkheidWerdGeregistreerd_With_Contactgege
             VCode = VCode,
             Naam = Naam,
             KorteNaam = "RDZ",
-            KboNummer = "7981199887",
+            KboNummer = "7981199845",
             Rechtsvorm = Verenigingstype.VZW.Code,
         };
 

@@ -43,9 +43,9 @@ public async Task Then_It_Returns_GeefOndernemingResponseBody(MagdaOptionsSectio
             onderneming?.Namen.MaatschappelijkeNamen.Should().ContainEquivalentOf(
                 new NaamOndernemingType
                 {
-                    Naam = "Vlaamse Liga tegen Kanker",
+                    Naam = "Kom op tegen Kanker",
                     Taalcode = "nl",
-                    DatumBegin = "1998-01-01",
+                    DatumBegin = "2015-10-13",
                     DatumEinde = null,
                 });
 

@@ -0,0 +1,78 @@
+namespace AssociationRegistry.Test.Admin.Api.VerenigingMetRechtspersoonlijkheid.When_RegistreerVerenigingMetRechtspersoonlijkheid;
+
+using AssociationRegistry.Admin.Api.Verenigingen.Registreer.MetRechtspersoonlijkheid.RequestModels;
+using AutoFixture;
+using Events;
+using Fixtures;
+using FluentAssertions;
+using Framework;
+using System.Net;
+using Vereniging;
+using Xunit;
+using Xunit.Categories;
+
+public sealed class When_RegistreerVerenigingMetRechtspersoonlijkheid_With_Duplicate_Requests
+{
+    private static When_RegistreerVerenigingMetRechtspersoonlijkheid_With_Duplicate_Requests? called;
+    public readonly RegistreerVerenigingUitKboRequest UitKboRequest;
+    public readonly List<Tuple<Task<HttpResponseMessage>, Task<HttpResponseMessage>>> Responses;
+
+    private When_RegistreerVerenigingMetRechtspersoonlijkheid_With_Duplicate_Requests(EventsInDbScenariosFixture fixture)
+    {
+        var autofixture = new Fixture().CustomizeAdminApi();
+
+        UitKboRequest = new RegistreerVerenigingUitKboRequest
+        {
+            KboNummer = fixture.V020VerenigingMetRechtspersoonlijkheidWerdGeregistreerdForDuplicateDetection
+                               .VerenigingMetRechtspersoonlijkheidWerdGeregistreerd.KboNummer,
+        };
+
+        Responses = new List<Tuple<Task<HttpResponseMessage>, Task<HttpResponseMessage>>>();
+
+        foreach (var kboNummer in autofixture.CreateMany<KboNummer>(5))
+        {
+            var request = new RegistreerVerenigingUitKboRequest { KboNummer = kboNummer };
+
+            Responses.Add(new Tuple<Task<HttpResponseMessage>, Task<HttpResponseMessage>>(
+                             fixture.DefaultClient.RegistreerKboVereniging(GetJsonBody(request)),
+                             fixture.DefaultClient.RegistreerKboVereniging(GetJsonBody(request))));
+        }
+    }
+
+    public static When_RegistreerVerenigingMetRechtspersoonlijkheid_With_Duplicate_Requests Called(EventsInDbScenariosFixture fixture)
+        => called ??= new When_RegistreerVerenigingMetRechtspersoonlijkheid_With_Duplicate_Requests(fixture);
+
+    private string GetJsonBody(RegistreerVerenigingUitKboRequest uitKboRequest)
+        => GetType()
+          .GetAssociatedResourceJson("files.request.with_kboNummer")
+          .Replace(oldValue: "{{kboNummer}}", uitKboRequest.KboNummer);
+}
+
+[Collection(nameof(AdminApiCollection))]
+[Category("AdminApi")]
+[IntegrationTest]
+public class With_Duplicate_Requests
+{
+    private readonly EventsInDbScenariosFixture _fixture;
+
+    public With_Duplicate_Requests(EventsInDbScenariosFixture fixture)
+    {
+        _fixture = fixture;
+    }
+
+    private RegistreerVerenigingUitKboRequest Request
+        => When_RegistreerVerenigingMetRechtspersoonlijkheid_With_Duplicate_Requests.Called(_fixture).UitKboRequest;
+
+
+    [Fact]
+    public async Task Then_it_returns_an_ok_response_with_correct_headers()
+    {
+        var responses = When_RegistreerVerenigingMetRechtspersoonlijkheid_With_Duplicate_Requests.Called(_fixture).Responses;
+
+        foreach (var responseTuple in responses)
+        {
+            var httpResponseMessages = await Task.WhenAll(responseTuple.Item1, responseTuple.Item2);
+            httpResponseMessages.Count(x => x.StatusCode == HttpStatusCode.Accepted).Should().Be(1);
+        }
+    }
+}
@@ -1,4 +1,5 @@
-namespace AssociationRegistry.Test.Admin.Api.VerenigingMetRechtspersoonlijkheid.When_RegistreerVerenigingMetRechtspersoonlijkheid.With_Kbo_Nummer_For_Supported_Rechtsvorm;
+namespace AssociationRegistry.Test.Admin.Api.VerenigingMetRechtspersoonlijkheid.When_RegistreerVerenigingMetRechtspersoonlijkheid.
+    With_Kbo_Nummer_For_Supported_Rechtsvorm;
 
 using Events;
 using Fixtures;
@@ -7,33 +8,39 @@ namespace AssociationRegistry.Test.Admin.Api.VerenigingMetRechtspersoonlijkheid.
 using Vereniging;
 using Xunit;
 
-public class RegistreerPrivateStichtingSetup: RegistreerVereniginMetRechtspersoonlijkheidSetup
+public class RegistreerPrivateStichtingSetup : RegistreerVereniginMetRechtspersoonlijkheidSetup
 {
-    public RegistreerPrivateStichtingSetup(EventsInDbScenariosFixture fixture): base(fixture, "0546572531")
+    public RegistreerPrivateStichtingSetup(EventsInDbScenariosFixture fixture) : base(fixture, kboNummer: "0546572531")
     {
-
     }
 }
 
-public class With_KboNummer_For_PrivateStichting: With_KboNummer_For_Supported_Vereniging, IClassFixture<RegistreerPrivateStichtingSetup>
+public class With_KboNummer_For_PrivateStichting : With_KboNummer_For_Supported_Vereniging, IClassFixture<RegistreerPrivateStichtingSetup>
 {
-    public With_KboNummer_For_PrivateStichting(EventsInDbScenariosFixture fixture, RegistreerPrivateStichtingSetup registreerSetup) : base(fixture, registreerSetup)
+    public With_KboNummer_For_PrivateStichting(EventsInDbScenariosFixture fixture, RegistreerPrivateStichtingSetup registreerSetup) : base(
+        fixture, registreerSetup)
     {
     }
 
     [Fact]
     public void Then_it_saves_the_events()
     {
         using var session = _fixture.DocumentStore
-            .LightweightSession();
+                                    .LightweightSession();
+
+        var verenigingMetRechtspersoonlijkheidWerdGeregistreerd = session
+                                                                 .Events
+                                                                 .QueryRawEventDataOnly<
+                                                                      VerenigingMetRechtspersoonlijkheidWerdGeregistreerd>()
+                                                                 .Should().ContainSingle(
+                                                                      e => e.KboNummer == RegistreerVerenigingMetRechtspersoonlijkheidSetup
+                                                                                         .UitKboRequest.KboNummer).Subject;
 
-        var verenigingMetRechtspersoonlijkheidWerdGeregistreerd = session.Events.QueryRawEventDataOnly<VerenigingMetRechtspersoonlijkheidWerdGeregistreerd>()
-            .Should().ContainSingle(e => e.KboNummer == RegistreerVerenigingMetRechtspersoonlijkheidSetup.UitKboRequest.KboNummer).Subject;
         using (new AssertionScope())
         {
-            verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Naam.Should().Be("Vlaamse Liga tegen Kanker");
+            verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Naam.Should().Be("Kom op tegen Kanker");
             verenigingMetRechtspersoonlijkheidWerdGeregistreerd.KorteNaam.Should().Be("V.L.K.");
-            verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Startdatum.Should().Be(new DateOnly(1989, 10, 03));
+            verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Startdatum.Should().Be(new DateOnly(year: 1989, month: 10, day: 03));
 
             verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Rechtsvorm.Should().Be(Verenigingstype.PrivateStichting.Code);
         }

@@ -41,7 +41,7 @@ public void Then_it_saves_the_events()
 
         using (new AssertionScope())
         {
-            verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Naam.Should().Be("Vlaamse Liga tegen Kanker");
+            verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Naam.Should().Be("Kom op tegen Kanker");
             verenigingMetRechtspersoonlijkheidWerdGeregistreerd.KorteNaam.Should().Be("V.L.K.");
             verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Startdatum.Should().Be(new DateOnly(year: 1989, month: 10, day: 03));
             verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Rechtsvorm.Should().Be(Verenigingstype.StichtingVanOpenbaarNut.Code);

@@ -38,7 +38,7 @@ public void Then_it_saves_the_events()
 
         using (new AssertionScope())
         {
-            verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Naam.Should().Be("Vlaamse Liga tegen Kanker");
+            verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Naam.Should().Be("Kom op tegen Kanker");
             verenigingMetRechtspersoonlijkheidWerdGeregistreerd.KorteNaam.Should().Be("V.L.K.");
             verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Startdatum.Should().Be(new DateOnly(year: 1989, month: 10, day: 03));
             verenigingMetRechtspersoonlijkheidWerdGeregistreerd.Rechtsvorm.Should().Be(Verenigingstype.VZW.Code);

@@ -8,12 +8,12 @@
 public class V015_VerenigingMetRechtspersoonlijkheidWerdGeregistreerd_With_WijzigBasisgegevens : IScenario
 {
     public readonly VerenigingMetRechtspersoonlijkheidWerdGeregistreerd VerenigingMetRechtspersoonlijkheidWerdGeregistreerd = new(
-        "V0001015",
-        "0987654321",
-        "VZW",
-        "Feesten Affligem",
+        VCode: "V0001015",
+        KboNummer: "0987654315",
+        Rechtsvorm: "VZW",
+        Naam: "Feesten Affligem",
         string.Empty,
-        null);
+        Startdatum: null);
 
     public readonly RoepnaamWerdGewijzigd RoepnaamWerdGewijzigd = new("The Affligem Party Squad");
 
@@ -30,5 +30,7 @@ public IEvent[] GetEvents()
     }
 
     public CommandMetadata GetCommandMetadata()
-        => new("OVO000001", new DateTimeOffset(year: 2023, month: 01, day: 25, hour: 0, minute: 0, second: 0, TimeSpan.Zero).ToInstant(), Guid.NewGuid());
+        => new(Initiator: "OVO000001",
+               new DateTimeOffset(year: 2023, month: 01, day: 25, hour: 0, minute: 0, second: 0, TimeSpan.Zero).ToInstant(),
+               Guid.NewGuid());
 }
@@ -8,19 +8,19 @@
 public class V016_VerenigingWerdGestopt : IScenario
 {
     public readonly FeitelijkeVerenigingWerdGeregistreerd FeitelijkeVerenigingWerdGeregistreerd = new(
-        "V0001016",
-        "0987654321",
-        "",
-        "",
-        null,
-        new Registratiedata.Doelgroep(0, 150),
-        false,
+        VCode: "V0001016",
+        Naam: "0987654316",
+        KorteNaam: "",
+        KorteBeschrijving: "",
+        Startdatum: null,
+        new Registratiedata.Doelgroep(Minimumleeftijd: 0, Maximumleeftijd: 150),
+        IsUitgeschrevenUitPubliekeDatastroom: false,
         Array.Empty<Registratiedata.Contactgegeven>(),
         Array.Empty<Registratiedata.Locatie>(),
         Array.Empty<Registratiedata.Vertegenwoordiger>(),
         Array.Empty<Registratiedata.HoofdactiviteitVerenigingsloket>());
 
-    public readonly VerenigingWerdGestopt VerenigingWerdGestopt = new(new DateOnly(2023,09,06));
+    public readonly VerenigingWerdGestopt VerenigingWerdGestopt = new(new DateOnly(year: 2023, month: 09, day: 06));
 
     public VCode VCode
         => VCode.Create(FeitelijkeVerenigingWerdGeregistreerd.VCode);
@@ -35,5 +35,7 @@ public IEvent[] GetEvents()
     }
 
     public CommandMetadata GetCommandMetadata()
-        => new("OVO000001", new DateTimeOffset(year: 2023, month: 01, day: 25, hour: 0, minute: 0, second: 0, TimeSpan.Zero).ToInstant(), Guid.NewGuid());
+        => new(Initiator: "OVO000001",
+               new DateTimeOffset(year: 2023, month: 01, day: 25, hour: 0, minute: 0, second: 0, TimeSpan.Zero).ToInstant(),
+               Guid.NewGuid());
 }
@@ -8,30 +8,31 @@
 public class V017_VerenigingMetRechtspersoonlijkheidWerdGeregistreerd_With_WijzigMaatschappelijkeZetel_Scenario : IScenario
 {
     public readonly VerenigingMetRechtspersoonlijkheidWerdGeregistreerd VerenigingMetRechtspersoonlijkheidWerdGeregistreerd = new(
-        "V0001017",
-        "0987654321",
-        "VZW",
-        "Feesten Affligem",
+        VCode: "V0001017",
+        KboNummer: "0987654317",
+        Rechtsvorm: "VZW",
+        Naam: "Feesten Affligem",
         string.Empty,
-        null);
+        Startdatum: null);
 
     public readonly MaatschappelijkeZetelWerdOvergenomenUitKbo MaatschappelijkeZetelWerdOvergenomenUitKbo = new(
         Locatie: new Registratiedata.Locatie(
-            1,
+            LocatieId: 1,
             Locatietype.MaatschappelijkeZetelVolgensKbo,
-            false,
+            IsPrimair: false,
             string.Empty,
             new Registratiedata.Adres(
-                "Stationsstraat",
-                "1",
-                "B",
-                "1790",
-                "Affligem",
-                "België"),
-            null
+                Straatnaam: "Stationsstraat",
+                Huisnummer: "1",
+                Busnummer: "B",
+                Postcode: "1790",
+                Gemeente: "Affligem",
+                Land: "België"),
+            AdresId: null
         ));
 
-    public readonly MaatschappelijkeZetelVolgensKBOWerdGewijzigd MaatschappelijkeZetelVolgensKBOWerdGewijzigd = new(1, "Station", true);
+    public readonly MaatschappelijkeZetelVolgensKBOWerdGewijzigd MaatschappelijkeZetelVolgensKBOWerdGewijzigd =
+        new(LocatieId: 1, Naam: "Station", IsPrimair: true);
 
     public VCode VCode
         => VCode.Create(VerenigingMetRechtspersoonlijkheidWerdGeregistreerd.VCode);
@@ -47,6 +48,7 @@ public IEvent[] GetEvents()
     }
 
     public CommandMetadata GetCommandMetadata()
-        => new("OVO000001", new DateTimeOffset(year: 2023, month: 01, day: 25, hour: 0, minute: 0, second: 0, TimeSpan.Zero).ToInstant(),
+        => new(Initiator: "OVO000001",
+               new DateTimeOffset(year: 2023, month: 01, day: 25, hour: 0, minute: 0, second: 0, TimeSpan.Zero).ToInstant(),
                Guid.NewGuid());
 }
@@ -60,13 +60,13 @@
                 <Namen
                   xmlns:web="http://webservice.geefondernemingdienst-02_00.onderneming-02_00.vip.vlaanderen.be">
                   <MaatschappelijkeNamen>
-                    <MaatschappelijkeNaam DatumBegin="1998-01-01">
-                      <Naam>Vlaamse Liga tegen Kanker</Naam>
+                    <MaatschappelijkeNaam DatumBegin="2015-10-13">
+                      <Naam>Kom op tegen Kanker</Naam>
                       <Taalcode>nl</Taalcode>
                     </MaatschappelijkeNaam>
                   </MaatschappelijkeNamen>
                   <AfgekorteNamen>
-                    <AfgekorteNaam DatumBegin="1998-01-01">
+                    <AfgekorteNaam DatumBegin="2015-10-13">
                       <Naam>V.L.K.</Naam>
                       <Taalcode>nl</Taalcode>
                     </AfgekorteNaam>

@@ -59,13 +59,13 @@
                 <Namen
                   xmlns:web="http://webservice.geefondernemingdienst-02_00.onderneming-02_00.vip.vlaanderen.be">
                   <MaatschappelijkeNamen>
-                    <MaatschappelijkeNaam DatumBegin="1998-01-01">
-                      <Naam>Vlaamse Liga tegen Kanker</Naam>
+                    <MaatschappelijkeNaam DatumBegin="2015-10-13">
+                      <Naam>Kom op tegen Kanker</Naam>
                       <Taalcode>nl</Taalcode>
                     </MaatschappelijkeNaam>
                   </MaatschappelijkeNamen>
                   <AfgekorteNamen>
-                    <AfgekorteNaam DatumBegin="1998-01-01">
+                    <AfgekorteNaam DatumBegin="2015-10-13">
                       <Naam>V.L.K.</Naam>
                       <Taalcode>nl</Taalcode>
                     </AfgekorteNaam>

@@ -60,13 +60,13 @@
                 <Namen
                   xmlns:web="http://webservice.geefondernemingdienst-02_00.onderneming-02_00.vip.vlaanderen.be">
                   <MaatschappelijkeNamen>
-                    <MaatschappelijkeNaam DatumBegin="1998-01-01">
-                      <Naam>Vlaamse Liga tegen Kanker</Naam>
+                    <MaatschappelijkeNaam DatumBegin="2015-10-13">
+                      <Naam>Kom op tegen Kanker</Naam>
                       <Taalcode>nl</Taalcode>
                     </MaatschappelijkeNaam>
                   </MaatschappelijkeNamen>
                   <AfgekorteNamen>
-                    <AfgekorteNaam DatumBegin="1998-01-01">
+                    <AfgekorteNaam DatumBegin="2015-10-13">
                       <Naam>V.L.K.</Naam>
                       <Taalcode>nl</Taalcode>
                     </AfgekorteNaam>