Fixes #124 (#125)

Eventuous · Aug 25, 2022 · 7bb546a · 7bb546a
1 parent da628a3
commit 7bb546a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/src/Core/src/Eventuous/Aggregate.cs b/src/Core/src/Eventuous/Aggregate.cs
@@ -56,7 +56,7 @@ public abstract class Aggregate {
     /// </summary>
     /// <exception cref="DomainException"></exception>
     protected void EnsureDoesntExist(Func<Exception>? getException = null) {
-        if (Original.Length > 0)
+        if (CurrentVersion >= 0)
             throw getException?.Invoke()
                ?? new DomainException($"{GetType().Name} already exists");
     }
@@ -66,7 +66,7 @@ protected void EnsureDoesntExist(Func<Exception>? getException = null) {
     /// </summary>
     /// <exception cref="DomainException"></exception>
     protected void EnsureExists(Func<Exception>? getException = null) {
-        if (Original.Length == 0)
+        if (CurrentVersion < 0)
             throw getException?.Invoke()
                ?? new DomainException($"{GetType().Name} doesn't exist");
     }

diff --git a/src/Kafka/src/Eventuous.Kafka/Producers/KafkaBasicProducer.cs b/src/Kafka/src/Eventuous.Kafka/Producers/KafkaBasicProducer.cs
@@ -4,7 +4,6 @@
 using Confluent.Kafka;
 using Eventuous.Producers;
 using Eventuous.Producers.Diagnostics;
-using Microsoft.Extensions.Hosting;
 
 namespace Eventuous.Kafka.Producers;