aboutsummaryrefslogtreecommitdiff
path: root/web/revolt
diff options
context:
space:
mode:
authorXe Iaso <me@xeiaso.net>2023-06-16 22:46:02 -0400
committerXe Iaso <me@xeiaso.net>2023-06-16 22:46:02 -0400
commit0b4d9abb80af44b026bd5f0e46cd7d303f059d73 (patch)
treebe49e75d1a168087bbfedf8d5b444f94b4c2ee91 /web/revolt
parentf3d2b8386a188041b823d02b65dad347a324a089 (diff)
downloadx-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.go9
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)