ControlHandler.cs 39 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111
  1. using MediaBrowser.Common.Extensions;
  2. using MediaBrowser.Common.Net;
  3. using MediaBrowser.Controller.Dlna;
  4. using MediaBrowser.Controller.Drawing;
  5. using MediaBrowser.Controller.Dto;
  6. using MediaBrowser.Controller.Entities;
  7. using MediaBrowser.Controller.Entities.Audio;
  8. using MediaBrowser.Controller.Entities.Movies;
  9. using MediaBrowser.Controller.Entities.TV;
  10. using MediaBrowser.Controller.Library;
  11. using MediaBrowser.Model.Dlna;
  12. using MediaBrowser.Model.Drawing;
  13. using MediaBrowser.Model.Entities;
  14. using MediaBrowser.Model.Logging;
  15. using MediaBrowser.Model.Querying;
  16. using System;
  17. using System.Collections.Generic;
  18. using System.Globalization;
  19. using System.Linq;
  20. using System.Text;
  21. using System.Threading;
  22. using System.Xml;
  23. namespace MediaBrowser.Dlna.Server
  24. {
  25. public class ControlHandler
  26. {
  27. private readonly ILogger _logger;
  28. private readonly ILibraryManager _libraryManager;
  29. private readonly DeviceProfile _profile;
  30. private readonly IDtoService _dtoService;
  31. private readonly IImageProcessor _imageProcessor;
  32. private readonly IUserDataManager _userDataManager;
  33. private readonly User _user;
  34. private readonly string _serverAddress;
  35. private const string NS_DC = "http://purl.org/dc/elements/1.1/";
  36. private const string NS_DIDL = "urn:schemas-upnp-org:metadata-1-0/DIDL-Lite/";
  37. private const string NS_DLNA = "urn:schemas-dlna-org:metadata-1-0/";
  38. private const string NS_SEC = "http://www.sec.co.kr/";
  39. private const string NS_SOAPENV = "http://schemas.xmlsoap.org/soap/envelope/";
  40. private const string NS_UPNP = "urn:schemas-upnp-org:metadata-1-0/upnp/";
  41. private readonly int _systemUpdateId;
  42. private readonly CultureInfo _usCulture = new CultureInfo("en-US");
  43. public ControlHandler(ILogger logger, ILibraryManager libraryManager, DeviceProfile profile, string serverAddress, IDtoService dtoService, IImageProcessor imageProcessor, IUserDataManager userDataManager, User user, int systemUpdateId)
  44. {
  45. _logger = logger;
  46. _libraryManager = libraryManager;
  47. _profile = profile;
  48. _serverAddress = serverAddress;
  49. _dtoService = dtoService;
  50. _imageProcessor = imageProcessor;
  51. _userDataManager = userDataManager;
  52. _user = user;
  53. _systemUpdateId = systemUpdateId;
  54. }
  55. public ControlResponse ProcessControlRequest(ControlRequest request)
  56. {
  57. try
  58. {
  59. return ProcessControlRequestInternal(request);
  60. }
  61. catch (Exception ex)
  62. {
  63. _logger.ErrorException("Error processing control request", ex);
  64. return GetErrorResponse(ex);
  65. }
  66. }
  67. private ControlResponse ProcessControlRequestInternal(ControlRequest request)
  68. {
  69. var soap = new XmlDocument();
  70. soap.LoadXml(request.InputXml);
  71. var sparams = new Headers();
  72. var body = soap.GetElementsByTagName("Body", NS_SOAPENV).Item(0);
  73. var method = body.FirstChild;
  74. foreach (var p in method.ChildNodes)
  75. {
  76. var e = p as XmlElement;
  77. if (e == null)
  78. {
  79. continue;
  80. }
  81. sparams.Add(e.LocalName, e.InnerText.Trim());
  82. }
  83. var deviceId = "fgd";
  84. var env = new XmlDocument();
  85. env.AppendChild(env.CreateXmlDeclaration("1.0", "utf-8", "yes"));
  86. var envelope = env.CreateElement("SOAP-ENV", "Envelope", NS_SOAPENV);
  87. env.AppendChild(envelope);
  88. envelope.SetAttribute("encodingStyle", NS_SOAPENV, "http://schemas.xmlsoap.org/soap/encoding/");
  89. var rbody = env.CreateElement("SOAP-ENV:Body", NS_SOAPENV);
  90. env.DocumentElement.AppendChild(rbody);
  91. IEnumerable<KeyValuePair<string, string>> result;
  92. _logger.Debug("Received control request {0}", method.Name);
  93. var user = _user;
  94. if (string.Equals(method.LocalName, "GetSearchCapabilities", StringComparison.OrdinalIgnoreCase))
  95. result = HandleGetSearchCapabilities();
  96. else if (string.Equals(method.LocalName, "GetSortCapabilities", StringComparison.OrdinalIgnoreCase))
  97. result = HandleGetSortCapabilities();
  98. else if (string.Equals(method.LocalName, "GetSystemUpdateID", StringComparison.OrdinalIgnoreCase))
  99. result = HandleGetSystemUpdateID();
  100. else if (string.Equals(method.LocalName, "Browse", StringComparison.OrdinalIgnoreCase))
  101. result = HandleBrowse(sparams, user, deviceId);
  102. else if (string.Equals(method.LocalName, "X_GetFeatureList", StringComparison.OrdinalIgnoreCase))
  103. result = HandleXGetFeatureList();
  104. else if (string.Equals(method.LocalName, "X_SetBookmark", StringComparison.OrdinalIgnoreCase))
  105. result = HandleXSetBookmark(sparams, user);
  106. else if (string.Equals(method.LocalName, "Search", StringComparison.OrdinalIgnoreCase))
  107. result = HandleSearch(sparams, user, deviceId);
  108. else
  109. throw new ResourceNotFoundException("Unexpected control request name: " + method.LocalName);
  110. var response = env.CreateElement(String.Format("u:{0}Response", method.LocalName), method.NamespaceURI);
  111. rbody.AppendChild(response);
  112. foreach (var i in result)
  113. {
  114. var ri = env.CreateElement(i.Key);
  115. ri.InnerText = i.Value;
  116. response.AppendChild(ri);
  117. }
  118. var controlResponse = new ControlResponse
  119. {
  120. Xml = env.OuterXml,
  121. IsSuccessful = true
  122. };
  123. controlResponse.Headers.Add("EXT", string.Empty);
  124. return controlResponse;
  125. }
  126. private ControlResponse GetErrorResponse(Exception ex)
  127. {
  128. var env = new XmlDocument();
  129. env.AppendChild(env.CreateXmlDeclaration("1.0", "utf-8", "yes"));
  130. var envelope = env.CreateElement("SOAP-ENV", "Envelope", NS_SOAPENV);
  131. env.AppendChild(envelope);
  132. envelope.SetAttribute("encodingStyle", NS_SOAPENV, "http://schemas.xmlsoap.org/soap/encoding/");
  133. var rbody = env.CreateElement("SOAP-ENV:Body", NS_SOAPENV);
  134. env.DocumentElement.AppendChild(rbody);
  135. var fault = env.CreateElement("SOAP-ENV", "Fault", NS_SOAPENV);
  136. var faultCode = env.CreateElement("faultcode");
  137. faultCode.InnerText = "500";
  138. fault.AppendChild(faultCode);
  139. var faultString = env.CreateElement("faultstring");
  140. faultString.InnerText = ex.ToString();
  141. fault.AppendChild(faultString);
  142. var detail = env.CreateDocumentFragment();
  143. detail.InnerXml = "<detail><UPnPError xmlns=\"urn:schemas-upnp-org:control-1-0\"><errorCode>401</errorCode><errorDescription>Invalid Action</errorDescription></UPnPError></detail>";
  144. fault.AppendChild(detail);
  145. rbody.AppendChild(fault);
  146. return new ControlResponse
  147. {
  148. Xml = env.OuterXml,
  149. IsSuccessful = false
  150. };
  151. }
  152. private IEnumerable<KeyValuePair<string, string>> HandleXSetBookmark(IDictionary<string, string> sparams, User user)
  153. {
  154. var id = sparams["ObjectID"];
  155. var item = GetItemFromObjectId(id, user);
  156. var newbookmark = int.Parse(sparams["PosSecond"], _usCulture);
  157. var userdata = _userDataManager.GetUserData(user.Id, item.GetUserDataKey());
  158. userdata.PlaybackPositionTicks = TimeSpan.FromSeconds(newbookmark).Ticks;
  159. _userDataManager.SaveUserData(user.Id, item, userdata, UserDataSaveReason.TogglePlayed,
  160. CancellationToken.None);
  161. return new Headers();
  162. }
  163. private IEnumerable<KeyValuePair<string, string>> HandleGetSearchCapabilities()
  164. {
  165. return new Headers { { "SearchCaps", string.Empty } };
  166. }
  167. private IEnumerable<KeyValuePair<string, string>> HandleGetSortCapabilities()
  168. {
  169. return new Headers { { "SortCaps", string.Empty } };
  170. }
  171. private IEnumerable<KeyValuePair<string, string>> HandleGetSystemUpdateID()
  172. {
  173. return new Headers { { "Id", _systemUpdateId.ToString(_usCulture) } };
  174. }
  175. private IEnumerable<KeyValuePair<string, string>> HandleXGetFeatureList()
  176. {
  177. return new Headers { { "FeatureList", GetFeatureListXml() } };
  178. }
  179. private string GetFeatureListXml()
  180. {
  181. var builder = new StringBuilder();
  182. builder.Append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
  183. builder.Append("<Features xmlns=\"urn:schemas-upnp-org:av:avs\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:schemaLocation=\"urn:schemas-upnp-org:av:avs http://www.upnp.org/schemas/av/avs.xsd\">");
  184. builder.Append("<Feature name=\"samsung.com_BASICVIEW\" version=\"1\">");
  185. builder.Append("<container id=\"I\" type=\"object.item.imageItem\"/>");
  186. builder.Append("<container id=\"A\" type=\"object.item.audioItem\"/>");
  187. builder.Append("<container id=\"V\" type=\"object.item.videoItem\"/>");
  188. builder.Append("</Feature>");
  189. builder.Append("</Features>");
  190. return builder.ToString();
  191. }
  192. private IEnumerable<KeyValuePair<string, string>> HandleBrowse(Headers sparams, User user, string deviceId)
  193. {
  194. var id = sparams["ObjectID"];
  195. var flag = sparams["BrowseFlag"];
  196. var filter = new Filter(sparams.GetValueOrDefault("Filter", "*"));
  197. var sortCriteria = new SortCriteria(sparams.GetValueOrDefault("SortCriteria", ""));
  198. var provided = 0;
  199. var requested = 0;
  200. var start = 0;
  201. if (sparams.ContainsKey("RequestedCount") && int.TryParse(sparams["RequestedCount"], out requested) && requested <= 0)
  202. {
  203. requested = 0;
  204. }
  205. if (sparams.ContainsKey("StartingIndex") && int.TryParse(sparams["StartingIndex"], out start) && start <= 0)
  206. {
  207. start = 0;
  208. }
  209. //var root = GetItem(id) as IMediaFolder;
  210. var result = new XmlDocument();
  211. var didl = result.CreateElement(string.Empty, "DIDL-Lite", NS_DIDL);
  212. didl.SetAttribute("xmlns:dc", NS_DC);
  213. didl.SetAttribute("xmlns:dlna", NS_DLNA);
  214. didl.SetAttribute("xmlns:upnp", NS_UPNP);
  215. //didl.SetAttribute("xmlns:sec", NS_SEC);
  216. result.AppendChild(didl);
  217. var folder = (Folder)GetItemFromObjectId(id, user);
  218. var children = GetChildrenSorted(folder, user, sortCriteria).ToList();
  219. var totalCount = children.Count;
  220. if (string.Equals(flag, "BrowseMetadata"))
  221. {
  222. Browse_AddFolder(result, folder, children.Count, filter);
  223. provided++;
  224. }
  225. else
  226. {
  227. if (start > 0)
  228. {
  229. children = children.Skip(start).ToList();
  230. }
  231. if (requested > 0)
  232. {
  233. children = children.Take(requested).ToList();
  234. }
  235. provided = children.Count;
  236. foreach (var i in children)
  237. {
  238. if (i.IsFolder)
  239. {
  240. var f = (Folder)i;
  241. var childCount = GetChildrenSorted(f, user, sortCriteria).Count();
  242. Browse_AddFolder(result, f, childCount, filter);
  243. }
  244. else
  245. {
  246. Browse_AddItem(result, i, deviceId, filter);
  247. }
  248. }
  249. }
  250. var resXML = result.OuterXml;
  251. return new List<KeyValuePair<string, string>>
  252. {
  253. new KeyValuePair<string,string>("Result", resXML),
  254. new KeyValuePair<string,string>("NumberReturned", provided.ToString(_usCulture)),
  255. new KeyValuePair<string,string>("TotalMatches", totalCount.ToString(_usCulture)),
  256. new KeyValuePair<string,string>("UpdateID", _systemUpdateId.ToString(_usCulture))
  257. };
  258. }
  259. private IEnumerable<KeyValuePair<string, string>> HandleSearch(Headers sparams, User user, string deviceId)
  260. {
  261. var searchCriteria = new SearchCriteria(sparams.GetValueOrDefault("SearchCriteria", ""));
  262. var sortCriteria = new SortCriteria(sparams.GetValueOrDefault("SortCriteria", ""));
  263. var filter = new Filter(sparams.GetValueOrDefault("Filter", "*"));
  264. // sort example: dc:title, dc:date
  265. var provided = 0;
  266. var requested = 0;
  267. var start = 0;
  268. if (sparams.ContainsKey("RequestedCount") && int.TryParse(sparams["RequestedCount"], out requested) && requested <= 0)
  269. {
  270. requested = 0;
  271. }
  272. if (sparams.ContainsKey("StartingIndex") && int.TryParse(sparams["StartingIndex"], out start) && start <= 0)
  273. {
  274. start = 0;
  275. }
  276. //var root = GetItem(id) as IMediaFolder;
  277. var result = new XmlDocument();
  278. var didl = result.CreateElement(string.Empty, "DIDL-Lite", NS_DIDL);
  279. didl.SetAttribute("xmlns:dc", NS_DC);
  280. didl.SetAttribute("xmlns:dlna", NS_DLNA);
  281. didl.SetAttribute("xmlns:upnp", NS_UPNP);
  282. //didl.SetAttribute("xmlns:sec", NS_SEC);
  283. result.AppendChild(didl);
  284. var folder = (Folder)GetItemFromObjectId(sparams["ContainerID"], user);
  285. var children = GetChildrenSorted(folder, user, searchCriteria, sortCriteria).ToList();
  286. var totalCount = children.Count;
  287. if (start > 0)
  288. {
  289. children = children.Skip(start).ToList();
  290. }
  291. if (requested > 0)
  292. {
  293. children = children.Take(requested).ToList();
  294. }
  295. provided = children.Count;
  296. foreach (var i in children)
  297. {
  298. if (i.IsFolder)
  299. {
  300. var f = (Folder)i;
  301. var childCount = GetChildrenSorted(f, user, searchCriteria, sortCriteria).Count();
  302. Browse_AddFolder(result, f, childCount, filter);
  303. }
  304. else
  305. {
  306. Browse_AddItem(result, i, deviceId, filter);
  307. }
  308. }
  309. var resXML = result.OuterXml;
  310. return new List<KeyValuePair<string, string>>
  311. {
  312. new KeyValuePair<string,string>("Result", resXML),
  313. new KeyValuePair<string,string>("NumberReturned", provided.ToString(_usCulture)),
  314. new KeyValuePair<string,string>("TotalMatches", totalCount.ToString(_usCulture)),
  315. new KeyValuePair<string,string>("UpdateID", _systemUpdateId.ToString(_usCulture))
  316. };
  317. }
  318. private IEnumerable<BaseItem> GetChildrenSorted(Folder folder, User user, SearchCriteria search, SortCriteria sort)
  319. {
  320. if (search.SearchType == SearchType.Unknown)
  321. {
  322. return GetChildrenSorted(folder, user, sort);
  323. }
  324. var items = folder.GetRecursiveChildren(user);
  325. items = FilterUnsupportedContent(items);
  326. if (search.SearchType == SearchType.Audio)
  327. {
  328. items = items.OfType<Audio>();
  329. }
  330. else if (search.SearchType == SearchType.Video)
  331. {
  332. items = items.OfType<Video>();
  333. }
  334. else if (search.SearchType == SearchType.Image)
  335. {
  336. items = items.OfType<Photo>();
  337. }
  338. else if (search.SearchType == SearchType.Playlist)
  339. {
  340. }
  341. return SortItems(items, user, sort);
  342. }
  343. private IEnumerable<BaseItem> GetChildrenSorted(Folder folder, User user, SortCriteria sort)
  344. {
  345. var items = folder.GetChildren(user, true);
  346. items = FilterUnsupportedContent(items);
  347. if (folder is Series || folder is Season || folder is BoxSet)
  348. {
  349. return items;
  350. }
  351. return SortItems(items, user, sort);
  352. }
  353. private IEnumerable<BaseItem> SortItems(IEnumerable<BaseItem> items, User user, SortCriteria sort)
  354. {
  355. return _libraryManager.Sort(items, user, new[] { ItemSortBy.SortName }, SortOrder.Ascending);
  356. }
  357. private IEnumerable<BaseItem> FilterUnsupportedContent(IEnumerable<BaseItem> items)
  358. {
  359. return items.Where(i =>
  360. {
  361. // Unplayable
  362. // TODO: Display and prevent playback with restricted flag?
  363. if (i.LocationType == LocationType.Virtual)
  364. {
  365. return false;
  366. }
  367. // Unplayable
  368. // TODO: Display and prevent playback with restricted flag?
  369. var supportsPlaceHolder = i as ISupportsPlaceHolders;
  370. if (supportsPlaceHolder != null && supportsPlaceHolder.IsPlaceHolder)
  371. {
  372. return false;
  373. }
  374. // Upnp renderers won't understand these
  375. // TODO: Display and prevent playback with restricted flag?
  376. if (i is Game || i is Book)
  377. {
  378. return false;
  379. }
  380. return true;
  381. });
  382. }
  383. private BaseItem GetItemFromObjectId(string id, User user)
  384. {
  385. return string.IsNullOrWhiteSpace(id) || string.Equals(id, "0", StringComparison.OrdinalIgnoreCase)
  386. // Samsung sometimes uses 1 as root
  387. || string.Equals(id, "1", StringComparison.OrdinalIgnoreCase)
  388. ? user.RootFolder
  389. : _libraryManager.GetItemById(new Guid(id));
  390. }
  391. private void Browse_AddFolder(XmlDocument result, Folder f, int childCount, Filter filter)
  392. {
  393. var container = result.CreateElement(string.Empty, "container", NS_DIDL);
  394. container.SetAttribute("restricted", "0");
  395. container.SetAttribute("searchable", "1");
  396. container.SetAttribute("childCount", childCount.ToString(_usCulture));
  397. container.SetAttribute("id", f.Id.ToString("N"));
  398. var parent = f.Parent;
  399. if (parent == null)
  400. {
  401. container.SetAttribute("parentID", "0");
  402. }
  403. else
  404. {
  405. container.SetAttribute("parentID", parent.Id.ToString("N"));
  406. }
  407. AddCommonFields(f, container, filter);
  408. AddCover(f, container);
  409. result.DocumentElement.AppendChild(container);
  410. }
  411. private void AddValue(XmlElement elem, string prefix, string name, string value, string namespaceUri)
  412. {
  413. try
  414. {
  415. var date = elem.OwnerDocument.CreateElement(prefix, name, namespaceUri);
  416. date.InnerText = value;
  417. elem.AppendChild(date);
  418. }
  419. catch (XmlException)
  420. {
  421. //_logger.Error("Error adding xml value: " + value);
  422. }
  423. }
  424. private void Browse_AddItem(XmlDocument result, BaseItem item, string deviceId, Filter filter)
  425. {
  426. var element = result.CreateElement(string.Empty, "item", NS_DIDL);
  427. element.SetAttribute("restricted", "1");
  428. element.SetAttribute("id", item.Id.ToString("N"));
  429. if (item.Parent != null)
  430. {
  431. element.SetAttribute("parentID", item.Parent.Id.ToString("N"));
  432. }
  433. //AddBookmarkInfo(item, user, element);
  434. AddGeneralProperties(item, element, filter);
  435. // refID?
  436. // storeAttribute(itemNode, object, ClassProperties.REF_ID, false);
  437. var audio = item as Audio;
  438. if (audio != null)
  439. {
  440. AddAudioResource(element, audio, deviceId, filter);
  441. }
  442. var video = item as Video;
  443. if (video != null)
  444. {
  445. AddVideoResource(element, video, deviceId, filter);
  446. }
  447. AddCover(item, element);
  448. result.DocumentElement.AppendChild(element);
  449. }
  450. private void AddVideoResource(XmlElement container, Video video, string deviceId, Filter filter)
  451. {
  452. var res = container.OwnerDocument.CreateElement(string.Empty, "res", NS_DIDL);
  453. var sources = _dtoService.GetMediaSources(video);
  454. int? maxBitrateSetting = null;
  455. var streamInfo = new StreamBuilder().BuildVideoItem(new VideoOptions
  456. {
  457. ItemId = video.Id.ToString("N"),
  458. MediaSources = sources,
  459. Profile = _profile,
  460. DeviceId = deviceId,
  461. MaxBitrate = maxBitrateSetting
  462. });
  463. var url = streamInfo.ToDlnaUrl(_serverAddress);
  464. res.InnerText = url;
  465. var mediaSource = sources.First(i => string.Equals(i.Id, streamInfo.MediaSourceId));
  466. if (mediaSource.RunTimeTicks.HasValue)
  467. {
  468. res.SetAttribute("duration", TimeSpan.FromTicks(mediaSource.RunTimeTicks.Value).ToString("c", _usCulture));
  469. }
  470. if (filter.Contains("res@size"))
  471. {
  472. if (streamInfo.IsDirectStream || streamInfo.EstimateContentLength)
  473. {
  474. var size = streamInfo.TargetSize;
  475. if (size.HasValue)
  476. {
  477. res.SetAttribute("size", size.Value.ToString(_usCulture));
  478. }
  479. }
  480. }
  481. var totalBitrate = streamInfo.TotalOutputBitrate;
  482. var targetSampleRate = streamInfo.TargetAudioSampleRate;
  483. var targetChannels = streamInfo.TargetAudioChannels;
  484. var targetWidth = streamInfo.TargetWidth;
  485. var targetHeight = streamInfo.TargetHeight;
  486. if (targetChannels.HasValue)
  487. {
  488. res.SetAttribute("nrAudioChannels", targetChannels.Value.ToString(_usCulture));
  489. }
  490. if (filter.Contains("res@resolution"))
  491. {
  492. if (targetWidth.HasValue && targetHeight.HasValue)
  493. {
  494. res.SetAttribute("resolution", string.Format("{0}x{1}", targetWidth.Value, targetHeight.Value));
  495. }
  496. }
  497. if (targetSampleRate.HasValue)
  498. {
  499. res.SetAttribute("sampleFrequency", targetSampleRate.Value.ToString(_usCulture));
  500. }
  501. if (totalBitrate.HasValue)
  502. {
  503. res.SetAttribute("bitrate", totalBitrate.Value.ToString(_usCulture));
  504. }
  505. var mediaProfile = _profile.GetVideoMediaProfile(streamInfo.Container,
  506. streamInfo.AudioCodec,
  507. streamInfo.VideoCodec);
  508. var filename = url.Substring(0, url.IndexOf('?'));
  509. var mimeType = mediaProfile == null || string.IsNullOrEmpty(mediaProfile.MimeType)
  510. ? MimeTypes.GetMimeType(filename)
  511. : mediaProfile.MimeType;
  512. var contentFeatures = new ContentFeatureBuilder(_profile).BuildVideoHeader(streamInfo.Container,
  513. streamInfo.VideoCodec,
  514. streamInfo.AudioCodec,
  515. targetWidth,
  516. targetHeight,
  517. totalBitrate,
  518. streamInfo.TargetTimestamp,
  519. streamInfo.IsDirectStream,
  520. streamInfo.RunTimeTicks,
  521. streamInfo.TranscodeSeekInfo);
  522. res.SetAttribute("protocolInfo", String.Format(
  523. "http-get:*:{0}:{1}",
  524. mimeType,
  525. contentFeatures
  526. ));
  527. container.AppendChild(res);
  528. }
  529. private void AddAudioResource(XmlElement container, Audio audio, string deviceId, Filter filter)
  530. {
  531. var res = container.OwnerDocument.CreateElement(string.Empty, "res", NS_DIDL);
  532. var sources = _dtoService.GetMediaSources(audio);
  533. var streamInfo = new StreamBuilder().BuildAudioItem(new AudioOptions
  534. {
  535. ItemId = audio.Id.ToString("N"),
  536. MediaSources = sources,
  537. Profile = _profile,
  538. DeviceId = deviceId
  539. });
  540. var url = streamInfo.ToDlnaUrl(_serverAddress);
  541. res.InnerText = url;
  542. var mediaSource = sources.First(i => string.Equals(i.Id, streamInfo.MediaSourceId));
  543. if (mediaSource.RunTimeTicks.HasValue)
  544. {
  545. res.SetAttribute("duration", TimeSpan.FromTicks(mediaSource.RunTimeTicks.Value).ToString("c", _usCulture));
  546. }
  547. if (filter.Contains("res@size"))
  548. {
  549. if (streamInfo.IsDirectStream || streamInfo.EstimateContentLength)
  550. {
  551. var size = streamInfo.TargetSize;
  552. if (size.HasValue)
  553. {
  554. res.SetAttribute("size", size.Value.ToString(_usCulture));
  555. }
  556. }
  557. }
  558. var targetAudioBitrate = streamInfo.TargetAudioBitrate;
  559. var targetSampleRate = streamInfo.TargetAudioSampleRate;
  560. var targetChannels = streamInfo.TargetAudioChannels;
  561. if (targetChannels.HasValue)
  562. {
  563. res.SetAttribute("nrAudioChannels", targetChannels.Value.ToString(_usCulture));
  564. }
  565. if (targetSampleRate.HasValue)
  566. {
  567. res.SetAttribute("sampleFrequency", targetSampleRate.Value.ToString(_usCulture));
  568. }
  569. if (targetAudioBitrate.HasValue)
  570. {
  571. res.SetAttribute("bitrate", targetAudioBitrate.Value.ToString(_usCulture));
  572. }
  573. var mediaProfile = _profile.GetAudioMediaProfile(streamInfo.Container,
  574. streamInfo.AudioCodec);
  575. var filename = url.Substring(0, url.IndexOf('?'));
  576. var mimeType = mediaProfile == null || string.IsNullOrEmpty(mediaProfile.MimeType)
  577. ? MimeTypes.GetMimeType(filename)
  578. : mediaProfile.MimeType;
  579. var contentFeatures = new ContentFeatureBuilder(_profile).BuildAudioHeader(streamInfo.Container,
  580. streamInfo.TargetAudioCodec,
  581. targetAudioBitrate,
  582. targetSampleRate,
  583. targetChannels,
  584. streamInfo.IsDirectStream,
  585. streamInfo.RunTimeTicks,
  586. streamInfo.TranscodeSeekInfo);
  587. res.SetAttribute("protocolInfo", String.Format(
  588. "http-get:*:{0}:{1}",
  589. mimeType,
  590. contentFeatures
  591. ));
  592. container.AppendChild(res);
  593. }
  594. private XmlElement CreateObjectClass(XmlDocument result, BaseItem item)
  595. {
  596. var objectClass = result.CreateElement("upnp", "class", NS_UPNP);
  597. if (item.IsFolder)
  598. {
  599. string classType = null;
  600. if (!_profile.RequiresPlainFolders)
  601. {
  602. if (item is MusicAlbum)
  603. {
  604. classType = "object.container.album.musicAlbum";
  605. }
  606. if (item is MusicArtist)
  607. {
  608. classType = "object.container.person.musicArtist";
  609. }
  610. }
  611. objectClass.InnerText = classType ?? "object.container.storageFolder";
  612. }
  613. else if (string.Equals(item.MediaType, MediaType.Audio, StringComparison.OrdinalIgnoreCase))
  614. {
  615. objectClass.InnerText = "object.item.audioItem.musicTrack";
  616. }
  617. else if (string.Equals(item.MediaType, MediaType.Photo, StringComparison.OrdinalIgnoreCase))
  618. {
  619. objectClass.InnerText = "object.item.imageItem.photo";
  620. }
  621. else if (string.Equals(item.MediaType, MediaType.Video, StringComparison.OrdinalIgnoreCase))
  622. {
  623. if (!_profile.RequiresPlainVideoItems && item is Movie)
  624. {
  625. objectClass.InnerText = "object.item.videoItem.movie";
  626. }
  627. else
  628. {
  629. objectClass.InnerText = "object.item.videoItem";
  630. }
  631. }
  632. else
  633. {
  634. throw new NotSupportedException();
  635. }
  636. return objectClass;
  637. }
  638. private void AddPeople(BaseItem item, XmlElement element)
  639. {
  640. foreach (var actor in item.People)
  641. {
  642. AddValue(element, "upnp", (actor.Type ?? PersonType.Actor).ToLower(), actor.Name, NS_UPNP);
  643. }
  644. }
  645. private void AddBookmarkInfo(BaseItem item, User user, XmlElement element)
  646. {
  647. var userdata = _userDataManager.GetUserData(user.Id, item.GetUserDataKey());
  648. if (userdata.PlaybackPositionTicks > 0)
  649. {
  650. var dcmInfo = element.OwnerDocument.CreateElement("sec", "dcmInfo", NS_SEC);
  651. dcmInfo.InnerText = string.Format("BM={0}", Convert.ToInt32(TimeSpan.FromTicks(userdata.PlaybackPositionTicks).TotalSeconds).ToString(_usCulture));
  652. element.AppendChild(dcmInfo);
  653. }
  654. }
  655. /// <summary>
  656. /// Adds fields used by both items and folders
  657. /// </summary>
  658. /// <param name="item">The item.</param>
  659. /// <param name="element">The element.</param>
  660. /// <param name="filter">The filter.</param>
  661. private void AddCommonFields(BaseItem item, XmlElement element, Filter filter)
  662. {
  663. if (filter.Contains("dc:title"))
  664. {
  665. AddValue(element, "dc", "title", item.Name, NS_DC);
  666. }
  667. element.AppendChild(CreateObjectClass(element.OwnerDocument, item));
  668. if (filter.Contains("dc:date"))
  669. {
  670. if (item.PremiereDate.HasValue)
  671. {
  672. AddValue(element, "dc", "date", item.PremiereDate.Value.ToString("o"), NS_DC);
  673. }
  674. }
  675. foreach (var genre in item.Genres)
  676. {
  677. AddValue(element, "upnp", "genre", genre, NS_UPNP);
  678. }
  679. foreach (var studio in item.Studios)
  680. {
  681. AddValue(element, "upnp", "publisher", studio, NS_UPNP);
  682. }
  683. if (filter.Contains("dc:description"))
  684. {
  685. if (!string.IsNullOrWhiteSpace(item.Overview))
  686. {
  687. AddValue(element, "dc", "description", item.Overview, NS_DC);
  688. }
  689. }
  690. if (filter.Contains("upnp:longDescription"))
  691. {
  692. if (!string.IsNullOrWhiteSpace(item.Overview))
  693. {
  694. AddValue(element, "upnp", "longDescription", item.Overview, NS_UPNP);
  695. }
  696. }
  697. if (!string.IsNullOrEmpty(item.OfficialRating))
  698. {
  699. if (filter.Contains("dc:rating"))
  700. {
  701. AddValue(element, "dc", "rating", item.OfficialRating, NS_DC);
  702. }
  703. if (filter.Contains("upnp:rating"))
  704. {
  705. AddValue(element, "upnp", "rating", item.OfficialRating, NS_UPNP);
  706. }
  707. }
  708. AddPeople(item, element);
  709. }
  710. private void AddGeneralProperties(BaseItem item, XmlElement element, Filter filter)
  711. {
  712. AddCommonFields(item, element, filter);
  713. var audio = item as Audio;
  714. if (audio != null)
  715. {
  716. foreach (var artist in audio.Artists)
  717. {
  718. AddValue(element, "upnp", "artist", artist, NS_UPNP);
  719. }
  720. if (!string.IsNullOrEmpty(audio.Album))
  721. {
  722. AddValue(element, "upnp", "album", audio.Album, NS_UPNP);
  723. }
  724. if (!string.IsNullOrEmpty(audio.AlbumArtist))
  725. {
  726. AddValue(element, "upnp", "albumArtist", audio.AlbumArtist, NS_UPNP);
  727. }
  728. }
  729. var album = item as MusicAlbum;
  730. if (album != null)
  731. {
  732. if (!string.IsNullOrEmpty(album.AlbumArtist))
  733. {
  734. AddValue(element, "upnp", "artist", album.AlbumArtist, NS_UPNP);
  735. AddValue(element, "upnp", "albumArtist", album.AlbumArtist, NS_UPNP);
  736. }
  737. }
  738. var musicVideo = item as MusicVideo;
  739. if (musicVideo != null)
  740. {
  741. if (!string.IsNullOrEmpty(musicVideo.Artist))
  742. {
  743. AddValue(element, "upnp", "artist", musicVideo.Artist, NS_UPNP);
  744. }
  745. if (!string.IsNullOrEmpty(musicVideo.Album))
  746. {
  747. AddValue(element, "upnp", "album", musicVideo.Album, NS_UPNP);
  748. }
  749. }
  750. if (item.IndexNumber.HasValue)
  751. {
  752. AddValue(element, "upnp", "originalTrackNumber", item.IndexNumber.Value.ToString(_usCulture), NS_UPNP);
  753. }
  754. }
  755. private void AddCover(BaseItem item, XmlElement element)
  756. {
  757. var imageInfo = GetImageInfo(item);
  758. if (imageInfo == null)
  759. {
  760. return;
  761. }
  762. var result = element.OwnerDocument;
  763. var albumartUrlInfo = GetImageUrl(imageInfo, _profile.MaxAlbumArtWidth, _profile.MaxAlbumArtHeight);
  764. var icon = result.CreateElement("upnp", "albumArtURI", NS_UPNP);
  765. var profile = result.CreateAttribute("dlna", "profileID", NS_DLNA);
  766. profile.InnerText = _profile.AlbumArtPn;
  767. icon.SetAttributeNode(profile);
  768. icon.InnerText = albumartUrlInfo.Url;
  769. element.AppendChild(icon);
  770. var iconUrlInfo = GetImageUrl(imageInfo, _profile.MaxIconWidth, _profile.MaxIconHeight);
  771. icon = result.CreateElement("upnp", "icon", NS_UPNP);
  772. profile = result.CreateAttribute("dlna", "profileID", NS_DLNA);
  773. profile.InnerText = _profile.AlbumArtPn;
  774. icon.SetAttributeNode(profile);
  775. icon.InnerText = iconUrlInfo.Url;
  776. element.AppendChild(icon);
  777. if (!_profile.EnableAlbumArtInDidl)
  778. {
  779. return;
  780. }
  781. var res = result.CreateElement(string.Empty, "res", NS_DIDL);
  782. res.InnerText = albumartUrlInfo.Url;
  783. var width = albumartUrlInfo.Width;
  784. var height = albumartUrlInfo.Height;
  785. var mediaProfile = new MediaFormatProfileResolver().ResolveImageFormat("jpg", width, height);
  786. var orgPn = mediaProfile.HasValue ? "DLNA.ORG_PN=:" + mediaProfile.Value + ";" : string.Empty;
  787. res.SetAttribute("protocolInfo", string.Format(
  788. "http-get:*:{1}:{0}DLNA.ORG_OP=01;DLNA.ORG_CI=0;DLNA.ORG_FLAGS={2}",
  789. orgPn,
  790. "image/jpeg",
  791. DlnaMaps.DefaultStreaming
  792. ));
  793. if (width.HasValue && height.HasValue)
  794. {
  795. res.SetAttribute("resolution", string.Format("{0}x{1}", width.Value, height.Value));
  796. }
  797. element.AppendChild(res);
  798. }
  799. private ImageDownloadInfo GetImageInfo(BaseItem item)
  800. {
  801. if (item.HasImage(ImageType.Primary))
  802. {
  803. return GetImageInfo(item, ImageType.Primary);
  804. }
  805. if (item.HasImage(ImageType.Thumb))
  806. {
  807. return GetImageInfo(item, ImageType.Thumb);
  808. }
  809. if (item is Audio || item is Episode)
  810. {
  811. item = item.Parents.FirstOrDefault(i => i.HasImage(ImageType.Primary));
  812. if (item != null)
  813. {
  814. return GetImageInfo(item, ImageType.Primary);
  815. }
  816. }
  817. return null;
  818. }
  819. private ImageDownloadInfo GetImageInfo(BaseItem item, ImageType type)
  820. {
  821. var imageInfo = item.GetImageInfo(type, 0);
  822. string tag = null;
  823. try
  824. {
  825. var guid = _imageProcessor.GetImageCacheTag(item, ImageType.Primary);
  826. tag = guid.HasValue ? guid.Value.ToString("N") : null;
  827. }
  828. catch
  829. {
  830. }
  831. int? width = null;
  832. int? height = null;
  833. try
  834. {
  835. var size = _imageProcessor.GetImageSize(imageInfo.Path, imageInfo.DateModified);
  836. width = Convert.ToInt32(size.Width);
  837. height = Convert.ToInt32(size.Height);
  838. }
  839. catch
  840. {
  841. }
  842. return new ImageDownloadInfo
  843. {
  844. ItemId = item.Id.ToString("N"),
  845. Type = ImageType.Primary,
  846. ImageTag = tag,
  847. Width = width,
  848. Height = height
  849. };
  850. }
  851. class ImageDownloadInfo
  852. {
  853. internal string ItemId;
  854. internal string ImageTag;
  855. internal ImageType Type;
  856. internal int? Width;
  857. internal int? Height;
  858. }
  859. class ImageUrlInfo
  860. {
  861. internal string Url;
  862. internal int? Width;
  863. internal int? Height;
  864. }
  865. private ImageUrlInfo GetImageUrl(ImageDownloadInfo info, int? maxWidth, int? maxHeight)
  866. {
  867. var url = string.Format("{0}/Items/{1}/Images/{2}?tag={3}&format=jpg",
  868. _serverAddress,
  869. info.ItemId,
  870. info.Type,
  871. info.ImageTag);
  872. if (maxWidth.HasValue)
  873. {
  874. url += "&maxWidth=" + maxWidth.Value.ToString(_usCulture);
  875. }
  876. if (maxHeight.HasValue)
  877. {
  878. url += "&maxHeight=" + maxHeight.Value.ToString(_usCulture);
  879. }
  880. var width = info.Width;
  881. var height = info.Height;
  882. if (width.HasValue && height.HasValue)
  883. {
  884. if (maxWidth.HasValue || maxHeight.HasValue)
  885. {
  886. var newSize = DrawingUtils.Resize(new ImageSize
  887. {
  888. Height = height.Value,
  889. Width = width.Value
  890. }, maxWidth: maxWidth, maxHeight: maxHeight);
  891. width = Convert.ToInt32(newSize.Width);
  892. height = Convert.ToInt32(newSize.Height);
  893. }
  894. }
  895. return new ImageUrlInfo
  896. {
  897. Url = url,
  898. Width = width,
  899. Height = height
  900. };
  901. }
  902. }
  903. }