about summary refs log tree commit diff
path: root/pkg/discord
diff options
context:
space:
mode:
authorMel <einebeere@gmail.com>2022-04-07 18:21:57 +0200
committerMel <einebeere@gmail.com>2022-04-07 18:21:57 +0200
commit4b08666755bc3a490815644c1a5f93abdb93a093 (patch)
treebfa936664915a30988199efaaa9ee100d48cb5c3 /pkg/discord
parent782e75b403c0d14beabdd7b74ad12388087b1321 (diff)
downloadjinx-4b08666755bc3a490815644c1a5f93abdb93a093.tar.zst
jinx-4b08666755bc3a490815644c1a5f93abdb93a093.zip
Fix heartbeat jitter order
Diffstat (limited to 'pkg/discord')
-rw-r--r--pkg/discord/heartbeat.go12
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
 		}
 	}
 }