SyncJobProcessor.cs 35 KB

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