From 0b4d9abb80af44b026bd5f0e46cd7d303f059d73 Mon Sep 17 00:00:00 2001 From: Xe Iaso Date: Fri, 16 Jun 2023 22:46:02 -0400 Subject: cmd/marabot: start importing discord data Signed-off-by: Xe Iaso --- web/revolt/websocket.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) (limited to 'web/revolt') diff --git a/web/revolt/websocket.go b/web/revolt/websocket.go index 87a35b4..84fbbcd 100644 --- a/web/revolt/websocket.go +++ b/web/revolt/websocket.go @@ -9,25 +9,22 @@ import ( "nhooyr.io/websocket" "within.website/ln" "within.website/ln/opname" - "within.website/x/cardio" ) func (c *Client) Connect(ctx context.Context, handler Handler) { ctx = opname.With(ctx, "websocket-connect") - heartbeat, slower, faster := cardio.Heartbeat(ctx, 10*time.Minute, time.Second) + t := time.NewTicker(30 * time.Second) + defer t.Stop() go func(ctx context.Context) { for { select { case <-ctx.Done(): return - case <-heartbeat: + case <-t.C: if err := c.doWebsocket(ctx, c.Token, c.WSURL, handler); err != nil { ln.Error(ctx, err, ln.Info("websocket error, retrying")) - slower() } - default: - faster() } } }(ctx) -- cgit v1.2.3