diff options
Diffstat (limited to 'packages/meshbay-node')
| -rw-r--r-- | packages/meshbay-node/src/meshbay_node/transport/webrtc_server.py | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/packages/meshbay-node/src/meshbay_node/transport/webrtc_server.py b/packages/meshbay-node/src/meshbay_node/transport/webrtc_server.py index 15c8f66..1d10aa8 100644 --- a/packages/meshbay-node/src/meshbay_node/transport/webrtc_server.py +++ b/packages/meshbay-node/src/meshbay_node/transport/webrtc_server.py @@ -298,6 +298,18 @@ class WebRTCPeerSession: except Exception: pass + hub_ws = self._ctx.get("hub_ws") + if hub_ws and self._group_id: + try: + import json as _json + asyncio.ensure_future(hub_ws.send(_json.dumps({ + "type": "chat_notify", + "group_id": self._group_id, + "sender_name": sender_name, + }))) + except Exception: + pass + self._send({"type": "ack", "v": MNP_VERSION}) def _do_chat_history(self, msg: dict) -> None: |