using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Library; using MediaBrowser.Model.Logging; using System; using System.Collections.Generic; using System.Linq; using System.Threading; using System.Threading.Tasks; namespace MediaBrowser.Server.Implementations.Library.Validators { class GameGenresValidator { /// /// The _library manager /// private readonly LibraryManager _libraryManager; /// /// The _user manager /// private readonly IUserManager _userManager; /// /// The _logger /// private readonly ILogger _logger; public GameGenresValidator(LibraryManager libraryManager, IUserManager userManager, ILogger logger) { _libraryManager = libraryManager; _userManager = userManager; _logger = logger; } /// /// Runs the specified progress. /// /// The progress. /// The cancellation token. /// Task. public async Task Run(IProgress progress, CancellationToken cancellationToken) { var allItems = _libraryManager.RootFolder.RecursiveChildren.OfType().ToList(); var userLibraries = _userManager.Users .Select(i => new Tuple>(i.Id, i.RootFolder.GetRecursiveChildren(i).OfType().ToList())) .ToList(); var allLibraryItems = allItems; var masterDictionary = new Dictionary>>(StringComparer.OrdinalIgnoreCase); // Populate counts of items SetItemCounts(null, allLibraryItems, masterDictionary); progress.Report(2); var numComplete = 0; foreach (var lib in userLibraries) { SetItemCounts(lib.Item1, lib.Item2, masterDictionary); numComplete++; double percent = numComplete; percent /= userLibraries.Count; percent *= 8; progress.Report(percent); } progress.Report(10); var names = masterDictionary.Keys.ToList(); numComplete = 0; foreach (var name in names) { try { await UpdateItemByNameCounts(name, cancellationToken, masterDictionary[name]).ConfigureAwait(false); } catch (Exception ex) { _logger.ErrorException("Error updating counts for {0}", ex, name); } numComplete++; double percent = numComplete; percent /= names.Count; percent *= 90; progress.Report(percent + 10); } progress.Report(100); } private async Task UpdateItemByNameCounts(string name, CancellationToken cancellationToken, Dictionary> counts) { var itemByName = await _libraryManager.GetGameGenre(name, cancellationToken, true, true).ConfigureAwait(false); foreach (var libraryId in counts.Keys.ToList()) { var itemCounts = CountHelpers.GetCounts(counts[libraryId]); if (libraryId == Guid.Empty) { itemByName.ItemCounts = itemCounts; } else { itemByName.UserItemCounts[libraryId] = itemCounts; } } } private void SetItemCounts(Guid? userId, IEnumerable allItems, Dictionary>> masterDictionary) { foreach (var media in allItems) { var names = media .Genres .Distinct(StringComparer.OrdinalIgnoreCase) .ToList(); CountHelpers.SetItemCounts(userId, media, names, masterDictionary); } } } }