g rddlmZddlmZmZddlmZmZmZddl m Z m Z ddl m Z mZmZmZGddeZy ) ) annotations)ABCabstractmethod)DictOptionalUnion) BasicAuthTimeout) AsyncClient SyncClient is_http_url is_valid_jwtceZdZdZddd d dZe d d dZddd dd Zdd Zy)BasePostgrestClientzBase PostgREST client.TN)verifyproxycvt|s tdi|||d}|j||||||_y)Nz(base_url must be a valid HTTP URL stringzAccept-ProfilezContent-Profile)r ValueErrorcreate_sessionsession)selfbase_urlschemaheaderstimeoutrrs J/var/www/openai/venv/lib/python3.12/site-packages/postgrest/base_client.py__init__zBasePostgrestClient.__init__sK8$ A B  $%  **8WgvuU ct)N)NotImplementedError)rrrrrrs rrz"BasePostgrestClient.create_session!s "##r )usernamepasswordc|r4t|s tdd||jjd<|S|rt |||j_|Std)a Authenticate the client with either bearer token or basic authentication. Raises: `ValueError`: If neither authentication scheme is provided. .. note:: Bearer token is preferred if both ones are provided. z-token must be a valid JWT authorization tokenzBearer Authorizationz?Neither bearer token or basic authentication scheme is provided)rrrrr auth)rtokenr$r%s rr(zBasePostgrestClient.auth,sk &JK6=eW4EDLL  1  )(H =DLL   Q r cV|jjj||d|S)zSwitch to another schema.r)rrupdate)rrs rrzBasePostgrestClient.schemaHs, ##"(#)   r )rstrrr,rDict[str, str]rUnion[int, float, Timeout]rboolr Optional[str]returnNone)TN) rr,rr-rr.rr/rr0r1zUnion[SyncClient, AsyncClient])r)r0r$zUnion[str, bytes, None]r%zUnion[str, bytes])rr,) __name__ __module__ __qualname____doc__rrrr(rr rrr s #VV V  V , VVV V& # $$ $, $  $  $ ($$-1&( *  $ 8r rN) __future__rabcrrtypingrrrhttpxr r utilsr r rrrr7r rr=s("#(($EEE#Er