SearchProcess.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Persistence.Filters;
using Waher.Persistence.FullTextSearch.Orders;
 
namespace Waher.Persistence.FullTextSearch.Keywords
{
    public class SearchProcess
    {
        private readonly Dictionary<ulong, ObjectReference> references = new Dictionary<ulong, ObjectReference>();
        private readonly string indexCollection;
 
        public SearchProcess(IPersistentDictionary Index, string IndexCollection)
        {
            this.Index = Index;
            this.indexCollection = IndexCollection;
            this.ReferencesByObject = new Dictionary<ulong, MatchInformation>();
            this.IsRestricted = false;
        }
 
        public IPersistentDictionary Index { get; }
 
        public Dictionary<ulong, MatchInformation> ReferencesByObject { get; }
 
        public bool IsRestricted 
        { 
            get;
            private set;
        }
 
        public Dictionary<ulong, bool> Found
        {
            get;
            private set;
        }
 
        public void IncRestricted()
        {
            if (!this.IsRestricted)
            {
                this.IsRestricted = true;
                this.Found = new Dictionary<ulong, bool>();
            }
        }
 
        public async Task<ObjectReference> TryGetObjectReference(ulong ObjectIndex, bool CanLoadFromDatabase)
        {
            if (this.references.TryGetValue(ObjectIndex, out ObjectReference Ref))
                return Ref;
 
            if (CanLoadFromDatabase)
            {
                Ref = await Database.FindFirstIgnoreRest<ObjectReference>(new FilterAnd(
                    new FilterFieldEqualTo("IndexCollection", this.indexCollection),
                    new FilterFieldEqualTo("Index", ObjectIndex)));
 
                this.references[ObjectIndex] = Ref;
            }
 
            return Ref;
        }
    }
}