From 2c95acd675120b50f661d670fc43737507f409e7 Mon Sep 17 00:00:00 2001 From: Arne Dumarey Date: Tue, 7 Jan 2025 12:06:14 +0100 Subject: [PATCH] fix(projections): include postalnames when retrieving postalinformation --- .../PostalLatestItemExtensions.cs | 4 +++- .../PostalInformation/PostalInformationExtensions.cs | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/PostalRegistry.Projections.Integration/PostalLatestItemExtensions.cs b/src/PostalRegistry.Projections.Integration/PostalLatestItemExtensions.cs index 848fad83..514cbc4b 100644 --- a/src/PostalRegistry.Projections.Integration/PostalLatestItemExtensions.cs +++ b/src/PostalRegistry.Projections.Integration/PostalLatestItemExtensions.cs @@ -4,6 +4,7 @@ using System.Threading; using System.Threading.Tasks; using Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector; + using Microsoft.EntityFrameworkCore; public static class PostalLatestItemExtensions { @@ -14,7 +15,8 @@ public static async Task FindAndUpdatePostal(this IntegrationC { var postalItem = await context .PostalLatestItems - .FindAsync(postalCode, cancellationToken: ct); + .Include(x=> x.PostalNames) + .SingleOrDefaultAsync(x => x.PostalCode == postalCode, cancellationToken: ct); if (postalItem == null) throw DatabaseItemNotFound(postalCode); diff --git a/src/PostalRegistry.Projections.Legacy/PostalInformation/PostalInformationExtensions.cs b/src/PostalRegistry.Projections.Legacy/PostalInformation/PostalInformationExtensions.cs index 29933cb4..71b06115 100755 --- a/src/PostalRegistry.Projections.Legacy/PostalInformation/PostalInformationExtensions.cs +++ b/src/PostalRegistry.Projections.Legacy/PostalInformation/PostalInformationExtensions.cs @@ -4,6 +4,7 @@ namespace PostalRegistry.Projections.Legacy.PostalInformation using System.Threading; using System.Threading.Tasks; using Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector; + using Microsoft.EntityFrameworkCore; public static class PostalInformationExtensions { @@ -15,7 +16,8 @@ public static async Task FindAndUpdatePostalInformation( { var postalInformation = await context .PostalInformation - .FindAsync(postalCode, cancellationToken: ct); + .Include(p => p.PostalNames) + .SingleOrDefaultAsync(x => x.PostalCode == postalCode, cancellationToken: ct); if (postalInformation == null) throw DatabaseItemNotFound(postalCode);