[eventsub] Suppress error on abnormal closure and reconnect

Signed-off-by: Knut Ahlers <knut@ahlers.me>
This commit is contained in:
Knut Ahlers 2024-03-23 12:03:39 +01:00
parent 031ad331e4
commit c3085ea7f9
Signed by: luzifer
SSH key fingerprint: SHA256:/xtE5lCgiRDQr8SLxHMS92ZBlACmATUmF1crK16Ks4E

View file

@ -385,6 +385,10 @@ func (e *EventSubSocketClient) handleSocketError(err error, msgC chan eventSubSo
e.logger.Debug("websocket was closed normally") e.logger.Debug("websocket was closed normally")
return nil return nil
case websocket.CloseAbnormalClosure:
e.logger.Warn("websocket reported abnormal closure")
return errors.Wrap(e.connect(e.socketDest, msgC, errC, "network-error"), "re-connecting after abnormal closure")
default: default:
// Some non-twitch close code we did not expect // Some non-twitch close code we did not expect
e.logger.WithError(closeErr).Error("websocket reported unexpected error code") e.logger.WithError(closeErr).Error("websocket reported unexpected error code")