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; }); } //********************************************** // Init - establish Websocket connection //********************************************** function init(elemid, api, verb, query) { function onopen() { 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); }