Feature/sqlserver fixes (#137)

* Fix that event was saved in metadata Fix naming * restore sql connection string in test
Eventuous · Sep 27, 2022 · 21fb4e6 · 21fb4e6
1 parent 15ffd13
commit 21fb4e6
Show file tree

Hide file tree

Showing 5 changed files with 28 additions and 7 deletions.
diff --git a/src/SqlServer/src/Eventuous.SqlServer/Extensions/SqlParameterCollectionExtensions.cs b/src/SqlServer/src/Eventuous.SqlServer/Extensions/SqlParameterCollectionExtensions.cs
@@ -23,7 +23,7 @@ IEnumerable<NewPersistedEvent>                                         persisted
             row["message_id"]    = persistedEvent.MessageId;
             row["message_type"]  = persistedEvent.MessageType;
             row["json_data"]     = persistedEvent.JsonData;
-            row["json_metadata"] = persistedEvent.JsonData;
+            row["json_metadata"] = persistedEvent.JsonMetadata;
             tableVariable.Rows.Add(row);
         }
 

diff --git a/src/SqlServer/src/Eventuous.SqlServer/Subscriptions/SqlServerAllStreamSubscription.cs b/src/SqlServer/src/Eventuous.SqlServer/Subscriptions/SqlServerAllStreamSubscription.cs
@@ -10,10 +10,10 @@
 
 namespace Eventuous.SqlServer.Subscriptions;
 
-public class SqlServerAllStreamSubscription : SqlServerSubscriptionBase<PostgresAllStreamSubscriptionOptions> {
+public class SqlServerAllStreamSubscription : SqlServerSubscriptionBase<SqlServerAllStreamSubscriptionOptions> {
     public SqlServerAllStreamSubscription(
         GetSqlServerConnection               getConnection,
-        PostgresAllStreamSubscriptionOptions options,
+        SqlServerAllStreamSubscriptionOptions options,
         ICheckpointStore                     checkpointStore,
         ConsumePipe                          consumePipe
     ) : base(getConnection, options, checkpointStore, consumePipe) { }
@@ -53,4 +53,4 @@ CancellationToken cancellationToken
         );
 }
 
-public record PostgresAllStreamSubscriptionOptions : SqlServerSubscriptionBaseOptions;
+public record SqlServerAllStreamSubscriptionOptions : SqlServerSubscriptionBaseOptions;
diff --git a/src/SqlServer/test/Eventuous.Tests.SqlServer/Store/Helpers.cs b/src/SqlServer/test/Eventuous.Tests.SqlServer/Store/Helpers.cs
@@ -28,8 +28,8 @@ ExpectedStreamVersion version
         return Instance.EventStore.AppendEvents(stream, version, streamEvents.ToArray(), default);
     }
 
-    public static Task<AppendEventsResult> AppendEvent(StreamName stream, object evt, ExpectedStreamVersion version) {
-        var streamEvent = new StreamEvent(Guid.NewGuid(), evt, new Metadata(), "", 0);
+    public static Task<AppendEventsResult> AppendEvent(StreamName stream, object evt, ExpectedStreamVersion version, Metadata? metadata = null) {
+        var streamEvent = new StreamEvent(Guid.NewGuid(), evt, metadata ?? new Metadata(), "", 0);
         return Instance.EventStore.AppendEvents(stream, version, new[] { streamEvent }, default);
     }
 }
diff --git a/src/SqlServer/test/Eventuous.Tests.SqlServer/Store/Read.cs b/src/SqlServer/test/Eventuous.Tests.SqlServer/Store/Read.cs
@@ -1,3 +1,4 @@
+using System.Text.Json;
 using static Eventuous.Tests.SqlServer.Fixtures.IntegrationFixture;
 using static Eventuous.Tests.SqlServer.Store.Helpers;
 
@@ -19,6 +20,26 @@ public async Task ShouldReadOne() {
 
         result.Length.Should().Be(1);
         result[0].Payload.Should().BeEquivalentTo(evt);
+        result[0].Metadata.Should().BeEquivalentTo(new Metadata());
+    }
+
+    [Fact]
+    public async Task ShouldReadMetadata() {
+        var evt        = CreateEvent();
+        var streamName = GetStreamName();
+        await AppendEvent(streamName, evt, ExpectedStreamVersion.NoStream, new Metadata {{"Key1","Value1"},{"Key2","Value2"}});
+
+        var result = await Instance.EventStore.ReadEvents(
+            streamName,
+            StreamReadPosition.Start,
+            100,
+            default
+        );
+
+        result.Length.Should().Be(1);
+        result[0].Payload.Should().BeEquivalentTo(evt);
+        result[0].Metadata.ToDictionary(m => m.Key, m => ((JsonElement)m.Value).GetString())
+            .Should().BeEquivalentTo(new Metadata {{"Key1", "Value1"},{"Key2","Value2"}});
     }
 
     [Fact]

diff --git a/src/SqlServer/test/Eventuous.Tests.SqlServer/Subscriptions/SubscriptionFixture.cs b/src/SqlServer/test/Eventuous.Tests.SqlServer/Subscriptions/SubscriptionFixture.cs
@@ -61,7 +61,7 @@ protected SubscriptionFixture(
                 )
                 : new SqlServerAllStreamSubscription(
                     Instance.GetConnection,
-                    new PostgresAllStreamSubscriptionOptions {
+                    new SqlServerAllStreamSubscriptionOptions {
                         SubscriptionId = SubscriptionId,
                         Schema         = SchemaName
                     },