diff options
| author | Xe Iaso <me@xeiaso.net> | 2023-06-16 22:46:02 -0400 |
|---|---|---|
| committer | Xe Iaso <me@xeiaso.net> | 2023-06-16 22:46:02 -0400 |
| commit | 0b4d9abb80af44b026bd5f0e46cd7d303f059d73 (patch) | |
| tree | be49e75d1a168087bbfedf8d5b444f94b4c2ee91 /web/revolt | |
| parent | f3d2b8386a188041b823d02b65dad347a324a089 (diff) | |
| download | x-0b4d9abb80af44b026bd5f0e46cd7d303f059d73.tar.xz x-0b4d9abb80af44b026bd5f0e46cd7d303f059d73.zip | |
cmd/marabot: start importing discord data
Signed-off-by: Xe Iaso <me@xeiaso.net>
Diffstat (limited to 'web/revolt')
| -rw-r--r-- | web/revolt/websocket.go | 9 |
1 files changed, 3 insertions, 6 deletions
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) |
