IMqttData.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Networking.MQTT;
using Waher.Runtime.Language;
using Waher.Things.ControlParameters;
using Waher.Things.SensorData;
using Waher.Runtime.Inventory;
using Waher.Networking;
 
namespace Waher.Things.Mqtt.Model
{
    public enum DataProcessingResult
    {
        Incompatible,
 
        Processed,
 
        ProcessedNewMomentaryValues
    }
 
    public interface IMqttData : IProcessingSupport<MqttContent>
    {
        DateTime Timestamp { get; }
 
        MqttQualityOfService QoS { get; }
 
        MqttTopic Topic { get; }
 
        bool Retain { get; }
 
        bool IsControllable { get; }
 
        Task<DataProcessingResult> DataReported(MqttTopic Topic, MqttContent Content);
 
        Task<string> GetTypeName(Language Language);
 
        Task StartReadout(ThingReference ThingReference, ISensorReadout Request, string Prefix, bool Last);
 
        void SnifferOutput(ICommunicationLayer Output);
 
        void Information(ICommunicationLayer Output, string Info);
 
        void Add(List<Field> Fields, Field Field, ISensorReadout Request);
 
        ControlParameter[] GetControlParameters();
 
        IMqttData CreateNew(MqttTopic Topic, MqttContent Content);
    }
}