From 745ef00cd2c809061bfeed8910b853daa595127c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Miroslav=20=C5=A0ediv=C3=BD?= Date: Mon, 30 Nov 2020 19:13:17 +0100 Subject: [PATCH] update connected / disconnected events. --- internal/session/session.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/internal/session/session.go b/internal/session/session.go index cbf75e0d..37bcf469 100644 --- a/internal/session/session.go +++ b/internal/session/session.go @@ -40,6 +40,7 @@ func (session *SessionCtx) VerifySecret(secret string) bool { } func (session *SessionCtx) Connected() bool { + // TODO: Refactor. return session.websocket_connected && session.webrtc_connected } @@ -50,7 +51,10 @@ func (session *SessionCtx) SetWebSocketPeer(websocket_peer types.WebSocketPeer) func (session *SessionCtx) SetWebSocketConnected(connected bool) { if connected { session.websocket_connected = true - session.manager.emmiter.Emit("websocket_connected", session) + + // TODO: Refactor. + //session.manager.emmiter.Emit("websocket_connected", session) + session.manager.emmiter.Emit("connected", session) } else { session.websocket_connected = false @@ -69,10 +73,7 @@ func (session *SessionCtx) SetWebRTCPeer(webrtc_peer types.WebRTCPeer) { func (session *SessionCtx) SetWebRTCConnected(connected bool) { if connected { session.webrtc_connected = true - - // TODO: Refactor. - //session.manager.emmiter.Emit("webrtc_connected", session) - session.manager.emmiter.Emit("connected", session) + session.manager.emmiter.Emit("webrtc_connected", session) } else { session.webrtc_connected = false session.manager.emmiter.Emit("webrtc_disconnected", session)