fix: update parcel geometry when ParcelWasCorrectedFromRetiredToRealized

Informatievlaanderen · Feb 14, 2025 · 07b380d · 07b380d
1 parent 999331f
commit 07b380d
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/src/BuildingRegistry.Consumer.Read.Parcel/ParcelWithCount/ParcelKafkaProjection.cs b/src/BuildingRegistry.Consumer.Read.Parcel/ParcelWithCount/ParcelKafkaProjection.cs
@@ -75,8 +75,12 @@ await context
                     .ParcelConsumerItemsWithCount.FindAsync([Guid.Parse(message.ParcelId)], cancellationToken: ct);
 
                 parcel!.Status = ParcelStatus.Realized;
+                var extendedWkbGeometry = message.ExtendedWkbGeometry.ToByteArray();
+                parcel.ExtendedWkbGeometry = extendedWkbGeometry;
+                parcel.SetGeometry(wkbReader.Read(extendedWkbGeometry));
 
                 var buildingPersistentLocalIds = await GetBuildingPersistentLocalIdsToInvalidate(parcel.Geometry);
+
                 context.BuildingsToInvalidate.AddRange(buildingPersistentLocalIds.Select(x => new BuildingToInvalidate
                 {
                     BuildingPersistentLocalId = x

diff --git a/...ldingRegistry.Tests/ProjectionTests/Consumer.Parcel/ParcelConsumerKafkaProjectionTests.cs b/...ldingRegistry.Tests/ProjectionTests/Consumer.Parcel/ParcelConsumerKafkaProjectionTests.cs
@@ -345,7 +345,7 @@ await Then(async context =>
         }
 
         [Fact]
-        public async Task ParcelWasCorrectedFromRetiredToRealized_SetsParcelStatusToRealized()
+        public async Task ParcelWasCorrectedFromRetiredToRealized_SetsParcelStatusToRealizedAndUpdatesGeometry()
         {
             var parcelId = Fixture.Create<Guid>().ToString("D");
             var capakey = Fixture.Create<Guid>().ToString("D");
@@ -368,12 +368,13 @@ public async Task ParcelWasCorrectedFromRetiredToRealized_SetsParcelStatusToReal
                 ))
                 .Create();
 
+            var expectedGeometry = GeometryHelper.SecondValidPolygon.AsBinary();
             var parcelWasCorrectedFromRetiredToRealized = Fixture
                 .Build<ParcelWasCorrectedFromRetiredToRealized>()
                 .FromFactory(() => new ParcelWasCorrectedFromRetiredToRealized(
                     parcelId,
                     capakey,
-                    GeometryHelper.ValidPolygon.AsBinary().ToHexString(),
+                    expectedGeometry.ToHexString(),
                     Fixture.Create<Provenance>()
                 ))
                 .Create();
@@ -384,7 +385,7 @@ public async Task ParcelWasCorrectedFromRetiredToRealized_SetsParcelStatusToReal
                 .SetupSequence(x => x.GetUnderlyingBuildings(It.IsAny<Geometry>()))
                 .Returns(Array.Empty<int>())
                 .Returns(Array.Empty<int>())
-                .Returns(new[] { underlyingBuildingId });
+                .Returns([underlyingBuildingId]);
 
             Given(parcelWasImported, parcelWasRetiredV2, parcelWasCorrectedFromRetiredToRealized);
 
@@ -396,6 +397,7 @@ await Then(async context =>
                 parcel.Should().NotBeNull();
                 parcel!.CaPaKey.Should().Be(parcelWasCorrectedFromRetiredToRealized.CaPaKey);
                 parcel.Status.Should().Be(ParcelStatus.Realized);
+                parcel.ExtendedWkbGeometry.Should().BeEquivalentTo(expectedGeometry);
                 parcel.IsRemoved.Should().Be(parcel.IsRemoved);
 
                 var buildingsToInvalidate = context.BuildingsToInvalidate.Local.ToList();