diff options
| -rw-r--r-- | pkg/discord/heartbeat.go | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/pkg/discord/heartbeat.go b/pkg/discord/heartbeat.go index 5d2972f..5c4a955 100644 --- a/pkg/discord/heartbeat.go +++ b/pkg/discord/heartbeat.go @@ -46,6 +46,8 @@ func (h *HeartbeatImpl) Ack() { } func (h *HeartbeatImpl) heartbeatRoutine(interval uint64) { + h.logger.Debug().Msgf("beating heart every %dms", interval) + // REF: heartbeat_interval * jitter jitter := rand.Intn(int(interval)) time.Sleep(time.Duration(jitter) * time.Millisecond) @@ -54,14 +56,16 @@ func (h *HeartbeatImpl) heartbeatRoutine(interval uint64) { defer ticker.Stop() for { + h.logger.Debug().Msg("sending heartbeat") + if err := h.gateway.Heartbeat(); err != nil { + h.logger.Error().Err(err).Msg("failed to send heartbeat") + } + select { case <-h.ctx.Done(): return case <-ticker.C: - h.logger.Debug().Msg("sending heartbeat") - if err := h.gateway.Heartbeat(); err != nil { - h.logger.Error().Err(err).Msg("failed to send heartbeat") - } + continue } } } |