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

feat(utilities): FOSS&EE assist socket creation customize path

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-03-16 16:02:47 +01:00
parent 83325af69f
commit 729d5715b4
3 changed files with 14 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ee/utilities/servers/websocket-cluster.js
View file

@ -21,7 +21,7 @@ const subClient = pubClient.duplicate();
let io;
const debug = process.env.debug === "1" || false;
const createSocketIOServer = function (server) {
const createSocketIOServer = function (server, prefix) {
if (process.env.uws !== "true") {
io = _io(server, {
maxHttpBufferSize: (parseInt(process.env.maxHttpBufferSize) || 5) * 1e6,
@ -29,7 +29,7 @@ const createSocketIOServer = function (server) {
origin: "*",
methods: ["GET", "POST", "PUT"]
},
path: '/socket'
path: (prefix ? prefix : '') + '/socket'
});
} else {
io = new _io.Server({
@ -38,7 +38,7 @@ const createSocketIOServer = function (server) {
origin: "*",
methods: ["GET", "POST", "PUT"]
},
path: '/socket',
path: (prefix ? prefix : '') + '/socket'
// transports: ['websocket'],
// upgrade: false
});
@ -287,8 +287,8 @@ function extractSessionInfo(socket) {
module.exports = {
wsRouter,
start: (server) => {
createSocketIOServer(server);
start: (server, prefix) => {
createSocketIOServer(server, prefix);
io.on('connection', async (socket) => {
debug && console.log(`WS started:${socket.id}, Query:${JSON.stringify(socket.handshake.query)}`);
socket.peerId = socket.handshake.query.peerId;

10
ee/utilities/servers/websocket.js
View file

@ -16,7 +16,7 @@ const SESSION_ALREADY_CONNECTED = "SESSION_ALREADY_CONNECTED";
let io;
const debug = process.env.debug === "1" || false;
const createSocketIOServer = function (server) {
const createSocketIOServer = function (server, prefix) {
if (process.env.uws !== "true") {
io = _io(server, {
maxHttpBufferSize: (parseInt(process.env.maxHttpBufferSize) || 5) * 1e6,
@ -24,7 +24,7 @@ const createSocketIOServer = function (server) {
origin: "*",
methods: ["GET", "POST", "PUT"]
},
path: '/socket'
path: (prefix ? prefix : '') + '/socket'
});
} else {
io = new _io.Server({
@ -33,7 +33,7 @@ const createSocketIOServer = function (server) {
origin: "*",
methods: ["GET", "POST", "PUT"]
},
path: '/socket',
path: (prefix ? prefix : '') + '/socket'
// transports: ['websocket'],
// upgrade: false
});
@ -265,8 +265,8 @@ function extractSessionInfo(socket) {
module.exports = {
wsRouter,
start: (server) => {
createSocketIOServer(server);
start: (server, prefix) => {
createSocketIOServer(server, prefix);
io.on('connection', async (socket) => {
debug && console.log(`WS started:${socket.id}, Query:${JSON.stringify(socket.handshake.query)}`);
socket.peerId = socket.handshake.query.peerId;

8
utilities/servers/websocket.js
View file

@ -16,14 +16,14 @@ const SESSION_ALREADY_CONNECTED = "SESSION_ALREADY_CONNECTED";
let io;
const debug = process.env.debug === "1" || false;
const createSocketIOServer = function (server) {
const createSocketIOServer = function (server, prefix) {
io = _io(server, {
maxHttpBufferSize: (parseInt(process.env.maxHttpBufferSize) || 5) * 1e6,
cors: {
origin: "*",
methods: ["GET", "POST", "PUT"]
},
path: '/socket'
path: (prefix ? prefix : '') + '/socket'
});
}
@ -236,8 +236,8 @@ function extractSessionInfo(socket) {
module.exports = {
wsRouter,
start: (server) => {
createSocketIOServer(server);
start: (server, prefix) => {
createSocketIOServer(server, prefix);
io.on('connection', async (socket) => {
debug && console.log(`WS started:${socket.id}, Query:${JSON.stringify(socket.handshake.query)}`);
socket.peerId = socket.handshake.query.peerId;