aboutsummaryrefslogtreecommitdiff
path: root/web/revolt/websocket.go
diff options
context:
space:
mode:
authorXe Iaso <me@xeiaso.net>2023-06-17 13:38:38 -0400
committerXe Iaso <me@xeiaso.net>2023-06-17 13:38:38 -0400
commit24f5fb57f3e36ff2f6150468c4cb10c4f5bb282c (patch)
tree80ae280ac54c1cdf36b43210f6e1dee062edf534 /web/revolt/websocket.go
parentacad94fc2d42f295e25d5a2d33d8be78290bc3a8 (diff)
downloadx-1.5.0.tar.xz
x-1.5.0.zip
cmd/marabot: move emoji copying to another binaryv1.5.0
Signed-off-by: Xe Iaso <me@xeiaso.net>
Diffstat (limited to 'web/revolt/websocket.go')
-rw-r--r--web/revolt/websocket.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/web/revolt/websocket.go b/web/revolt/websocket.go
index 84fbbcd..2e2ad74 100644
--- a/web/revolt/websocket.go
+++ b/web/revolt/websocket.go
@@ -17,6 +17,10 @@ func (c *Client) Connect(ctx context.Context, handler Handler) {
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"))
+ }
+
for {
select {
case <-ctx.Done():