Module livekit.plugins.telnyx.common

def get_api_key(api_key: str | None = None) -> str:
    resolved_key = api_key or os.environ.get("TELNYX_API_KEY")
    if not resolved_key:
        raise ValueError("Telnyx API key required. Set TELNYX_API_KEY or provide api_key.")
    return resolved_key

class SessionManager:
    def __init__(self, http_session: aiohttp.ClientSession | None = None) -> None:
        self._session = http_session
        self._owns_session = False

    def ensure_session(self) -> aiohttp.ClientSession:
        if not self._session:
            self._session = aiohttp.ClientSession()
            self._owns_session = True
        return self._session

    async def close(self) -> None:
        if self._owns_session and self._session:
            await self._session.close()
            self._session = None