Function buildFileMapFromTorrents

internal/services/orphanscan/service.go:1238–1296

(torrents []qbt.Torrent, filesByHash map[string]qbt.TorrentFiles)

}

func buildFileMapFromTorrents(torrents []qbt.Torrent, filesByHash map[string]qbt.TorrentFiles) (*buildFileMapResult, error) {
	tfm := NewTorrentFileMap()
	scanRoots := make(map[string]struct{})
	skippedRoots := make(map[string]struct{})
	stableMissingFiles := 0

	for i := range torrents {
		torrent := torrents[i]
		savePath := filepath.Clean(torrent.SavePath)
		hasAbsSavePath := savePath != "" && filepath.IsAbs(savePath)
		files, ok := filesByHash[canonicalizeHash(torrent.Hash)]
		hasFiles := ok && len(files) > 0

		if !hasFiles {
			if isTransientTorrentStateForOrphanScan(torrent.State) {
				if hasAbsSavePath {
					skippedRoots[savePath] = struct{}{}
				}
				continue
			}

			stableMissingFiles++
			continue
		}

		if !hasAbsSavePath {
			continue
		}

		scanRoots[savePath] = struct{}{}
		for _, f := range files {
			tfm.Add(normalizePath(filepath.Join(savePath, f.Name)))
		}

		// Auto TMM can update save_path to the category root without moving the
		// payload. content_path still reflects the real on-disk location.
		actualSavePath := actualSavePathFromContentPath(savePath, torrent.ContentPath, files)
		if actualSavePath != "" && actualSavePath != savePath {
			scanRoots[actualSavePath] = struct{}{}
			for _, f := range files {
				tfm.Add(normalizePath(filepath.Join(actualSavePath, f.Name)))
			}
		}
	}

	if stableMissingFiles > 0 {
		return nil, fmt.Errorf("%d stable torrents returned no files - partial data detected", stableMissingFiles)
	}

	skippedRootList := sortedRoots(skippedRoots)
	scanRootList := filterScanRootsCoveredBySkippedRoots(sortedRoots(scanRoots), skippedRootList)

	return &buildFileMapResult{
		fileMap:      tfm,
		scanRoots:    scanRootList,
		skippedRoots: skippedRootList,
		torrentCount: len(torrents),
	}, nil