GeoSubscription.cs

using System;
using System.Text;
using System.Threading.Tasks;
using Waher.Networking.XMPP.Server;
using Waher.Runtime.Geo;
using Waher.Content.Xml;
 
namespace Waher.Service.IoTBroker.GeoSpatial
{
    public class GeoSubscription : IGeoBoundingBox
    {
        private readonly string boxId = Guid.NewGuid().ToString();
        private readonly XmppAddress from;
        private readonly GeoPosition min;
        private readonly GeoPosition max;
        private DateTime elapses;
 
        public GeoSubscription(XmppAddress From, GeoPosition Min, GeoPosition Max, DateTime Elapses)
        {
            this.from = From;
            this.min = Min;
            this.max = Max;
            this.elapses = Elapses;
        }
 
        public string BoxId => this.boxId;
 
        public XmppAddress From => this.from;
 
        public GeoPosition Min => this.min;
 
        public GeoPosition Max => this.max;
 
        public bool IncludeMin => true;
 
        public bool IncludeMax => true;
 
        public bool LongitudeWrapped => this.min.Longitude > this.max.Longitude;
 
        public DateTime Elapses
        {
            get => this.elapses;
            internal set => this.elapses = value;
        }
 
        public override bool Equals(object obj)
        {
            return
                obj is GeoSubscription Obj &&
                (this.min?.Equals(Obj.Min) ?? Obj.Min is null) &&
                (this.max?.Equals(Obj.Max) ?? Obj.Max is null);
        }
 
        public override int GetHashCode()
        {
            int Result = this.min?.GetHashCode() ?? 0;
            Result ^= Result << 5 ^ (this.max?.GetHashCode() ?? 0);
 
            return Result;
        }
 
        public bool Contains(GeoPosition Location)
        {
            return !Location.LiesOutside(this.min, this.max, false, false);
        }
 
        public bool Contains(GeoPosition Location, bool IgnoreAltitude)
        {
            return !Location.LiesOutside(this.min, this.max, false, false, IgnoreAltitude);
        }
 
        public Task ObjectAdded(PersistedGeoSpatialObjectReference Reference,
            GeoSpatialComponent Sender)
        {
            return this.SendEvent(Reference, Sender, "added");
        }
 
        public Task ObjectUpdated(PersistedGeoSpatialObjectReference Reference,
            GeoSpatialComponent Sender)
        {
            return this.SendEvent(Reference, Sender, "updated");
        }
 
        public Task ObjectRemoved(PersistedGeoSpatialObjectReference Reference,
            GeoSpatialComponent Sender)
        {
            return this.SendEvent(Reference, Sender, "removed");
        }
 
        private Task SendEvent(PersistedGeoSpatialObjectReference Reference,
            GeoSpatialComponent Sender, string EventName)
        {
            StringBuilder Xml = new StringBuilder();
 
            Xml.Append('<');
            Xml.Append(EventName);
            Xml.Append(" xmlns='");
            Xml.Append(GeoSpatialComponent.NamespaceGeoSpatialNeuroFoundationV1);
            Xml.Append("' id='");
            Xml.Append(XML.Encode(this.boxId));
            Xml.Append("'>");
 
            Reference.Serialize(Xml);
 
            Xml.Append("</");
            Xml.Append(EventName);
            Xml.Append('>');
 
            return XmppServerModule.Server.SendMessage(string.Empty, string.Empty, Sender.MainDomain,
                this.from, string.Empty, Xml.ToString());
        }
    }
}