From e515e9764ca510051732b3dc1b42326fbbdd4151 Mon Sep 17 00:00:00 2001
From: Arne Dumarey <dumarey.arne@gmail.com>
Date: Mon, 21 Oct 2024 08:58:28 +0200
Subject: [PATCH] fix: building snapshot producer buildingunit status  events

---
 .../ProducerBuildingProjections.cs            | 333 +++++++++---------
 1 file changed, 167 insertions(+), 166 deletions(-)

diff --git a/src/BuildingRegistry.Producer.Snapshot.Oslo/ProducerBuildingProjections.cs b/src/BuildingRegistry.Producer.Snapshot.Oslo/ProducerBuildingProjections.cs
index b75eb1e4c..c931b6749 100644
--- a/src/BuildingRegistry.Producer.Snapshot.Oslo/ProducerBuildingProjections.cs
+++ b/src/BuildingRegistry.Producer.Snapshot.Oslo/ProducerBuildingProjections.cs
@@ -315,173 +315,174 @@ await snapshotManager.FindMatchingSnapshot(
                     message.Position,
                     ct);
             });
-            When<Store.Envelope<BuildingUnitWasCorrectedFromNotRealizedToPlanned>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasCorrectedFromRealizedToPlanned>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasCorrectedFromRealizedToPlannedBecauseBuildingWasCorrected>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasCorrectedFromRetiredToRealized>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasNotRealizedBecauseBuildingWasDemolished>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasNotRealizedBecauseBuildingWasNotRealized>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
 
-            When<Store.Envelope<BuildingUnitWasNotRealizedV2>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasRealizedBecauseBuildingWasRealized>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasRealizedV2>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasRemovedBecauseBuildingWasRemoved>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasRetiredBecauseBuildingWasDemolished>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
-
-            When<Store.Envelope<BuildingUnitWasRetiredV2>>(async (_, message, ct) =>
-            {
-                await FindAndProduce(async () =>
-                        await snapshotManager.FindMatchingSnapshot(
-                            message.Message.BuildingPersistentLocalId.ToString(),
-                            message.Message.Provenance.Timestamp,
-                            message.Message.GetHash(),
-                            message.Position,
-                            throwStaleWhenGone: false,
-                            ct),
-                    message.Position,
-                    ct);
-            });
+            // When<Store.Envelope<BuildingUnitWasCorrectedFromNotRealizedToPlanned>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+
+            // When<Store.Envelope<BuildingUnitWasCorrectedFromRealizedToPlanned>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+            //
+            // When<Store.Envelope<BuildingUnitWasCorrectedFromRealizedToPlannedBecauseBuildingWasCorrected>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+            //
+            // When<Store.Envelope<BuildingUnitWasCorrectedFromRetiredToRealized>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+            //
+            // When<Store.Envelope<BuildingUnitWasNotRealizedBecauseBuildingWasDemolished>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+
+            // When<Store.Envelope<BuildingUnitWasNotRealizedBecauseBuildingWasNotRealized>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+            //
+            // When<Store.Envelope<BuildingUnitWasNotRealizedV2>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+
+            // When<Store.Envelope<BuildingUnitWasRealizedBecauseBuildingWasRealized>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+
+            // When<Store.Envelope<BuildingUnitWasRealizedV2>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+            //
+            // When<Store.Envelope<BuildingUnitWasRemovedBecauseBuildingWasRemoved>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+
+            // When<Store.Envelope<BuildingUnitWasRetiredBecauseBuildingWasDemolished>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
+            //
+            // When<Store.Envelope<BuildingUnitWasRetiredV2>>(async (_, message, ct) =>
+            // {
+            //     await FindAndProduce(async () =>
+            //             await snapshotManager.FindMatchingSnapshot(
+            //                 message.Message.BuildingPersistentLocalId.ToString(),
+            //                 message.Message.Provenance.Timestamp,
+            //                 message.Message.GetHash(),
+            //                 message.Position,
+            //                 throwStaleWhenGone: false,
+            //                 ct),
+            //         message.Position,
+            //         ct);
+            // });
         }
 
         private async Task FindAndProduce(Func<Task<OsloResult?>> findMatchingSnapshot, long storePosition, CancellationToken ct)