dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-20 05:26:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed stream

Browse Source
This commit is contained in:
Jan Prochazka
2024-05-20 20:15:53 +02:00
parent 7d984d8faf
commit d00ee890e5
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
packages/api/src/utility/socket.js
View File

@@ -14,8 +14,8 @@ module.exports = {
}, },
addSseResponse(value, strmid) { addSseResponse(value, strmid) {
sseResponses[strmid] = { sseResponses[strmid] = {
...sseResponses[strmid],
response: value, response: value,
filter: {},
}; };
this.ensurePing(); this.ensurePing();
}, },
@@ -32,11 +32,13 @@ module.exports = {
} }
for (const strmid in sseResponses) { for (const strmid in sseResponses) {
let skipThisStream = false; let skipThisStream = false;
for (const key in sseResponses[strmid].filter) { if (sseResponses[strmid].filter) {
if (data && data[key]) { for (const key in sseResponses[strmid].filter) {
if (!sseResponses[strmid].filter[key].includes(data[key])) { if (data && data[key]) {
skipThisStream = true; if (!sseResponses[strmid].filter[key].includes(data[key])) {
break; skipThisStream = true;
break;
}
} }
} }
} }
@@ -55,6 +57,9 @@ module.exports = {
// this.emit(key); // this.emit(key);
}, },
setStreamIdFilter(strmid, filter) { setStreamIdFilter(strmid, filter) {
sseResponses[strmid].filter = filter; sseResponses[strmid] = {
...sseResponses[strmid],
filter,
};
}, },
}; };