Method checkFolderStats

pkg/unpackerr/folder.go:562–593

checkFolderStats runs at an interval to see if any folders need work done on them. This runs on an interval ticker in the main go routine.

(now time.Time)

// checkFolderStats runs at an interval to see if any folders need work done on them.
// This runs on an interval ticker in the main go routine.
func (u *Unpackerr) checkFolderStats(now time.Time) {
	for name, folder := range u.folders.Folders {
		switch elapsed := now.Sub(folder.updated); {
		case WAITING == folder.status && elapsed >= u.StartDelay.Duration:
			// The folder hasn't been written to in a while, extract it.
			u.extractTrackedItem(name, folder, now)
		case EXTRACTEDNOTHING == folder.status:
			// Wait until this item hasn't been touched for a while, so it doesn't re-queue.
			if now.Sub(folder.updated) > u.StartDelay.Duration {
				// Ignore "no compressed files" errors for folders.
				delete(u.Map, name)
				delete(u.folders.Folders, name)
			}
		case EXTRACTFAILED == folder.status && elapsed >= u.RetryDelay.Duration &&
			(u.MaxRetries == 0 || folder.retries < u.MaxRetries):
			u.Retries++
			folder.retries++
			folder.updated = now
			folder.status = WAITING
			u.Printf("[Folder] Re-starting Failed Extraction: %s (%d/%d, failed %v ago)",
				folder.config.Path, folder.retries, u.MaxRetries, elapsed.Round(time.Second))
		case EXTRACTFAILED == folder.status && folder.retries < u.MaxRetries:
			// This empty block is to avoid deleting an item that needs more retries.
		case folder.status > EXTRACTING && folder.config.DeleteAfter.Duration <= 0:
			// if DeleteAfter is 0 we don't delete anything. we are done.
			u.updateQueueStatus(&newStatus{Name: name, Status: DELETED, Resp: nil}, now, false)
			delete(u.folders.Folders, name)
		case EXTRACTED == folder.status && elapsed >= folder.config.DeleteAfter.Duration:
			u.deleteAfterReached(name, now, folder)
		}
	}
}

//nolint:wsl
func (u *Unpackerr) deleteAfterReached(name string, now time.Time, folder *Folder) {