diff options
| -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")) } |