Heartbeat

Author: tylerlong

ringcentral/demos/demo_web_socket.py

@@ -1,17 +1,20 @@
 from dotenv import load_dotenv
-from ringcentral import SDK
-from ringcentral.websocket.events import WebSocketEvents
 import json
 import uuid
 import os
 import asyncio
+import sys
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..', '..')))  # Add the project root to sys.path
+from ringcentral import SDK
+from ringcentral.websocket.events import WebSocketEvents
 
 
 def on_message(message):
     print("\n WebSocket message:\n")
     print(json.loads(message))
-    print("\n User email:\n")
-    print(json.loads(message)[1]["contact"]["email"])
+    if(len(json.loads(message)) > 1):
+        print("\n User email:\n")
+        print(json.loads(message)[1]["contact"]["email"])
 
 
 def on_created(web_socket_client):

ringcentral/websocket/web_socket_client.py

@@ -6,7 +6,7 @@
 from .events import WebSocketEvents
 import json
 import asyncio
-
+import uuid
 
 class WebSocketClient(Observable):
     def __init__(self, platform):
@@ -48,6 +48,17 @@ async def open_connection(self, ws_uri, ws_access_token):
             self._web_socket = connection_info
             self._is_ready = True
             self.trigger(WebSocketEvents.connectionCreated, self)
+
+            # heartbeat every 10 minutes
+            async def timer_function():
+                while True:
+                    if self._done:
+                        timer.cancel()
+                        break
+                    await asyncio.sleep(600)
+                    await self.send_message([{"type": "Heartbeat", "messageId": str(uuid.uuid4())}])
+            timer = asyncio.create_task(timer_function())
+
             await asyncio.sleep(0)
             while True:
                 message = await websocket.recv()