[Exchange Oracle] Support host substitution for CVAT storage config

Author: Bobronium

packages/examples/cvat/exchange-oracle/debug.py

@@ -5,6 +5,7 @@
 from typing import Any
 
 import uvicorn
+from httpx import URL
 
 from src.chain.kvstore import register_in_kvstore
 from src.core.config import Config
@@ -25,7 +26,27 @@ def apply_local_development_patches():
     - Generates ECDSA keys if not already present for local JWT signing,
       and sets the public key in `Config.human_app_config`.
     """
-    import src.utils.webhooks
+    import src.handlers.job_creation
+
+    original_make_cvat_cloud_storage_params = (
+        src.handlers.job_creation._make_cvat_cloud_storage_params
+    )
+
+    def patched_make_cvat_cloud_storage_params(bucket_info: BucketAccessInfo) -> dict:
+        original_host_url = bucket_info.host_url
+
+        if Config.development_config.cvat_in_docker:
+            bucket_info.host_url = str(
+                URL(original_host_url).copy_with(host=Config.development_config.cvat_local_host)
+            )
+        try:
+            return original_make_cvat_cloud_storage_params(bucket_info)
+        finally:
+            bucket_info.host_url = original_host_url
+
+    src.handlers.job_creation._make_cvat_cloud_storage_params = (
+        patched_make_cvat_cloud_storage_params
+    )
 
     def prepare_signed_message(
         escrow_address,

packages/examples/cvat/exchange-oracle/src/.env.template

@@ -121,3 +121,7 @@ LOCALHOST_REPUTATION_ORACLE_URL=
 PGP_PRIVATE_KEY=
 PGP_PASSPHRASE=
 PGP_PUBLIC_KEY_URL=
+
+
+# Development
+DEV_CVAT_IN_DOCKER=

packages/examples/cvat/exchange-oracle/src/core/config.py

@@ -313,6 +313,12 @@ def _missing_(cls, value: str) -> Optional["Environment"]:
         return None
 
 
+class Development:
+    cvat_in_docker = bool(int(os.environ.get("CVAT_IN_DOCKER", "0")))
+    # might be `host.docker.internal` or `172.22.0.1` if CVAT is running in docker
+    cvat_local_host = os.environ.get("CVAT_LOCAL_HOST", "localhost")
+
+
 class Config:
     debug = to_bool(os.environ.get("DEBUG", "false"))
     port = int(os.environ.get("PORT", 8000))
@@ -337,6 +343,7 @@ class Config:
     features = FeaturesConfig
     core_config = CoreConfig
     encryption_config = EncryptionConfig
+    development_config = Development
 
     @classmethod
     def is_development_mode(cls) -> bool: