From 696266c3be8c962595583fdc5b69faa9feb7e218 Mon Sep 17 00:00:00 2001
From: codey <codey@code.ee>
Date: Wed, 18 Sep 2024 09:45:45 -0400
Subject: [PATCH] "progress"

---
 cah/websocket_conn.py | 2 +-
 endpoints/cah.py      | 9 ++++++++-
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/cah/websocket_conn.py b/cah/websocket_conn.py
index 2303837..99172c9 100644
--- a/cah/websocket_conn.py
+++ b/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, 
             }
diff --git a/endpoints/cah.py b/endpoints/cah.py
index 7118795..df4a874 100644
--- a/endpoints/cah.py
+++ b/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,
                 }