diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..30bd623 --- /dev/null +++ b/.gitignore @@ -0,0 +1,2 @@ +.env + diff --git a/index.js b/index.js index ca07a51..828c284 100644 --- a/index.js +++ b/index.js @@ -44,16 +44,6 @@ wss.on('connection', function connection(ws) { executeSet(message, ws).catch(console.error); break; 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]; if (!subject) { subject = collections[message.subject] = db.collection(message.subject); diff --git a/test b/test deleted file mode 100644 index e69de29..0000000