SendPresenceSubscription.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.Networking.XMPP.Server;
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 SendPresenceSubscription : AgentXmppPostResource
    {
        public SendPresenceSubscription()
            : base("Xmpp/SendPresenceSubscription",
                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(SendPresenceSubscription).Namespace + ".JSON.SendPresenceSubscription.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(SendPresenceSubscription).Namespace + ".XML.SendPresenceSubscription.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 (!IsValidBareJID(To))
                throw new BadRequestException("Recpient must be a Bare JID.");
 
            string CustomXml = (string)Parameters["PCustomXml"]?.AssociatedObjectValue;
            string Language = (string)Parameters["PLanguage"]?.AssociatedObjectValue;
            string Id = (string)Parameters["PId"]?.AssociatedObjectValue;
 
            if (string.IsNullOrEmpty(Id))
                Id = Guid.NewGuid().ToString();
 
            if (string.IsNullOrEmpty(CustomXml))
                CustomXml = await GetApprovedLegalIDXml(User.UserName);
            else
            {
                if (!XML.IsValidXml(CustomXml, true, true, true, true, false, false))
                    throw new BadRequestException("Not valid XML.");
 
                CustomXml += await GetApprovedLegalIDXml(User.UserName);
            }
 
            Dictionary<string, object> NewItem;
            bool Result;
 
            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.RequestPresenceSubscription(To, CustomXml);
                Result = true;
 
                Networking.XMPP.RosterItem Item = Client[To];
 
                NewItem = new Dictionary<string, object>()
                {
                    { "bareJid", Item?.BareJid ?? To },
                    { "pendingSubscription", (Item?.PendingSubscription ?? PendingSubscription.Subscribe) == PendingSubscription.Subscribe },
                    { "status", Item?.State ?? SubscriptionState.None },
                    { "name", Item?.Name ?? string.Empty },
                    { "Groups", Item?.Groups ?? Array.Empty<string>() }
                };
            }
            else
            {
                PersistenceLayer PersistenceLayer = XmppServerModule.PersistenceLayer ?? new PersistenceLayer();
                IRosterItem Item = await PersistenceLayer.GetRosterItem(User.UserName, To);
 
                await PersistenceLayer.SetRosterItem(User.UserName, To,
                    Item?.Name ?? string.Empty, null, null, null);
 
                Result = await XmppServerModule.Server.Presence("subscribe", Id,
                    new XmppAddress(To),
                    new XmppAddress(User.UserName + "@" + XmppServerModule.Server.Domain),
                    Language, CustomXml, XmppServerModule.Server);
 
                Item = await PersistenceLayer.GetRosterItem(User.UserName, To);
                NewItem = new Dictionary<string, object>()
                {
                    { "bareJid", Item.BareJid.Value },
                    { "pendingSubscription", Item.PendingSubscription },
                    { "status", Item.Subscription },
                    { "name", Item.Name },
                    { "Groups", Item.Groups }
                };
            }
 
            await Response.Return(new NamedDictionary<string, object>("PresenceSubscriptionResult", AgentNamespace)
            {
                { "sent", Result },
                { "id", Id },
                { "RosterItem", NewItem }
            });
        }
    }
}