getReadarrQueue saves the Readarr Queue(s).
(server *ReadarrConfig, start time.Time)
| 55 | |
| 56 | // getReadarrQueue saves the Readarr Queue(s). |
| 57 | func (u *Unpackerr) getReadarrQueue(server *ReadarrConfig, start time.Time) { |
| 58 | if server.APIKey == "" { |
| 59 | u.Debugf("Readarr (%s): skipped, no API key", server.URL) |
| 60 | return |
| 61 | } |
| 62 | |
| 63 | queue, err := server.GetQueue(DefaultQueuePageSize, DefaultQueuePageSize) |
| 64 | if err != nil { |
| 65 | u.saveQueueMetrics(0, start, starr.Readarr, server.URL, err) |
| 66 | return |
| 67 | } |
| 68 | |
| 69 | // Only update if there was not an error fetching. |
| 70 | server.Queue = queue |
| 71 | u.saveQueueMetrics(server.Queue.TotalRecords, start, starr.Readarr, server.URL, nil) |
| 72 | |
| 73 | if !u.Activity || queue.TotalRecords > 0 { |
| 74 | u.Printf("[Readarr] Updated (%s): %d Items Queued, %d Retrieved", server.URL, queue.TotalRecords, len(queue.Records)) |
| 75 | } |
| 76 | } |
| 77 | |
| 78 | // checkReadarQueue saves completed Readarr-queued downloads to u.Map. |
| 79 | func (u *Unpackerr) checkReadarrQueue(now time.Time) { |
no test coverage detected