feat: consume AddressWasRejectedBecauseOfMunicipalityMerger and Addre…

…ssWasRetiredBecauseOfMunicipalityMerger and send domain commands

src/ParcelRegistry.Consumer.Address/Projections/CommandHandlingKafkaProjection.cs

@@ -99,6 +99,36 @@ await DetachBecauseRejected(
                     ct);
             });
 
+            When<AddressWasRejectedBecauseOfMunicipalityMerger>(async (commandHandler, message, ct) =>
+            {
+                await using var backOfficeContext = await _backOfficeContextFactory.CreateDbContextAsync(ct);
+                var relations = backOfficeContext.ParcelAddressRelations
+                    .AsNoTracking()
+                    .Where(x => x.AddressPersistentLocalId == new AddressPersistentLocalId(message.AddressPersistentLocalId))
+                    .ToList();
+
+                foreach (var relation in relations)
+                {
+                    var command = new ReplaceParcelAddressBecauseOfMunicipalityMerger(
+                        new ParcelId(relation.ParcelId),
+                        new AddressPersistentLocalId(message.NewAddressPersistentLocalId),
+                        new AddressPersistentLocalId(message.AddressPersistentLocalId),
+                        FromProvenance(message.Provenance));
+
+                    await commandHandler.Handle(command, ct);
+
+                    await backOfficeContext.RemoveIdempotentParcelAddressRelation(
+                        command.ParcelId,
+                        command.PreviousAddressPersistentLocalId,
+                        ct);
+
+                    await backOfficeContext.AddIdempotentParcelAddressRelation(
+                        command.ParcelId,
+                        command.NewAddressPersistentLocalId,
+                        ct);
+                }
+            });
+
             When<AddressWasRetiredV2>(async (commandHandler, message, ct) =>
             {
                 await DetachBecauseRetired(
@@ -135,6 +165,36 @@ await DetachBecauseRetired(
                     ct);
             });
 
+            When<AddressWasRetiredBecauseOfMunicipalityMerger>(async (commandHandler, message, ct) =>
+            {
+                await using var backOfficeContext = await _backOfficeContextFactory.CreateDbContextAsync(ct);
+                var relations = backOfficeContext.ParcelAddressRelations
+                    .AsNoTracking()
+                    .Where(x => x.AddressPersistentLocalId == new AddressPersistentLocalId(message.AddressPersistentLocalId))
+                    .ToList();
+
+                foreach (var relation in relations)
+                {
+                    var command = new ReplaceParcelAddressBecauseOfMunicipalityMerger(
+                        new ParcelId(relation.ParcelId),
+                        new AddressPersistentLocalId(message.NewAddressPersistentLocalId),
+                        new AddressPersistentLocalId(message.AddressPersistentLocalId),
+                        FromProvenance(message.Provenance));
+
+                    await commandHandler.Handle(command, ct);
+
+                    await backOfficeContext.RemoveIdempotentParcelAddressRelation(
+                        command.ParcelId,
+                        command.PreviousAddressPersistentLocalId,
+                        ct);
+
+                    await backOfficeContext.AddIdempotentParcelAddressRelation(
+                        command.ParcelId,
+                        command.NewAddressPersistentLocalId,
+                        ct);
+                }
+            });
+
             When<AddressWasRemovedV2>(async (commandHandler, message, ct) =>
             {
                 await DetachBecauseRemoved(

test/ParcelRegistry.Tests/ProjectionTests/Consumer.Address/CommandHandlingKafkaProjectionTests.cs

@@ -1,17 +1,13 @@
 namespace ParcelRegistry.Tests.ProjectionTests.Consumer.Address
 {
     using System;
-    using System.Collections.Generic;
     using System.Linq;
     using System.Threading;
     using System.Threading.Tasks;
     using Api.BackOffice.Abstractions;
-    using Autofac;
     using AutoFixture;
-    using Be.Vlaanderen.Basisregisters.AggregateSource.Snapshotting;
     using Be.Vlaanderen.Basisregisters.GrAr.Contracts.AddressRegistry;
     using Be.Vlaanderen.Basisregisters.GrAr.Provenance;
-    using EventExtensions;
     using Fixtures;
     using FluentAssertions;
     using Microsoft.EntityFrameworkCore;
@@ -20,7 +16,6 @@ namespace ParcelRegistry.Tests.ProjectionTests.Consumer.Address
     using NodaTime;
     using Parcel;
     using Parcel.Commands;
-    using Parcel.Events;
     using ParcelRegistry.Consumer.Address;
     using ParcelRegistry.Consumer.Address.Projections;
     using Tests.BackOffice;
@@ -587,6 +582,88 @@ await Then(async _ =>
             });
         }
 
+        [Fact]
+        public async Task ReplaceParcelAddressBecauseOfMunicipalityMerger_AddressWasRejectedBecauseOfMunicipalityMerger()
+        {
+            var oldAddressPersistentLocalId = 1;
+            var newAddressPersistentLocalId = 2;
+
+            var @event = new AddressWasRejectedBecauseOfMunicipalityMerger(
+                Fixture.Create<int>(),
+                oldAddressPersistentLocalId,
+                newAddressPersistentLocalId,
+                new Provenance(
+                    Instant.FromDateTimeOffset(DateTimeOffset.Now).ToString(),
+                    Application.ParcelRegistry.ToString(),
+                    Modification.Update.ToString(),
+                    Organisation.Aiv.ToString(),
+                    "test"));
+
+            AddParcelAddressRelations(Fixture.Create<ParcelId>(), [oldAddressPersistentLocalId]);
+            AddParcelAddressRelations(Fixture.Create<ParcelId>(), [oldAddressPersistentLocalId]);
+
+            Given(@event);
+            await Then(async _ =>
+            {
+                _mockCommandHandler.Verify(x => x.Handle(
+                        It.IsAny<ReplaceParcelAddressBecauseOfMunicipalityMerger>(), CancellationToken.None),
+                    Times.Exactly(2));
+
+                var oldAddressRelations = _fakeBackOfficeContext.ParcelAddressRelations
+                    .Where(x => x.AddressPersistentLocalId == oldAddressPersistentLocalId)
+                    .ToList();
+
+                var newAddressRelations = _fakeBackOfficeContext.ParcelAddressRelations
+                    .Where(x => x.AddressPersistentLocalId == newAddressPersistentLocalId)
+                    .ToList();
+
+                oldAddressRelations.Should().BeEmpty();
+                newAddressRelations.Should().HaveCount(2);
+                await Task.CompletedTask;
+            });
+        }
+
+        [Fact]
+        public async Task ReplaceParcelAddressBecauseOfMunicipalityMerger_AddressWasRetiredBecauseOfMunicipalityMerger()
+        {
+            var oldAddressPersistentLocalId = 1;
+            var newAddressPersistentLocalId = 2;
+
+            var @event = new AddressWasRetiredBecauseOfMunicipalityMerger(
+                Fixture.Create<int>(),
+                oldAddressPersistentLocalId,
+                newAddressPersistentLocalId,
+                new Provenance(
+                    Instant.FromDateTimeOffset(DateTimeOffset.Now).ToString(),
+                    Application.ParcelRegistry.ToString(),
+                    Modification.Update.ToString(),
+                    Organisation.Aiv.ToString(),
+                    "test"));
+
+            AddParcelAddressRelations(Fixture.Create<ParcelId>(), [oldAddressPersistentLocalId]);
+            AddParcelAddressRelations(Fixture.Create<ParcelId>(), [oldAddressPersistentLocalId]);
+
+            Given(@event);
+            await Then(async _ =>
+            {
+                _mockCommandHandler.Verify(x => x.Handle(
+                        It.IsAny<ReplaceParcelAddressBecauseOfMunicipalityMerger>(), CancellationToken.None),
+                    Times.Exactly(2));
+
+                var oldAddressRelations = _fakeBackOfficeContext.ParcelAddressRelations
+                    .Where(x => x.AddressPersistentLocalId == oldAddressPersistentLocalId)
+                    .ToList();
+
+                var newAddressRelations = _fakeBackOfficeContext.ParcelAddressRelations
+                    .Where(x => x.AddressPersistentLocalId == newAddressPersistentLocalId)
+                    .ToList();
+
+                oldAddressRelations.Should().BeEmpty();
+                newAddressRelations.Should().HaveCount(2);
+                await Task.CompletedTask;
+            });
+        }
+
         private void AddParcelAddressRelations(ParcelId parcelId, int[] addressPersistentLocalIds)
         {
             foreach (var addressPersistentLocalId in addressPersistentLocalIds)