SyncJobProcessor.cs 38 KB

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