ServiceDescriptionDocument.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using System.Xml;
 
namespace Waher.Networking.UPnP
{
    public class ServiceDescriptionDocument
    {
        private readonly Dictionary<string, UPnPAction> actionsByName = new Dictionary<string, UPnPAction>();
        private readonly Dictionary<string, UPnPStateVariable> variablesByName = new Dictionary<string, UPnPStateVariable>();
        private readonly UPnPAction[] actions;
        private readonly UPnPStateVariable[] variables;
        private readonly UPnPService service;
        private readonly XmlDocument xml;
        private readonly int majorVersion;
        private readonly int minorVersion;
 
        internal ServiceDescriptionDocument(XmlDocument Xml, UPnPClient Client, UPnPService Service)
        {
            List<UPnPStateVariable> Variables = new List<UPnPStateVariable>();
            List<UPnPAction> Actions = new List<UPnPAction>();
            this.xml = Xml;
            this.service = Service;
 
            if (!(Xml.DocumentElement is null) && Xml.DocumentElement.LocalName == "scpd" &&
                Xml.DocumentElement.NamespaceURI == "urn:schemas-upnp-org:service-1-0")
            {
                foreach (XmlNode N in Xml.DocumentElement.ChildNodes)
                {
                    switch (N.LocalName)
                    {
                        case "specVersion":
                            foreach (XmlNode N2 in N.ChildNodes)
                            {
                                switch (N2.LocalName)
                                {
                                    case "major":
                                        this.majorVersion = int.Parse(N2.InnerText);
                                        break;
 
                                    case "minor":
                                        this.minorVersion = int.Parse(N2.InnerText);
                                        break;
                                }
                            }
                            break;
 
                        case "actionList":
                            foreach (XmlNode N2 in N.ChildNodes)
                            {
                                if (N2.LocalName == "action")
                                {
                                    UPnPAction Action = new UPnPAction((XmlElement)N2, this);
                                    Actions.Add(Action);
                                    this.actionsByName[Action.Name] = Action;
                                }
                            }
                            break;
 
                        case "serviceStateTable":
                            foreach (XmlNode N2 in N.ChildNodes)
                            {
                                if (N2.LocalName == "stateVariable")
                                {
                                    UPnPStateVariable Variable = new UPnPStateVariable((XmlElement)N2);
                                    Variables.Add(Variable);
                                    this.variablesByName[Variable.Name] = Variable;
                                }
                            }
                            break;
                    }
                }
            }
            else
                throw new Exception("Unrecognized file format.");
 
            this.actions = Actions.ToArray();
            this.variables = Variables.ToArray();
        }
 
        public XmlDocument Xml => this.xml;
 
        public int MajorVersion => this.majorVersion;
 
        public int MinorVersion => this.minorVersion;
 
        public UPnPAction[] Actions => this.actions;
 
        public UPnPStateVariable[] Variables => this.variables;
 
        public UPnPService Service => this.service;
 
        public UPnPAction GetAction(string Name)
        {
            if (this.actionsByName.TryGetValue(Name, out UPnPAction Action))
                return Action;
            else
                return null;
        }
 
        public UPnPStateVariable GetVariable(string Name)
        {
            if (this.variablesByName.TryGetValue(Name, out UPnPStateVariable Variable))
                return Variable;
            else
                return null;
        }
 
        public Task<KeyValuePair<object, Dictionary<string, object>>> InvokeAsync(string ActionName, int Timeout, params KeyValuePair<string, object>[] InputValues)
        {
            UPnPAction Action = this.GetAction(ActionName);
            if (Action is null)
                throw new ArgumentException("Action not found: " + ActionName, nameof(ActionName));
 
            return Action.InvokeAsync(Timeout, InputValues);
        }
 
        public Task<KeyValuePair<object, Dictionary<string, object>>> InvokeAsync(string ActionName, Dictionary<string, object> InputValues, int Timeout)
        {
            UPnPAction Action = this.GetAction(ActionName);
            if (Action is null)
                throw new ArgumentException("Action not found: " + ActionName, nameof(ActionName));
 
            return Action.InvokeAsync(InputValues, Timeout);
        }
 
    }
}