createSuperuser.js

#!/usr/bin/node
'use strict';

const userDao = require("./dao/userDao");

const readline = require("readline");
const rl = readline.createInterface(
    process.stdin, process.stdout);

rl._writeToOutput = function _writeToOutput(stringToWrite) {
    if (rl.stdoutMuted)
        rl.output.write("\x1B[2K\x1B[200D"+ rl.query+ "*".repeat(rl.line.length));
    else
        rl.output.write(stringToWrite);
};

function ask(query) {
    rl.stdoutMuted = false;
    rl.query = query;
    return new Promise((resolve) => {
        rl.question(query, (input) => resolve(input) );
    });
}

function askHidden(query){
    rl.stdoutMuted = true;
    rl.query = query;
    return new Promise((resolve) => {
        rl.question(query, (input) =>{
            console.log("");
            resolve(input)
        });
    });
}

async function readUsername(){
    while(true){
        let username = await ask("Username:");
        if(username.length < 3){
            console.log("Too short username. At least 3 characters required.");
        }
        else if(await userDao.isUsernameTaken(username)){
            console.log("This username is already taken.");
        }
        else{
            return username;
        }
    }
}


async function readPassword(){

    while(true){
        let pass1 = await askHidden("Password:");
    
        let pass2 = await askHidden("Repeat password:");

        if(pass1==pass2)return pass1;

        console.log("Passwords do not match, please re-enter.");
    }
}

async function readEmail(){
    while(true){
        let email = await ask("Email:");
        if(!userDao.isEmailValid(email)){
            console.log("This is not email, please re-enter.");    
        }
        else if(await userDao.isEmailTaken(email)){
            console.log("This email is already taken.");
        }
        else{
            return email;
        }
    }
}

async function createSuperuser(){
    let username = await readUsername();
    let password = await readPassword();
    let given_name = await ask("Given name:");
    let family_name = await ask("Family name:");
    let email = await readEmail();
    let admin = true;

    let result = await userDao.postUser({username, password, given_name, family_name, email, admin}, true);
    if(!result.success){
        throw result.message;
    }
}

console.log("Creating an administrator account.")

createSuperuser().then(function(){
    console.log("Successfully created superuser account.");
    process.exit(0);
}).catch(function(err){
    console.error("Exception occured");
    console.error(err);
    process.exit(1);
});