feat: or-2006 simple solution for or-2006

src/AssociationRegistry/EventStore/EventStore.cs

@@ -20,14 +20,20 @@ public EventStore(IDocumentStore documentStore)
         _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 @@ public async Task<StreamActionResult> Save(string aggregateId, CommandMetadata m
         }
     }
 
+    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)