Add a new thread for message sending due to web socket requirements (#…

…140)
paranext · Apr 10, 2023 · 0e5ea44 · 0e5ea44
1 parent b1b2cde
commit 0e5ea44
Show file tree

Hide file tree

Showing 4 changed files with 266 additions and 129 deletions.
diff --git a/c-sharp/MessageHandlers/MessageHandlerInitClient.cs b/c-sharp/MessageHandlers/MessageHandlerInitClient.cs
@@ -0,0 +1,30 @@
+using Paranext.DataProvider.Messages;
+
+namespace Paranext.DataProvider.MessageHandlers;
+
+/// <summary>
+/// Handler for "Response" messages
+/// </summary>
+internal class MessageHandlerInitClient : IMessageHandler
+{
+    Action<int> _clientIdCallback;
+
+    public MessageHandlerInitClient(Action<int> clientIdCallback)
+    {
+        _clientIdCallback = clientIdCallback;
+    }
+
+    public IEnumerable<Message> HandleMessage(Message message)
+    {
+        if (message == null)
+            throw new ArgumentNullException(nameof(message));
+
+        if (message.Type != MessageType.InitClient)
+            throw new ArgumentException("Incorrect message type", nameof(message));
+
+        var initClientMsg = (MessageInitClient)message;
+        int clientId = initClientMsg.ConnectorInfo.ClientId;
+        _clientIdCallback(clientId);
+        yield return new MessageClientConnect(clientId);
+    }
+}