RegisterEventHandler.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.Script;
using Waher.Script.Abstraction.Elements;
using Waher.Service.IoTBroker.DataStorage;
 
namespace Waher.Service.IoTBroker.WebServices.Agent.Xmpp
{
    public class RegisterEventHandler : AgentXmppPostResource
    {
        public RegisterEventHandler()
            : base("Xmpp/RegisterEventHandler",
                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(PresenceProbe).Namespace + ".JSON.RegisterEventHandler.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(PresenceProbe).Namespace + ".XML.RegisterEventHandler.req");
 
        public override Task POST(HttpRequest Request, HttpResponse Response, Dictionary<string, IElement> Parameters)
        {
            AccountUser User = AssertUserAuthenticated(Request);
            string LocalName = (string)Parameters["PLocalName"]?.AssociatedObjectValue;
            string Namespace = (string)Parameters["PNamespace"]?.AssociatedObjectValue;
            string Type = (string)Parameters["PType"]?.AssociatedObjectValue;
            string Function = (string)Parameters["PFunction"]?.AssociatedObjectValue;
            string TabId = (string)Parameters["PTabId"].AssociatedObjectValue;
            string BareJid = User.UserName + "@" + (Gateway.Domain?.Value ?? string.Empty);
 
            if (string.IsNullOrEmpty(LocalName))
                throw new BadRequestException("Local Name not defined.");
 
            if (string.IsNullOrEmpty(Namespace))
                throw new BadRequestException("Namespace not defined.");
 
            PersistenceLayer.RegisterEventsTab(BareJid, Type, LocalName, Namespace, Function, TabId);
 
            return Response.Return(new NamedDictionary<string, object>("EventHandlerRegistered", AgentNamespace));
        }
    }
}