File tree Expand file tree Collapse file tree 1 file changed +12
-13
lines changed
formant_ros2_adapter/scripts/components/subscriber Expand file tree Collapse file tree 1 file changed +12
-13
lines changed Original file line number Diff line number Diff line change 1
- # from cv_bridge import CvBridge
2
- # import cv2
1
+ from cv_bridge import CvBridge
2
+ import cv2
3
3
import grpc
4
4
from typing import Dict
5
5
from sensor_msgs .msg import (
51
51
class Ingester :
52
52
def __init__ (self , _fclient : Client ):
53
53
self ._fclient = _fclient
54
- # self.cv_bridge = CvBridge()
54
+ self .cv_bridge = CvBridge ()
55
55
self ._logger = get_logger ()
56
56
57
57
def ingest (
@@ -124,17 +124,16 @@ def ingest(
124
124
)
125
125
126
126
elif msg_type == Image :
127
- self ._logger .info ("ROS IMAGE UNSUPPORTED" )
128
127
# Convert Image to a Formant image
129
- # cv_image = self.cv_bridge.imgmsg_to_cv2(msg, "bgr8")
130
- # encoded_image = cv2.imencode(".jpg", cv_image)[1].tobytes()
131
-
132
- # self._fclient.post_image(
133
- # stream=formant_stream,
134
- # value=encoded_image,
135
- # tags=tags,
136
- # timestamp=msg_timestamp,
137
- # )
128
+ cv_image = self .cv_bridge .imgmsg_to_cv2 (msg , "bgr8" )
129
+ encoded_image = cv2 .imencode (".jpg" , cv_image )[1 ].tobytes ()
130
+
131
+ self ._fclient .post_image (
132
+ stream = formant_stream ,
133
+ value = encoded_image ,
134
+ tags = tags ,
135
+ timestamp = msg_timestamp ,
136
+ )
138
137
139
138
elif msg_type == CompressedImage :
140
139
# Post the compressed image
You can’t perform that action at this time.
0 commit comments