trweb/js/trdom_servermanager.js

"use strict";

class trdom_servermanager extends EventTarget {

    #logcb;
    #log(loglevel, msg) {
        if (this.#logcb !== null) {
            this.#logcb('trdom_servermanager', loglevel, msg);
        }
    }

    #servers = {};
    getServers() {
        return this.#servers;
    }

    #elements = {
        menuentry: document.createElement('div'),
        serverlist: {
            shade: document.createElement('div'),
            form: document.createElement('div'),
            header: {
                container: document.createElement('div'),
                addbutton: document.createElement('div')
            },
            list: document.createElement('div')
        }
    };

    get menuentry() {
        return this.#elements.menuentry;
    }

    #registerServer(name, initdata) {
        let server = new trserver(name, initdata, this.#logcb);
        this.#servers[name] = server;
        this.#elements.serverlist.list.appendChild(server.element);
        let button = document.createElement('div');
        server.addServerListButton('deleteserver', button);
        button.setAttributeNS('trweb', 'servermanagerbutton', 'delete');
        button.setAttribute('server', name);
        button.appendChild(document.createTextNode('[Delete]'));
        button.addEventListener('click', this);
        //server.addEventListener('torrent-updated', this);
        server.addEventListener('torrent-initialize', this);
        let e = new CustomEvent('torrentserver-added', {
            detail: {
                serverName: name,
                serverObject: server
            }
        });
        this.dispatchEvent(e);
        server.refreshTorrentList();
    }

    addServer(name, url, user = null, pass = '') {
        let initdata = {rpcurl: url};
        if (user != null) {
            initdata.auth = `Basic ${btoa(`${user}:${pass}`)}`
        }
        this.#registerServer(name, initdata);
        this.#saveServers();
    }

    deleteServer(name) {
        delete this.#servers[name];
        this.saveServers();
        window.location.reload();
    }

    #loadcb;
    #loadServers() {
        let serverjson = this.#loadcb('servers');
        this.#servers = {};
        if (serverjson == null) {
            this.#log(4, 'No saved server data found');
        }
        else {
            let serverdata = JSON.parse(serverjson);
            for (const [key, value] of Object.entries(serverdata)) {
                this.#registerServer(key, value);
            }
            this.#log(5, `Loaded ${Object.keys(this.#servers).length} servers`);
        }
    }
    loadServers() {
        this.#loadServers();
    }
    
    #savecb;
    #saveServers() {
        let serverdata = {};
        for (const [key, value] of Object.entries(this.#servers)) {
            serverdata[key] = value.getInstanceData();
        }
        this.#log(5, `Saving ${Object.keys(serverdata).length} servers`);
        this.#savecb('servers', JSON.stringify(serverdata));
    }
    saveServers() {
        this.#saveServers();
    }

    constructor (loadcb = null, savecb = null, logcb = null) {
        super();
        this.#loadcb = loadcb;
        this.#savecb = savecb;
        this.#logcb = logcb

        this.menuentry.appendChild(document.createTextNode('[Servers]'));
        this.menuentry.setAttributeNS('trweb', 'servermanagerbutton', 'manager');
        this.menuentry.addEventListener('click', this);

        this.#elements.serverlist.shade.classList.add('trweb_formshade', 'd-flex', 'justify-content-center', 'align-items-center');
        this.#elements.serverlist.shade.setAttributeNS('trweb', 'servermanagerbutton', 'hide');
        this.#elements.serverlist.shade.addEventListener('click', this);
        this.#elements.serverlist.shade.appendChild(this.#elements.serverlist.form);

        this.#elements.serverlist.form.classList.add('trweb_form', 'd-flex', 'flex-column');
        this.#elements.serverlist.form.setAttributeNS('trweb', 'servermanagerbutton', 'block');
        this.#elements.serverlist.form.addEventListener('click', this);
        this.#elements.serverlist.form.style.backgroundColor = 'cyan';
        this.#elements.serverlist.form.appendChild(this.#elements.serverlist.header.container);
        this.#elements.serverlist.form.appendChild(this.#elements.serverlist.list);

        this.#elements.serverlist.header.container.classList.add('d-flex', 'flex-row');
        this.#elements.serverlist.header.container.appendChild(this.#elements.serverlist.header.addbutton);

        this.#elements.serverlist.header.addbutton.appendChild(document.createTextNode('[Add server]'));
        this.#elements.serverlist.header.addbutton.setAttributeNS('trweb', 'servermanagerbutton', 'add');
        this.#elements.serverlist.header.addbutton.addEventListener('click', this);

        this.#elements.serverlist.list.classList.add('d-flex', 'flex-column');
    }

    handleEvent(e) {
        this.#log(6, `Handling event of type ${e.type}`);
        switch (e.type) {
        case 'click':
            if (e.currentTarget.hasAttributeNS('trweb', 'servermanagerbutton')) {
                switch (e.currentTarget.getAttributeNS('trweb', 'servermanagerbutton')) {
                case 'add':
                    e.stopPropagation();
                    let addName = window.prompt('Enter name for the new server');
                    if (addName != null) {
                        if (addName == '') {
                            window.alert('No name was provided, aborting');
                        }
                        else {
                            if (this.#servers[addName] != null) {
                                window.alert('Server with the provided name already exists, aborting');
                            }
                            else {
                                let addUrl = window.prompt('Enter server URL', 'http://localhost:9091/transmission/rpc');
                                if (addUrl != null) {
                                    if (addUrl == '') {
                                        window.alert('No URL provided, aborting');
                                    }
                                    else {
                                        let addUser;
                                        let addPass;
                                        addUser = window.prompt('Enter username, leave empty of not required');
                                        if (addUser == null) {
                                            return;
                                        }
                                        if (addUser == '') {
                                            addUser = null;
                                        }
                                        else {
                                            addPass = window.prompt(`Enter password for user ${addUser}`);
                                            if (addPass == null) {
                                                return;
                                            }
                                        }
                                        this.addServer(addName, addUrl, addUser, addPass); 
                                    }
                                }
                            }
                        }
                    }
                    break;
                case 'block':
                    e.stopPropagation();
                    break;
                case 'delete':
                    e.stopPropagation();
                    let deleteSrv = e.currentTarget.getAttribute('server');
                    if (window.confirm(`Are you sure you want to delete server ${deleteSrv}?`)) {
                        this.deleteServer(deleteSrv);
                    }
                    break;
                case 'hide':
                    e.stopPropagation();
                    document.body.removeChild(this.#elements.serverlist.shade);
                    break;
                case 'manager':
                    e.stopPropagation();
                    document.body.appendChild(this.#elements.serverlist.shade);
                    break;
                }
            }
            break;
        case 'torrent-initialize':
            let initControls = {};
            let initHash = e.detail.torrentHash;
            for (const [srv, server] of Object.entries(this.#servers)) {
                let control = server == e.detail.serverObject ? e.detail.torrentControl : new trdom_torrentcontrol(initHash, server, {magnetLink: e.detail.torrentControl.magnet}, this.#logcb);
                //server.addControl(control);
                initControls[srv] = control;
            }
            let initEvent = new CustomEvent('torrent-created', {
                detail: {
                    torrentHash: initHash,
                    torrentControls: initControls,
                    torrentName: e.detail.torrentControl.name,
                    magnetLink: e.detail.torrentControl.magnet
                }
            });
            this.dispatchEvent(initEvent);
            break;
        default:
            this.#log(5, `Event type ${e.type} not supported`);
            break;
        }
    }
}