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

fix(assist): fixed issue with sessionUpdate event

Browse source
This commit is contained in:
Alexander Zavorotynskiy 2023-06-19 12:32:48 +02:00
parent 81e8302a9e
commit 5256615edc
3 changed files with 6 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
assist/servers/websocket.js
View file

@ -345,11 +345,10 @@ module.exports = {
} }
Object.assign(socket.handshake.query.sessionInfo, args[0].data, {tabId: args[0].meta.tabId}); Object.assign(socket.handshake.query.sessionInfo, args[0].data, {tabId: args[0].meta.tabId});
socket.to(socket.roomId).emit(EVENTS_DEFINITION.emit.UPDATE_EVENT, args[0]); socket.to(socket.roomId).emit(EVENTS_DEFINITION.emit.UPDATE_EVENT, args[0]);
// Update sessionInfo for all sessions (TODO: rewrite this) // Update sessionInfo for all sessions in room
const rooms = await getAvailableRooms(io); const rooms = await getAvailableRooms(io);
for (let roomId of rooms.keys()) { for (let roomId of rooms.keys()) {
let {projectKey} = extractPeerId(roomId); if (roomId === socket.roomId) {
if (projectKey === connProjectKey) {
const connected_sockets = await io.in(roomId).fetchSockets(); const connected_sockets = await io.in(roomId).fetchSockets();
for (let item of connected_sockets) { for (let item of connected_sockets) {
if (item.handshake.query.identity === IDENTITIES.session && item.handshake.query.sessionInfo) { if (item.handshake.query.identity === IDENTITIES.session && item.handshake.query.sessionInfo) {

5
ee/assist/servers/websocket-cluster.js
View file

@ -398,11 +398,10 @@ module.exports = {
} }
Object.assign(socket.handshake.query.sessionInfo, args[0].data, {tabId: args[0].meta.tabId}); Object.assign(socket.handshake.query.sessionInfo, args[0].data, {tabId: args[0].meta.tabId});
socket.to(socket.roomId).emit(EVENTS_DEFINITION.emit.UPDATE_EVENT, args[0]); socket.to(socket.roomId).emit(EVENTS_DEFINITION.emit.UPDATE_EVENT, args[0]);
// Update sessionInfo for all sessions (TODO: rewrite this) // Update sessionInfo for all sessions in room
const rooms = await getAvailableRooms(io); const rooms = await getAvailableRooms(io);
for (let roomId of rooms.keys()) { for (let roomId of rooms.keys()) {
let {projectKey} = extractPeerId(roomId); if (roomId === socket.roomId) {
if (projectKey === connProjectKey) {
const connected_sockets = await io.in(roomId).fetchSockets(); const connected_sockets = await io.in(roomId).fetchSockets();
for (let item of connected_sockets) { for (let item of connected_sockets) {
if (item.handshake.query.identity === IDENTITIES.session && item.handshake.query.sessionInfo) { if (item.handshake.query.identity === IDENTITIES.session && item.handshake.query.sessionInfo) {

5
ee/assist/servers/websocket.js
View file

@ -366,11 +366,10 @@ module.exports = {
} }
Object.assign(socket.handshake.query.sessionInfo, args[0].data, {tabId: args[0].meta.tabId}); Object.assign(socket.handshake.query.sessionInfo, args[0].data, {tabId: args[0].meta.tabId});
socket.to(socket.roomId).emit(EVENTS_DEFINITION.emit.UPDATE_EVENT, args[0]); socket.to(socket.roomId).emit(EVENTS_DEFINITION.emit.UPDATE_EVENT, args[0]);
// Update sessionInfo for all sessions (TODO: rewrite this) // Update sessionInfo for all sessions in room
const rooms = await getAvailableRooms(io); const rooms = await getAvailableRooms(io);
for (let roomId of rooms.keys()) { for (let roomId of rooms.keys()) {
let {projectKey} = extractPeerId(roomId); if (roomId === socket.roomId) {
if (projectKey === connProjectKey) {
const connected_sockets = await io.in(roomId).fetchSockets(); const connected_sockets = await io.in(roomId).fetchSockets();
for (let item of connected_sockets) { for (let item of connected_sockets) {
if (item.handshake.query.identity === IDENTITIES.session && item.handshake.query.sessionInfo) { if (item.handshake.query.identity === IDENTITIES.session && item.handshake.query.sessionInfo) {