using MediaBrowser.Common.Progress; using MediaBrowser.Controller.Library; using MediaBrowser.Controller.Providers; using MediaBrowser.Model.Dto; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Querying; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Threading; using System.Threading.Tasks; using MediaBrowser.Controller.Channels; using MediaBrowser.Controller.Dto; using MediaBrowser.Controller.Entities.Audio; using MediaBrowser.Controller.Entities.Movies; using MediaBrowser.Controller.Entities.TV; using MediaBrowser.Controller.IO; using MediaBrowser.Model.Channels; using MediaBrowser.Model.IO; using MediaBrowser.Model.Serialization; namespace MediaBrowser.Controller.Entities { /// /// Class Folder /// public class Folder : BaseItem { public static IUserManager UserManager { get; set; } public static IUserViewManager UserViewManager { get; set; } /// /// Gets or sets a value indicating whether this instance is root. /// /// true if this instance is root; otherwise, false. public bool IsRoot { get; set; } public virtual List LinkedChildren { get; set; } [IgnoreDataMember] public DateTime? DateLastMediaAdded { get; set; } public Folder() { LinkedChildren = new List(); } [IgnoreDataMember] public override bool SupportsThemeMedia { get { return true; } } [IgnoreDataMember] public virtual bool IsPreSorted { get { return false; } } [IgnoreDataMember] public virtual bool IsPhysicalRoot { get { return false; } } [IgnoreDataMember] public override bool SupportsInheritedParentImages { get { return true; } } [IgnoreDataMember] public override bool SupportsPlayedStatus { get { return true; } } /// /// Gets a value indicating whether this instance is folder. /// /// true if this instance is folder; otherwise, false. [IgnoreDataMember] public override bool IsFolder { get { return true; } } [IgnoreDataMember] public override bool IsDisplayedAsFolder { get { return true; } } [IgnoreDataMember] public virtual bool SupportsCumulativeRunTimeTicks { get { return false; } } [IgnoreDataMember] public virtual bool SupportsDateLastMediaAdded { get { return false; } } public override bool CanDelete() { if (IsRoot) { return false; } return base.CanDelete(); } public override bool RequiresRefresh() { var baseResult = base.RequiresRefresh(); if (SupportsCumulativeRunTimeTicks && !RunTimeTicks.HasValue) { baseResult = true; } return baseResult; } [IgnoreDataMember] public override string FileNameWithoutExtension { get { if (LocationType == LocationType.FileSystem) { return System.IO.Path.GetFileName(Path); } return null; } } protected override bool IsAllowTagFilterEnforced() { if (this is ICollectionFolder) { return false; } if (this is UserView) { return false; } return true; } [IgnoreDataMember] protected virtual bool SupportsShortcutChildren { get { return false; } } /// /// Adds the child. /// /// The item. /// The cancellation token. /// Task. /// Unable to add + item.Name public async Task AddChild(BaseItem item, CancellationToken cancellationToken) { item.SetParent(this); if (item.Id == Guid.Empty) { item.Id = LibraryManager.GetNewItemId(item.Path, item.GetType()); } if (Children.Any(i => i.Id == item.Id)) { throw new ArgumentException(string.Format("A child with the Id {0} already exists.", item.Id)); } if (item.DateCreated == DateTime.MinValue) { item.DateCreated = DateTime.UtcNow; } if (item.DateModified == DateTime.MinValue) { item.DateModified = DateTime.UtcNow; } await LibraryManager.CreateItem(item, cancellationToken).ConfigureAwait(false); } /// /// Removes the child. /// /// The item. public void RemoveChild(BaseItem item) { item.SetParent(null); } /// /// Gets the actual children. /// /// The actual children. [IgnoreDataMember] public virtual IEnumerable Children { get { return LoadChildren(); } } /// /// thread-safe access to all recursive children of this folder - without regard to user /// /// The recursive children. [IgnoreDataMember] public IEnumerable RecursiveChildren { get { return GetRecursiveChildren(); } } public override bool IsVisible(User user) { if (this is ICollectionFolder && !(this is BasePluginFolder)) { if (user.Policy.BlockedMediaFolders != null) { if (user.Policy.BlockedMediaFolders.Contains(Id.ToString("N"), StringComparer.OrdinalIgnoreCase) || // Backwards compatibility user.Policy.BlockedMediaFolders.Contains(Name, StringComparer.OrdinalIgnoreCase)) { return false; } } else { if (!user.Policy.EnableAllFolders && !user.Policy.EnabledFolders.Contains(Id.ToString("N"), StringComparer.OrdinalIgnoreCase)) { return false; } } } return base.IsVisible(user); } /// /// Loads our children. Validation will occur externally. /// We want this sychronous. /// protected virtual List LoadChildren() { //Logger.Debug("Loading children from {0} {1} {2}", GetType().Name, Id, Path); //just load our children from the repo - the library will be validated and maintained in other processes return GetCachedChildren(); } public override double? GetRefreshProgress() { return ProviderManager.GetRefreshProgress(Id); } public Task ValidateChildren(IProgress progress, CancellationToken cancellationToken) { return ValidateChildren(progress, cancellationToken, new MetadataRefreshOptions(new DirectoryService(Logger, FileSystem))); } /// /// Validates that the children of the folder still exist /// /// The progress. /// The cancellation token. /// The metadata refresh options. /// if set to true [recursive]. /// Task. public Task ValidateChildren(IProgress progress, CancellationToken cancellationToken, MetadataRefreshOptions metadataRefreshOptions, bool recursive = true) { return ValidateChildrenInternal(progress, cancellationToken, recursive, true, metadataRefreshOptions, metadataRefreshOptions.DirectoryService); } private Dictionary GetActualChildrenDictionary() { var dictionary = new Dictionary(); var childrenList = Children.ToList(); foreach (var child in childrenList) { var id = child.Id; if (dictionary.ContainsKey(id)) { Logger.Error("Found folder containing items with duplicate id. Path: {0}, Child Name: {1}", Path ?? Name, child.Path ?? child.Name); } else { dictionary[id] = child; } } return dictionary; } private bool IsValidFromResolver(BaseItem current, BaseItem newItem) { return current.IsValidFromResolver(newItem); } protected override void TriggerOnRefreshStart() { } protected override void TriggerOnRefreshComplete() { } /// /// Validates the children internal. /// /// The progress. /// The cancellation token. /// if set to true [recursive]. /// if set to true [refresh child metadata]. /// The refresh options. /// The directory service. /// Task. protected virtual async Task ValidateChildrenInternal(IProgress progress, CancellationToken cancellationToken, bool recursive, bool refreshChildMetadata, MetadataRefreshOptions refreshOptions, IDirectoryService directoryService) { if (recursive) { ProviderManager.OnRefreshStart(this); } try { await ValidateChildrenInternal2(progress, cancellationToken, recursive, refreshChildMetadata, refreshOptions, directoryService).ConfigureAwait(false); } finally { if (recursive) { ProviderManager.OnRefreshComplete(this); } } } private async Task ValidateChildrenInternal2(IProgress progress, CancellationToken cancellationToken, bool recursive, bool refreshChildMetadata, MetadataRefreshOptions refreshOptions, IDirectoryService directoryService) { var locationType = LocationType; cancellationToken.ThrowIfCancellationRequested(); var validChildren = new List(); var allLibraryPaths = LibraryManager .GetVirtualFolders() .SelectMany(i => i.Locations) .ToList(); if (locationType != LocationType.Remote && locationType != LocationType.Virtual) { IEnumerable nonCachedChildren; try { nonCachedChildren = GetNonCachedChildren(directoryService); } catch (IOException ex) { nonCachedChildren = new BaseItem[] { }; Logger.ErrorException("Error getting file system entries for {0}", ex, Path); } if (nonCachedChildren == null) return; //nothing to validate progress.Report(5); if (recursive) { ProviderManager.OnRefreshProgress(this, 5); } //build a dictionary of the current children we have now by Id so we can compare quickly and easily var currentChildren = GetActualChildrenDictionary(); //create a list for our validated children var newItems = new List(); cancellationToken.ThrowIfCancellationRequested(); foreach (var child in nonCachedChildren) { BaseItem currentChild; if (currentChildren.TryGetValue(child.Id, out currentChild) && IsValidFromResolver(currentChild, child)) { validChildren.Add(currentChild); continue; } // Brand new item - needs to be added child.SetParent(this); newItems.Add(child); validChildren.Add(child); } // If any items were added or removed.... if (newItems.Count > 0 || currentChildren.Count != validChildren.Count) { // That's all the new and changed ones - now see if there are any that are missing var itemsRemoved = currentChildren.Values.Except(validChildren).ToList(); var actualRemovals = new List(); foreach (var item in itemsRemoved) { var itemLocationType = item.LocationType; if (itemLocationType == LocationType.Virtual || itemLocationType == LocationType.Remote) { } else if (!string.IsNullOrEmpty(item.Path) && IsPathOffline(item.Path, allLibraryPaths)) { } else { actualRemovals.Add(item); } } if (actualRemovals.Count > 0) { foreach (var item in actualRemovals) { Logger.Debug("Removed item: " + item.Path); item.SetParent(null); await LibraryManager.DeleteItem(item, new DeleteOptions { DeleteFileLocation = false }).ConfigureAwait(false); LibraryManager.ReportItemRemoved(item); } } await LibraryManager.CreateItems(newItems, cancellationToken).ConfigureAwait(false); } } else { if (recursive || refreshChildMetadata) { // used below validChildren = Children.ToList(); } } progress.Report(10); if (recursive) { ProviderManager.OnRefreshProgress(this, 10); } cancellationToken.ThrowIfCancellationRequested(); if (recursive) { using (var innerProgress = new ActionableProgress()) { var folder = this; innerProgress.RegisterAction(p => { double newPct = .80 * p + 10; progress.Report(newPct); ProviderManager.OnRefreshProgress(folder, newPct); }); await ValidateSubFolders(validChildren.OfType().ToList(), directoryService, innerProgress, cancellationToken).ConfigureAwait(false); } } if (refreshChildMetadata) { progress.Report(90); if (recursive) { ProviderManager.OnRefreshProgress(this, 90); } var container = this as IMetadataContainer; using (var innerProgress = new ActionableProgress()) { var folder = this; innerProgress.RegisterAction(p => { double newPct = .10 * p + 90; progress.Report(newPct); if (recursive) { ProviderManager.OnRefreshProgress(folder, newPct); } }); if (container != null) { await container.RefreshAllMetadata(refreshOptions, innerProgress, cancellationToken).ConfigureAwait(false); } else { await RefreshMetadataRecursive(validChildren, refreshOptions, recursive, innerProgress, cancellationToken); } } } } private async Task RefreshMetadataRecursive(List children, MetadataRefreshOptions refreshOptions, bool recursive, IProgress progress, CancellationToken cancellationToken) { var numComplete = 0; var count = children.Count; double currentPercent = 0; foreach (var child in children) { cancellationToken.ThrowIfCancellationRequested(); using (var innerProgress = new ActionableProgress()) { // Avoid implicitly captured closure var currentInnerPercent = currentPercent; innerProgress.RegisterAction(p => { double innerPercent = currentInnerPercent; innerPercent += p / (count); progress.Report(innerPercent); }); await RefreshChildMetadata(child, refreshOptions, recursive && child.IsFolder, innerProgress, cancellationToken) .ConfigureAwait(false); } numComplete++; double percent = numComplete; percent /= count; percent *= 100; currentPercent = percent; progress.Report(percent); } } private async Task RefreshChildMetadata(BaseItem child, MetadataRefreshOptions refreshOptions, bool recursive, IProgress progress, CancellationToken cancellationToken) { var container = child as IMetadataContainer; if (container != null) { await container.RefreshAllMetadata(refreshOptions, progress, cancellationToken).ConfigureAwait(false); } else { await child.RefreshMetadata(refreshOptions, cancellationToken).ConfigureAwait(false); if (recursive) { var folder = child as Folder; if (folder != null) { await folder.RefreshMetadataRecursive(folder.Children.ToList(), refreshOptions, true, progress, cancellationToken); } } } } /// /// Refreshes the children. /// /// The children. /// The directory service. /// The progress. /// The cancellation token. /// Task. private async Task ValidateSubFolders(IList children, IDirectoryService directoryService, IProgress progress, CancellationToken cancellationToken) { var numComplete = 0; var count = children.Count; double currentPercent = 0; foreach (var child in children) { cancellationToken.ThrowIfCancellationRequested(); using (var innerProgress = new ActionableProgress()) { // Avoid implicitly captured closure var currentInnerPercent = currentPercent; innerProgress.RegisterAction(p => { double innerPercent = currentInnerPercent; innerPercent += p / (count); progress.Report(innerPercent); }); await child.ValidateChildrenInternal(innerProgress, cancellationToken, true, false, null, directoryService) .ConfigureAwait(false); } numComplete++; double percent = numComplete; percent /= count; percent *= 100; currentPercent = percent; progress.Report(percent); } } public static bool IsPathOffline(string path, List allLibraryPaths) { if (FileSystem.FileExists(path)) { return false; } var originalPath = path; // Depending on whether the path is local or unc, it may return either null or '\' at the top while (!string.IsNullOrEmpty(path) && path.Length > 1) { if (FileSystem.DirectoryExists(path)) { return false; } if (allLibraryPaths.Contains(path, StringComparer.OrdinalIgnoreCase)) { return true; } path = FileSystem.GetDirectoryName(path); } return allLibraryPaths.Any(i => ContainsPath(i, originalPath)); } private static bool ContainsPath(string parent, string path) { return FileSystem.AreEqual(parent, path) || FileSystem.ContainsSubPath(parent, path); } /// /// Get the children of this folder from the actual file system /// /// IEnumerable{BaseItem}. protected virtual IEnumerable GetNonCachedChildren(IDirectoryService directoryService) { var collectionType = LibraryManager.GetContentType(this); var libraryOptions = LibraryManager.GetLibraryOptions(this); return LibraryManager.ResolvePaths(GetFileSystemChildren(directoryService), directoryService, this, libraryOptions, collectionType); } /// /// Get our children from the repo - stubbed for now /// /// IEnumerable{BaseItem}. protected List GetCachedChildren() { return ItemRepository.GetItemList(new InternalItemsQuery { Parent = this, GroupByPresentationUniqueKey = false, DtoOptions = new DtoOptions(true) }); } public virtual int GetChildCount(User user) { if (LinkedChildren.Count > 0) { if (!(this is ICollectionFolder)) { return GetChildren(user, true).Count(); } } var result = GetItems(new InternalItemsQuery(user) { Recursive = false, Limit = 0, Parent = this, DtoOptions = new DtoOptions(false) { EnableImages = false } }); return result.TotalRecordCount; } public virtual int GetRecursiveChildCount(User user) { return GetItems(new InternalItemsQuery(user) { Recursive = true, IsFolder = false, IsVirtualItem = false, EnableTotalRecordCount = true, Limit = 0, DtoOptions = new DtoOptions(false) { EnableImages = false } }).TotalRecordCount; } public QueryResult QueryRecursive(InternalItemsQuery query) { var user = query.User; if (!query.ForceDirect && RequiresPostFiltering(query)) { IEnumerable items; Func filter = i => UserViewBuilder.Filter(i, user, query, UserDataManager, LibraryManager); if (query.User == null) { items = GetRecursiveChildren(filter); } else { items = GetRecursiveChildren(user, query); } return PostFilterAndSort(items, query, true, true); } if (!(this is UserRootFolder) && !(this is AggregateFolder)) { if (!query.ParentId.HasValue) { query.Parent = this; } } if (RequiresPostFiltering2(query)) { return QueryWithPostFiltering2(query); } return LibraryManager.GetItemsResult(query); } private QueryResult QueryWithPostFiltering2(InternalItemsQuery query) { var startIndex = query.StartIndex; var limit = query.Limit; query.StartIndex = null; query.Limit = null; var itemsList = LibraryManager.GetItemList(query); var user = query.User; if (user != null) { // needed for boxsets itemsList = itemsList.Where(i => i.IsVisibleStandalone(query.User)); } IEnumerable returnItems; int totalCount = 0; if (query.EnableTotalRecordCount) { var itemsArray = itemsList.ToArray(); totalCount = itemsArray.Length; returnItems = itemsArray; } else { returnItems = itemsList; } if (limit.HasValue) { returnItems = returnItems.Skip(startIndex ?? 0).Take(limit.Value); } else if (startIndex.HasValue) { returnItems = returnItems.Skip(startIndex.Value); } return new QueryResult { TotalRecordCount = totalCount, Items = returnItems.ToArray() }; } private bool RequiresPostFiltering2(InternalItemsQuery query) { if (query.IncludeItemTypes.Length == 1 && string.Equals(query.IncludeItemTypes[0], typeof(BoxSet).Name, StringComparison.OrdinalIgnoreCase)) { Logger.Debug("Query requires post-filtering due to BoxSet query"); return true; } return false; } private bool RequiresPostFiltering(InternalItemsQuery query) { if (LinkedChildren.Count > 0) { if (!(this is ICollectionFolder)) { Logger.Debug("Query requires post-filtering due to LinkedChildren. Type: " + GetType().Name); return true; } } if (query.IsInBoxSet.HasValue) { Logger.Debug("Query requires post-filtering due to IsInBoxSet"); return true; } // Filter by Video3DFormat if (query.Is3D.HasValue) { Logger.Debug("Query requires post-filtering due to Is3D"); return true; } if (query.HasOfficialRating.HasValue) { Logger.Debug("Query requires post-filtering due to HasOfficialRating"); return true; } if (query.IsPlaceHolder.HasValue) { Logger.Debug("Query requires post-filtering due to IsPlaceHolder"); return true; } if (query.HasSpecialFeature.HasValue) { Logger.Debug("Query requires post-filtering due to HasSpecialFeature"); return true; } if (query.HasSubtitles.HasValue) { Logger.Debug("Query requires post-filtering due to HasSubtitles"); return true; } if (query.HasTrailer.HasValue) { Logger.Debug("Query requires post-filtering due to HasTrailer"); return true; } // Filter by VideoType if (query.VideoTypes.Length > 0) { Logger.Debug("Query requires post-filtering due to VideoTypes"); return true; } // Apply person filter if (query.ItemIdsFromPersonFilters != null) { Logger.Debug("Query requires post-filtering due to ItemIdsFromPersonFilters"); return true; } if (UserViewBuilder.CollapseBoxSetItems(query, this, query.User, ConfigurationManager)) { Logger.Debug("Query requires post-filtering due to CollapseBoxSetItems"); return true; } if (!string.IsNullOrWhiteSpace(query.AdjacentTo)) { Logger.Debug("Query requires post-filtering due to AdjacentTo"); return true; } if (query.AirDays.Length > 0) { Logger.Debug("Query requires post-filtering due to AirDays"); return true; } if (query.SeriesStatuses.Length > 0) { Logger.Debug("Query requires post-filtering due to SeriesStatuses"); return true; } if (query.AiredDuringSeason.HasValue) { Logger.Debug("Query requires post-filtering due to AiredDuringSeason"); return true; } if (query.IsPlayed.HasValue) { if (query.IncludeItemTypes.Length == 1 && query.IncludeItemTypes.Contains(typeof(Series).Name)) { Logger.Debug("Query requires post-filtering due to IsPlayed"); return true; } } return false; } public QueryResult GetItems(InternalItemsQuery query) { if (query.ItemIds.Length > 0) { var result = LibraryManager.GetItemsResult(query); if (query.SortBy.Length == 0) { var ids = query.ItemIds.ToList(); // Try to preserve order result.Items = result.Items.OrderBy(i => ids.IndexOf(i.Id.ToString("N"))).ToArray(); } return result; } return GetItemsInternal(query); } public IEnumerable GetItemList(InternalItemsQuery query) { query.EnableTotalRecordCount = false; if (query.ItemIds.Length > 0) { var result = LibraryManager.GetItemList(query); if (query.SortBy.Length == 0) { var ids = query.ItemIds.ToList(); // Try to preserve order result = result.OrderBy(i => ids.IndexOf(i.Id.ToString("N"))).ToArray(); } return result; } return GetItemsInternal(query).Items; } protected virtual QueryResult GetItemsInternal(InternalItemsQuery query) { if (SourceType == SourceType.Channel) { try { // Don't blow up here because it could cause parent screens with other content to fail return ChannelManager.GetChannelItemsInternal(new ChannelItemQuery { ChannelId = ChannelId, FolderId = Id.ToString("N"), Limit = query.Limit, StartIndex = query.StartIndex, UserId = query.User.Id.ToString("N"), SortBy = query.SortBy, SortOrder = query.SortOrder }, new SimpleProgress(), CancellationToken.None).Result; } catch { // Already logged at lower levels return new QueryResult(); } } if (query.Recursive) { return QueryRecursive(query); } var user = query.User; Func filter = i => UserViewBuilder.Filter(i, user, query, UserDataManager, LibraryManager); IEnumerable items; if (query.User == null) { items = query.Recursive ? GetRecursiveChildren(filter) : Children.Where(filter); } else { items = query.Recursive ? GetRecursiveChildren(user, query) : GetChildren(user, true).Where(filter); } return PostFilterAndSort(items, query, true, true); } protected QueryResult PostFilterAndSort(IEnumerable items, InternalItemsQuery query, bool collapseBoxSetItems, bool enableSorting) { return UserViewBuilder.PostFilterAndSort(items, this, null, query, LibraryManager, ConfigurationManager, collapseBoxSetItems, enableSorting); } public virtual IEnumerable GetChildren(User user, bool includeLinkedChildren) { if (user == null) { throw new ArgumentNullException(); } //the true root should return our users root folder children if (IsPhysicalRoot) return user.RootFolder.GetChildren(user, includeLinkedChildren); var result = new Dictionary(); AddChildren(user, includeLinkedChildren, result, false, null); return result.Values; } protected virtual IEnumerable GetEligibleChildrenForRecursiveChildren(User user) { return Children; } /// /// Adds the children to list. /// /// true if XXXX, false otherwise private void AddChildren(User user, bool includeLinkedChildren, Dictionary result, bool recursive, InternalItemsQuery query) { foreach (var child in GetEligibleChildrenForRecursiveChildren(user)) { if (child.IsVisible(user)) { if (query == null || UserViewBuilder.FilterItem(child, query)) { result[child.Id] = child; } if (recursive && child.IsFolder) { var folder = (Folder)child; folder.AddChildren(user, includeLinkedChildren, result, true, query); } } } if (includeLinkedChildren) { foreach (var child in GetLinkedChildren(user)) { if (child.IsVisible(user)) { if (query == null || UserViewBuilder.FilterItem(child, query)) { result[child.Id] = child; } } } } } /// /// Gets allowed recursive children of an item /// /// The user. /// if set to true [include linked children]. /// IEnumerable{BaseItem}. /// public IEnumerable GetRecursiveChildren(User user, bool includeLinkedChildren = true) { return GetRecursiveChildren(user, null); } public virtual IEnumerable GetRecursiveChildren(User user, InternalItemsQuery query) { if (user == null) { throw new ArgumentNullException("user"); } var result = new Dictionary(); AddChildren(user, true, result, true, query); return result.Values; } /// /// Gets the recursive children. /// /// IList{BaseItem}. public IList GetRecursiveChildren() { return GetRecursiveChildren(true); } public IList GetRecursiveChildren(bool includeLinkedChildren) { return GetRecursiveChildren(i => true, includeLinkedChildren); } public IList GetRecursiveChildren(Func filter) { return GetRecursiveChildren(filter, true); } public IList GetRecursiveChildren(Func filter, bool includeLinkedChildren) { var result = new Dictionary(); AddChildrenToList(result, includeLinkedChildren, true, filter); return result.Values.ToList(); } /// /// Adds the children to list. /// private void AddChildrenToList(Dictionary result, bool includeLinkedChildren, bool recursive, Func filter) { foreach (var child in Children) { if (filter == null || filter(child)) { result[child.Id] = child; } if (recursive && child.IsFolder) { var folder = (Folder)child; // We can only support includeLinkedChildren for the first folder, or we might end up stuck in a loop of linked items folder.AddChildrenToList(result, false, true, filter); } } if (includeLinkedChildren) { foreach (var child in GetLinkedChildren()) { if (filter == null || filter(child)) { result[child.Id] = child; } } } } /// /// Gets the linked children. /// /// IEnumerable{BaseItem}. public IEnumerable GetLinkedChildren() { return LinkedChildren .Select(GetLinkedChild) .Where(i => i != null); } protected virtual bool FilterLinkedChildrenPerUser { get { return false; } } public IEnumerable GetLinkedChildren(User user) { if (!FilterLinkedChildrenPerUser || user == null) { return GetLinkedChildren(); } if (LinkedChildren.Count == 0) { return new List(); } var allUserRootChildren = user.RootFolder.Children.OfType().ToList(); var collectionFolderIds = allUserRootChildren .OfType() .Where(i => i.IsVisible(user)) .Select(i => i.Id) .ToList(); return LinkedChildren .Select(i => { var child = GetLinkedChild(i); if (child != null) { var childLocationType = child.LocationType; if (childLocationType == LocationType.Remote || childLocationType == LocationType.Virtual) { if (!child.IsVisibleStandalone(user)) { return null; } } else if (childLocationType == LocationType.FileSystem) { var itemCollectionFolderIds = LibraryManager.GetCollectionFolders(child, allUserRootChildren) .Select(f => f.Id).ToList(); if (!itemCollectionFolderIds.Any(collectionFolderIds.Contains)) { return null; } } } return child; }) .Where(i => i != null); } /// /// Gets the linked children. /// /// IEnumerable{BaseItem}. public IEnumerable> GetLinkedChildrenInfos() { return LinkedChildren .Select(i => new Tuple(i, GetLinkedChild(i))) .Where(i => i.Item2 != null); } [IgnoreDataMember] protected override bool SupportsOwnedItems { get { return base.SupportsOwnedItems || SupportsShortcutChildren; } } protected override async Task RefreshedOwnedItems(MetadataRefreshOptions options, List fileSystemChildren, CancellationToken cancellationToken) { var changesFound = false; if (LocationType == LocationType.FileSystem) { if (RefreshLinkedChildren(fileSystemChildren)) { changesFound = true; } } var baseHasChanges = await base.RefreshedOwnedItems(options, fileSystemChildren, cancellationToken).ConfigureAwait(false); return baseHasChanges || changesFound; } /// /// Refreshes the linked children. /// /// true if XXXX, false otherwise protected virtual bool RefreshLinkedChildren(IEnumerable fileSystemChildren) { var currentManualLinks = LinkedChildren.Where(i => i.Type == LinkedChildType.Manual).ToList(); var currentShortcutLinks = LinkedChildren.Where(i => i.Type == LinkedChildType.Shortcut).ToList(); List newShortcutLinks; if (SupportsShortcutChildren) { newShortcutLinks = fileSystemChildren .Where(i => !i.IsDirectory && FileSystem.IsShortcut(i.FullName)) .Select(i => { try { Logger.Debug("Found shortcut at {0}", i.FullName); var resolvedPath = FileSystem.ResolveShortcut(i.FullName); if (!string.IsNullOrEmpty(resolvedPath)) { return new LinkedChild { Path = resolvedPath, Type = LinkedChildType.Shortcut }; } Logger.Error("Error resolving shortcut {0}", i.FullName); return null; } catch (IOException ex) { Logger.ErrorException("Error resolving shortcut {0}", ex, i.FullName); return null; } }) .Where(i => i != null) .ToList(); } else { newShortcutLinks = new List(); } if (!newShortcutLinks.SequenceEqual(currentShortcutLinks, new LinkedChildComparer(FileSystem))) { Logger.Info("Shortcut links have changed for {0}", Path); newShortcutLinks.AddRange(currentManualLinks); LinkedChildren = newShortcutLinks; return true; } foreach (var child in LinkedChildren) { // Reset the cached value child.ItemId = null; } return false; } /// /// Marks the played. /// /// The user. /// The date played. /// if set to true [reset position]. /// Task. public override async Task MarkPlayed(User user, DateTime? datePlayed, bool resetPosition) { var query = new InternalItemsQuery { User = user, Recursive = true, IsFolder = false, EnableTotalRecordCount = false }; if (!user.Configuration.DisplayMissingEpisodes || !user.Configuration.DisplayUnairedEpisodes) { query.IsVirtualItem = false; } var itemsResult = GetItemList(query); // Sweep through recursively and update status var tasks = itemsResult.Select(c => c.MarkPlayed(user, datePlayed, resetPosition)); await Task.WhenAll(tasks).ConfigureAwait(false); } /// /// Marks the unplayed. /// /// The user. /// Task. public override async Task MarkUnplayed(User user) { var itemsResult = GetItemList(new InternalItemsQuery { User = user, Recursive = true, IsFolder = false, EnableTotalRecordCount = false }); // Sweep through recursively and update status var tasks = itemsResult.Select(c => c.MarkUnplayed(user)); await Task.WhenAll(tasks).ConfigureAwait(false); } public override bool IsPlayed(User user) { var itemsResult = GetItemList(new InternalItemsQuery(user) { Recursive = true, IsFolder = false, IsVirtualItem = false, EnableTotalRecordCount = false }); return itemsResult .All(i => i.IsPlayed(user)); } public override bool IsUnplayed(User user) { return !IsPlayed(user); } [IgnoreDataMember] public virtual bool SupportsUserDataFromChildren { get { // These are just far too slow. if (this is ICollectionFolder) { return false; } if (this is UserView) { return false; } if (this is UserRootFolder) { return false; } if (this is Channel) { return false; } if (SourceType != SourceType.Library) { return false; } var iItemByName = this as IItemByName; if (iItemByName != null) { var hasDualAccess = this as IHasDualAccess; if (hasDualAccess == null || hasDualAccess.IsAccessedByName) { return false; } } return true; } } public override void FillUserDataDtoValues(UserItemDataDto dto, UserItemData userData, BaseItemDto itemDto, User user, List fields) { if (!SupportsUserDataFromChildren) { return; } if (itemDto != null) { if (fields.Contains(ItemFields.RecursiveItemCount)) { itemDto.RecursiveItemCount = GetRecursiveChildCount(user); } } if (SupportsPlayedStatus) { var unplayedQueryResult = GetItems(new InternalItemsQuery(user) { Recursive = true, IsFolder = false, IsVirtualItem = false, EnableTotalRecordCount = true, Limit = 0, IsPlayed = false, DtoOptions = new DtoOptions(false) { EnableImages = false } }); double unplayedCount = unplayedQueryResult.TotalRecordCount; dto.UnplayedItemCount = unplayedQueryResult.TotalRecordCount; if (itemDto != null && itemDto.RecursiveItemCount.HasValue) { if (itemDto.RecursiveItemCount.Value > 0) { var unplayedPercentage = (unplayedCount / itemDto.RecursiveItemCount.Value) * 100; dto.PlayedPercentage = 100 - unplayedPercentage; dto.Played = dto.PlayedPercentage.Value >= 100; } } else { dto.Played = (dto.UnplayedItemCount ?? 0) == 0; } } } } }