1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
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, '<').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 '<span class="' + cls + '">' + match + '</span>';
});
},
};
//**********************************************
// 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);
}
|
