GetIdentity.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;
using Waher.Service.IoTBroker.Legal;
 
namespace Waher.Service.IoTBroker.WebServices.Agent.Legal
{
    public class GetIdentity : AgentPostResource
    {
        public GetIdentity()
            : base("Legal/GetIdentity",
                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(GetIdentity).Namespace + ".JSON.GetIdentity.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(GetIdentity).Namespace + ".XML.GetIdentity.req");
 
        public override bool Synchronous => false;
 
        public override async Task POST(HttpRequest Request, HttpResponse Response, Dictionary<string, IElement> Parameters)
        {
            AccountUser User = AssertUserAuthenticated(Request);
            string LegalId = (string)Parameters["PLegalId"].AssociatedObjectValue;
            int i = LegalId.IndexOf('@');
            if (i < 0)
                throw new BadRequestException("Invalid Legal ID.");
 
            string LegalDomain = LegalId.Substring(i + 1);
            string LegalNamespace = LegalComponent.NamespaceLegalIdentity(NamespaceSet.Current);
 
            if (XmppServerModule.Server is null)
            {
                XmppClient Client = Gateway.XmppClient;
 
                if (Client is null)
                {
                    if (Types.TryGetModuleParameter("XMPP", out object Obj) && Obj is XmppClient Client2)
                        Client = Client2;
                }
 
                if (Client is null)
                    throw new ServiceUnavailableException("XMPP Client not available.");
 
                await Client.SendIqGet(LegalDomain, "<getLegalIdentity id=\"" + XML.Encode(LegalId) + "\" xmlns=\"" +
                    LegalNamespace + "\"/>", async (Sender, e) =>
                    {
                        XmlElement E;
 
                        if (e.Ok && !((E = e.FirstElement) is null) && E.LocalName == "identity")
                        {
                            await Response.Return(new NamedDictionary<string, object>("IdentityResponse", AgentNamespace)
                            {
                                { "Identity", E }
                            });
                        }
                        else
                            await Response.SendResponse(ToHttpException(e.StanzaError) ?? new ServiceUnavailableException("Unable to get identity."));
 
                    }, null);
            }
            else
            {
                await XmppServerModule.Server.SendIqRequest("get",
                    User.UserName + "@" + (Gateway.Domain?.Value ?? string.Empty),
                    LegalDomain, string.Empty, "<getLegalIdentity id=\"" + XML.Encode(LegalId) + "\" xmlns=\"" +
                    LegalNamespace + "\"/>", async (Sender, e) =>
                    {
                        XmlElement E;
 
                        if (e.Ok && !((E = e.FirstElement) is null) && E.LocalName == "identity")
                        {
                            await Response.Return(new NamedDictionary<string, object>("IdentityResponse", AgentNamespace)
                            {
                                { "Identity", E }
                            });
                        }
                        else
                            await Response.SendResponse(ToHttpException(XmppClient.GetExceptionObject(e.ErrorElement)) ?? new ServiceUnavailableException("Unable to get identity."));
                        
                    }, null);
            }
        }
 
    }
}