o i.@sddlmZddlZddlZddlmZmZmZmZm Z ddl m Z ddl m Z ddlmZmZmZmZddlmZdd lmZdd lmZmZdd lmZdd lmZd dlmZm Z m!Z!GdddeZ"dS)) annotationsN)AnyDictOptionalUnioncast)warn) deprecated) AsyncClientHeaders QueryParamsTimeout)URL)BasePostgrestClient) DEFAULT_POSTGREST_CLIENT_HEADERS DEFAULT_POSTGREST_CLIENT_TIMEOUT) CountMethod) __version__)AsyncRequestBuilderAsyncRPCFilterRequestBuilder RequestConfigc@seZdZdZdedddddd5ddZd6ddZd7ddZd8ddZd8ddZ d9d d!Z d9d"d#Z e d$d%e d&d9d'd(Z  ) )d:d;d3d4ZdS)<AsyncPostgrestClientzPostgREST client.publicN)schemaheaderstimeoutverifyproxy http_clientbase_urlstrrrDict[str, str]r Union[int, float, Timeout, None]rOptional[bool]r Optional[str]r Optional[AsyncClient]returnNonec Csdtttdtd|}tjdkrtdtdd|dur*tdtdd|dur5td tdd|dur@td tdd|durHt |nd |_ t |t rR|n |dur\t t|nt|_tj|t||||j|j |d |p}t||j||j |d d d |_dS)Nzsupabase-py/postgrest-py vpython)z X-Client-InfozX-Supabase-Client-Platformz"X-Supabase-Client-Platform-VersionzX-Supabase-Client-Runtimez!X-Supabase-Client-Runtime-Version) zPython versions below 3.10 are deprecated and will not be supported in future versions. Please upgrade to Python 3.10 or newer.r) stacklevelzVThe 'timeout' parameter is deprecated. Please configure it in the http client instead.zUThe 'verify' parameter is deprecated. Please configure it in the http client instead.zTThe 'proxy' parameter is deprecated. Please configure it in the http client instead.T)rrrrr)r!rrrrfollow_redirectshttp2)rplatformsystemreleasepython_versionsys version_inforDeprecationWarningboolr isinstancer intabsrrr__init__rr rsession)selfr!rrrrrr r>U/home/ubuntu/transcripts/venv/lib/python3.10/site-packages/postgrest/_async/client.pyr;sr      zAsyncPostgrestClient.__init__cCs&tt|j|t|j|j|j|jdS)zSwitch to another schema.)r!rrrrr)rr"r!dictrrrr)r=rr>r>r?riszAsyncPostgrestClient.schemacs|SNr>r=r>r>r? __aenter__tszAsyncPostgrestClient.__aenter__cs|IdHdSrA)aclose)r=exc_typeexctbr>r>r? __aexit__wszAsyncPostgrestClient.__aexit__cs|jIdHdS)z&Close the underlying HTTP connections.N)r<rDrBr>r>r?rDzszAsyncPostgrestClient.aclosetablercCst|j|j||j|jS)zPerform a table operation. Args: table: The name of the table Returns: :class:`AsyncRequestBuilder` )rr<r!joinpathr basic_authr=rIr>r>r?from_~szAsyncPostgrestClient.from_cC ||SzAlias to :meth:`from_`.rMrLr>r>r?rIs zAsyncPostgrestClient.tablez0.2.0z1.0.0zUse self.from_() insteadcCrNrOrPrLr>r>r? from_tables zAsyncPostgrestClient.from_tableFfuncparamsdict[str, str]countOptional[CountMethod]headr7getrc Cs|rdn|rdnd}|rtdd|int}||j|dvr(it|fn|tf\}} t|j|jd|||| |j|} 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=)rYrZrpc) r updaterr rr<r!rJrKr) r=rRrSrUrWrXmethodrjson http_paramsrequestr>r>r?r]s"    zAsyncPostgrestClient.rpc)r!r"rr"rr#rr$rr%rr&r r'r(r))rr"r(r)r(r)r(r))rIr"r(r)NFF) rRr"rSrTrUrVrWr7rXr7r(r)__name__ __module__ __qualname____doc__rr;rrCrHrDrMrIr rrQr]r>r>r>r?rs* L     r)# __future__rr0r4typingrrrrrwarningsr deprecationr httpxr r r r yarlr base_clientr constantsrrtypesrversionrrequest_builderrrrrr>r>r>r?s