dave/server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cleanup

Browse Source
This commit is contained in:
dave 2025-03-01 11:02:23 +01:00
parent 339fd208c4
commit 3c44f223c0
3 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.gitignore vendored Normal file
View File

@ -0,0 +1,2 @@
.env

10
index.js
View File

@ -44,16 +44,6 @@ wss.on('connection', function connection(ws) {
executeSet(message, ws).catch(console.error); executeSet(message, ws).catch(console.error);
break; break;
case 'subscribe': case 'subscribe':
if (!subscriptions[message.subject]) {
subscriptions[message.subject] = {};
}
if (!subscriptions[message.subject][JSON.stringify(message.filter)]) {
subscriptions[message.subject][JSON.stringify(message.filter)] = {};
}
if (!subscriptions[message.subject][JSON.stringify(message.filter)][message.field]) {
subscriptions[message.subject][JSON.stringify(message.filter)][message.field] = [];
}
subscriptions[message.subject][JSON.stringify(message.filter)][message.field].push(ws);
let subject = collections[message.subject]; let subject = collections[message.subject];
if (!subject) { if (!subject) {
subject = collections[message.subject] = db.collection(message.subject); subject = collections[message.subject] = db.collection(message.subject);

0
test
View File