fix: keep event provenance timestamp for new commands

Informatievlaanderen · Jun 3, 2024 · b8e81b3 · b8e81b3
1 parent cf6f76b
commit b8e81b3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/src/ParcelRegistry.Consumer.Address/Projections/CommandHandlingKafkaProjection.cs b/src/ParcelRegistry.Consumer.Address/Projections/CommandHandlingKafkaProjection.cs
@@ -11,6 +11,7 @@ namespace ParcelRegistry.Consumer.Address.Projections
     using Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector;
     using Microsoft.EntityFrameworkCore;
     using NodaTime;
+    using NodaTime.Text;
     using Parcel;
     using Parcel.Commands;
     using Contracts = Be.Vlaanderen.Basisregisters.GrAr.Contracts.Common;
@@ -333,7 +334,7 @@ private async Task DetachBecauseRejected(
 
         private static Provenance FromProvenance(Contracts.Provenance provenance) =>
             new Provenance(
-                SystemClock.Instance.GetCurrentInstant(),
+                InstantPattern.General.Parse(provenance.Timestamp).Value,
                 Enum.Parse<Application>(Application.AddressRegistry.ToString()),
                 new Reason(provenance.Reason),
                 new Operator(string.Empty),

diff --git a/...y.Tests/ProjectionTests/Consumer.Address/CommandHandlingKafkaProjectionTests-Readdress.cs b/...y.Tests/ProjectionTests/Consumer.Address/CommandHandlingKafkaProjectionTests-Readdress.cs
@@ -93,7 +93,9 @@ await Then(async _ =>
                                     && z.DestinationAddressPersistentLocalId == destinationAddressPersistentLocalIdOne)
                                 && y.Readdresses.Any(z =>
                                     z.SourceAddressPersistentLocalId == sourceAddressPersistentLocalIdTwo
-                                    && z.DestinationAddressPersistentLocalId == destinationAddressPersistentLocalIdTwo)),
+                                    && z.DestinationAddressPersistentLocalId == destinationAddressPersistentLocalIdTwo)
+                                && y.Provenance.Timestamp.ToString() == @event.Provenance.Timestamp
+                            ),
                             CancellationToken.None),
                     Times.Once);
                 _mockCommandHandler.Verify(x =>
@@ -103,7 +105,9 @@ await Then(async _ =>
                                 && y.Readdresses.Count == 1
                                 && y.Readdresses.Any(z =>
                                     z.SourceAddressPersistentLocalId == sourceAddressPersistentLocalIdThree
-                                    && z.DestinationAddressPersistentLocalId == destinationAddressPersistentLocalIdThree)),
+                                    && z.DestinationAddressPersistentLocalId == destinationAddressPersistentLocalIdThree)
+                                && y.Provenance.Timestamp.ToString() == @event.Provenance.Timestamp
+                            ),
                             CancellationToken.None),
                     Times.Once);