U #i @s^ddlmZmZmZmZmZddlmZmZddl m Z m Z ddl m Z mZGdddZdS) )AnyDictLiteralOptionalUnion) HTTPErrorResponse)FunctionsHttpErrorFunctionsRelayError) SyncClient __version__c@seZdZdeeeedddZdedee eeefdfe ee e fe ddd Z edd d d Zdee ee eefd ddZdS)SyncFunctionsClientT)urlheaderstimeoutverifycCs<||_ddti||_t|j|jt||ddd|_dS)Nz User-Agentzsupabase-py/functions-py vT)base_urlrrrZfollow_redirectsZhttp2)rr rr bool_client)selfrrrrrC/tmp/pip-unpacked-wheel-snf83r8y/supafunc/_sync/functions_client.py__init__ szSyncFunctionsClient.__init__N)GETOPTIONSHEADPOSTPUTPATCHDELETE)methodrrjsonreturnc Csl|jj||||d}z |WnFtk rf}z(t|dpPd|jjd|W5d}~XYnX|S)N)r"rerrorz9An error occurred while requesting your edge function at .)rrequestraise_for_statusrr r"getr)rr!rrr"responseexcrrr_requests zSyncFunctionsClient._request)tokenr#cCsd||jd<dS)zUpdates the authorization header Parameters ---------- token : str the new jwt token sent in the authorization header zBearer AuthorizationN)r)rr,rrrset_auth+s zSyncFunctionsClient.set_auth) function_nameinvoke_optionsr#c Cs|j}d}d}|dk r||di|dd}|d}|rdt|trd|dkrd||d<|d}t|trd|d <nt|trd |d <|jd |j d |||d }|jd}|r|dkrt | d|dkr| } n|j } | S)aInvokes a function Parameters ---------- function_name : the name of the function to invoke invoke_options : object with the following properties `headers`: object representing the headers to send with the request `body`: the body of the request `responseType`: how the response should be parsed. The default is `json` Nz text/plainrZ responseTyperegionanyzx-regionbodyz Content-Typezapplication/jsonr/)rr"zx-relay-headertruer$r") rupdater( isinstancestrlowerstripdictr+rr r"content) rr/r0rr3Z response_typer1r)Zis_relay_errordatarrrinvoke6s6          zSyncFunctionsClient.invoke)T)NN)N)__name__ __module__ __qualname__r8rintrrrrrrrr+r.bytesr>rrrrr s"   rN)typingrrrrrZhttpxrrerrorsr r utilsr r rrrrrs