Salastil/KfChatDotNet
1
0
Fork 0
mirror of https://github.com/barelyprofessional/KfChatDotNet.git synced 2026-05-02 04:22:04 -04:00
Code Issues Packages Projects Releases Wiki Activity

Hopeful fix for invalid operation exception when reconnecting to Howl and Discord

Browse Source
This commit is contained in:
barelyprofessional
2024-07-18 14:20:15 +10:00
parent 6c8ee91ad6
commit e4c4b3b41f
2 changed files with 21 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
KfChatDotNetKickBot/Services/Discord.cs
View File

@@ -161,7 +161,16 @@ public class DiscordService
"\"since\":0,\"activities\":[],\"afk\":false},\"compress\":false,\"client_state\":{\"guild_versions\":{}}}}"; "\"since\":0,\"activities\":[],\"afk\":false},\"compress\":false,\"client_state\":{\"guild_versions\":{}}}}";
_logger.Debug(initPayload); _logger.Debug(initPayload);
_wsClient.SendInstant(initPayload).Wait(_cancellationToken); _wsClient.SendInstant(initPayload).Wait(_cancellationToken);
_heartbeatTask?.Dispose(); if (_heartbeatTask != null)
{
_pingCts.Cancel();
while (!_heartbeatTask.IsCompleted)
{
_logger.Debug("Waiting for heartbeat task to die");
Task.Delay(TimeSpan.FromMilliseconds(100), _cancellationToken).Wait(_cancellationToken);
}
_heartbeatTask.Dispose();
}
_heartbeatInterval = _heartbeatInterval =
TimeSpan.FromMilliseconds(packet.Data.GetProperty("heartbeat_interval").GetInt32()); TimeSpan.FromMilliseconds(packet.Data.GetProperty("heartbeat_interval").GetInt32());
_heartbeatTask = Task.Run(HeartbeatTimer, _cancellationToken); _heartbeatTask = Task.Run(HeartbeatTimer, _cancellationToken);

12
KfChatDotNetKickBot/Services/Howlgg.cs
View File

@@ -143,7 +143,17 @@ public class Howlgg
// Received on initial connection // Received on initial connection
var packetData = JsonSerializer.Deserialize<JsonElement>(message.Text.TrimStart('0')); var packetData = JsonSerializer.Deserialize<JsonElement>(message.Text.TrimStart('0'));
_heartbeatInterval = TimeSpan.FromMilliseconds(packetData.GetProperty("pingInterval").GetInt32()); _heartbeatInterval = TimeSpan.FromMilliseconds(packetData.GetProperty("pingInterval").GetInt32());
_heartbeatTask?.Dispose(); if (_heartbeatTask != null)
{
_pingCts.Cancel();
while (!_heartbeatTask.IsCompleted)
{
_logger.Debug("Waiting for heartbeat task to die");
Task.Delay(TimeSpan.FromMilliseconds(100), _cancellationToken).Wait(_cancellationToken);
}
_heartbeatTask.Dispose();
}
_heartbeatTask = Task.Run(HeartbeatTimer, _cancellationToken); _heartbeatTask = Task.Run(HeartbeatTimer, _cancellationToken);
_logger.Info("Received connection packet from Howl.gg. Setting up heartbeat timer"); _logger.Info("Received connection packet from Howl.gg. Setting up heartbeat timer");
return; return;