Method checkExtractDone

pkg/unpackerr/handlers.go:176–213

checkExtractDone checks if an extracted and imported item needs to be deleted. Or if an extraction failed and needs to be restarted. This runs at a short interval to check for extraction state changes, and should return quickly. nolint:cyclop,wsl

(now time.Time)

//
//nolint:cyclop,wsl
func (u *Unpackerr) checkExtractDone(now time.Time) {
	for name, item := range u.Map {
		switch elapsed := now.Sub(item.Updated); {
		case item.Status == DELETED && elapsed >= item.DeleteDelay:
			// Remove the item from history some time after it's deleted.
			u.Finished++
			delete(u.Map, name)
			u.Printf("[%s] Finished, Removed History: %v", item.App, name)
		case item.App == FolderString:
			continue // folders are handled in folder.go.
		case item.Status == EXTRACTFAILED && elapsed >= u.RetryDelay.Duration &&
			(u.MaxRetries == 0 || item.Retries < u.MaxRetries):
			u.Retries++
			item.Retries++
			item.Status = WAITING
			item.Updated = now
			u.Printf("[%s] Extract failed %v ago, triggering restart (%d/%d): %v",
				item.App, elapsed.Round(time.Second), item.Retries, u.MaxRetries, name)
		case item.Status == IMPORTED && elapsed >= item.DeleteDelay:
			var webhook bool

			if item.DeleteOrig {
				u.delChan <- &fileDeleteReq{Paths: []string{item.Path}}
				webhook = true
			} else if item.Resp != nil && len(item.Resp.NewFiles) > 0 && item.DeleteDelay >= 0 {
				// Delete extracted files and purge empty parents up to and including the download path.
				u.delChan <- &fileDeleteReq{
					Paths:            item.Resp.NewFiles,
					PurgeEmptyParent: true,
					PurgeEmptyRoot:   item.Path,
				}
				webhook = true
			}

			u.updateQueueStatus(&newStatus{Name: name, Status: DELETED, Resp: item.Resp}, now, webhook)
		}
	}
}

// handleXtractrCallback handles callbacks from the xtractr library for starr apps (not folders).
// This takes the provided info and logs it then sends it the queue update method.