set and subcribe handler added

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 + '"';