SearchEngine.cs 7.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212
  1. #pragma warning disable CS1591
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using MediaBrowser.Controller.Dto;
  6. using MediaBrowser.Controller.Entities;
  7. using MediaBrowser.Controller.Entities.Audio;
  8. using MediaBrowser.Controller.Extensions;
  9. using MediaBrowser.Controller.Library;
  10. using MediaBrowser.Model.Entities;
  11. using MediaBrowser.Model.Querying;
  12. using MediaBrowser.Model.Search;
  13. using Microsoft.Extensions.Logging;
  14. namespace Emby.Server.Implementations.Library
  15. {
  16. public class SearchEngine : ISearchEngine
  17. {
  18. private readonly ILibraryManager _libraryManager;
  19. private readonly IUserManager _userManager;
  20. private readonly ILogger _logger;
  21. public SearchEngine(ILoggerFactory loggerFactory, ILibraryManager libraryManager, IUserManager userManager)
  22. {
  23. _libraryManager = libraryManager;
  24. _userManager = userManager;
  25. _logger = loggerFactory.CreateLogger("SearchEngine");
  26. }
  27. public QueryResult<SearchHintInfo> GetSearchHints(SearchQuery query)
  28. {
  29. User user = null;
  30. if (query.UserId.Equals(Guid.Empty))
  31. {
  32. }
  33. else
  34. {
  35. user = _userManager.GetUserById(query.UserId);
  36. }
  37. var results = GetSearchHints(query, user);
  38. var totalRecordCount = results.Count;
  39. if (query.StartIndex.HasValue)
  40. {
  41. results = results.Skip(query.StartIndex.Value).ToList();
  42. }
  43. if (query.Limit.HasValue)
  44. {
  45. results = results.Take(query.Limit.Value).ToList();
  46. }
  47. return new QueryResult<SearchHintInfo>
  48. {
  49. TotalRecordCount = totalRecordCount,
  50. Items = results.ToArray()
  51. };
  52. }
  53. private static void AddIfMissing(List<string> list, string value)
  54. {
  55. if (!list.Contains(value, StringComparer.OrdinalIgnoreCase))
  56. {
  57. list.Add(value);
  58. }
  59. }
  60. /// <summary>
  61. /// Gets the search hints.
  62. /// </summary>
  63. /// <param name="query">The query.</param>
  64. /// <param name="user">The user.</param>
  65. /// <returns>IEnumerable{SearchHintResult}.</returns>
  66. /// <exception cref="ArgumentNullException">searchTerm</exception>
  67. private List<SearchHintInfo> GetSearchHints(SearchQuery query, User user)
  68. {
  69. var searchTerm = query.SearchTerm;
  70. if (string.IsNullOrEmpty(searchTerm))
  71. {
  72. throw new ArgumentNullException("SearchTerm can't be empty.", nameof(searchTerm));
  73. }
  74. searchTerm = searchTerm.Trim().RemoveDiacritics();
  75. var excludeItemTypes = query.ExcludeItemTypes.ToList();
  76. var includeItemTypes = (query.IncludeItemTypes ?? Array.Empty<string>()).ToList();
  77. excludeItemTypes.Add(typeof(Year).Name);
  78. excludeItemTypes.Add(typeof(Folder).Name);
  79. if (query.IncludeGenres && (includeItemTypes.Count == 0 || includeItemTypes.Contains("Genre", StringComparer.OrdinalIgnoreCase)))
  80. {
  81. if (!query.IncludeMedia)
  82. {
  83. AddIfMissing(includeItemTypes, typeof(Genre).Name);
  84. AddIfMissing(includeItemTypes, typeof(MusicGenre).Name);
  85. }
  86. }
  87. else
  88. {
  89. AddIfMissing(excludeItemTypes, typeof(Genre).Name);
  90. AddIfMissing(excludeItemTypes, typeof(MusicGenre).Name);
  91. }
  92. if (query.IncludePeople && (includeItemTypes.Count == 0 || includeItemTypes.Contains("People", StringComparer.OrdinalIgnoreCase) || includeItemTypes.Contains("Person", StringComparer.OrdinalIgnoreCase)))
  93. {
  94. if (!query.IncludeMedia)
  95. {
  96. AddIfMissing(includeItemTypes, typeof(Person).Name);
  97. }
  98. }
  99. else
  100. {
  101. AddIfMissing(excludeItemTypes, typeof(Person).Name);
  102. }
  103. if (query.IncludeStudios && (includeItemTypes.Count == 0 || includeItemTypes.Contains("Studio", StringComparer.OrdinalIgnoreCase)))
  104. {
  105. if (!query.IncludeMedia)
  106. {
  107. AddIfMissing(includeItemTypes, typeof(Studio).Name);
  108. }
  109. }
  110. else
  111. {
  112. AddIfMissing(excludeItemTypes, typeof(Studio).Name);
  113. }
  114. if (query.IncludeArtists && (includeItemTypes.Count == 0 || includeItemTypes.Contains("MusicArtist", StringComparer.OrdinalIgnoreCase)))
  115. {
  116. if (!query.IncludeMedia)
  117. {
  118. AddIfMissing(includeItemTypes, typeof(MusicArtist).Name);
  119. }
  120. }
  121. else
  122. {
  123. AddIfMissing(excludeItemTypes, typeof(MusicArtist).Name);
  124. }
  125. AddIfMissing(excludeItemTypes, typeof(CollectionFolder).Name);
  126. AddIfMissing(excludeItemTypes, typeof(Folder).Name);
  127. var mediaTypes = query.MediaTypes.ToList();
  128. if (includeItemTypes.Count > 0)
  129. {
  130. excludeItemTypes.Clear();
  131. mediaTypes.Clear();
  132. }
  133. var searchQuery = new InternalItemsQuery(user)
  134. {
  135. SearchTerm = searchTerm,
  136. ExcludeItemTypes = excludeItemTypes.ToArray(),
  137. IncludeItemTypes = includeItemTypes.ToArray(),
  138. Limit = query.Limit,
  139. IncludeItemsByName = string.IsNullOrEmpty(query.ParentId),
  140. ParentId = string.IsNullOrEmpty(query.ParentId) ? Guid.Empty : new Guid(query.ParentId),
  141. OrderBy = new[] { (ItemSortBy.SortName, SortOrder.Ascending) },
  142. Recursive = true,
  143. IsKids = query.IsKids,
  144. IsMovie = query.IsMovie,
  145. IsNews = query.IsNews,
  146. IsSeries = query.IsSeries,
  147. IsSports = query.IsSports,
  148. MediaTypes = mediaTypes.ToArray(),
  149. DtoOptions = new DtoOptions
  150. {
  151. Fields = new ItemFields[]
  152. {
  153. ItemFields.AirTime,
  154. ItemFields.DateCreated,
  155. ItemFields.ChannelInfo,
  156. ItemFields.ParentId
  157. }
  158. }
  159. };
  160. List<BaseItem> mediaItems;
  161. if (searchQuery.IncludeItemTypes.Length == 1 && string.Equals(searchQuery.IncludeItemTypes[0], "MusicArtist", StringComparison.OrdinalIgnoreCase))
  162. {
  163. if (!searchQuery.ParentId.Equals(Guid.Empty))
  164. {
  165. searchQuery.AncestorIds = new[] { searchQuery.ParentId };
  166. }
  167. searchQuery.ParentId = Guid.Empty;
  168. searchQuery.IncludeItemsByName = true;
  169. searchQuery.IncludeItemTypes = Array.Empty<string>();
  170. mediaItems = _libraryManager.GetAllArtists(searchQuery).Items.Select(i => i.Item1).ToList();
  171. }
  172. else
  173. {
  174. mediaItems = _libraryManager.GetItemList(searchQuery);
  175. }
  176. return mediaItems.Select(i => new SearchHintInfo
  177. {
  178. Item = i
  179. }).ToList();
  180. }
  181. }
  182. }