SavePrivateXml.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
using Waher.Content;
using Waher.Networking.HTTP;
using Waher.Networking.XMPP.Server.PrivateXmlStorage;
using Waher.Persistence;
using Waher.Persistence.Filters;
using Waher.Script;
using Waher.Script.Abstraction.Elements;
using Waher.Service.IoTBroker.DataStorage;
 
namespace Waher.Service.IoTBroker.WebServices.Agent.Storage
{
    public class SavePrivateXml : AgentPostResource
    {
        public SavePrivateXml()
            : base("Storage/SavePrivateXml",
                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(SavePrivateXml).Namespace + ".JSON.SavePrivateXml.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(SavePrivateXml).Namespace + ".XML.SavePrivateXml.req");
 
        public override async Task POST(HttpRequest Request, HttpResponse Response, Dictionary<string, IElement> Parameters)
        {
            AccountUser User = AssertUserAuthenticated(Request);
 
            XmlDocument Xml = (XmlDocument)Parameters["PXml"].AssociatedObjectValue;
 
            if (Xml.DocumentElement is null)
                throw new BadRequestException("XML is empty.");
 
            string XmlStr = Xml.DocumentElement.OuterXml;
 
            PersistedElement Element = await Database.FindFirstDeleteRest<PersistedElement>(new FilterAnd(
                new FilterFieldEqualTo("Account", User.UserName),
                new FilterFieldEqualTo("Namespace", Xml.DocumentElement.NamespaceURI),
                new FilterFieldEqualTo("LocalName", Xml.DocumentElement.LocalName)));
 
            if (Element is null)
            {
                DateTime TP = DateTime.UtcNow;
 
                Element = new PersistedElement()
                {
                    Account = User.UserName,
                    Created = TP,
                    Updated = TP,
                    LocalName = Xml.DocumentElement.LocalName,
                    Namespace = Xml.DocumentElement.NamespaceURI,
                    Xml = XmlStr
                };
 
                await Database.Insert(Element);
            }
            else if (Element.Xml != XmlStr)
            {
                Element.Xml = XmlStr;
                Element.Updated = DateTime.UtcNow;
 
                await Database.Update(Element);
            }
 
            await Response.Return(new NamedDictionary<string, object>("Stored", AgentNamespace)
            {
                { "created", Element.Created },
                { "updated", Element.Updated }
            });
        }
    }
}