jellyfin/MediaBrowser.Server.Implementations/Sync/SyncJobProcessor.cs

974 lines
38 KiB
C#
Raw Normal View History

2015-01-21 03:54:45 +00:00
using MediaBrowser.Common.Configuration;
2015-01-17 04:29:53 +00:00
using MediaBrowser.Common.IO;
using MediaBrowser.Common.Progress;
2015-01-05 06:00:13 +00:00
using MediaBrowser.Controller.Entities;
2014-12-13 03:56:30 +00:00
using MediaBrowser.Controller.Entities.Audio;
2015-02-07 05:28:38 +00:00
using MediaBrowser.Controller.Entities.TV;
2014-12-11 06:20:28 +00:00
using MediaBrowser.Controller.Library;
2015-01-02 05:36:27 +00:00
using MediaBrowser.Controller.MediaEncoding;
2014-12-11 06:20:28 +00:00
using MediaBrowser.Controller.Sync;
2014-12-30 16:36:49 +00:00
using MediaBrowser.Controller.TV;
2014-12-13 03:56:30 +00:00
using MediaBrowser.Model.Dlna;
using MediaBrowser.Model.Dto;
2014-12-30 16:36:49 +00:00
using MediaBrowser.Model.Entities;
2014-12-13 03:56:30 +00:00
using MediaBrowser.Model.Logging;
using MediaBrowser.Model.MediaInfo;
2014-12-30 16:36:49 +00:00
using MediaBrowser.Model.Querying;
2014-12-13 03:56:30 +00:00
using MediaBrowser.Model.Session;
2014-12-11 06:20:28 +00:00
using MediaBrowser.Model.Sync;
using MoreLinq;
using System;
using System.Collections.Generic;
2016-02-21 17:22:31 +00:00
using System.Globalization;
2015-01-17 04:29:53 +00:00
using System.IO;
2014-12-11 06:20:28 +00:00
using System.Linq;
2014-12-13 03:56:30 +00:00
using System.Threading;
2014-12-11 06:20:28 +00:00
using System.Threading.Tasks;
2015-10-04 04:23:11 +00:00
using CommonIO;
2014-12-11 06:20:28 +00:00
namespace MediaBrowser.Server.Implementations.Sync
{
public class SyncJobProcessor
{
private readonly ILibraryManager _libraryManager;
private readonly ISyncRepository _syncRepo;
2015-02-05 03:01:37 +00:00
private readonly SyncManager _syncManager;
2014-12-13 03:56:30 +00:00
private readonly ILogger _logger;
private readonly IUserManager _userManager;
2014-12-30 16:36:49 +00:00
private readonly ITVSeriesManager _tvSeriesManager;
2015-01-05 00:49:22 +00:00
private readonly IMediaEncoder _mediaEncoder;
2015-01-16 20:54:37 +00:00
private readonly ISubtitleEncoder _subtitleEncoder;
2015-01-17 04:29:53 +00:00
private readonly IConfigurationManager _config;
private readonly IFileSystem _fileSystem;
2015-03-07 22:43:53 +00:00
private readonly IMediaSourceManager _mediaSourceManager;
2014-12-11 06:20:28 +00:00
2015-03-07 22:43:53 +00:00
public SyncJobProcessor(ILibraryManager libraryManager, ISyncRepository syncRepo, SyncManager syncManager, ILogger logger, IUserManager userManager, ITVSeriesManager tvSeriesManager, IMediaEncoder mediaEncoder, ISubtitleEncoder subtitleEncoder, IConfigurationManager config, IFileSystem fileSystem, IMediaSourceManager mediaSourceManager)
2014-12-11 06:20:28 +00:00
{
_libraryManager = libraryManager;
_syncRepo = syncRepo;
2014-12-13 03:56:30 +00:00
_syncManager = syncManager;
_logger = logger;
_userManager = userManager;
2014-12-30 16:36:49 +00:00
_tvSeriesManager = tvSeriesManager;
2015-01-05 00:49:22 +00:00
_mediaEncoder = mediaEncoder;
2015-01-16 20:54:37 +00:00
_subtitleEncoder = subtitleEncoder;
2015-01-17 04:29:53 +00:00
_config = config;
_fileSystem = fileSystem;
2015-03-07 22:43:53 +00:00
_mediaSourceManager = mediaSourceManager;
2014-12-11 06:20:28 +00:00
}
public async Task EnsureJobItems(SyncJob job)
{
2014-12-13 03:56:30 +00:00
var user = _userManager.GetUserById(job.UserId);
2014-12-11 06:20:28 +00:00
2014-12-13 03:56:30 +00:00
if (user == null)
{
throw new InvalidOperationException("Cannot proceed with sync because user no longer exists.");
}
2014-12-30 16:36:49 +00:00
var items = (await GetItemsForSync(job.Category, job.ParentId, job.RequestedItemIds, user, job.UnwatchedOnly).ConfigureAwait(false))
2014-12-11 06:20:28 +00:00
.ToList();
2015-04-04 01:24:49 +00:00
var jobItems = _syncManager.GetJobItems(new SyncJobItemQuery
2014-12-13 03:56:30 +00:00
{
2015-04-04 01:24:49 +00:00
JobId = job.Id,
AddMetadata = false
2014-12-13 03:56:30 +00:00
}).Items.ToList();
2014-12-11 06:20:28 +00:00
foreach (var item in items)
{
2014-12-17 05:30:31 +00:00
// Respect ItemLimit, if set
if (job.ItemLimit.HasValue)
{
2014-12-30 19:16:01 +00:00
if (jobItems.Count(j => j.Status != SyncJobItemStatus.RemovedFromDevice && j.Status != SyncJobItemStatus.Failed) >= job.ItemLimit.Value)
2014-12-17 05:30:31 +00:00
{
break;
}
}
2014-12-11 06:20:28 +00:00
var itemId = item.Id.ToString("N");
var jobItem = jobItems.FirstOrDefault(i => string.Equals(i.ItemId, itemId, StringComparison.OrdinalIgnoreCase));
if (jobItem != null)
{
continue;
}
2015-01-24 22:33:26 +00:00
var index = jobItems.Count == 0 ?
2015-01-23 06:15:15 +00:00
0 :
2016-03-27 21:11:27 +00:00
jobItems.Select(i => i.JobItemIndex).Max() + 1;
2015-01-23 06:15:15 +00:00
2014-12-11 06:20:28 +00:00
jobItem = new SyncJobItem
{
Id = Guid.NewGuid().ToString("N"),
ItemId = itemId,
2014-12-31 06:24:49 +00:00
ItemName = GetSyncJobItemName(item),
2014-12-11 06:20:28 +00:00
JobId = job.Id,
2014-12-13 03:56:30 +00:00
TargetId = job.TargetId,
2015-01-23 06:15:15 +00:00
DateCreated = DateTime.UtcNow,
JobItemIndex = index
2014-12-11 06:20:28 +00:00
};
await _syncRepo.Create(jobItem).ConfigureAwait(false);
2015-02-05 03:01:37 +00:00
_syncManager.OnSyncJobItemCreated(jobItem);
2014-12-11 06:20:28 +00:00
2014-12-13 03:56:30 +00:00
jobItems.Add(jobItem);
}
jobItems = jobItems
.OrderBy(i => i.DateCreated)
.ToList();
await UpdateJobStatus(job, jobItems).ConfigureAwait(false);
}
2014-12-31 06:24:49 +00:00
private string GetSyncJobItemName(BaseItem item)
{
2016-02-21 17:22:31 +00:00
var name = item.Name;
var episode = item as Episode;
if (episode != null)
{
if (episode.IndexNumber.HasValue)
{
name = "E" + episode.IndexNumber.Value.ToString(CultureInfo.InvariantCulture) + " - " + name;
}
if (episode.ParentIndexNumber.HasValue)
{
name = "S" + episode.ParentIndexNumber.Value.ToString(CultureInfo.InvariantCulture) + ", " + name;
}
}
return name;
2014-12-31 06:24:49 +00:00
}
2014-12-17 05:30:31 +00:00
public Task UpdateJobStatus(string id)
{
var job = _syncRepo.GetJob(id);
2016-04-27 20:29:27 +00:00
if (job == null)
{
return Task.FromResult(true);
}
2015-04-04 01:24:49 +00:00
var result = _syncManager.GetJobItems(new SyncJobItemQuery
2014-12-13 03:56:30 +00:00
{
2015-04-04 01:24:49 +00:00
JobId = job.Id,
AddMetadata = false
2014-12-13 03:56:30 +00:00
});
return UpdateJobStatus(job, result.Items.ToList());
}
2015-02-04 20:16:23 +00:00
private async Task UpdateJobStatus(SyncJob job, List<SyncJobItem> jobItems)
2014-12-13 03:56:30 +00:00
{
job.ItemCount = jobItems.Count;
double pct = 0;
foreach (var item in jobItems)
{
2015-02-03 07:08:49 +00:00
if (item.Status == SyncJobItemStatus.Failed || item.Status == SyncJobItemStatus.Synced || item.Status == SyncJobItemStatus.RemovedFromDevice || item.Status == SyncJobItemStatus.Cancelled)
2014-12-13 03:56:30 +00:00
{
pct += 100;
}
else
{
pct += item.Progress ?? 0;
}
}
if (job.ItemCount > 0)
{
pct /= job.ItemCount;
job.Progress = pct;
}
else
{
job.Progress = null;
}
2015-10-02 06:14:04 +00:00
if (jobItems.Any(i => i.Status == SyncJobItemStatus.Transferring))
2015-02-04 19:13:00 +00:00
{
2015-10-02 06:14:04 +00:00
job.Status = SyncJobStatus.Transferring;
}
else if (jobItems.Any(i => i.Status == SyncJobItemStatus.Converting))
{
job.Status = SyncJobStatus.Converting;
2015-02-04 19:13:00 +00:00
}
else if (jobItems.All(i => i.Status == SyncJobItemStatus.Failed))
{
job.Status = SyncJobStatus.Failed;
}
else if (jobItems.All(i => i.Status == SyncJobItemStatus.Cancelled))
{
job.Status = SyncJobStatus.Cancelled;
}
2015-02-05 03:01:37 +00:00
else if (jobItems.All(i => i.Status == SyncJobItemStatus.ReadyToTransfer))
{
job.Status = SyncJobStatus.ReadyToTransfer;
}
else if (jobItems.All(i => i.Status == SyncJobItemStatus.Cancelled || i.Status == SyncJobItemStatus.Failed || i.Status == SyncJobItemStatus.Synced || i.Status == SyncJobItemStatus.RemovedFromDevice))
2014-12-13 03:56:30 +00:00
{
if (jobItems.Any(i => i.Status == SyncJobItemStatus.Failed))
{
job.Status = SyncJobStatus.CompletedWithError;
}
else
{
job.Status = SyncJobStatus.Completed;
}
}
else
{
2015-02-05 03:01:37 +00:00
job.Status = SyncJobStatus.Queued;
2014-12-11 06:20:28 +00:00
}
2015-02-04 20:16:23 +00:00
await _syncRepo.Update(job).ConfigureAwait(false);
2015-02-05 03:01:37 +00:00
_syncManager.OnSyncJobUpdated(job);
2014-12-11 06:20:28 +00:00
}
2014-12-30 16:36:49 +00:00
public async Task<IEnumerable<BaseItem>> GetItemsForSync(SyncCategory? category, string parentId, IEnumerable<string> itemIds, User user, bool unwatchedOnly)
2014-12-11 06:20:28 +00:00
{
2014-12-30 16:36:49 +00:00
var items = category.HasValue ?
await GetItemsForSync(category.Value, parentId, user).ConfigureAwait(false) :
2015-02-07 13:43:44 +00:00
itemIds.SelectMany(i => GetItemsForSync(i, user));
items = items.Where(_syncManager.SupportsSync);
2014-12-17 22:39:17 +00:00
if (unwatchedOnly)
{
// Avoid implicitly captured closure
var currentUser = user;
items = items.Where(i =>
{
var video = i as Video;
if (video != null)
{
return !video.IsPlayed(currentUser);
}
return true;
});
}
return items.DistinctBy(i => i.Id);
2014-12-11 06:20:28 +00:00
}
2014-12-30 16:36:49 +00:00
private async Task<IEnumerable<BaseItem>> GetItemsForSync(SyncCategory category, string parentId, User user)
{
var parent = string.IsNullOrWhiteSpace(parentId)
? user.RootFolder
: (Folder)_libraryManager.GetItemById(parentId);
InternalItemsQuery query;
switch (category)
{
case SyncCategory.Latest:
query = new InternalItemsQuery
{
IsFolder = false,
SortBy = new[] { ItemSortBy.DateCreated, ItemSortBy.SortName },
SortOrder = SortOrder.Descending,
Recursive = true
};
break;
case SyncCategory.Resume:
query = new InternalItemsQuery
{
IsFolder = false,
SortBy = new[] { ItemSortBy.DatePlayed, ItemSortBy.SortName },
SortOrder = SortOrder.Descending,
Recursive = true,
IsResumable = true,
MediaTypes = new[] { MediaType.Video }
};
break;
case SyncCategory.NextUp:
return _tvSeriesManager.GetNextUp(new NextUpQuery
{
ParentId = parentId,
UserId = user.Id.ToString("N")
}).Items;
default:
throw new ArgumentException("Unrecognized category: " + category);
}
2016-03-01 04:24:14 +00:00
if (parent == null)
{
return new List<BaseItem>();
}
2014-12-30 16:36:49 +00:00
query.User = user;
var result = await parent.GetItems(query).ConfigureAwait(false);
return result.Items;
}
2014-12-13 03:56:30 +00:00
private IEnumerable<BaseItem> GetItemsForSync(string id, User user)
2014-12-11 06:20:28 +00:00
{
var item = _libraryManager.GetItemById(id);
if (item == null)
{
return new List<BaseItem>();
}
2014-12-13 03:56:30 +00:00
var itemByName = item as IItemByName;
if (itemByName != null)
{
2016-05-07 17:47:41 +00:00
return itemByName.GetTaggedItems(new InternalItemsQuery(user)
{
IsFolder = false,
Recursive = true
});
2016-02-26 06:38:29 +00:00
}
2014-12-13 03:56:30 +00:00
if (item.IsFolder)
{
var folder = (Folder)item;
2016-05-07 17:47:41 +00:00
var items = folder.GetItems(new InternalItemsQuery(user)
{
Recursive = true,
IsFolder = false
}).Result.Items;
2014-12-13 03:56:30 +00:00
if (!folder.IsPreSorted)
{
2016-05-10 16:18:05 +00:00
items = _libraryManager.Sort(items, user, new[] { ItemSortBy.SortName }, SortOrder.Ascending)
.ToArray();
2014-12-13 03:56:30 +00:00
}
return items;
}
2014-12-11 06:20:28 +00:00
return new[] { item };
}
2014-12-13 03:56:30 +00:00
2015-02-19 17:46:18 +00:00
private async Task EnsureSyncJobItems(string targetId, CancellationToken cancellationToken)
2014-12-13 03:56:30 +00:00
{
var jobResult = _syncRepo.GetJobs(new SyncJobQuery
{
2015-02-19 17:46:18 +00:00
SyncNewContent = true,
TargetId = targetId
2014-12-13 03:56:30 +00:00
});
foreach (var job in jobResult.Items)
{
cancellationToken.ThrowIfCancellationRequested();
if (job.SyncNewContent)
{
await EnsureJobItems(job).ConfigureAwait(false);
}
}
}
public async Task Sync(IProgress<double> progress, CancellationToken cancellationToken)
{
2015-02-19 17:46:18 +00:00
await EnsureSyncJobItems(null, cancellationToken).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
2016-02-26 02:41:43 +00:00
// Look job items that are supposedly transfering, but need to be requeued because the synced files have been deleted somehow
await HandleDeletedSyncFiles(cancellationToken).ConfigureAwait(false);
2014-12-30 19:16:01 +00:00
// If it already has a converting status then is must have been aborted during conversion
2015-04-04 01:24:49 +00:00
var result = _syncManager.GetJobItems(new SyncJobItemQuery
2014-12-13 03:56:30 +00:00
{
2015-04-04 01:24:49 +00:00
Statuses = new[] { SyncJobItemStatus.Queued, SyncJobItemStatus.Converting },
AddMetadata = false
2014-12-13 03:56:30 +00:00
});
2015-01-13 05:40:27 +00:00
await SyncJobItems(result.Items, true, progress, cancellationToken).ConfigureAwait(false);
2015-01-17 04:29:53 +00:00
CleanDeadSyncFiles();
}
2016-02-26 02:41:43 +00:00
private async Task HandleDeletedSyncFiles(CancellationToken cancellationToken)
{
// Look job items that are supposedly transfering, but need to be requeued because the synced files have been deleted somehow
var result = _syncManager.GetJobItems(new SyncJobItemQuery
{
Statuses = new[] { SyncJobItemStatus.ReadyToTransfer, SyncJobItemStatus.Transferring },
AddMetadata = false
});
foreach (var item in result.Items)
{
cancellationToken.ThrowIfCancellationRequested();
if (string.IsNullOrWhiteSpace(item.OutputPath) || !_fileSystem.FileExists(item.OutputPath))
{
item.Status = SyncJobItemStatus.Queued;
await _syncManager.UpdateSyncJobItemInternal(item).ConfigureAwait(false);
await UpdateJobStatus(item.JobId).ConfigureAwait(false);
}
}
}
2015-01-17 04:29:53 +00:00
private void CleanDeadSyncFiles()
{
// TODO
2015-01-24 22:33:26 +00:00
// Clean files in sync temp folder that are not linked to any sync jobs
2015-01-13 05:40:27 +00:00
}
2015-02-19 17:46:18 +00:00
public async Task SyncJobItems(string targetId, bool enableConversion, IProgress<double> progress,
CancellationToken cancellationToken)
{
await EnsureSyncJobItems(targetId, cancellationToken).ConfigureAwait(false);
// If it already has a converting status then is must have been aborted during conversion
2015-04-04 01:24:49 +00:00
var result = _syncManager.GetJobItems(new SyncJobItemQuery
2015-02-19 17:46:18 +00:00
{
2015-04-04 01:24:49 +00:00
Statuses = new[] { SyncJobItemStatus.Queued, SyncJobItemStatus.Converting },
TargetId = targetId,
AddMetadata = false
2015-02-19 17:46:18 +00:00
});
2015-04-04 02:16:42 +00:00
await SyncJobItems(result.Items, enableConversion, progress, cancellationToken).ConfigureAwait(false);
2015-02-19 17:46:18 +00:00
}
2015-01-13 05:40:27 +00:00
public async Task SyncJobItems(SyncJobItem[] items, bool enableConversion, IProgress<double> progress, CancellationToken cancellationToken)
{
2015-01-24 22:33:26 +00:00
if (items.Length > 0)
{
if (!SyncRegistrationInfo.Instance.IsRegistered)
{
_logger.Debug("Cancelling sync job processing. Please obtain a supporter membership.");
return;
}
}
2015-01-19 20:53:02 +00:00
var numComplete = 0;
2014-12-13 03:56:30 +00:00
2015-01-13 05:40:27 +00:00
foreach (var item in items)
2014-12-13 03:56:30 +00:00
{
cancellationToken.ThrowIfCancellationRequested();
2015-01-19 20:53:02 +00:00
double percentPerItem = 1;
percentPerItem /= items.Length;
var startingPercent = numComplete * percentPerItem * 100;
2015-01-05 06:00:13 +00:00
var innerProgress = new ActionableProgress<double>();
2016-03-27 21:11:27 +00:00
innerProgress.RegisterAction(p => progress.Report(startingPercent + percentPerItem * p));
2015-01-05 06:00:13 +00:00
2015-01-21 03:54:45 +00:00
// Pull it fresh from the db just to make sure it wasn't deleted or cancelled while another item was converting
var jobItem = enableConversion ? _syncRepo.GetJobItem(item.Id) : item;
2015-01-06 03:25:23 +00:00
2015-01-21 03:54:45 +00:00
if (jobItem != null)
{
if (jobItem.Status != SyncJobItemStatus.Cancelled)
{
await ProcessJobItem(jobItem, enableConversion, innerProgress, cancellationToken).ConfigureAwait(false);
2015-01-21 03:54:45 +00:00
}
await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
2015-01-21 03:54:45 +00:00
}
2014-12-13 03:56:30 +00:00
2015-01-19 20:53:02 +00:00
numComplete++;
double percent = numComplete;
percent /= items.Length;
progress.Report(100 * percent);
2014-12-13 03:56:30 +00:00
}
}
private async Task ProcessJobItem(SyncJobItem jobItem, bool enableConversion, IProgress<double> progress, CancellationToken cancellationToken)
2014-12-13 03:56:30 +00:00
{
2016-05-29 18:42:18 +00:00
if (jobItem == null)
{
throw new ArgumentNullException("jobItem");
}
2014-12-13 03:56:30 +00:00
var item = _libraryManager.GetItemById(jobItem.ItemId);
if (item == null)
{
jobItem.Status = SyncJobItemStatus.Failed;
_logger.Error("Unable to locate library item for JobItem {0}, ItemId {1}", jobItem.Id, jobItem.ItemId);
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
return;
}
jobItem.Progress = 0;
2015-04-09 17:30:18 +00:00
var syncOptions = _config.GetSyncOptions();
var job = _syncManager.GetJob(jobItem.JobId);
2015-01-06 03:25:23 +00:00
var user = _userManager.GetUserById(job.UserId);
2015-05-18 22:23:03 +00:00
if (user == null)
{
jobItem.Status = SyncJobItemStatus.Failed;
_logger.Error("User not found. Cannot complete the sync job.");
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
return;
}
2015-01-06 03:25:23 +00:00
2015-08-18 19:45:41 +00:00
// See if there's already another active job item for the same target
var existingJobItems = _syncManager.GetJobItems(new SyncJobItemQuery
{
AddMetadata = false,
ItemId = jobItem.ItemId,
TargetId = jobItem.TargetId,
2015-08-18 19:45:41 +00:00
Statuses = new[] { SyncJobItemStatus.Converting, SyncJobItemStatus.Queued, SyncJobItemStatus.ReadyToTransfer, SyncJobItemStatus.Synced, SyncJobItemStatus.Transferring }
});
var duplicateJobItems = existingJobItems.Items
.Where(i => !string.Equals(i.Id, jobItem.Id, StringComparison.OrdinalIgnoreCase))
.ToList();
if (duplicateJobItems.Count > 0)
{
var syncProvider = _syncManager.GetSyncProvider(jobItem) as IHasDuplicateCheck;
2015-08-18 19:45:41 +00:00
if (!duplicateJobItems.Any(i => AllowDuplicateJobItem(syncProvider, i, jobItem)))
{
_logger.Debug("Cancelling sync job item because there is already another active job for the same target.");
jobItem.Status = SyncJobItemStatus.Cancelled;
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
return;
}
}
2014-12-13 03:56:30 +00:00
var video = item as Video;
if (video != null)
{
await Sync(jobItem, video, user, enableConversion, syncOptions, progress, cancellationToken).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
else if (item is Audio)
{
await Sync(jobItem, (Audio)item, user, enableConversion, syncOptions, progress, cancellationToken).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
else if (item is Photo)
{
2015-03-12 04:47:16 +00:00
await Sync(jobItem, (Photo)item, cancellationToken).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
2014-12-28 06:21:39 +00:00
else
2014-12-13 03:56:30 +00:00
{
2015-02-03 18:14:53 +00:00
await SyncGeneric(jobItem, item, cancellationToken).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
}
2015-08-18 19:45:41 +00:00
private bool AllowDuplicateJobItem(IHasDuplicateCheck provider, SyncJobItem original, SyncJobItem duplicate)
{
if (provider != null)
{
return provider.AllowDuplicateJobItem(original, duplicate);
}
return true;
}
private async Task Sync(SyncJobItem jobItem, Video item, User user, bool enableConversion, SyncOptions syncOptions, IProgress<double> progress, CancellationToken cancellationToken)
2014-12-13 03:56:30 +00:00
{
var job = _syncManager.GetJob(jobItem.JobId);
2015-03-15 17:50:47 +00:00
var jobOptions = _syncManager.GetVideoOptions(jobItem, job);
2015-03-15 19:10:27 +00:00
var conversionOptions = new VideoOptions
{
Profile = jobOptions.DeviceProfile
};
2015-02-03 18:14:53 +00:00
2015-03-15 17:50:47 +00:00
conversionOptions.DeviceId = jobItem.TargetId;
conversionOptions.Context = EncodingContext.Static;
conversionOptions.ItemId = item.Id.ToString("N");
conversionOptions.MediaSources = _mediaSourceManager.GetStaticMediaSources(item, false, user).ToList();
2014-12-13 03:56:30 +00:00
var streamInfo = new StreamBuilder(_mediaEncoder, _logger).BuildVideoItem(conversionOptions);
2014-12-13 03:56:30 +00:00
var mediaSource = streamInfo.MediaSource;
2015-02-03 18:14:53 +00:00
// No sense creating external subs if we're already burning one into the video
var externalSubs = streamInfo.SubtitleDeliveryMethod == SubtitleDeliveryMethod.Encode ?
new List<SubtitleStreamInfo>() :
2015-03-31 16:24:16 +00:00
streamInfo.GetExternalSubtitles(false, true, null, null);
2014-12-13 03:56:30 +00:00
2015-01-19 20:53:02 +00:00
// Mark as requiring conversion if transcoding the video, or if any subtitles need to be extracted
2015-03-15 17:50:47 +00:00
var requiresVideoTranscoding = streamInfo.PlayMethod == PlayMethod.Transcode && jobOptions.IsConverting;
2015-02-09 20:54:04 +00:00
var requiresConversion = requiresVideoTranscoding || externalSubs.Any(i => RequiresExtraction(i, mediaSource));
2014-12-26 17:45:06 +00:00
2015-01-17 04:29:53 +00:00
if (requiresConversion && !enableConversion)
2014-12-28 06:21:39 +00:00
{
2015-01-17 04:29:53 +00:00
return;
}
2015-01-13 05:40:27 +00:00
2015-01-17 04:29:53 +00:00
jobItem.MediaSourceId = streamInfo.MediaSourceId;
jobItem.TemporaryPath = GetTemporaryPath(jobItem);
if (requiresConversion)
{
2015-01-02 05:36:27 +00:00
jobItem.Status = SyncJobItemStatus.Converting;
2015-01-17 04:29:53 +00:00
}
2015-02-09 20:54:04 +00:00
if (requiresVideoTranscoding)
2015-01-17 04:29:53 +00:00
{
// Save the job item now since conversion could take a while
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
2015-01-02 05:36:27 +00:00
2015-01-05 06:00:13 +00:00
try
{
2015-02-03 19:37:50 +00:00
var lastJobUpdate = DateTime.MinValue;
var innerProgress = new ActionableProgress<double>();
innerProgress.RegisterAction(async pct =>
{
progress.Report(pct);
if ((DateTime.UtcNow - lastJobUpdate).TotalSeconds >= DatabaseProgressUpdateIntervalSeconds)
{
jobItem.Progress = pct / 2;
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
2015-02-03 19:37:50 +00:00
}
});
2015-03-15 17:50:47 +00:00
jobItem.OutputPath = await _mediaEncoder.EncodeVideo(new EncodingJobOptions(streamInfo, conversionOptions.Profile)
2015-01-17 04:29:53 +00:00
{
2015-04-09 17:30:18 +00:00
OutputDirectory = jobItem.TemporaryPath,
CpuCoreLimit = syncOptions.TranscodingCpuCoreLimit,
ReadInputAtNativeFramerate = !syncOptions.EnableFullSpeedTranscoding
2015-01-17 04:29:53 +00:00
2015-02-03 19:37:50 +00:00
}, innerProgress, cancellationToken);
2016-03-21 03:04:44 +00:00
2016-04-27 20:24:53 +00:00
jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
_syncManager.OnConversionComplete(jobItem);
2015-01-05 06:00:13 +00:00
}
catch (OperationCanceledException)
{
jobItem.Status = SyncJobItemStatus.Queued;
2015-02-03 19:37:50 +00:00
jobItem.Progress = 0;
2015-01-05 06:00:13 +00:00
}
catch (Exception ex)
{
jobItem.Status = SyncJobItemStatus.Failed;
_logger.ErrorException("Error during sync transcoding", ex);
}
if (jobItem.Status == SyncJobItemStatus.Failed || jobItem.Status == SyncJobItemStatus.Queued)
{
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
2015-01-05 06:00:13 +00:00
return;
}
2015-01-17 04:29:53 +00:00
jobItem.MediaSource = await GetEncodedMediaSource(jobItem.OutputPath, user, true).ConfigureAwait(false);
2014-12-28 06:21:39 +00:00
}
else
2014-12-13 03:56:30 +00:00
{
if (mediaSource.Protocol == MediaProtocol.File)
{
2014-12-28 06:21:39 +00:00
jobItem.OutputPath = mediaSource.Path;
2014-12-13 03:56:30 +00:00
}
2015-01-02 06:12:58 +00:00
else if (mediaSource.Protocol == MediaProtocol.Http)
2014-12-13 03:56:30 +00:00
{
2014-12-28 06:21:39 +00:00
jobItem.OutputPath = await DownloadFile(jobItem, mediaSource, cancellationToken).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
2015-01-02 05:36:27 +00:00
else
{
throw new InvalidOperationException(string.Format("Cannot direct stream {0} protocol", mediaSource.Protocol));
}
2015-01-17 04:29:53 +00:00
2016-04-27 20:24:53 +00:00
jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
2015-01-17 04:29:53 +00:00
jobItem.MediaSource = mediaSource;
}
2015-03-13 05:29:39 +00:00
jobItem.MediaSource.SupportsTranscoding = false;
2015-01-19 20:53:02 +00:00
if (externalSubs.Count > 0)
2015-01-17 04:29:53 +00:00
{
// Save the job item now since conversion could take a while
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
2015-01-17 04:29:53 +00:00
await ConvertSubtitles(jobItem, externalSubs, streamInfo, cancellationToken).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
2014-12-28 06:21:39 +00:00
jobItem.Progress = 50;
2015-02-05 03:01:37 +00:00
jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
2015-01-19 20:53:02 +00:00
private bool RequiresExtraction(SubtitleStreamInfo stream, MediaSourceInfo mediaSource)
{
var originalStream = mediaSource.MediaStreams.FirstOrDefault(i => i.Type == MediaStreamType.Subtitle && i.Index == stream.Index);
return originalStream != null && !originalStream.IsExternal;
}
2014-12-13 03:56:30 +00:00
2015-01-17 04:29:53 +00:00
private async Task ConvertSubtitles(SyncJobItem jobItem,
IEnumerable<SubtitleStreamInfo> subtitles,
StreamInfo streamInfo,
CancellationToken cancellationToken)
2015-01-16 20:54:37 +00:00
{
2015-01-17 04:29:53 +00:00
var files = new List<ItemFileInfo>();
var mediaStreams = jobItem.MediaSource.MediaStreams
.Where(i => i.Type != MediaStreamType.Subtitle || !i.IsExternal)
.ToList();
var startingIndex = mediaStreams.Count == 0 ?
0 :
2016-03-27 21:11:27 +00:00
mediaStreams.Select(i => i.Index).Max() + 1;
2015-01-17 04:29:53 +00:00
foreach (var subtitle in subtitles)
2015-01-16 20:54:37 +00:00
{
2015-01-17 04:29:53 +00:00
var fileInfo = await ConvertSubtitles(jobItem.TemporaryPath, streamInfo, subtitle, cancellationToken).ConfigureAwait(false);
// Reset this to a value that will be based on the output media
fileInfo.Index = startingIndex;
files.Add(fileInfo);
mediaStreams.Add(new MediaStream
{
Index = startingIndex,
Codec = subtitle.Format,
IsForced = subtitle.IsForced,
IsExternal = true,
Language = subtitle.Language,
Path = fileInfo.Path,
2015-03-27 04:17:04 +00:00
SupportsExternalStream = true,
Type = MediaStreamType.Subtitle
2015-01-17 04:29:53 +00:00
});
startingIndex++;
2015-01-16 20:54:37 +00:00
}
2015-01-17 04:29:53 +00:00
jobItem.AdditionalFiles.AddRange(files);
2015-01-16 20:54:37 +00:00
2015-01-17 04:29:53 +00:00
jobItem.MediaSource.MediaStreams = mediaStreams;
}
private async Task<ItemFileInfo> ConvertSubtitles(string temporaryPath, StreamInfo streamInfo, SubtitleStreamInfo subtitleStreamInfo, CancellationToken cancellationToken)
{
var subtitleStreamIndex = subtitleStreamInfo.Index;
var filename = Guid.NewGuid() + "." + subtitleStreamInfo.Format.ToLower();
var path = Path.Combine(temporaryPath, filename);
2016-02-21 17:22:31 +00:00
_fileSystem.CreateDirectory(Path.GetDirectoryName(path));
2015-01-17 04:29:53 +00:00
2016-05-27 17:17:57 +00:00
using (var stream = await _subtitleEncoder.GetSubtitles(streamInfo.ItemId, streamInfo.MediaSourceId, subtitleStreamIndex, subtitleStreamInfo.Format, 0, null, false, cancellationToken).ConfigureAwait(false))
2015-01-17 04:29:53 +00:00
{
using (var fs = _fileSystem.GetFileStream(path, FileMode.Create, FileAccess.Write, FileShare.Read, true))
{
await stream.CopyToAsync(fs, StreamDefaults.DefaultCopyToBufferSize, cancellationToken).ConfigureAwait(false);
}
}
return new ItemFileInfo
{
Name = Path.GetFileName(path),
Path = path,
Type = ItemFileType.Subtitles,
Index = subtitleStreamIndex
};
2015-01-16 20:54:37 +00:00
}
2015-02-03 19:37:50 +00:00
private const int DatabaseProgressUpdateIntervalSeconds = 2;
private async Task Sync(SyncJobItem jobItem, Audio item, User user, bool enableConversion, SyncOptions syncOptions, IProgress<double> progress, CancellationToken cancellationToken)
2014-12-13 03:56:30 +00:00
{
var job = _syncManager.GetJob(jobItem.JobId);
2015-03-15 17:50:47 +00:00
var jobOptions = _syncManager.GetAudioOptions(jobItem, job);
2015-03-15 19:10:27 +00:00
var conversionOptions = new AudioOptions
{
Profile = jobOptions.DeviceProfile
};
2015-02-03 18:14:53 +00:00
2015-03-15 17:50:47 +00:00
conversionOptions.DeviceId = jobItem.TargetId;
conversionOptions.Context = EncodingContext.Static;
conversionOptions.ItemId = item.Id.ToString("N");
conversionOptions.MediaSources = _mediaSourceManager.GetStaticMediaSources(item, false, user).ToList();
2014-12-13 03:56:30 +00:00
var streamInfo = new StreamBuilder(_mediaEncoder, _logger).BuildAudioItem(conversionOptions);
2014-12-13 03:56:30 +00:00
var mediaSource = streamInfo.MediaSource;
2014-12-26 17:45:06 +00:00
jobItem.MediaSourceId = streamInfo.MediaSourceId;
2015-01-17 04:29:53 +00:00
jobItem.TemporaryPath = GetTemporaryPath(jobItem);
2014-12-26 17:45:06 +00:00
2015-03-15 17:50:47 +00:00
if (streamInfo.PlayMethod == PlayMethod.Transcode && jobOptions.IsConverting)
2014-12-28 06:21:39 +00:00
{
2015-01-13 05:40:27 +00:00
if (!enableConversion)
{
return;
}
2015-01-02 05:36:27 +00:00
jobItem.Status = SyncJobItemStatus.Converting;
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
2015-01-05 06:00:13 +00:00
try
{
2015-02-03 19:37:50 +00:00
var lastJobUpdate = DateTime.MinValue;
var innerProgress = new ActionableProgress<double>();
innerProgress.RegisterAction(async pct =>
{
progress.Report(pct);
if ((DateTime.UtcNow - lastJobUpdate).TotalSeconds >= DatabaseProgressUpdateIntervalSeconds)
{
jobItem.Progress = pct / 2;
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
2015-02-03 19:37:50 +00:00
}
});
2015-03-15 17:50:47 +00:00
jobItem.OutputPath = await _mediaEncoder.EncodeAudio(new EncodingJobOptions(streamInfo, conversionOptions.Profile)
2015-01-17 04:29:53 +00:00
{
2015-04-09 17:30:18 +00:00
OutputDirectory = jobItem.TemporaryPath,
CpuCoreLimit = syncOptions.TranscodingCpuCoreLimit
2015-01-17 04:29:53 +00:00
2015-02-03 19:37:50 +00:00
}, innerProgress, cancellationToken);
2016-03-21 03:04:44 +00:00
2016-04-27 20:24:53 +00:00
jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
_syncManager.OnConversionComplete(jobItem);
2015-01-05 06:00:13 +00:00
}
catch (OperationCanceledException)
{
jobItem.Status = SyncJobItemStatus.Queued;
2015-02-03 19:37:50 +00:00
jobItem.Progress = 0;
2015-01-05 06:00:13 +00:00
}
catch (Exception ex)
{
jobItem.Status = SyncJobItemStatus.Failed;
_logger.ErrorException("Error during sync transcoding", ex);
}
if (jobItem.Status == SyncJobItemStatus.Failed || jobItem.Status == SyncJobItemStatus.Queued)
{
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
2015-01-05 06:00:13 +00:00
return;
}
2015-01-17 04:29:53 +00:00
jobItem.MediaSource = await GetEncodedMediaSource(jobItem.OutputPath, user, false).ConfigureAwait(false);
2014-12-28 06:21:39 +00:00
}
else
2014-12-13 03:56:30 +00:00
{
if (mediaSource.Protocol == MediaProtocol.File)
{
2014-12-28 06:21:39 +00:00
jobItem.OutputPath = mediaSource.Path;
2014-12-13 03:56:30 +00:00
}
2015-01-02 06:12:58 +00:00
else if (mediaSource.Protocol == MediaProtocol.Http)
2014-12-13 03:56:30 +00:00
{
2014-12-28 06:21:39 +00:00
jobItem.OutputPath = await DownloadFile(jobItem, mediaSource, cancellationToken).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
2015-01-02 05:36:27 +00:00
else
{
throw new InvalidOperationException(string.Format("Cannot direct stream {0} protocol", mediaSource.Protocol));
}
2015-01-17 04:29:53 +00:00
2016-04-27 20:24:53 +00:00
jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
2015-01-17 04:29:53 +00:00
jobItem.MediaSource = mediaSource;
2014-12-13 03:56:30 +00:00
}
2015-03-13 05:29:39 +00:00
jobItem.MediaSource.SupportsTranscoding = false;
2014-12-28 06:21:39 +00:00
jobItem.Progress = 50;
2015-02-05 03:01:37 +00:00
jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
2015-03-12 04:47:16 +00:00
private async Task Sync(SyncJobItem jobItem, Photo item, CancellationToken cancellationToken)
2014-12-13 03:56:30 +00:00
{
2014-12-28 06:21:39 +00:00
jobItem.OutputPath = item.Path;
jobItem.Progress = 50;
2015-02-05 03:01:37 +00:00
jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
2016-04-27 20:24:53 +00:00
jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
2015-02-03 18:14:53 +00:00
private async Task SyncGeneric(SyncJobItem jobItem, BaseItem item, CancellationToken cancellationToken)
2014-12-13 03:56:30 +00:00
{
2014-12-28 06:21:39 +00:00
jobItem.OutputPath = item.Path;
2015-02-09 20:54:04 +00:00
2014-12-28 06:21:39 +00:00
jobItem.Progress = 50;
2015-02-05 03:01:37 +00:00
jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
2016-04-27 20:24:53 +00:00
jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
2015-02-05 03:01:37 +00:00
await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
2014-12-13 03:56:30 +00:00
}
private async Task<string> DownloadFile(SyncJobItem jobItem, MediaSourceInfo mediaSource, CancellationToken cancellationToken)
{
// TODO: Download
return mediaSource.Path;
}
2015-01-17 04:29:53 +00:00
public string GetTemporaryPath(SyncJob job)
{
return GetTemporaryPath(job.Id);
}
public string GetTemporaryPath(string jobId)
2015-01-17 04:29:53 +00:00
{
var basePath = _config.GetSyncOptions().TemporaryPath;
if (string.IsNullOrWhiteSpace(basePath))
{
basePath = Path.Combine(_config.CommonApplicationPaths.ProgramDataPath, "sync");
}
return Path.Combine(basePath, jobId);
}
public string GetTemporaryPath(SyncJobItem jobItem)
{
return Path.Combine(GetTemporaryPath(jobItem.JobId), jobItem.Id);
2015-01-17 04:29:53 +00:00
}
private async Task<MediaSourceInfo> GetEncodedMediaSource(string path, User user, bool isVideo)
{
2015-10-04 03:38:46 +00:00
var item = _libraryManager.ResolvePath(_fileSystem.GetFileSystemInfo(path));
2015-01-17 04:29:53 +00:00
await item.RefreshMetadata(CancellationToken.None).ConfigureAwait(false);
var hasMediaSources = item as IHasMediaSources;
2015-03-31 16:24:16 +00:00
var mediaSources = _mediaSourceManager.GetStaticMediaSources(hasMediaSources, false).ToList();
2015-01-17 04:29:53 +00:00
var preferredAudio = string.IsNullOrEmpty(user.Configuration.AudioLanguagePreference)
2015-01-18 05:45:10 +00:00
? new string[] { }
: new[] { user.Configuration.AudioLanguagePreference };
2015-01-17 04:29:53 +00:00
var preferredSubs = string.IsNullOrEmpty(user.Configuration.SubtitleLanguagePreference)
? new List<string> { }
: new List<string> { user.Configuration.SubtitleLanguagePreference };
foreach (var source in mediaSources)
{
if (isVideo)
{
source.DefaultAudioStreamIndex =
MediaStreamSelector.GetDefaultAudioStreamIndex(source.MediaStreams, preferredAudio, user.Configuration.PlayDefaultAudioTrack);
var defaultAudioIndex = source.DefaultAudioStreamIndex;
var audioLangage = defaultAudioIndex == null
? null
: source.MediaStreams.Where(i => i.Type == MediaStreamType.Audio && i.Index == defaultAudioIndex).Select(i => i.Language).FirstOrDefault();
source.DefaultAudioStreamIndex =
MediaStreamSelector.GetDefaultSubtitleStreamIndex(source.MediaStreams, preferredSubs, user.Configuration.SubtitleMode, audioLangage);
}
else
{
var audio = source.MediaStreams.FirstOrDefault(i => i.Type == MediaStreamType.Audio);
if (audio != null)
{
source.DefaultAudioStreamIndex = audio.Index;
}
}
}
return mediaSources.FirstOrDefault();
}
2014-12-11 06:20:28 +00:00
}
}