g3ddlmZddlmZmZmZmZmZddlm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZdd lmZdd lmZd d lmZmZeeefZGd deZy)) annotations)AnyDictOptionalUnioncast) deprecated)Headers QueryParamsTimeout)BasePostgrestClient) DEFAULT_POSTGREST_CLIENT_HEADERS DEFAULT_POSTGREST_CLIENT_TIMEOUT) CountMethod AsyncClient) __version__)AsyncRequestBuilderAsyncRPCFilterRequestBuilderceZdZdZdeeddd ddZ d ddZddZdd Z dd Z dd Z dd Z e d dedddZ d ddZy)AsyncPostgrestClientzPostgREST client.publicTNschemaheaderstimeoutverifyproxyc ztj|||||||tt|j|_y)Nr)r__init__rrsession)selfbase_urlrrrrr s L/var/www/openai/venv/lib/python3.12/site-packages/postgrest/_async/client.pyr"zAsyncPostgrestClient.__init__s; $$   K6 c &t|||||ddS)NT)r%rrrr follow_redirectshttp2r)r$r%rrrr s r&create_sessionz#AsyncPostgrestClient.create_session-s&!  r'cK|SwNr$s r& __aenter__zAsyncPostgrestClient.__aenter__?s  sc@K|jd{y7wr-)aclose)r$exc_typeexctbs r& __aexit__zAsyncPostgrestClient.__aexit__Bskkms cTK|jjd{y7w)z&Close the underlying HTTP connections.N)r#r2r/s r&r2zAsyncPostgrestClient.acloseEsll!!###s (&(cBtt|jd|S)zPerform a table operation. Args: table: The name of the table Returns: :class:`AsyncRequestBuilder` /)r_TableTr#r$tables r&from_zAsyncPostgrestClient.from_Is #7+DLLAeW+FFr'c$|j|SzAlias to :meth:`from_`.r=r;s r&r<zAsyncPostgrestClient.tableSszz%  r'z0.2.0z1.0.0zUse self.from_() insteadc$|j|Sr?r@r;s r& from_tablezAsyncPostgrestClient.from_tableWszz%  r'c|rdn|rdnd}|rtdd|in t}tt|jd|||t |S)aPerform a stored procedure call. Args: func: The name of the remote procedure to run. params: The parameters to be passed to the remote procedure. count: The method to use to get the count of rows returned. head: When set to `true`, `data` will not be returned. Useful if you only need the count. get: When set to `true`, the function will be called with read-only access mode. Returns: :class:`AsyncRPCFilterRequestBuilder` Example: .. code-block:: python await client.rpc("foobar", {"arg": "value"}).execute() .. versionchanged:: 0.10.9 This method now returns a :class:`AsyncRPCFilterRequestBuilder`. .. versionchanged:: 0.10.2 This method now returns a :class:`AsyncFilterRequestBuilder` which allows you to filter on the RPC's resultset. HEADGETPOSTPreferzcount=z/rpc/)json)r rrr#r )r$funcparamscountheadgetmethodrs r&rpczAsyncPostgrestClient.rpc\sZ: cUv;@'8veW%567gi,C0 LLE$.&';=v  r')r%strrrPrDict[str, str]rUnion[int, float, Timeout]rboolr Optional[str]returnNone)TN) r%rPrrQrrRrrSr rTrUr)rUr)rUrV)r<rPrUzAsyncRequestBuilder[_TableT])r<rPrUr)NFF) rIrPrJdictrKzOptional[CountMethod]rLrSrMrSrUz!AsyncRPCFilterRequestBuilder[Any])__name__ __module__ __qualname____doc__rrr"r+r0r6r2r=r<r rrBrOr.r'r&rrs+ "B.N#77 7  7 , 777 74#     ,        $$G!+/IJ!K!(, $ $ $ % $  $  $  +$ r'rN) __future__rtypingrrrrr deprecationr httpxr r r base_clientr constantsrrtypesrutilsrversionrrequest_builderrrrPr:rr.r'r&rfsI"33"//- !N sCx.k .k r'