aboutsummaryrefslogtreecommitdiff
path: root/web
diff options
context:
space:
mode:
authorXe Iaso <me@xeiaso.net>2023-06-20 07:12:47 -0400
committerXe Iaso <me@xeiaso.net>2023-06-20 07:13:15 -0400
commit1b657dbcce1ffd81c1a301234367176523b4acb5 (patch)
tree25150eb2b735fea32684b9d8942e249f8f94898d /web
parent74ba1a3f951c890e646f98d686c3a9866a4fde06 (diff)
downloadx-1b657dbcce1ffd81c1a301234367176523b4acb5.tar.xz
x-1b657dbcce1ffd81c1a301234367176523b4acb5.zip
web/revolt: more logging on reconnect attempts
Signed-off-by: Xe Iaso <me@xeiaso.net>
Diffstat (limited to 'web')
-rw-r--r--web/revolt/websocket.go6
1 files changed, 4 insertions, 2 deletions
diff --git a/web/revolt/websocket.go b/web/revolt/websocket.go
index 2e2ad74..f7477c4 100644
--- a/web/revolt/websocket.go
+++ b/web/revolt/websocket.go
@@ -13,19 +13,21 @@ import (
func (c *Client) Connect(ctx context.Context, handler Handler) {
ctx = opname.With(ctx, "websocket-connect")
- t := time.NewTicker(30 * time.Second)
- defer t.Stop()
go func(ctx context.Context) {
if err := c.doWebsocket(ctx, c.Token, c.WSURL, handler); err != nil {
ln.Error(ctx, err, ln.Info("websocket error, retrying"))
}
+ t := time.NewTicker(30 * time.Second)
+ defer t.Stop()
+
for {
select {
case <-ctx.Done():
return
case <-t.C:
+ ln.Log(ctx, ln.Action("reconnecting"))
if err := c.doWebsocket(ctx, c.Token, c.WSURL, handler); err != nil {
ln.Error(ctx, err, ln.Info("websocket error, retrying"))
}