InformationQuery.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Content;
using Waher.IoTGateway;
using Waher.Networking.HTTP;
using Waher.Networking.XMPP;
using Waher.Runtime.Inventory;
using Waher.Runtime.IO;
using Waher.Script;
using Waher.Script.Abstraction.Elements;
using Waher.Service.IoTBroker.DataStorage;
 
namespace Waher.Service.IoTBroker.WebServices.Agent.Xmpp
{
    public class InformationQuery : AgentXmppPostResource
    {
        public InformationQuery()
            : base("Xmpp/InformationQuery",
                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(InformationQuery).Namespace + ".JSON.InformationQuery.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(InformationQuery).Namespace + ".XML.InformationQuery.req");
 
        public override bool Synchronous => false;
 
        public override async Task POST(HttpRequest Request, HttpResponse Response, Dictionary<string, IElement> Parameters)
        {
            AccountUser User = AssertUserAuthenticated(Request);
            string To = (string)Parameters["PTo"].AssociatedObjectValue;
            string Type = (string)Parameters["PType"].AssociatedObjectValue;
            XmlDocument Query = (XmlDocument)Parameters["PQuery"].AssociatedObjectValue;
 
            if (string.IsNullOrEmpty(To))
                throw new BadRequestException("Recipient not defined.");
 
            if (!IsValidJID(To))
                throw new BadRequestException("Invalid JID.");
 
            if (Type != "get" && Type != "set")
                throw new BadRequestException("Invalid Type.");
 
            if (Query.DocumentElement is null)
                throw new BadRequestException("Empty query.");
 
            if (XmppServerModule.Server is null)
            {
                XmppClient Client = Gateway.XmppClient;
 
                if (Client is null)
                {
                    if (Types.TryGetModuleParameter("XMPP", out XmppClient Client2))
                        Client = Client2;
                }
 
                if (Client is null)
                    throw new ServiceUnavailableException("XMPP Client not available.");
 
                await Client.SendIq(string.Empty, To, Query.DocumentElement.OuterXml, Type,
                    async (Sender, e) =>
                    {
                        NamedDictionary<string, object> Result = new NamedDictionary<string, object>("QueryResult", AgentNamespace)
                        {
                            { "ok", e.Ok },
                            { "Stanza", e.Response }
                        };
 
                        if (!e.Ok)
                        {
                            Result["errorCode"] = e.ErrorCode;
                            Result["errorText"] = e.ErrorText;
                            Result["errorType"] = e.ErrorType;
                            Result["ErrorElement"] = e.ErrorElement;
                        }
 
                        await Response.Return(Result);
                    }, null);
            }
            else
            {
                await XmppServerModule.Server.SendIqRequest(Type,
                    User.UserName + "@" + (Gateway.Domain?.Value ?? string.Empty),
                    To, string.Empty, Query.DocumentElement.OuterXml, false, async (Sender, e) =>
                    {
                        NamedDictionary<string, object> Result = new NamedDictionary<string, object>("QueryResult", AgentNamespace)
                        {
                            { "ok", e.Ok },
                            { "Stanza", e.Response }
                        };
 
                        if (!e.Ok)
                        {
                            Result["errorCode"] = e.ErrorCode;
                            Result["errorText"] = e.ErrorText;
                            Result["errorType"] = e.ErrorType;
                            Result["ErrorElement"] = e.ErrorElement;
                        }
 
                        await Response.Return(Result);
                    }, null);
            }
        }
 
    }
}