XmppMessage.cs

using System.Threading.Tasks;
using System.Xml;
using Waher.Content.Markdown;
using Waher.Content.Xml;
using Waher.IoTGateway;
using Waher.Networking.XMPP.Server;
using Waher.Service.IoTBroker.StateMachines.Exceptions;
 
namespace Waher.Service.IoTBroker.StateMachines.Model.Actions.Outbound
{
    public class XmppMessage : XmppOperation
    {
        public XmppMessage()
            : base()
        {
        }
 
        public override string LocalName => nameof(XmppMessage);
 
        public override IStateMachineNode Create()
        {
            return new XmppMessage();
        }
 
        public override async Task Execute(EvaluationArguments Arguments)
        {
            string To = (await this.To.Evaluate(Arguments))?.ToString();
            object Content = await this.Content.Evaluate(Arguments);
            string Type = string.Empty;
            string ContentXml;
 
            if (Content is XmlNode N)
                ContentXml = N.OuterXml;
            else if (Content is string s)
            {
                s = s.Trim();
 
                if (s.StartsWith('<') && s.EndsWith('>') && XML.IsValidXml(s, true, true, true, true, false, false))
                    ContentXml = s;
                else
                {
                    int? HeaderEndPos = MarkdownDocument.HeaderEndPosition(s);
                    bool HasHeader = HeaderEndPos.HasValue && HeaderEndPos.Value > 0;
                    MarkdownSettings Settings = new MarkdownSettings(Gateway.Emoji1_24x24, HasHeader, Arguments.Variables);
                    string Markdown = await MarkdownDocument.Preprocess(s, Settings);
                    
                    ContentXml = await Gateway.GetMultiFormatChatMessageXml(Markdown, true, true);
                    Type = "chat";
                }
            }
            else if (Content is MarkdownContent MarkdownContent)
            {
                int? HeaderEndPos = MarkdownDocument.HeaderEndPosition(MarkdownContent.Markdown);
                bool HasHeader = HeaderEndPos.HasValue && HeaderEndPos.Value > 0;
                MarkdownSettings Settings = MarkdownContent.Settings ?? new MarkdownSettings(Gateway.Emoji1_24x24, HasHeader, Arguments.Variables);
                string Markdown = await MarkdownDocument.Preprocess(MarkdownContent.Markdown, Settings);
 
                ContentXml = await Gateway.GetMultiFormatChatMessageXml(Markdown, true, true);
                Type = "chat";
            }
            else
                throw new StateMachineException(Arguments.Machine, "Expected XML or Markdown content.");
 
            await Arguments.Legal.Server.SendMessage(Type, string.Empty,
                Arguments.EDaler.MainDomain, new XmppAddress(To), string.Empty, ContentXml);
        }
    }
}