sem/5g_drone_ROS2
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add more websocket connected checks

Browse Source
This commit is contained in:
Sem van der Hoeven
2023-05-29 14:14:55 +02:00
parent 73709a257f
commit f98b44917c
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/api_communication/api_communication/api_listener.py
View File

@@ -73,7 +73,10 @@ class ApiListener(Node):
def publish_message(self, message): def publish_message(self, message):
self.get_logger().info(f'Publishing message: {message}') self.get_logger().info(f'Publishing message: {message}')
asyncio.run(self.websocket.send(message)) if self.websocket is not None:
asyncio.run(self.websocket.send(message))
else:
self.get_logger().error('Trying to publish message but no websocket connection')
def publish_status(self): def publish_status(self):
if self.status_data_received: if self.status_data_received:
@@ -84,7 +87,7 @@ class ApiListener(Node):
def handle_responses(self): def handle_responses(self):
while True: while True:
if len(self.message_queue) > 0: if len(self.message_queue) > 0 and self.websocket is not None:
self.get_logger().info("sending message") self.get_logger().info("sending message")
self.publish_message(self.message_queue.pop(0)) self.publish_message(self.message_queue.pop(0))