Method retrieveAppQueues

pkg/unpackerr/apps.go:102–133

retrieveAppQueues polls all the starr app queues. At the same time. Then calls the check methods to scan their queue contents for changes.

(now time.Time)

// retrieveAppQueues polls all the starr app queues. At the same time.
// Then calls the check methods to scan their queue contents for changes.
func (u *Unpackerr) retrieveAppQueues(now time.Time) {
	wait := sync.WaitGroup{}
	wait.Add(len(u.Lidarr) + len(u.Radarr) + len(u.Readarr) + len(u.Sonarr) + len(u.Whisparr))
	// Run each app's getQueue method in a go routine as a waitgroup.
	for _, server := range u.Lidarr {
		u.workChan <- []func(){func() { u.getLidarrQueue(server, now) }, wait.Done}
	}

	for _, server := range u.Radarr {
		u.workChan <- []func(){func() { u.getRadarrQueue(server, now) }, wait.Done}
	}

	for _, server := range u.Readarr {
		u.workChan <- []func(){func() { u.getReadarrQueue(server, now) }, wait.Done}
	}

	for _, server := range u.Sonarr {
		u.workChan <- []func(){func() { u.getSonarrQueue(server, now) }, wait.Done}
	}

	for _, server := range u.Whisparr {
		u.workChan <- []func(){func() { u.getWhisparrQueue(server, now) }, wait.Done}
	}

	wait.Wait()
	// These are not thread safe because they call saveCompletedDownload.
	u.checkLidarrQueue(now)
	u.checkRadarrQueue(now)
	u.checkReadarrQueue(now)
	u.checkSonarrQueue(now)
	u.checkWhisparrQueue(now)
}

// validateApps is broken-out into this file to make adding new apps easier.
func (u *Unpackerr) validateApps() error {