From f5e0ac2cbeab096e938e1c2fcf3706b3dc86de90 Mon Sep 17 00:00:00 2001
From: dave <david.habereder@gmail.com>
Date: Mon, 31 Mar 2025 14:27:39 +0200
Subject: [PATCH] set and subcribe handler added

---
 lib/ws.js | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/lib/ws.js b/lib/ws.js
index 55e0d14..f8b401c 100644
--- a/lib/ws.js
+++ b/lib/ws.js
@@ -5,9 +5,8 @@ let connections = [];
 
 export function init(cfg, db) {
   wss = new WebSocketServer(cfg);
-  console.log(cfg);
+
   wss.on('connection', ws => {
-    console.log('new connection')
     connections.push(ws);
 
     ws.on('error', console.error);
@@ -20,8 +19,18 @@ export function init(cfg, db) {
 
         switch (message.action) {
           case "set":
+            db.persist(
+              message.subject,
+              message.filter,
+              message.field,
+              message.value
+            );
             break;
           case "subscribe":
+            db.subscribe(
+              message.subject,
+              message.filter
+            ).then(r => ws.send(r));
             break;
           default:
             throw 'invalid action "' + message.action + '"';