BaseItemRepository.cs 82 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232
  1. #pragma warning disable RS0030 // Do not use banned APIs
  2. // Do not enforce that because EFCore cannot deal with cultures well.
  3. #pragma warning disable CA1304 // Specify CultureInfo
  4. #pragma warning disable CA1311 // Specify a culture or use an invariant version
  5. #pragma warning disable CA1862 // Use the 'StringComparison' method overloads to perform case-insensitive string comparisons
  6. using System;
  7. using System.Collections.Concurrent;
  8. using System.Collections.Generic;
  9. using System.Globalization;
  10. using System.Linq;
  11. using System.Linq.Expressions;
  12. using System.Reflection;
  13. using System.Text;
  14. using System.Text.Json;
  15. using System.Threading;
  16. using Jellyfin.Data.Enums;
  17. using Jellyfin.Database.Implementations;
  18. using Jellyfin.Database.Implementations.Entities;
  19. using Jellyfin.Database.Implementations.Enums;
  20. using Jellyfin.Extensions;
  21. using Jellyfin.Extensions.Json;
  22. using Jellyfin.Server.Implementations.Extensions;
  23. using MediaBrowser.Common;
  24. using MediaBrowser.Controller;
  25. using MediaBrowser.Controller.Channels;
  26. using MediaBrowser.Controller.Configuration;
  27. using MediaBrowser.Controller.Entities;
  28. using MediaBrowser.Controller.Entities.Audio;
  29. using MediaBrowser.Controller.Entities.TV;
  30. using MediaBrowser.Controller.LiveTv;
  31. using MediaBrowser.Controller.Persistence;
  32. using MediaBrowser.Model.Dto;
  33. using MediaBrowser.Model.Entities;
  34. using MediaBrowser.Model.LiveTv;
  35. using MediaBrowser.Model.Querying;
  36. using Microsoft.EntityFrameworkCore;
  37. using Microsoft.Extensions.Logging;
  38. using BaseItemDto = MediaBrowser.Controller.Entities.BaseItem;
  39. using BaseItemEntity = Jellyfin.Database.Implementations.Entities.BaseItemEntity;
  40. namespace Jellyfin.Server.Implementations.Item;
  41. /*
  42. All queries in this class and all other nullable enabled EFCore repository classes will make liberal use of the null-forgiving operator "!".
  43. This is done as the code isn't actually executed client side, but only the expressions are interpret and the compiler cannot know that.
  44. This is your only warning/message regarding this topic.
  45. */
  46. /// <summary>
  47. /// Handles all storage logic for BaseItems.
  48. /// </summary>
  49. public sealed class BaseItemRepository
  50. : IItemRepository
  51. {
  52. /// <summary>
  53. /// This holds all the types in the running assemblies
  54. /// so that we can de-serialize properly when we don't have strong types.
  55. /// </summary>
  56. private static readonly ConcurrentDictionary<string, Type?> _typeMap = new ConcurrentDictionary<string, Type?>();
  57. private readonly IDbContextFactory<JellyfinDbContext> _dbProvider;
  58. private readonly IServerApplicationHost _appHost;
  59. private readonly IItemTypeLookup _itemTypeLookup;
  60. private readonly IServerConfigurationManager _serverConfigurationManager;
  61. private readonly ILogger<BaseItemRepository> _logger;
  62. private static readonly IReadOnlyList<ItemValueType> _getAllArtistsValueTypes = [ItemValueType.Artist, ItemValueType.AlbumArtist];
  63. private static readonly IReadOnlyList<ItemValueType> _getArtistValueTypes = [ItemValueType.Artist];
  64. private static readonly IReadOnlyList<ItemValueType> _getAlbumArtistValueTypes = [ItemValueType.AlbumArtist];
  65. private static readonly IReadOnlyList<ItemValueType> _getStudiosValueTypes = [ItemValueType.Studios];
  66. private static readonly IReadOnlyList<ItemValueType> _getGenreValueTypes = [ItemValueType.Genre];
  67. /// <summary>
  68. /// Initializes a new instance of the <see cref="BaseItemRepository"/> class.
  69. /// </summary>
  70. /// <param name="dbProvider">The db factory.</param>
  71. /// <param name="appHost">The Application host.</param>
  72. /// <param name="itemTypeLookup">The static type lookup.</param>
  73. /// <param name="serverConfigurationManager">The server Configuration manager.</param>
  74. /// <param name="logger">System logger.</param>
  75. public BaseItemRepository(
  76. IDbContextFactory<JellyfinDbContext> dbProvider,
  77. IServerApplicationHost appHost,
  78. IItemTypeLookup itemTypeLookup,
  79. IServerConfigurationManager serverConfigurationManager,
  80. ILogger<BaseItemRepository> logger)
  81. {
  82. _dbProvider = dbProvider;
  83. _appHost = appHost;
  84. _itemTypeLookup = itemTypeLookup;
  85. _serverConfigurationManager = serverConfigurationManager;
  86. _logger = logger;
  87. }
  88. /// <inheritdoc />
  89. public void DeleteItem(Guid id)
  90. {
  91. if (id.IsEmpty())
  92. {
  93. throw new ArgumentException("Guid can't be empty", nameof(id));
  94. }
  95. using var context = _dbProvider.CreateDbContext();
  96. using var transaction = context.Database.BeginTransaction();
  97. context.AncestorIds.Where(e => e.ItemId == id || e.ParentItemId == id).ExecuteDelete();
  98. context.AttachmentStreamInfos.Where(e => e.ItemId == id).ExecuteDelete();
  99. context.BaseItemImageInfos.Where(e => e.ItemId == id).ExecuteDelete();
  100. context.BaseItemMetadataFields.Where(e => e.ItemId == id).ExecuteDelete();
  101. context.BaseItemProviders.Where(e => e.ItemId == id).ExecuteDelete();
  102. context.BaseItemTrailerTypes.Where(e => e.ItemId == id).ExecuteDelete();
  103. context.BaseItems.Where(e => e.Id == id).ExecuteDelete();
  104. context.Chapters.Where(e => e.ItemId == id).ExecuteDelete();
  105. context.CustomItemDisplayPreferences.Where(e => e.ItemId == id).ExecuteDelete();
  106. context.ItemDisplayPreferences.Where(e => e.ItemId == id).ExecuteDelete();
  107. context.ItemValues.Where(e => e.BaseItemsMap!.Count == 0).ExecuteDelete();
  108. context.ItemValuesMap.Where(e => e.ItemId == id).ExecuteDelete();
  109. context.KeyframeData.Where(e => e.ItemId == id).ExecuteDelete();
  110. context.MediaSegments.Where(e => e.ItemId == id).ExecuteDelete();
  111. context.MediaStreamInfos.Where(e => e.ItemId == id).ExecuteDelete();
  112. context.PeopleBaseItemMap.Where(e => e.ItemId == id).ExecuteDelete();
  113. context.Peoples.Where(e => e.BaseItems!.Count == 0).ExecuteDelete();
  114. context.TrickplayInfos.Where(e => e.ItemId == id).ExecuteDelete();
  115. context.SaveChanges();
  116. transaction.Commit();
  117. }
  118. /// <inheritdoc />
  119. public void UpdateInheritedValues()
  120. {
  121. using var context = _dbProvider.CreateDbContext();
  122. using var transaction = context.Database.BeginTransaction();
  123. context.ItemValuesMap.Where(e => e.ItemValue.Type == ItemValueType.InheritedTags).ExecuteDelete();
  124. // ItemValue Inheritance is now correctly mapped via AncestorId on demand
  125. context.SaveChanges();
  126. transaction.Commit();
  127. }
  128. /// <inheritdoc />
  129. public IReadOnlyList<Guid> GetItemIdsList(InternalItemsQuery filter)
  130. {
  131. ArgumentNullException.ThrowIfNull(filter);
  132. PrepareFilterQuery(filter);
  133. using var context = _dbProvider.CreateDbContext();
  134. return ApplyQueryFilter(context.BaseItems.AsNoTracking(), context, filter).Select(e => e.Id).ToArray();
  135. }
  136. /// <inheritdoc />
  137. public QueryResult<(BaseItemDto Item, ItemCounts ItemCounts)> GetAllArtists(InternalItemsQuery filter)
  138. {
  139. return GetItemValues(filter, _getAllArtistsValueTypes, _itemTypeLookup.BaseItemKindNames[BaseItemKind.MusicArtist]);
  140. }
  141. /// <inheritdoc />
  142. public QueryResult<(BaseItemDto Item, ItemCounts ItemCounts)> GetArtists(InternalItemsQuery filter)
  143. {
  144. return GetItemValues(filter, _getArtistValueTypes, _itemTypeLookup.BaseItemKindNames[BaseItemKind.MusicArtist]);
  145. }
  146. /// <inheritdoc />
  147. public QueryResult<(BaseItemDto Item, ItemCounts ItemCounts)> GetAlbumArtists(InternalItemsQuery filter)
  148. {
  149. return GetItemValues(filter, _getAlbumArtistValueTypes, _itemTypeLookup.BaseItemKindNames[BaseItemKind.MusicArtist]);
  150. }
  151. /// <inheritdoc />
  152. public QueryResult<(BaseItemDto Item, ItemCounts ItemCounts)> GetStudios(InternalItemsQuery filter)
  153. {
  154. return GetItemValues(filter, _getStudiosValueTypes, _itemTypeLookup.BaseItemKindNames[BaseItemKind.Studio]);
  155. }
  156. /// <inheritdoc />
  157. public QueryResult<(BaseItemDto Item, ItemCounts ItemCounts)> GetGenres(InternalItemsQuery filter)
  158. {
  159. return GetItemValues(filter, _getGenreValueTypes, _itemTypeLookup.BaseItemKindNames[BaseItemKind.Genre]);
  160. }
  161. /// <inheritdoc />
  162. public QueryResult<(BaseItemDto Item, ItemCounts ItemCounts)> GetMusicGenres(InternalItemsQuery filter)
  163. {
  164. return GetItemValues(filter, _getGenreValueTypes, _itemTypeLookup.BaseItemKindNames[BaseItemKind.MusicGenre]);
  165. }
  166. /// <inheritdoc />
  167. public IReadOnlyList<string> GetStudioNames()
  168. {
  169. return GetItemValueNames(_getStudiosValueTypes, [], []);
  170. }
  171. /// <inheritdoc />
  172. public IReadOnlyList<string> GetAllArtistNames()
  173. {
  174. return GetItemValueNames(_getAllArtistsValueTypes, [], []);
  175. }
  176. /// <inheritdoc />
  177. public IReadOnlyList<string> GetMusicGenreNames()
  178. {
  179. return GetItemValueNames(
  180. _getGenreValueTypes,
  181. _itemTypeLookup.MusicGenreTypes,
  182. []);
  183. }
  184. /// <inheritdoc />
  185. public IReadOnlyList<string> GetGenreNames()
  186. {
  187. return GetItemValueNames(
  188. _getGenreValueTypes,
  189. [],
  190. _itemTypeLookup.MusicGenreTypes);
  191. }
  192. /// <inheritdoc />
  193. public QueryResult<BaseItemDto> GetItems(InternalItemsQuery filter)
  194. {
  195. ArgumentNullException.ThrowIfNull(filter);
  196. if (!filter.EnableTotalRecordCount || (!filter.Limit.HasValue && (filter.StartIndex ?? 0) == 0))
  197. {
  198. var returnList = GetItemList(filter);
  199. return new QueryResult<BaseItemDto>(
  200. filter.StartIndex,
  201. returnList.Count,
  202. returnList);
  203. }
  204. PrepareFilterQuery(filter);
  205. var result = new QueryResult<BaseItemDto>();
  206. using var context = _dbProvider.CreateDbContext();
  207. IQueryable<BaseItemEntity> dbQuery = PrepareItemQuery(context, filter);
  208. dbQuery = TranslateQuery(dbQuery, context, filter);
  209. if (filter.EnableTotalRecordCount)
  210. {
  211. result.TotalRecordCount = dbQuery.Count();
  212. }
  213. dbQuery = ApplyGroupingFilter(dbQuery, filter);
  214. dbQuery = ApplyQueryPaging(dbQuery, filter);
  215. result.Items = dbQuery.AsEnumerable().Where(e => e is not null).Select(w => DeserialiseBaseItem(w, filter.SkipDeserialization)).ToArray();
  216. result.StartIndex = filter.StartIndex ?? 0;
  217. return result;
  218. }
  219. /// <inheritdoc />
  220. public IReadOnlyList<BaseItemDto> GetItemList(InternalItemsQuery filter)
  221. {
  222. ArgumentNullException.ThrowIfNull(filter);
  223. PrepareFilterQuery(filter);
  224. using var context = _dbProvider.CreateDbContext();
  225. IQueryable<BaseItemEntity> dbQuery = PrepareItemQuery(context, filter);
  226. dbQuery = TranslateQuery(dbQuery, context, filter);
  227. dbQuery = ApplyGroupingFilter(dbQuery, filter);
  228. dbQuery = ApplyQueryPaging(dbQuery, filter);
  229. return dbQuery.AsEnumerable().Where(e => e is not null).Select(w => DeserialiseBaseItem(w, filter.SkipDeserialization)).ToArray();
  230. }
  231. /// <inheritdoc/>
  232. public IReadOnlyList<BaseItem> GetLatestItemList(InternalItemsQuery filter, CollectionType collectionType)
  233. {
  234. ArgumentNullException.ThrowIfNull(filter);
  235. PrepareFilterQuery(filter);
  236. // Early exit if collection type is not tvshows or music
  237. if (collectionType != CollectionType.tvshows && collectionType != CollectionType.music)
  238. {
  239. return Array.Empty<BaseItem>();
  240. }
  241. using var context = _dbProvider.CreateDbContext();
  242. // Subquery to group by SeriesNames/Album and get the max Date Created for each group.
  243. var subquery = PrepareItemQuery(context, filter);
  244. subquery = TranslateQuery(subquery, context, filter);
  245. var subqueryGrouped = subquery.GroupBy(g => collectionType == CollectionType.tvshows ? g.SeriesName : g.Album)
  246. .Select(g => new
  247. {
  248. Key = g.Key,
  249. MaxDateCreated = g.Max(a => a.DateCreated)
  250. })
  251. .OrderByDescending(g => g.MaxDateCreated)
  252. .Select(g => g);
  253. if (filter.Limit.HasValue)
  254. {
  255. subqueryGrouped = subqueryGrouped.Take(filter.Limit.Value);
  256. }
  257. filter.Limit = null;
  258. var mainquery = PrepareItemQuery(context, filter);
  259. mainquery = TranslateQuery(mainquery, context, filter);
  260. mainquery = mainquery.Where(g => g.DateCreated >= subqueryGrouped.Min(s => s.MaxDateCreated));
  261. mainquery = ApplyGroupingFilter(mainquery, filter);
  262. mainquery = ApplyQueryPaging(mainquery, filter);
  263. return mainquery.AsEnumerable().Where(e => e is not null).Select(w => DeserialiseBaseItem(w, filter.SkipDeserialization)).ToArray();
  264. }
  265. /// <inheritdoc />
  266. public IReadOnlyList<string> GetNextUpSeriesKeys(InternalItemsQuery filter, DateTime dateCutoff)
  267. {
  268. ArgumentNullException.ThrowIfNull(filter);
  269. ArgumentNullException.ThrowIfNull(filter.User);
  270. using var context = _dbProvider.CreateDbContext();
  271. var query = context.BaseItems
  272. .AsNoTracking()
  273. .Where(i => filter.TopParentIds.Contains(i.TopParentId!.Value))
  274. .Where(i => i.Type == _itemTypeLookup.BaseItemKindNames[BaseItemKind.Episode])
  275. .Join(
  276. context.UserData.AsNoTracking(),
  277. i => new { UserId = filter.User.Id, ItemId = i.Id },
  278. u => new { UserId = u.UserId, ItemId = u.ItemId },
  279. (entity, data) => new { Item = entity, UserData = data })
  280. .GroupBy(g => g.Item.SeriesPresentationUniqueKey)
  281. .Select(g => new { g.Key, LastPlayedDate = g.Max(u => u.UserData.LastPlayedDate) })
  282. .Where(g => g.Key != null && g.LastPlayedDate != null && g.LastPlayedDate >= dateCutoff)
  283. .OrderByDescending(g => g.LastPlayedDate)
  284. .Select(g => g.Key!);
  285. if (filter.Limit.HasValue)
  286. {
  287. query = query.Take(filter.Limit.Value);
  288. }
  289. return query.ToArray();
  290. }
  291. private IQueryable<BaseItemEntity> ApplyGroupingFilter(IQueryable<BaseItemEntity> dbQuery, InternalItemsQuery filter)
  292. {
  293. // This whole block is needed to filter duplicate entries on request
  294. // for the time being it cannot be used because it would destroy the ordering
  295. // this results in "duplicate" responses for queries that try to lookup individual series or multiple versions but
  296. // for that case the invoker has to run a DistinctBy(e => e.PresentationUniqueKey) on their own
  297. // var enableGroupByPresentationUniqueKey = EnableGroupByPresentationUniqueKey(filter);
  298. // if (enableGroupByPresentationUniqueKey && filter.GroupBySeriesPresentationUniqueKey)
  299. // {
  300. // dbQuery = ApplyOrder(dbQuery, filter);
  301. // dbQuery = dbQuery.GroupBy(e => new { e.PresentationUniqueKey, e.SeriesPresentationUniqueKey }).Select(e => e.First());
  302. // }
  303. // else if (enableGroupByPresentationUniqueKey)
  304. // {
  305. // dbQuery = ApplyOrder(dbQuery, filter);
  306. // dbQuery = dbQuery.GroupBy(e => e.PresentationUniqueKey).Select(e => e.First());
  307. // }
  308. // else if (filter.GroupBySeriesPresentationUniqueKey)
  309. // {
  310. // dbQuery = ApplyOrder(dbQuery, filter);
  311. // dbQuery = dbQuery.GroupBy(e => e.SeriesPresentationUniqueKey).Select(e => e.First());
  312. // }
  313. // else
  314. // {
  315. // dbQuery = dbQuery.Distinct();
  316. // dbQuery = ApplyOrder(dbQuery, filter);
  317. // }
  318. dbQuery = dbQuery.Distinct();
  319. dbQuery = ApplyOrder(dbQuery, filter);
  320. return dbQuery;
  321. }
  322. private IQueryable<BaseItemEntity> ApplyQueryPaging(IQueryable<BaseItemEntity> dbQuery, InternalItemsQuery filter)
  323. {
  324. if (filter.Limit.HasValue || filter.StartIndex.HasValue)
  325. {
  326. var offset = filter.StartIndex ?? 0;
  327. if (offset > 0)
  328. {
  329. dbQuery = dbQuery.Skip(offset);
  330. }
  331. if (filter.Limit.HasValue)
  332. {
  333. dbQuery = dbQuery.Take(filter.Limit.Value);
  334. }
  335. }
  336. return dbQuery;
  337. }
  338. private IQueryable<BaseItemEntity> ApplyQueryFilter(IQueryable<BaseItemEntity> dbQuery, JellyfinDbContext context, InternalItemsQuery filter)
  339. {
  340. dbQuery = TranslateQuery(dbQuery, context, filter);
  341. dbQuery = ApplyOrder(dbQuery, filter);
  342. dbQuery = ApplyGroupingFilter(dbQuery, filter);
  343. dbQuery = ApplyQueryPaging(dbQuery, filter);
  344. return dbQuery;
  345. }
  346. private IQueryable<BaseItemEntity> PrepareItemQuery(JellyfinDbContext context, InternalItemsQuery filter)
  347. {
  348. IQueryable<BaseItemEntity> dbQuery = context.BaseItems.AsNoTracking().AsSplitQuery()
  349. .Include(e => e.TrailerTypes)
  350. .Include(e => e.Provider)
  351. .Include(e => e.LockedFields);
  352. if (filter.DtoOptions.EnableImages)
  353. {
  354. dbQuery = dbQuery.Include(e => e.Images);
  355. }
  356. return dbQuery;
  357. }
  358. /// <inheritdoc/>
  359. public int GetCount(InternalItemsQuery filter)
  360. {
  361. ArgumentNullException.ThrowIfNull(filter);
  362. // Hack for right now since we currently don't support filtering out these duplicates within a query
  363. PrepareFilterQuery(filter);
  364. using var context = _dbProvider.CreateDbContext();
  365. var dbQuery = TranslateQuery(context.BaseItems.AsNoTracking(), context, filter);
  366. return dbQuery.Count();
  367. }
  368. #pragma warning disable CA1307 // Specify StringComparison for clarity
  369. /// <summary>
  370. /// Gets the type.
  371. /// </summary>
  372. /// <param name="typeName">Name of the type.</param>
  373. /// <returns>Type.</returns>
  374. /// <exception cref="ArgumentNullException"><c>typeName</c> is null.</exception>
  375. private static Type? GetType(string typeName)
  376. {
  377. ArgumentException.ThrowIfNullOrEmpty(typeName);
  378. // TODO: this isn't great. Refactor later to be both globally handled by a dedicated service not just an static variable and be loaded eagerly.
  379. // currently this is done so that plugins may introduce their own type of baseitems as we dont know when we are first called, before or after plugins are loaded
  380. return _typeMap.GetOrAdd(typeName, k => AppDomain.CurrentDomain.GetAssemblies()
  381. .Select(a => a.GetType(k))
  382. .FirstOrDefault(t => t is not null));
  383. }
  384. /// <inheritdoc />
  385. public void SaveImages(BaseItemDto item)
  386. {
  387. ArgumentNullException.ThrowIfNull(item);
  388. var images = item.ImageInfos.Select(e => Map(item.Id, e));
  389. using var context = _dbProvider.CreateDbContext();
  390. using var transaction = context.Database.BeginTransaction();
  391. context.BaseItemImageInfos.Where(e => e.ItemId == item.Id).ExecuteDelete();
  392. context.BaseItemImageInfos.AddRange(images);
  393. context.SaveChanges();
  394. transaction.Commit();
  395. }
  396. /// <inheritdoc />
  397. public void SaveItems(IReadOnlyList<BaseItemDto> items, CancellationToken cancellationToken)
  398. {
  399. UpdateOrInsertItems(items, cancellationToken);
  400. }
  401. /// <inheritdoc cref="IItemRepository"/>
  402. public void UpdateOrInsertItems(IReadOnlyList<BaseItemDto> items, CancellationToken cancellationToken)
  403. {
  404. ArgumentNullException.ThrowIfNull(items);
  405. cancellationToken.ThrowIfCancellationRequested();
  406. var tuples = new List<(BaseItemDto Item, List<Guid>? AncestorIds, BaseItemDto TopParent, IEnumerable<string> UserDataKey, List<string> InheritedTags)>();
  407. foreach (var item in items.GroupBy(e => e.Id).Select(e => e.Last()))
  408. {
  409. var ancestorIds = item.SupportsAncestors ?
  410. item.GetAncestorIds().Distinct().ToList() :
  411. null;
  412. var topParent = item.GetTopParent();
  413. var userdataKey = item.GetUserDataKeys();
  414. var inheritedTags = item.GetInheritedTags();
  415. tuples.Add((item, ancestorIds, topParent, userdataKey, inheritedTags));
  416. }
  417. var localItemValueCache = new Dictionary<(int MagicNumber, string Value), Guid>();
  418. using var context = _dbProvider.CreateDbContext();
  419. using var transaction = context.Database.BeginTransaction();
  420. foreach (var item in tuples)
  421. {
  422. var entity = Map(item.Item);
  423. // TODO: refactor this "inconsistency"
  424. entity.TopParentId = item.TopParent?.Id;
  425. if (!context.BaseItems.Any(e => e.Id == entity.Id))
  426. {
  427. context.BaseItems.Add(entity);
  428. }
  429. else
  430. {
  431. context.BaseItemProviders.Where(e => e.ItemId == entity.Id).ExecuteDelete();
  432. context.BaseItems.Attach(entity).State = EntityState.Modified;
  433. }
  434. context.AncestorIds.Where(e => e.ItemId == entity.Id).ExecuteDelete();
  435. if (item.Item.SupportsAncestors && item.AncestorIds != null)
  436. {
  437. foreach (var ancestorId in item.AncestorIds)
  438. {
  439. if (!context.BaseItems.Any(f => f.Id == ancestorId))
  440. {
  441. continue;
  442. }
  443. context.AncestorIds.Add(new AncestorId()
  444. {
  445. ParentItemId = ancestorId,
  446. ItemId = entity.Id,
  447. Item = null!,
  448. ParentItem = null!
  449. });
  450. }
  451. }
  452. // Never save duplicate itemValues as they are now mapped anyway.
  453. var itemValuesToSave = GetItemValuesToSave(item.Item, item.InheritedTags).DistinctBy(e => (GetCleanValue(e.Value), e.MagicNumber));
  454. context.ItemValuesMap.Where(e => e.ItemId == entity.Id).ExecuteDelete();
  455. foreach (var itemValue in itemValuesToSave)
  456. {
  457. if (!localItemValueCache.TryGetValue(itemValue, out var refValue))
  458. {
  459. refValue = context.ItemValues
  460. .Where(f => f.Value == itemValue.Value && (int)f.Type == itemValue.MagicNumber)
  461. .Select(e => e.ItemValueId)
  462. .FirstOrDefault();
  463. }
  464. if (refValue.IsEmpty())
  465. {
  466. context.ItemValues.Add(new ItemValue()
  467. {
  468. CleanValue = GetCleanValue(itemValue.Value),
  469. Type = (ItemValueType)itemValue.MagicNumber,
  470. ItemValueId = refValue = Guid.NewGuid(),
  471. Value = itemValue.Value
  472. });
  473. localItemValueCache[itemValue] = refValue;
  474. }
  475. context.ItemValuesMap.Add(new ItemValueMap()
  476. {
  477. Item = null!,
  478. ItemId = entity.Id,
  479. ItemValue = null!,
  480. ItemValueId = refValue
  481. });
  482. }
  483. }
  484. context.SaveChanges();
  485. transaction.Commit();
  486. }
  487. /// <inheritdoc />
  488. public BaseItemDto? RetrieveItem(Guid id)
  489. {
  490. if (id.IsEmpty())
  491. {
  492. throw new ArgumentException("Guid can't be empty", nameof(id));
  493. }
  494. using var context = _dbProvider.CreateDbContext();
  495. var item = PrepareItemQuery(context, new()
  496. {
  497. DtoOptions = new()
  498. {
  499. EnableImages = true
  500. }
  501. }).FirstOrDefault(e => e.Id == id);
  502. if (item is null)
  503. {
  504. return null;
  505. }
  506. return DeserialiseBaseItem(item);
  507. }
  508. /// <summary>
  509. /// Maps a Entity to the DTO.
  510. /// </summary>
  511. /// <param name="entity">The entity.</param>
  512. /// <param name="dto">The dto base instance.</param>
  513. /// <param name="appHost">The Application server Host.</param>
  514. /// <returns>The dto to map.</returns>
  515. public static BaseItemDto Map(BaseItemEntity entity, BaseItemDto dto, IServerApplicationHost? appHost)
  516. {
  517. dto.Id = entity.Id;
  518. dto.ParentId = entity.ParentId.GetValueOrDefault();
  519. dto.Path = appHost?.ExpandVirtualPath(entity.Path) ?? entity.Path;
  520. dto.EndDate = entity.EndDate;
  521. dto.CommunityRating = entity.CommunityRating;
  522. dto.CustomRating = entity.CustomRating;
  523. dto.IndexNumber = entity.IndexNumber;
  524. dto.IsLocked = entity.IsLocked;
  525. dto.Name = entity.Name;
  526. dto.OfficialRating = entity.OfficialRating;
  527. dto.Overview = entity.Overview;
  528. dto.ParentIndexNumber = entity.ParentIndexNumber;
  529. dto.PremiereDate = entity.PremiereDate;
  530. dto.ProductionYear = entity.ProductionYear;
  531. dto.SortName = entity.SortName;
  532. dto.ForcedSortName = entity.ForcedSortName;
  533. dto.RunTimeTicks = entity.RunTimeTicks;
  534. dto.PreferredMetadataLanguage = entity.PreferredMetadataLanguage;
  535. dto.PreferredMetadataCountryCode = entity.PreferredMetadataCountryCode;
  536. dto.IsInMixedFolder = entity.IsInMixedFolder;
  537. dto.InheritedParentalRatingValue = entity.InheritedParentalRatingValue;
  538. dto.InheritedParentalRatingSubValue = entity.InheritedParentalRatingSubValue;
  539. dto.CriticRating = entity.CriticRating;
  540. dto.PresentationUniqueKey = entity.PresentationUniqueKey;
  541. dto.OriginalTitle = entity.OriginalTitle;
  542. dto.Album = entity.Album;
  543. dto.LUFS = entity.LUFS;
  544. dto.NormalizationGain = entity.NormalizationGain;
  545. dto.IsVirtualItem = entity.IsVirtualItem;
  546. dto.ExternalSeriesId = entity.ExternalSeriesId;
  547. dto.Tagline = entity.Tagline;
  548. dto.TotalBitrate = entity.TotalBitrate;
  549. dto.ExternalId = entity.ExternalId;
  550. dto.Size = entity.Size;
  551. dto.Genres = entity.Genres?.Split('|') ?? [];
  552. dto.DateCreated = entity.DateCreated.GetValueOrDefault();
  553. dto.DateModified = entity.DateModified.GetValueOrDefault();
  554. dto.ChannelId = entity.ChannelId ?? Guid.Empty;
  555. dto.DateLastRefreshed = entity.DateLastRefreshed.GetValueOrDefault();
  556. dto.DateLastSaved = entity.DateLastSaved.GetValueOrDefault();
  557. dto.OwnerId = string.IsNullOrWhiteSpace(entity.OwnerId) ? Guid.Empty : (Guid.TryParse(entity.OwnerId, out var ownerId) ? ownerId : Guid.Empty);
  558. dto.Width = entity.Width.GetValueOrDefault();
  559. dto.Height = entity.Height.GetValueOrDefault();
  560. if (entity.Provider is not null)
  561. {
  562. dto.ProviderIds = entity.Provider.ToDictionary(e => e.ProviderId, e => e.ProviderValue);
  563. }
  564. if (entity.ExtraType is not null)
  565. {
  566. dto.ExtraType = (ExtraType)entity.ExtraType;
  567. }
  568. if (entity.LockedFields is not null)
  569. {
  570. dto.LockedFields = entity.LockedFields?.Select(e => (MetadataField)e.Id).ToArray() ?? [];
  571. }
  572. if (entity.Audio is not null)
  573. {
  574. dto.Audio = (ProgramAudio)entity.Audio;
  575. }
  576. dto.ExtraIds = string.IsNullOrWhiteSpace(entity.ExtraIds) ? [] : entity.ExtraIds.Split('|').Select(e => Guid.Parse(e)).ToArray();
  577. dto.ProductionLocations = entity.ProductionLocations?.Split('|') ?? [];
  578. dto.Studios = entity.Studios?.Split('|') ?? [];
  579. dto.Tags = entity.Tags?.Split('|') ?? [];
  580. if (dto is IHasProgramAttributes hasProgramAttributes)
  581. {
  582. hasProgramAttributes.IsMovie = entity.IsMovie;
  583. hasProgramAttributes.IsSeries = entity.IsSeries;
  584. hasProgramAttributes.EpisodeTitle = entity.EpisodeTitle;
  585. hasProgramAttributes.IsRepeat = entity.IsRepeat;
  586. }
  587. if (dto is LiveTvChannel liveTvChannel)
  588. {
  589. liveTvChannel.ServiceName = entity.ExternalServiceId;
  590. }
  591. if (dto is Trailer trailer)
  592. {
  593. trailer.TrailerTypes = entity.TrailerTypes?.Select(e => (TrailerType)e.Id).ToArray() ?? [];
  594. }
  595. if (dto is Video video)
  596. {
  597. video.PrimaryVersionId = entity.PrimaryVersionId;
  598. }
  599. if (dto is IHasSeries hasSeriesName)
  600. {
  601. hasSeriesName.SeriesName = entity.SeriesName;
  602. hasSeriesName.SeriesId = entity.SeriesId.GetValueOrDefault();
  603. hasSeriesName.SeriesPresentationUniqueKey = entity.SeriesPresentationUniqueKey;
  604. }
  605. if (dto is Episode episode)
  606. {
  607. episode.SeasonName = entity.SeasonName;
  608. episode.SeasonId = entity.SeasonId.GetValueOrDefault();
  609. }
  610. if (dto is IHasArtist hasArtists)
  611. {
  612. hasArtists.Artists = entity.Artists?.Split('|', StringSplitOptions.RemoveEmptyEntries) ?? [];
  613. }
  614. if (dto is IHasAlbumArtist hasAlbumArtists)
  615. {
  616. hasAlbumArtists.AlbumArtists = entity.AlbumArtists?.Split('|', StringSplitOptions.RemoveEmptyEntries) ?? [];
  617. }
  618. if (dto is LiveTvProgram program)
  619. {
  620. program.ShowId = entity.ShowId;
  621. }
  622. if (entity.Images is not null)
  623. {
  624. dto.ImageInfos = entity.Images.Select(e => Map(e, appHost)).ToArray();
  625. }
  626. // dto.Type = entity.Type;
  627. // dto.Data = entity.Data;
  628. // dto.MediaType = Enum.TryParse<MediaType>(entity.MediaType);
  629. if (dto is IHasStartDate hasStartDate)
  630. {
  631. hasStartDate.StartDate = entity.StartDate.GetValueOrDefault();
  632. }
  633. // Fields that are present in the DB but are never actually used
  634. // dto.UnratedType = entity.UnratedType;
  635. // dto.TopParentId = entity.TopParentId;
  636. // dto.CleanName = entity.CleanName;
  637. // dto.UserDataKey = entity.UserDataKey;
  638. if (dto is Folder folder)
  639. {
  640. folder.DateLastMediaAdded = entity.DateLastMediaAdded;
  641. }
  642. return dto;
  643. }
  644. /// <summary>
  645. /// Maps a Entity to the DTO.
  646. /// </summary>
  647. /// <param name="dto">The entity.</param>
  648. /// <returns>The dto to map.</returns>
  649. public BaseItemEntity Map(BaseItemDto dto)
  650. {
  651. var dtoType = dto.GetType();
  652. var entity = new BaseItemEntity()
  653. {
  654. Type = dtoType.ToString(),
  655. Id = dto.Id
  656. };
  657. if (TypeRequiresDeserialization(dtoType))
  658. {
  659. entity.Data = JsonSerializer.Serialize(dto, dtoType, JsonDefaults.Options);
  660. }
  661. entity.ParentId = !dto.ParentId.IsEmpty() ? dto.ParentId : null;
  662. entity.Path = GetPathToSave(dto.Path);
  663. entity.EndDate = dto.EndDate;
  664. entity.CommunityRating = dto.CommunityRating;
  665. entity.CustomRating = dto.CustomRating;
  666. entity.IndexNumber = dto.IndexNumber;
  667. entity.IsLocked = dto.IsLocked;
  668. entity.Name = dto.Name;
  669. entity.CleanName = GetCleanValue(dto.Name);
  670. entity.OfficialRating = dto.OfficialRating;
  671. entity.Overview = dto.Overview;
  672. entity.ParentIndexNumber = dto.ParentIndexNumber;
  673. entity.PremiereDate = dto.PremiereDate;
  674. entity.ProductionYear = dto.ProductionYear;
  675. entity.SortName = dto.SortName;
  676. entity.ForcedSortName = dto.ForcedSortName;
  677. entity.RunTimeTicks = dto.RunTimeTicks;
  678. entity.PreferredMetadataLanguage = dto.PreferredMetadataLanguage;
  679. entity.PreferredMetadataCountryCode = dto.PreferredMetadataCountryCode;
  680. entity.IsInMixedFolder = dto.IsInMixedFolder;
  681. entity.InheritedParentalRatingValue = dto.InheritedParentalRatingValue;
  682. entity.InheritedParentalRatingSubValue = dto.InheritedParentalRatingSubValue;
  683. entity.CriticRating = dto.CriticRating;
  684. entity.PresentationUniqueKey = dto.PresentationUniqueKey;
  685. entity.OriginalTitle = dto.OriginalTitle;
  686. entity.Album = dto.Album;
  687. entity.LUFS = dto.LUFS;
  688. entity.NormalizationGain = dto.NormalizationGain;
  689. entity.IsVirtualItem = dto.IsVirtualItem;
  690. entity.ExternalSeriesId = dto.ExternalSeriesId;
  691. entity.Tagline = dto.Tagline;
  692. entity.TotalBitrate = dto.TotalBitrate;
  693. entity.ExternalId = dto.ExternalId;
  694. entity.Size = dto.Size;
  695. entity.Genres = string.Join('|', dto.Genres);
  696. entity.DateCreated = dto.DateCreated;
  697. entity.DateModified = dto.DateModified;
  698. entity.ChannelId = dto.ChannelId;
  699. entity.DateLastRefreshed = dto.DateLastRefreshed;
  700. entity.DateLastSaved = dto.DateLastSaved;
  701. entity.OwnerId = dto.OwnerId.ToString();
  702. entity.Width = dto.Width;
  703. entity.Height = dto.Height;
  704. entity.Provider = dto.ProviderIds.Select(e => new BaseItemProvider()
  705. {
  706. Item = entity,
  707. ProviderId = e.Key,
  708. ProviderValue = e.Value
  709. }).ToList();
  710. if (dto.Audio.HasValue)
  711. {
  712. entity.Audio = (ProgramAudioEntity)dto.Audio;
  713. }
  714. if (dto.ExtraType.HasValue)
  715. {
  716. entity.ExtraType = (BaseItemExtraType)dto.ExtraType;
  717. }
  718. entity.ExtraIds = dto.ExtraIds is not null ? string.Join('|', dto.ExtraIds) : null;
  719. entity.ProductionLocations = dto.ProductionLocations is not null ? string.Join('|', dto.ProductionLocations) : null;
  720. entity.Studios = dto.Studios is not null ? string.Join('|', dto.Studios) : null;
  721. entity.Tags = dto.Tags is not null ? string.Join('|', dto.Tags) : null;
  722. entity.LockedFields = dto.LockedFields is not null ? dto.LockedFields
  723. .Select(e => new BaseItemMetadataField()
  724. {
  725. Id = (int)e,
  726. Item = entity,
  727. ItemId = entity.Id
  728. })
  729. .ToArray() : null;
  730. if (dto is IHasProgramAttributes hasProgramAttributes)
  731. {
  732. entity.IsMovie = hasProgramAttributes.IsMovie;
  733. entity.IsSeries = hasProgramAttributes.IsSeries;
  734. entity.EpisodeTitle = hasProgramAttributes.EpisodeTitle;
  735. entity.IsRepeat = hasProgramAttributes.IsRepeat;
  736. }
  737. if (dto is LiveTvChannel liveTvChannel)
  738. {
  739. entity.ExternalServiceId = liveTvChannel.ServiceName;
  740. }
  741. if (dto is Video video)
  742. {
  743. entity.PrimaryVersionId = video.PrimaryVersionId;
  744. }
  745. if (dto is IHasSeries hasSeriesName)
  746. {
  747. entity.SeriesName = hasSeriesName.SeriesName;
  748. entity.SeriesId = hasSeriesName.SeriesId;
  749. entity.SeriesPresentationUniqueKey = hasSeriesName.SeriesPresentationUniqueKey;
  750. }
  751. if (dto is Episode episode)
  752. {
  753. entity.SeasonName = episode.SeasonName;
  754. entity.SeasonId = episode.SeasonId;
  755. }
  756. if (dto is IHasArtist hasArtists)
  757. {
  758. entity.Artists = hasArtists.Artists is not null ? string.Join('|', hasArtists.Artists) : null;
  759. }
  760. if (dto is IHasAlbumArtist hasAlbumArtists)
  761. {
  762. entity.AlbumArtists = hasAlbumArtists.AlbumArtists is not null ? string.Join('|', hasAlbumArtists.AlbumArtists) : null;
  763. }
  764. if (dto is LiveTvProgram program)
  765. {
  766. entity.ShowId = program.ShowId;
  767. }
  768. if (dto.ImageInfos is not null)
  769. {
  770. entity.Images = dto.ImageInfos.Select(f => Map(dto.Id, f)).ToArray();
  771. }
  772. if (dto is Trailer trailer)
  773. {
  774. entity.TrailerTypes = trailer.TrailerTypes?.Select(e => new BaseItemTrailerType()
  775. {
  776. Id = (int)e,
  777. Item = entity,
  778. ItemId = entity.Id
  779. }).ToArray() ?? [];
  780. }
  781. // dto.Type = entity.Type;
  782. // dto.Data = entity.Data;
  783. entity.MediaType = dto.MediaType.ToString();
  784. if (dto is IHasStartDate hasStartDate)
  785. {
  786. entity.StartDate = hasStartDate.StartDate;
  787. }
  788. entity.UnratedType = dto.GetBlockUnratedType().ToString();
  789. // Fields that are present in the DB but are never actually used
  790. // dto.UserDataKey = entity.UserDataKey;
  791. if (dto is Folder folder)
  792. {
  793. entity.DateLastMediaAdded = folder.DateLastMediaAdded;
  794. entity.IsFolder = folder.IsFolder;
  795. }
  796. return entity;
  797. }
  798. private string[] GetItemValueNames(IReadOnlyList<ItemValueType> itemValueTypes, IReadOnlyList<string> withItemTypes, IReadOnlyList<string> excludeItemTypes)
  799. {
  800. using var context = _dbProvider.CreateDbContext();
  801. var query = context.ItemValuesMap
  802. .AsNoTracking()
  803. .Where(e => itemValueTypes.Any(w => (ItemValueType)w == e.ItemValue.Type));
  804. if (withItemTypes.Count > 0)
  805. {
  806. query = query.Where(e => withItemTypes.Contains(e.Item.Type));
  807. }
  808. if (excludeItemTypes.Count > 0)
  809. {
  810. query = query.Where(e => !excludeItemTypes.Contains(e.Item.Type));
  811. }
  812. // query = query.DistinctBy(e => e.CleanValue);
  813. return query.Select(e => e.ItemValue)
  814. .GroupBy(e => e.CleanValue)
  815. .Select(e => e.First().Value)
  816. .ToArray();
  817. }
  818. private static bool TypeRequiresDeserialization(Type type)
  819. {
  820. return type.GetCustomAttribute<RequiresSourceSerialisationAttribute>() == null;
  821. }
  822. private BaseItemDto DeserialiseBaseItem(BaseItemEntity baseItemEntity, bool skipDeserialization = false)
  823. {
  824. ArgumentNullException.ThrowIfNull(baseItemEntity, nameof(baseItemEntity));
  825. if (_serverConfigurationManager?.Configuration is null)
  826. {
  827. throw new InvalidOperationException("Server Configuration manager or configuration is null");
  828. }
  829. var typeToSerialise = GetType(baseItemEntity.Type);
  830. return BaseItemRepository.DeserialiseBaseItem(
  831. baseItemEntity,
  832. _logger,
  833. _appHost,
  834. skipDeserialization || (_serverConfigurationManager.Configuration.SkipDeserializationForBasicTypes && (typeToSerialise == typeof(Channel) || typeToSerialise == typeof(UserRootFolder))));
  835. }
  836. /// <summary>
  837. /// Deserialises a BaseItemEntity and sets all properties.
  838. /// </summary>
  839. /// <param name="baseItemEntity">The DB entity.</param>
  840. /// <param name="logger">Logger.</param>
  841. /// <param name="appHost">The application server Host.</param>
  842. /// <param name="skipDeserialization">If only mapping should be processed.</param>
  843. /// <returns>A mapped BaseItem.</returns>
  844. /// <exception cref="InvalidOperationException">Will be thrown if an invalid serialisation is requested.</exception>
  845. public static BaseItemDto DeserialiseBaseItem(BaseItemEntity baseItemEntity, ILogger logger, IServerApplicationHost? appHost, bool skipDeserialization = false)
  846. {
  847. var type = GetType(baseItemEntity.Type) ?? throw new InvalidOperationException("Cannot deserialise unknown type.");
  848. BaseItemDto? dto = null;
  849. if (TypeRequiresDeserialization(type) && baseItemEntity.Data is not null && !skipDeserialization)
  850. {
  851. try
  852. {
  853. dto = JsonSerializer.Deserialize(baseItemEntity.Data, type, JsonDefaults.Options) as BaseItemDto;
  854. }
  855. catch (JsonException ex)
  856. {
  857. logger.LogError(ex, "Error deserializing item with JSON: {Data}", baseItemEntity.Data);
  858. }
  859. }
  860. if (dto is null)
  861. {
  862. dto = Activator.CreateInstance(type) as BaseItemDto ?? throw new InvalidOperationException("Cannot deserialise unknown type.");
  863. }
  864. return Map(baseItemEntity, dto, appHost);
  865. }
  866. private QueryResult<(BaseItemDto Item, ItemCounts ItemCounts)> GetItemValues(InternalItemsQuery filter, IReadOnlyList<ItemValueType> itemValueTypes, string returnType)
  867. {
  868. ArgumentNullException.ThrowIfNull(filter);
  869. if (!filter.Limit.HasValue)
  870. {
  871. filter.EnableTotalRecordCount = false;
  872. }
  873. using var context = _dbProvider.CreateDbContext();
  874. var query = TranslateQuery(context.BaseItems.AsNoTracking(), context, filter);
  875. query = query.Where(e => e.Type == returnType);
  876. // this does not seem to be nesseary but it does not make any sense why this isn't working.
  877. // && e.ItemValues!.Any(f => e.CleanName == f.ItemValue.CleanValue && itemValueTypes.Any(w => (ItemValueType)w == f.ItemValue.Type)));
  878. if (filter.OrderBy.Count != 0
  879. || !string.IsNullOrEmpty(filter.SearchTerm))
  880. {
  881. query = ApplyOrder(query, filter);
  882. }
  883. else
  884. {
  885. query = query.OrderBy(e => e.SortName);
  886. }
  887. if (filter.Limit.HasValue || filter.StartIndex.HasValue)
  888. {
  889. var offset = filter.StartIndex ?? 0;
  890. if (offset > 0)
  891. {
  892. query = query.Skip(offset);
  893. }
  894. if (filter.Limit.HasValue)
  895. {
  896. query = query.Take(filter.Limit.Value);
  897. }
  898. }
  899. var result = new QueryResult<(BaseItemDto, ItemCounts)>();
  900. if (filter.EnableTotalRecordCount)
  901. {
  902. result.TotalRecordCount = query.GroupBy(e => e.PresentationUniqueKey).Select(e => e.First()).Count();
  903. }
  904. var seriesTypeName = _itemTypeLookup.BaseItemKindNames[BaseItemKind.Series];
  905. var movieTypeName = _itemTypeLookup.BaseItemKindNames[BaseItemKind.Movie];
  906. var episodeTypeName = _itemTypeLookup.BaseItemKindNames[BaseItemKind.Episode];
  907. var musicAlbumTypeName = _itemTypeLookup.BaseItemKindNames[BaseItemKind.MusicAlbum];
  908. var musicArtistTypeName = _itemTypeLookup.BaseItemKindNames[BaseItemKind.MusicArtist];
  909. var audioTypeName = _itemTypeLookup.BaseItemKindNames[BaseItemKind.Audio];
  910. var trailerTypeName = _itemTypeLookup.BaseItemKindNames[BaseItemKind.Trailer];
  911. var resultQuery = query.Select(e => new
  912. {
  913. item = e,
  914. // TODO: This is bad refactor!
  915. itemCount = new ItemCounts()
  916. {
  917. SeriesCount = e.ItemValues!.Count(f => f.Item.Type == seriesTypeName),
  918. EpisodeCount = e.ItemValues!.Count(f => f.Item.Type == episodeTypeName),
  919. MovieCount = e.ItemValues!.Count(f => f.Item.Type == movieTypeName),
  920. AlbumCount = e.ItemValues!.Count(f => f.Item.Type == musicAlbumTypeName),
  921. ArtistCount = e.ItemValues!.Count(f => f.Item.Type == musicArtistTypeName),
  922. SongCount = e.ItemValues!.Count(f => f.Item.Type == audioTypeName),
  923. TrailerCount = e.ItemValues!.Count(f => f.Item.Type == trailerTypeName),
  924. }
  925. });
  926. result.StartIndex = filter.StartIndex ?? 0;
  927. result.Items = resultQuery.ToArray().Where(e => e is not null).Select(e =>
  928. {
  929. return (DeserialiseBaseItem(e.item, filter.SkipDeserialization), e.itemCount);
  930. }).ToArray();
  931. return result;
  932. }
  933. private static void PrepareFilterQuery(InternalItemsQuery query)
  934. {
  935. if (query.Limit.HasValue && query.EnableGroupByMetadataKey)
  936. {
  937. query.Limit = query.Limit.Value + 4;
  938. }
  939. if (query.IsResumable ?? false)
  940. {
  941. query.IsVirtualItem = false;
  942. }
  943. }
  944. private string GetCleanValue(string value)
  945. {
  946. if (string.IsNullOrWhiteSpace(value))
  947. {
  948. return value;
  949. }
  950. return value.RemoveDiacritics().ToLowerInvariant();
  951. }
  952. private List<(int MagicNumber, string Value)> GetItemValuesToSave(BaseItemDto item, List<string> inheritedTags)
  953. {
  954. var list = new List<(int, string)>();
  955. if (item is IHasArtist hasArtist)
  956. {
  957. list.AddRange(hasArtist.Artists.Select(i => (0, i)));
  958. }
  959. if (item is IHasAlbumArtist hasAlbumArtist)
  960. {
  961. list.AddRange(hasAlbumArtist.AlbumArtists.Select(i => (1, i)));
  962. }
  963. list.AddRange(item.Genres.Select(i => (2, i)));
  964. list.AddRange(item.Studios.Select(i => (3, i)));
  965. list.AddRange(item.Tags.Select(i => (4, i)));
  966. // keywords was 5
  967. list.AddRange(inheritedTags.Select(i => (6, i)));
  968. // Remove all invalid values.
  969. list.RemoveAll(i => string.IsNullOrWhiteSpace(i.Item2));
  970. return list;
  971. }
  972. private static BaseItemImageInfo Map(Guid baseItemId, ItemImageInfo e)
  973. {
  974. return new BaseItemImageInfo()
  975. {
  976. ItemId = baseItemId,
  977. Id = Guid.NewGuid(),
  978. Path = e.Path,
  979. Blurhash = e.BlurHash is null ? null : Encoding.UTF8.GetBytes(e.BlurHash),
  980. DateModified = e.DateModified,
  981. Height = e.Height,
  982. Width = e.Width,
  983. ImageType = (ImageInfoImageType)e.Type,
  984. Item = null!
  985. };
  986. }
  987. private static ItemImageInfo Map(BaseItemImageInfo e, IServerApplicationHost? appHost)
  988. {
  989. return new ItemImageInfo()
  990. {
  991. Path = appHost?.ExpandVirtualPath(e.Path) ?? e.Path,
  992. BlurHash = e.Blurhash is null ? null : Encoding.UTF8.GetString(e.Blurhash),
  993. DateModified = e.DateModified,
  994. Height = e.Height,
  995. Width = e.Width,
  996. Type = (ImageType)e.ImageType
  997. };
  998. }
  999. private string? GetPathToSave(string path)
  1000. {
  1001. if (path is null)
  1002. {
  1003. return null;
  1004. }
  1005. return _appHost.ReverseVirtualPath(path);
  1006. }
  1007. private List<string> GetItemByNameTypesInQuery(InternalItemsQuery query)
  1008. {
  1009. var list = new List<string>();
  1010. if (IsTypeInQuery(BaseItemKind.Person, query))
  1011. {
  1012. list.Add(_itemTypeLookup.BaseItemKindNames[BaseItemKind.Person]!);
  1013. }
  1014. if (IsTypeInQuery(BaseItemKind.Genre, query))
  1015. {
  1016. list.Add(_itemTypeLookup.BaseItemKindNames[BaseItemKind.Genre]!);
  1017. }
  1018. if (IsTypeInQuery(BaseItemKind.MusicGenre, query))
  1019. {
  1020. list.Add(_itemTypeLookup.BaseItemKindNames[BaseItemKind.MusicGenre]!);
  1021. }
  1022. if (IsTypeInQuery(BaseItemKind.MusicArtist, query))
  1023. {
  1024. list.Add(_itemTypeLookup.BaseItemKindNames[BaseItemKind.MusicArtist]!);
  1025. }
  1026. if (IsTypeInQuery(BaseItemKind.Studio, query))
  1027. {
  1028. list.Add(_itemTypeLookup.BaseItemKindNames[BaseItemKind.Studio]!);
  1029. }
  1030. return list;
  1031. }
  1032. private bool IsTypeInQuery(BaseItemKind type, InternalItemsQuery query)
  1033. {
  1034. if (query.ExcludeItemTypes.Contains(type))
  1035. {
  1036. return false;
  1037. }
  1038. return query.IncludeItemTypes.Length == 0 || query.IncludeItemTypes.Contains(type);
  1039. }
  1040. private bool EnableGroupByPresentationUniqueKey(InternalItemsQuery query)
  1041. {
  1042. if (!query.GroupByPresentationUniqueKey)
  1043. {
  1044. return false;
  1045. }
  1046. if (query.GroupBySeriesPresentationUniqueKey)
  1047. {
  1048. return false;
  1049. }
  1050. if (!string.IsNullOrWhiteSpace(query.PresentationUniqueKey))
  1051. {
  1052. return false;
  1053. }
  1054. if (query.User is null)
  1055. {
  1056. return false;
  1057. }
  1058. if (query.IncludeItemTypes.Length == 0)
  1059. {
  1060. return true;
  1061. }
  1062. return query.IncludeItemTypes.Contains(BaseItemKind.Episode)
  1063. || query.IncludeItemTypes.Contains(BaseItemKind.Video)
  1064. || query.IncludeItemTypes.Contains(BaseItemKind.Movie)
  1065. || query.IncludeItemTypes.Contains(BaseItemKind.MusicVideo)
  1066. || query.IncludeItemTypes.Contains(BaseItemKind.Series)
  1067. || query.IncludeItemTypes.Contains(BaseItemKind.Season);
  1068. }
  1069. private IQueryable<BaseItemEntity> ApplyOrder(IQueryable<BaseItemEntity> query, InternalItemsQuery filter)
  1070. {
  1071. var orderBy = filter.OrderBy;
  1072. var hasSearch = !string.IsNullOrEmpty(filter.SearchTerm);
  1073. if (hasSearch)
  1074. {
  1075. orderBy = filter.OrderBy = [(ItemSortBy.SortName, SortOrder.Ascending), .. orderBy];
  1076. }
  1077. else if (orderBy.Count == 0)
  1078. {
  1079. return query;
  1080. }
  1081. IOrderedQueryable<BaseItemEntity>? orderedQuery = null;
  1082. var firstOrdering = orderBy.FirstOrDefault();
  1083. if (firstOrdering != default)
  1084. {
  1085. var expression = OrderMapper.MapOrderByField(firstOrdering.OrderBy, filter);
  1086. if (firstOrdering.SortOrder == SortOrder.Ascending)
  1087. {
  1088. orderedQuery = query.OrderBy(expression);
  1089. }
  1090. else
  1091. {
  1092. orderedQuery = query.OrderByDescending(expression);
  1093. }
  1094. if (firstOrdering.OrderBy is ItemSortBy.Default or ItemSortBy.SortName)
  1095. {
  1096. if (firstOrdering.SortOrder is SortOrder.Ascending)
  1097. {
  1098. orderedQuery = orderedQuery.ThenBy(e => e.Name);
  1099. }
  1100. else
  1101. {
  1102. orderedQuery = orderedQuery.ThenByDescending(e => e.Name);
  1103. }
  1104. }
  1105. }
  1106. foreach (var item in orderBy.Skip(1))
  1107. {
  1108. var expression = OrderMapper.MapOrderByField(item.OrderBy, filter);
  1109. if (item.SortOrder == SortOrder.Ascending)
  1110. {
  1111. orderedQuery = orderedQuery!.ThenBy(expression);
  1112. }
  1113. else
  1114. {
  1115. orderedQuery = orderedQuery!.ThenByDescending(expression);
  1116. }
  1117. }
  1118. return orderedQuery ?? query;
  1119. }
  1120. private IQueryable<BaseItemEntity> TranslateQuery(
  1121. IQueryable<BaseItemEntity> baseQuery,
  1122. JellyfinDbContext context,
  1123. InternalItemsQuery filter)
  1124. {
  1125. const int HDWidth = 1200;
  1126. const int UHDWidth = 3800;
  1127. const int UHDHeight = 2100;
  1128. var minWidth = filter.MinWidth;
  1129. var maxWidth = filter.MaxWidth;
  1130. var now = DateTime.UtcNow;
  1131. if (filter.IsHD.HasValue || filter.Is4K.HasValue)
  1132. {
  1133. bool includeSD = false;
  1134. bool includeHD = false;
  1135. bool include4K = false;
  1136. if (filter.IsHD.HasValue && !filter.IsHD.Value)
  1137. {
  1138. includeSD = true;
  1139. }
  1140. if (filter.IsHD.HasValue && filter.IsHD.Value)
  1141. {
  1142. includeHD = true;
  1143. }
  1144. if (filter.Is4K.HasValue && filter.Is4K.Value)
  1145. {
  1146. include4K = true;
  1147. }
  1148. baseQuery = baseQuery.Where(e =>
  1149. (includeSD && e.Width < HDWidth) ||
  1150. (includeHD && e.Width >= HDWidth && !(e.Width >= UHDWidth || e.Height >= UHDHeight)) ||
  1151. (include4K && (e.Width >= UHDWidth || e.Height >= UHDHeight)));
  1152. }
  1153. if (minWidth.HasValue)
  1154. {
  1155. baseQuery = baseQuery.Where(e => e.Width >= minWidth);
  1156. }
  1157. if (filter.MinHeight.HasValue)
  1158. {
  1159. baseQuery = baseQuery.Where(e => e.Height >= filter.MinHeight);
  1160. }
  1161. if (maxWidth.HasValue)
  1162. {
  1163. baseQuery = baseQuery.Where(e => e.Width >= maxWidth);
  1164. }
  1165. if (filter.MaxHeight.HasValue)
  1166. {
  1167. baseQuery = baseQuery.Where(e => e.Height <= filter.MaxHeight);
  1168. }
  1169. if (filter.IsLocked.HasValue)
  1170. {
  1171. baseQuery = baseQuery.Where(e => e.IsLocked == filter.IsLocked);
  1172. }
  1173. var tags = filter.Tags.ToList();
  1174. var excludeTags = filter.ExcludeTags.ToList();
  1175. if (filter.IsMovie == true)
  1176. {
  1177. if (filter.IncludeItemTypes.Length == 0
  1178. || filter.IncludeItemTypes.Contains(BaseItemKind.Movie)
  1179. || filter.IncludeItemTypes.Contains(BaseItemKind.Trailer))
  1180. {
  1181. baseQuery = baseQuery.Where(e => e.IsMovie);
  1182. }
  1183. }
  1184. else if (filter.IsMovie.HasValue)
  1185. {
  1186. baseQuery = baseQuery.Where(e => e.IsMovie == filter.IsMovie);
  1187. }
  1188. if (filter.IsSeries.HasValue)
  1189. {
  1190. baseQuery = baseQuery.Where(e => e.IsSeries == filter.IsSeries);
  1191. }
  1192. if (filter.IsSports.HasValue)
  1193. {
  1194. if (filter.IsSports.Value)
  1195. {
  1196. tags.Add("Sports");
  1197. }
  1198. else
  1199. {
  1200. excludeTags.Add("Sports");
  1201. }
  1202. }
  1203. if (filter.IsNews.HasValue)
  1204. {
  1205. if (filter.IsNews.Value)
  1206. {
  1207. tags.Add("News");
  1208. }
  1209. else
  1210. {
  1211. excludeTags.Add("News");
  1212. }
  1213. }
  1214. if (filter.IsKids.HasValue)
  1215. {
  1216. if (filter.IsKids.Value)
  1217. {
  1218. tags.Add("Kids");
  1219. }
  1220. else
  1221. {
  1222. excludeTags.Add("Kids");
  1223. }
  1224. }
  1225. if (!string.IsNullOrEmpty(filter.SearchTerm))
  1226. {
  1227. var searchTerm = filter.SearchTerm.ToLower();
  1228. baseQuery = baseQuery.Where(e => e.CleanName!.ToLower().Contains(searchTerm) || (e.OriginalTitle != null && e.OriginalTitle.ToLower().Contains(searchTerm)));
  1229. }
  1230. if (filter.IsFolder.HasValue)
  1231. {
  1232. baseQuery = baseQuery.Where(e => e.IsFolder == filter.IsFolder);
  1233. }
  1234. var includeTypes = filter.IncludeItemTypes;
  1235. // Only specify excluded types if no included types are specified
  1236. if (filter.IncludeItemTypes.Length == 0)
  1237. {
  1238. var excludeTypes = filter.ExcludeItemTypes;
  1239. if (excludeTypes.Length == 1)
  1240. {
  1241. if (_itemTypeLookup.BaseItemKindNames.TryGetValue(excludeTypes[0], out var excludeTypeName))
  1242. {
  1243. baseQuery = baseQuery.Where(e => e.Type != excludeTypeName);
  1244. }
  1245. }
  1246. else if (excludeTypes.Length > 1)
  1247. {
  1248. var excludeTypeName = new List<string>();
  1249. foreach (var excludeType in excludeTypes)
  1250. {
  1251. if (_itemTypeLookup.BaseItemKindNames.TryGetValue(excludeType, out var baseItemKindName))
  1252. {
  1253. excludeTypeName.Add(baseItemKindName!);
  1254. }
  1255. }
  1256. baseQuery = baseQuery.Where(e => !excludeTypeName.Contains(e.Type));
  1257. }
  1258. }
  1259. else if (includeTypes.Length == 1)
  1260. {
  1261. if (_itemTypeLookup.BaseItemKindNames.TryGetValue(includeTypes[0], out var includeTypeName))
  1262. {
  1263. baseQuery = baseQuery.Where(e => e.Type == includeTypeName);
  1264. }
  1265. }
  1266. else if (includeTypes.Length > 1)
  1267. {
  1268. var includeTypeName = new List<string>();
  1269. foreach (var includeType in includeTypes)
  1270. {
  1271. if (_itemTypeLookup.BaseItemKindNames.TryGetValue(includeType, out var baseItemKindName))
  1272. {
  1273. includeTypeName.Add(baseItemKindName!);
  1274. }
  1275. }
  1276. baseQuery = baseQuery.Where(e => includeTypeName.Contains(e.Type));
  1277. }
  1278. if (filter.ChannelIds.Count > 0)
  1279. {
  1280. baseQuery = baseQuery.Where(e => e.ChannelId != null && filter.ChannelIds.Contains(e.ChannelId.Value));
  1281. }
  1282. if (!filter.ParentId.IsEmpty())
  1283. {
  1284. baseQuery = baseQuery.Where(e => e.ParentId!.Value == filter.ParentId);
  1285. }
  1286. if (!string.IsNullOrWhiteSpace(filter.Path))
  1287. {
  1288. baseQuery = baseQuery.Where(e => e.Path == filter.Path);
  1289. }
  1290. if (!string.IsNullOrWhiteSpace(filter.PresentationUniqueKey))
  1291. {
  1292. baseQuery = baseQuery.Where(e => e.PresentationUniqueKey == filter.PresentationUniqueKey);
  1293. }
  1294. if (filter.MinCommunityRating.HasValue)
  1295. {
  1296. baseQuery = baseQuery.Where(e => e.CommunityRating >= filter.MinCommunityRating);
  1297. }
  1298. if (filter.MinIndexNumber.HasValue)
  1299. {
  1300. baseQuery = baseQuery.Where(e => e.IndexNumber >= filter.MinIndexNumber);
  1301. }
  1302. if (filter.MinParentAndIndexNumber.HasValue)
  1303. {
  1304. baseQuery = baseQuery
  1305. .Where(e => (e.ParentIndexNumber == filter.MinParentAndIndexNumber.Value.ParentIndexNumber && e.IndexNumber >= filter.MinParentAndIndexNumber.Value.IndexNumber) || e.ParentIndexNumber > filter.MinParentAndIndexNumber.Value.ParentIndexNumber);
  1306. }
  1307. if (filter.MinDateCreated.HasValue)
  1308. {
  1309. baseQuery = baseQuery.Where(e => e.DateCreated >= filter.MinDateCreated);
  1310. }
  1311. if (filter.MinDateLastSaved.HasValue)
  1312. {
  1313. baseQuery = baseQuery.Where(e => e.DateLastSaved != null && e.DateLastSaved >= filter.MinDateLastSaved.Value);
  1314. }
  1315. if (filter.MinDateLastSavedForUser.HasValue)
  1316. {
  1317. baseQuery = baseQuery.Where(e => e.DateLastSaved != null && e.DateLastSaved >= filter.MinDateLastSavedForUser.Value);
  1318. }
  1319. if (filter.IndexNumber.HasValue)
  1320. {
  1321. baseQuery = baseQuery.Where(e => e.IndexNumber == filter.IndexNumber.Value);
  1322. }
  1323. if (filter.ParentIndexNumber.HasValue)
  1324. {
  1325. baseQuery = baseQuery.Where(e => e.ParentIndexNumber == filter.ParentIndexNumber.Value);
  1326. }
  1327. if (filter.ParentIndexNumberNotEquals.HasValue)
  1328. {
  1329. baseQuery = baseQuery.Where(e => e.ParentIndexNumber != filter.ParentIndexNumberNotEquals.Value || e.ParentIndexNumber == null);
  1330. }
  1331. var minEndDate = filter.MinEndDate;
  1332. var maxEndDate = filter.MaxEndDate;
  1333. if (filter.HasAired.HasValue)
  1334. {
  1335. if (filter.HasAired.Value)
  1336. {
  1337. maxEndDate = DateTime.UtcNow;
  1338. }
  1339. else
  1340. {
  1341. minEndDate = DateTime.UtcNow;
  1342. }
  1343. }
  1344. if (minEndDate.HasValue)
  1345. {
  1346. baseQuery = baseQuery.Where(e => e.EndDate >= minEndDate);
  1347. }
  1348. if (maxEndDate.HasValue)
  1349. {
  1350. baseQuery = baseQuery.Where(e => e.EndDate <= maxEndDate);
  1351. }
  1352. if (filter.MinStartDate.HasValue)
  1353. {
  1354. baseQuery = baseQuery.Where(e => e.StartDate >= filter.MinStartDate.Value);
  1355. }
  1356. if (filter.MaxStartDate.HasValue)
  1357. {
  1358. baseQuery = baseQuery.Where(e => e.StartDate <= filter.MaxStartDate.Value);
  1359. }
  1360. if (filter.MinPremiereDate.HasValue)
  1361. {
  1362. baseQuery = baseQuery.Where(e => e.PremiereDate <= filter.MinPremiereDate.Value);
  1363. }
  1364. if (filter.MaxPremiereDate.HasValue)
  1365. {
  1366. baseQuery = baseQuery.Where(e => e.PremiereDate <= filter.MaxPremiereDate.Value);
  1367. }
  1368. if (filter.TrailerTypes.Length > 0)
  1369. {
  1370. var trailerTypes = filter.TrailerTypes.Select(e => (int)e).ToArray();
  1371. baseQuery = baseQuery.Where(e => trailerTypes.Any(f => e.TrailerTypes!.Any(w => w.Id == f)));
  1372. }
  1373. if (filter.IsAiring.HasValue)
  1374. {
  1375. if (filter.IsAiring.Value)
  1376. {
  1377. baseQuery = baseQuery.Where(e => e.StartDate <= now && e.EndDate >= now);
  1378. }
  1379. else
  1380. {
  1381. baseQuery = baseQuery.Where(e => e.StartDate > now && e.EndDate < now);
  1382. }
  1383. }
  1384. if (filter.PersonIds.Length > 0)
  1385. {
  1386. baseQuery = baseQuery
  1387. .Where(e =>
  1388. context.PeopleBaseItemMap.Where(w => context.BaseItems.Where(r => filter.PersonIds.Contains(r.Id)).Any(f => f.Name == w.People.Name))
  1389. .Any(f => f.ItemId == e.Id));
  1390. }
  1391. if (!string.IsNullOrWhiteSpace(filter.Person))
  1392. {
  1393. baseQuery = baseQuery.Where(e => e.Peoples!.Any(f => f.People.Name == filter.Person));
  1394. }
  1395. if (!string.IsNullOrWhiteSpace(filter.MinSortName))
  1396. {
  1397. // this does not makes sense.
  1398. // baseQuery = baseQuery.Where(e => e.SortName >= query.MinSortName);
  1399. // whereClauses.Add("SortName>=@MinSortName");
  1400. // statement?.TryBind("@MinSortName", query.MinSortName);
  1401. }
  1402. if (!string.IsNullOrWhiteSpace(filter.ExternalSeriesId))
  1403. {
  1404. baseQuery = baseQuery.Where(e => e.ExternalSeriesId == filter.ExternalSeriesId);
  1405. }
  1406. if (!string.IsNullOrWhiteSpace(filter.ExternalId))
  1407. {
  1408. baseQuery = baseQuery.Where(e => e.ExternalId == filter.ExternalId);
  1409. }
  1410. if (!string.IsNullOrWhiteSpace(filter.Name))
  1411. {
  1412. var cleanName = GetCleanValue(filter.Name);
  1413. baseQuery = baseQuery.Where(e => e.CleanName == cleanName);
  1414. }
  1415. // These are the same, for now
  1416. var nameContains = filter.NameContains;
  1417. if (!string.IsNullOrWhiteSpace(nameContains))
  1418. {
  1419. baseQuery = baseQuery.Where(e =>
  1420. e.CleanName!.Contains(nameContains)
  1421. || e.OriginalTitle!.ToLower().Contains(nameContains!));
  1422. }
  1423. if (!string.IsNullOrWhiteSpace(filter.NameStartsWith))
  1424. {
  1425. baseQuery = baseQuery.Where(e => e.SortName!.StartsWith(filter.NameStartsWith) || e.Name!.StartsWith(filter.NameStartsWith));
  1426. }
  1427. if (!string.IsNullOrWhiteSpace(filter.NameStartsWithOrGreater))
  1428. {
  1429. // i hate this
  1430. baseQuery = baseQuery.Where(e => e.SortName!.FirstOrDefault() > filter.NameStartsWithOrGreater[0] || e.Name!.FirstOrDefault() > filter.NameStartsWithOrGreater[0]);
  1431. }
  1432. if (!string.IsNullOrWhiteSpace(filter.NameLessThan))
  1433. {
  1434. // i hate this
  1435. baseQuery = baseQuery.Where(e => e.SortName!.FirstOrDefault() < filter.NameLessThan[0] || e.Name!.FirstOrDefault() < filter.NameLessThan[0]);
  1436. }
  1437. if (filter.ImageTypes.Length > 0)
  1438. {
  1439. var imgTypes = filter.ImageTypes.Select(e => (ImageInfoImageType)e).ToArray();
  1440. baseQuery = baseQuery.Where(e => imgTypes.Any(f => e.Images!.Any(w => w.ImageType == f)));
  1441. }
  1442. if (filter.IsLiked.HasValue)
  1443. {
  1444. baseQuery = baseQuery
  1445. .Where(e => e.UserData!.FirstOrDefault(f => f.UserId == filter.User!.Id)!.Rating >= UserItemData.MinLikeValue);
  1446. }
  1447. if (filter.IsFavoriteOrLiked.HasValue)
  1448. {
  1449. baseQuery = baseQuery
  1450. .Where(e => e.UserData!.FirstOrDefault(f => f.UserId == filter.User!.Id)!.IsFavorite == filter.IsFavoriteOrLiked);
  1451. }
  1452. if (filter.IsFavorite.HasValue)
  1453. {
  1454. baseQuery = baseQuery
  1455. .Where(e => e.UserData!.FirstOrDefault(f => f.UserId == filter.User!.Id)!.IsFavorite == filter.IsFavorite);
  1456. }
  1457. if (filter.IsPlayed.HasValue)
  1458. {
  1459. // We should probably figure this out for all folders, but for right now, this is the only place where we need it
  1460. if (filter.IncludeItemTypes.Length == 1 && filter.IncludeItemTypes[0] == BaseItemKind.Series)
  1461. {
  1462. baseQuery = baseQuery.Where(e => context.BaseItems
  1463. .Where(e => e.IsFolder == false && e.IsVirtualItem == false)
  1464. .Where(f => f.UserData!.FirstOrDefault(e => e.UserId == filter.User!.Id && e.Played)!.Played)
  1465. .Any(f => f.SeriesPresentationUniqueKey == e.PresentationUniqueKey) == filter.IsPlayed);
  1466. }
  1467. else
  1468. {
  1469. baseQuery = baseQuery
  1470. .Select(e => new
  1471. {
  1472. IsPlayed = e.UserData!.Where(f => f.UserId == filter.User!.Id).Select(f => (bool?)f.Played).FirstOrDefault() ?? false,
  1473. Item = e
  1474. })
  1475. .Where(e => e.IsPlayed == filter.IsPlayed)
  1476. .Select(f => f.Item);
  1477. }
  1478. }
  1479. if (filter.IsResumable.HasValue)
  1480. {
  1481. if (filter.IsResumable.Value)
  1482. {
  1483. baseQuery = baseQuery
  1484. .Where(e => e.UserData!.FirstOrDefault(f => f.UserId == filter.User!.Id)!.PlaybackPositionTicks > 0);
  1485. }
  1486. else
  1487. {
  1488. baseQuery = baseQuery
  1489. .Where(e => e.UserData!.FirstOrDefault(f => f.UserId == filter.User!.Id)!.PlaybackPositionTicks == 0);
  1490. }
  1491. }
  1492. if (filter.ArtistIds.Length > 0)
  1493. {
  1494. baseQuery = baseQuery
  1495. .Where(e => e.ItemValues!.Any(f => f.ItemValue.Type <= ItemValueType.Artist && filter.ArtistIds.Contains(f.ItemId)));
  1496. }
  1497. if (filter.AlbumArtistIds.Length > 0)
  1498. {
  1499. baseQuery = baseQuery
  1500. .Where(e => e.ItemValues!.Any(f => f.ItemValue.Type == ItemValueType.Artist && filter.AlbumArtistIds.Contains(f.ItemId)));
  1501. }
  1502. if (filter.ContributingArtistIds.Length > 0)
  1503. {
  1504. baseQuery = baseQuery
  1505. .Where(e => e.ItemValues!.Any(f => f.ItemValue.Type == ItemValueType.Artist && filter.ContributingArtistIds.Contains(f.ItemId)));
  1506. }
  1507. if (filter.AlbumIds.Length > 0)
  1508. {
  1509. baseQuery = baseQuery.Where(e => context.BaseItems.Where(f => filter.AlbumIds.Contains(f.Id)).Any(f => f.Name == e.Album));
  1510. }
  1511. if (filter.ExcludeArtistIds.Length > 0)
  1512. {
  1513. baseQuery = baseQuery
  1514. .Where(e => !e.ItemValues!.Any(f => f.ItemValue.Type == ItemValueType.Artist && filter.ExcludeArtistIds.Contains(f.ItemId)));
  1515. }
  1516. if (filter.GenreIds.Count > 0)
  1517. {
  1518. baseQuery = baseQuery
  1519. .Where(e => e.ItemValues!.Any(f => f.ItemValue.Type == ItemValueType.Genre && filter.GenreIds.Contains(f.ItemId)));
  1520. }
  1521. if (filter.Genres.Count > 0)
  1522. {
  1523. var cleanGenres = filter.Genres.Select(e => GetCleanValue(e)).ToArray();
  1524. baseQuery = baseQuery
  1525. .Where(e => e.ItemValues!.Any(f => f.ItemValue.Type == ItemValueType.Genre && cleanGenres.Contains(f.ItemValue.CleanValue)));
  1526. }
  1527. if (tags.Count > 0)
  1528. {
  1529. var cleanValues = tags.Select(e => GetCleanValue(e)).ToArray();
  1530. baseQuery = baseQuery
  1531. .Where(e => e.ItemValues!.Any(f => f.ItemValue.Type == ItemValueType.Tags && cleanValues.Contains(f.ItemValue.CleanValue)));
  1532. }
  1533. if (excludeTags.Count > 0)
  1534. {
  1535. var cleanValues = excludeTags.Select(e => GetCleanValue(e)).ToArray();
  1536. baseQuery = baseQuery
  1537. .Where(e => !e.ItemValues!.Any(f => f.ItemValue.Type == ItemValueType.Tags && cleanValues.Contains(f.ItemValue.CleanValue)));
  1538. }
  1539. if (filter.StudioIds.Length > 0)
  1540. {
  1541. baseQuery = baseQuery
  1542. .Where(e => e.ItemValues!.Any(f => f.ItemValue.Type == ItemValueType.Studios && filter.StudioIds.Contains(f.ItemId)));
  1543. }
  1544. if (filter.OfficialRatings.Length > 0)
  1545. {
  1546. baseQuery = baseQuery
  1547. .Where(e => filter.OfficialRatings.Contains(e.OfficialRating));
  1548. }
  1549. Expression<Func<BaseItemEntity, bool>>? minParentalRatingFilter = null;
  1550. if (filter.MinParentalRating != null)
  1551. {
  1552. var min = filter.MinParentalRating;
  1553. minParentalRatingFilter = e => e.InheritedParentalRatingValue >= min.Score || e.InheritedParentalRatingValue == null;
  1554. if (min.SubScore != null)
  1555. {
  1556. minParentalRatingFilter = minParentalRatingFilter.And(e => e.InheritedParentalRatingValue >= min.SubScore || e.InheritedParentalRatingValue == null);
  1557. }
  1558. }
  1559. Expression<Func<BaseItemEntity, bool>>? maxParentalRatingFilter = null;
  1560. if (filter.MaxParentalRating != null)
  1561. {
  1562. var max = filter.MaxParentalRating;
  1563. maxParentalRatingFilter = e => e.InheritedParentalRatingValue <= max.Score || e.InheritedParentalRatingValue == null;
  1564. if (max.SubScore != null)
  1565. {
  1566. maxParentalRatingFilter = maxParentalRatingFilter.And(e => e.InheritedParentalRatingValue <= max.SubScore || e.InheritedParentalRatingValue == null);
  1567. }
  1568. }
  1569. if (filter.HasParentalRating ?? false)
  1570. {
  1571. if (minParentalRatingFilter != null)
  1572. {
  1573. baseQuery = baseQuery.Where(minParentalRatingFilter);
  1574. }
  1575. if (maxParentalRatingFilter != null)
  1576. {
  1577. baseQuery = baseQuery.Where(maxParentalRatingFilter);
  1578. }
  1579. }
  1580. else if (filter.BlockUnratedItems.Length > 0)
  1581. {
  1582. var unratedItemTypes = filter.BlockUnratedItems.Select(f => f.ToString()).ToArray();
  1583. Expression<Func<BaseItemEntity, bool>> unratedItemFilter = e => e.InheritedParentalRatingValue != null || !unratedItemTypes.Contains(e.UnratedType);
  1584. if (minParentalRatingFilter != null && maxParentalRatingFilter != null)
  1585. {
  1586. baseQuery = baseQuery.Where(unratedItemFilter.And(minParentalRatingFilter.And(maxParentalRatingFilter)));
  1587. }
  1588. else if (minParentalRatingFilter != null)
  1589. {
  1590. baseQuery = baseQuery.Where(unratedItemFilter.And(minParentalRatingFilter));
  1591. }
  1592. else if (maxParentalRatingFilter != null)
  1593. {
  1594. baseQuery = baseQuery.Where(unratedItemFilter.And(maxParentalRatingFilter));
  1595. }
  1596. else
  1597. {
  1598. baseQuery = baseQuery.Where(unratedItemFilter);
  1599. }
  1600. }
  1601. else if (minParentalRatingFilter != null || maxParentalRatingFilter != null)
  1602. {
  1603. if (minParentalRatingFilter != null)
  1604. {
  1605. baseQuery = baseQuery.Where(minParentalRatingFilter);
  1606. }
  1607. if (maxParentalRatingFilter != null)
  1608. {
  1609. baseQuery = baseQuery.Where(maxParentalRatingFilter);
  1610. }
  1611. }
  1612. else if (!filter.HasParentalRating ?? false)
  1613. {
  1614. baseQuery = baseQuery
  1615. .Where(e => e.InheritedParentalRatingValue == null);
  1616. }
  1617. if (filter.HasOfficialRating.HasValue)
  1618. {
  1619. if (filter.HasOfficialRating.Value)
  1620. {
  1621. baseQuery = baseQuery
  1622. .Where(e => e.OfficialRating != null && e.OfficialRating != string.Empty);
  1623. }
  1624. else
  1625. {
  1626. baseQuery = baseQuery
  1627. .Where(e => e.OfficialRating == null || e.OfficialRating == string.Empty);
  1628. }
  1629. }
  1630. if (filter.HasOverview.HasValue)
  1631. {
  1632. if (filter.HasOverview.Value)
  1633. {
  1634. baseQuery = baseQuery
  1635. .Where(e => e.Overview != null && e.Overview != string.Empty);
  1636. }
  1637. else
  1638. {
  1639. baseQuery = baseQuery
  1640. .Where(e => e.Overview == null || e.Overview == string.Empty);
  1641. }
  1642. }
  1643. if (filter.HasOwnerId.HasValue)
  1644. {
  1645. if (filter.HasOwnerId.Value)
  1646. {
  1647. baseQuery = baseQuery
  1648. .Where(e => e.OwnerId != null);
  1649. }
  1650. else
  1651. {
  1652. baseQuery = baseQuery
  1653. .Where(e => e.OwnerId == null);
  1654. }
  1655. }
  1656. if (!string.IsNullOrWhiteSpace(filter.HasNoAudioTrackWithLanguage))
  1657. {
  1658. baseQuery = baseQuery
  1659. .Where(e => !e.MediaStreams!.Any(f => f.StreamType == MediaStreamTypeEntity.Audio && f.Language == filter.HasNoAudioTrackWithLanguage));
  1660. }
  1661. if (!string.IsNullOrWhiteSpace(filter.HasNoInternalSubtitleTrackWithLanguage))
  1662. {
  1663. baseQuery = baseQuery
  1664. .Where(e => !e.MediaStreams!.Any(f => f.StreamType == MediaStreamTypeEntity.Subtitle && !f.IsExternal && f.Language == filter.HasNoInternalSubtitleTrackWithLanguage));
  1665. }
  1666. if (!string.IsNullOrWhiteSpace(filter.HasNoExternalSubtitleTrackWithLanguage))
  1667. {
  1668. baseQuery = baseQuery
  1669. .Where(e => !e.MediaStreams!.Any(f => f.StreamType == MediaStreamTypeEntity.Subtitle && f.IsExternal && f.Language == filter.HasNoExternalSubtitleTrackWithLanguage));
  1670. }
  1671. if (!string.IsNullOrWhiteSpace(filter.HasNoSubtitleTrackWithLanguage))
  1672. {
  1673. baseQuery = baseQuery
  1674. .Where(e => !e.MediaStreams!.Any(f => f.StreamType == MediaStreamTypeEntity.Subtitle && f.Language == filter.HasNoSubtitleTrackWithLanguage));
  1675. }
  1676. if (filter.HasSubtitles.HasValue)
  1677. {
  1678. baseQuery = baseQuery
  1679. .Where(e => e.MediaStreams!.Any(f => f.StreamType == MediaStreamTypeEntity.Subtitle) == filter.HasSubtitles.Value);
  1680. }
  1681. if (filter.HasChapterImages.HasValue)
  1682. {
  1683. baseQuery = baseQuery
  1684. .Where(e => e.Chapters!.Any(f => f.ImagePath != null) == filter.HasChapterImages.Value);
  1685. }
  1686. if (filter.HasDeadParentId.HasValue && filter.HasDeadParentId.Value)
  1687. {
  1688. baseQuery = baseQuery
  1689. .Where(e => e.ParentId.HasValue && !context.BaseItems.Any(f => f.Id == e.ParentId.Value));
  1690. }
  1691. if (filter.IsDeadArtist.HasValue && filter.IsDeadArtist.Value)
  1692. {
  1693. baseQuery = baseQuery
  1694. .Where(e => !context.ItemValues.Where(f => _getAllArtistsValueTypes.Contains(f.Type)).Any(f => f.Value == e.Name));
  1695. }
  1696. if (filter.IsDeadStudio.HasValue && filter.IsDeadStudio.Value)
  1697. {
  1698. baseQuery = baseQuery
  1699. .Where(e => !context.ItemValues.Where(f => _getStudiosValueTypes.Contains(f.Type)).Any(f => f.Value == e.Name));
  1700. }
  1701. if (filter.IsDeadGenre.HasValue && filter.IsDeadGenre.Value)
  1702. {
  1703. baseQuery = baseQuery
  1704. .Where(e => !context.ItemValues.Where(f => _getGenreValueTypes.Contains(f.Type)).Any(f => f.Value == e.Name));
  1705. }
  1706. if (filter.IsDeadPerson.HasValue && filter.IsDeadPerson.Value)
  1707. {
  1708. baseQuery = baseQuery
  1709. .Where(e => !context.Peoples.Any(f => f.Name == e.Name));
  1710. }
  1711. if (filter.Years.Length == 1)
  1712. {
  1713. baseQuery = baseQuery
  1714. .Where(e => e.ProductionYear == filter.Years[0]);
  1715. }
  1716. else if (filter.Years.Length > 1)
  1717. {
  1718. baseQuery = baseQuery
  1719. .Where(e => filter.Years.Any(f => f == e.ProductionYear));
  1720. }
  1721. var isVirtualItem = filter.IsVirtualItem ?? filter.IsMissing;
  1722. if (isVirtualItem.HasValue)
  1723. {
  1724. baseQuery = baseQuery
  1725. .Where(e => e.IsVirtualItem == isVirtualItem.Value);
  1726. }
  1727. if (filter.IsSpecialSeason.HasValue)
  1728. {
  1729. if (filter.IsSpecialSeason.Value)
  1730. {
  1731. baseQuery = baseQuery
  1732. .Where(e => e.IndexNumber == 0);
  1733. }
  1734. else
  1735. {
  1736. baseQuery = baseQuery
  1737. .Where(e => e.IndexNumber != 0);
  1738. }
  1739. }
  1740. if (filter.IsUnaired.HasValue)
  1741. {
  1742. if (filter.IsUnaired.Value)
  1743. {
  1744. baseQuery = baseQuery
  1745. .Where(e => e.PremiereDate >= now);
  1746. }
  1747. else
  1748. {
  1749. baseQuery = baseQuery
  1750. .Where(e => e.PremiereDate < now);
  1751. }
  1752. }
  1753. if (filter.MediaTypes.Length > 0)
  1754. {
  1755. var mediaTypes = filter.MediaTypes.Select(f => f.ToString()).ToArray();
  1756. baseQuery = baseQuery
  1757. .Where(e => mediaTypes.Contains(e.MediaType));
  1758. }
  1759. if (filter.ItemIds.Length > 0)
  1760. {
  1761. baseQuery = baseQuery
  1762. .Where(e => filter.ItemIds.Contains(e.Id));
  1763. }
  1764. if (filter.ExcludeItemIds.Length > 0)
  1765. {
  1766. baseQuery = baseQuery
  1767. .Where(e => !filter.ItemIds.Contains(e.Id));
  1768. }
  1769. if (filter.ExcludeProviderIds is not null && filter.ExcludeProviderIds.Count > 0)
  1770. {
  1771. baseQuery = baseQuery.Where(e => !e.Provider!.All(f => !filter.ExcludeProviderIds.All(w => f.ProviderId == w.Key && f.ProviderValue == w.Value)));
  1772. }
  1773. if (filter.HasAnyProviderId is not null && filter.HasAnyProviderId.Count > 0)
  1774. {
  1775. baseQuery = baseQuery.Where(e => e.Provider!.Any(f => !filter.HasAnyProviderId.Any(w => f.ProviderId == w.Key && f.ProviderValue == w.Value)));
  1776. }
  1777. if (filter.HasImdbId.HasValue)
  1778. {
  1779. baseQuery = baseQuery.Where(e => e.Provider!.Any(f => f.ProviderId == "imdb"));
  1780. }
  1781. if (filter.HasTmdbId.HasValue)
  1782. {
  1783. baseQuery = baseQuery.Where(e => e.Provider!.Any(f => f.ProviderId == "tmdb"));
  1784. }
  1785. if (filter.HasTvdbId.HasValue)
  1786. {
  1787. baseQuery = baseQuery.Where(e => e.Provider!.Any(f => f.ProviderId == "tvdb"));
  1788. }
  1789. var queryTopParentIds = filter.TopParentIds;
  1790. if (queryTopParentIds.Length > 0)
  1791. {
  1792. var includedItemByNameTypes = GetItemByNameTypesInQuery(filter);
  1793. var enableItemsByName = (filter.IncludeItemsByName ?? false) && includedItemByNameTypes.Count > 0;
  1794. if (enableItemsByName && includedItemByNameTypes.Count > 0)
  1795. {
  1796. baseQuery = baseQuery.Where(e => includedItemByNameTypes.Contains(e.Type) || queryTopParentIds.Any(w => w == e.TopParentId!.Value));
  1797. }
  1798. else
  1799. {
  1800. baseQuery = baseQuery.Where(e => queryTopParentIds.Contains(e.TopParentId!.Value));
  1801. }
  1802. }
  1803. if (filter.AncestorIds.Length > 0)
  1804. {
  1805. baseQuery = baseQuery.Where(e => e.Children!.Any(f => filter.AncestorIds.Contains(f.ParentItemId)));
  1806. }
  1807. if (!string.IsNullOrWhiteSpace(filter.AncestorWithPresentationUniqueKey))
  1808. {
  1809. baseQuery = baseQuery
  1810. .Where(e => context.BaseItems.Where(f => f.PresentationUniqueKey == filter.AncestorWithPresentationUniqueKey).Any(f => f.Children!.Any(w => w.ItemId == e.Id)));
  1811. }
  1812. if (!string.IsNullOrWhiteSpace(filter.SeriesPresentationUniqueKey))
  1813. {
  1814. baseQuery = baseQuery
  1815. .Where(e => e.SeriesPresentationUniqueKey == filter.SeriesPresentationUniqueKey);
  1816. }
  1817. if (filter.ExcludeInheritedTags.Length > 0)
  1818. {
  1819. baseQuery = baseQuery
  1820. .Where(e => !e.ItemValues!.Where(w => w.ItemValue.Type == ItemValueType.InheritedTags)
  1821. .Any(f => filter.ExcludeInheritedTags.Contains(f.ItemValue.CleanValue)));
  1822. }
  1823. if (filter.IncludeInheritedTags.Length > 0)
  1824. {
  1825. // Episodes do not store inherit tags from their parents in the database, and the tag may be still required by the client.
  1826. // In addition to the tags for the episodes themselves, we need to manually query its parent (the season)'s tags as well.
  1827. if (includeTypes.Length == 1 && includeTypes.FirstOrDefault() is BaseItemKind.Episode)
  1828. {
  1829. baseQuery = baseQuery
  1830. .Where(e => e.ItemValues!.Where(f => f.ItemValue.Type == ItemValueType.InheritedTags)
  1831. .Any(f => filter.IncludeInheritedTags.Contains(f.ItemValue.CleanValue))
  1832. ||
  1833. (e.ParentId.HasValue && context.ItemValuesMap.Where(w => w.ItemId == e.ParentId.Value)!.Where(w => w.ItemValue.Type == ItemValueType.InheritedTags)
  1834. .Any(f => filter.IncludeInheritedTags.Contains(f.ItemValue.CleanValue))));
  1835. }
  1836. // A playlist should be accessible to its owner regardless of allowed tags.
  1837. else if (includeTypes.Length == 1 && includeTypes.FirstOrDefault() is BaseItemKind.Playlist)
  1838. {
  1839. baseQuery = baseQuery
  1840. .Where(e =>
  1841. e.Parents!
  1842. .Any(f =>
  1843. f.ParentItem.ItemValues!.Any(w => w.ItemValue.Type == ItemValueType.Tags && filter.IncludeInheritedTags.Contains(w.ItemValue.CleanValue))
  1844. || e.Data!.Contains($"OwnerUserId\":\"{filter.User!.Id:N}\"")));
  1845. // d ^^ this is stupid it hate this.
  1846. }
  1847. else
  1848. {
  1849. baseQuery = baseQuery
  1850. .Where(e => e.Parents!.Any(f => f.ParentItem.ItemValues!.Any(w => w.ItemValue.Type == ItemValueType.Tags && filter.IncludeInheritedTags.Contains(w.ItemValue.CleanValue))));
  1851. }
  1852. }
  1853. if (filter.SeriesStatuses.Length > 0)
  1854. {
  1855. var seriesStatus = filter.SeriesStatuses.Select(e => e.ToString()).ToArray();
  1856. baseQuery = baseQuery
  1857. .Where(e => seriesStatus.Any(f => e.Data!.Contains(f)));
  1858. }
  1859. if (filter.BoxSetLibraryFolders.Length > 0)
  1860. {
  1861. var boxsetFolders = filter.BoxSetLibraryFolders.Select(e => e.ToString("N", CultureInfo.InvariantCulture)).ToArray();
  1862. baseQuery = baseQuery
  1863. .Where(e => boxsetFolders.Any(f => e.Data!.Contains(f)));
  1864. }
  1865. if (filter.VideoTypes.Length > 0)
  1866. {
  1867. var videoTypeBs = filter.VideoTypes.Select(e => $"\"VideoType\":\"{e}\"");
  1868. baseQuery = baseQuery
  1869. .Where(e => videoTypeBs.Any(f => e.Data!.Contains(f)));
  1870. }
  1871. if (filter.Is3D.HasValue)
  1872. {
  1873. if (filter.Is3D.Value)
  1874. {
  1875. baseQuery = baseQuery
  1876. .Where(e => e.Data!.Contains("Video3DFormat"));
  1877. }
  1878. else
  1879. {
  1880. baseQuery = baseQuery
  1881. .Where(e => !e.Data!.Contains("Video3DFormat"));
  1882. }
  1883. }
  1884. if (filter.IsPlaceHolder.HasValue)
  1885. {
  1886. if (filter.IsPlaceHolder.Value)
  1887. {
  1888. baseQuery = baseQuery
  1889. .Where(e => e.Data!.Contains("IsPlaceHolder\":true"));
  1890. }
  1891. else
  1892. {
  1893. baseQuery = baseQuery
  1894. .Where(e => !e.Data!.Contains("IsPlaceHolder\":true"));
  1895. }
  1896. }
  1897. if (filter.HasSpecialFeature.HasValue)
  1898. {
  1899. if (filter.HasSpecialFeature.Value)
  1900. {
  1901. baseQuery = baseQuery
  1902. .Where(e => e.ExtraIds != null);
  1903. }
  1904. else
  1905. {
  1906. baseQuery = baseQuery
  1907. .Where(e => e.ExtraIds == null);
  1908. }
  1909. }
  1910. if (filter.HasTrailer.HasValue || filter.HasThemeSong.HasValue || filter.HasThemeVideo.HasValue)
  1911. {
  1912. if (filter.HasTrailer.GetValueOrDefault() || filter.HasThemeSong.GetValueOrDefault() || filter.HasThemeVideo.GetValueOrDefault())
  1913. {
  1914. baseQuery = baseQuery
  1915. .Where(e => e.ExtraIds != null);
  1916. }
  1917. else
  1918. {
  1919. baseQuery = baseQuery
  1920. .Where(e => e.ExtraIds == null);
  1921. }
  1922. }
  1923. return baseQuery;
  1924. }
  1925. }