using System; using System.Linq; using MediaBrowser.Controller.Dto; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Entities.Audio; using MediaBrowser.Controller.Library; using MediaBrowser.Controller.Net; using MediaBrowser.Controller.Session; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Services; using MediaBrowser.Model.Querying; using Microsoft.Extensions.Logging; namespace MediaBrowser.Api { /// /// Class BaseApiService /// public class BaseApiService : IService, IRequiresRequest { /// /// Gets or sets the logger. /// /// The logger. public ILogger Logger => ApiEntryPoint.Instance.Logger; /// /// Gets or sets the HTTP result factory. /// /// The HTTP result factory. public IHttpResultFactory ResultFactory => ApiEntryPoint.Instance.ResultFactory; /// /// Gets or sets the request context. /// /// The request context. public IRequest Request { get; set; } public string GetHeader(string name) { return Request.Headers[name]; } public static string[] SplitValue(string value, char delim) { if (value == null) { return Array.Empty(); } return value.Split(new[] { delim }, StringSplitOptions.RemoveEmptyEntries); } public static Guid[] GetGuids(string value) { if (value == null) { return Array.Empty(); } return value.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries) .Select(i => new Guid(i)) .ToArray(); } /// /// To the optimized result. /// /// /// The result. /// System.Object. protected object ToOptimizedResult(T result) where T : class { return ResultFactory.GetResult(Request, result); } protected void AssertCanUpdateUser(IAuthorizationContext authContext, IUserManager userManager, Guid userId, bool restrictUserPreferences) { var auth = authContext.GetAuthorizationInfo(Request); var authenticatedUser = auth.User; // If they're going to update the record of another user, they must be an administrator if (!userId.Equals(auth.UserId)) { if (!authenticatedUser.Policy.IsAdministrator) { throw new SecurityException("Unauthorized access."); } } else if (restrictUserPreferences) { if (!authenticatedUser.Policy.EnableUserPreferenceAccess) { throw new SecurityException("Unauthorized access."); } } } /// /// Gets the session. /// /// SessionInfo. protected SessionInfo GetSession(ISessionContext sessionContext) { var session = sessionContext.GetSession(Request); if (session == null) { throw new ArgumentException("Session not found."); } return session; } protected DtoOptions GetDtoOptions(IAuthorizationContext authContext, object request) { var options = new DtoOptions(); if (request is IHasItemFields hasFields) { options.Fields = hasFields.GetItemFields(); } if (!options.ContainsField(Model.Querying.ItemFields.RecursiveItemCount) || !options.ContainsField(Model.Querying.ItemFields.ChildCount)) { var client = authContext.GetAuthorizationInfo(Request).Client ?? string.Empty; if (client.IndexOf("kodi", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("wmc", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("media center", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("classic", StringComparison.OrdinalIgnoreCase) != -1) { int oldLen = options.Fields.Length; var arr = new ItemFields[oldLen + 1]; options.Fields.CopyTo(arr, 0); arr[oldLen] = Model.Querying.ItemFields.RecursiveItemCount; options.Fields = arr; } if (client.IndexOf("kodi", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("wmc", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("media center", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("classic", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("roku", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("samsung", StringComparison.OrdinalIgnoreCase) != -1 || client.IndexOf("androidtv", StringComparison.OrdinalIgnoreCase) != -1) { int oldLen = options.Fields.Length; var arr = new ItemFields[oldLen + 1]; options.Fields.CopyTo(arr, 0); arr[oldLen] = Model.Querying.ItemFields.ChildCount; options.Fields = arr; } } if (request is IHasDtoOptions hasDtoOptions) { options.EnableImages = hasDtoOptions.EnableImages ?? true; if (hasDtoOptions.ImageTypeLimit.HasValue) { options.ImageTypeLimit = hasDtoOptions.ImageTypeLimit.Value; } if (hasDtoOptions.EnableUserData.HasValue) { options.EnableUserData = hasDtoOptions.EnableUserData.Value; } if (!string.IsNullOrWhiteSpace(hasDtoOptions.EnableImageTypes)) { options.ImageTypes = hasDtoOptions.EnableImageTypes.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries) .Select(v => (ImageType)Enum.Parse(typeof(ImageType), v, true)) .ToArray(); } } return options; } protected MusicArtist GetArtist(string name, ILibraryManager libraryManager, DtoOptions dtoOptions) { if (name.IndexOf(BaseItem.SlugChar) != -1) { var result = GetItemFromSlugName(libraryManager, name, dtoOptions); if (result != null) { return result; } } return libraryManager.GetArtist(name, dtoOptions); } protected Studio GetStudio(string name, ILibraryManager libraryManager, DtoOptions dtoOptions) { if (name.IndexOf(BaseItem.SlugChar) != -1) { var result = GetItemFromSlugName(libraryManager, name, dtoOptions); if (result != null) { return result; } } return libraryManager.GetStudio(name); } protected Genre GetGenre(string name, ILibraryManager libraryManager, DtoOptions dtoOptions) { if (name.IndexOf(BaseItem.SlugChar) != -1) { var result = GetItemFromSlugName(libraryManager, name, dtoOptions); if (result != null) { return result; } } return libraryManager.GetGenre(name); } protected MusicGenre GetMusicGenre(string name, ILibraryManager libraryManager, DtoOptions dtoOptions) { if (name.IndexOf(BaseItem.SlugChar) != -1) { var result = GetItemFromSlugName(libraryManager, name, dtoOptions); if (result != null) { return result; } } return libraryManager.GetMusicGenre(name); } protected Person GetPerson(string name, ILibraryManager libraryManager, DtoOptions dtoOptions) { if (name.IndexOf(BaseItem.SlugChar) != -1) { var result = GetItemFromSlugName(libraryManager, name, dtoOptions); if (result != null) { return result; } } return libraryManager.GetPerson(name); } private T GetItemFromSlugName(ILibraryManager libraryManager, string name, DtoOptions dtoOptions) where T : BaseItem, new() { var result = libraryManager.GetItemList(new InternalItemsQuery { Name = name.Replace(BaseItem.SlugChar, '&'), IncludeItemTypes = new[] { typeof(T).Name }, DtoOptions = dtoOptions }).OfType().FirstOrDefault(); if (result == null) { result = libraryManager.GetItemList(new InternalItemsQuery { Name = name.Replace(BaseItem.SlugChar, '/'), IncludeItemTypes = new[] { typeof(T).Name }, DtoOptions = dtoOptions }).OfType().FirstOrDefault(); } if (result == null) { result = libraryManager.GetItemList(new InternalItemsQuery { Name = name.Replace(BaseItem.SlugChar, '?'), IncludeItemTypes = new[] { typeof(T).Name }, DtoOptions = dtoOptions }).OfType().FirstOrDefault(); } return result; } protected string GetPathValue(int index) { var pathInfo = Parse(Request.PathInfo); var first = pathInfo[0]; string baseUrl = ApiEntryPoint.Instance.ConfigurationManager.Configuration.BaseUrl; // backwards compatibility if (baseUrl.Length == 0 && (string.Equals(first, "mediabrowser", StringComparison.OrdinalIgnoreCase) || string.Equals(first, "emby", StringComparison.OrdinalIgnoreCase))) { index++; } else if (string.Equals(first, baseUrl)) { index++; var second = pathInfo[1]; if (string.Equals(second, "mediabrowser", StringComparison.OrdinalIgnoreCase) || string.Equals(second, "emby", StringComparison.OrdinalIgnoreCase)) { index++; } } return pathInfo[index]; } private static string[] Parse(string pathUri) { var actionParts = pathUri.Split(new[] { "://" }, StringSplitOptions.None); var pathInfo = actionParts[actionParts.Length - 1]; var optionsPos = pathInfo.LastIndexOf('?'); if (optionsPos != -1) { pathInfo = pathInfo.Substring(0, optionsPos); } var args = pathInfo.Split('/'); return args.Skip(1).ToArray(); } /// /// Gets the name of the item by. /// protected BaseItem GetItemByName(string name, string type, ILibraryManager libraryManager, DtoOptions dtoOptions) { if (type.Equals("Person", StringComparison.OrdinalIgnoreCase)) { return GetPerson(name, libraryManager, dtoOptions); } else if (type.Equals("Artist", StringComparison.OrdinalIgnoreCase)) { return GetArtist(name, libraryManager, dtoOptions); } else if (type.Equals("Genre", StringComparison.OrdinalIgnoreCase)) { return GetGenre(name, libraryManager, dtoOptions); } else if (type.Equals("MusicGenre", StringComparison.OrdinalIgnoreCase)) { return GetMusicGenre(name, libraryManager, dtoOptions); } else if (type.Equals("Studio", StringComparison.OrdinalIgnoreCase)) { return GetStudio(name, libraryManager, dtoOptions); } else if (type.Equals("Year", StringComparison.OrdinalIgnoreCase)) { return libraryManager.GetYear(int.Parse(name)); } throw new ArgumentException("Invalid type", nameof(type)); } } }