LegalIdentityStateChanged.cs

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Content;
using Waher.Content.Json;
using Waher.IoTGateway;
using Waher.Networking.HTTP;
using Waher.Networking.XMPP.Server;
using Waher.Service.IoTBroker.Legal;
using Waher.Service.IoTBroker.Legal.Identity;
 
namespace Waher.Service.IoTBroker.WebServices
{
    public class LegalIdentityStateChanged : HttpSynchronousResource, IHttpPostMethod
    {
        public LegalIdentityStateChanged()
            : base("/LegalIdentityStateChanged")
        {
        }
 
        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.Notarius.Identities");
            // TODO: OR Admin.Notarius.PendingIdentities
 
            if (!Request.HasData)
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            ContentResponse Content = await Request.DecodeDataAsync();
            if (Content.HasError || !(Content.Decoded is Dictionary<string, object> Obj))
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            if (!Obj.TryGetValue("id", out object Obj2) || !(Obj2 is string Id) ||
                !Obj.TryGetValue("state", out Obj2) || !(Obj2 is string s) ||
                !Enum.TryParse(s, out IdentityState State))
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            KeyValuePair<LegalIdentity, bool> P = await LegalComponent.GetLocalLegalIdentity(Id, true);
            LegalIdentity Identity = P.Key;
            bool Preview = P.Value;
 
            if (Identity is null)
            {
                await Response.SendResponse(new NotFoundException());
                return;
            }
 
            IAccount Account = await XmppServerModule.GetAccountAsync(Identity.Account);
            if (Account is null)
            {
                await Response.SendResponse(new ForbiddenException(Request, "Account has been removed."));
                return;
            }
 
            if (!Account.Enabled)
            {
                await Response.SendResponse(new ForbiddenException(Request, "Account has been disabled."));
                return;
            }
 
            await XmppServerModule.Legal.UpdateState(Identity, State, Request.RemoteEndPoint, 
                Account as DataStorage.Account, Preview, true, null);
 
            Response.StatusCode = 200;
            Response.StatusMessage = "OK";
            Response.ContentType = JsonCodec.DefaultContentType;
            await Response.Write("true");
        }
    }
}