o `g@sddlmZddlmZmZmZmZmZddlm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZdd lmZdd lmZd d lmZmZeeefZGd ddeZdS)) annotations)AnyDictOptionalUnioncast) deprecated)Headers QueryParamsTimeout)BasePostgrestClient) DEFAULT_POSTGREST_CLIENT_HEADERS DEFAULT_POSTGREST_CLIENT_TIMEOUT) CountMethod SyncClient) __version__)SyncRequestBuilderSyncRPCFilterRequestBuilderc@seZdZdZdeedddd5ddZ  d6d7ddZd8ddZd9ddZ d9ddZ d:d d!Z d:d"d#Z e d$d%ed&d;d(d)Z  * *dSyncPostgrestClientzPostgREST client.publicTNschemaheaderstimeoutverifyproxybase_urlstrrrDict[str, str]rUnion[int, float, Timeout]rboolr Optional[str]returnNonec Cs*tj|||||||dtt|j|_dS)Nr)r __init__rrsession)selfrrrrrrr*Q/var/www/html/propose/venv/lib/python3.10/site-packages/postgrest/_sync/client.pyr's  zSyncPostgrestClient.__init__rc Cst|||||dddS)NT)rrrrrfollow_redirectshttp2r)r)rrrrrr*r*r+create_session-sz"SyncPostgrestClient.create_sessioncCs|SNr*r)r*r*r+ __enter__?szSyncPostgrestClient.__enter__cCs |dSr/)aclose)r)exc_typeexctbr*r*r+__exit__Bs zSyncPostgrestClient.__exit__cCs|jdS)z&Close the underlying HTTP connections.N)r(r2r0r*r*r+r2EszSyncPostgrestClient.aclosetableSyncRequestBuilder[_TableT]cCstt|jd|S)zPerform a table operation. Args: table: The name of the table Returns: :class:`AsyncRequestBuilder` /)r_TableTr(r)r7r*r*r+from_IszSyncPostgrestClient.from_cC ||SzAlias to :meth:`from_`.r<r;r*r*r+r7Ss zSyncPostgrestClient.tablez0.2.0z1.0.0zUse self.from_() insteadrcCr=r>r?r;r*r*r+ from_tableWs zSyncPostgrestClient.from_tableFfuncparamsdictcountOptional[CountMethod]headget SyncRPCFilterRequestBuilder[Any]cCsR|rdn|rdnd}|rtdd|int}tt|jd|||t|dS)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)rArBrDrFrGmethodrr*r*r+rpc\s zSyncPostgrestClient.rpc)rr rr rr!rr"rr#rr$r%r&)TN) rr rr!rr"rr#rr$r%r)r%r)r%r&)r7r r%r8)r7r r%r)NFF) rAr rBrCrDrErFr#rGr#r%rH)__name__ __module__ __qualname____doc__rrr'r.r1r6r2r<r7rrr@rOr*r*r*r+rs,      rN) __future__rtypingrrrrr deprecationrhttpxr r r base_clientr constantsrrtypesrutilsrversionrrequest_builderrrr r:rr*r*r*r+s