SyncJobProcessor.cs 35 KB

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