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 ILibraryManager _libraryManager; /// /// The _user manager /// private readonly IUserManager _userManager; /// /// The _logger /// private readonly ILogger _logger; public GameGenresValidator(ILibraryManager 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 userLibraries = _userManager.Users .Select(i => new Tuple>(i.Id, i.RootFolder.GetRecursiveChildren(i).OfType().ToList())) .ToList(); 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 count = masterDictionary.Count; numComplete = 0; foreach (var name in masterDictionary.Keys) { try { await UpdateItemByNameCounts(name, cancellationToken, masterDictionary[name]).ConfigureAwait(false); } catch (OperationCanceledException) { // Don't clutter the log break; } catch (Exception ex) { _logger.ErrorException("Error updating counts for {0}", ex, name); } numComplete++; double percent = numComplete; percent /= count; percent *= 90; progress.Report(percent + 10); } progress.Report(100); } private async Task UpdateItemByNameCounts(string name, CancellationToken cancellationToken, Dictionary> counts) { var itemByName = _libraryManager.GetGameGenre(name); foreach (var libraryId in counts.Keys) { var itemCounts = CountHelpers.GetCounts(counts[libraryId]); itemByName.SetItemByNameCounts(libraryId, itemCounts); } await itemByName.RefreshMetadata(cancellationToken).ConfigureAwait(false); } 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); } } } }