ObjectIdCursor.cs

using System;
using System.Collections;
using System.Threading.Tasks;
using Waher.Persistence.Serialization;
 
namespace Waher.Persistence.Files.Searching
{
    internal class ObjectIdCursor<T> : ICursor<T>
    {
        private readonly ICursor<T> cursor;
        private readonly string objectIdFieldName;
 
        public ObjectIdCursor(ICursor<T> Cursor, string ObjectIdFieldName)
        {
            this.cursor = Cursor;
            this.objectIdFieldName = ObjectIdFieldName;
        }
 
        public T Current => this.cursor.Current;
 
        public IObjectSerializer CurrentSerializer => this.cursor.CurrentSerializer;
 
        public bool CurrentTypeCompatible => this.cursor.CurrentTypeCompatible;
 
        public Guid CurrentObjectId => this.cursor.CurrentObjectId;
 
        public void Dispose()
        {
        }
 
        Task<bool> IAsyncEnumerator.MoveNextAsync() => this.MoveNextAsyncLocked();
 
        object IEnumerator.Current => this.Current;
 
        public bool MoveNext() => this.MoveNextAsyncLocked().Result;
 
        public void Reset() => this.cursor.Reset();
 
        public Task<bool> MoveNextAsyncLocked()
        {
            return this.cursor.MoveNextAsyncLocked();
        }
 
        public Task<bool> MovePreviousAsyncLocked()
        {
            return this.cursor.MovePreviousAsyncLocked();
        }
 
        public bool SameSortOrder(string[] ConstantFields, string[] SortOrder)
        {
            return (SortOrder.Length == 1 && SortOrder[0] == this.objectIdFieldName);
        }
 
        public bool ReverseSortOrder(string[] ConstantFields, string[] SortOrder)
        {
            return (SortOrder.Length == 1 && SortOrder[0] == "-" + this.objectIdFieldName);
        }
 
        public Task ContinueAfterLocked(T LastItem)
        {
            return this.cursor.ContinueAfterLocked(LastItem);
        }
 
        public Task ContinueBeforeLocked(T LastItem)
        {
            return this.cursor.ContinueBeforeLocked(LastItem);
        }
    }
}