Add ReadRawTests.fs

Author: Jamil Maqdis Anton

tests/ReadRawTests.fs

@@ -16,7 +16,7 @@ let guidString2 = "22222222-2222-2222-2222-222222222222"
 [<Tests>]
 let tests =
     testList
-        "Read Tests"
+        "ReadRaw Tests"
         [ testAsync "Should read forward from specific stream." {
               let inMemStore = new SqlStreamStore.InMemoryStreamStore()
 

tests/ReadTests.fs

@@ -0,0 +1,153 @@
+module SqlStreamStore.FSharp.Tests.ReadTests
+
+open Expecto
+open SqlStreamStore.FSharp
+
+let newTestMessage (guidString: string): MessageDetails =
+    { id = StreamMessageId.Custom(System.Guid.Parse(guidString))
+      type_ = "testing"
+      jsonData = "{}"
+      jsonMetadata = "{}" }
+
+let guidString1 = "11111111-1111-1111-1111-111111111111"
+
+let guidString2 = "22222222-2222-2222-2222-222222222222"
+
+[<Tests>]
+let tests =
+    testList
+        "Read Tests"
+        [ testAsync "Should read forward from specific stream." {
+              let inMemStore = new SqlStreamStore.InMemoryStreamStore()
+
+              let streamName = "test"
+
+              let appendVersion = AppendVersion.NoStream
+
+              let msg1 = newTestMessage guidString1
+
+              let msg2 = newTestMessage guidString2
+
+              let msgList = [ msg1; msg2 ]
+
+              do! AppendRaw.appendNewMessages inMemStore streamName appendVersion msgList
+                  |> Async.Ignore
+
+              let readVersion = ReadVersion.Start
+
+              let! readResult = ReadRaw.readFromStream inMemStore ReadingDirection.Forward streamName readVersion 10
+
+              readResult.Messages
+              |> Array.sortBy (fun msg -> msg.MessageId)
+              |> fun sorted ->
+                  Expect.equal
+                      (sorted.[0].MessageId.ToString())
+                      guidString1
+                      "Error: first message in stream doesn't match."
+                  Expect.equal
+                      (sorted.[1].MessageId.ToString())
+                      guidString2
+                      "Error: second message in stream doesn't match."
+          }
+          testAsync "Should read Backward from specific stream." {
+              let inMemStore = new SqlStreamStore.InMemoryStreamStore()
+
+              let streamName = "test"
+
+              let appendVersion = AppendVersion.NoStream
+
+              let msg1 = newTestMessage guidString1
+
+              let msg2 = newTestMessage guidString2
+
+              let msgList = [ msg1; msg2 ]
+
+              do! AppendRaw.appendNewMessages inMemStore streamName appendVersion msgList
+                  |> Async.Ignore
+
+              let readVersion = ReadVersion.End
+
+              let! readResult = ReadRaw.readFromStream inMemStore ReadingDirection.Backward streamName readVersion 10
+
+              readResult.Messages
+              |> Array.sortBy (fun msg -> msg.MessageId)
+              |> fun sorted ->
+                  Expect.equal
+                      (sorted.[1].MessageId.ToString())
+                      guidString2
+                      "Error: second message in stream doesn't match."
+                  Expect.equal
+                      (sorted.[0].MessageId.ToString())
+                      guidString1
+                      "Error: first message in stream doesn't match."
+          }
+
+          testAsync "Should read from all streams forward." {
+              let inMemStore = new SqlStreamStore.InMemoryStreamStore()
+
+              let stream1 = "test1"
+
+              let stream2 = "test2"
+
+              let appendVersion = AppendVersion.NoStream
+
+              let msg1 = newTestMessage guidString1
+
+              let msg2 = newTestMessage guidString2
+
+              do! AppendRaw.appendNewMessage inMemStore stream1 appendVersion msg1
+                  |> Async.Ignore
+
+              do! AppendRaw.appendNewMessage inMemStore stream2 appendVersion msg2
+                  |> Async.Ignore
+
+              let! readResult = ReadRaw.readFromAllStream inMemStore ReadingDirection.Forward StartPosition.Start 10
+
+              readResult.Messages
+              |> Array.sortBy (fun msg -> msg.MessageId)
+              |> fun sorted ->
+                  Expect.equal
+                      (sorted.[0].MessageId.ToString())
+                      guidString1
+                      "Error: first message in stream doesn't match."
+                  Expect.equal
+                      (sorted.[1].MessageId.ToString())
+                      guidString2
+                      "Error: second message in stream doesn't match."
+          }
+
+          testAsync "Should read from all streams backward." {
+              let inMemStore = new SqlStreamStore.InMemoryStreamStore()
+
+              let stream1 = "test1"
+
+              let stream2 = "test2"
+
+              let appendVersion = AppendVersion.NoStream
+
+              let msg1 = newTestMessage guidString1
+
+              let msg2 = newTestMessage guidString2
+
+              do! AppendRaw.appendNewMessage inMemStore stream1 appendVersion msg1
+                  |> Async.Ignore
+
+              do! AppendRaw.appendNewMessage inMemStore stream2 appendVersion msg2
+                  |> Async.Ignore
+
+              let! readResult = ReadRaw.readFromAllStream inMemStore ReadingDirection.Backward StartPosition.End 10
+
+              readResult.Messages
+              |> Array.sortBy (fun msg -> msg.MessageId)
+              |> fun sorted ->
+                  Expect.equal
+                      (sorted.[1].MessageId.ToString())
+                      guidString2
+                      "Error: second message in stream doesn't match."
+                  Expect.equal
+                      (sorted.[0].MessageId.ToString())
+                      guidString1
+                      "Error: first message in stream doesn't match."
+          } ]
+
+

tests/SqlStreamStore.FSharp.Tests.fsproj

@@ -10,6 +10,7 @@
         <Compile Include="AppendRawTests.fs" />
         <Compile Include="AppendTests.fs" />
         <Compile Include="ReadRawTests.fs" />
+        <Compile Include="ReadTests.fs" />
         <Compile Include="Program.fs" />
     </ItemGroup>