SendXmlMessage.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Content;
using Waher.Content.Xml;
using Waher.IoTGateway;
using Waher.Networking.HTTP;
using Waher.Networking.XMPP;
using Waher.Runtime.Inventory;
using Waher.Script;
using Waher.Script.Abstraction.Elements;
using Waher.Service.IoTBroker.DataStorage;
 
namespace Waher.Service.IoTBroker.WebServices.Agent.Xmpp
{
    public class SendXmlMessage : AgentXmppPostResource
    {
        public SendXmlMessage()
            : base("Xmpp/SendXmlMessage",
                new KeyValuePair<Type, Expression>(typeof(Dictionary<string, object>), new Expression(jsonPattern)),
                new KeyValuePair<Type, Expression>(typeof(XmlDocument), new Expression(xmlPattern)))
        {
        }
 
        private static readonly string jsonPattern = Resources.LoadResourceAsText(typeof(SendXmlMessage).Namespace + ".JSON.SendXmlMessage.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(SendXmlMessage).Namespace + ".XML.SendXmlMessage.req");
 
        public override async Task POST(HttpRequest Request, HttpResponse Response, Dictionary<string, IElement> Parameters)
        {
            AccountUser User = AssertUserAuthenticated(Request);
 
            string To = (string)Parameters["PTo"].AssociatedObjectValue;
 
            if (string.IsNullOrEmpty(To))
                throw new BadRequestException("Missing recipient JID.");
 
            if (!IsValidJID(To))
                throw new BadRequestException("Recpient must be a Bare or Full JID.");
 
            object Obj = Parameters["PXml"].AssociatedObjectValue;
            string Xml;
 
            if (Obj is string s)
            {
                if (string.IsNullOrEmpty(s))
                    throw new BadRequestException("Message is empty.");
 
                if (!XML.IsValidXml(s, false, false, true, true, false, false))
                    throw new BadRequestException("Message is not valid XML.");
 
                Xml = s;
            }
            else if (Obj is XmlDocument Doc)
                Xml = Doc.DocumentElement.OuterXml;
            else if (Obj is XmlElement E)
                Xml = E.OuterXml;
            else
                throw new BadRequestException("Message is not valid XML.");
 
            string Subject = (string)Parameters["PSubject"]?.AssociatedObjectValue;
            string Language = (string)Parameters["PLanguage"]?.AssociatedObjectValue;
            string Id = (string)Parameters["PId"]?.AssociatedObjectValue;
 
            if (string.IsNullOrEmpty(Id))
                Id = Guid.NewGuid().ToString();
 
            bool Result;
 
            if (XmppServerModule.Server is null)
            {
                XmppClient Client = Gateway.XmppClient;
 
                Result = false;
 
                if (Client is null)
                {
                    if (Types.TryGetModuleParameter("XMPP", out Obj) && Obj is XmppClient Client2)
                        Client = Client2;
                }
 
                if (Client is null)
                    throw new ServiceUnavailableException("XMPP Client not available.");
 
                await Client.SendMessage(QoSLevel.Unacknowledged, MessageType.Normal, Id, To, Xml,
                    string.Empty, string.Empty, Language, string.Empty, string.Empty, null, null);
 
                Result = true;
            }
            else
            {
                Result = await XmppServerModule.Server.SendMessage(string.Empty, Id,
                     User.Account.UserName + "@" + XmppServerModule.Server.Domain, To,
                     Language, Xml);
            }
 
            await Response.Return(new NamedDictionary<string, object>("StanzaResult", AgentNamespace)
            {
                { "sent", Result },
                { "id", Id }
            });
        }
    }
}