diff options
| author | Xe Iaso <me@xeiaso.net> | 2023-06-20 07:12:47 -0400 |
|---|---|---|
| committer | Xe Iaso <me@xeiaso.net> | 2023-06-20 07:13:15 -0400 |
| commit | 1b657dbcce1ffd81c1a301234367176523b4acb5 (patch) | |
| tree | 25150eb2b735fea32684b9d8942e249f8f94898d /web | |
| parent | 74ba1a3f951c890e646f98d686c3a9866a4fde06 (diff) | |
| download | x-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.go | 6 |
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")) } |
