add try except for sending move request
This commit is contained in:
@@ -53,6 +53,7 @@ app.get("/image", function (req, res) {
|
|||||||
var request = JSON.stringify({
|
var request = JSON.stringify({
|
||||||
command: 5
|
command: 5
|
||||||
});
|
});
|
||||||
|
console.log("sending picture request")
|
||||||
ws.send(request);
|
ws.send(request);
|
||||||
while (received_picture == false) { }
|
while (received_picture == false) { }
|
||||||
res.status(200).send(last_image);
|
res.status(200).send(last_image);
|
||||||
|
|||||||
@@ -135,6 +135,7 @@
|
|||||||
const img = req.response;
|
const img = req.response;
|
||||||
document.getElementById("picture").src = "data:image/png;base64," + img;
|
document.getElementById("picture").src = "data:image/png;base64," + img;
|
||||||
}
|
}
|
||||||
|
console.log("sending picture request")
|
||||||
xhr.send();
|
xhr.send();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -137,18 +137,22 @@ class ApiListener(Node):
|
|||||||
self.get_logger().info(f'Calling move position service with request: {str(self.move_position_request)}')
|
self.get_logger().info(f'Calling move position service with request: {str(self.move_position_request)}')
|
||||||
|
|
||||||
|
|
||||||
self.future = self.move_position_client.call_async(self.move_position_request)
|
try:
|
||||||
rclpy.spin_until_future_complete(self, self.future)
|
self.future = self.move_position_client.call_async(self.move_position_request)
|
||||||
result = self.future.result()
|
rclpy.spin_until_future_complete(self, self.future)
|
||||||
message_result = {}
|
result = self.future.result()
|
||||||
message_result['type'] = ResponseMessage.MOVE_DIRECTION_RESULT.name
|
message_result = {}
|
||||||
if result.success == True:
|
message_result['type'] = ResponseMessage.MOVE_DIRECTION_RESULT.name
|
||||||
self.get_logger().info('Move position service call success')
|
if result.success == True:
|
||||||
message_result['success'] = True
|
self.get_logger().info('Move position service call success')
|
||||||
else:
|
message_result['success'] = True
|
||||||
self.get_logger().error('Move position service call failed')
|
else:
|
||||||
message_result['success'] = False
|
self.get_logger().error('Move position service call failed')
|
||||||
self.message_queue.append(json.dumps(message_result))
|
message_result['success'] = False
|
||||||
|
self.message_queue.append(json.dumps(message_result))
|
||||||
|
except Exception as e:
|
||||||
|
self.get_logger().error('Something went wrong while sending a move position request!\n' + str(e))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def consume_message(self, message):
|
def consume_message(self, message):
|
||||||
|
|||||||
Reference in New Issue
Block a user