|
@ -32,19 +32,16 @@ async function sendNotificationList(socket) { |
|
|
async function sendHeartbeatList(socket, monitorID, toUser = false, overwrite = false) { |
|
|
async function sendHeartbeatList(socket, monitorID, toUser = false, overwrite = false) { |
|
|
const timeLogger = new TimeLogger(); |
|
|
const timeLogger = new TimeLogger(); |
|
|
|
|
|
|
|
|
let list = await R.find("heartbeat", ` |
|
|
let list = await R.getAll(` |
|
|
monitor_id = ? |
|
|
SELECT * FROM heartbeat |
|
|
|
|
|
WHERE monitor_id = ? |
|
|
ORDER BY time DESC |
|
|
ORDER BY time DESC |
|
|
LIMIT 100 |
|
|
LIMIT 100 |
|
|
`, [
|
|
|
`, [
|
|
|
monitorID, |
|
|
monitorID, |
|
|
]) |
|
|
]) |
|
|
|
|
|
|
|
|
let result = []; |
|
|
let result = list.reverse(); |
|
|
|
|
|
|
|
|
for (let bean of list) { |
|
|
|
|
|
result.unshift(bean.toJSON()); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (toUser) { |
|
|
if (toUser) { |
|
|
io.to(socket.userID).emit("heartbeatList", monitorID, result, overwrite); |
|
|
io.to(socket.userID).emit("heartbeatList", monitorID, result, overwrite); |
|
|