From c61f5f2835a1cb1f88b3c93fd48dc18e4569003f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Miroslav=20=C5=A0ediv=C3=BD?= Date: Thu, 3 Dec 2020 17:03:15 +0100 Subject: [PATCH] WebRTC + peer closed. --- internal/webrtc/manager.go | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/internal/webrtc/manager.go b/internal/webrtc/manager.go index 6641904b..e0346383 100644 --- a/internal/webrtc/manager.go +++ b/internal/webrtc/manager.go @@ -153,15 +153,18 @@ func (manager *WebRTCManagerCtx) CreatePeer(session types.Session) (string, bool connection.OnConnectionStateChange(func(state webrtc.PeerConnectionState) { switch state { - case webrtc.PeerConnectionStateDisconnected: - manager.logger.Info().Str("id", session.ID()).Msg("peer disconnected successfully") - session.SetWebRTCConnected(false) - case webrtc.PeerConnectionStateFailed: - manager.logger.Warn().Str("id", session.ID()).Msg("peer disconnected with error") - session.SetWebRTCConnected(false) case webrtc.PeerConnectionStateConnected: manager.logger.Info().Str("id", session.ID()).Msg("peer connected") session.SetWebRTCConnected(true) + case webrtc.PeerConnectionStateDisconnected: + manager.logger.Info().Str("id", session.ID()).Msg("peer disconnected") + session.SetWebRTCConnected(false) + case webrtc.PeerConnectionStateFailed: + manager.logger.Warn().Str("id", session.ID()).Msg("peer failed") + session.SetWebRTCConnected(false) + case webrtc.PeerConnectionStateClosed: + manager.logger.Warn().Str("id", session.ID()).Msg("peer closed") + session.SetWebRTCConnected(false) } })