comment out cv_bridge

Author: AaronGBoswell

formant_ros2_adapter/scripts/components/subscriber/ingester.py

@@ -1,5 +1,5 @@
-from cv_bridge import CvBridge
-import cv2
+# from cv_bridge import CvBridge
+# import cv2
 import grpc
 from typing import Dict
 from sensor_msgs.msg import (
@@ -51,7 +51,7 @@
 class Ingester:
     def __init__(self, _fclient: Client):
         self._fclient = _fclient
-        self.cv_bridge = CvBridge()
+        # self.cv_bridge = CvBridge()
         self._logger = get_logger()
 
     def ingest(
@@ -124,16 +124,17 @@ def ingest(
                 )
 
             elif msg_type == Image:
+                self._logger.info("ROS IMAGE UNSUPPORTED")
                 # Convert Image to a Formant image
-                cv_image = self.cv_bridge.imgmsg_to_cv2(msg, "bgr8")
-                encoded_image = cv2.imencode(".jpg", cv_image)[1].tobytes()
+                # cv_image = self.cv_bridge.imgmsg_to_cv2(msg, "bgr8")
+                # encoded_image = cv2.imencode(".jpg", cv_image)[1].tobytes()
 
-                self._fclient.post_image(
-                    stream=formant_stream,
-                    value=encoded_image,
-                    tags=tags,
-                    timestamp=msg_timestamp,
-                )
+                # self._fclient.post_image(
+                #     stream=formant_stream,
+                #     value=encoded_image,
+                #     tags=tags,
+                #     timestamp=msg_timestamp,
+                # )
 
             elif msg_type == CompressedImage:
                 # Post the compressed image
@@ -177,7 +178,9 @@ def ingest(
                 except grpc.RpcError as e:
                     return
                 except Exception as e:
-                    self._logger.error("Could not ingest " + formant_stream + ": " + str(e))
+                    self._logger.error(
+                        "Could not ingest " + formant_stream + ": " + str(e)
+                    )
                     return
 
             elif msg_type == PointCloud2:
@@ -193,7 +196,9 @@ def ingest(
                 except grpc.RpcError as e:
                     return
                 except Exception as e:
-                    self._logger.error("Could not ingest " + formant_stream + ": " + str(e))
+                    self._logger.error(
+                        "Could not ingest " + formant_stream + ": " + str(e)
+                    )
                     return
 
             else: