using MediaBrowser.Controller.Entities;
using MediaBrowser.Controller.IO;
using MediaBrowser.Controller.Resolvers;
using MediaBrowser.Common.Extensions;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
namespace MediaBrowser.Controller.Library
{
public class ItemController
{
///
/// Resolves a path into a BaseItem
///
public async Task GetItem(string path, Folder parent = null, WIN32_FIND_DATA? fileInfo = null, bool allowInternetProviders = true)
{
var args = new ItemResolveEventArgs
{
FileInfo = fileInfo ?? FileData.GetFileData(path),
Parent = parent,
Cancel = false,
Path = path
};
// Gather child folder and files
if (args.IsDirectory)
{
args.FileSystemChildren = FileData.GetFileSystemEntries(path, "*").ToArray();
bool isVirtualFolder = parent != null && parent.IsRoot;
args = FileSystemHelper.FilterChildFileSystemEntries(args, isVirtualFolder);
}
else
{
args.FileSystemChildren = new WIN32_FIND_DATA[] { };
}
// Check to see if we should resolve based on our contents
if (!EntityResolutionHelper.ShouldResolvePathContents(args))
{
return null;
}
BaseItem item = Kernel.Instance.ResolveItem(args);
return item;
}
///
/// Gets a Person
///
public Task GetPerson(string name)
{
return GetImagesByNameItem(Kernel.Instance.ApplicationPaths.PeoplePath, name);
}
///
/// Gets a Studio
///
public Task GetStudio(string name)
{
return GetImagesByNameItem(Kernel.Instance.ApplicationPaths.StudioPath, name);
}
///
/// Gets a Genre
///
public Task GetGenre(string name)
{
return GetImagesByNameItem(Kernel.Instance.ApplicationPaths.GenrePath, name);
}
///
/// Gets a Year
///
public Task GetYear(int value)
{
return GetImagesByNameItem(Kernel.Instance.ApplicationPaths.YearPath, value.ToString());
}
private readonly ConcurrentDictionary ImagesByNameItemCache = new ConcurrentDictionary(StringComparer.OrdinalIgnoreCase);
///
/// Generically retrieves an IBN item
///
private Task GetImagesByNameItem(string path, string name)
where T : BaseEntity, new()
{
name = FileData.GetValidFilename(name);
path = Path.Combine(path, name);
// Look for it in the cache, if it's not there, create it
if (!ImagesByNameItemCache.ContainsKey(path))
{
ImagesByNameItemCache[path] = CreateImagesByNameItem(path, name);
}
return ImagesByNameItemCache[path] as Task;
}
///
/// Creates an IBN item based on a given path
///
private async Task CreateImagesByNameItem(string path, string name)
where T : BaseEntity, new()
{
var item = new T { };
item.Name = name;
item.Id = path.GetMD5();
if (!Directory.Exists(path))
{
Directory.CreateDirectory(path);
}
item.DateCreated = Directory.GetCreationTimeUtc(path);
item.DateModified = Directory.GetLastWriteTimeUtc(path);
var args = new ItemResolveEventArgs { };
args.FileInfo = FileData.GetFileData(path);
args.FileSystemChildren = FileData.GetFileSystemEntries(path, "*").ToArray();
await Kernel.Instance.ExecuteMetadataProviders(item).ConfigureAwait(false);
return item;
}
}
}