X-Git-Url: https://code.octet-stream.net/broadcaster/blobdiff_plain/8320951221d45c5f5f3d387c5cb4b97d9fa2094c..33a19d553807d171f6ba9f4dafe30f43bc4bab5e:/broadcaster-server/status.go

diff --git a/broadcaster-server/status.go b/broadcaster-server/status.go
new file mode 100644
index 0000000..b2edd49
--- /dev/null
+++ b/broadcaster-server/status.go
@@ -0,0 +1,54 @@
+package main
+
+import (
+	"code.octet-stream.net/broadcaster/internal/protocol"
+	"sync"
+)
+
+type ServerStatus struct {
+	statuses      map[int]protocol.StatusMessage
+	statusesMutex sync.Mutex
+	changeWait    chan bool
+}
+
+var status ServerStatus
+
+func InitServerStatus() {
+	status = ServerStatus{
+		statuses:   make(map[int]protocol.StatusMessage),
+		changeWait: make(chan bool),
+	}
+}
+
+func (s *ServerStatus) MergeStatus(radioId int, status protocol.StatusMessage) {
+	s.statusesMutex.Lock()
+	defer s.statusesMutex.Unlock()
+	s.statuses[radioId] = status
+	s.TriggerChange()
+}
+
+func (s *ServerStatus) RadioDisconnected(radioId int) {
+	s.statusesMutex.Lock()
+	defer s.statusesMutex.Unlock()
+	delete(s.statuses, radioId)
+	s.TriggerChange()
+}
+
+func (s *ServerStatus) TriggerChange() {
+	close(s.changeWait)
+	s.changeWait = make(chan bool)
+}
+
+func (s *ServerStatus) Statuses() map[int]protocol.StatusMessage {
+	s.statusesMutex.Lock()
+	defer s.statusesMutex.Unlock()
+	c := make(map[int]protocol.StatusMessage)
+	for k, v := range s.statuses {
+		c[k] = v
+	}
+	return c
+}
+
+func (s *ServerStatus) ChangeChannel() chan bool {
+	return s.changeWait
+}