|
@@ -1,1372 +0,0 @@
|
|
|
-using MediaBrowser.Common.Configuration;
|
|
|
-using MediaBrowser.Common.Events;
|
|
|
-using MediaBrowser.Common.Extensions;
|
|
|
-using MediaBrowser.Controller;
|
|
|
-using MediaBrowser.Controller.Drawing;
|
|
|
-using MediaBrowser.Controller.Dto;
|
|
|
-using MediaBrowser.Controller.Entities;
|
|
|
-using MediaBrowser.Controller.Entities.Audio;
|
|
|
-using MediaBrowser.Controller.Entities.TV;
|
|
|
-using MediaBrowser.Controller.Library;
|
|
|
-using MediaBrowser.Controller.MediaEncoding;
|
|
|
-using MediaBrowser.Controller.Playlists;
|
|
|
-using MediaBrowser.Controller.Sync;
|
|
|
-using MediaBrowser.Controller.TV;
|
|
|
-using MediaBrowser.Model.Dto;
|
|
|
-using MediaBrowser.Model.Entities;
|
|
|
-using MediaBrowser.Model.Events;
|
|
|
-using MediaBrowser.Model.Logging;
|
|
|
-using MediaBrowser.Model.Querying;
|
|
|
-using MediaBrowser.Model.Serialization;
|
|
|
-using MediaBrowser.Model.Sync;
|
|
|
-using MediaBrowser.Model.Users;
|
|
|
-using System;
|
|
|
-using System.Collections.Concurrent;
|
|
|
-using System.Collections.Generic;
|
|
|
-using System.Globalization;
|
|
|
-using System.IO;
|
|
|
-using System.Linq;
|
|
|
-using System.Threading;
|
|
|
-using System.Threading.Tasks;
|
|
|
-using MediaBrowser.Model.IO;
|
|
|
-using MediaBrowser.Model.Tasks;
|
|
|
-
|
|
|
-namespace Emby.Server.Implementations.Sync
|
|
|
-{
|
|
|
- public class SyncManager : ISyncManager
|
|
|
- {
|
|
|
- private readonly ILibraryManager _libraryManager;
|
|
|
- private readonly ISyncRepository _repo;
|
|
|
- private readonly IImageProcessor _imageProcessor;
|
|
|
- private readonly ILogger _logger;
|
|
|
- private readonly IUserManager _userManager;
|
|
|
- private readonly Func<IDtoService> _dtoService;
|
|
|
- private readonly IServerApplicationHost _appHost;
|
|
|
- private readonly ITVSeriesManager _tvSeriesManager;
|
|
|
- private readonly Func<IMediaEncoder> _mediaEncoder;
|
|
|
- private readonly IFileSystem _fileSystem;
|
|
|
- private readonly Func<ISubtitleEncoder> _subtitleEncoder;
|
|
|
- private readonly IConfigurationManager _config;
|
|
|
- private readonly IUserDataManager _userDataManager;
|
|
|
- private readonly Func<IMediaSourceManager> _mediaSourceManager;
|
|
|
- private readonly IJsonSerializer _json;
|
|
|
- private readonly ITaskManager _taskManager;
|
|
|
- private readonly IMemoryStreamFactory _memoryStreamProvider;
|
|
|
-
|
|
|
- private ISyncProvider[] _providers = { };
|
|
|
-
|
|
|
- public event EventHandler<GenericEventArgs<SyncJobCreationResult>> SyncJobCreated;
|
|
|
- public event EventHandler<GenericEventArgs<SyncJob>> SyncJobCancelled;
|
|
|
- public event EventHandler<GenericEventArgs<SyncJob>> SyncJobUpdated;
|
|
|
- public event EventHandler<GenericEventArgs<SyncJobItem>> SyncJobItemUpdated;
|
|
|
- public event EventHandler<GenericEventArgs<SyncJobItem>> SyncJobItemCreated;
|
|
|
-
|
|
|
- public SyncManager(ILibraryManager libraryManager, ISyncRepository repo, IImageProcessor imageProcessor, ILogger logger, IUserManager userManager, Func<IDtoService> dtoService, IServerApplicationHost appHost, ITVSeriesManager tvSeriesManager, Func<IMediaEncoder> mediaEncoder, IFileSystem fileSystem, Func<ISubtitleEncoder> subtitleEncoder, IConfigurationManager config, IUserDataManager userDataManager, Func<IMediaSourceManager> mediaSourceManager, IJsonSerializer json, ITaskManager taskManager, IMemoryStreamFactory memoryStreamProvider)
|
|
|
- {
|
|
|
- _libraryManager = libraryManager;
|
|
|
- _repo = repo;
|
|
|
- _imageProcessor = imageProcessor;
|
|
|
- _logger = logger;
|
|
|
- _userManager = userManager;
|
|
|
- _dtoService = dtoService;
|
|
|
- _appHost = appHost;
|
|
|
- _tvSeriesManager = tvSeriesManager;
|
|
|
- _mediaEncoder = mediaEncoder;
|
|
|
- _fileSystem = fileSystem;
|
|
|
- _subtitleEncoder = subtitleEncoder;
|
|
|
- _config = config;
|
|
|
- _userDataManager = userDataManager;
|
|
|
- _mediaSourceManager = mediaSourceManager;
|
|
|
- _json = json;
|
|
|
- _taskManager = taskManager;
|
|
|
- _memoryStreamProvider = memoryStreamProvider;
|
|
|
- }
|
|
|
-
|
|
|
- public void AddParts(IEnumerable<ISyncProvider> providers)
|
|
|
- {
|
|
|
- _providers = providers.ToArray();
|
|
|
- }
|
|
|
-
|
|
|
- public IEnumerable<IServerSyncProvider> ServerSyncProviders
|
|
|
- {
|
|
|
- get { return _providers.OfType<IServerSyncProvider>(); }
|
|
|
- }
|
|
|
-
|
|
|
- private readonly ConcurrentDictionary<string, ISyncDataProvider> _dataProviders =
|
|
|
- new ConcurrentDictionary<string, ISyncDataProvider>(StringComparer.OrdinalIgnoreCase);
|
|
|
-
|
|
|
- public ISyncDataProvider GetDataProvider(IServerSyncProvider provider, SyncTarget target)
|
|
|
- {
|
|
|
- return _dataProviders.GetOrAdd(target.Id, key => new TargetDataProvider(provider, target, _appHost, _logger, _json, _fileSystem, _config.CommonApplicationPaths, _memoryStreamProvider));
|
|
|
- }
|
|
|
-
|
|
|
- public async Task<SyncJobCreationResult> CreateJob(SyncJobRequest request)
|
|
|
- {
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- var user = _userManager.GetUserById(request.UserId);
|
|
|
-
|
|
|
- var items = (await processor
|
|
|
- .GetItemsForSync(request.Category, request.ParentId, request.ItemIds, user, request.UnwatchedOnly).ConfigureAwait(false))
|
|
|
- .ToList();
|
|
|
-
|
|
|
- if (items.Any(i => !SupportsSync(i)))
|
|
|
- {
|
|
|
- throw new ArgumentException("Item does not support sync.");
|
|
|
- }
|
|
|
-
|
|
|
- if (string.IsNullOrWhiteSpace(request.Name))
|
|
|
- {
|
|
|
- if (request.ItemIds.Count == 1)
|
|
|
- {
|
|
|
- request.Name = GetDefaultName(_libraryManager.GetItemById(request.ItemIds[0]));
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (string.IsNullOrWhiteSpace(request.Name))
|
|
|
- {
|
|
|
- request.Name = DateTime.Now.ToString("f1", CultureInfo.CurrentCulture);
|
|
|
- }
|
|
|
-
|
|
|
- var target = GetSyncTargets(request.UserId)
|
|
|
- .FirstOrDefault(i => string.Equals(request.TargetId, i.Id));
|
|
|
-
|
|
|
- if (target == null)
|
|
|
- {
|
|
|
- throw new ArgumentException("Sync target not found.");
|
|
|
- }
|
|
|
-
|
|
|
- var jobId = Guid.NewGuid().ToString("N");
|
|
|
-
|
|
|
- if (string.IsNullOrWhiteSpace(request.Quality))
|
|
|
- {
|
|
|
- request.Quality = GetQualityOptions(request.TargetId)
|
|
|
- .Where(i => i.IsDefault)
|
|
|
- .Select(i => i.Id)
|
|
|
- .FirstOrDefault(i => !string.IsNullOrWhiteSpace(i));
|
|
|
- }
|
|
|
-
|
|
|
- var job = new SyncJob
|
|
|
- {
|
|
|
- Id = jobId,
|
|
|
- Name = request.Name,
|
|
|
- TargetId = target.Id,
|
|
|
- UserId = request.UserId,
|
|
|
- UnwatchedOnly = request.UnwatchedOnly,
|
|
|
- ItemLimit = request.ItemLimit,
|
|
|
- RequestedItemIds = request.ItemIds ?? new List<string>(),
|
|
|
- DateCreated = DateTime.UtcNow,
|
|
|
- DateLastModified = DateTime.UtcNow,
|
|
|
- SyncNewContent = request.SyncNewContent,
|
|
|
- ItemCount = items.Count,
|
|
|
- Category = request.Category,
|
|
|
- ParentId = request.ParentId,
|
|
|
- Quality = request.Quality,
|
|
|
- Profile = request.Profile,
|
|
|
- Bitrate = request.Bitrate
|
|
|
- };
|
|
|
-
|
|
|
- if (!request.Category.HasValue && request.ItemIds != null)
|
|
|
- {
|
|
|
- var requestedItems = request.ItemIds
|
|
|
- .Select(_libraryManager.GetItemById)
|
|
|
- .Where(i => i != null);
|
|
|
-
|
|
|
- // It's just a static list
|
|
|
- if (!requestedItems.Any(i => i.IsFolder || i is IItemByName))
|
|
|
- {
|
|
|
- job.SyncNewContent = false;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- await _repo.Create(job).ConfigureAwait(false);
|
|
|
-
|
|
|
- await processor.EnsureJobItems(job, user).ConfigureAwait(false);
|
|
|
-
|
|
|
- // If it already has a converting status then is must have been aborted during conversion
|
|
|
- var jobItemsResult = GetJobItems(new SyncJobItemQuery
|
|
|
- {
|
|
|
- Statuses = new[] { SyncJobItemStatus.Queued, SyncJobItemStatus.Converting },
|
|
|
- JobId = jobId,
|
|
|
- AddMetadata = false
|
|
|
- });
|
|
|
-
|
|
|
- await processor.SyncJobItems(jobItemsResult.Items, false, new Progress<double>(), CancellationToken.None)
|
|
|
- .ConfigureAwait(false);
|
|
|
-
|
|
|
- jobItemsResult = GetJobItems(new SyncJobItemQuery
|
|
|
- {
|
|
|
- Statuses = new[] { SyncJobItemStatus.Queued, SyncJobItemStatus.Converting },
|
|
|
- JobId = jobId,
|
|
|
- AddMetadata = false
|
|
|
- });
|
|
|
-
|
|
|
- var returnResult = new SyncJobCreationResult
|
|
|
- {
|
|
|
- Job = GetJob(jobId),
|
|
|
- JobItems = jobItemsResult.Items.ToList()
|
|
|
- };
|
|
|
-
|
|
|
- if (SyncJobCreated != null)
|
|
|
- {
|
|
|
- EventHelper.FireEventIfNotNull(SyncJobCreated, this, new GenericEventArgs<SyncJobCreationResult>
|
|
|
- {
|
|
|
- Argument = returnResult
|
|
|
-
|
|
|
- }, _logger);
|
|
|
- }
|
|
|
-
|
|
|
- if (returnResult.JobItems.Any(i => i.Status == SyncJobItemStatus.Queued || i.Status == SyncJobItemStatus.Converting))
|
|
|
- {
|
|
|
- _taskManager.QueueScheduledTask<SyncConvertScheduledTask>();
|
|
|
- }
|
|
|
-
|
|
|
- return returnResult;
|
|
|
- }
|
|
|
-
|
|
|
- public async Task UpdateJob(SyncJob job)
|
|
|
- {
|
|
|
- // Get fresh from the db and only update the fields that are supported to be changed.
|
|
|
- var instance = _repo.GetJob(job.Id);
|
|
|
-
|
|
|
- instance.Name = job.Name;
|
|
|
- instance.Quality = job.Quality;
|
|
|
- instance.Profile = job.Profile;
|
|
|
- instance.UnwatchedOnly = job.UnwatchedOnly;
|
|
|
- instance.SyncNewContent = job.SyncNewContent;
|
|
|
- instance.ItemLimit = job.ItemLimit;
|
|
|
-
|
|
|
- await _repo.Update(instance).ConfigureAwait(false);
|
|
|
-
|
|
|
- OnSyncJobUpdated(instance);
|
|
|
- }
|
|
|
-
|
|
|
- internal void OnSyncJobUpdated(SyncJob job)
|
|
|
- {
|
|
|
- if (SyncJobUpdated != null)
|
|
|
- {
|
|
|
- EventHelper.FireEventIfNotNull(SyncJobUpdated, this, new GenericEventArgs<SyncJob>
|
|
|
- {
|
|
|
- Argument = job
|
|
|
-
|
|
|
- }, _logger);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- internal async Task UpdateSyncJobItemInternal(SyncJobItem jobItem)
|
|
|
- {
|
|
|
- await _repo.Update(jobItem).ConfigureAwait(false);
|
|
|
-
|
|
|
- if (SyncJobUpdated != null)
|
|
|
- {
|
|
|
- EventHelper.FireEventIfNotNull(SyncJobItemUpdated, this, new GenericEventArgs<SyncJobItem>
|
|
|
- {
|
|
|
- Argument = jobItem
|
|
|
-
|
|
|
- }, _logger);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- internal void OnSyncJobItemCreated(SyncJobItem job)
|
|
|
- {
|
|
|
- if (SyncJobUpdated != null)
|
|
|
- {
|
|
|
- EventHelper.FireEventIfNotNull(SyncJobItemCreated, this, new GenericEventArgs<SyncJobItem>
|
|
|
- {
|
|
|
- Argument = job
|
|
|
-
|
|
|
- }, _logger);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public async Task<QueryResult<SyncJob>> GetJobs(SyncJobQuery query)
|
|
|
- {
|
|
|
- var result = _repo.GetJobs(query);
|
|
|
-
|
|
|
- foreach (var item in result.Items)
|
|
|
- {
|
|
|
- await FillMetadata(item).ConfigureAwait(false);
|
|
|
- }
|
|
|
-
|
|
|
- return result;
|
|
|
- }
|
|
|
-
|
|
|
- private async Task FillMetadata(SyncJob job)
|
|
|
- {
|
|
|
- var user = _userManager.GetUserById(job.UserId);
|
|
|
-
|
|
|
- if (user == null)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- var target = GetSyncTargets(job.UserId)
|
|
|
- .FirstOrDefault(i => string.Equals(i.Id, job.TargetId, StringComparison.OrdinalIgnoreCase));
|
|
|
-
|
|
|
- if (target != null)
|
|
|
- {
|
|
|
- job.TargetName = target.Name;
|
|
|
- }
|
|
|
-
|
|
|
- var item = job.RequestedItemIds
|
|
|
- .Select(_libraryManager.GetItemById)
|
|
|
- .FirstOrDefault(i => i != null);
|
|
|
-
|
|
|
- if (item == null)
|
|
|
- {
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- item = (await processor
|
|
|
- .GetItemsForSync(job.Category, job.ParentId, job.RequestedItemIds, user, job.UnwatchedOnly).ConfigureAwait(false))
|
|
|
- .FirstOrDefault();
|
|
|
- }
|
|
|
-
|
|
|
- if (item != null)
|
|
|
- {
|
|
|
- var hasSeries = item as IHasSeries;
|
|
|
- if (hasSeries != null)
|
|
|
- {
|
|
|
- job.ParentName = hasSeries.SeriesName;
|
|
|
- }
|
|
|
-
|
|
|
- var hasAlbumArtist = item as IHasAlbumArtist;
|
|
|
- if (hasAlbumArtist != null)
|
|
|
- {
|
|
|
- job.ParentName = hasAlbumArtist.AlbumArtists.FirstOrDefault();
|
|
|
- }
|
|
|
-
|
|
|
- var primaryImage = item.GetImageInfo(ImageType.Primary, 0);
|
|
|
- var itemWithImage = item;
|
|
|
-
|
|
|
- if (primaryImage == null)
|
|
|
- {
|
|
|
- var parentWithImage = item.GetParents().FirstOrDefault(i => i.HasImage(ImageType.Primary));
|
|
|
-
|
|
|
- if (parentWithImage != null)
|
|
|
- {
|
|
|
- itemWithImage = parentWithImage;
|
|
|
- primaryImage = parentWithImage.GetImageInfo(ImageType.Primary, 0);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (primaryImage != null)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- job.PrimaryImageTag = _imageProcessor.GetImageCacheTag(itemWithImage, ImageType.Primary);
|
|
|
- job.PrimaryImageItemId = itemWithImage.Id.ToString("N");
|
|
|
-
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- _logger.ErrorException("Error getting image info", ex);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private void FillMetadata(SyncJobItem jobItem)
|
|
|
- {
|
|
|
- var item = _libraryManager.GetItemById(jobItem.ItemId);
|
|
|
-
|
|
|
- if (item == null)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- var primaryImage = item.GetImageInfo(ImageType.Primary, 0);
|
|
|
- var itemWithImage = item;
|
|
|
-
|
|
|
- if (primaryImage == null)
|
|
|
- {
|
|
|
- var parentWithImage = item.GetParents().FirstOrDefault(i => i.HasImage(ImageType.Primary));
|
|
|
-
|
|
|
- if (parentWithImage != null)
|
|
|
- {
|
|
|
- itemWithImage = parentWithImage;
|
|
|
- primaryImage = parentWithImage.GetImageInfo(ImageType.Primary, 0);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (primaryImage != null)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- jobItem.PrimaryImageTag = _imageProcessor.GetImageCacheTag(itemWithImage, ImageType.Primary);
|
|
|
- jobItem.PrimaryImageItemId = itemWithImage.Id.ToString("N");
|
|
|
-
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- _logger.ErrorException("Error getting image info", ex);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public async Task CancelJob(string id)
|
|
|
- {
|
|
|
- var job = GetJob(id);
|
|
|
-
|
|
|
- if (job == null)
|
|
|
- {
|
|
|
- throw new ArgumentException("Job not found.");
|
|
|
- }
|
|
|
-
|
|
|
- await _repo.DeleteJob(id).ConfigureAwait(false);
|
|
|
-
|
|
|
- var path = GetSyncJobProcessor().GetTemporaryPath(id);
|
|
|
-
|
|
|
- try
|
|
|
- {
|
|
|
- _fileSystem.DeleteDirectory(path, true);
|
|
|
- }
|
|
|
- catch (IOException)
|
|
|
- {
|
|
|
-
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- _logger.ErrorException("Error deleting directory {0}", ex, path);
|
|
|
- }
|
|
|
-
|
|
|
- if (SyncJobCancelled != null)
|
|
|
- {
|
|
|
- EventHelper.FireEventIfNotNull(SyncJobCancelled, this, new GenericEventArgs<SyncJob>
|
|
|
- {
|
|
|
- Argument = job
|
|
|
-
|
|
|
- }, _logger);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public SyncJob GetJob(string id)
|
|
|
- {
|
|
|
- return _repo.GetJob(id);
|
|
|
- }
|
|
|
-
|
|
|
- public IEnumerable<SyncTarget> GetSyncTargets(string userId)
|
|
|
- {
|
|
|
- return _providers
|
|
|
- .SelectMany(i => GetSyncTargets(i, userId))
|
|
|
- .OrderBy(i => i.Name);
|
|
|
- }
|
|
|
-
|
|
|
- private IEnumerable<SyncTarget> GetSyncTargets(ISyncProvider provider)
|
|
|
- {
|
|
|
- return provider.GetAllSyncTargets().Select(i => new SyncTarget
|
|
|
- {
|
|
|
- Name = i.Name,
|
|
|
- Id = GetSyncTargetId(provider, i)
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- private IEnumerable<SyncTarget> GetSyncTargets(ISyncProvider provider, string userId)
|
|
|
- {
|
|
|
- return provider.GetSyncTargets(userId).Select(i => new SyncTarget
|
|
|
- {
|
|
|
- Name = i.Name,
|
|
|
- Id = GetSyncTargetId(provider, i)
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- private string GetSyncTargetId(ISyncProvider provider, SyncTarget target)
|
|
|
- {
|
|
|
- var hasUniqueId = provider as IHasUniqueTargetIds;
|
|
|
-
|
|
|
- if (hasUniqueId != null)
|
|
|
- {
|
|
|
- return target.Id;
|
|
|
- }
|
|
|
-
|
|
|
- return target.Id;
|
|
|
- //var providerId = GetSyncProviderId(provider);
|
|
|
- //return (providerId + "-" + target.Id).GetMD5().ToString("N");
|
|
|
- }
|
|
|
-
|
|
|
- private string GetSyncProviderId(ISyncProvider provider)
|
|
|
- {
|
|
|
- return provider.GetType().Name.GetMD5().ToString("N");
|
|
|
- }
|
|
|
-
|
|
|
- public bool SupportsSync(BaseItem item)
|
|
|
- {
|
|
|
- if (item == null)
|
|
|
- {
|
|
|
- throw new ArgumentNullException("item");
|
|
|
- }
|
|
|
-
|
|
|
- if (item is Playlist)
|
|
|
- {
|
|
|
- return true;
|
|
|
- }
|
|
|
-
|
|
|
- if (item is Person)
|
|
|
- {
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- if (item is Year)
|
|
|
- {
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- if (string.Equals(item.MediaType, MediaType.Video, StringComparison.OrdinalIgnoreCase) ||
|
|
|
- string.Equals(item.MediaType, MediaType.Audio, StringComparison.OrdinalIgnoreCase) ||
|
|
|
- string.Equals(item.MediaType, MediaType.Photo, StringComparison.OrdinalIgnoreCase) ||
|
|
|
- string.Equals(item.MediaType, MediaType.Game, StringComparison.OrdinalIgnoreCase) ||
|
|
|
- string.Equals(item.MediaType, MediaType.Book, StringComparison.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- if (item.LocationType == LocationType.Virtual)
|
|
|
- {
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- var video = item as Video;
|
|
|
- if (video != null)
|
|
|
- {
|
|
|
- if (video.IsPlaceHolder)
|
|
|
- {
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- if (video.IsShortcut)
|
|
|
- {
|
|
|
- return false;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (item.SourceType != SourceType.Library)
|
|
|
- {
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- return true;
|
|
|
- }
|
|
|
-
|
|
|
- if (item.SourceType == SourceType.Channel)
|
|
|
- {
|
|
|
- return BaseItem.ChannelManager.SupportsSync(item.ChannelId);
|
|
|
- }
|
|
|
-
|
|
|
- return item.LocationType == LocationType.FileSystem || item is Season;
|
|
|
- }
|
|
|
-
|
|
|
- private string GetDefaultName(BaseItem item)
|
|
|
- {
|
|
|
- return item.Name;
|
|
|
- }
|
|
|
-
|
|
|
- public async Task ReportSyncJobItemTransferred(string id)
|
|
|
- {
|
|
|
- var jobItem = _repo.GetJobItem(id);
|
|
|
-
|
|
|
- if (jobItem == null)
|
|
|
- {
|
|
|
- _logger.Debug("ReportSyncJobItemTransferred: SyncJobItem {0} doesn't exist anymore", id);
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- jobItem.Status = SyncJobItemStatus.Synced;
|
|
|
- jobItem.Progress = 100;
|
|
|
-
|
|
|
- await UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
|
|
|
-
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- await processor.UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
|
|
|
-
|
|
|
- if (!string.IsNullOrWhiteSpace(jobItem.TemporaryPath))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- _fileSystem.DeleteDirectory(jobItem.TemporaryPath, true);
|
|
|
- }
|
|
|
- catch (IOException)
|
|
|
- {
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- _logger.ErrorException("Error deleting temporary job file: {0}", ex, jobItem.OutputPath);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private SyncJobProcessor GetSyncJobProcessor()
|
|
|
- {
|
|
|
- return new SyncJobProcessor(_libraryManager, _repo, this, _logger, _userManager, _tvSeriesManager, _mediaEncoder(), _subtitleEncoder(), _config, _fileSystem, _mediaSourceManager());
|
|
|
- }
|
|
|
-
|
|
|
- public SyncJobItem GetJobItem(string id)
|
|
|
- {
|
|
|
- return _repo.GetJobItem(id);
|
|
|
- }
|
|
|
-
|
|
|
- public QueryResult<SyncJobItem> GetJobItems(SyncJobItemQuery query)
|
|
|
- {
|
|
|
- var result = _repo.GetJobItems(query);
|
|
|
-
|
|
|
- if (query.AddMetadata)
|
|
|
- {
|
|
|
- foreach (var item in result.Items)
|
|
|
- {
|
|
|
- FillMetadata(item);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return result;
|
|
|
- }
|
|
|
-
|
|
|
- private SyncedItem GetJobItemInfo(SyncJobItem jobItem)
|
|
|
- {
|
|
|
- var job = _repo.GetJob(jobItem.JobId);
|
|
|
-
|
|
|
- if (job == null)
|
|
|
- {
|
|
|
- _logger.Error("GetJobItemInfo job id {0} no longer exists", jobItem.JobId);
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- var libraryItem = _libraryManager.GetItemById(jobItem.ItemId);
|
|
|
-
|
|
|
- if (libraryItem == null)
|
|
|
- {
|
|
|
- _logger.Error("GetJobItemInfo library item with id {0} no longer exists", jobItem.ItemId);
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- var syncedItem = new SyncedItem
|
|
|
- {
|
|
|
- SyncJobId = jobItem.JobId,
|
|
|
- SyncJobItemId = jobItem.Id,
|
|
|
- ServerId = _appHost.SystemId,
|
|
|
- UserId = job.UserId,
|
|
|
- SyncJobName = job.Name,
|
|
|
- SyncJobDateCreated = job.DateCreated,
|
|
|
- AdditionalFiles = jobItem.AdditionalFiles.Select(i => new ItemFileInfo
|
|
|
- {
|
|
|
- ImageType = i.ImageType,
|
|
|
- Name = i.Name,
|
|
|
- Type = i.Type,
|
|
|
- Index = i.Index
|
|
|
-
|
|
|
- }).ToList()
|
|
|
- };
|
|
|
-
|
|
|
- var dtoOptions = new DtoOptions();
|
|
|
-
|
|
|
- // Remove some bloat
|
|
|
- dtoOptions.Fields.Remove(ItemFields.MediaStreams);
|
|
|
- dtoOptions.Fields.Remove(ItemFields.IndexOptions);
|
|
|
- dtoOptions.Fields.Remove(ItemFields.MediaSourceCount);
|
|
|
- dtoOptions.Fields.Remove(ItemFields.Path);
|
|
|
- dtoOptions.Fields.Remove(ItemFields.SeriesGenres);
|
|
|
- dtoOptions.Fields.Remove(ItemFields.Settings);
|
|
|
- dtoOptions.Fields.Remove(ItemFields.SyncInfo);
|
|
|
- dtoOptions.Fields.Remove(ItemFields.BasicSyncInfo);
|
|
|
-
|
|
|
- syncedItem.Item = _dtoService().GetBaseItemDto(libraryItem, dtoOptions);
|
|
|
-
|
|
|
- var mediaSource = jobItem.MediaSource;
|
|
|
-
|
|
|
- syncedItem.Item.MediaSources = new List<MediaSourceInfo>();
|
|
|
-
|
|
|
- syncedItem.OriginalFileName = Path.GetFileName(libraryItem.Path);
|
|
|
- if (string.IsNullOrWhiteSpace(syncedItem.OriginalFileName))
|
|
|
- {
|
|
|
- syncedItem.OriginalFileName = Path.GetFileName(mediaSource.Path);
|
|
|
- }
|
|
|
-
|
|
|
- // This will be null for items that are not audio/video
|
|
|
- if (mediaSource != null)
|
|
|
- {
|
|
|
- syncedItem.OriginalFileName = Path.ChangeExtension(syncedItem.OriginalFileName, Path.GetExtension(mediaSource.Path));
|
|
|
- syncedItem.Item.MediaSources.Add(mediaSource);
|
|
|
- }
|
|
|
- if (string.IsNullOrWhiteSpace(syncedItem.OriginalFileName))
|
|
|
- {
|
|
|
- syncedItem.OriginalFileName = libraryItem.Name;
|
|
|
- }
|
|
|
-
|
|
|
- return syncedItem;
|
|
|
- }
|
|
|
-
|
|
|
- public Task ReportOfflineAction(UserAction action)
|
|
|
- {
|
|
|
- switch (action.Type)
|
|
|
- {
|
|
|
- case UserActionType.PlayedItem:
|
|
|
- return ReportOfflinePlayedItem(action);
|
|
|
- default:
|
|
|
- throw new ArgumentException("Unexpected action type");
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private Task ReportOfflinePlayedItem(UserAction action)
|
|
|
- {
|
|
|
- var item = _libraryManager.GetItemById(action.ItemId);
|
|
|
- var userData = _userDataManager.GetUserData(action.UserId, item);
|
|
|
-
|
|
|
- userData.LastPlayedDate = action.Date;
|
|
|
- _userDataManager.UpdatePlayState(item, userData, action.PositionTicks);
|
|
|
-
|
|
|
- return _userDataManager.SaveUserData(new Guid(action.UserId), item, userData, UserDataSaveReason.Import, CancellationToken.None);
|
|
|
- }
|
|
|
-
|
|
|
- public async Task<List<SyncedItem>> GetReadySyncItems(string targetId)
|
|
|
- {
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- await processor.SyncJobItems(targetId, false, new Progress<double>(), CancellationToken.None).ConfigureAwait(false);
|
|
|
-
|
|
|
- var jobItemResult = GetJobItems(new SyncJobItemQuery
|
|
|
- {
|
|
|
- TargetId = targetId,
|
|
|
- Statuses = new[]
|
|
|
- {
|
|
|
- SyncJobItemStatus.ReadyToTransfer,
|
|
|
- SyncJobItemStatus.Transferring
|
|
|
- }
|
|
|
- });
|
|
|
-
|
|
|
- var readyItems = jobItemResult.Items
|
|
|
- .Select(GetJobItemInfo)
|
|
|
- .Where(i => i != null)
|
|
|
- .ToList();
|
|
|
-
|
|
|
- _logger.Debug("Returning {0} ready sync items for targetId {1}", readyItems.Count, targetId);
|
|
|
-
|
|
|
- return readyItems;
|
|
|
- }
|
|
|
-
|
|
|
- public async Task<SyncDataResponse> SyncData(SyncDataRequest request)
|
|
|
- {
|
|
|
- if (request.SyncJobItemIds != null)
|
|
|
- {
|
|
|
- return await SyncDataUsingSyncJobItemIds(request).ConfigureAwait(false);
|
|
|
- }
|
|
|
-
|
|
|
- var jobItemResult = GetJobItems(new SyncJobItemQuery
|
|
|
- {
|
|
|
- TargetId = request.TargetId,
|
|
|
- Statuses = new[] { SyncJobItemStatus.Synced }
|
|
|
- });
|
|
|
-
|
|
|
- var response = new SyncDataResponse();
|
|
|
-
|
|
|
- foreach (var jobItem in jobItemResult.Items)
|
|
|
- {
|
|
|
- var requiresSaving = false;
|
|
|
- var removeFromDevice = false;
|
|
|
-
|
|
|
- if (request.LocalItemIds.Contains(jobItem.ItemId, StringComparer.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- var libraryItem = _libraryManager.GetItemById(jobItem.ItemId);
|
|
|
-
|
|
|
- var job = _repo.GetJob(jobItem.JobId);
|
|
|
- var user = _userManager.GetUserById(job.UserId);
|
|
|
-
|
|
|
- if (jobItem.IsMarkedForRemoval)
|
|
|
- {
|
|
|
- // Tell the device to remove it since it has been marked for removal
|
|
|
- _logger.Info("Adding ItemIdsToRemove {0} because IsMarkedForRemoval is set.", jobItem.ItemId);
|
|
|
- removeFromDevice = true;
|
|
|
- }
|
|
|
- else if (user == null)
|
|
|
- {
|
|
|
- // Tell the device to remove it since the user is gone now
|
|
|
- _logger.Info("Adding ItemIdsToRemove {0} because the user is no longer valid.", jobItem.ItemId);
|
|
|
- removeFromDevice = true;
|
|
|
- }
|
|
|
- else if (!IsLibraryItemAvailable(libraryItem))
|
|
|
- {
|
|
|
- // Tell the device to remove it since it's no longer available
|
|
|
- _logger.Info("Adding ItemIdsToRemove {0} because it is no longer available.", jobItem.ItemId);
|
|
|
- removeFromDevice = true;
|
|
|
- }
|
|
|
- else if (job.UnwatchedOnly)
|
|
|
- {
|
|
|
- if (libraryItem is Video && libraryItem.IsPlayed(user))
|
|
|
- {
|
|
|
- // Tell the device to remove it since it has been played
|
|
|
- _logger.Info("Adding ItemIdsToRemove {0} because it has been marked played.", jobItem.ItemId);
|
|
|
- removeFromDevice = true;
|
|
|
- }
|
|
|
- }
|
|
|
- else if (libraryItem != null && libraryItem.DateModified.Ticks != jobItem.ItemDateModifiedTicks && jobItem.ItemDateModifiedTicks > 0)
|
|
|
- {
|
|
|
- _logger.Info("Setting status to Queued for {0} because the media has been modified since the original sync.", jobItem.ItemId);
|
|
|
- jobItem.Status = SyncJobItemStatus.Queued;
|
|
|
- jobItem.Progress = 0;
|
|
|
- requiresSaving = true;
|
|
|
- }
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- // Content is no longer on the device
|
|
|
- if (jobItem.IsMarkedForRemoval)
|
|
|
- {
|
|
|
- jobItem.Status = SyncJobItemStatus.RemovedFromDevice;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- _logger.Info("Setting status to Queued for {0} because it is no longer on the device.", jobItem.ItemId);
|
|
|
- jobItem.Status = SyncJobItemStatus.Queued;
|
|
|
- jobItem.Progress = 0;
|
|
|
- }
|
|
|
- requiresSaving = true;
|
|
|
- }
|
|
|
-
|
|
|
- if (removeFromDevice)
|
|
|
- {
|
|
|
- response.ItemIdsToRemove.Add(jobItem.ItemId);
|
|
|
- jobItem.IsMarkedForRemoval = true;
|
|
|
- requiresSaving = true;
|
|
|
- }
|
|
|
-
|
|
|
- if (requiresSaving)
|
|
|
- {
|
|
|
- await UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- // Now check each item that's on the device
|
|
|
- foreach (var itemId in request.LocalItemIds)
|
|
|
- {
|
|
|
- // See if it's already marked for removal
|
|
|
- if (response.ItemIdsToRemove.Contains(itemId, StringComparer.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- continue;
|
|
|
- }
|
|
|
-
|
|
|
- // If there isn't a sync job for this item, mark it for removal
|
|
|
- if (!jobItemResult.Items.Any(i => string.Equals(itemId, i.ItemId, StringComparison.OrdinalIgnoreCase)))
|
|
|
- {
|
|
|
- response.ItemIdsToRemove.Add(itemId);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- response.ItemIdsToRemove = response.ItemIdsToRemove.Distinct(StringComparer.OrdinalIgnoreCase).ToList();
|
|
|
-
|
|
|
- var itemsOnDevice = request.LocalItemIds
|
|
|
- .Except(response.ItemIdsToRemove)
|
|
|
- .ToList();
|
|
|
-
|
|
|
- SetUserAccess(request, response, itemsOnDevice);
|
|
|
-
|
|
|
- return response;
|
|
|
- }
|
|
|
-
|
|
|
- private async Task<SyncDataResponse> SyncDataUsingSyncJobItemIds(SyncDataRequest request)
|
|
|
- {
|
|
|
- var jobItemResult = GetJobItems(new SyncJobItemQuery
|
|
|
- {
|
|
|
- TargetId = request.TargetId,
|
|
|
- Statuses = new[] { SyncJobItemStatus.Synced }
|
|
|
- });
|
|
|
-
|
|
|
- var response = new SyncDataResponse();
|
|
|
-
|
|
|
- foreach (var jobItem in jobItemResult.Items)
|
|
|
- {
|
|
|
- var requiresSaving = false;
|
|
|
- var removeFromDevice = false;
|
|
|
-
|
|
|
- if (request.SyncJobItemIds.Contains(jobItem.Id, StringComparer.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- var libraryItem = _libraryManager.GetItemById(jobItem.ItemId);
|
|
|
-
|
|
|
- var job = _repo.GetJob(jobItem.JobId);
|
|
|
- var user = _userManager.GetUserById(job.UserId);
|
|
|
-
|
|
|
- if (jobItem.IsMarkedForRemoval)
|
|
|
- {
|
|
|
- // Tell the device to remove it since it has been marked for removal
|
|
|
- _logger.Info("Adding ItemIdsToRemove {0} because IsMarkedForRemoval is set.", jobItem.Id);
|
|
|
- removeFromDevice = true;
|
|
|
- }
|
|
|
- else if (user == null)
|
|
|
- {
|
|
|
- // Tell the device to remove it since the user is gone now
|
|
|
- _logger.Info("Adding ItemIdsToRemove {0} because the user is no longer valid.", jobItem.Id);
|
|
|
- removeFromDevice = true;
|
|
|
- }
|
|
|
- else if (!IsLibraryItemAvailable(libraryItem))
|
|
|
- {
|
|
|
- // Tell the device to remove it since it's no longer available
|
|
|
- _logger.Info("Adding ItemIdsToRemove {0} because it is no longer available.", jobItem.Id);
|
|
|
- removeFromDevice = true;
|
|
|
- }
|
|
|
- else if (job.UnwatchedOnly)
|
|
|
- {
|
|
|
- if (libraryItem is Video && libraryItem.IsPlayed(user))
|
|
|
- {
|
|
|
- // Tell the device to remove it since it has been played
|
|
|
- _logger.Info("Adding ItemIdsToRemove {0} because it has been marked played.", jobItem.Id);
|
|
|
- removeFromDevice = true;
|
|
|
- }
|
|
|
- }
|
|
|
- else if (libraryItem != null && libraryItem.DateModified.Ticks != jobItem.ItemDateModifiedTicks && jobItem.ItemDateModifiedTicks > 0)
|
|
|
- {
|
|
|
- _logger.Info("Setting status to Queued for {0} because the media has been modified since the original sync.", jobItem.ItemId);
|
|
|
- jobItem.Status = SyncJobItemStatus.Queued;
|
|
|
- jobItem.Progress = 0;
|
|
|
- requiresSaving = true;
|
|
|
- }
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- // Content is no longer on the device
|
|
|
- if (jobItem.IsMarkedForRemoval)
|
|
|
- {
|
|
|
- jobItem.Status = SyncJobItemStatus.RemovedFromDevice;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- _logger.Info("Setting status to Queued for {0} because it is no longer on the device.", jobItem.Id);
|
|
|
- jobItem.Status = SyncJobItemStatus.Queued;
|
|
|
- jobItem.Progress = 0;
|
|
|
- }
|
|
|
- requiresSaving = true;
|
|
|
- }
|
|
|
-
|
|
|
- if (removeFromDevice)
|
|
|
- {
|
|
|
- response.ItemIdsToRemove.Add(jobItem.Id);
|
|
|
- jobItem.IsMarkedForRemoval = true;
|
|
|
- requiresSaving = true;
|
|
|
- }
|
|
|
-
|
|
|
- if (requiresSaving)
|
|
|
- {
|
|
|
- await UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- // Now check each item that's on the device
|
|
|
- foreach (var syncJobItemId in request.SyncJobItemIds)
|
|
|
- {
|
|
|
- // See if it's already marked for removal
|
|
|
- if (response.ItemIdsToRemove.Contains(syncJobItemId, StringComparer.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- continue;
|
|
|
- }
|
|
|
-
|
|
|
- // If there isn't a sync job for this item, mark it for removal
|
|
|
- if (!jobItemResult.Items.Any(i => string.Equals(syncJobItemId, i.Id, StringComparison.OrdinalIgnoreCase)))
|
|
|
- {
|
|
|
- response.ItemIdsToRemove.Add(syncJobItemId);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- response.ItemIdsToRemove = response.ItemIdsToRemove.Distinct(StringComparer.OrdinalIgnoreCase).ToList();
|
|
|
-
|
|
|
- return response;
|
|
|
- }
|
|
|
-
|
|
|
- private void SetUserAccess(SyncDataRequest request, SyncDataResponse response, List<string> itemIds)
|
|
|
- {
|
|
|
- var users = request.OfflineUserIds
|
|
|
- .Select(_userManager.GetUserById)
|
|
|
- .Where(i => i != null)
|
|
|
- .ToList();
|
|
|
-
|
|
|
- foreach (var itemId in itemIds)
|
|
|
- {
|
|
|
- var item = _libraryManager.GetItemById(itemId);
|
|
|
-
|
|
|
- if (item != null)
|
|
|
- {
|
|
|
- response.ItemUserAccess[itemId] = users
|
|
|
- .Where(i => IsUserVisible(item, i))
|
|
|
- .Select(i => i.Id.ToString("N"))
|
|
|
- .OrderBy(i => i)
|
|
|
- .ToList();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private bool IsUserVisible(BaseItem item, User user)
|
|
|
- {
|
|
|
- return item.IsVisibleStandalone(user);
|
|
|
- }
|
|
|
-
|
|
|
- private bool IsLibraryItemAvailable(BaseItem item)
|
|
|
- {
|
|
|
- if (item == null)
|
|
|
- {
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- return true;
|
|
|
- }
|
|
|
-
|
|
|
- public async Task ReEnableJobItem(string id)
|
|
|
- {
|
|
|
- var jobItem = _repo.GetJobItem(id);
|
|
|
-
|
|
|
- if (jobItem.Status != SyncJobItemStatus.Failed && jobItem.Status != SyncJobItemStatus.Cancelled)
|
|
|
- {
|
|
|
- throw new ArgumentException("Operation is not valid for this job item");
|
|
|
- }
|
|
|
-
|
|
|
- jobItem.Status = SyncJobItemStatus.Queued;
|
|
|
- jobItem.Progress = 0;
|
|
|
- jobItem.IsMarkedForRemoval = false;
|
|
|
-
|
|
|
- await UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
|
|
|
-
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- await processor.UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
|
|
|
- }
|
|
|
-
|
|
|
- public async Task CancelItems(string targetId, IEnumerable<string> itemIds)
|
|
|
- {
|
|
|
- foreach (var item in itemIds)
|
|
|
- {
|
|
|
- var syncJobItemResult = GetJobItems(new SyncJobItemQuery
|
|
|
- {
|
|
|
- AddMetadata = false,
|
|
|
- ItemId = item,
|
|
|
- TargetId = targetId,
|
|
|
- Statuses = new[] { SyncJobItemStatus.Queued, SyncJobItemStatus.ReadyToTransfer, SyncJobItemStatus.Converting, SyncJobItemStatus.Synced, SyncJobItemStatus.Failed }
|
|
|
- });
|
|
|
-
|
|
|
- foreach (var jobItem in syncJobItemResult.Items)
|
|
|
- {
|
|
|
- await CancelJobItem(jobItem.Id).ConfigureAwait(false);
|
|
|
- }
|
|
|
-
|
|
|
- var syncJobResult = await GetJobs(new SyncJobQuery
|
|
|
- {
|
|
|
- ItemId = item,
|
|
|
- TargetId = targetId
|
|
|
-
|
|
|
- }).ConfigureAwait(false);
|
|
|
-
|
|
|
- foreach (var job in syncJobResult.Items)
|
|
|
- {
|
|
|
- await CancelJob(job.Id).ConfigureAwait(false);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public async Task CancelJobItem(string id)
|
|
|
- {
|
|
|
- var jobItem = _repo.GetJobItem(id);
|
|
|
-
|
|
|
- jobItem.Status = SyncJobItemStatus.Cancelled;
|
|
|
-
|
|
|
- jobItem.Progress = 0;
|
|
|
- jobItem.IsMarkedForRemoval = true;
|
|
|
-
|
|
|
- await UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
|
|
|
-
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- await processor.UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
|
|
|
-
|
|
|
- var path = processor.GetTemporaryPath(jobItem);
|
|
|
-
|
|
|
- try
|
|
|
- {
|
|
|
- _fileSystem.DeleteDirectory(path, true);
|
|
|
- }
|
|
|
- catch (IOException)
|
|
|
- {
|
|
|
-
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- _logger.ErrorException("Error deleting directory {0}", ex, path);
|
|
|
- }
|
|
|
-
|
|
|
- var jobItemsResult = GetJobItems(new SyncJobItemQuery
|
|
|
- {
|
|
|
- AddMetadata = false,
|
|
|
- JobId = jobItem.JobId,
|
|
|
- Limit = 0,
|
|
|
- Statuses = new[] { SyncJobItemStatus.Converting, SyncJobItemStatus.Queued, SyncJobItemStatus.ReadyToTransfer, SyncJobItemStatus.Synced, SyncJobItemStatus.Transferring }
|
|
|
- });
|
|
|
-
|
|
|
- if (jobItemsResult.TotalRecordCount == 0)
|
|
|
- {
|
|
|
- await CancelJob(jobItem.JobId).ConfigureAwait(false);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public Task MarkJobItemForRemoval(string id)
|
|
|
- {
|
|
|
- return CancelJobItem(id);
|
|
|
- }
|
|
|
-
|
|
|
- public async Task UnmarkJobItemForRemoval(string id)
|
|
|
- {
|
|
|
- var jobItem = _repo.GetJobItem(id);
|
|
|
-
|
|
|
- if (jobItem.Status != SyncJobItemStatus.Synced)
|
|
|
- {
|
|
|
- throw new ArgumentException("Operation is not valid for this job item");
|
|
|
- }
|
|
|
-
|
|
|
- jobItem.IsMarkedForRemoval = false;
|
|
|
-
|
|
|
- await UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
|
|
|
-
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- await processor.UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
|
|
|
- }
|
|
|
-
|
|
|
- public async Task ReportSyncJobItemTransferBeginning(string id)
|
|
|
- {
|
|
|
- var jobItem = _repo.GetJobItem(id);
|
|
|
-
|
|
|
- jobItem.Status = SyncJobItemStatus.Transferring;
|
|
|
-
|
|
|
- await UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
|
|
|
-
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- await processor.UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
|
|
|
- }
|
|
|
-
|
|
|
- public async Task ReportSyncJobItemTransferFailed(string id)
|
|
|
- {
|
|
|
- var jobItem = _repo.GetJobItem(id);
|
|
|
-
|
|
|
- jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
|
|
|
-
|
|
|
- await UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
|
|
|
-
|
|
|
- var processor = GetSyncJobProcessor();
|
|
|
-
|
|
|
- await processor.UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
|
|
|
- }
|
|
|
-
|
|
|
- public Dictionary<string, SyncedItemProgress> GetSyncedItemProgresses(SyncJobItemQuery query)
|
|
|
- {
|
|
|
- return _repo.GetSyncedItemProgresses(query);
|
|
|
- }
|
|
|
-
|
|
|
- public SyncJobOptions GetAudioOptions(SyncJobItem jobItem, SyncJob job)
|
|
|
- {
|
|
|
- var options = GetSyncJobOptions(jobItem.TargetId, null, null);
|
|
|
-
|
|
|
- if (job.Bitrate.HasValue)
|
|
|
- {
|
|
|
- options.DeviceProfile.MaxStaticBitrate = job.Bitrate.Value;
|
|
|
- }
|
|
|
-
|
|
|
- return options;
|
|
|
- }
|
|
|
-
|
|
|
- public ISyncProvider GetSyncProvider(SyncJobItem jobItem)
|
|
|
- {
|
|
|
- foreach (var provider in _providers)
|
|
|
- {
|
|
|
- foreach (var target in GetSyncTargets(provider))
|
|
|
- {
|
|
|
- if (string.Equals(target.Id, jobItem.TargetId, StringComparison.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- return provider;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- public SyncJobOptions GetVideoOptions(SyncJobItem jobItem, SyncJob job)
|
|
|
- {
|
|
|
- var options = GetSyncJobOptions(jobItem.TargetId, job.Profile, job.Quality);
|
|
|
-
|
|
|
- if (job.Bitrate.HasValue)
|
|
|
- {
|
|
|
- options.DeviceProfile.MaxStaticBitrate = job.Bitrate.Value;
|
|
|
- }
|
|
|
-
|
|
|
- return options;
|
|
|
- }
|
|
|
-
|
|
|
- private SyncJobOptions GetSyncJobOptions(string targetId, string profile, string quality)
|
|
|
- {
|
|
|
- foreach (var provider in _providers)
|
|
|
- {
|
|
|
- foreach (var target in GetSyncTargets(provider))
|
|
|
- {
|
|
|
- if (string.Equals(target.Id, targetId, StringComparison.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- return GetSyncJobOptions(provider, target, profile, quality);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return GetDefaultSyncJobOptions(profile, quality);
|
|
|
- }
|
|
|
-
|
|
|
- private SyncJobOptions GetSyncJobOptions(ISyncProvider provider, SyncTarget target, string profile, string quality)
|
|
|
- {
|
|
|
- var hasProfile = provider as IHasSyncQuality;
|
|
|
-
|
|
|
- if (hasProfile != null)
|
|
|
- {
|
|
|
- return hasProfile.GetSyncJobOptions(target, profile, quality);
|
|
|
- }
|
|
|
-
|
|
|
- return GetDefaultSyncJobOptions(profile, quality);
|
|
|
- }
|
|
|
-
|
|
|
- private SyncJobOptions GetDefaultSyncJobOptions(string profile, string quality)
|
|
|
- {
|
|
|
- var supportsAc3 = string.Equals(profile, "general", StringComparison.OrdinalIgnoreCase);
|
|
|
-
|
|
|
- var deviceProfile = new CloudSyncProfile(supportsAc3, false);
|
|
|
- deviceProfile.MaxStaticBitrate = SyncHelper.AdjustBitrate(deviceProfile.MaxStaticBitrate, quality);
|
|
|
-
|
|
|
- return new SyncJobOptions
|
|
|
- {
|
|
|
- DeviceProfile = deviceProfile,
|
|
|
- IsConverting = IsConverting(profile, quality)
|
|
|
- };
|
|
|
- }
|
|
|
-
|
|
|
- private bool IsConverting(string profile, string quality)
|
|
|
- {
|
|
|
- return !string.Equals(profile, "original", StringComparison.OrdinalIgnoreCase);
|
|
|
- }
|
|
|
-
|
|
|
- public IEnumerable<SyncQualityOption> GetQualityOptions(string targetId)
|
|
|
- {
|
|
|
- return GetQualityOptions(targetId, null);
|
|
|
- }
|
|
|
-
|
|
|
- public IEnumerable<SyncQualityOption> GetQualityOptions(string targetId, User user)
|
|
|
- {
|
|
|
- foreach (var provider in _providers)
|
|
|
- {
|
|
|
- foreach (var target in GetSyncTargets(provider))
|
|
|
- {
|
|
|
- if (string.Equals(target.Id, targetId, StringComparison.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- return GetQualityOptions(provider, target, user);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return new List<SyncQualityOption>();
|
|
|
- }
|
|
|
-
|
|
|
- private IEnumerable<SyncQualityOption> GetQualityOptions(ISyncProvider provider, SyncTarget target, User user)
|
|
|
- {
|
|
|
- var hasQuality = provider as IHasSyncQuality;
|
|
|
- if (hasQuality != null)
|
|
|
- {
|
|
|
- var options = hasQuality.GetQualityOptions(target);
|
|
|
-
|
|
|
- if (user != null && !user.Policy.EnableSyncTranscoding)
|
|
|
- {
|
|
|
- options = options.Where(i => i.IsOriginalQuality);
|
|
|
- }
|
|
|
-
|
|
|
- return options;
|
|
|
- }
|
|
|
-
|
|
|
- // Default options for providers that don't override
|
|
|
- return new List<SyncQualityOption>
|
|
|
- {
|
|
|
- new SyncQualityOption
|
|
|
- {
|
|
|
- Name = "High",
|
|
|
- Id = "high",
|
|
|
- IsDefault = true
|
|
|
- },
|
|
|
- new SyncQualityOption
|
|
|
- {
|
|
|
- Name = "Medium",
|
|
|
- Id = "medium"
|
|
|
- },
|
|
|
- new SyncQualityOption
|
|
|
- {
|
|
|
- Name = "Low",
|
|
|
- Id = "low"
|
|
|
- },
|
|
|
- new SyncQualityOption
|
|
|
- {
|
|
|
- Name = "Custom",
|
|
|
- Id = "custom"
|
|
|
- }
|
|
|
- };
|
|
|
- }
|
|
|
-
|
|
|
- public IEnumerable<SyncProfileOption> GetProfileOptions(string targetId, User user)
|
|
|
- {
|
|
|
- foreach (var provider in _providers)
|
|
|
- {
|
|
|
- foreach (var target in GetSyncTargets(provider))
|
|
|
- {
|
|
|
- if (string.Equals(target.Id, targetId, StringComparison.OrdinalIgnoreCase))
|
|
|
- {
|
|
|
- return GetProfileOptions(provider, target, user);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return new List<SyncProfileOption>();
|
|
|
- }
|
|
|
-
|
|
|
- public IEnumerable<SyncProfileOption> GetProfileOptions(string targetId)
|
|
|
- {
|
|
|
- return GetProfileOptions(targetId, null);
|
|
|
- }
|
|
|
-
|
|
|
- private IEnumerable<SyncProfileOption> GetProfileOptions(ISyncProvider provider, SyncTarget target, User user)
|
|
|
- {
|
|
|
- var hasQuality = provider as IHasSyncQuality;
|
|
|
- if (hasQuality != null)
|
|
|
- {
|
|
|
- return hasQuality.GetProfileOptions(target);
|
|
|
- }
|
|
|
-
|
|
|
- var list = new List<SyncProfileOption>();
|
|
|
-
|
|
|
- list.Add(new SyncProfileOption
|
|
|
- {
|
|
|
- Name = "Original",
|
|
|
- Id = "Original",
|
|
|
- Description = "Syncs original files as-is.",
|
|
|
- EnableQualityOptions = false
|
|
|
- });
|
|
|
-
|
|
|
- if (user == null || user.Policy.EnableSyncTranscoding)
|
|
|
- {
|
|
|
- list.Add(new SyncProfileOption
|
|
|
- {
|
|
|
- Name = "Baseline",
|
|
|
- Id = "baseline",
|
|
|
- Description = "Designed for compatibility with all devices, including web browsers. Targets H264/AAC video and MP3 audio."
|
|
|
- });
|
|
|
-
|
|
|
- list.Add(new SyncProfileOption
|
|
|
- {
|
|
|
- Name = "General",
|
|
|
- Id = "general",
|
|
|
- Description = "Designed for compatibility with Chromecast, Roku, Smart TV's, and other similar devices. Targets H264/AAC/AC3 video and MP3 audio.",
|
|
|
- IsDefault = true
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- return list;
|
|
|
- }
|
|
|
-
|
|
|
- protected internal void OnConversionComplete(SyncJobItem item)
|
|
|
- {
|
|
|
- var syncProvider = GetSyncProvider(item);
|
|
|
- if (syncProvider is AppSyncProvider)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- _taskManager.QueueIfNotRunning<ServerSyncScheduledTask>();
|
|
|
- }
|
|
|
- }
|
|
|
-}
|