o zsg@sddlmZmZmZmZmZddlmZddlm Z m Z ddl m Z m Z ddlmZmZmZmZmZddlmZGdd d Zd S) )AnyDictLiteralOptionalUnion)warn) HTTPErrorResponse)FunctionsHttpErrorFunctionsRelayError) AsyncClientFunctionRegion is_http_url is_valid_jwtis_valid_str_arg) __version__c @seZdZ  ddededededeef dd Z  dd e d dedeeeefd eee e fd e f ddZ ded dfddZ ddedeed eeeffddZdS)AsyncFunctionsClientTNurlheaderstimeoutverifyproxyc CsVt|std||_ddti||_t|j|jt|tt||ddd|_ dS)Nz#url must be a valid HTTP URL stringz User-Agentzsupabase-py/functions-py vT)base_urlrrrrfollow_redirectshttp2) r ValueErrorrrrr boolintabs_client)selfrrrrrr"\/var/www/html/minecraft/env/lib/python3.10/site-packages/supafunc/_async/functions_client.py__init__s    zAsyncFunctionsClient.__init__method)GETOPTIONSHEADPOSTPUTPATCHDELETEjsonreturnc sh|jj||||dIdH}z|W|Sty3}zt|dp,d|jjd|d}~ww)N)r-rerrorz9An error occurred while requesting your edge function at .)r requestraise_for_statusrr r-getr)r!r%rrr-responseexcr"r"r#_request+s zAsyncFunctionsClient._requesttokencCs$t|stdd||jd<dS)zUpdates the authorization header Parameters ---------- token : str the new jwt token sent in the authorization header z5token must be a valid JWT authorization token string.zBearer AuthorizationN)rrr)r!r7r"r"r#set_auth=s zAsyncFunctionsClient.set_auth function_nameinvoke_optionsc s&t|s td|j}d}d}|dur]||di|dd}|d}|rEt|ts;td|dt|}|jd krE|j|d <|d }t|t rTd|d <n t|t r]d |d <|j d|j d|||dIdH}|jd}|r|dkrt |d|dkr|} | 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` z(function_name must a valid string value.Nz text/plainr responseTyperegionzUse FunctionRegion()anyzx-regionbodyz Content-Typezapplication/jsonr)/)rr-zx-relay-headertruer/r-)rrrupdater3 isinstancerrvaluestrdictr6rr r-content) r!r:r;rr@ response_typer=r4is_relay_errordatar"r"r#invokeKs@            zAsyncFunctionsClient.invoke)TN)NN)N)__name__ __module__ __qualname__rFrrrrr$rrr r6r9rbytesrLr"r"r"r#rsH   rN)typingrrrrrwarningsrhttpxrr errorsr r utilsr rrrrversionrrr"r"r"r#s