jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge d7ea0d44aa into 13e83fa774

Browse source
This commit is contained in:
Mehdi Osman 2025-06-08 07:45:14 +00:00 • committed by GitHub
commit 57192adbac
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
assist/utils/wsServer.js
View file

@ -21,8 +21,9 @@ const createSocketIOServer = function (server, prefix) {
if (io) {
return io;
}
let bufferSize = (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6
io = _io(server, {
maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6,
maxHttpBufferSize: bufferSize,
cors: {
origin: "*",
methods: ["GET", "POST", "PUT"]
@ -30,6 +31,7 @@ const createSocketIOServer = function (server, prefix) {
path: (prefix ? prefix : '') + '/socket',
...getCompressionConfig()
});
console.log('The maximum http buffer size:', bufferSize);
return io;
}
@ -37,4 +39,4 @@ module.exports = {
createSocketIOServer,
getServer,
fetchSockets,
}
}

9
ee/assist/utils/wsServer.js
View file

@ -72,9 +72,10 @@ const createSocketIOServer = function (server, prefix) {
if (io) {
return io;
}
let bufferSize = (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6
if (process.env.uws !== "true") {
io = _io(server, {
maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6,
maxHttpBufferSize: bufferSize,
cors: {
origin: "*",
methods: ["GET", "POST", "PUT"],
@ -83,9 +84,10 @@ const createSocketIOServer = function (server, prefix) {
path: (prefix ? prefix : '') + '/socket',
...getCompressionConfig()
});
console.log('The maximum http buffer size:', bufferSize);
} else {
io = new _io.Server({
maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6,
maxHttpBufferSize: bufferSize,
cors: {
origin: "*",
methods: ["GET", "POST", "PUT"],
@ -94,6 +96,7 @@ const createSocketIOServer = function (server, prefix) {
path: (prefix ? prefix : '') + '/socket',
...getCompressionConfig()
});
console.log('The maximum http buffer size:', bufferSize);
io.attachApp(server);
}
startCacheRefresher();
@ -104,4 +107,4 @@ module.exports = {
createSocketIOServer,
getServer,
fetchSockets,
}
}