ReferenceLoader.cs

using System;
using System.Threading.Tasks;
using Waher.Events;
using Waher.Persistence;
using Waher.Persistence.Serialization;
using Waher.Runtime.Collections;
 
namespace Waher.Service.IoTBroker.GeoSpatial
{
    internal class ReferenceLoader : IDatabaseIteration<PersistedGeoSpatialObjectReference>
    {
        private readonly GeoSpatialComponent component;
        private ChunkedList<PersistedGeoSpatialObjectReference> expired = null;
 
        public ReferenceLoader(GeoSpatialComponent Component)
        {
            this.component = Component;
        }
 
        public Task StartDatabase() => Task.CompletedTask;
 
        public async Task EndDatabase()
        {
            if (!(this.expired is null))
                await Database.Delete(this.expired);
        }
 
        public Task StartCollection(string CollectionName) => Task.CompletedTask;
 
        public Task EndCollection() => Task.CompletedTask;
 
        public Task ProcessObject(PersistedGeoSpatialObjectReference Object)
        {
            if (Object.Expires.HasValue && Object.Expires.Value <= DateTime.Now.AddMinutes(1))
            {
                this.expired ??= new ChunkedList<PersistedGeoSpatialObjectReference>();
                this.expired.Add(Object);
            }
            else
                this.component.Loaded(Object);
 
            return Task.CompletedTask;
        }
 
        public Task IncompatibleObject(object ObjectId) => Task.CompletedTask;
 
        public Task ReportException(Exception Exception)
        {
            Log.Exception(Exception);
            return Task.CompletedTask;
        }
 
    }
}