SyncJobProcessor.cs 33 KB

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