using System; using System.Collections; using System.Collections.Generic; using System.Linq; using System.Reflection; using System.Text.RegularExpressions; using System.Xml.XPath; using Examine; using Examine.Search; using Umbraco.Core; using Umbraco.Core.Models.PublishedContent; using Umbraco.Core.Services; using Umbraco.Core.Xml; using Umbraco.Examine; using Umbraco.Web.PublishedCache; namespace Umbraco.Web { using Examine = global::Examine; /// /// A class used to query for published content, media items /// public class PublishedContentQuery : IPublishedContentQuery { private readonly IPublishedContentCache _contentCache; private readonly IPublishedMediaCache _mediaCache; private readonly IVariationContextAccessor _variationContextAccessor; /// /// Constructor used to return results from the caches /// /// /// /// public PublishedContentQuery(IPublishedContentCache contentCache, IPublishedMediaCache mediaCache, IVariationContextAccessor variationContextAccessor) { _contentCache = contentCache ?? throw new ArgumentNullException(nameof(contentCache)); _mediaCache = mediaCache ?? throw new ArgumentNullException(nameof(mediaCache)); _variationContextAccessor = variationContextAccessor ?? throw new ArgumentNullException(nameof(variationContextAccessor)); } #region Content public IPublishedContent Content(int id) { return ItemById(id, _contentCache); } public IPublishedContent Content(Guid id) { return ItemById(id, _contentCache); } public IPublishedContent Content(Udi id) { if (!(id is GuidUdi udi)) return null; return ItemById(udi.Guid, _contentCache); } public IPublishedContent ContentSingleAtXPath(string xpath, params XPathVariable[] vars) { return ItemByXPath(xpath, vars, _contentCache); } public IEnumerable Content(IEnumerable ids) { return ItemsByIds(_contentCache, ids); } public IEnumerable Content(IEnumerable ids) { return ItemsByIds(_contentCache, ids); } public IEnumerable ContentAtXPath(string xpath, params XPathVariable[] vars) { return ItemsByXPath(xpath, vars, _contentCache); } public IEnumerable ContentAtXPath(XPathExpression xpath, params XPathVariable[] vars) { return ItemsByXPath(xpath, vars, _contentCache); } public IEnumerable ContentAtRoot() { return ItemsAtRoot(_contentCache); } #endregion #region Media public IPublishedContent Media(int id) { return ItemById(id, _mediaCache); } public IPublishedContent Media(Guid id) { return ItemById(id, _mediaCache); } public IPublishedContent Media(Udi id) { if (!(id is GuidUdi udi)) return null; return ItemById(udi.Guid, _mediaCache); } public IEnumerable Media(IEnumerable ids) { return ItemsByIds(_mediaCache, ids); } public IEnumerable Media(IEnumerable ids) { return ItemsByIds(_mediaCache, ids); } public IEnumerable MediaAtRoot() { return ItemsAtRoot(_mediaCache); } #endregion #region Used by Content/Media private static IPublishedContent ItemById(int id, IPublishedCache cache) { var doc = cache.GetById(id); return doc; } private static IPublishedContent ItemById(Guid id, IPublishedCache cache) { var doc = cache.GetById(id); return doc; } private static IPublishedContent ItemByXPath(string xpath, XPathVariable[] vars, IPublishedCache cache) { var doc = cache.GetSingleByXPath(xpath, vars); return doc; } //NOTE: Not used? //private IPublishedContent ItemByXPath(XPathExpression xpath, XPathVariable[] vars, IPublishedCache cache) //{ // var doc = cache.GetSingleByXPath(xpath, vars); // return doc; //} private static IEnumerable ItemsByIds(IPublishedCache cache, IEnumerable ids) { return ids.Select(eachId => ItemById(eachId, cache)).WhereNotNull(); } private IEnumerable ItemsByIds(IPublishedCache cache, IEnumerable ids) { return ids.Select(eachId => ItemById(eachId, cache)).WhereNotNull(); } private static IEnumerable ItemsByXPath(string xpath, XPathVariable[] vars, IPublishedCache cache) { var doc = cache.GetByXPath(xpath, vars); return doc; } private static IEnumerable ItemsByXPath(XPathExpression xpath, XPathVariable[] vars, IPublishedCache cache) { var doc = cache.GetByXPath(xpath, vars); return doc; } private static IEnumerable ItemsAtRoot(IPublishedCache cache) { return cache.GetAtRoot(); } #endregion #region Search /// public IEnumerable Search(string term, string culture = null, string indexName = null) { return Search(term, 0, 0, out _, culture, indexName); } /// public IEnumerable Search(string term, int skip, int take, out long totalRecords, string culture = null, string indexName = null) { indexName = string.IsNullOrEmpty(indexName) ? Constants.UmbracoIndexes.ExternalIndexName : indexName; if (!ExamineManager.Instance.TryGetIndex(indexName, out var index) || !(index is IUmbracoIndex umbIndex)) throw new InvalidOperationException($"No index found by name {indexName} or is not of type {typeof(IUmbracoIndex)}"); var searcher = umbIndex.GetSearcher(); // default to max 500 results var count = skip == 0 && take == 0 ? 500 : skip + take; //set this to the specific culture or to the culture in the request culture = culture ?? _variationContextAccessor.VariationContext.Culture; ISearchResults results; if (culture.IsNullOrWhiteSpace()) { results = searcher.Search(term, count); } else { //get all index fields suffixed with the culture name supplied var cultureFields = new List(); var fields = umbIndex.GetFields(); var qry = searcher.CreateQuery().Field(UmbracoContentIndex.VariesByCultureFieldName, "y"); //must vary by culture // ReSharper disable once LoopCanBeConvertedToQuery foreach (var field in fields) { var match = CultureIsoCodeFieldName.Match(field); if (match.Success && match.Groups.Count == 2 && culture.InvariantEquals(match.Groups[1].Value)) cultureFields.Add(field); } qry = qry.And().ManagedQuery(term, cultureFields.ToArray()); results = qry.Execute(count); } totalRecords = results.TotalItemCount; return new CultureContextualSearchResults(results.ToPublishedSearchResults(_contentCache), _variationContextAccessor, culture); } /// public IEnumerable Search(IQueryExecutor query) { return Search(query, 0, 0, out _); } /// public IEnumerable Search(IQueryExecutor query, int skip, int take, out long totalRecords) { var results = skip == 0 && take == 0 ? query.Execute() : query.Execute(maxResults: skip + take); totalRecords = results.TotalItemCount; return results.ToPublishedSearchResults(_contentCache); } /// /// This is used to contextualize the values in the search results when enumerating over them so that the correct culture values are used /// private class CultureContextualSearchResults : IEnumerable { private readonly IEnumerable _wrapped; private readonly IVariationContextAccessor _variationContextAccessor; private readonly string _culture; public CultureContextualSearchResults(IEnumerable wrapped, IVariationContextAccessor variationContextAccessor, string culture) { _wrapped = wrapped; _variationContextAccessor = variationContextAccessor; _culture = culture; } public IEnumerator GetEnumerator() { //We need to change the current culture to what is requested and then change it back var originalContext = _variationContextAccessor.VariationContext; if (!_culture.IsNullOrWhiteSpace() && !_culture.InvariantEquals(originalContext.Culture)) _variationContextAccessor.VariationContext = new VariationContext(_culture); //now the IPublishedContent returned will be contextualized to the culture specified and will be reset when the enumerator is disposed return new CultureContextualSearchResultsEnumerator(_wrapped.GetEnumerator(), _variationContextAccessor, originalContext); } IEnumerator IEnumerable.GetEnumerator() { return GetEnumerator(); } /// /// Resets the variation context when this is disposed /// private class CultureContextualSearchResultsEnumerator : IEnumerator { private readonly IEnumerator _wrapped; private readonly IVariationContextAccessor _variationContextAccessor; private readonly VariationContext _originalContext; public CultureContextualSearchResultsEnumerator(IEnumerator wrapped, IVariationContextAccessor variationContextAccessor, VariationContext originalContext) { _wrapped = wrapped; _variationContextAccessor = variationContextAccessor; _originalContext = originalContext; } public void Dispose() { _wrapped.Dispose(); //reset _variationContextAccessor.VariationContext = _originalContext; } public bool MoveNext() { return _wrapped.MoveNext(); } public void Reset() { _wrapped.Reset(); } public PublishedSearchResult Current => _wrapped.Current; object IEnumerator.Current => Current; } } /// /// Matches a culture iso name suffix /// /// /// myFieldName_en-us will match the "en-us" /// private static readonly Regex CultureIsoCodeFieldName = new Regex("^[_\\w]+_([a-z]{2}-[a-z0-9]{2,4})$", RegexOptions.Compiled); #endregion } }