09e1ba6f34
This also fixes an improperly written server deletion listener to look at the correct context cancelation. Theoretically this should help address the issues in pterodactyl/panel#3596 but I'm not really sure how that happens, and theres no steps for reproduction.
63 lines
1.2 KiB
Go
63 lines
1.2 KiB
Go
package server
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
|
|
"github.com/google/uuid"
|
|
)
|
|
|
|
type WebsocketBag struct {
|
|
mu sync.Mutex
|
|
conns map[uuid.UUID]*context.CancelFunc
|
|
}
|
|
|
|
// Websockets returns the websocket bag which contains all the currently open websocket connections
|
|
// for the server instance.
|
|
func (s *Server) Websockets() *WebsocketBag {
|
|
s.wsBagLocker.Lock()
|
|
defer s.wsBagLocker.Unlock()
|
|
|
|
if s.wsBag == nil {
|
|
s.wsBag = &WebsocketBag{}
|
|
}
|
|
|
|
return s.wsBag
|
|
}
|
|
|
|
// Push adds a new websocket connection to the end of the stack.
|
|
func (w *WebsocketBag) Push(u uuid.UUID, cancel *context.CancelFunc) {
|
|
w.mu.Lock()
|
|
defer w.mu.Unlock()
|
|
|
|
if w.conns == nil {
|
|
w.conns = make(map[uuid.UUID]*context.CancelFunc)
|
|
}
|
|
|
|
w.conns[u] = cancel
|
|
}
|
|
|
|
// Remove removes a connection from the stack.
|
|
func (w *WebsocketBag) Remove(u uuid.UUID) {
|
|
w.mu.Lock()
|
|
delete(w.conns, u)
|
|
w.mu.Unlock()
|
|
}
|
|
|
|
// CancelAll cancels all the stored cancel functions which has the effect of
|
|
// disconnecting every listening websocket for the server.
|
|
func (w *WebsocketBag) CancelAll() {
|
|
w.mu.Lock()
|
|
defer w.mu.Unlock()
|
|
|
|
if w.conns != nil {
|
|
for _, cancel := range w.conns {
|
|
c := *cancel
|
|
c()
|
|
}
|
|
}
|
|
|
|
// Reset the connections.
|
|
w.conns = make(map[uuid.UUID]*context.CancelFunc)
|
|
}
|