forked from cklokmose/vhstatus
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathindex.js
70 lines (62 loc) · 1.88 KB
/
index.js
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
const http = require("http")
const express = require('express')
const app = express()
const fs = require("fs");
const ws = require('ws');
let users = {}
app.use(express.static('www'))
const server = http.createServer(app);
const wss = new ws.Server({ server });
const config = JSON.parse(fs.readFileSync("config.json", "utf8"));
wss.on('connection', socket => {
socket.on('message', message => console.log(message));
sendUsers();
});
function sendUsers() {
fs.readFile(config.log, "utf8", (err, data) => {
if (err) {
console.log(err)
process.exit(1)
} else {
let lines = data.split("\n");
let lastUser;
for (let line of lines) {
let handshake = line.match(/(handshake from client )(\d+)/);
let user = line.match(/(Got character ZDOID from )([\w ]+)(\s:)/);
let disconnected = line.match(/(Closing socket )(\d\d+)/)
if (handshake) {
let id = handshake[2];
let time = new Date(line.match(/\d{2}\/\d{2}\/\d{4} \d{2}:\d{2}:\d{2}/));
users[id] = {connected: time, disconnected: undefined, user: undefined};
lastUser = id;
}
if (disconnected) {
let id = disconnected[2];
if (!users[id]) continue;
let user = users[id];
let time = new Date(line.match(/\d{2}\/\d{2}\/\d{4} \d{2}:\d{2}:\d{2}/));
user.disconnected = time;
}
if (user) {
if (lastUser) {
users[lastUser].user = user[2];
for (let u in users) { // Clean up users showing up multiple times in the list
if (users[u].user == user[2] && u !== lastUser) delete users[u];
}
lastUser = undefined;
}
}
}
wss.clients.forEach((client) => {
let msg = {};
msg.users = users;
msg.serverName = config.serverName;
client.send(JSON.stringify(msg));
});
}
});
}
setInterval(sendUsers, config.freq);
server.listen(config.port, () => {
console.log(`Valheim status at http://localhost:${config.port}`)
})