CreateAccount.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Waher.Content;
using Waher.IoTGateway;
using Waher.Networking.HTTP;
using Waher.Networking.XMPP.Server;
using Waher.Persistence;
 
namespace Waher.Service.IoTBroker.WebServices
{
    public class CreateAccount : HttpSynchronousResource, IHttpPostMethod
    {
        public CreateAccount()
            : base("/CreateAccount")
        {
        }
 
        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.Broker.Accounts");
 
            if (!Request.HasData)
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            ContentResponse Content = await Request.DecodeDataAsync();
            if (Content.HasError || !(Content.Decoded is Dictionary<string, string> Form))
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            CaseInsensitiveString UserName;
            string Password;
            CaseInsensitiveString EMail;
            CaseInsensitiveString PhoneNr;
 
            if (!Form.ContainsKey("UserName") || CaseInsensitiveString.IsNullOrEmpty(UserName = Form["UserName"]))
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            if (!Form.ContainsKey("Password") || string.IsNullOrEmpty(Password = Form["Password"]))
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            if (!Form.ContainsKey("EMail") || CaseInsensitiveString.IsNullOrEmpty(EMail = Form["EMail"]))
            {
                await Response.SendResponse(new BadRequestException());
                return;
            }
 
            if (!Form.ContainsKey("PhoneNr") || CaseInsensitiveString.IsNullOrEmpty(PhoneNr = Form["PhoneNr"]))
                PhoneNr = string.Empty;
 
            DataStorage.PersistenceLayer PersistenceLayer = XmppServerModule.PersistenceLayer ?? new DataStorage.PersistenceLayer();
            KeyValuePair<IAccount, string[]> P = await PersistenceLayer.CreateAccount(string.Empty, UserName, Password, EMail, PhoneNr, Request.RemoteEndPoint);
            IAccount Account = P.Key;
 
            if (Account is null)
            {
                await Response.SendResponse(new ConflictException(GetAlterntivesHeaders(P.Value)));
                return;
            }
 
            await Response.SendResponse(new SeeOtherException("/Account.md?UserName=" + Account.UserName));  // PRG pattern.
        }
 
        internal static KeyValuePair<string, string>[] GetAlterntivesHeaders(string[] Alternatives)
        {
            int i, c = Alternatives?.Length ?? 0;
            KeyValuePair<string, string>[] Suggestions = new KeyValuePair<string, string>[c];
 
            for (i = 0; i < c; i++)
                Suggestions[i] = new KeyValuePair<string, string>("X-AlternativeName" + (i + 1).ToString(), Alternatives[i]);
 
            return Suggestions;
        }
 
    }
}