BaseApiService.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338
  1. using MediaBrowser.Controller.Entities;
  2. using MediaBrowser.Controller.Entities.Audio;
  3. using MediaBrowser.Controller.Library;
  4. using MediaBrowser.Controller.Net;
  5. using MediaBrowser.Controller.Session;
  6. using MediaBrowser.Model.Logging;
  7. using ServiceStack.Web;
  8. using System;
  9. using System.Collections.Generic;
  10. using System.Linq;
  11. namespace MediaBrowser.Api
  12. {
  13. /// <summary>
  14. /// Class BaseApiService
  15. /// </summary>
  16. public class BaseApiService : IHasResultFactory, IRestfulService, IHasSession
  17. {
  18. /// <summary>
  19. /// Gets or sets the logger.
  20. /// </summary>
  21. /// <value>The logger.</value>
  22. public ILogger Logger { get; set; }
  23. /// <summary>
  24. /// Gets or sets the HTTP result factory.
  25. /// </summary>
  26. /// <value>The HTTP result factory.</value>
  27. public IHttpResultFactory ResultFactory { get; set; }
  28. /// <summary>
  29. /// Gets or sets the request context.
  30. /// </summary>
  31. /// <value>The request context.</value>
  32. public IRequest Request { get; set; }
  33. public ISessionContext SessionContext { get; set; }
  34. public string GetHeader(string name)
  35. {
  36. return Request.Headers[name];
  37. }
  38. /// <summary>
  39. /// To the optimized result.
  40. /// </summary>
  41. /// <typeparam name="T"></typeparam>
  42. /// <param name="result">The result.</param>
  43. /// <returns>System.Object.</returns>
  44. protected object ToOptimizedResult<T>(T result)
  45. where T : class
  46. {
  47. return ResultFactory.GetOptimizedResult(Request, result);
  48. }
  49. /// <summary>
  50. /// To the optimized result using cache.
  51. /// </summary>
  52. /// <typeparam name="T"></typeparam>
  53. /// <param name="cacheKey">The cache key.</param>
  54. /// <param name="lastDateModified">The last date modified.</param>
  55. /// <param name="cacheDuration">Duration of the cache.</param>
  56. /// <param name="factoryFn">The factory function.</param>
  57. /// <returns>System.Object.</returns>
  58. protected object ToOptimizedResultUsingCache<T>(Guid cacheKey, DateTime? lastDateModified, TimeSpan? cacheDuration, Func<T> factoryFn)
  59. where T : class
  60. {
  61. return ResultFactory.GetOptimizedResultUsingCache(Request, cacheKey, lastDateModified, cacheDuration, factoryFn);
  62. }
  63. /// <summary>
  64. /// To the optimized serialized result using cache.
  65. /// </summary>
  66. /// <typeparam name="T"></typeparam>
  67. /// <param name="result">The result.</param>
  68. /// <returns>System.Object.</returns>
  69. protected object ToOptimizedSerializedResultUsingCache<T>(T result)
  70. where T : class
  71. {
  72. return ToOptimizedResult(result);
  73. }
  74. /// <summary>
  75. /// Gets the session.
  76. /// </summary>
  77. /// <returns>SessionInfo.</returns>
  78. protected SessionInfo GetSession()
  79. {
  80. var session = SessionContext.GetSession(Request);
  81. if (session == null)
  82. {
  83. throw new ArgumentException("Session not found.");
  84. }
  85. return session;
  86. }
  87. /// <summary>
  88. /// To the static file result.
  89. /// </summary>
  90. /// <param name="path">The path.</param>
  91. /// <returns>System.Object.</returns>
  92. protected object ToStaticFileResult(string path)
  93. {
  94. return ResultFactory.GetStaticFileResult(Request, path);
  95. }
  96. private readonly char[] _dashReplaceChars = { '?', '/', '&' };
  97. private const char SlugChar = '-';
  98. protected MusicArtist GetArtist(string name, ILibraryManager libraryManager)
  99. {
  100. return libraryManager.GetArtist(DeSlugArtistName(name, libraryManager));
  101. }
  102. protected Studio GetStudio(string name, ILibraryManager libraryManager)
  103. {
  104. return libraryManager.GetStudio(DeSlugStudioName(name, libraryManager));
  105. }
  106. protected Genre GetGenre(string name, ILibraryManager libraryManager)
  107. {
  108. return libraryManager.GetGenre(DeSlugGenreName(name, libraryManager));
  109. }
  110. protected MusicGenre GetMusicGenre(string name, ILibraryManager libraryManager)
  111. {
  112. return libraryManager.GetMusicGenre(DeSlugGenreName(name, libraryManager));
  113. }
  114. protected GameGenre GetGameGenre(string name, ILibraryManager libraryManager)
  115. {
  116. return libraryManager.GetGameGenre(DeSlugGameGenreName(name, libraryManager));
  117. }
  118. protected Person GetPerson(string name, ILibraryManager libraryManager)
  119. {
  120. return libraryManager.GetPerson(DeSlugPersonName(name, libraryManager));
  121. }
  122. protected IEnumerable<BaseItem> GetAllLibraryItems(Guid? userId, IUserManager userManager, ILibraryManager libraryManager, string parentId = null)
  123. {
  124. if (!string.IsNullOrEmpty(parentId))
  125. {
  126. var folder = (Folder) libraryManager.GetItemById(new Guid(parentId));
  127. if (userId.HasValue)
  128. {
  129. var user = userManager.GetUserById(userId.Value);
  130. if (user == null)
  131. {
  132. throw new ArgumentException("User not found");
  133. }
  134. return folder.GetRecursiveChildren(user);
  135. }
  136. return folder.GetRecursiveChildren();
  137. }
  138. if (userId.HasValue)
  139. {
  140. var user = userManager.GetUserById(userId.Value);
  141. if (user == null)
  142. {
  143. throw new ArgumentException("User not found");
  144. }
  145. return userManager.GetUserById(userId.Value).RootFolder.GetRecursiveChildren(user);
  146. }
  147. return libraryManager.RootFolder.GetRecursiveChildren();
  148. }
  149. /// <summary>
  150. /// Deslugs an artist name by finding the correct entry in the library
  151. /// </summary>
  152. /// <param name="name"></param>
  153. /// <param name="libraryManager"></param>
  154. /// <returns></returns>
  155. protected string DeSlugArtistName(string name, ILibraryManager libraryManager)
  156. {
  157. if (name.IndexOf(SlugChar) == -1)
  158. {
  159. return name;
  160. }
  161. return libraryManager.RootFolder.RecursiveChildren
  162. .OfType<Audio>()
  163. .SelectMany(i => i.AllArtists)
  164. .Distinct(StringComparer.OrdinalIgnoreCase)
  165. .FirstOrDefault(i =>
  166. {
  167. i = _dashReplaceChars.Aggregate(i, (current, c) => current.Replace(c, SlugChar));
  168. return string.Equals(i, name, StringComparison.OrdinalIgnoreCase);
  169. }) ?? name;
  170. }
  171. /// <summary>
  172. /// Deslugs a genre name by finding the correct entry in the library
  173. /// </summary>
  174. protected string DeSlugGenreName(string name, ILibraryManager libraryManager)
  175. {
  176. if (name.IndexOf(SlugChar) == -1)
  177. {
  178. return name;
  179. }
  180. return libraryManager.RootFolder.GetRecursiveChildren()
  181. .SelectMany(i => i.Genres)
  182. .Distinct(StringComparer.OrdinalIgnoreCase)
  183. .FirstOrDefault(i =>
  184. {
  185. i = _dashReplaceChars.Aggregate(i, (current, c) => current.Replace(c, SlugChar));
  186. return string.Equals(i, name, StringComparison.OrdinalIgnoreCase);
  187. }) ?? name;
  188. }
  189. protected string DeSlugGameGenreName(string name, ILibraryManager libraryManager)
  190. {
  191. if (name.IndexOf(SlugChar) == -1)
  192. {
  193. return name;
  194. }
  195. return libraryManager.RootFolder.GetRecursiveChildren()
  196. .OfType<Game>()
  197. .SelectMany(i => i.Genres)
  198. .Distinct(StringComparer.OrdinalIgnoreCase)
  199. .FirstOrDefault(i =>
  200. {
  201. i = _dashReplaceChars.Aggregate(i, (current, c) => current.Replace(c, SlugChar));
  202. return string.Equals(i, name, StringComparison.OrdinalIgnoreCase);
  203. }) ?? name;
  204. }
  205. /// <summary>
  206. /// Deslugs a studio name by finding the correct entry in the library
  207. /// </summary>
  208. protected string DeSlugStudioName(string name, ILibraryManager libraryManager)
  209. {
  210. if (name.IndexOf(SlugChar) == -1)
  211. {
  212. return name;
  213. }
  214. return libraryManager.RootFolder.GetRecursiveChildren()
  215. .SelectMany(i => i.Studios)
  216. .Distinct(StringComparer.OrdinalIgnoreCase)
  217. .FirstOrDefault(i =>
  218. {
  219. i = _dashReplaceChars.Aggregate(i, (current, c) => current.Replace(c, SlugChar));
  220. return string.Equals(i, name, StringComparison.OrdinalIgnoreCase);
  221. }) ?? name;
  222. }
  223. /// <summary>
  224. /// Deslugs a person name by finding the correct entry in the library
  225. /// </summary>
  226. protected string DeSlugPersonName(string name, ILibraryManager libraryManager)
  227. {
  228. if (name.IndexOf(SlugChar) == -1)
  229. {
  230. return name;
  231. }
  232. return libraryManager.RootFolder.GetRecursiveChildren()
  233. .SelectMany(i => i.People)
  234. .Select(i => i.Name)
  235. .Distinct(StringComparer.OrdinalIgnoreCase)
  236. .FirstOrDefault(i =>
  237. {
  238. i = _dashReplaceChars.Aggregate(i, (current, c) => current.Replace(c, SlugChar));
  239. return string.Equals(i, name, StringComparison.OrdinalIgnoreCase);
  240. }) ?? name;
  241. }
  242. /// <summary>
  243. /// Gets the name of the item by.
  244. /// </summary>
  245. /// <param name="name">The name.</param>
  246. /// <param name="type">The type.</param>
  247. /// <param name="libraryManager">The library manager.</param>
  248. /// <returns>Task{BaseItem}.</returns>
  249. /// <exception cref="System.ArgumentException"></exception>
  250. protected BaseItem GetItemByName(string name, string type, ILibraryManager libraryManager)
  251. {
  252. BaseItem item;
  253. if (type.IndexOf("Person", StringComparison.OrdinalIgnoreCase) == 0)
  254. {
  255. item = GetPerson(name, libraryManager);
  256. }
  257. else if (type.IndexOf("Artist", StringComparison.OrdinalIgnoreCase) == 0)
  258. {
  259. item = GetArtist(name, libraryManager);
  260. }
  261. else if (type.IndexOf("Genre", StringComparison.OrdinalIgnoreCase) == 0)
  262. {
  263. item = GetGenre(name, libraryManager);
  264. }
  265. else if (type.IndexOf("MusicGenre", StringComparison.OrdinalIgnoreCase) == 0)
  266. {
  267. item = GetMusicGenre(name, libraryManager);
  268. }
  269. else if (type.IndexOf("GameGenre", StringComparison.OrdinalIgnoreCase) == 0)
  270. {
  271. item = GetGameGenre(name, libraryManager);
  272. }
  273. else if (type.IndexOf("Studio", StringComparison.OrdinalIgnoreCase) == 0)
  274. {
  275. item = GetStudio(name, libraryManager);
  276. }
  277. else if (type.IndexOf("Year", StringComparison.OrdinalIgnoreCase) == 0)
  278. {
  279. item = libraryManager.GetYear(int.Parse(name));
  280. }
  281. else
  282. {
  283. throw new ArgumentException();
  284. }
  285. return item;
  286. }
  287. }
  288. }