39 lines
1.1 KiB
JavaScript
39 lines
1.1 KiB
JavaScript
import { appendFile } from 'fs/promises';
|
|
import WebSocket, { WebSocketServer } from "ws";
|
|
const wss = new WebSocketServer({ noServer: true });
|
|
let dataFile = "data/online.txt";
|
|
|
|
|
|
wss.on("connection", function connection(ws, req, res) {
|
|
ws.send(`online=${wss.clients.size}`);
|
|
setInterval(() => {
|
|
ws.send(`online=${wss.clients.size}`);
|
|
}, 10000);
|
|
|
|
ws.on("message", async function message(data, isBinary) {
|
|
let message = Buffer.from(data).toString();
|
|
if (message.startsWith("annc")) {
|
|
let splitMessage = message.split(";;");
|
|
wss.clients.forEach(client => {
|
|
client.send(`annc;;${splitMessage[2]};;${splitMessage[3]}`);
|
|
})
|
|
}
|
|
});
|
|
|
|
ws.on("close", () => {});
|
|
});
|
|
let port = 7910;
|
|
import express from "express";
|
|
const app = express();
|
|
const server = app.listen(port, () => {
|
|
console.log("Websocket server is online.");
|
|
console.log("- http://localhost:" + port);
|
|
});
|
|
server.on("upgrade", (request, socket, head) => {
|
|
wss.handleUpgrade(request, socket, head, (socket) => {
|
|
wss.emit("connection", socket, request);
|
|
});
|
|
});
|
|
setInterval(async () => {
|
|
await appendFile(dataFile, String(wss.clients.size) + "\n")
|
|
}, 10000) |