iridium/neko
2
2
Fork 0
mirror of https://github.com/m1k1o/neko.git synced 2024-07-24 14:40:50 +12:00
Code Issues Packages Projects Releases Wiki Activity

update connected / disconnected events.

Browse Source
This commit is contained in:
Miroslav Šedivý 2020-11-30 19:13:17 +01:00
parent 753fb01955
commit 745ef00cd2
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
internal/session/session.go
View File

@ -40,6 +40,7 @@ func (session *SessionCtx) VerifySecret(secret string) bool {
} }
func (session *SessionCtx) Connected() bool { func (session *SessionCtx) Connected() bool {
// TODO: Refactor.
return session.websocket_connected && session.webrtc_connected 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) { func (session *SessionCtx) SetWebSocketConnected(connected bool) {
if connected { if connected {
session.websocket_connected = true 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 { } else {
session.websocket_connected = false session.websocket_connected = false
@ -69,10 +73,7 @@ func (session *SessionCtx) SetWebRTCPeer(webrtc_peer types.WebRTCPeer) {
func (session *SessionCtx) SetWebRTCConnected(connected bool) { func (session *SessionCtx) SetWebRTCConnected(connected bool) {
if connected { if connected {
session.webrtc_connected = true session.webrtc_connected = true
session.manager.emmiter.Emit("webrtc_connected", session)
// TODO: Refactor.
//session.manager.emmiter.Emit("webrtc_connected", session)
session.manager.emmiter.Emit("connected", session)
} else { } else {
session.webrtc_connected = false session.webrtc_connected = false
session.manager.emmiter.Emit("webrtc_disconnected", session) session.manager.emmiter.Emit("webrtc_disconnected", session)