diff options
Diffstat (limited to 'Sites')
| -rw-r--r-- | Sites/PagerMon.cs | 16 |
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); } |