[DEVEX-222] Added tests for appends with autoserialization

Author: oskardudycz

src/Kurrent.Client/Streams/KurrentClient.Append.cs

@@ -37,10 +37,10 @@ public Task<IWriteResult> AppendToStreamAsync(
 
 			var eventsData = _messageSerializer.Serialize(messages, serializationContext);
 
-			return options.StreamRevision.HasValue
+			return options.ExpectedStreamRevision.HasValue
 				? AppendToStreamAsync(
 					streamName,
-					options.StreamRevision.Value,
+					options.ExpectedStreamRevision.Value,
 					eventsData,
 					options.ConfigureOperationOptions,
 					options.Deadline,
@@ -49,7 +49,7 @@ public Task<IWriteResult> AppendToStreamAsync(
 				)
 				: AppendToStreamAsync(
 					streamName,
-					options.StreamState ?? StreamState.Any,
+					options.ExpectedStreamState ?? StreamState.Any,
 					eventsData,
 					options.ConfigureOperationOptions,
 					options.Deadline,
@@ -562,14 +562,14 @@ public static Task<IWriteResult> AppendToStreamAsync(
 	// TODO: In the follow up PR merge StreamState and StreamRevision into a one thing
 	public class AppendToStreamOptions {
 		/// <summary>
-		/// The expected <see cref="StreamState"/> of the stream to append to.
+		/// The expected <see cref="ExpectedStreamState"/> of the stream to append to.
 		/// </summary>
-		public StreamState? StreamState { get; set; }
+		public StreamState? ExpectedStreamState { get; set; }
 
 		/// <summary>
-		/// The expected <see cref="StreamRevision"/> of the stream to append to.
+		/// The expected <see cref="ExpectedStreamRevision"/> of the stream to append to.
 		/// </summary>
-		public StreamRevision? StreamRevision { get; set; }
+		public StreamRevision? ExpectedStreamRevision { get; set; }
 
 		/// <summary>
 		/// An <see cref="Action{KurrentClientOperationOptions}"/> to configure the operation's options.

test/Kurrent.Client.Tests.Common/Fixtures/KurrentPermanentFixture.Helpers.cs

@@ -1,6 +1,7 @@
 using System.Runtime.CompilerServices;
 using System.Text;
 using EventStore.Client;
+using Kurrent.Client.Core.Serialization;
 
 namespace Kurrent.Client.Tests;
 
@@ -48,6 +49,11 @@ public IEnumerable<EventData> CreateTestEvents(
 		Enumerable.Range(0, count)
 			.Select(index => CreateTestEvent(index, type ?? TestEventType, metadata, contentType));
 
+
+	public IEnumerable<Message> CreateTestMessages(int count = 1, object? metadata = null) =>
+		Enumerable.Range(0, count)
+			.Select(index => CreateTestMessage(index, metadata));
+
 	public EventData CreateTestEvent(
 		string? type = null, ReadOnlyMemory<byte>? metadata = null, string? contentType = null
 	) =>
@@ -63,6 +69,13 @@ public IEnumerable<EventData> CreateTestEventsThatThrowsException() {
 
 	protected static EventData CreateTestEvent(int index) => CreateTestEvent(index, TestEventType);
 
+	protected static Message CreateTestMessage(int index, object? metadata = null) =>
+		Message.From(
+			new DummyEvent(index),
+			metadata,
+			Uuid.NewUuid()
+		);
+	
 	protected static EventData CreateTestEvent(
 		int index, string type, ReadOnlyMemory<byte>? metadata = null, string? contentType = null
 	) =>
@@ -104,4 +117,6 @@ public async Task RestartService(TimeSpan delay) {
 		await Streams.WarmUp();
 		Log.Information("Service restarted.");
 	}
+
+	public record DummyEvent(int X);
 }