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
|
const serviceMap = new Map();
async function getServices() {
const url = "api/v1/status";
try {
const response = await fetch(url);
if (!response.ok) {
throw new Error(`Response status: ${response.status}`);
}
const json = await response.json();
return json;
} catch (error) {
console.error(error.message);
}
}
function updateStatus() {
const statusElm = document.getElementById("status");
const issuesElm = document.getElementById("issues");
const issues = [...serviceMap.values()].filter((s) => !s).length;
issuesElm.textContent = `${issues} issue(s) detected`;
if (issues) {
statusElm.setAttribute("class", "error");
} else {
statusElm.setAttribute("class", "ok");
}
}
function updateService(name, node, data) {
switch (data.status) {
case "ok":
node.textContent = "Ok";
node.setAttribute("class", "ok");
serviceMap.set(name, true);
break;
case "error":
node.textContent = "Error";
node.title = data.output;
node.setAttribute("class", "error");
serviceMap.set(name, false);
break;
}
updateStatus();
}
getServices().then((services) => {
const evtSource = new EventSource("/api/v1/sse");
evtSource.onmessage = (event) => {
console.log(event.data);
};
for (const [service, status] of Object.entries(services)) {
const table = document.getElementById("services");
const row = table.insertRow();
const nameNode = row.insertCell();
nameNode.textContent = service;
const node = row.insertCell();
updateService(service, node, status);
evtSource.addEventListener(service, (event) => {
data = JSON.parse(event.data);
updateService(service, node, data);
console.log(`service: ${service}, event: ${event}`);
});
}
});
|
