MqttData.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Networking;
using Waher.Networking.MQTT;
using Waher.Networking.Sniffers;
using Waher.Runtime.Inventory;
using Waher.Runtime.Language;
using Waher.Things.ControlParameters;
using Waher.Things.SensorData;
 
namespace Waher.Things.Mqtt.Model.Encapsulations
{
    public abstract class MqttData : IMqttData
    {
        public MqttData()
        {
            this.Topic = new MqttTopic(null, string.Empty, string.Empty, null, null);
        }
 
        public MqttData(MqttTopic Topic)
        {
            this.Topic = Topic;
        }
 
        public DateTime Timestamp { get; protected set; } = DateTime.UtcNow;
 
        public MqttQualityOfService QoS { get; protected set; } = MqttQualityOfService.AtLeastOnce;
 
        public MqttTopic Topic { get; }
 
        public bool Retain { get; protected set; }
 
        public virtual bool IsControllable => false;
 
        public abstract Task<DataProcessingResult> DataReported(MqttTopic Topic, MqttContent Content);
 
        public abstract Task<string> GetTypeName(Language Language);
 
        public abstract Task StartReadout(ThingReference ThingReference, ISensorReadout Request, string Prefix, bool Last);
 
        public abstract void SnifferOutput(ICommunicationLayer Output);
 
        public void Information(ICommunicationLayer Output, string Info)
        {
            foreach (ISniffer Sniffer in Output.Sniffers)
                Sniffer.Information(this.Topic.FullTopic + ": " + Info);
        }
 
        protected string Append(string Prefix, string Name)
        {
            if (string.IsNullOrEmpty(Prefix))
                return Name;
 
            if (Name == "Value")
                return Prefix;
            else
                return Prefix + ", " + Name;
        }
 
        public void Add(List<Field> Fields, Field Field, ISensorReadout Request)
        {
            if (Fields.Count > 50)
            {
                Request.ReportFields(false, Fields.ToArray());
                Fields.Clear();
            }
 
            Fields.Add(Field);
        }
 
        public virtual ControlParameter[] GetControlParameters()
        {
            return new ControlParameter[0];
        }
 
        public Grade Supports(MqttContent Content)
        {
            return this.DataReported(null, Content).Result != DataProcessingResult.Incompatible ? this.DefaultSupport : Grade.NotAtAll;
        }
 
        public abstract Grade DefaultSupport { get; }
 
        public abstract IMqttData CreateNew(MqttTopic Topic, MqttContent Content);
    }
}