DeletePubSubNode.cs

using System.Threading.Tasks;
using Waher.Content;
using Waher.Content.Text;
using Waher.IoTGateway;
using Waher.Networking.HTTP;
using Waher.Networking.XMPP.Server;
using Waher.Service.IoTBroker.PubSub;
 
namespace Waher.Service.IoTBroker.WebServices
{
    public class DeletePubSubNode : HttpSynchronousResource, IHttpPostMethod
    {
        public DeletePubSubNode()
            : base("/DeletePubSubNode")
        {
        }
 
        public override bool HandlesSubPaths => false;
        public override bool UserSessions => true;
        public bool AllowsPOST => true;
 
        public async Task POST(HttpRequest Request, HttpResponse Response)
        {
            Gateway.AssertUserAuthenticated(Request, "Admin.Broker.XMPP.PubSub");
 
            if (!Request.HasData)
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            ContentResponse Content = await Request.DecodeDataAsync();
            if (Content.HasError || !(Content.Decoded is string NodeName))
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            PubSubNode PubSubNode = await XmppServerModule.GetPubSubNodeAsync(NodeName);
            if (PubSubNode is null)
            {
                await Response.SendResponse(new NotFoundException());
                return;
            }
 
            await XmppServerModule.PubSub.DeleteNode(string.Empty, PubSubNode, 
                new XmppAddress(PubSubNode.Domain ?? XmppServerModule.PubSub.MainDomain.Address));
 
            XmppServerModule.Instance.WebNodeStatus(NodeName, false);
 
            Response.StatusCode = 200;
            Response.StatusMessage = "OK";
            Response.ContentType = PlainTextCodec.DefaultContentType;
            await Response.Write("1");
        }
    }
}