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

camera controler

Browse Source
This commit is contained in:
Sem van der Hoeven
2023-06-02 12:10:33 +02:00
parent 9cbd7f1be8
commit 8045c0c96e
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
api/index.js
View File

@@ -80,7 +80,7 @@ var connect_to_api = function () {
try { try {
var msg = JSON.parse(message); var msg = JSON.parse(message);
if (msg.type != "IMAGE") { if (msg.type != "IMAGE") {
console.log("got message"); // console.log("got message");
send_events_to_clients(msg); send_events_to_clients(msg);
} else { } else {
console.log("got image"); console.log("got image");

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

@@ -136,7 +136,7 @@ class ApiListener(Node):
def handle_responses(self): def handle_responses(self):
while True: while True:
if len(self.message_queue) > 0 and self.websocket is not None and self.event_loop is not None: if len(self.message_queue) > 0 and self.websocket is not None and self.event_loop is not None:
self.get_logger().info("sending message") # self.get_logger().info("sending message")
asyncio.run(self.publish_message(self.message_queue.pop(0))) asyncio.run(self.publish_message(self.message_queue.pop(0)))
def start_api_thread(self): def start_api_thread(self):

2
src/camera/camera/camera_controller.py
View File

@@ -69,7 +69,7 @@ class CameraController(Node):
encode_param = [int(cv2.IMWRITE_JPEG_QUALITY), 65] encode_param = [int(cv2.IMWRITE_JPEG_QUALITY), 65]
man = cv2.imencode('.jpg', frame, encode_param)[1] man = cv2.imencode('.jpg', frame, encode_param)[1]
self.get_logger().info('Sending video') self.get_logger().info('Sending video')
await self.websocket.send(man.tobytes()) asyncio.ensure_future(self.websocket.send(man.tobytes()),loop=self.event_loop)
else: else:
self.get_logger().info('No websocket connection') self.get_logger().info('No websocket connection')
await asyncio.sleep(1) await asyncio.sleep(1)