v0.4-rc1v0.4-rc1

1 files changed, 10 insertions, 6 deletions

diff --git a/Sites/PagerMon.cs b/Sites/PagerMon.cs
index 4d19354..9dfd7df 100644
--- a/Sites/PagerMon.cs
+++ b/Sites/PagerMon.cs
@@ -1,5 +1,4 @@
 using SocketIOClient;
-using System;
 using System.Text.Json;
 
 namespace PagerParser.PagerProviders;
@@ -22,8 +21,9 @@ public class PagerMon : IPagerProvider {
         public PagerMonMessage[] Messages { get; set; }
     }
 
-    public event EventHandler        OnConnect;
-    public event PagerMessageHandler OnPagerMessage;
+    public event EventHandler         OnConnect;
+    public event EventHandler<string> OnDisconnect;
+    public event PagerMessageHandler  OnPagerMessage;
 
     private const string QueryBaseUrl =
         "https://jobyyy.net/api/messages";
@@ -34,14 +34,18 @@ public class PagerMon : IPagerProvider {
 
     public PagerMon() {
         socketIOClient = new SocketIO("https://jobyyy.net/", new SocketIOOptions() {
-            Transport   = SocketIOClient.Transport.TransportProtocol.WebSocket,
-            AutoUpgrade = false,
-            EIO         = EngineIO.V3
+            AutoUpgrade       = false,
+            ConnectionTimeout = TimeSpan.FromMinutes(15),
+            EIO               = EngineIO.V3,
+            Transport         = SocketIOClient.Transport.TransportProtocol.WebSocket
         });
 
         socketIOClient.OnConnected += (sender, e) =>
             OnConnect?.Invoke(this, e);
 
+        socketIOClient.OnDisconnected += (sender, e) =>
+            OnDisconnect?.Invoke(this, e);
+
         socketIOClient.On("messagePost", PagerMessageReceived);
     }