refactor: perform an explicit SaveChanges in the backoffice projectio…

…ns although it's redundant
Informatievlaanderen · May 22, 2024 · 2d00018 · 2d00018
1 parent ee7ca00
commit 2d00018
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/ParcelRegistry.Projections.BackOffice/BackOfficeProjections.cs b/src/ParcelRegistry.Projections.BackOffice/BackOfficeProjections.cs
@@ -21,6 +21,8 @@ await backOfficeContext.AddIdempotentParcelAddressRelation(
                         new ParcelId(message.Message.ParcelId),
                         new AddressPersistentLocalId(addressPersistentLocalId),
                         cancellationToken);
+
+                    await backOfficeContext.SaveChangesAsync(cancellationToken);
                 }
             });
 
@@ -31,6 +33,8 @@ await backOfficeContext.AddIdempotentParcelAddressRelation(
                     new ParcelId(message.Message.ParcelId),
                     new AddressPersistentLocalId(message.Message.AddressPersistentLocalId),
                     cancellationToken);
+
+                await backOfficeContext.SaveChangesAsync(cancellationToken);
             });
 
             When<Envelope<ParcelAddressWasDetachedV2>>(async (_, message, cancellationToken) =>
@@ -40,6 +44,8 @@ await backOfficeContext.RemoveIdempotentParcelAddressRelation(
                     new ParcelId(message.Message.ParcelId),
                     new AddressPersistentLocalId(message.Message.AddressPersistentLocalId),
                     cancellationToken);
+
+                await backOfficeContext.SaveChangesAsync(cancellationToken);
             });
 
             When<Envelope<ParcelAddressWasDetachedBecauseAddressWasRejected>>(async (_, message, cancellationToken) =>
@@ -49,6 +55,8 @@ await backOfficeContext.RemoveIdempotentParcelAddressRelation(
                     new ParcelId(message.Message.ParcelId),
                     new AddressPersistentLocalId(message.Message.AddressPersistentLocalId),
                     cancellationToken);
+
+                await backOfficeContext.SaveChangesAsync(cancellationToken);
             });
 
             When<Envelope<ParcelAddressWasDetachedBecauseAddressWasRetired>>(async (_, message, cancellationToken) =>
@@ -58,6 +66,8 @@ await backOfficeContext.RemoveIdempotentParcelAddressRelation(
                     new ParcelId(message.Message.ParcelId),
                     new AddressPersistentLocalId(message.Message.AddressPersistentLocalId),
                     cancellationToken);
+
+                await backOfficeContext.SaveChangesAsync(cancellationToken);
             });
 
             When<Envelope<ParcelAddressWasDetachedBecauseAddressWasRemoved>>(async (_, message, cancellationToken) =>
@@ -67,6 +77,8 @@ await backOfficeContext.RemoveIdempotentParcelAddressRelation(
                     new ParcelId(message.Message.ParcelId),
                     new AddressPersistentLocalId(message.Message.AddressPersistentLocalId),
                     cancellationToken);
+
+                await backOfficeContext.SaveChangesAsync(cancellationToken);
             });
 
             When<Envelope<ParcelAddressWasReplacedBecauseAddressWasReaddressed>>(async (_, message, cancellationToken) =>