Track addition errors will now be logged, added empty queue retry
This commit is contained in:
parent
044e7ffd68
commit
c9111f8e8c
4
api.go
4
api.go
|
@ -214,6 +214,8 @@ func (a *API) listen() {
|
||||||
if err = a.queue.AddTrack(e, false); err == nil {
|
if err = a.queue.AddTrack(e, false); err == nil {
|
||||||
result.Success = true
|
result.Success = true
|
||||||
result.QueueId = e.QueueIdentifier
|
result.QueueId = e.QueueIdentifier
|
||||||
|
} else {
|
||||||
|
log.Printf("track addition error: \"%s\"", err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -242,6 +244,8 @@ func (a *API) listen() {
|
||||||
if err = a.queue.AddTrack(e, true); err == nil {
|
if err = a.queue.AddTrack(e, true); err == nil {
|
||||||
result.Success = true
|
result.Success = true
|
||||||
result.QueueId = e.QueueIdentifier
|
result.QueueId = e.QueueIdentifier
|
||||||
|
} else {
|
||||||
|
log.Printf("track addition error: \"%s\"", err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
9
queue.go
9
queue.go
|
@ -277,7 +277,14 @@ func (q *Queue) AddTrack(entry *QueueTrackEntry, tail bool) error {
|
||||||
|
|
||||||
func (q *Queue) HandleQueue() {
|
func (q *Queue) HandleQueue() {
|
||||||
if q.audioQueue.GetQueueSize() == 0 {
|
if q.audioQueue.GetQueueSize() == 0 {
|
||||||
q.AddTrack(<-q.QueueEmpty, true)
|
if err := q.AddTrack(<-q.QueueEmpty, true); err != nil {
|
||||||
|
log.Printf("track addition error: \"%s\"", err)
|
||||||
|
|
||||||
|
//TODO: maybe fail after n tries
|
||||||
|
time.Sleep(time.Second)
|
||||||
|
|
||||||
|
q.HandleQueue()
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue