Compare commits

...
Sign in to create a new pull request.

2 commits

Author SHA1 Message Date
Mehdi Osman
d7ea0d44aa
Update foss 2024-05-09 11:49:40 -04:00
Mehdi Osman
570d873270
Added logs for maxHttpBufferSize 2024-05-09 11:36:54 -04:00
2 changed files with 10 additions and 5 deletions

View file

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

View file

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