Simplify package names

[broadcaster] / server / status.go

diff --git a/server/status.go b/server/status.go
new file mode 100644 (file)
index 0000000..b2edd49
--- /dev/null
+++ b/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
+}