SyncJobProcessor.cs 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864
  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 async Task Sync(SyncJobItem jobItem, SyncJob job, Video item, User user, DeviceProfile profile, bool enableConversion, IProgress<double> progress, CancellationToken cancellationToken)
  407. {
  408. var options = _syncManager.GetVideoOptions(jobItem, job);
  409. options.DeviceId = jobItem.TargetId;
  410. options.Context = EncodingContext.Static;
  411. options.Profile = profile;
  412. options.ItemId = item.Id.ToString("N");
  413. options.MediaSources = _mediaSourceManager.GetStaticMediaSources(item, false, user).ToList();
  414. var streamInfo = new StreamBuilder().BuildVideoItem(options);
  415. var mediaSource = streamInfo.MediaSource;
  416. // No sense creating external subs if we're already burning one into the video
  417. var externalSubs = streamInfo.SubtitleDeliveryMethod == SubtitleDeliveryMethod.Encode ?
  418. new List<SubtitleStreamInfo>() :
  419. streamInfo.GetExternalSubtitles(false);
  420. // Mark as requiring conversion if transcoding the video, or if any subtitles need to be extracted
  421. var requiresVideoTranscoding = streamInfo.PlayMethod == PlayMethod.Transcode && job.Quality != SyncQuality.Original;
  422. var requiresConversion = requiresVideoTranscoding || externalSubs.Any(i => RequiresExtraction(i, mediaSource));
  423. if (requiresConversion && !enableConversion)
  424. {
  425. return;
  426. }
  427. jobItem.MediaSourceId = streamInfo.MediaSourceId;
  428. jobItem.TemporaryPath = GetTemporaryPath(jobItem);
  429. if (requiresConversion)
  430. {
  431. jobItem.Status = SyncJobItemStatus.Converting;
  432. }
  433. if (requiresVideoTranscoding)
  434. {
  435. // Save the job item now since conversion could take a while
  436. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  437. await UpdateJobStatus(job).ConfigureAwait(false);
  438. try
  439. {
  440. var lastJobUpdate = DateTime.MinValue;
  441. var innerProgress = new ActionableProgress<double>();
  442. innerProgress.RegisterAction(async pct =>
  443. {
  444. progress.Report(pct);
  445. if ((DateTime.UtcNow - lastJobUpdate).TotalSeconds >= DatabaseProgressUpdateIntervalSeconds)
  446. {
  447. jobItem.Progress = pct / 2;
  448. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  449. await UpdateJobStatus(job).ConfigureAwait(false);
  450. }
  451. });
  452. jobItem.OutputPath = await _mediaEncoder.EncodeVideo(new EncodingJobOptions(streamInfo, profile)
  453. {
  454. OutputDirectory = jobItem.TemporaryPath
  455. }, innerProgress, cancellationToken);
  456. }
  457. catch (OperationCanceledException)
  458. {
  459. jobItem.Status = SyncJobItemStatus.Queued;
  460. jobItem.Progress = 0;
  461. }
  462. catch (Exception ex)
  463. {
  464. jobItem.Status = SyncJobItemStatus.Failed;
  465. _logger.ErrorException("Error during sync transcoding", ex);
  466. }
  467. if (jobItem.Status == SyncJobItemStatus.Failed || jobItem.Status == SyncJobItemStatus.Queued)
  468. {
  469. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  470. return;
  471. }
  472. jobItem.MediaSource = await GetEncodedMediaSource(jobItem.OutputPath, user, true).ConfigureAwait(false);
  473. }
  474. else
  475. {
  476. if (mediaSource.Protocol == MediaProtocol.File)
  477. {
  478. jobItem.OutputPath = mediaSource.Path;
  479. }
  480. else if (mediaSource.Protocol == MediaProtocol.Http)
  481. {
  482. jobItem.OutputPath = await DownloadFile(jobItem, mediaSource, cancellationToken).ConfigureAwait(false);
  483. }
  484. else
  485. {
  486. throw new InvalidOperationException(string.Format("Cannot direct stream {0} protocol", mediaSource.Protocol));
  487. }
  488. jobItem.MediaSource = mediaSource;
  489. }
  490. if (externalSubs.Count > 0)
  491. {
  492. // Save the job item now since conversion could take a while
  493. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  494. await ConvertSubtitles(jobItem, externalSubs, streamInfo, cancellationToken).ConfigureAwait(false);
  495. }
  496. jobItem.Progress = 50;
  497. jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
  498. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  499. }
  500. private bool RequiresExtraction(SubtitleStreamInfo stream, MediaSourceInfo mediaSource)
  501. {
  502. var originalStream = mediaSource.MediaStreams.FirstOrDefault(i => i.Type == MediaStreamType.Subtitle && i.Index == stream.Index);
  503. return originalStream != null && !originalStream.IsExternal;
  504. }
  505. private async Task ConvertSubtitles(SyncJobItem jobItem,
  506. IEnumerable<SubtitleStreamInfo> subtitles,
  507. StreamInfo streamInfo,
  508. CancellationToken cancellationToken)
  509. {
  510. var files = new List<ItemFileInfo>();
  511. var mediaStreams = jobItem.MediaSource.MediaStreams
  512. .Where(i => i.Type != MediaStreamType.Subtitle || !i.IsExternal)
  513. .ToList();
  514. var startingIndex = mediaStreams.Count == 0 ?
  515. 0 :
  516. (mediaStreams.Select(i => i.Index).Max() + 1);
  517. foreach (var subtitle in subtitles)
  518. {
  519. var fileInfo = await ConvertSubtitles(jobItem.TemporaryPath, streamInfo, subtitle, cancellationToken).ConfigureAwait(false);
  520. // Reset this to a value that will be based on the output media
  521. fileInfo.Index = startingIndex;
  522. files.Add(fileInfo);
  523. mediaStreams.Add(new MediaStream
  524. {
  525. Index = startingIndex,
  526. Codec = subtitle.Format,
  527. IsForced = subtitle.IsForced,
  528. IsExternal = true,
  529. Language = subtitle.Language,
  530. Path = fileInfo.Path,
  531. SupportsExternalStream = true
  532. });
  533. startingIndex++;
  534. }
  535. jobItem.AdditionalFiles.AddRange(files);
  536. jobItem.MediaSource.MediaStreams = mediaStreams;
  537. }
  538. private async Task<ItemFileInfo> ConvertSubtitles(string temporaryPath, StreamInfo streamInfo, SubtitleStreamInfo subtitleStreamInfo, CancellationToken cancellationToken)
  539. {
  540. var subtitleStreamIndex = subtitleStreamInfo.Index;
  541. var filename = Guid.NewGuid() + "." + subtitleStreamInfo.Format.ToLower();
  542. var path = Path.Combine(temporaryPath, filename);
  543. Directory.CreateDirectory(Path.GetDirectoryName(path));
  544. using (var stream = await _subtitleEncoder.GetSubtitles(streamInfo.ItemId, streamInfo.MediaSourceId, subtitleStreamIndex, subtitleStreamInfo.Format, 0, null, cancellationToken).ConfigureAwait(false))
  545. {
  546. using (var fs = _fileSystem.GetFileStream(path, FileMode.Create, FileAccess.Write, FileShare.Read, true))
  547. {
  548. await stream.CopyToAsync(fs, StreamDefaults.DefaultCopyToBufferSize, cancellationToken).ConfigureAwait(false);
  549. }
  550. }
  551. return new ItemFileInfo
  552. {
  553. Name = Path.GetFileName(path),
  554. Path = path,
  555. Type = ItemFileType.Subtitles,
  556. Index = subtitleStreamIndex
  557. };
  558. }
  559. private const int DatabaseProgressUpdateIntervalSeconds = 2;
  560. private async Task Sync(SyncJobItem jobItem, SyncJob job, Audio item, User user, DeviceProfile profile, bool enableConversion, IProgress<double> progress, CancellationToken cancellationToken)
  561. {
  562. var options = _syncManager.GetAudioOptions(jobItem);
  563. options.DeviceId = jobItem.TargetId;
  564. options.Context = EncodingContext.Static;
  565. options.Profile = profile;
  566. options.ItemId = item.Id.ToString("N");
  567. options.MediaSources = _mediaSourceManager.GetStaticMediaSources(item, false, user).ToList();
  568. var streamInfo = new StreamBuilder().BuildAudioItem(options);
  569. var mediaSource = streamInfo.MediaSource;
  570. jobItem.MediaSourceId = streamInfo.MediaSourceId;
  571. jobItem.TemporaryPath = GetTemporaryPath(jobItem);
  572. if (streamInfo.PlayMethod == PlayMethod.Transcode && job.Quality != SyncQuality.Original)
  573. {
  574. if (!enableConversion)
  575. {
  576. return;
  577. }
  578. jobItem.Status = SyncJobItemStatus.Converting;
  579. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  580. await UpdateJobStatus(job).ConfigureAwait(false);
  581. try
  582. {
  583. var lastJobUpdate = DateTime.MinValue;
  584. var innerProgress = new ActionableProgress<double>();
  585. innerProgress.RegisterAction(async pct =>
  586. {
  587. progress.Report(pct);
  588. if ((DateTime.UtcNow - lastJobUpdate).TotalSeconds >= DatabaseProgressUpdateIntervalSeconds)
  589. {
  590. jobItem.Progress = pct / 2;
  591. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  592. await UpdateJobStatus(job).ConfigureAwait(false);
  593. }
  594. });
  595. jobItem.OutputPath = await _mediaEncoder.EncodeAudio(new EncodingJobOptions(streamInfo, profile)
  596. {
  597. OutputDirectory = jobItem.TemporaryPath
  598. }, innerProgress, cancellationToken);
  599. }
  600. catch (OperationCanceledException)
  601. {
  602. jobItem.Status = SyncJobItemStatus.Queued;
  603. jobItem.Progress = 0;
  604. }
  605. catch (Exception ex)
  606. {
  607. jobItem.Status = SyncJobItemStatus.Failed;
  608. _logger.ErrorException("Error during sync transcoding", ex);
  609. }
  610. if (jobItem.Status == SyncJobItemStatus.Failed || jobItem.Status == SyncJobItemStatus.Queued)
  611. {
  612. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  613. return;
  614. }
  615. jobItem.MediaSource = await GetEncodedMediaSource(jobItem.OutputPath, user, false).ConfigureAwait(false);
  616. }
  617. else
  618. {
  619. if (mediaSource.Protocol == MediaProtocol.File)
  620. {
  621. jobItem.OutputPath = mediaSource.Path;
  622. }
  623. else if (mediaSource.Protocol == MediaProtocol.Http)
  624. {
  625. jobItem.OutputPath = await DownloadFile(jobItem, mediaSource, cancellationToken).ConfigureAwait(false);
  626. }
  627. else
  628. {
  629. throw new InvalidOperationException(string.Format("Cannot direct stream {0} protocol", mediaSource.Protocol));
  630. }
  631. jobItem.MediaSource = mediaSource;
  632. }
  633. jobItem.Progress = 50;
  634. jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
  635. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  636. }
  637. private async Task Sync(SyncJobItem jobItem, Photo item, DeviceProfile profile, CancellationToken cancellationToken)
  638. {
  639. jobItem.OutputPath = item.Path;
  640. jobItem.Progress = 50;
  641. jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
  642. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  643. }
  644. private async Task SyncGeneric(SyncJobItem jobItem, BaseItem item, CancellationToken cancellationToken)
  645. {
  646. jobItem.OutputPath = item.Path;
  647. jobItem.Progress = 50;
  648. jobItem.Status = SyncJobItemStatus.ReadyToTransfer;
  649. await _syncManager.UpdateSyncJobItemInternal(jobItem).ConfigureAwait(false);
  650. }
  651. private async Task<string> DownloadFile(SyncJobItem jobItem, MediaSourceInfo mediaSource, CancellationToken cancellationToken)
  652. {
  653. // TODO: Download
  654. return mediaSource.Path;
  655. }
  656. public string GetTemporaryPath(SyncJob job)
  657. {
  658. return GetTemporaryPath(job.Id);
  659. }
  660. public string GetTemporaryPath(string jobId)
  661. {
  662. var basePath = _config.GetSyncOptions().TemporaryPath;
  663. if (string.IsNullOrWhiteSpace(basePath))
  664. {
  665. basePath = Path.Combine(_config.CommonApplicationPaths.ProgramDataPath, "sync");
  666. }
  667. return Path.Combine(basePath, jobId);
  668. }
  669. public string GetTemporaryPath(SyncJobItem jobItem)
  670. {
  671. return Path.Combine(GetTemporaryPath(jobItem.JobId), jobItem.Id);
  672. }
  673. private async Task<MediaSourceInfo> GetEncodedMediaSource(string path, User user, bool isVideo)
  674. {
  675. var item = _libraryManager.ResolvePath(new FileInfo(path));
  676. await item.RefreshMetadata(CancellationToken.None).ConfigureAwait(false);
  677. var hasMediaSources = item as IHasMediaSources;
  678. var mediaSources = hasMediaSources.GetMediaSources(false).ToList();
  679. var preferredAudio = string.IsNullOrEmpty(user.Configuration.AudioLanguagePreference)
  680. ? new string[] { }
  681. : new[] { user.Configuration.AudioLanguagePreference };
  682. var preferredSubs = string.IsNullOrEmpty(user.Configuration.SubtitleLanguagePreference)
  683. ? new List<string> { }
  684. : new List<string> { user.Configuration.SubtitleLanguagePreference };
  685. foreach (var source in mediaSources)
  686. {
  687. if (isVideo)
  688. {
  689. source.DefaultAudioStreamIndex =
  690. MediaStreamSelector.GetDefaultAudioStreamIndex(source.MediaStreams, preferredAudio, user.Configuration.PlayDefaultAudioTrack);
  691. var defaultAudioIndex = source.DefaultAudioStreamIndex;
  692. var audioLangage = defaultAudioIndex == null
  693. ? null
  694. : source.MediaStreams.Where(i => i.Type == MediaStreamType.Audio && i.Index == defaultAudioIndex).Select(i => i.Language).FirstOrDefault();
  695. source.DefaultAudioStreamIndex =
  696. MediaStreamSelector.GetDefaultSubtitleStreamIndex(source.MediaStreams, preferredSubs, user.Configuration.SubtitleMode, audioLangage);
  697. }
  698. else
  699. {
  700. var audio = source.MediaStreams.FirstOrDefault(i => i.Type == MediaStreamType.Audio);
  701. if (audio != null)
  702. {
  703. source.DefaultAudioStreamIndex = audio.Index;
  704. }
  705. }
  706. }
  707. return mediaSources.FirstOrDefault();
  708. }
  709. }
  710. }