diff --git a/comms/email/websocket.go b/comms/email/websocket.go index 657a6797..9c208ffd 100644 --- a/comms/email/websocket.go +++ b/comms/email/websocket.go @@ -80,6 +80,12 @@ func StartWebsocket(ctx context.Context, username, password string) { time.Sleep(10 * time.Second) continue } + if websocket.IsCloseError(err, websocket.CloseGoingAway) { + conn = nil + log.Info().Msg("email websocket server going away") + time.Sleep(60 * time.Second) + continue + } log.Error().Err(err).Msg("Error reading message") time.Sleep(10 * time.Second) continue