more logs
This commit is contained in:
@@ -121,7 +121,7 @@ class ApiListener(Node):
|
|||||||
self.get_logger().info(f'Consuming message: {message}')
|
self.get_logger().info(f'Consuming message: {message}')
|
||||||
try:
|
try:
|
||||||
message_json = json.loads(str(message))
|
message_json = json.loads(str(message))
|
||||||
self.get_logger().info(f'JSON: {message_json}')
|
self.get_logger().info(f'JSON: {message_json}, type:{type(message_json)}')
|
||||||
if not message_json['command']:
|
if not message_json['command']:
|
||||||
self.get_logger().error('Received message without command')
|
self.get_logger().error('Received message without command')
|
||||||
self.send_available_commands()
|
self.send_available_commands()
|
||||||
@@ -156,9 +156,9 @@ class ApiListener(Node):
|
|||||||
|
|
||||||
async def api_handler(self, websocket):
|
async def api_handler(self, websocket):
|
||||||
self.get_logger().info('New connection')
|
self.get_logger().info('New connection')
|
||||||
if self.websocket is not None:
|
# if self.websocket is not None:
|
||||||
self.get_logger().error('Got a new websocket connection but I am already connected!')
|
# self.get_logger().error('Got a new websocket connection but I am already connected!')
|
||||||
return
|
# return
|
||||||
|
|
||||||
self.websocket = websocket
|
self.websocket = websocket
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user