Add tests for MessageSender (#29)

Emulsion.Tests/Emulsion.Tests.fsproj

@@ -5,7 +5,8 @@
   </PropertyGroup>
   <ItemGroup>
     <Compile Include="Settings.fs" />
-    <Compile Include="MessageSystem.fs" />
+    <Compile Include="MessageSenderTests.fs" />
+    <Compile Include="MessageSystemTests.fs" />
     <Compile Include="Actors/Core.fs" />
     <Compile Include="Actors/SyncTaskWatcher.fs" />
     <Compile Include="Actors/Telegram.fs" />

Emulsion.Tests/MessageSenderTests.fs

@@ -0,0 +1,59 @@
+module Emulsion.Tests.MessageSenderTests
+
+open System
+open System.Threading
+
+open Xunit
+open Emulsion
+open Emulsion.MessageSender
+
+let private testContext = {
+    send = fun _ -> async { return () }
+    logError = ignore
+    cooldown = TimeSpan.Zero
+}
+
+[<Fact>]
+let ``Message sender sends the messages sequentially``() =
+    use cts = new CancellationTokenSource()
+    let messagesReceived = ResizeArray()
+    let context = {
+        testContext with
+            send = fun m -> async {
+                lock messagesReceived (fun () ->
+                    messagesReceived.Add m
+                )
+            }
+    }
+    let sender = MessageSender.startActivity(context, cts.Token)
+
+    let messagesSent = [| 1..100 |] |> Array.map (fun i ->
+        OutgoingMessage {
+            author = "author"
+            text = string i
+        }
+    )
+    messagesSent |> Array.iter(MessageSender.send sender)
+
+    SpinWait.SpinUntil((fun () -> messagesReceived.Count = messagesSent.Length), TimeSpan.FromSeconds 30.0)
+    |> Assert.True
+
+    Assert.Equal(messagesSent, messagesReceived)
+
+[<Fact>]
+let ``Message sender should be cancellable``() =
+    use cts = new CancellationTokenSource()
+    let errors = ResizeArray()
+    let context = {
+        testContext with
+            send = fun _ -> failwith "Should not be called"
+            logError = fun e -> lock errors (fun () -> errors.Add e)
+    }
+    let sender = MessageSender.startActivity(context, cts.Token)
+    cts.Cancel()
+
+    let msg = OutgoingMessage { author = "author"; text = "xx" }
+    MessageSender.send sender msg
+
+    SpinWait.SpinUntil((fun () -> errors.Count > 0), TimeSpan.FromMilliseconds 100.0) |> ignore
+    Assert.Empty errors

Emulsion.Tests/MessageSystem.fs → Emulsion.Tests/MessageSystemTests.fs

@@ -1,4 +1,4 @@
-module Emulsion.Tests.MessageSystem
+module Emulsion.Tests.MessageSystemTests
 
 open System
 open System.Threading

Emulsion/MessageSender.fs

@@ -32,4 +32,3 @@ let startActivity(ctx: MessageSenderContext, token: CancellationToken): Sender =
     MailboxProcessor.Start(receiver ctx, token)
 
 let send(activity: Sender): OutgoingMessage -> unit = activity.Post
-// TODO[F]: Tests for this module.