Add stream deletion tests when there are existing events [DB-573]

test/EventStore.Client.Streams.Tests/subscribe_to_stream.cs

@@ -226,7 +226,7 @@ Task EventAppeared(StreamSubscription s, ResolvedEvent e, CancellationToken ct)
 	}
 
 	[Fact]
-	public async Task catches_deletions() {
+	public async Task catches_deletions_when_stream_has_no_existing_events() {
 		var stream = _fixture.GetStreamName();
 
 		var dropped = new TaskCompletionSource<(SubscriptionDroppedReason, Exception?)>();
@@ -253,6 +253,36 @@ public async Task catches_deletions() {
 		void SubscriptionDropped(StreamSubscription s, SubscriptionDroppedReason reason, Exception? ex) => dropped.SetResult((reason, ex));
 	}
 
+	[Fact]
+	public async Task catches_deletions_when_stream_has_existing_events() {
+		var stream = _fixture.GetStreamName();
+
+		var dropped = new TaskCompletionSource<(SubscriptionDroppedReason, Exception?)>();
+
+		await _fixture.Client.AppendToStreamAsync(stream, StreamState.NoStream, _fixture.CreateTestEvents());
+
+		using var _ = await _fixture.Client
+			.SubscribeToStreamAsync(
+				stream,
+				FromStream.Start,
+				EventAppeared,
+				false,
+				SubscriptionDropped
+			)
+			.WithTimeout();
+
+		await _fixture.Client.TombstoneAsync(stream, StreamState.StreamExists);
+		var (reason, ex) = await dropped.Task.WithTimeout();
+
+		Assert.Equal(SubscriptionDroppedReason.ServerError, reason);
+		var sdex = Assert.IsType<StreamDeletedException>(ex);
+		Assert.Equal(stream, sdex.Stream);
+
+		Task EventAppeared(StreamSubscription s, ResolvedEvent e, CancellationToken ct) => Task.CompletedTask;
+
+		void SubscriptionDropped(StreamSubscription s, SubscriptionDroppedReason reason, Exception? ex) => dropped.SetResult((reason, ex));
+	}
+
 	public class Fixture : EventStoreClientFixture {
 		public Fixture() => Events = CreateTestEvents(10).ToArray();
 
@@ -262,4 +292,4 @@ public class Fixture : EventStoreClientFixture {
 
 		protected override Task When() => Task.CompletedTask;
 	}
-}
+}

test/EventStore.Client.Streams.Tests/subscribe_to_stream_live.cs

@@ -131,7 +131,7 @@
 	}
 
 	[Fact]
-	public async Task catches_deletions() {
+	public async Task catches_deletions_when_stream_has_no_existing_events() {
 		var stream = _fixture.GetStreamName();
 
 		var dropped = new TaskCompletionSource<(SubscriptionDroppedReason, Exception?)>();
@@ -147,7 +147,7 @@
 			.WithTimeout();
 
 		await _fixture.Client.TombstoneAsync(stream, StreamState.NoStream);
 		var (reason, ex) = await dropped.Task.WithTimeout();
 
 		Assert.Equal(SubscriptionDroppedReason.ServerError, reason);
 		var sdex = Assert.IsType<StreamDeletedException>(ex);
@@ -158,8 +158,38 @@
 		void SubscriptionDropped(StreamSubscription s, SubscriptionDroppedReason reason, Exception? ex) => dropped.SetResult((reason, ex));
 	}
 
+	[Fact]
+	public async Task catches_deletions_when_stream_has_existing_events() {
+		var stream = _fixture.GetStreamName();
+
+		var dropped = new TaskCompletionSource<(SubscriptionDroppedReason, Exception?)>();
+
+		await _fixture.Client.AppendToStreamAsync(stream, StreamState.NoStream, _fixture.CreateTestEvents());
+
+		using var _ = await _fixture.Client
+			.SubscribeToStreamAsync(
+				stream,
+				FromStream.End,
+				EventAppeared,
+				false,
+				SubscriptionDropped
+			)
+			.WithTimeout();
+
+		await _fixture.Client.TombstoneAsync(stream, StreamState.StreamExists);
+		var (reason, ex) = await dropped.Task.WithTimeout();
+
+		Assert.Equal(SubscriptionDroppedReason.ServerError, reason);
+		var sdex = Assert.IsType<StreamDeletedException>(ex);
+		Assert.Equal(stream, sdex.Stream);
+
+		Task EventAppeared(StreamSubscription s, ResolvedEvent e, CancellationToken ct) => Task.CompletedTask;
+
+		void SubscriptionDropped(StreamSubscription s, SubscriptionDroppedReason reason, Exception? ex) => dropped.SetResult((reason, ex));
+	}
+
 	public class Fixture : EventStoreClientFixture {
 		protected override Task Given() => Task.CompletedTask;
 		protected override Task When()  => Task.CompletedTask;
 	}
-}
+}