fix: use Python SDK update listener (#1496)

* fix: remove output_image parameter in detect_from_image_tf

* fix: use openfoodfacts UpdateListener class

pyproject.toml

@@ -74,7 +74,7 @@ lark = "~1.1.4"
 h5py = "~3.8.0"
 opencv-python-headless = "~4.10.0.84"
 toml = "~0.10.2"
-openfoodfacts = "2.3.4"
+openfoodfacts = "2.4.0"
 imagehash = "~4.3.1"
 peewee-migrate = "~1.12.2"
 diskcache = "~5.6.3"

robotoff/cli/main.py

@@ -59,12 +59,19 @@ def process_updates_since(
     )
 ):
     """Process all updates since a given datetime."""
+    from robotoff import settings
     from robotoff.utils.logger import get_logger
-    from robotoff.workers.update_listener import process_updates_since
+    from robotoff.workers.update_listener import UpdateListener, get_redis_client
 
     logger = get_logger()
     logger.info("Processing Redis updates since %s", since)
-    process_updates_since(since)
+    redis_client = get_redis_client()
+    update_listener = UpdateListener(
+        redis_client=redis_client,
+        redis_stream_name=settings.REDIS_STREAM_NAME,
+        redis_latest_id_key=settings.REDIS_LATEST_ID_KEY,
+    )
+    update_listener.process_updates_since(since)
 
 
 @app.command()

robotoff/settings.py

@@ -200,6 +200,9 @@ def event_api() -> str:
 
 # Name of the Redis stream where Product Opener publishes product updates
 REDIS_STREAM_NAME = os.environ.get("REDIS_STREAM_NAME", "product_updates_off")
+REDIS_LATEST_ID_KEY = os.environ.get(
+    "REDIS_LATEST_ID_KEY", "robotoff:product_updates:latest_id"
+)
 
 # how many seconds should we wait to compute insight on product updated
 UPDATED_PRODUCT_WAIT = float(os.environ.get("ROBOTOFF_UPDATED_PRODUCT_WAIT", 10))