Integrate compat monitor into resource observability split

backend/web/core/storage_factory.py

@@ -6,12 +6,35 @@
 
 from __future__ import annotations
 
+import importlib
+import os
 from functools import lru_cache
 from typing import Any
 
 
+def _strategy() -> str:
+    return os.getenv("LEON_STORAGE_STRATEGY", "sqlite").strip().lower()
+
+
+def _sandbox_db_path() -> Any:
+    from storage.providers.sqlite.kernel import SQLiteDBRole, resolve_role_db_path
+
+    return resolve_role_db_path(SQLiteDBRole.SANDBOX)
+
+
 @lru_cache(maxsize=1)
 def _supabase_client() -> Any:
+    factory_ref = os.getenv("LEON_SUPABASE_CLIENT_FACTORY")
+    if factory_ref:
+        module_name, sep, attr_name = factory_ref.partition(":")
+        if not sep or not module_name or not attr_name:
+            raise RuntimeError("Invalid LEON_SUPABASE_CLIENT_FACTORY format. Expected '<module>:<callable>'.")
+        module = importlib.import_module(module_name)
+        factory = getattr(module, attr_name)
+        if not callable(factory):
+            raise RuntimeError(f"Supabase client factory {factory_ref!r} must be callable.")
+        return factory()
+
     from backend.web.core.supabase_factory import create_supabase_client
 
     return create_supabase_client()
@@ -30,11 +53,45 @@ def make_cron_job_repo() -> Any:
 
 
 def make_sandbox_monitor_repo() -> Any:
+    if _strategy() == "supabase":
+        from storage.providers.supabase.sandbox_monitor_repo import SupabaseSandboxMonitorRepo
+
+        return SupabaseSandboxMonitorRepo(_supabase_client())
     from storage.providers.sqlite.sandbox_monitor_repo import SQLiteSandboxMonitorRepo
 
     return SQLiteSandboxMonitorRepo()
 
 
+def make_lease_repo(db_path: Any = None) -> Any:
+    if _strategy() == "supabase":
+        from storage.providers.supabase.lease_repo import SupabaseLeaseRepo
+
+        return SupabaseLeaseRepo(_supabase_client())
+    from storage.providers.sqlite.lease_repo import SQLiteLeaseRepo
+
+    return SQLiteLeaseRepo(db_path=db_path or _sandbox_db_path())
+
+
+def make_terminal_repo(db_path: Any = None) -> Any:
+    if _strategy() == "supabase":
+        from storage.providers.supabase.terminal_repo import SupabaseTerminalRepo
+
+        return SupabaseTerminalRepo(_supabase_client())
+    from storage.providers.sqlite.terminal_repo import SQLiteTerminalRepo
+
+    return SQLiteTerminalRepo(db_path=db_path or _sandbox_db_path())
+
+
+def make_chat_session_repo(db_path: Any = None) -> Any:
+    if _strategy() == "supabase":
+        from storage.providers.supabase.chat_session_repo import SupabaseChatSessionRepo
+
+        return SupabaseChatSessionRepo(_supabase_client())
+    from storage.providers.sqlite.chat_session_repo import SQLiteChatSessionRepo
+
+    return SQLiteChatSessionRepo(db_path=db_path or _sandbox_db_path())
+
+
 def make_agent_registry_repo() -> Any:
     from storage.providers.supabase.agent_registry_repo import SupabaseAgentRegistryRepo