From e8e3c4cba8ffa0056e984c113cfbb75319e00022 Mon Sep 17 00:00:00 2001
From: Jake Mannens <jake@asger.xyz>
Date: Fri, 20 Sep 2024 16:21:09 +1000
Subject: v0.4-rc1

---
 Sites/PagerMon.cs | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

(limited to 'Sites')

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);
     }
 
-- 
cgit v1.3