Base64Ncap.cs

using System;
using System.Threading.Tasks;
using Waher.Networking;
using Waher.Networking.MQTT;
using Waher.Runtime.Language;
using Waher.Things.Mqtt.Model;
using Waher.Things.Mqtt.Model.Encapsulations;
 
namespace Waher.Things.Ieee1451.Ieee1451_1_6
{
    public class Base64Ncap : Ncap
    {
        private bool firstMessage = true;
 
        public Base64Ncap()
            : base()
        {
        }
 
        public Base64Ncap(MqttTopic Topic, byte[] Value)
            : base(Topic, Value)
        {
        }
 
        public override async Task<DataProcessingResult> DataReported(MqttTopic Topic, MqttContent Content)
        {
            string s = Content.DataString;
 
            if (!Base64Data.RegEx.IsMatch(s))
                return this.firstMessage ? DataProcessingResult.Incompatible : DataProcessingResult.Processed;
 
            try
            {
                this.firstMessage = false;
                return await this.DataReported(Topic, Content, Convert.FromBase64String(s));
            }
            catch (Exception)
            {
                return DataProcessingResult.Processed;
            }
        }
 
        public override Task<string> GetTypeName(Language Language)
        {
            return Language.GetStringAsync(typeof(RootTopic), 12, "IEEE 1451.1.6 NCAP (BASE64)");
        }
 
        public override void SnifferOutput(ICommunicationLayer Output)
        {
        }
 
        public override IMqttData CreateNew(MqttTopic Topic, MqttContent Content)
        {
            IMqttData Result = new Base64Ncap(Topic, default);
            Result.DataReported(Topic, Content);
            return Result;
        }
    }
}