SendSubscriptionDeclined.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.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 SendSubscriptionDeclined : AgentXmppPostResource
    {
        public SendSubscriptionDeclined()
            : base("Xmpp/SendSubscriptionDeclined",
                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(SendSubscriptionDeclined).Namespace + ".JSON.SendSubscriptionDeclined.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(SendSubscriptionDeclined).Namespace + ".XML.SendSubscriptionDeclined.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 Id = (string)Parameters["PId"]?.AssociatedObjectValue;
 
            if (string.IsNullOrEmpty(Id))
                Id = Guid.NewGuid().ToString();
 
            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.");
 
                Networking.XMPP.Events.PresenceEventArgs e = Client.GetSubscriptionRequest(To)
                    ?? throw new NotFoundException("Presence subscription request not found.");
 
                Id = e.Id;
 
                await e.Decline();
                Result = true;
            }
            else
            {
                Result = await XmppServerModule.Server.Presence("unsubscribed", Id,
                    new XmppAddress(To),
                    new XmppAddress(User.UserName + "@" + XmppServerModule.Server.Domain),
                    string.Empty, string.Empty, XmppServerModule.Server);
            }
 
            await Response.Return(new NamedDictionary<string, object>("StanzaResult", AgentNamespace)
            {
                { "sent", Result },
                { "id", Id }
            });
        }
    }
}