mirrors/navidrome
1
0
Fork 0
mirror of https://github.com/navidrome/navidrome.git synced 2025-04-05 13:37:38 +03:00
Code Issues Projects Releases Packages Wiki Activity

Make ServerStart variable global

Browse source
This commit is contained in:
Deluan 2020-12-21 11:39:38 -05:00
parent 8c063c4f0c
commit cdae4347a6
2 changed files with 5 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

2
consts/consts.go
View file

@ -69,4 +69,6 @@ var (
VariousArtists = "Various Artists" VariousArtists = "Various Artists"
VariousArtistsID = fmt.Sprintf("%x", md5.Sum([]byte(strings.ToLower(VariousArtists)))) VariousArtistsID = fmt.Sprintf("%x", md5.Sum([]byte(strings.ToLower(VariousArtists))))
UnknownArtist = "[Unknown Artist]" UnknownArtist = "[Unknown Artist]"
ServerStart = time.Now()
) )

11
server/events/sse.go
View file

@ -10,6 +10,7 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"github.com/deluan/navidrome/consts"
"github.com/deluan/navidrome/log" "github.com/deluan/navidrome/log"
"github.com/deluan/navidrome/model/request" "github.com/deluan/navidrome/model/request"
"github.com/google/uuid" "github.com/google/uuid"
@ -186,7 +187,7 @@ func (b *broker) listen() {
log.Debug("Client added to event broker", "numClients", len(clients), "newClient", c.String()) log.Debug("Client added to event broker", "numClients", len(clients), "newClient", c.String())
// Send a serverStart event to new client // Send a serverStart event to new client
c.channel <- b.preparePackage(&ServerStart{serverStart}) c.channel <- b.preparePackage(&ServerStart{consts.ServerStart})
case c := <-b.unsubscribing: case c := <-b.unsubscribing:
// A client has detached and we want to // A client has detached and we want to
@ -200,7 +201,7 @@ func (b *broker) listen() {
// Send event to all connected clients // Send event to all connected clients
for c := range clients { for c := range clients {
log.Trace("Putting event on client's queue", "client", c.String(), "event", event) log.Trace("Putting event on client's queue", "client", c.String(), "event", event)
// Use non-blocking send. If cannot send, terminate the client's connection // Use non-blocking send. If cannot send, ignore the message
select { select {
case c.channel <- event: case c.channel <- event:
default: default:
@ -214,9 +215,3 @@ func (b *broker) listen() {
} }
} }
} }
var serverStart time.Time
func init() {
serverStart = time.Now()
}