fix(integration): v2 address to correct table

Informatievlaanderen · Nov 19, 2024 · d4c35f6 · d4c35f6
1 parent 8c36ccd
commit d4c35f6
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...arcelRegistry.Projections.Integration/ParcelLatestItemV2/ParcelLatestItemV2Projections.cs b/...arcelRegistry.Projections.Integration/ParcelLatestItemV2/ParcelLatestItemV2Projections.cs
@@ -130,20 +130,20 @@ await context.FindAndUpdateParcel(
                     }, ct);
 
                 var previousAddress = await context
-                    .ParcelLatestItemAddresses
+                    .ParcelLatestItemV2Addresses
                     .FindAsync([message.Message.ParcelId, message.Message.PreviousAddressPersistentLocalId], cancellationToken: ct);
 
                 if (previousAddress is not null && previousAddress.Count == 1)
                 {
-                    context.ParcelLatestItemAddresses.Remove(previousAddress);
+                    context.ParcelLatestItemV2Addresses.Remove(previousAddress);
                 }
                 else if (previousAddress is not null)
                 {
                     previousAddress.Count -= 1;
                 }
 
                 var newAddress = await context
-                    .ParcelLatestItemAddresses
+                    .ParcelLatestItemV2Addresses
                     .FindAsync([message.Message.ParcelId, message.Message.NewAddressPersistentLocalId], cancellationToken: ct);
 
                 if (newAddress is null || context.Entry(newAddress).State == EntityState.Deleted)
@@ -250,7 +250,7 @@ private static async Task AddParcelAddress(
             CancellationToken ct)
         {
             var newAddress = await context
-                .ParcelLatestItemAddresses
+                .ParcelLatestItemV2Addresses
                 .FindAsync([parcelId, addressPersistentLocalId], cancellationToken: ct);
 
             if (newAddress is null || context.Entry(newAddress).State == EntityState.Deleted)