var afb = new AFB("api", "mysecret"); var ws; var evtIdx = 0; var count = 0; //********************************************** // Logger //********************************************** var log = { command: function (api, verb, query) { console.log("subscribe api=" + api + " verb=" + verb + " query=", query); var question = urlWS + "/" + api + "/" + verb + "?query=" + JSON.stringify(query); log._write("question", count + ": " + log.syntaxHighlight(question)); }, event: function (obj) { console.log("gotevent:" + JSON.stringify(obj)); log._write("outevt", (evtIdx++) + ": " + JSON.stringify(obj)); }, reply: function (obj) { console.log("replyok:" + JSON.stringify(obj)); log._write("output", count + ": OK: " + log.syntaxHighlight(obj)); }, error: function (obj) { console.log("replyerr:" + JSON.stringify(obj)); log._write("output", count + ": ERROR: " + log.syntaxHighlight(obj)); }, _write: function (element, msg) { var el = document.getElementById(element); el.innerHTML += msg + '\n'; // auto scroll down setTimeout(function () { el.scrollTop = el.scrollHeight; }, 100); }, syntaxHighlight: function (json) { if (typeof json !== 'string') { json = JSON.stringify(json, undefined, 2); } json = json.replace(/&/g, '&').replace(//g, '>'); return json.replace(/("(\\u[a-zA-Z0-9]{4}|\\[^u]|[^\\"])*"(\s*:)?|\b(true|false|null)\b|-?\d+(?:\.\d*)?(?:[eE][+\-]?\d+)?)/g, function (match) { var cls = 'number'; if (/^"/.test(match)) { if (/:$/.test(match)) { cls = 'key'; } else { cls = 'string'; } } else if (/true|false/.test(match)) { cls = 'boolean'; } else if (/null/.test(match)) { cls = 'null'; } return '' + match + ''; }); }, }; //********************************************** // Generic function to call binder //*********************************************** function callbinder(api, verb, query) { log.command(api, verb, query); // ws.call return a Promise return ws.call(api + '/' + verb, query) .then(function (res) { log.reply(res); count++; return res; }) .catch(function (err) { log.reply(err); count++; throw err; }); }; //********************************************** // //********************************************** var topo = null; function getTopo() { callbinder('supervisor', 'list', null) .then(list => { var reqs = []; for (pid in list.response) { this.pid = pid; reqs.push( callbinder('supervisor', 'config', { "pid": pid }) .then((res) => { return { 'pid': this.pid, 'ws_servers': res.response.ws_servers, 'ws_clients': res.response.ws_clients } }) ); }; return Promise.all(reqs); }) .then(daemons => { console.log("daemons count ", daemons.length); daemons.forEach(dd => { console.log(dd); }); topo = daemons; }) .catch(err => { console.log() }); }; //********************************************** // Init - establish Websocket connection //********************************************** function init(elemID, api, verb, query) { function onopen() { // Request initial authorization callbinder('xds-service', 'auth', ''); document.getElementById("main").style.visibility = "visible"; document.getElementById("connected").innerHTML = "Binder WS Active"; document.getElementById("connected").style.background = "lightgreen"; ws.onevent("*", log.event); } function onabort() { document.getElementById("main").style.visibility = "hidden"; document.getElementById("connected").innerHTML = "Connected Closed"; document.getElementById("connected").style.background = "red"; } ws = new afb.ws(onopen, onabort); }