neko/internal/session/manager.go

229 lines
5.0 KiB
Go
Raw Normal View History

package session
import (
2020-11-15 10:54:35 +13:00
"sync"
"github.com/kataras/go-events"
"github.com/rs/zerolog"
"github.com/rs/zerolog/log"
2020-10-29 07:15:48 +13:00
"demodesk/neko/internal/types"
2020-11-02 06:39:12 +13:00
"demodesk/neko/internal/config"
2020-10-29 07:15:48 +13:00
"demodesk/neko/internal/utils"
)
2020-11-02 06:39:12 +13:00
func New(capture types.CaptureManager, config *config.Session) *SessionManagerCtx {
2020-11-02 04:09:48 +13:00
return &SessionManagerCtx{
2020-11-15 11:05:09 +13:00
logger: log.With().Str("module", "session").Logger(),
host: nil,
hostMu: sync.Mutex{},
capture: capture,
config: config,
members: make(map[string]*SessionCtx),
membersMu: sync.Mutex{},
emmiter: events.New(),
}
}
2020-11-02 04:09:48 +13:00
type SessionManagerCtx struct {
2020-11-15 11:05:09 +13:00
logger zerolog.Logger
host types.Session
hostMu sync.Mutex
capture types.CaptureManager
config *config.Session
members map[string]*SessionCtx
membersMu sync.Mutex
emmiter events.EventEmmiter
}
2020-11-02 08:23:09 +13:00
func (manager *SessionManagerCtx) New(id string, admin bool) types.Session {
2020-11-15 11:05:09 +13:00
manager.membersMu.Lock()
defer manager.membersMu.Unlock()
2020-11-02 04:09:48 +13:00
session := &SessionCtx{
id: id,
admin: admin,
manager: manager,
logger: manager.logger.With().Str("id", id).Logger(),
connected: false,
}
manager.members[id] = session
return session
}
2020-11-02 04:09:48 +13:00
func (manager *SessionManagerCtx) Get(id string) (types.Session, bool) {
2020-11-15 11:05:09 +13:00
manager.membersMu.Lock()
defer manager.membersMu.Unlock()
2020-11-02 04:09:48 +13:00
session, ok := manager.members[id]
return session, ok
}
func (manager *SessionManagerCtx) Destroy(id string) error {
2020-11-15 11:05:09 +13:00
manager.membersMu.Lock()
defer manager.membersMu.Unlock()
2020-11-02 04:09:48 +13:00
session, ok := manager.members[id]
if ok {
delete(manager.members, id)
2020-11-02 08:53:25 +13:00
return session.destroy()
2020-11-02 04:09:48 +13:00
}
return nil
}
// ---
// host
// ---
func (manager *SessionManagerCtx) HasHost() bool {
2020-11-15 10:54:35 +13:00
manager.hostMu.Lock()
defer manager.hostMu.Unlock()
return manager.host != nil
}
2020-11-02 04:09:48 +13:00
func (manager *SessionManagerCtx) SetHost(host types.Session) {
2020-11-15 10:54:35 +13:00
manager.hostMu.Lock()
defer manager.hostMu.Unlock()
manager.host = host
manager.emmiter.Emit("host", host)
}
2020-11-02 04:09:48 +13:00
func (manager *SessionManagerCtx) GetHost() types.Session {
2020-11-15 10:54:35 +13:00
manager.hostMu.Lock()
defer manager.hostMu.Unlock()
return manager.host
}
2020-11-02 04:09:48 +13:00
func (manager *SessionManagerCtx) ClearHost() {
2020-11-15 10:54:35 +13:00
manager.hostMu.Lock()
defer manager.hostMu.Unlock()
host := manager.host
manager.host = nil
manager.emmiter.Emit("host_cleared", host)
}
2020-11-02 04:09:48 +13:00
// ---
// members list
// ---
func (manager *SessionManagerCtx) Admins() []types.Session {
2020-11-15 11:05:09 +13:00
manager.membersMu.Lock()
defer manager.membersMu.Unlock()
2020-11-02 04:09:48 +13:00
var sessions []types.Session
for _, session := range manager.members {
if !session.connected || !session.admin {
continue
}
2020-11-02 04:09:48 +13:00
sessions = append(sessions, session)
}
2020-11-02 04:09:48 +13:00
return sessions
}
2020-11-02 04:09:48 +13:00
func (manager *SessionManagerCtx) Members() []types.Session {
2020-11-15 11:05:09 +13:00
manager.membersMu.Lock()
defer manager.membersMu.Unlock()
2020-11-02 04:09:48 +13:00
var sessions []types.Session
for _, session := range manager.members {
if !session.connected {
continue
}
2020-11-02 04:09:48 +13:00
sessions = append(sessions, session)
}
2020-11-02 04:09:48 +13:00
return sessions
}
2020-11-19 08:30:33 +13:00
func (manager *SessionManagerCtx) Broadcast(v interface{}, exclude interface{}) {
2020-11-15 11:05:09 +13:00
manager.membersMu.Lock()
defer manager.membersMu.Unlock()
for id, session := range manager.members {
if !session.connected {
continue
}
if exclude != nil {
if in, _ := utils.ArrayIn(id, exclude); in {
continue
}
}
if err := session.Send(v); err != nil {
2020-11-19 08:30:33 +13:00
manager.logger.Warn().Err(err).Msgf("broadcasting event has failed")
}
}
}
func (manager *SessionManagerCtx) AdminBroadcast(v interface{}, exclude interface{}) {
manager.membersMu.Lock()
defer manager.membersMu.Unlock()
for id, session := range manager.members {
if !session.connected || !session.Admin() {
continue
}
if exclude != nil {
if in, _ := utils.ArrayIn(id, exclude); in {
continue
}
}
if err := session.Send(v); err != nil {
manager.logger.Warn().Err(err).Msgf("broadcasting admin event has failed")
}
}
}
2020-11-02 04:09:48 +13:00
// ---
// events
// ---
func (manager *SessionManagerCtx) OnHost(listener func(session types.Session)) {
manager.emmiter.On("host", func(payload ...interface{}) {
2020-11-02 04:09:48 +13:00
listener(payload[0].(*SessionCtx))
})
}
2020-11-02 04:09:48 +13:00
func (manager *SessionManagerCtx) OnHostCleared(listener func(session types.Session)) {
manager.emmiter.On("host_cleared", func(payload ...interface{}) {
2020-11-02 04:09:48 +13:00
listener(payload[0].(*SessionCtx))
})
}
2020-11-02 04:09:48 +13:00
func (manager *SessionManagerCtx) OnCreated(listener func(session types.Session)) {
manager.emmiter.On("created", func(payload ...interface{}) {
2020-11-02 08:23:09 +13:00
// Start streaming, when first joins
if !manager.capture.Streaming() {
manager.capture.StartStream()
}
2020-11-02 04:09:48 +13:00
listener(payload[0].(*SessionCtx))
})
}
2020-11-02 04:09:48 +13:00
func (manager *SessionManagerCtx) OnConnected(listener func(session types.Session)) {
manager.emmiter.On("connected", func(payload ...interface{}) {
2020-11-02 04:09:48 +13:00
listener(payload[0].(*SessionCtx))
})
}
2020-11-02 08:53:25 +13:00
func (manager *SessionManagerCtx) OnDisconnected(listener func(session types.Session)) {
manager.emmiter.On("disconnected", func(payload ...interface{}) {
// Stop streaming, if everyone left
2020-11-02 09:03:25 +13:00
if manager.capture.Streaming() && len(manager.Members()) == 0 {
2020-11-02 08:53:25 +13:00
manager.capture.StopStream()
}
listener(payload[0].(*SessionCtx))
})
}