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

feat(assist): small fix for isLive request

Browse source
This commit is contained in:
Alexander 2025-03-24 16:47:37 +01:00
parent cb4e318650
commit 269b960035
3 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
assist/utils/httpHandlers.js
View file

@ -41,8 +41,8 @@ const respond = function (req, res, data) {
RecordRequestDuration(req.method.toLowerCase(), res.handlerName, 200, duration/1000.0);
}
const getParticularSession = async function (roomId, filters) {
let connected_sockets = await fetchSockets(roomId);
const getParticularSession = async function (roomId, filters, all=false) {
let connected_sockets = await fetchSockets(roomId, all);
if (connected_sockets.length === 0) {
return null;
}
@ -172,7 +172,7 @@ const socketsLiveBySession = async function (req, res) {
// find a particular session
if (_sessionId) {
let sessInfo = await getParticularSession(`${_projectKey}-${_sessionId}`, filters);
let sessInfo = await getParticularSession(`${_projectKey}-${_sessionId}`, filters, true);
return respond(req, res, sessInfo);
}
return respond(req, res, null);

2
assist/utils/wsServer.js
View file

@ -11,7 +11,7 @@ function sendTo(to, eventName, ...data) {
sendFrom(io, to, eventName, ...data);
}
const fetchSockets = async function (roomID) {
const fetchSockets = async function (roomID, all=false) {
if (!io) {
return [];
}

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

@ -61,7 +61,7 @@ function sendTo(to, eventName, ...data) {
sendFrom(io, to, eventName, ...data);
}
const fetchSockets = async function (roomID) {
const fetchSockets = async function (roomID, all=false) {
if (!io) {
return [];
}
@ -69,7 +69,7 @@ const fetchSockets = async function (roomID) {
return await doFetchAllSockets();
}
try {
if (useStickySessions) {
if (useStickySessions && !all) {
return await io.local.in(roomID).fetchSockets();
} else {
return await io.in(roomID).fetchSockets();