openai4s/storage/connectors.py

• env_secret_name · function · L38-L39 — def env_secret_name(connector_id: str, var: str) -> str
• broker_connector_env · function · L42-L65 — def broker_connector_env(store, connector_id: str, env: dict | None) -> dict
• resolve_connector_env · function · L68-L88 — def resolve_connector_env(store, connector: dict) -> dict
• forget_connector_env · function · L91-L102 — def forget_connector_env(store, connector: dict | None) -> None
• public_connector · function · L105-L117 — def public_connector(connector: dict) -> dict
• ConnectorRepository · class · L120-L226 — class ConnectorRepository
• init · method · L123-L132 — def init( self, connection: sqlite3.Connection, lock: Any, *, clock_ms: Callable[[], int], ) -> None
• list · method · L134-L152 — def list(self) -> list[dict]
• get · method · L154-L158 — def get(self, connector_id: str) -> dict | None
• upsert · method · L160-L209 — def upsert( self, *, connector_id: str, name: str, command, description: str = "", args=None, env=None, enabled: bool = True, ) -> dict: # Preserve the legacy read-then-write boundary. It intentionally does # not widen the shared lock into a new transaction in this extraction.
• set_enabled · method · L211-L215 — def set_enabled(self, connector_id: str, enabled: bool) -> None
• delete · method · L217-L221 — def delete(self, connector_id: str) -> None
• _execute · method · L223-L226 — def _execute(self, sql: str, params: tuple = ()) -> None