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

inactiveCursors to own func.

Browse Source
This commit is contained in:
Miroslav Šedivý 2021-11-03 23:52:44 +01:00
parent 437eb44003
commit 6b77f54b8c
1 changed files with 45 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

86
internal/websocket/manager.go
View File

@ -136,47 +136,7 @@ func (manager *WebSocketManagerCtx) Start() {
manager.fileChooserDialogEvents()
if manager.sessions.InactiveCursors() {
manager.logger.Info().Msg("starting inactive cursors handler")
manager.wg.Add(1)
go func() {
defer manager.wg.Done()
ticker := time.NewTicker(inactiveCursorsPeriod)
defer ticker.Stop()
lastEmpty := false
for {
select {
case <-manager.shutdown:
manager.logger.Info().Msg("stopping inactive cursors handler")
return
case <-ticker.C:
cursorsMap := manager.sessions.PopCursors()
length := len(cursorsMap)
if length == 0 && lastEmpty {
continue
}
lastEmpty = length == 0
cursors := []message.SessionCursor{}
for session, cursor := range cursorsMap {
cursors = append(
cursors,
message.SessionCursor{
ID: session.ID(),
X: uint16(cursor.X),
Y: uint16(cursor.Y),
},
)
}
manager.sessions.InactiveCursorsBroadcast(event.SESSION_CURSORS, cursors, nil)
}
}
}()
manager.inactiveCursors()
}
manager.logger.Info().Msg("websocket starting")
@ -338,3 +298,47 @@ func (manager *WebSocketManagerCtx) handle(connection *websocket.Conn, peer type
}
}
}
func (manager *WebSocketManagerCtx) inactiveCursors() {
manager.logger.Info().Msg("starting inactive cursors handler")
manager.wg.Add(1)
go func() {
defer manager.wg.Done()
ticker := time.NewTicker(inactiveCursorsPeriod)
defer ticker.Stop()
lastEmpty := false
for {
select {
case <-manager.shutdown:
manager.logger.Info().Msg("stopping inactive cursors handler")
return
case <-ticker.C:
cursorsMap := manager.sessions.PopCursors()
length := len(cursorsMap)
if length == 0 && lastEmpty {
continue
}
lastEmpty = length == 0
cursors := []message.SessionCursor{}
for session, cursor := range cursorsMap {
cursors = append(
cursors,
message.SessionCursor{
ID: session.ID(),
X: uint16(cursor.X),
Y: uint16(cursor.Y),
},
)
}
manager.sessions.InactiveCursorsBroadcast(event.SESSION_CURSORS, cursors, nil)
}
}
}()
}