import { appendFile } from 'fs/promises';
import WebSocket, { WebSocketServer } from "ws";
const wss = new WebSocketServer({ noServer: true });


wss.on("connection", function connection(ws, req, res) {
	ws.send(`online=${wss.clients.size}`);
	const onlineInterval = setInterval(() => {
		ws.send(`online=${wss.clients.size}`);
	}, 10000);

	const killTimer = setTimeout(() => {
		ws.close();
	}, 1000 * 60 * 60 * 12);
	
	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", () => {
		clearTimeout(killTimer);
		clearInterval(onlineInterval)
	});
});
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);
	});
});