ControlHandler.cs 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107
  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, user, 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, user, 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. container.AppendChild(CreateObjectClass(result, f));
  410. result.DocumentElement.AppendChild(container);
  411. }
  412. private void AddValue(XmlElement elem, string prefix, string name, string value, string namespaceUri)
  413. {
  414. try
  415. {
  416. var date = elem.OwnerDocument.CreateElement(prefix, name, namespaceUri);
  417. date.InnerText = value;
  418. elem.AppendChild(date);
  419. }
  420. catch (XmlException)
  421. {
  422. //_logger.Error("Error adding xml value: " + value);
  423. }
  424. }
  425. private void Browse_AddItem(XmlDocument result, BaseItem item, User user, string deviceId, Filter filter)
  426. {
  427. var element = result.CreateElement(string.Empty, "item", NS_DIDL);
  428. element.SetAttribute("restricted", "1");
  429. element.SetAttribute("id", item.Id.ToString("N"));
  430. if (item.Parent != null)
  431. {
  432. element.SetAttribute("parentID", item.Parent.Id.ToString("N"));
  433. }
  434. element.AppendChild(CreateObjectClass(result, item));
  435. AddBookmarkInfo(item, user, element);
  436. AddGeneralProperties(item, element, filter);
  437. // refID?
  438. // storeAttribute(itemNode, object, ClassProperties.REF_ID, false);
  439. var audio = item as Audio;
  440. if (audio != null)
  441. {
  442. AddAudioResource(element, audio, deviceId, filter);
  443. }
  444. var video = item as Video;
  445. if (video != null)
  446. {
  447. AddVideoResource(element, video, deviceId, filter);
  448. }
  449. AddCover(item, element);
  450. result.DocumentElement.AppendChild(element);
  451. }
  452. private void AddVideoResource(XmlElement container, Video video, string deviceId, Filter filter)
  453. {
  454. var res = container.OwnerDocument.CreateElement(string.Empty, "res", NS_DIDL);
  455. var sources = _dtoService.GetMediaSources(video);
  456. int? maxBitrateSetting = null;
  457. var streamInfo = new StreamBuilder().BuildVideoItem(new VideoOptions
  458. {
  459. ItemId = video.Id.ToString("N"),
  460. MediaSources = sources,
  461. Profile = _profile,
  462. DeviceId = deviceId,
  463. MaxBitrate = maxBitrateSetting
  464. });
  465. var url = streamInfo.ToDlnaUrl(_serverAddress);
  466. res.InnerText = url;
  467. var mediaSource = sources.First(i => string.Equals(i.Id, streamInfo.MediaSourceId));
  468. if (mediaSource.RunTimeTicks.HasValue)
  469. {
  470. res.SetAttribute("duration", TimeSpan.FromTicks(mediaSource.RunTimeTicks.Value).ToString("c", _usCulture));
  471. }
  472. if (filter.Contains("res@size"))
  473. {
  474. if (streamInfo.IsDirectStream || streamInfo.EstimateContentLength)
  475. {
  476. var size = streamInfo.TargetSize;
  477. if (size.HasValue)
  478. {
  479. res.SetAttribute("size", size.Value.ToString(_usCulture));
  480. }
  481. }
  482. }
  483. var videoStream = mediaSource.MediaStreams.FirstOrDefault(i => i.Type == MediaStreamType.Video && !string.Equals(i.Codec, "mjpeg", StringComparison.OrdinalIgnoreCase));
  484. var targetAudioBitrate = streamInfo.TargetAudioBitrate;
  485. var targetSampleRate = streamInfo.TargetAudioSampleRate;
  486. var targetChannels = streamInfo.TargetAudioChannels;
  487. var targetWidth = streamInfo.MaxWidth ?? (videoStream == null ? null : videoStream.Width);
  488. var targetHeight = streamInfo.MaxHeight ?? (videoStream == null ? null : videoStream.Height);
  489. var targetVideoCodec = streamInfo.IsDirectStream
  490. ? (videoStream == null ? null : videoStream.Codec)
  491. : streamInfo.VideoCodec;
  492. var targetAudioCodec = streamInfo.TargetAudioCodec;
  493. var targetBitrate = maxBitrateSetting ?? mediaSource.Bitrate;
  494. if (targetChannels.HasValue)
  495. {
  496. res.SetAttribute("nrAudioChannels", targetChannels.Value.ToString(_usCulture));
  497. }
  498. if (filter.Contains("res@resolution"))
  499. {
  500. if (targetWidth.HasValue && targetHeight.HasValue)
  501. {
  502. res.SetAttribute("resolution", string.Format("{0}x{1}", targetWidth.Value, targetHeight.Value));
  503. }
  504. }
  505. if (targetSampleRate.HasValue)
  506. {
  507. res.SetAttribute("sampleFrequency", targetSampleRate.Value.ToString(_usCulture));
  508. }
  509. if (targetAudioBitrate.HasValue)
  510. {
  511. res.SetAttribute("bitrate", targetAudioBitrate.Value.ToString(_usCulture));
  512. }
  513. var formatProfile = new MediaFormatProfileResolver().ResolveVideoFormat(streamInfo.Container,
  514. targetVideoCodec,
  515. targetAudioCodec,
  516. targetWidth,
  517. targetHeight,
  518. targetBitrate,
  519. TransportStreamTimestamp.NONE);
  520. var filename = url.Substring(0, url.IndexOf('?'));
  521. var orgOpValue = DlnaMaps.GetOrgOpValue(mediaSource.RunTimeTicks.HasValue, streamInfo.IsDirectStream, streamInfo.TranscodeSeekInfo);
  522. var orgCi = streamInfo.IsDirectStream ? ";DLNA.ORG_CI=0" : ";DLNA.ORG_CI=1";
  523. res.SetAttribute("protocolInfo", String.Format(
  524. "http-get:*:{0}:DLNA.ORG_PN={1};DLNA.ORG_OP={2};DLNA.ORG_CI={3};DLNA.ORG_FLAGS={4}",
  525. MimeTypes.GetMimeType(filename),
  526. formatProfile,
  527. orgOpValue,
  528. orgCi,
  529. DlnaMaps.DefaultStreaming
  530. ));
  531. container.AppendChild(res);
  532. }
  533. private void AddAudioResource(XmlElement container, Audio audio, string deviceId, Filter filter)
  534. {
  535. var res = container.OwnerDocument.CreateElement(string.Empty, "res", NS_DIDL);
  536. var sources = _dtoService.GetMediaSources(audio);
  537. var streamInfo = new StreamBuilder().BuildAudioItem(new AudioOptions
  538. {
  539. ItemId = audio.Id.ToString("N"),
  540. MediaSources = sources,
  541. Profile = _profile,
  542. DeviceId = deviceId
  543. });
  544. var url = streamInfo.ToDlnaUrl(_serverAddress);
  545. res.InnerText = url;
  546. var mediaSource = sources.First(i => string.Equals(i.Id, streamInfo.MediaSourceId));
  547. if (mediaSource.RunTimeTicks.HasValue)
  548. {
  549. res.SetAttribute("duration", TimeSpan.FromTicks(mediaSource.RunTimeTicks.Value).ToString("c", _usCulture));
  550. }
  551. if (filter.Contains("res@size"))
  552. {
  553. if (streamInfo.IsDirectStream || streamInfo.EstimateContentLength)
  554. {
  555. var size = streamInfo.TargetSize;
  556. if (size.HasValue)
  557. {
  558. res.SetAttribute("size", size.Value.ToString(_usCulture));
  559. }
  560. }
  561. }
  562. var targetAudioBitrate = streamInfo.TargetAudioBitrate;
  563. var targetSampleRate = streamInfo.TargetAudioSampleRate;
  564. var targetChannels = streamInfo.TargetAudioChannels;
  565. if (targetChannels.HasValue)
  566. {
  567. res.SetAttribute("nrAudioChannels", targetChannels.Value.ToString(_usCulture));
  568. }
  569. if (targetSampleRate.HasValue)
  570. {
  571. res.SetAttribute("sampleFrequency", targetSampleRate.Value.ToString(_usCulture));
  572. }
  573. if (targetAudioBitrate.HasValue)
  574. {
  575. res.SetAttribute("bitrate", targetAudioBitrate.Value.ToString(_usCulture));
  576. }
  577. var formatProfile = new MediaFormatProfileResolver().ResolveAudioFormat(streamInfo.Container, targetAudioBitrate, targetSampleRate, targetChannels);
  578. var filename = url.Substring(0, url.IndexOf('?'));
  579. var orgOpValue = DlnaMaps.GetOrgOpValue(mediaSource.RunTimeTicks.HasValue, streamInfo.IsDirectStream, streamInfo.TranscodeSeekInfo);
  580. var orgCi = streamInfo.IsDirectStream ? ";DLNA.ORG_CI=0" : ";DLNA.ORG_CI=1";
  581. res.SetAttribute("protocolInfo", String.Format(
  582. "http-get:*:{0}:DLNA.ORG_PN={1};DLNA.ORG_OP={2};DLNA.ORG_CI={3};DLNA.ORG_FLAGS={4}",
  583. MimeTypes.GetMimeType(filename),
  584. formatProfile,
  585. orgOpValue,
  586. orgCi,
  587. DlnaMaps.DefaultStreaming
  588. ));
  589. container.AppendChild(res);
  590. }
  591. private XmlElement CreateObjectClass(XmlDocument result, BaseItem item)
  592. {
  593. var objectClass = result.CreateElement("upnp", "class", NS_UPNP);
  594. if (item.IsFolder)
  595. {
  596. string classType = null;
  597. if (!_profile.RequiresPlainFolders)
  598. {
  599. if (item is MusicAlbum)
  600. {
  601. classType = "object.container.musicAlbum";
  602. }
  603. if (item is MusicArtist)
  604. {
  605. classType = "object.container.musicArtist";
  606. }
  607. }
  608. objectClass.InnerText = classType ?? "object.container.storageFolder";
  609. }
  610. else if (string.Equals(item.MediaType, MediaType.Audio, StringComparison.OrdinalIgnoreCase))
  611. {
  612. objectClass.InnerText = "object.item.audioItem.musicTrack";
  613. }
  614. else if (string.Equals(item.MediaType, MediaType.Photo, StringComparison.OrdinalIgnoreCase))
  615. {
  616. objectClass.InnerText = "object.item.imageItem.photo";
  617. }
  618. else if (string.Equals(item.MediaType, MediaType.Video, StringComparison.OrdinalIgnoreCase))
  619. {
  620. if (!_profile.RequiresPlainVideoItems && item is Movie)
  621. {
  622. objectClass.InnerText = "object.item.videoItem.movie";
  623. }
  624. else
  625. {
  626. objectClass.InnerText = "object.item.videoItem";
  627. }
  628. }
  629. else
  630. {
  631. throw new NotSupportedException();
  632. }
  633. return objectClass;
  634. }
  635. private void AddPeople(BaseItem item, XmlElement element)
  636. {
  637. foreach (var actor in item.People)
  638. {
  639. AddValue(element, "upnp", (actor.Type ?? PersonType.Actor).ToLower(), actor.Name, NS_UPNP);
  640. }
  641. }
  642. private void AddBookmarkInfo(BaseItem item, User user, XmlElement element)
  643. {
  644. var userdata = _userDataManager.GetUserData(user.Id, item.GetUserDataKey());
  645. if (userdata.PlaybackPositionTicks > 0)
  646. {
  647. var dcmInfo = element.OwnerDocument.CreateElement("sec", "dcmInfo", NS_SEC);
  648. dcmInfo.InnerText = string.Format("BM={0}", Convert.ToInt32(TimeSpan.FromTicks(userdata.PlaybackPositionTicks).TotalSeconds).ToString(_usCulture));
  649. element.AppendChild(dcmInfo);
  650. }
  651. }
  652. /// <summary>
  653. /// Adds fields used by both items and folders
  654. /// </summary>
  655. /// <param name="item">The item.</param>
  656. /// <param name="element">The element.</param>
  657. /// <param name="filter">The filter.</param>
  658. private void AddCommonFields(BaseItem item, XmlElement element, Filter filter)
  659. {
  660. if (filter.Contains("dc:date"))
  661. {
  662. if (item.PremiereDate.HasValue)
  663. {
  664. AddValue(element, "dc", "date", item.PremiereDate.Value.ToString("o"), NS_DC);
  665. }
  666. }
  667. foreach (var genre in item.Genres)
  668. {
  669. AddValue(element, "upnp", "genre", genre, NS_UPNP);
  670. }
  671. foreach (var studio in item.Studios)
  672. {
  673. AddValue(element, "upnp", "publisher", studio, NS_UPNP);
  674. }
  675. if (filter.Contains("dc:title"))
  676. {
  677. AddValue(element, "dc", "title", item.Name, NS_DC);
  678. }
  679. if (filter.Contains("dc:description"))
  680. {
  681. if (!string.IsNullOrWhiteSpace(item.Overview))
  682. {
  683. AddValue(element, "dc", "description", item.Overview, NS_DC);
  684. }
  685. }
  686. if (filter.Contains("upnp:longDescription"))
  687. {
  688. if (!string.IsNullOrWhiteSpace(item.Overview))
  689. {
  690. AddValue(element, "upnp", "longDescription", item.Overview, NS_UPNP);
  691. }
  692. }
  693. if (!string.IsNullOrEmpty(item.OfficialRating))
  694. {
  695. if (filter.Contains("dc:rating"))
  696. {
  697. AddValue(element, "dc", "rating", item.OfficialRating, NS_DC);
  698. }
  699. if (filter.Contains("upnp:rating"))
  700. {
  701. AddValue(element, "upnp", "rating", item.OfficialRating, NS_UPNP);
  702. }
  703. }
  704. AddPeople(item, element);
  705. }
  706. private void AddGeneralProperties(BaseItem item, XmlElement element, Filter filter)
  707. {
  708. AddCommonFields(item, element, filter);
  709. var audio = item as Audio;
  710. if (audio != null)
  711. {
  712. foreach (var artist in audio.Artists)
  713. {
  714. AddValue(element, "upnp", "artist", artist, NS_UPNP);
  715. }
  716. if (!string.IsNullOrEmpty(audio.Album))
  717. {
  718. AddValue(element, "upnp", "album", audio.Album, NS_UPNP);
  719. }
  720. if (!string.IsNullOrEmpty(audio.AlbumArtist))
  721. {
  722. AddValue(element, "upnp", "albumArtist", audio.AlbumArtist, NS_UPNP);
  723. }
  724. }
  725. var album = item as MusicAlbum;
  726. if (album != null)
  727. {
  728. if (!string.IsNullOrEmpty(album.AlbumArtist))
  729. {
  730. AddValue(element, "upnp", "artist", album.AlbumArtist, NS_UPNP);
  731. AddValue(element, "upnp", "albumArtist", album.AlbumArtist, NS_UPNP);
  732. }
  733. }
  734. var musicVideo = item as MusicVideo;
  735. if (musicVideo != null)
  736. {
  737. if (!string.IsNullOrEmpty(musicVideo.Artist))
  738. {
  739. AddValue(element, "upnp", "artist", musicVideo.Artist, NS_UPNP);
  740. }
  741. if (!string.IsNullOrEmpty(musicVideo.Album))
  742. {
  743. AddValue(element, "upnp", "album", musicVideo.Album, NS_UPNP);
  744. }
  745. }
  746. if (item.IndexNumber.HasValue)
  747. {
  748. AddValue(element, "upnp", "originalTrackNumber", item.IndexNumber.Value.ToString(_usCulture), NS_UPNP);
  749. }
  750. }
  751. private void AddCover(BaseItem item, XmlElement element)
  752. {
  753. var imageInfo = GetImageInfo(item);
  754. if (imageInfo == null)
  755. {
  756. return;
  757. }
  758. var result = element.OwnerDocument;
  759. var albumartUrlInfo = GetImageUrl(imageInfo, _profile.MaxAlbumArtWidth, _profile.MaxAlbumArtHeight);
  760. var icon = result.CreateElement("upnp", "albumArtURI", NS_UPNP);
  761. var profile = result.CreateAttribute("dlna", "profileID", NS_DLNA);
  762. profile.InnerText = _profile.AlbumArtPn;
  763. icon.SetAttributeNode(profile);
  764. icon.InnerText = albumartUrlInfo.Url;
  765. element.AppendChild(icon);
  766. var iconUrlInfo = GetImageUrl(imageInfo, _profile.MaxIconWidth, _profile.MaxIconHeight);
  767. icon = result.CreateElement("upnp", "icon", NS_UPNP);
  768. profile = result.CreateAttribute("dlna", "profileID", NS_DLNA);
  769. profile.InnerText = _profile.AlbumArtPn;
  770. icon.SetAttributeNode(profile);
  771. icon.InnerText = iconUrlInfo.Url;
  772. element.AppendChild(icon);
  773. if (!_profile.EnableAlbumArtInDidl)
  774. {
  775. return;
  776. }
  777. var res = result.CreateElement(string.Empty, "res", NS_DIDL);
  778. res.InnerText = albumartUrlInfo.Url;
  779. var width = albumartUrlInfo.Width;
  780. var height = albumartUrlInfo.Height;
  781. var mediaProfile = new MediaFormatProfileResolver().ResolveImageFormat("jpg", width, height);
  782. res.SetAttribute("protocolInfo", string.Format(
  783. "http-get:*:{1}DLNA.ORG_PN=:{0};DLNA.ORG_OP=01;DLNA.ORG_CI=0;DLNA.ORG_FLAGS={2}",
  784. mediaProfile, "image/jpeg", DlnaMaps.DefaultStreaming
  785. ));
  786. if (width.HasValue && height.HasValue)
  787. {
  788. res.SetAttribute("resolution", string.Format("{0}x{1}", width.Value, height.Value));
  789. }
  790. element.AppendChild(res);
  791. }
  792. private ImageDownloadInfo GetImageInfo(BaseItem item)
  793. {
  794. if (item.HasImage(ImageType.Primary))
  795. {
  796. return GetImageInfo(item, ImageType.Primary);
  797. }
  798. if (item.HasImage(ImageType.Thumb))
  799. {
  800. return GetImageInfo(item, ImageType.Thumb);
  801. }
  802. if (item is Audio || item is Episode)
  803. {
  804. item = item.Parents.FirstOrDefault(i => i.HasImage(ImageType.Primary));
  805. if (item != null)
  806. {
  807. return GetImageInfo(item, ImageType.Primary);
  808. }
  809. }
  810. return null;
  811. }
  812. private ImageDownloadInfo GetImageInfo(BaseItem item, ImageType type)
  813. {
  814. var imageInfo = item.GetImageInfo(type, 0);
  815. string tag = null;
  816. try
  817. {
  818. var guid = _imageProcessor.GetImageCacheTag(item, ImageType.Primary);
  819. tag = guid.HasValue ? guid.Value.ToString("N") : null;
  820. }
  821. catch
  822. {
  823. }
  824. int? width = null;
  825. int? height = null;
  826. try
  827. {
  828. var size = _imageProcessor.GetImageSize(imageInfo.Path, imageInfo.DateModified);
  829. width = Convert.ToInt32(size.Width);
  830. height = Convert.ToInt32(size.Height);
  831. }
  832. catch
  833. {
  834. }
  835. return new ImageDownloadInfo
  836. {
  837. ItemId = item.Id.ToString("N"),
  838. Type = ImageType.Primary,
  839. ImageTag = tag,
  840. Width = width,
  841. Height = height
  842. };
  843. }
  844. class ImageDownloadInfo
  845. {
  846. internal string ItemId;
  847. internal string ImageTag;
  848. internal ImageType Type;
  849. internal int? Width;
  850. internal int? Height;
  851. }
  852. class ImageUrlInfo
  853. {
  854. internal string Url;
  855. internal int? Width;
  856. internal int? Height;
  857. }
  858. private ImageUrlInfo GetImageUrl(ImageDownloadInfo info, int? maxWidth, int? maxHeight)
  859. {
  860. var url = string.Format("{0}/Items/{1}/Images/{2}?tag={3}&format=jpg",
  861. _serverAddress,
  862. info.ItemId,
  863. info.Type,
  864. info.ImageTag);
  865. if (maxWidth.HasValue)
  866. {
  867. url += "&maxWidth=" + maxWidth.Value.ToString(_usCulture);
  868. }
  869. if (maxHeight.HasValue)
  870. {
  871. url += "&maxHeight=" + maxHeight.Value.ToString(_usCulture);
  872. }
  873. var width = info.Width;
  874. var height = info.Height;
  875. if (width.HasValue && height.HasValue)
  876. {
  877. if (maxWidth.HasValue || maxHeight.HasValue)
  878. {
  879. var newSize = DrawingUtils.Resize(new ImageSize
  880. {
  881. Height = height.Value,
  882. Width = width.Value
  883. }, maxWidth: maxWidth, maxHeight: maxHeight);
  884. width = Convert.ToInt32(newSize.Width);
  885. height = Convert.ToInt32(newSize.Height);
  886. }
  887. }
  888. return new ImageUrlInfo
  889. {
  890. Url = url,
  891. Width = width,
  892. Height = height
  893. };
  894. }
  895. }
  896. }