using MediaBrowser.Controller.IO; using MediaBrowser.Controller.Library; using MediaBrowser.Controller.Providers; using System; using System.Collections.Generic; using System.Linq; using System.Runtime.Serialization; using System.Threading; using System.Threading.Tasks; using CommonIO; using MoreLinq; namespace MediaBrowser.Controller.Entities { /// /// Specialized Folder class that points to a subset of the physical folders in the system. /// It is created from the user-specific folders within the system root /// public class CollectionFolder : Folder, ICollectionFolder { public CollectionFolder() { PhysicalLocationsList = new List(); } [IgnoreDataMember] protected override bool SupportsShortcutChildren { get { return true; } } public override bool CanDelete() { return false; } public string CollectionType { get; set; } /// /// Allow different display preferences for each collection folder /// /// The display prefs id. [IgnoreDataMember] public override Guid DisplayPreferencesId { get { return Id; } } [IgnoreDataMember] public override IEnumerable PhysicalLocations { get { return PhysicalLocationsList; } } public override bool IsSaveLocalMetadataEnabled() { return true; } public List PhysicalLocationsList { get; set; } protected override IEnumerable GetFileSystemChildren(IDirectoryService directoryService) { return CreateResolveArgs(directoryService, true).FileSystemChildren; } private bool _requiresRefresh; public override bool RequiresRefresh() { var changed = base.RequiresRefresh() || _requiresRefresh; if (!changed) { var locations = PhysicalLocations.ToList(); var newLocations = CreateResolveArgs(new DirectoryService(Logger, FileSystem), false).PhysicalLocations.ToList(); if (!locations.SequenceEqual(newLocations)) { changed = true; } } return changed; } public override bool BeforeMetadataRefresh() { var changed = base.BeforeMetadataRefresh() || _requiresRefresh; _requiresRefresh = false; return changed; } internal override bool IsValidFromResolver(BaseItem newItem) { var newCollectionFolder = newItem as CollectionFolder; if (newCollectionFolder != null) { if (!string.Equals(CollectionType, newCollectionFolder.CollectionType, StringComparison.OrdinalIgnoreCase)) { return false; } } return base.IsValidFromResolver(newItem); } private ItemResolveArgs CreateResolveArgs(IDirectoryService directoryService, bool setPhysicalLocations) { var path = ContainingFolderPath; var args = new ItemResolveArgs(ConfigurationManager.ApplicationPaths, directoryService) { FileInfo = FileSystem.GetDirectoryInfo(path), Path = path, Parent = Parent, CollectionType = CollectionType }; // Gather child folder and files if (args.IsDirectory) { var isPhysicalRoot = args.IsPhysicalRoot; // When resolving the root, we need it's grandchildren (children of user views) var flattenFolderDepth = isPhysicalRoot ? 2 : 0; var fileSystemDictionary = FileData.GetFilteredFileSystemEntries(directoryService, args.Path, FileSystem, Logger, args, flattenFolderDepth: flattenFolderDepth, resolveShortcuts: isPhysicalRoot || args.IsVf); // Need to remove subpaths that may have been resolved from shortcuts // Example: if \\server\movies exists, then strip out \\server\movies\action if (isPhysicalRoot) { var paths = LibraryManager.NormalizeRootPathList(fileSystemDictionary.Values); fileSystemDictionary = paths.ToDictionary(i => i.FullName); } args.FileSystemDictionary = fileSystemDictionary; } _requiresRefresh = _requiresRefresh || !args.PhysicalLocations.SequenceEqual(PhysicalLocations); if (setPhysicalLocations) { PhysicalLocationsList = args.PhysicalLocations.ToList(); } return args; } /// /// Compare our current children (presumably just read from the repo) with the current state of the file system and adjust for any changes /// ***Currently does not contain logic to maintain items that are unavailable in the file system*** /// /// 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 override Task ValidateChildrenInternal(IProgress progress, CancellationToken cancellationToken, bool recursive, bool refreshChildMetadata, MetadataRefreshOptions refreshOptions, IDirectoryService directoryService) { return Task.FromResult(true); } /// /// Our children are actually just references to the ones in the physical root... /// /// The linked children. public override List LinkedChildren { get { return GetLinkedChildrenInternal(); } set { base.LinkedChildren = value; } } private List GetLinkedChildrenInternal() { return GetPhysicalParents() .SelectMany(c => c.LinkedChildren) .ToList(); } /// /// Our children are actually just references to the ones in the physical root... /// /// The actual children. [IgnoreDataMember] protected override IEnumerable ActualChildren { get { return GetActualChildren(); } } private IEnumerable GetActualChildren() { return GetPhysicalParents().SelectMany(c => c.Children); } public IEnumerable GetPhysicalParents() { var rootChildren = LibraryManager.RootFolder.Children .OfType() .ToList(); return PhysicalLocations.Where(i => !string.Equals(i, Path, StringComparison.OrdinalIgnoreCase)).SelectMany(i => GetPhysicalParents(i, rootChildren)).DistinctBy(i => i.Id); } private IEnumerable GetPhysicalParents(string path, List rootChildren) { var result = rootChildren .Where(i => string.Equals(i.Path, path, StringComparison.OrdinalIgnoreCase)) .ToList(); if (result.Count == 0) { var folder = LibraryManager.FindByPath(path, true) as Folder; if (folder != null) { result.Add(folder); } } return result; } [IgnoreDataMember] public override bool SupportsPeople { get { return false; } } } }