zefie/minisrv
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

use larger socket ID to prevent collisions on high traffic servers

Browse Source
This commit is contained in:
zefie
2025-06-19 13:41:59 -04:00
parent 7787d8217d
commit d64d795ffb
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
zefie_wtvp_minisrv/app.js
View File

@@ -2226,10 +2226,19 @@ async function cleanupSocket(socket) {
} }
} }
function getSocketRandomID(socket) {
//return parseInt(crc16('CCITT-FALSE', Buffer.from(String(req.socket.remoteAddress) + String(req.socket.remotePort), "utf8")).toString(16), 16);
return parseInt(
crypto.createHash('sha256')
.update(String(socket.remoteAddress) + String(socket.remotePort))
.digest('hex')
.substring(0, 8), 16
) % 100000000;
}
async function handleSocket(socket) { async function handleSocket(socket) {
// create unique socket id with client address and port // create unique socket id with client address and port
socket.id = parseInt(crc16('CCITT-FALSE', Buffer.from(String(socket.remoteAddress) + String(socket.remotePort), "utf8")).toString(16), 16); socket.id = getSocketRandomID(socket);
socket.ssid = null; socket.ssid = null;
socket_sessions[socket.id] = []; socket_sessions[socket.id] = [];
socket.minisrv_pc_mode = false; socket.minisrv_pc_mode = false;
@@ -2523,7 +2532,7 @@ pc_bind_ports.every(function (v) {
req.socket.minisrv_pc_mode = true; req.socket.minisrv_pc_mode = true;
req.socket.res = res; req.socket.res = res;
req.socket.service_name = service_name; req.socket.service_name = service_name;
req.socket.id = parseInt(crc16('CCITT-FALSE', Buffer.from(String(req.socket.remoteAddress) + String(req.socket.remotePort), "utf8")).toString(16), 16); req.socket.id = getSocketRandomID(req.socket);
socket_sessions[req.socket.id] = []; socket_sessions[req.socket.id] = [];
if (getServiceEnabled(service_name)) { if (getServiceEnabled(service_name)) {
@@ -2569,7 +2578,7 @@ Content-type: text/html`;
req.socket.minisrv_pc_mode = true; req.socket.minisrv_pc_mode = true;
req.socket.res = res; req.socket.res = res;
req.socket.service_name = service_name; req.socket.service_name = service_name;
req.socket.id = parseInt(crc16('CCITT-FALSE', Buffer.from(String(req.socket.remoteAddress) + String(req.socket.remotePort), "utf8")).toString(16), 16); req.socket.id = getSocketRandomID(req.socket);
socket_sessions[req.socket.id] = []; socket_sessions[req.socket.id] = [];
if (getServiceEnabled(service_name)) { if (getServiceEnabled(service_name)) {