Draft: Resolve "Add websockets"

Closes #11

api_wrap_socket.py

             parsed = self.token.validate(token)
             print(str(parsed))
             if parsed['valid']:
-                # client = self.clients.get(parsed['client_id'])
-                # if client: 
-                #     self.client = client
-                allow = True
+                client = self.clients.get(parsed['client_id'])
+                if client: 
+                    self.client = client
+                    allow = True
         return allow
         
     def onOpen(self):
         print("Client connecting: {}".format(request.peer))
         allow = self.auth(request)
         print(f"Allowed: {allow}")
+        # if allow:
+        #     setup queue consumer 
 
     def onMessage(self, payload, isBinary):
         if not isBinary:
             if (msg := payload.decode("utf-8")).startswith("@a"):
                 self.factory.broadcast("Got message: " + msg)
+                # identify client 
+                # deliver to client-outbox rmq
 
     def connectionLost(self, reason):
         WebSocketServerProtocol.connectionLost(self, reason)
         print("broadcasting message '{}' to {} clients ...".format(msg, len(self.clients)))
         for cid in self.clients:
             self.clients[cid].sendMessage(msg.encode('utf-8'))
+    
+    def deliver(self, cid, msg):
+        print("delivering message '{}' to {} client ...".format(msg, cid))
+        if cid in self.clients:
+            self.clients[cid].sendMessage(msg.encode('utf-8'))
 
 
 def run():
     ServerFactory = SubscriptionServerFactory
-    factory = ServerFactory("ws://localhost:9000")
+    factory = ServerFactory("ws://localhost:8088")
 
     factory.protocol = SubscriptionServerProtocol
     listenWS(factory)