@@ -3,12 +3,11 @@ module SqlStreamStore.FSharp.Tests.ReadTests
33open Expecto
44open SqlStreamStore.FSharp
55
6- let newTestMessage : string -> MessageDetails =
7- fun guid ->
8- { id = StreamMessageId.Custom( System.Guid.Parse( guid))
9- type_ = " testing"
10- jsonData = " {}"
11- jsonMetadata = " {}" }
6+ let newTestMessage ( guidString : string ): MessageDetails =
7+ { id = StreamMessageId.Custom( System.Guid.Parse( guidString))
8+ type_ = " testing"
9+ jsonData = " {}"
10+ jsonMetadata = " {}" }
1211
1312let guidString1 = " 11111111-1111-1111-1111-111111111111"
1413
@@ -41,8 +40,14 @@ let tests =
4140 readResult.Messages
4241 |> Array.sortBy ( fun msg -> msg.MessageId)
4342 |> fun sorted ->
44- Expect.equal ( sorted.[ 0 ]. MessageId.ToString()) guidString1 " Error: first message in stream doesn't match."
45- Expect.equal ( sorted.[ 1 ]. MessageId.ToString()) guidString2 " Error: second message in stream doesn't match."
43+ Expect.equal
44+ ( sorted.[ 0 ]. MessageId.ToString())
45+ guidString1
46+ " Error: first message in stream doesn't match."
47+ Expect.equal
48+ ( sorted.[ 1 ]. MessageId.ToString())
49+ guidString2
50+ " Error: second message in stream doesn't match."
4651 }
4752 testAsync " Should read Backward from specific stream." {
4853 let inMemStore = new SqlStreamStore.InMemoryStreamStore()
@@ -67,8 +72,14 @@ let tests =
6772 readResult.Messages
6873 |> Array.sortBy ( fun msg -> msg.MessageId)
6974 |> fun sorted ->
70- Expect.equal ( sorted.[ 1 ]. MessageId.ToString()) guidString2 " Error: second message in stream doesn't match."
71- Expect.equal ( sorted.[ 0 ]. MessageId.ToString()) guidString1 " Error: first message in stream doesn't match."
75+ Expect.equal
76+ ( sorted.[ 1 ]. MessageId.ToString())
77+ guidString2
78+ " Error: second message in stream doesn't match."
79+ Expect.equal
80+ ( sorted.[ 0 ]. MessageId.ToString())
81+ guidString1
82+ " Error: first message in stream doesn't match."
7283 }
7384
7485 testAsync " Should read from all streams forward." {
@@ -95,8 +106,14 @@ let tests =
95106 readResult.Messages
96107 |> Array.sortBy ( fun msg -> msg.MessageId)
97108 |> fun sorted ->
98- Expect.equal ( sorted.[ 0 ]. MessageId.ToString()) guidString1 " Error: first message in stream doesn't match."
99- Expect.equal ( sorted.[ 1 ]. MessageId.ToString()) guidString2 " Error: second message in stream doesn't match."
109+ Expect.equal
110+ ( sorted.[ 0 ]. MessageId.ToString())
111+ guidString1
112+ " Error: first message in stream doesn't match."
113+ Expect.equal
114+ ( sorted.[ 1 ]. MessageId.ToString())
115+ guidString2
116+ " Error: second message in stream doesn't match."
100117 }
101118
102119 testAsync " Should read from all streams backward." {
@@ -123,6 +140,12 @@ let tests =
123140 readResult.Messages
124141 |> Array.sortBy ( fun msg -> msg.MessageId)
125142 |> fun sorted ->
126- Expect.equal ( sorted.[ 1 ]. MessageId.ToString()) guidString2 " Error: second message in stream doesn't match."
127- Expect.equal ( sorted.[ 0 ]. MessageId.ToString()) guidString1 " Error: first message in stream doesn't match."
143+ Expect.equal
144+ ( sorted.[ 1 ]. MessageId.ToString())
145+ guidString2
146+ " Error: second message in stream doesn't match."
147+ Expect.equal
148+ ( sorted.[ 0 ]. MessageId.ToString())
149+ guidString1
150+ " Error: first message in stream doesn't match."
128151 } ]
0 commit comments