'use strict';
function node_require(module) {
    return require(module);
}
let fs = node_require("fs");
let path = node_require("path");
var Realm = node_require('realm');

const DEFAULT_ADMIN_TOKEN_PATH = path.join(__dirname, "..", "..", "object-server-for-testing", "admin_token.base64");
const ADMIN_TOKEN_PATH = process.env.ADMIN_TOKEN_PATH || DEFAULT_ADMIN_TOKEN_PATH;

function getAdminToken() {
    if (fs.existsSync(ADMIN_TOKEN_PATH)) {
        return fs.readFileSync(ADMIN_TOKEN_PATH, 'utf-8');
    } else {
        throw new Error("Missing the file with an admin token: " + ADMIN_TOKEN_PATH);
    }
}

function random(min, max) {
    min = Math.ceil(min);
    max = Math.floor(max);
    return Math.floor(Math.random() * (max - min + 1)) + min;
}

const newAdminName = 'admin' + random(1, 100000);
const password = '123';
exports.createAdminUser = function () {
    let nonTokenUser, userIdentity, admin_token_user
    return new Promise((resolve, reject) => {
        Realm.Sync.User.register('http://localhost:9080', newAdminName, password, (error, user) => {
            if (error) {
                reject(error);
                return;
            }
            nonTokenUser = user
            userIdentity = user.identity;
            user.logout();

            admin_token_user = Realm.Sync.User.adminUser(getAdminToken(), 'http://localhost:9080');

            const config = {
                sync: {
                    user: admin_token_user,
                    url: 'realm://localhost:9080/__admin',
                    error: err => {
                        reject(new Error('Error opening __admin realm error:' + err.user  + ' url:' + err.url + ' state:' + err.state));
                    }
                }
            };

            resolve(Realm.open(config));
        });
    }).then(realm => {
        let pendingAdminUser = realm.objectForPrimaryKey('User', userIdentity);
        realm.write(() => {
            pendingAdminUser.isAdmin = true;
        });

        admin_token_user.logout();
    }).then(() => {
        return new Promise((resolve, reject) => {
            let isAdminRetryCounter = 0;
            let waitForServerToUpdateAdminUser = function () {
                isAdminRetryCounter++;
                if (isAdminRetryCounter > 10) {
                    reject("admin-user-helper: Create admin user timeout");
                    return;
                }

                Realm.Sync.User.login('http://localhost:9080', newAdminName, password, (error, newAdminUser) => {
                    if (error) {
                        reject(error);
                        return;
                    }

                    let isAdmin = newAdminUser.isAdmin;
                    nonTokenUser.logout();
                    if (!isAdmin) {
                        setTimeout(waitForServerToUpdateAdminUser, 500);
                        return;
                    }

                    resolve({
                        username: newAdminName,
                        password
                    });
                });
            }
            waitForServerToUpdateAdminUser();
        });
    });
}