2
0

SearchEngine.cs 7.6 KB

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