jellyfin-server/MediaBrowser.Server.Implementations/FileOrganization/FileOrganizationService.cs

184 lines
6.2 KiB
C#
Raw Normal View History

2014-01-21 06:10:58 +00:00
using MediaBrowser.Common.Extensions;
using MediaBrowser.Common.ScheduledTasks;
2014-01-22 17:05:06 +00:00
using MediaBrowser.Controller.Configuration;
using MediaBrowser.Controller.FileOrganization;
2014-01-21 06:10:58 +00:00
using MediaBrowser.Controller.Library;
using MediaBrowser.Controller.Persistence;
using MediaBrowser.Controller.Providers;
using MediaBrowser.Model.FileOrganization;
2014-01-21 06:10:58 +00:00
using MediaBrowser.Model.Logging;
2014-01-20 18:46:08 +00:00
using MediaBrowser.Model.Querying;
2014-01-21 06:10:58 +00:00
using System;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
2015-10-04 04:23:11 +00:00
using CommonIO;
namespace MediaBrowser.Server.Implementations.FileOrganization
{
public class FileOrganizationService : IFileOrganizationService
{
private readonly ITaskManager _taskManager;
private readonly IFileOrganizationRepository _repo;
2014-01-21 06:10:58 +00:00
private readonly ILogger _logger;
private readonly ILibraryMonitor _libraryMonitor;
2014-01-21 06:10:58 +00:00
private readonly ILibraryManager _libraryManager;
2014-01-22 17:05:06 +00:00
private readonly IServerConfigurationManager _config;
private readonly IFileSystem _fileSystem;
private readonly IProviderManager _providerManager;
public FileOrganizationService(ITaskManager taskManager, IFileOrganizationRepository repo, ILogger logger, ILibraryMonitor libraryMonitor, ILibraryManager libraryManager, IServerConfigurationManager config, IFileSystem fileSystem, IProviderManager providerManager)
{
_taskManager = taskManager;
_repo = repo;
2014-01-21 06:10:58 +00:00
_logger = logger;
_libraryMonitor = libraryMonitor;
2014-01-21 06:10:58 +00:00
_libraryManager = libraryManager;
2014-01-22 17:05:06 +00:00
_config = config;
_fileSystem = fileSystem;
_providerManager = providerManager;
}
public void BeginProcessNewFiles()
{
2014-01-21 06:10:58 +00:00
_taskManager.CancelIfRunningAndQueue<OrganizerScheduledTask>();
}
public Task SaveResult(FileOrganizationResult result, CancellationToken cancellationToken)
{
2014-01-21 06:10:58 +00:00
if (result == null || string.IsNullOrEmpty(result.OriginalPath))
{
throw new ArgumentNullException("result");
}
2014-01-21 16:24:12 +00:00
result.Id = result.OriginalPath.GetMD5().ToString("N");
2014-01-21 06:10:58 +00:00
return _repo.SaveResult(result, cancellationToken);
}
2014-01-20 18:46:08 +00:00
public QueryResult<FileOrganizationResult> GetResults(FileOrganizationResultQuery query)
{
return _repo.GetResults(query);
}
2014-01-21 06:10:58 +00:00
2014-01-22 17:05:06 +00:00
public FileOrganizationResult GetResult(string id)
{
return _repo.GetResult(id);
}
2014-02-19 16:24:06 +00:00
public FileOrganizationResult GetResultBySourcePath(string path)
{
if (string.IsNullOrEmpty(path))
{
throw new ArgumentNullException("path");
}
var id = path.GetMD5().ToString("N");
return GetResult(id);
}
2014-01-21 06:10:58 +00:00
public Task DeleteOriginalFile(string resultId)
{
var result = _repo.GetResult(resultId);
_logger.Info("Requested to delete {0}", result.OriginalPath);
try
{
_fileSystem.DeleteFile(result.OriginalPath);
2014-01-21 06:10:58 +00:00
}
catch (Exception ex)
{
_logger.ErrorException("Error deleting {0}", ex, result.OriginalPath);
}
return _repo.Delete(resultId);
}
2016-05-14 16:06:01 +00:00
private AutoOrganizeOptions GetAutoOrganizeOptions()
2014-07-31 02:09:23 +00:00
{
return _config.GetAutoOrganizeOptions();
2014-07-31 02:09:23 +00:00
}
2014-01-21 06:10:58 +00:00
public async Task PerformOrganization(string resultId)
{
var result = _repo.GetResult(resultId);
if (string.IsNullOrEmpty(result.TargetPath))
{
throw new ArgumentException("No target path available.");
}
2014-01-22 17:05:06 +00:00
var organizer = new EpisodeFileOrganizer(this, _config, _fileSystem, _logger, _libraryManager,
_libraryMonitor, _providerManager);
2014-01-21 06:10:58 +00:00
2016-05-14 16:06:01 +00:00
await organizer.OrganizeEpisodeFile(result.OriginalPath, GetAutoOrganizeOptions(), true, CancellationToken.None)
2014-01-22 17:05:06 +00:00
.ConfigureAwait(false);
}
2014-01-21 06:10:58 +00:00
2014-01-22 17:05:06 +00:00
public Task ClearLog()
{
return _repo.DeleteAll();
}
2014-01-21 06:10:58 +00:00
2014-01-22 17:05:06 +00:00
public async Task PerformEpisodeOrganization(EpisodeFileOrganizationRequest request)
{
var organizer = new EpisodeFileOrganizer(this, _config, _fileSystem, _logger, _libraryManager,
_libraryMonitor, _providerManager);
2014-01-21 06:10:58 +00:00
2016-05-14 16:06:01 +00:00
await organizer.OrganizeWithCorrection(request, GetAutoOrganizeOptions(), CancellationToken.None).ConfigureAwait(false);
}
public QueryResult<SmartMatchInfo> GetSmartMatchInfos(FileOrganizationResultQuery query)
{
if (query == null)
{
throw new ArgumentNullException("query");
}
2016-05-14 16:06:01 +00:00
var options = GetAutoOrganizeOptions();
2016-02-07 05:15:26 +00:00
var items = options.SmartMatchInfos.Skip(query.StartIndex ?? 0).Take(query.Limit ?? Int32.MaxValue).ToArray();
return new QueryResult<SmartMatchInfo>()
{
2016-02-07 05:15:26 +00:00
Items = items,
TotalRecordCount = options.SmartMatchInfos.Length
};
}
public void DeleteSmartMatchEntry(string itemName, string matchString)
{
if (string.IsNullOrEmpty(itemName))
{
throw new ArgumentNullException("itemName");
}
if (string.IsNullOrEmpty(matchString))
{
throw new ArgumentNullException("matchString");
}
2016-05-14 16:06:01 +00:00
var options = GetAutoOrganizeOptions();
SmartMatchInfo info = options.SmartMatchInfos.FirstOrDefault(i => string.Equals(i.ItemName, itemName));
if (info != null && info.MatchStrings.Contains(matchString))
{
2016-02-07 05:15:26 +00:00
var list = info.MatchStrings.ToList();
list.Remove(matchString);
info.MatchStrings = list.ToArray();
if (info.MatchStrings.Length == 0)
{
2016-02-07 05:15:26 +00:00
var infos = options.SmartMatchInfos.ToList();
infos.Remove(info);
options.SmartMatchInfos = infos.ToArray();
}
_config.SaveAutoOrganizeOptions(options);
}
2014-01-21 06:10:58 +00:00
}
}
}