BaseApiService.cs 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using MediaBrowser.Controller.Dto;
  5. using MediaBrowser.Controller.Entities;
  6. using MediaBrowser.Controller.Entities.Audio;
  7. using MediaBrowser.Controller.Library;
  8. using MediaBrowser.Controller.Net;
  9. using MediaBrowser.Controller.Session;
  10. using MediaBrowser.Model.Entities;
  11. using MediaBrowser.Model.Services;
  12. using MediaBrowser.Model.Querying;
  13. using Microsoft.Extensions.Logging;
  14. namespace MediaBrowser.Api
  15. {
  16. /// <summary>
  17. /// Class BaseApiService
  18. /// </summary>
  19. public class BaseApiService : IService, IRequiresRequest
  20. {
  21. /// <summary>
  22. /// Gets or sets the logger.
  23. /// </summary>
  24. /// <value>The logger.</value>
  25. public ILogger Logger => ApiEntryPoint.Instance.Logger;
  26. /// <summary>
  27. /// Gets or sets the HTTP result factory.
  28. /// </summary>
  29. /// <value>The HTTP result factory.</value>
  30. public IHttpResultFactory ResultFactory => ApiEntryPoint.Instance.ResultFactory;
  31. /// <summary>
  32. /// Gets or sets the request context.
  33. /// </summary>
  34. /// <value>The request context.</value>
  35. public IRequest Request { get; set; }
  36. public string GetHeader(string name)
  37. {
  38. return Request.Headers[name];
  39. }
  40. public static string[] SplitValue(string value, char delim)
  41. {
  42. if (value == null)
  43. {
  44. return Array.Empty<string>();
  45. }
  46. return value.Split(new[] { delim }, StringSplitOptions.RemoveEmptyEntries);
  47. }
  48. public static Guid[] GetGuids(string value)
  49. {
  50. if (value == null)
  51. {
  52. return Array.Empty<Guid>();
  53. }
  54. return value.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries)
  55. .Select(i => new Guid(i))
  56. .ToArray();
  57. }
  58. /// <summary>
  59. /// To the optimized result.
  60. /// </summary>
  61. /// <typeparam name="T"></typeparam>
  62. /// <param name="result">The result.</param>
  63. /// <returns>System.Object.</returns>
  64. protected object ToOptimizedResult<T>(T result)
  65. where T : class
  66. {
  67. return ResultFactory.GetResult(Request, result);
  68. }
  69. protected void AssertCanUpdateUser(IAuthorizationContext authContext, IUserManager userManager, Guid userId, bool restrictUserPreferences)
  70. {
  71. var auth = authContext.GetAuthorizationInfo(Request);
  72. var authenticatedUser = auth.User;
  73. // If they're going to update the record of another user, they must be an administrator
  74. if (!userId.Equals(auth.UserId))
  75. {
  76. if (!authenticatedUser.Policy.IsAdministrator)
  77. {
  78. throw new SecurityException("Unauthorized access.");
  79. }
  80. }
  81. else if (restrictUserPreferences)
  82. {
  83. if (!authenticatedUser.Policy.EnableUserPreferenceAccess)
  84. {
  85. throw new SecurityException("Unauthorized access.");
  86. }
  87. }
  88. }
  89. /// <summary>
  90. /// Gets the session.
  91. /// </summary>
  92. /// <returns>SessionInfo.</returns>
  93. protected SessionInfo GetSession(ISessionContext sessionContext)
  94. {
  95. var session = sessionContext.GetSession(Request);
  96. if (session == null)
  97. {
  98. throw new ArgumentException("Session not found.");
  99. }
  100. return session;
  101. }
  102. protected DtoOptions GetDtoOptions(IAuthorizationContext authContext, object request)
  103. {
  104. var options = new DtoOptions();
  105. if (request is IHasItemFields hasFields)
  106. {
  107. options.Fields = hasFields.GetItemFields();
  108. }
  109. if (!options.ContainsField(Model.Querying.ItemFields.RecursiveItemCount)
  110. || !options.ContainsField(Model.Querying.ItemFields.ChildCount))
  111. {
  112. var client = authContext.GetAuthorizationInfo(Request).Client ?? string.Empty;
  113. if (client.IndexOf("kodi", StringComparison.OrdinalIgnoreCase) != -1 ||
  114. client.IndexOf("wmc", StringComparison.OrdinalIgnoreCase) != -1 ||
  115. client.IndexOf("media center", StringComparison.OrdinalIgnoreCase) != -1 ||
  116. client.IndexOf("classic", StringComparison.OrdinalIgnoreCase) != -1)
  117. {
  118. int oldLen = options.Fields.Length;
  119. var arr = new ItemFields[oldLen + 1];
  120. options.Fields.CopyTo(arr, 0);
  121. arr[oldLen] = Model.Querying.ItemFields.RecursiveItemCount;
  122. options.Fields = arr;
  123. }
  124. if (client.IndexOf("kodi", StringComparison.OrdinalIgnoreCase) != -1 ||
  125. client.IndexOf("wmc", StringComparison.OrdinalIgnoreCase) != -1 ||
  126. client.IndexOf("media center", StringComparison.OrdinalIgnoreCase) != -1 ||
  127. client.IndexOf("classic", StringComparison.OrdinalIgnoreCase) != -1 ||
  128. client.IndexOf("roku", StringComparison.OrdinalIgnoreCase) != -1 ||
  129. client.IndexOf("samsung", StringComparison.OrdinalIgnoreCase) != -1 ||
  130. client.IndexOf("androidtv", StringComparison.OrdinalIgnoreCase) != -1)
  131. {
  132. int oldLen = options.Fields.Length;
  133. var arr = new ItemFields[oldLen + 1];
  134. options.Fields.CopyTo(arr, 0);
  135. arr[oldLen] = Model.Querying.ItemFields.ChildCount;
  136. options.Fields = arr;
  137. }
  138. }
  139. if (request is IHasDtoOptions hasDtoOptions)
  140. {
  141. options.EnableImages = hasDtoOptions.EnableImages ?? true;
  142. if (hasDtoOptions.ImageTypeLimit.HasValue)
  143. {
  144. options.ImageTypeLimit = hasDtoOptions.ImageTypeLimit.Value;
  145. }
  146. if (hasDtoOptions.EnableUserData.HasValue)
  147. {
  148. options.EnableUserData = hasDtoOptions.EnableUserData.Value;
  149. }
  150. if (!string.IsNullOrWhiteSpace(hasDtoOptions.EnableImageTypes))
  151. {
  152. if (string.IsNullOrEmpty(hasDtoOptions.EnableImageTypes))
  153. {
  154. options.ImageTypes = Array.Empty<ImageType>();
  155. }
  156. else
  157. {
  158. options.ImageTypes = hasDtoOptions.EnableImageTypes.Split(new [] { ',' }, StringSplitOptions.RemoveEmptyEntries)
  159. .Select(v => (ImageType)Enum.Parse(typeof(ImageType), v, true))
  160. .ToArray();
  161. }
  162. }
  163. }
  164. return options;
  165. }
  166. protected MusicArtist GetArtist(string name, ILibraryManager libraryManager, DtoOptions dtoOptions)
  167. {
  168. if (name.IndexOf(BaseItem.SlugChar) != -1)
  169. {
  170. var result = GetItemFromSlugName<MusicArtist>(libraryManager, name, dtoOptions);
  171. if (result != null)
  172. {
  173. return result;
  174. }
  175. }
  176. return libraryManager.GetArtist(name, dtoOptions);
  177. }
  178. protected Studio GetStudio(string name, ILibraryManager libraryManager, DtoOptions dtoOptions)
  179. {
  180. if (name.IndexOf(BaseItem.SlugChar) != -1)
  181. {
  182. var result = GetItemFromSlugName<Studio>(libraryManager, name, dtoOptions);
  183. if (result != null)
  184. {
  185. return result;
  186. }
  187. }
  188. return libraryManager.GetStudio(name);
  189. }
  190. protected Genre GetGenre(string name, ILibraryManager libraryManager, DtoOptions dtoOptions)
  191. {
  192. if (name.IndexOf(BaseItem.SlugChar) != -1)
  193. {
  194. var result = GetItemFromSlugName<Genre>(libraryManager, name, dtoOptions);
  195. if (result != null)
  196. {
  197. return result;
  198. }
  199. }
  200. return libraryManager.GetGenre(name);
  201. }
  202. protected MusicGenre GetMusicGenre(string name, ILibraryManager libraryManager, DtoOptions dtoOptions)
  203. {
  204. if (name.IndexOf(BaseItem.SlugChar) != -1)
  205. {
  206. var result = GetItemFromSlugName<MusicGenre>(libraryManager, name, dtoOptions);
  207. if (result != null)
  208. {
  209. return result;
  210. }
  211. }
  212. return libraryManager.GetMusicGenre(name);
  213. }
  214. protected Person GetPerson(string name, ILibraryManager libraryManager, DtoOptions dtoOptions)
  215. {
  216. if (name.IndexOf(BaseItem.SlugChar) != -1)
  217. {
  218. var result = GetItemFromSlugName<Person>(libraryManager, name, dtoOptions);
  219. if (result != null)
  220. {
  221. return result;
  222. }
  223. }
  224. return libraryManager.GetPerson(name);
  225. }
  226. private T GetItemFromSlugName<T>(ILibraryManager libraryManager, string name, DtoOptions dtoOptions)
  227. where T : BaseItem, new()
  228. {
  229. var result = libraryManager.GetItemList(new InternalItemsQuery
  230. {
  231. Name = name.Replace(BaseItem.SlugChar, '&'),
  232. IncludeItemTypes = new[] { typeof(T).Name },
  233. DtoOptions = dtoOptions
  234. }).OfType<T>().FirstOrDefault();
  235. if (result == null)
  236. {
  237. result = libraryManager.GetItemList(new InternalItemsQuery
  238. {
  239. Name = name.Replace(BaseItem.SlugChar, '/'),
  240. IncludeItemTypes = new[] { typeof(T).Name },
  241. DtoOptions = dtoOptions
  242. }).OfType<T>().FirstOrDefault();
  243. }
  244. if (result == null)
  245. {
  246. result = libraryManager.GetItemList(new InternalItemsQuery
  247. {
  248. Name = name.Replace(BaseItem.SlugChar, '?'),
  249. IncludeItemTypes = new[] { typeof(T).Name },
  250. DtoOptions = dtoOptions
  251. }).OfType<T>().FirstOrDefault();
  252. }
  253. return result;
  254. }
  255. protected string GetPathValue(int index)
  256. {
  257. var pathInfo = Parse(Request.PathInfo);
  258. var first = pathInfo[0];
  259. // backwards compatibility
  260. if (string.Equals(first, "mediabrowser", StringComparison.OrdinalIgnoreCase) ||
  261. string.Equals(first, "emby", StringComparison.OrdinalIgnoreCase))
  262. {
  263. index++;
  264. }
  265. return pathInfo[index];
  266. }
  267. private string[] Parse(string pathUri)
  268. {
  269. var actionParts = pathUri.Split(new[] { "://" }, StringSplitOptions.None);
  270. var pathInfo = actionParts[actionParts.Length - 1];
  271. var optionsPos = pathInfo.LastIndexOf('?');
  272. if (optionsPos != -1)
  273. {
  274. pathInfo = pathInfo.Substring(0, optionsPos);
  275. }
  276. var args = pathInfo.Split('/');
  277. return args.Skip(1).ToArray();
  278. }
  279. /// <summary>
  280. /// Gets the name of the item by.
  281. /// </summary>
  282. protected BaseItem GetItemByName(string name, string type, ILibraryManager libraryManager, DtoOptions dtoOptions)
  283. {
  284. BaseItem item;
  285. if (type.IndexOf("Person", StringComparison.OrdinalIgnoreCase) == 0)
  286. {
  287. item = GetPerson(name, libraryManager, dtoOptions);
  288. }
  289. else if (type.IndexOf("Artist", StringComparison.OrdinalIgnoreCase) == 0)
  290. {
  291. item = GetArtist(name, libraryManager, dtoOptions);
  292. }
  293. else if (type.IndexOf("Genre", StringComparison.OrdinalIgnoreCase) == 0)
  294. {
  295. item = GetGenre(name, libraryManager, dtoOptions);
  296. }
  297. else if (type.IndexOf("MusicGenre", StringComparison.OrdinalIgnoreCase) == 0)
  298. {
  299. item = GetMusicGenre(name, libraryManager, dtoOptions);
  300. }
  301. else if (type.IndexOf("Studio", StringComparison.OrdinalIgnoreCase) == 0)
  302. {
  303. item = GetStudio(name, libraryManager, dtoOptions);
  304. }
  305. else if (type.IndexOf("Year", StringComparison.OrdinalIgnoreCase) == 0)
  306. {
  307. item = libraryManager.GetYear(int.Parse(name));
  308. }
  309. else
  310. {
  311. throw new ArgumentException();
  312. }
  313. return item;
  314. }
  315. }
  316. }