selenite/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

optimize websockets

Browse Source
This commit is contained in:
sky
2026-04-06 21:48:54 -04:00
parent 5be3f06fe2
commit a7d194631c
2 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
index.js
View File

@ -45,6 +45,11 @@ app.use("/resources/semag/portal/", (req, res, next) => {
next(); next();
}); });
app.use("/resources/semag/hatsunemikuprojectdiva/", (req, res, next) => {
res.setHeader('Cross-Origin-Embedder-Policy', 'require-corp');
res.setHeader('Cross-Origin-Opener-Policy', 'same-origin');
next();
});
app.use("/resources/semag/danganronpa/", (req, res, next) => { app.use("/resources/semag/danganronpa/", (req, res, next) => {
res.setHeader('Cross-Origin-Embedder-Policy', 'require-corp'); res.setHeader('Cross-Origin-Embedder-Policy', 'require-corp');
res.setHeader('Cross-Origin-Opener-Policy', 'same-origin'); res.setHeader('Cross-Origin-Opener-Policy', 'same-origin');

9
websocket.js
View File

@ -10,6 +10,10 @@ wss.on("connection", function connection(ws, req, res) {
ws.send(`online=${wss.clients.size}`); ws.send(`online=${wss.clients.size}`);
}, 10000); }, 10000);
ws.killTimer = setTimeout(() => {
ws.close();
}, 1000 * 60 * 60 * 12);
ws.on("message", async function message(data, isBinary) { ws.on("message", async function message(data, isBinary) {
let message = Buffer.from(data).toString(); let message = Buffer.from(data).toString();
if (message.startsWith("annc")) { if (message.startsWith("annc")) {
@ -20,7 +24,7 @@ wss.on("connection", function connection(ws, req, res) {
} }
}); });
ws.on("close", () => {}); ws.on("close", () => {clearTimeout(ws.killTimer)});
}); });
let port = 7910; let port = 7910;
import express from "express"; import express from "express";
@ -34,6 +38,3 @@ server.on("upgrade", (request, socket, head) => {
wss.emit("connection", socket, request); wss.emit("connection", socket, request);
}); });
}); });
setInterval(async () => {
await appendFile(dataFile, String(wss.clients.size) + "\n")
}, 10000)