SyncJobProcessor.cs 31 KB

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