o /h @s^ddlmZmZmZmZmZddlmZmZddl m Z m Z ddl m Z mZGdddZdS) )AnyDictLiteralOptionalUnion) HTTPErrorResponse)FunctionsHttpErrorFunctionsRelayError) SyncClient __version__c @seZdZddedededefddZ  dd ed dede eeefdfd e ee e fd e f d dZ ded dfddZ ddede ed e eeffddZdS)SyncFunctionsClientTurlheaderstimeoutverifycCs<||_ddti||_t|j|jt||ddd|_dS)Nz User-Agentzsupabase-py/functions-py vT)base_urlrrrfollow_redirectshttp2)rr rr bool_client)selfrrrrrX/var/www/html/govbot/env/lib/python3.10/site-packages/supafunc/_sync/functions_client.py__init__ s  zSyncFunctionsClient.__init__Nmethod)GETOPTIONSHEADPOSTPUTPATCHDELETEjsonreturnc Cs`|jj||||d}z|W|Sty/}zt|dp(d|jjd|d}~ww)N)r$rerrorz9An error occurred while requesting your edge function at .)rrequestraise_for_statusrr r$getr)rrrrr$responseexcrrr_requests zSyncFunctionsClient._requesttokencCsd||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_optionsc Cs|j}d}d}|durJ||di|dd}|d}|r2t|tr2|dkr2||d<|d}t|trAd|d <n t|trJd |d <|jd |j d |||d }|jd}|rn|dkrnt | d|dkrx| } | S|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/plainr responseTyperegionanyzx-regionbodyz Content-Typezapplication/jsonr /)rr$zx-relay-headertruer&r$) rupdater* isinstancestrlowerstripdictr-rr r$content) rr1r2rr6 response_typer4r+is_relay_errordatarrrinvoke6s2         zSyncFunctionsClient.invoke)T)NN)N)__name__ __module__ __qualname__r;rintrrrrrrrr-r0bytesrCrrrrr s0   rN)typingrrrrrhttpxrrerrorsr r utilsr r rrrrrs