feat: add missing event handlers where nothing was expected #19

Informatievlaanderen · Aug 12, 2019 · b0dd8fc · b0dd8fc
1 parent 65df6a9
commit b0dd8fc
Show file tree

Hide file tree

Showing 6 changed files with 61 additions and 0 deletions.
diff --git a/...istry.Projections.Extract/PostalInformationExtract/PostalInformationExtractProjections.cs b/...istry.Projections.Extract/PostalInformationExtract/PostalInformationExtractProjections.cs
@@ -9,6 +9,8 @@ namespace PostalRegistry.Projections.Extract.PostalInformationExtract
     using Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore;
     using NodaTime;
     using PostalInformation.Events;
+    using PostalInformation.Events.BPost;
+    using PostalInformation.Events.Crab;
 
     public class PostalInformationExtractProjections : ConnectedProjection<ExtractContext>
     {
@@ -125,6 +127,10 @@ await context.FindAndUpdatePostalInformationExtract(
                     },
                     ct);
             });
+
+            When<Envelope<MunicipalityWasAttached>>(async (context, message, ct) => DoNothing());
+            When<Envelope<PostalInformationWasImportedFromCrab>>(async (context, message, ct) => DoNothing());
+            When<Envelope<PostalInformationWasImportedFromBPost>>(async (context, message, ct) => DoNothing());
         }
 
         private void UpdateStatus(IEnumerable<PostalInformationExtractItem> postalInformationSet, string status)
@@ -148,5 +154,7 @@ private void UpdateRecord(PostalInformationExtractItem postalInformation, Action
 
             postalInformation.DbaseRecord = record.ToBytes(_encoding);
         }
+
+        private static void DoNothing() { }
     }
 }
diff --git a/src/PostalRegistry.Projections.LastChangedList/LastChangedListProjections.cs b/src/PostalRegistry.Projections.LastChangedList/LastChangedListProjections.cs
@@ -3,6 +3,8 @@ namespace PostalRegistry.Projections.LastChangedList
     using Be.Vlaanderen.Basisregisters.ProjectionHandling.LastChangedList;
     using Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore;
     using PostalInformation.Events;
+    using PostalInformation.Events.BPost;
+    using PostalInformation.Events.Crab;
 
     public class LastChangedListProjections : LastChangedListConnectedProjection
     {
@@ -14,6 +16,11 @@ public class LastChangedListProjections : LastChangedListConnectedProjection
         public LastChangedListProjections()
          : base(SupportedAcceptTypes)
         {
+            When<Envelope<PostalInformationWasRegistered>>(async (context, message, ct) =>
+            {
+                await GetLastChangedRecordsAndUpdatePosition(message.Message.PostalCode, message.Position, context, ct);
+            });
+
             When<Envelope<PostalInformationBecameCurrent>>(async (context, message, ct) =>
             {
                 await GetLastChangedRecordsAndUpdatePosition(message.Message.PostalCode, message.Position, context, ct);
@@ -33,6 +40,12 @@ public LastChangedListProjections()
             {
                 await GetLastChangedRecordsAndUpdatePosition(message.Message.PostalCode, message.Position, context, ct);
             });
+
+            When<Envelope<MunicipalityWasAttached>>(async (context, message, ct) => DoNothing());
+            When<Envelope<PostalInformationWasImportedFromCrab>>(async (context, message, ct) => DoNothing());
+            When<Envelope<PostalInformationWasImportedFromBPost>>(async (context, message, ct) => DoNothing());
         }
+
+        private static void DoNothing() { }
     }
 }
diff --git a/src/PostalRegistry.Projections.Legacy/PostalInformation/PostalInformationProjections.cs b/src/PostalRegistry.Projections.Legacy/PostalInformation/PostalInformationProjections.cs
@@ -7,6 +7,8 @@ namespace PostalRegistry.Projections.Legacy.PostalInformation
     using Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore;
     using NodaTime;
     using PostalRegistry.PostalInformation.Events;
+    using PostalRegistry.PostalInformation.Events.BPost;
+    using PostalRegistry.PostalInformation.Events.Crab;
 
     public class PostalInformationProjections : ConnectedProjection<LegacyContext>
     {
@@ -92,8 +94,13 @@ await context.FindAndUpdatePostalInformation(
                     },
                     ct);
             });
+
+            When<Envelope<PostalInformationWasImportedFromCrab>>(async (context, message, ct) => DoNothing());
+            When<Envelope<PostalInformationWasImportedFromBPost>>(async (context, message, ct) => DoNothing());
         }
 
+        private static void DoNothing() { }
+
         private static void UpdateVersionTimestamp(PostalInformation postalInformation, Instant versionTimestamp)
             => postalInformation.VersionTimestamp = versionTimestamp;
     }

diff --git a/...rojections.Legacy/PostalInformationSyndication/PostalInformationSyndicationProjections.cs b/...rojections.Legacy/PostalInformationSyndication/PostalInformationSyndicationProjections.cs
@@ -4,6 +4,8 @@ namespace PostalRegistry.Projections.Legacy.PostalInformationSyndication
     using Be.Vlaanderen.Basisregisters.ProjectionHandling.Connector;
     using Be.Vlaanderen.Basisregisters.ProjectionHandling.SqlStreamStore;
     using PostalRegistry.PostalInformation.Events;
+    using PostalRegistry.PostalInformation.Events.BPost;
+    using PostalRegistry.PostalInformation.Events.Crab;
 
     public class PostalInformationSyndicationProjections : ConnectedProjection<LegacyContext>
     {
@@ -76,6 +78,11 @@ await context.CreateNewPostalInformationSyndicationItem(
                     x => x.MunicipalityNisCode = message.Message.NisCode,
                     ct);
             });
+
+            When<Envelope<PostalInformationWasImportedFromCrab>>(async (context, message, ct) => DoNothing());
+            When<Envelope<PostalInformationWasImportedFromBPost>>(async (context, message, ct) => DoNothing());
         }
+
+        private static void DoNothing() { }
     }
 }
diff --git a/src/PostalRegistry.Projections.Syndication/Municipality/MunicipalityEvent.cs b/src/PostalRegistry.Projections.Syndication/Municipality/MunicipalityEvent.cs
@@ -13,5 +13,14 @@ public enum MunicipalityEvent
         MunicipalityOfficialLanguageWasRemoved,
         MunicipalityFacilitiesLanguageWasAdded,
         MunicipalityFacilitiesLanguageWasRemoved,
+
+        MunicipalityWasDrawn,
+        MunicipalityGeometryWasCleared,
+        MunicipalityGeometryWasCorrected,
+        MunicipalityGeometryWasCorrectedToCleared,
+        MunicipalityBecameCurrent,
+        MunicipalityWasRetired,
+        MunicipalityWasCorrectedToCurrent,
+        MunicipalityWasCorrectedToRetired,
     }
 }
diff --git a/src/PostalRegistry.Projections.Syndication/Municipality/MunicipalityLatestProjections.cs b/src/PostalRegistry.Projections.Syndication/Municipality/MunicipalityLatestProjections.cs
@@ -25,6 +25,15 @@ public MunicipalityLatestProjections()
             When(MunicipalityEvent.MunicipalityOfficialLanguageWasRemoved, AddSyndicationItemEntry);
             When(MunicipalityEvent.MunicipalityFacilitiesLanguageWasAdded, AddSyndicationItemEntry);
             When(MunicipalityEvent.MunicipalityFacilitiesLanguageWasRemoved, AddSyndicationItemEntry);
+
+            When(MunicipalityEvent.MunicipalityWasDrawn, DoNothing);
+            When(MunicipalityEvent.MunicipalityGeometryWasCleared, DoNothing);
+            When(MunicipalityEvent.MunicipalityGeometryWasCorrected, DoNothing);
+            When(MunicipalityEvent.MunicipalityGeometryWasCorrectedToCleared, DoNothing);
+            When(MunicipalityEvent.MunicipalityBecameCurrent, DoNothing);
+            When(MunicipalityEvent.MunicipalityWasRetired, DoNothing);
+            When(MunicipalityEvent.MunicipalityWasCorrectedToCurrent, DoNothing);
+            When(MunicipalityEvent.MunicipalityWasCorrectedToRetired, DoNothing);
         }
 
         private static async Task AddSyndicationItemEntry(AtomEntry<SyndicationContent<Gemeente>> entry, SyndicationContext context, CancellationToken ct)
@@ -93,5 +102,13 @@ private static void UpdateNamesByGemeentenamen(MunicipalityLatestItem syndicatio
                 }
             }
         }
+
+        private static Task DoNothing(
+            AtomEntry<SyndicationContent<Gemeente>> entry,
+            SyndicationContext context,
+            CancellationToken ct)
+        {
+            return Task.CompletedTask;
+        }
     }
 }