Skip to content

Commit

Permalink
fix: building snapshot producer buildingunit status events
Browse files Browse the repository at this point in the history
  • Loading branch information
@ArneD
ArneD committed Oct 21, 2024
1 parent be044fc commit e515e97
Showing 1 changed file with 167 additions and 166 deletions.
333 changes: 167 additions & 166 deletions src/BuildingRegistry.Producer.Snapshot.Oslo/ProducerBuildingProjections.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit e515e97

Please sign in to comment.