SyncJobProcessor.cs 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996
  1. using MediaBrowser.Common.Configuration;
  2. using MediaBrowser.Common.IO;
  3. using MediaBrowser.Common.Progress;
  4. using MediaBrowser.Controller.Entities;
  5. using MediaBrowser.Controller.Entities.Audio;
  6. using MediaBrowser.Controller.Entities.TV;
  7. using MediaBrowser.Controller.Library;
  8. using MediaBrowser.Controller.MediaEncoding;
  9. using MediaBrowser.Controller.Sync;
  10. using MediaBrowser.Controller.TV;
  11. using MediaBrowser.Model.Dlna;
  12. using MediaBrowser.Model.Dto;
  13. using MediaBrowser.Model.Entities;
  14. using MediaBrowser.Model.Logging;
  15. using MediaBrowser.Model.MediaInfo;
  16. using MediaBrowser.Model.Querying;
  17. using MediaBrowser.Model.Session;
  18. using MediaBrowser.Model.Sync;
  19. using System;
  20. using System.Collections.Generic;
  21. using System.Globalization;
  22. using System.IO;
  23. using System.Linq;
  24. using System.Threading;
  25. using System.Threading.Tasks;
  26. using MediaBrowser.Controller.IO;
  27. using MediaBrowser.Model.IO;
  28. using MediaBrowser.Model.Extensions;
  29. using MediaBrowser.Model.IO;
  30. namespace Emby.Server.Implementations.Sync
  31. {
  32. public class SyncJobProcessor
  33. {
  34. private readonly ILibraryManager _libraryManager;
  35. private readonly ISyncRepository _syncRepo;
  36. private readonly SyncManager _syncManager;
  37. private readonly ILogger _logger;
  38. private readonly IUserManager _userManager;
  39. private readonly ITVSeriesManager _tvSeriesManager;
  40. private readonly IMediaEncoder _mediaEncoder;
  41. private readonly ISubtitleEncoder _subtitleEncoder;
  42. private readonly IConfigurationManager _config;
  43. private readonly IFileSystem _fileSystem;
  44. private readonly IMediaSourceManager _mediaSourceManager;
  45. public SyncJobProcessor(ILibraryManager libraryManager, ISyncRepository syncRepo, SyncManager syncManager, ILogger logger, IUserManager userManager, ITVSeriesManager tvSeriesManager, IMediaEncoder mediaEncoder, ISubtitleEncoder subtitleEncoder, IConfigurationManager config, IFileSystem fileSystem, IMediaSourceManager mediaSourceManager)
  46. {
  47. _libraryManager = libraryManager;
  48. _syncRepo = syncRepo;
  49. _syncManager = syncManager;
  50. _logger = logger;
  51. _userManager = userManager;
  52. _tvSeriesManager = tvSeriesManager;
  53. _mediaEncoder = mediaEncoder;
  54. _subtitleEncoder = subtitleEncoder;
  55. _config = config;
  56. _fileSystem = fileSystem;
  57. _mediaSourceManager = mediaSourceManager;
  58. }
  59. public async Task EnsureJobItems(SyncJob job)
  60. {
  61. var user = _userManager.GetUserById(job.UserId);
  62. if (user == null)
  63. {
  64. throw new InvalidOperationException("Cannot proceed with sync because user no longer exists.");
  65. }
  66. var items = (await GetItemsForSync(job.Category, job.ParentId, job.RequestedItemIds, user, job.UnwatchedOnly).ConfigureAwait(false))
  67. .ToList();
  68. var jobItems = _syncManager.GetJobItems(new SyncJobItemQuery
  69. {
  70. JobId = job.Id,
  71. AddMetadata = false
  72. }).Items.ToList();
  73. foreach (var item in items)
  74. {
  75. // Respect ItemLimit, if set
  76. if (job.ItemLimit.HasValue)
  77. {
  78. if (jobItems.Count(j => j.Status != SyncJobItemStatus.RemovedFromDevice && j.Status != SyncJobItemStatus.Failed) >= job.ItemLimit.Value)
  79. {
  80. break;
  81. }
  82. }
  83. var itemId = item.Id.ToString("N");
  84. var jobItem = jobItems.FirstOrDefault(i => string.Equals(i.ItemId, itemId, StringComparison.OrdinalIgnoreCase));
  85. if (jobItem != null)
  86. {
  87. continue;
  88. }
  89. var index = jobItems.Count == 0 ?
  90. 0 :
  91. jobItems.Select(i => i.JobItemIndex).Max() + 1;
  92. jobItem = new SyncJobItem
  93. {
  94. Id = Guid.NewGuid().ToString("N"),
  95. ItemId = itemId,
  96. ItemName = GetSyncJobItemName(item),
  97. JobId = job.Id,
  98. TargetId = job.TargetId,
  99. DateCreated = DateTime.UtcNow,
  100. JobItemIndex = index
  101. };
  102. await _syncRepo.Create(jobItem).ConfigureAwait(false);
  103. _syncManager.OnSyncJobItemCreated(jobItem);
  104. jobItems.Add(jobItem);
  105. }
  106. jobItems = jobItems
  107. .OrderBy(i => i.DateCreated)
  108. .ToList();
  109. await UpdateJobStatus(job, jobItems).ConfigureAwait(false);
  110. }
  111. private string GetSyncJobItemName(BaseItem item)
  112. {
  113. var name = item.Name;
  114. var episode = item as Episode;
  115. if (episode != null)
  116. {
  117. if (episode.IndexNumber.HasValue)
  118. {
  119. name = "E" + episode.IndexNumber.Value.ToString(CultureInfo.InvariantCulture) + " - " + name;
  120. }
  121. if (episode.ParentIndexNumber.HasValue)
  122. {
  123. name = "S" + episode.ParentIndexNumber.Value.ToString(CultureInfo.InvariantCulture) + ", " + name;
  124. }
  125. }
  126. return name;
  127. }
  128. public Task UpdateJobStatus(string id)
  129. {
  130. var job = _syncRepo.GetJob(id);
  131. if (job == null)
  132. {
  133. return Task.FromResult(true);
  134. }
  135. var result = _syncManager.GetJobItems(new SyncJobItemQuery
  136. {
  137. JobId = job.Id,
  138. AddMetadata = false
  139. });
  140. return UpdateJobStatus(job, result.Items.ToList());
  141. }
  142. private async Task UpdateJobStatus(SyncJob job, List<SyncJobItem> jobItems)
  143. {
  144. job.ItemCount = jobItems.Count;
  145. double pct = 0;
  146. foreach (var item in jobItems)
  147. {
  148. if (item.Status == SyncJobItemStatus.Failed || item.Status == SyncJobItemStatus.Synced || item.Status == SyncJobItemStatus.RemovedFromDevice || item.Status == SyncJobItemStatus.Cancelled)
  149. {
  150. pct += 100;
  151. }
  152. else
  153. {
  154. pct += item.Progress ?? 0;
  155. }
  156. }
  157. if (job.ItemCount > 0)
  158. {
  159. pct /= job.ItemCount;
  160. job.Progress = pct;
  161. }
  162. else
  163. {
  164. job.Progress = null;
  165. }
  166. if (jobItems.Any(i => i.Status == SyncJobItemStatus.Transferring))
  167. {
  168. job.Status = SyncJobStatus.Transferring;
  169. }
  170. else if (jobItems.Any(i => i.Status == SyncJobItemStatus.Converting))
  171. {
  172. job.Status = SyncJobStatus.Converting;
  173. }
  174. else if (jobItems.All(i => i.Status == SyncJobItemStatus.Failed))
  175. {
  176. job.Status = SyncJobStatus.Failed;
  177. }
  178. else if (jobItems.All(i => i.Status == SyncJobItemStatus.Cancelled))
  179. {
  180. job.Status = SyncJobStatus.Cancelled;
  181. }
  182. else if (jobItems.All(i => i.Status == SyncJobItemStatus.ReadyToTransfer))
  183. {
  184. job.Status = SyncJobStatus.ReadyToTransfer;
  185. }
  186. else if (jobItems.All(i => i.Status == SyncJobItemStatus.Cancelled || i.Status == SyncJobItemStatus.Failed || i.Status == SyncJobItemStatus.Synced || i.Status == SyncJobItemStatus.RemovedFromDevice))
  187. {
  188. if (jobItems.Any(i => i.Status == SyncJobItemStatus.Failed))
  189. {
  190. job.Status = SyncJobStatus.CompletedWithError;
  191. }
  192. else
  193. {
  194. job.Status = SyncJobStatus.Completed;
  195. }
  196. }
  197. else
  198. {
  199. job.Status = SyncJobStatus.Queued;
  200. }
  201. await _syncRepo.Update(job).ConfigureAwait(false);
  202. _syncManager.OnSyncJobUpdated(job);
  203. }
  204. public async Task<IEnumerable<BaseItem>> GetItemsForSync(SyncCategory? category, string parentId, IEnumerable<string> itemIds, User user, bool unwatchedOnly)
  205. {
  206. var list = new List<BaseItem>();
  207. if (category.HasValue)
  208. {
  209. list = (await GetItemsForSync(category.Value, parentId, user).ConfigureAwait(false)).ToList();
  210. }
  211. else
  212. {
  213. foreach (var itemId in itemIds)
  214. {
  215. var subList = await GetItemsForSync(itemId, user).ConfigureAwait(false);
  216. list.AddRange(subList);
  217. }
  218. }
  219. IEnumerable<BaseItem> items = list;
  220. items = items.Where(_syncManager.SupportsSync);
  221. if (unwatchedOnly)
  222. {
  223. // Avoid implicitly captured closure
  224. var currentUser = user;
  225. items = items.Where(i =>
  226. {
  227. var video = i as Video;
  228. if (video != null)
  229. {
  230. return !video.IsPlayed(currentUser);
  231. }
  232. return true;
  233. });
  234. }
  235. return items.DistinctBy(i => i.Id);
  236. }
  237. private async Task<IEnumerable<BaseItem>> GetItemsForSync(SyncCategory category, string parentId, User user)
  238. {
  239. var parent = string.IsNullOrWhiteSpace(parentId)
  240. ? user.RootFolder
  241. : (Folder)_libraryManager.GetItemById(parentId);
  242. InternalItemsQuery query;
  243. switch (category)
  244. {
  245. case SyncCategory.Latest:
  246. query = new InternalItemsQuery
  247. {
  248. IsFolder = false,
  249. SortBy = new[] { ItemSortBy.DateCreated, ItemSortBy.SortName },
  250. SortOrder = SortOrder.Descending,
  251. Recursive = true
  252. };
  253. break;
  254. case SyncCategory.Resume:
  255. query = new InternalItemsQuery
  256. {
  257. IsFolder = false,
  258. SortBy = new[] { ItemSortBy.DatePlayed, ItemSortBy.SortName },
  259. SortOrder = SortOrder.Descending,
  260. Recursive = true,
  261. IsResumable = true,
  262. MediaTypes = new[] { MediaType.Video }
  263. };
  264. break;
  265. case SyncCategory.NextUp:
  266. return _tvSeriesManager.GetNextUp(new NextUpQuery
  267. {
  268. ParentId = parentId,
  269. UserId = user.Id.ToString("N")
  270. }).Items;
  271. default:
  272. throw new ArgumentException("Unrecognized category: " + category);
  273. }
  274. if (parent == null)
  275. {
  276. return new List<BaseItem>();
  277. }
  278. query.User = user;
  279. var result = await parent.GetItems(query).ConfigureAwait(false);
  280. return result.Items;
  281. }
  282. private async Task<List<BaseItem>> GetItemsForSync(string id, User user)
  283. {
  284. var item = _libraryManager.GetItemById(id);
  285. if (item == null)
  286. {
  287. return new List<BaseItem>();
  288. }
  289. var itemByName = item as IItemByName;
  290. if (itemByName != null)
  291. {
  292. return itemByName.GetTaggedItems(new InternalItemsQuery(user)
  293. {
  294. IsFolder = false,
  295. Recursive = true
  296. }).ToList();
  297. }
  298. if (item.IsFolder)
  299. {
  300. var folder = (Folder)item;
  301. var itemsResult = await folder.GetItems(new InternalItemsQuery(user)
  302. {
  303. Recursive = true,
  304. IsFolder = false
  305. }).ConfigureAwait(false);
  306. var items = itemsResult.Items;
  307. if (!folder.IsPreSorted)
  308. {
  309. items = _libraryManager.Sort(items, user, new[] { ItemSortBy.SortName }, SortOrder.Ascending)
  310. .ToArray();
  311. }
  312. return items.ToList();
  313. }
  314. return new List<BaseItem> { item };
  315. }
  316. private async Task EnsureSyncJobItems(string targetId, CancellationToken cancellationToken)
  317. {
  318. var jobResult = _syncRepo.GetJobs(new SyncJobQuery
  319. {
  320. SyncNewContent = true,
  321. TargetId = targetId
  322. });
  323. foreach (var job in jobResult.Items)
  324. {
  325. cancellationToken.ThrowIfCancellationRequested();
  326. if (job.SyncNewContent)
  327. {
  328. await EnsureJobItems(job).ConfigureAwait(false);
  329. }
  330. }
  331. }
  332. public async Task Sync(IProgress<double> progress, CancellationToken cancellationToken)
  333. {
  334. await EnsureSyncJobItems(null, cancellationToken).ConfigureAwait(false);
  335. // Look job items that are supposedly transfering, but need to be requeued because the synced files have been deleted somehow
  336. await HandleDeletedSyncFiles(cancellationToken).ConfigureAwait(false);
  337. // If it already has a converting status then is must have been aborted during conversion
  338. var result = _syncManager.GetJobItems(new SyncJobItemQuery
  339. {
  340. Statuses = new[] { SyncJobItemStatus.Queued, SyncJobItemStatus.Converting },
  341. AddMetadata = false
  342. });
  343. await SyncJobItems(result.Items, true, progress, cancellationToken).ConfigureAwait(false);
  344. CleanDeadSyncFiles();
  345. }
  346. private async Task HandleDeletedSyncFiles(CancellationToken cancellationToken)
  347. {
  348. // Look job items that are supposedly transfering, but need to be requeued because the synced files have been deleted somehow
  349. var result = _syncManager.GetJobItems(new SyncJobItemQuery
  350. {
  351. Statuses = new[] { SyncJobItemStatus.ReadyToTransfer, SyncJobItemStatus.Transferring },
  352. AddMetadata = false
  353. });
  354. foreach (var item in result.Items)
  355. {
  356. cancellationToken.ThrowIfCancellationRequested();
  357. if (string.IsNullOrWhiteSpace(item.OutputPath) || !_fileSystem.FileExists(item.OutputPath))
  358. {
  359. item.Status = SyncJobItemStatus.Queued;
  360. await _syncManager.UpdateSyncJobItemInternal(item).ConfigureAwait(false);
  361. await UpdateJobStatus(item.JobId).ConfigureAwait(false);
  362. }
  363. }
  364. }
  365. private void CleanDeadSyncFiles()
  366. {
  367. // TODO
  368. // Clean files in sync temp folder that are not linked to any sync jobs
  369. }
  370. public async Task SyncJobItems(string targetId, bool enableConversion, IProgress<double> progress,
  371. CancellationToken cancellationToken)
  372. {
  373. await EnsureSyncJobItems(targetId, cancellationToken).ConfigureAwait(false);
  374. // If it already has a converting status then is must have been aborted during conversion
  375. var result = _syncManager.GetJobItems(new SyncJobItemQuery
  376. {
  377. Statuses = new[] { SyncJobItemStatus.Queued, SyncJobItemStatus.Converting },
  378. TargetId = targetId,
  379. AddMetadata = false
  380. });
  381. await SyncJobItems(result.Items, enableConversion, progress, cancellationToken).ConfigureAwait(false);
  382. }
  383. public async Task SyncJobItems(SyncJobItem[] items, bool enableConversion, IProgress<double> progress, CancellationToken cancellationToken)
  384. {
  385. if (items.Length > 0)
  386. {
  387. if (!SyncRegistrationInfo.Instance.IsRegistered)
  388. {
  389. _logger.Debug("Cancelling sync job processing. Please obtain a supporter membership.");
  390. return;
  391. }
  392. }
  393. var numComplete = 0;
  394. foreach (var item in items)
  395. {
  396. cancellationToken.ThrowIfCancellationRequested();
  397. double percentPerItem = 1;
  398. percentPerItem /= items.Length;
  399. var startingPercent = numComplete * percentPerItem * 100;
  400. var innerProgress = new ActionableProgress<double>();
  401. innerProgress.RegisterAction(p => progress.Report(startingPercent + percentPerItem * p));
  402. // Pull it fresh from the db just to make sure it wasn't deleted or cancelled while another item was converting
  403. var jobItem = enableConversion ? _syncRepo.GetJobItem(item.Id) : item;
  404. if (jobItem != null)
  405. {
  406. if (jobItem.Status != SyncJobItemStatus.Cancelled)
  407. {
  408. await ProcessJobItem(jobItem, enableConversion, innerProgress, cancellationToken).ConfigureAwait(false);
  409. }
  410. await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
  411. }
  412. numComplete++;
  413. double percent = numComplete;
  414. percent /= items.Length;
  415. progress.Report(100 * percent);
  416. }
  417. }
  418. private async Task ProcessJobItem(SyncJobItem jobItem, bool enableConversion, IProgress<double> progress, CancellationToken cancellationToken)
  419. {
  420. if (jobItem == null)
  421. {
  422. throw new ArgumentNullException("jobItem");
  423. }
  424. var item = _libraryManager.GetItemById(jobItem.ItemId);
  425. if (item == null)
  426. {
  427. jobItem.Status = SyncJobItemStatus.Failed;
  428. _logger.Error("Unable to locate library item for JobItem {0}, ItemId {1}", jobItem.Id, jobItem.ItemId);
  429. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  430. return;
  431. }
  432. jobItem.Progress = 0;
  433. var job = _syncManager.GetJob(jobItem.JobId);
  434. if (job == null)
  435. {
  436. _logger.Error("Job not found. Cannot complete the sync job.");
  437. await _syncManager.CancelJobItem(jobItem.Id).ConfigureAwait(false);
  438. return;
  439. }
  440. var user = _userManager.GetUserById(job.UserId);
  441. if (user == null)
  442. {
  443. jobItem.Status = SyncJobItemStatus.Failed;
  444. _logger.Error("User not found. Cannot complete the sync job.");
  445. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  446. return;
  447. }
  448. // See if there's already another active job item for the same target
  449. var existingJobItems = _syncManager.GetJobItems(new SyncJobItemQuery
  450. {
  451. AddMetadata = false,
  452. ItemId = jobItem.ItemId,
  453. TargetId = jobItem.TargetId,
  454. Statuses = new[] { SyncJobItemStatus.Converting, SyncJobItemStatus.Queued, SyncJobItemStatus.ReadyToTransfer, SyncJobItemStatus.Synced, SyncJobItemStatus.Transferring }
  455. });
  456. var duplicateJobItems = existingJobItems.Items
  457. .Where(i => !string.Equals(i.Id, jobItem.Id, StringComparison.OrdinalIgnoreCase))
  458. .ToList();
  459. if (duplicateJobItems.Count > 0)
  460. {
  461. var syncProvider = _syncManager.GetSyncProvider(jobItem) as IHasDuplicateCheck;
  462. if (!duplicateJobItems.Any(i => AllowDuplicateJobItem(syncProvider, i, jobItem)))
  463. {
  464. _logger.Debug("Cancelling sync job item because there is already another active job for the same target.");
  465. jobItem.Status = SyncJobItemStatus.Cancelled;
  466. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  467. return;
  468. }
  469. }
  470. var syncOptions = _config.GetSyncOptions();
  471. var video = item as Video;
  472. if (video != null)
  473. {
  474. await Sync(jobItem, video, user, enableConversion, syncOptions, progress, cancellationToken).ConfigureAwait(false);
  475. }
  476. else if (item is Audio)
  477. {
  478. await Sync(jobItem, (Audio)item, user, enableConversion, syncOptions, progress, cancellationToken).ConfigureAwait(false);
  479. }
  480. else if (item is Photo)
  481. {
  482. await Sync(jobItem, (Photo)item, cancellationToken).ConfigureAwait(false);
  483. }
  484. else
  485. {
  486. await SyncGeneric(jobItem, item, cancellationToken).ConfigureAwait(false);
  487. }
  488. }
  489. private bool AllowDuplicateJobItem(IHasDuplicateCheck provider, SyncJobItem original, SyncJobItem duplicate)
  490. {
  491. if (provider != null)
  492. {
  493. return provider.AllowDuplicateJobItem(original, duplicate);
  494. }
  495. return true;
  496. }
  497. private async Task Sync(SyncJobItem jobItem, Video item, User user, bool enableConversion, SyncOptions syncOptions, IProgress<double> progress, CancellationToken cancellationToken)
  498. {
  499. var job = _syncManager.GetJob(jobItem.JobId);
  500. var jobOptions = _syncManager.GetVideoOptions(jobItem, job);
  501. var conversionOptions = new VideoOptions
  502. {
  503. Profile = jobOptions.DeviceProfile
  504. };
  505. conversionOptions.DeviceId = jobItem.TargetId;
  506. conversionOptions.Context = EncodingContext.Static;
  507. conversionOptions.ItemId = item.Id.ToString("N");
  508. conversionOptions.MediaSources = _mediaSourceManager.GetStaticMediaSources(item, false, user).ToList();
  509. var streamInfo = new StreamBuilder(_mediaEncoder, _logger).BuildVideoItem(conversionOptions);
  510. var mediaSource = streamInfo.MediaSource;
  511. // No sense creating external subs if we're already burning one into the video
  512. var externalSubs = streamInfo.SubtitleDeliveryMethod == SubtitleDeliveryMethod.Encode ?
  513. new List<SubtitleStreamInfo>() :
  514. streamInfo.GetExternalSubtitles(false, true, null, null);
  515. // Mark as requiring conversion if transcoding the video, or if any subtitles need to be extracted
  516. var requiresVideoTranscoding = streamInfo.PlayMethod == PlayMethod.Transcode && jobOptions.IsConverting;
  517. var requiresConversion = requiresVideoTranscoding || externalSubs.Any(i => RequiresExtraction(i, mediaSource));
  518. if (requiresConversion && !enableConversion)
  519. {
  520. return;
  521. }
  522. jobItem.MediaSourceId = streamInfo.MediaSourceId;
  523. jobItem.TemporaryPath = GetTemporaryPath(jobItem);
  524. if (requiresConversion)
  525. {
  526. jobItem.Status = SyncJobItemStatus.Converting;
  527. }
  528. if (requiresVideoTranscoding)
  529. {
  530. // Save the job item now since conversion could take a while
  531. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  532. await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
  533. try
  534. {
  535. var lastJobUpdate = DateTime.MinValue;
  536. var innerProgress = new ActionableProgress<double>();
  537. innerProgress.RegisterAction(async pct =>
  538. {
  539. progress.Report(pct);
  540. if ((DateTime.UtcNow - lastJobUpdate).TotalSeconds >= DatabaseProgressUpdateIntervalSeconds)
  541. {
  542. jobItem.Progress = pct / 2;
  543. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  544. await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
  545. }
  546. });
  547. jobItem.OutputPath = await _mediaEncoder.EncodeVideo(new EncodingJobOptions(streamInfo, conversionOptions.Profile)
  548. {
  549. OutputDirectory = jobItem.TemporaryPath,
  550. CpuCoreLimit = syncOptions.TranscodingCpuCoreLimit,
  551. ReadInputAtNativeFramerate = !syncOptions.EnableFullSpeedTranscoding
  552. }, innerProgress, cancellationToken);
  553. jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
  554. _syncManager.OnConversionComplete(jobItem);
  555. }
  556. catch (OperationCanceledException)
  557. {
  558. jobItem.Status = SyncJobItemStatus.Queued;
  559. jobItem.Progress = 0;
  560. }
  561. catch (Exception ex)
  562. {
  563. jobItem.Status = SyncJobItemStatus.Failed;
  564. _logger.ErrorException("Error during sync transcoding", ex);
  565. }
  566. if (jobItem.Status == SyncJobItemStatus.Failed || jobItem.Status == SyncJobItemStatus.Queued)
  567. {
  568. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  569. return;
  570. }
  571. jobItem.MediaSource = await GetEncodedMediaSource(jobItem.OutputPath, user, true).ConfigureAwait(false);
  572. }
  573. else
  574. {
  575. if (mediaSource.Protocol == MediaProtocol.File)
  576. {
  577. jobItem.OutputPath = mediaSource.Path;
  578. }
  579. else if (mediaSource.Protocol == MediaProtocol.Http)
  580. {
  581. jobItem.OutputPath = await DownloadFile(jobItem, mediaSource, cancellationToken).ConfigureAwait(false);
  582. }
  583. else
  584. {
  585. throw new InvalidOperationException(string.Format("Cannot direct stream {0} protocol", mediaSource.Protocol));
  586. }
  587. jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
  588. jobItem.MediaSource = mediaSource;
  589. }
  590. jobItem.MediaSource.SupportsTranscoding = false;
  591. if (externalSubs.Count > 0)
  592. {
  593. // Save the job item now since conversion could take a while
  594. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  595. await ConvertSubtitles(jobItem, externalSubs, streamInfo, cancellationToken).ConfigureAwait(false);
  596. }
  597. jobItem.Progress = 50;
  598. jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
  599. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  600. }
  601. private bool RequiresExtraction(SubtitleStreamInfo stream, MediaSourceInfo mediaSource)
  602. {
  603. var originalStream = mediaSource.MediaStreams.FirstOrDefault(i => i.Type == MediaStreamType.Subtitle && i.Index == stream.Index);
  604. return originalStream != null && !originalStream.IsExternal;
  605. }
  606. private async Task ConvertSubtitles(SyncJobItem jobItem,
  607. IEnumerable<SubtitleStreamInfo> subtitles,
  608. StreamInfo streamInfo,
  609. CancellationToken cancellationToken)
  610. {
  611. var files = new List<ItemFileInfo>();
  612. var mediaStreams = jobItem.MediaSource.MediaStreams
  613. .Where(i => i.Type != MediaStreamType.Subtitle || !i.IsExternal)
  614. .ToList();
  615. var startingIndex = mediaStreams.Count == 0 ?
  616. 0 :
  617. mediaStreams.Select(i => i.Index).Max() + 1;
  618. foreach (var subtitle in subtitles)
  619. {
  620. var fileInfo = await ConvertSubtitles(jobItem.TemporaryPath, streamInfo, subtitle, cancellationToken).ConfigureAwait(false);
  621. // Reset this to a value that will be based on the output media
  622. fileInfo.Index = startingIndex;
  623. files.Add(fileInfo);
  624. mediaStreams.Add(new MediaStream
  625. {
  626. Index = startingIndex,
  627. Codec = subtitle.Format,
  628. IsForced = subtitle.IsForced,
  629. IsExternal = true,
  630. Language = subtitle.Language,
  631. Path = fileInfo.Path,
  632. SupportsExternalStream = true,
  633. Type = MediaStreamType.Subtitle
  634. });
  635. startingIndex++;
  636. }
  637. jobItem.AdditionalFiles.AddRange(files);
  638. jobItem.MediaSource.MediaStreams = mediaStreams;
  639. }
  640. private async Task<ItemFileInfo> ConvertSubtitles(string temporaryPath, StreamInfo streamInfo, SubtitleStreamInfo subtitleStreamInfo, CancellationToken cancellationToken)
  641. {
  642. var subtitleStreamIndex = subtitleStreamInfo.Index;
  643. var filename = Guid.NewGuid() + "." + subtitleStreamInfo.Format.ToLower();
  644. var path = Path.Combine(temporaryPath, filename);
  645. _fileSystem.CreateDirectory(Path.GetDirectoryName(path));
  646. using (var stream = await _subtitleEncoder.GetSubtitles(streamInfo.ItemId, streamInfo.MediaSourceId, subtitleStreamIndex, subtitleStreamInfo.Format, 0, null, false, cancellationToken).ConfigureAwait(false))
  647. {
  648. using (var fs = _fileSystem.GetFileStream(path, FileOpenMode.Create, FileAccessMode.Write, FileShareMode.Read, true))
  649. {
  650. await stream.CopyToAsync(fs, StreamDefaults.DefaultCopyToBufferSize, cancellationToken).ConfigureAwait(false);
  651. }
  652. }
  653. return new ItemFileInfo
  654. {
  655. Name = Path.GetFileName(path),
  656. Path = path,
  657. Type = ItemFileType.Subtitles,
  658. Index = subtitleStreamIndex
  659. };
  660. }
  661. private const int DatabaseProgressUpdateIntervalSeconds = 2;
  662. private async Task Sync(SyncJobItem jobItem, Audio item, User user, bool enableConversion, SyncOptions syncOptions, IProgress<double> progress, CancellationToken cancellationToken)
  663. {
  664. var job = _syncManager.GetJob(jobItem.JobId);
  665. var jobOptions = _syncManager.GetAudioOptions(jobItem, job);
  666. var conversionOptions = new AudioOptions
  667. {
  668. Profile = jobOptions.DeviceProfile
  669. };
  670. conversionOptions.DeviceId = jobItem.TargetId;
  671. conversionOptions.Context = EncodingContext.Static;
  672. conversionOptions.ItemId = item.Id.ToString("N");
  673. conversionOptions.MediaSources = _mediaSourceManager.GetStaticMediaSources(item, false, user).ToList();
  674. var streamInfo = new StreamBuilder(_mediaEncoder, _logger).BuildAudioItem(conversionOptions);
  675. var mediaSource = streamInfo.MediaSource;
  676. jobItem.MediaSourceId = streamInfo.MediaSourceId;
  677. jobItem.TemporaryPath = GetTemporaryPath(jobItem);
  678. if (streamInfo.PlayMethod == PlayMethod.Transcode && jobOptions.IsConverting)
  679. {
  680. if (!enableConversion)
  681. {
  682. return;
  683. }
  684. jobItem.Status = SyncJobItemStatus.Converting;
  685. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  686. await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
  687. try
  688. {
  689. var lastJobUpdate = DateTime.MinValue;
  690. var innerProgress = new ActionableProgress<double>();
  691. innerProgress.RegisterAction(async pct =>
  692. {
  693. progress.Report(pct);
  694. if ((DateTime.UtcNow - lastJobUpdate).TotalSeconds >= DatabaseProgressUpdateIntervalSeconds)
  695. {
  696. jobItem.Progress = pct / 2;
  697. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  698. await UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
  699. }
  700. });
  701. jobItem.OutputPath = await _mediaEncoder.EncodeAudio(new EncodingJobOptions(streamInfo, conversionOptions.Profile)
  702. {
  703. OutputDirectory = jobItem.TemporaryPath,
  704. CpuCoreLimit = syncOptions.TranscodingCpuCoreLimit
  705. }, innerProgress, cancellationToken);
  706. jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
  707. _syncManager.OnConversionComplete(jobItem);
  708. }
  709. catch (OperationCanceledException)
  710. {
  711. jobItem.Status = SyncJobItemStatus.Queued;
  712. jobItem.Progress = 0;
  713. }
  714. catch (Exception ex)
  715. {
  716. jobItem.Status = SyncJobItemStatus.Failed;
  717. _logger.ErrorException("Error during sync transcoding", ex);
  718. }
  719. if (jobItem.Status == SyncJobItemStatus.Failed || jobItem.Status == SyncJobItemStatus.Queued)
  720. {
  721. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  722. return;
  723. }
  724. jobItem.MediaSource = await GetEncodedMediaSource(jobItem.OutputPath, user, false).ConfigureAwait(false);
  725. }
  726. else
  727. {
  728. if (mediaSource.Protocol == MediaProtocol.File)
  729. {
  730. jobItem.OutputPath = mediaSource.Path;
  731. }
  732. else if (mediaSource.Protocol == MediaProtocol.Http)
  733. {
  734. jobItem.OutputPath = await DownloadFile(jobItem, mediaSource, cancellationToken).ConfigureAwait(false);
  735. }
  736. else
  737. {
  738. throw new InvalidOperationException(string.Format("Cannot direct stream {0} protocol", mediaSource.Protocol));
  739. }
  740. jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
  741. jobItem.MediaSource = mediaSource;
  742. }
  743. jobItem.MediaSource.SupportsTranscoding = false;
  744. jobItem.Progress = 50;
  745. jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
  746. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  747. }
  748. private async Task Sync(SyncJobItem jobItem, Photo item, CancellationToken cancellationToken)
  749. {
  750. jobItem.OutputPath = item.Path;
  751. jobItem.Progress = 50;
  752. jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
  753. jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
  754. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  755. }
  756. private async Task SyncGeneric(SyncJobItem jobItem, BaseItem item, CancellationToken cancellationToken)
  757. {
  758. jobItem.OutputPath = item.Path;
  759. jobItem.Progress = 50;
  760. jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
  761. jobItem.ItemDateModifiedTicks = item.DateModified.Ticks;
  762. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  763. }
  764. private async Task<string> DownloadFile(SyncJobItem jobItem, MediaSourceInfo mediaSource, CancellationToken cancellationToken)
  765. {
  766. // TODO: Download
  767. return mediaSource.Path;
  768. }
  769. public string GetTemporaryPath(SyncJob job)
  770. {
  771. return GetTemporaryPath(job.Id);
  772. }
  773. public string GetTemporaryPath(string jobId)
  774. {
  775. var basePath = _config.GetSyncOptions().TemporaryPath;
  776. if (string.IsNullOrWhiteSpace(basePath))
  777. {
  778. basePath = Path.Combine(_config.CommonApplicationPaths.ProgramDataPath, "sync");
  779. }
  780. return Path.Combine(basePath, jobId);
  781. }
  782. public string GetTemporaryPath(SyncJobItem jobItem)
  783. {
  784. return Path.Combine(GetTemporaryPath(jobItem.JobId), jobItem.Id);
  785. }
  786. private async Task<MediaSourceInfo> GetEncodedMediaSource(string path, User user, bool isVideo)
  787. {
  788. var item = _libraryManager.ResolvePath(_fileSystem.GetFileSystemInfo(path));
  789. await item.RefreshMetadata(CancellationToken.None).ConfigureAwait(false);
  790. var hasMediaSources = item as IHasMediaSources;
  791. var mediaSources = _mediaSourceManager.GetStaticMediaSources(hasMediaSources, false).ToList();
  792. var preferredAudio = string.IsNullOrEmpty(user.Configuration.AudioLanguagePreference)
  793. ? new string[] { }
  794. : new[] { user.Configuration.AudioLanguagePreference };
  795. var preferredSubs = string.IsNullOrEmpty(user.Configuration.SubtitleLanguagePreference)
  796. ? new List<string>() : new List<string> { user.Configuration.SubtitleLanguagePreference };
  797. foreach (var source in mediaSources)
  798. {
  799. if (isVideo)
  800. {
  801. source.DefaultAudioStreamIndex =
  802. MediaStreamSelector.GetDefaultAudioStreamIndex(source.MediaStreams, preferredAudio, user.Configuration.PlayDefaultAudioTrack);
  803. var defaultAudioIndex = source.DefaultAudioStreamIndex;
  804. var audioLangage = defaultAudioIndex == null
  805. ? null
  806. : source.MediaStreams.Where(i => i.Type == MediaStreamType.Audio && i.Index == defaultAudioIndex).Select(i => i.Language).FirstOrDefault();
  807. source.DefaultAudioStreamIndex =
  808. MediaStreamSelector.GetDefaultSubtitleStreamIndex(source.MediaStreams, preferredSubs, user.Configuration.SubtitleMode, audioLangage);
  809. }
  810. else
  811. {
  812. var audio = source.MediaStreams.FirstOrDefault(i => i.Type == MediaStreamType.Audio);
  813. if (audio != null)
  814. {
  815. source.DefaultAudioStreamIndex = audio.Index;
  816. }
  817. }
  818. }
  819. return mediaSources.FirstOrDefault();
  820. }
  821. }
  822. }