103 lines
3.2 KiB
JavaScript
103 lines
3.2 KiB
JavaScript
"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;
|
|
}
|
|
|
|
#registerServer = function(name, initdata) {
|
|
let server = new trserver(name, initdata, this.#logcb);
|
|
this.#servers[name] = server;
|
|
//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, pass) {
|
|
this.#registerServer(name, {'rpcurl': url, 'auth': `Basic ${btoa(`${user}:${pass}`)}`});
|
|
this.#saveServers();
|
|
}
|
|
|
|
#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
|
|
}
|
|
|
|
handleEvent(e) {
|
|
this.#log(6, `Handling event of type ${e.type}`);
|
|
switch (e.type) {
|
|
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;
|
|
}
|
|
}
|
|
}
|