"progress"

cah/websocket_conn.py

@@ -38,7 +38,7 @@ class ConnectionManager:
         
         await self.broadcast({
             "event": "client_connected",
-            "ts": str(time.time()),
+            "ts": int(time.time()),
             "data": {
                 "connected_resource": handshakedClient.resource, 
             }

endpoints/cah.py

@@ -49,12 +49,19 @@ class CAH(FastAPI):
                 if data.get('event') == 'handshake':
                     await self.cah_handshake(websocket,
                                                     data)
+                else:
+                    sender = self.connection_manager.get_connection_by_ws(websocket)
+                    await self.connection_manager.broadcast({
+                        "event": "echo",
+                        "from": sender.get('client').resource,
+                        "data": data,
+                    })
         except WebSocketDisconnect:
             disconnected = self.connection_manager.get_connection_by_ws(websocket)
             self.connection_manager.disconnect(websocket)
             await self.connection_manager.broadcast({
                 "event": "client_disconnected",
-                "ts": time.time(),
+                "ts": int(time.time()),
                 "data": {
                     "disconnected_resource": disconnected.get('client').resource,
                 }