From fc08423330565fd96387e2ca4ba69259f0eca8a0 Mon Sep 17 00:00:00 2001
From: MASES Public Developers Team
<94312179+masesdevelopers@users.noreply.github.com>
Date: Sun, 22 Oct 2023 03:08:54 +0200
Subject: [PATCH] Distinguish between Added and Removed (#133)
* Removed Upserted and distinguished between Added and Removed
* Removed helper
---
src/net/KEFCore/Storage/EntityTypeChanged.cs | 8 --------
src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs | 2 +-
2 files changed, 1 insertion(+), 9 deletions(-)
diff --git a/src/net/KEFCore/Storage/EntityTypeChanged.cs b/src/net/KEFCore/Storage/EntityTypeChanged.cs
index 03f4068c..f2f6def8 100644
--- a/src/net/KEFCore/Storage/EntityTypeChanged.cs
+++ b/src/net/KEFCore/Storage/EntityTypeChanged.cs
@@ -42,10 +42,6 @@ public enum ChangeKindType
/// The was removed
///
Removed = 4,
- ///
- /// The was added or updated
- ///
- Upserted = Added | Updated,
}
internal EntityTypeChanged(IEntityType entityType, ChangeKindType changeKind, object key)
@@ -78,8 +74,4 @@ internal EntityTypeChanged(IEntityType entityType, ChangeKindType changeKind, ob
/// Helper to understand if the was removed
///
public bool KeyRemoved => ChangeKind.HasFlag(ChangeKindType.Removed);
- ///
- /// Helper to understand if the was added or updated
- ///
- public bool KeyUpserted => ChangeKind.HasFlag(ChangeKindType.Added) | ChangeKind.HasFlag(ChangeKindType.Updated);
}
diff --git a/src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs b/src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs
index 7bef6792..cc497435 100644
--- a/src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs
+++ b/src/net/KEFCore/Storage/Internal/EntityTypeProducer.cs
@@ -300,7 +300,7 @@ private void KafkaCompactedReplicator_OnRemoteUpdate(IKNetCompactedReplicator
{
- _onChangeEvent?.Invoke(new EntityTypeChanged(_entityType, EntityTypeChanged.ChangeKindType.Upserted, arg2.Key));
+ _onChangeEvent?.Invoke(new EntityTypeChanged(_entityType, arg1.ContainsKey(arg2.Key) ? EntityTypeChanged.ChangeKindType.Updated : EntityTypeChanged.ChangeKindType.Added, arg2.Key));
});
}