ReadyForApproval.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.Server;
using Waher.Persistence;
using Waher.Runtime.Threading;
using Waher.Script;
using Waher.Script.Abstraction.Elements;
using Waher.Service.IoTBroker.DataStorage;
using Waher.Service.IoTBroker.Legal;
using Waher.Service.IoTBroker.Legal.Identity;
 
namespace Waher.Service.IoTBroker.WebServices.Agent.Legal
{
    public class ReadyForApproval : AgentPostResource
    {
        public ReadyForApproval()
            : base("Legal/ReadyForApproval",
                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(ReadyForApproval).Namespace + ".JSON.ReadyForApproval.req");
        private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(ReadyForApproval).Namespace + ".XML.ReadyForApproval.req");
 
        public override async Task POST(HttpRequest Request, HttpResponse Response, Dictionary<string, IElement> Parameters)
        {
            AccountUser User = AssertUserAuthenticated(Request);
            CaseInsensitiveString LegalId = (string)Parameters["PLegalId"].AssociatedObjectValue;
            int i = LegalId.IndexOf('@');
            if (i < 0)
                throw new BadRequestException("Invalid Legal ID.");
 
            using (Semaphore Semaphore = await Semaphores.BeginRead("iotid:" + LegalId.LowerCase))
            {
                LegalIdentity Identity = await LegalComponent.GetLocalLegalIdentity(LegalId)
                    ?? throw new NotFoundException("Legal identity not found.");
 
                if (Identity.Account != User.UserName)
                    throw new ForbiddenException("Only allowed to ready your own legal identities.");
 
                if (Identity.State != IdentityState.Created)
                    throw new ForbiddenException("Identity must be in a Created state.");
 
                IAccount Account = await XmppServerModule.GetAccountAsync(Identity.Account)
                    ?? throw new ForbiddenException("Account has been removed.");
                
                if (!Account.Enabled)
                    throw new ForbiddenException("Account has been disabled.");
 
                XmppServerModule.Legal?.CheckAuthenticityOfIdentity(Identity, Identity.GetTags(),
                    XmppServerModule.Legal.MainDomain, new XmppAddress(User.UserName + "@" + Gateway.Domain), 
                    Account as DataStorage.Account);
 
                await Response.Return(new NamedDictionary<string, object>("AckResponse", AgentNamespace));
            }
        }
 
    }
}