From d4c35f6c29162154dd6d5d2a95d13dc6d64ebb81 Mon Sep 17 00:00:00 2001 From: Arne Dumarey Date: Tue, 19 Nov 2024 09:03:12 +0100 Subject: [PATCH] fix(integration): v2 address to correct table --- .../ParcelLatestItemV2/ParcelLatestItemV2Projections.cs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/ParcelRegistry.Projections.Integration/ParcelLatestItemV2/ParcelLatestItemV2Projections.cs b/src/ParcelRegistry.Projections.Integration/ParcelLatestItemV2/ParcelLatestItemV2Projections.cs index db253b9b..299523df 100644 --- a/src/ParcelRegistry.Projections.Integration/ParcelLatestItemV2/ParcelLatestItemV2Projections.cs +++ b/src/ParcelRegistry.Projections.Integration/ParcelLatestItemV2/ParcelLatestItemV2Projections.cs @@ -130,12 +130,12 @@ 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) { @@ -143,7 +143,7 @@ await context.FindAndUpdateParcel( } 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)