o ˳i"@sddlZddlZddlmZmZmZmZmZddlm Z ddl m Z m Z m Z mZddlmZddlmZmZddlmZmZmZdd lmZGd d d ZdS) N)AnyDictLiteralOptionalUnion)warn) AsyncClient HTTPError QueryParamsResponse)URL)FunctionsHttpErrorFunctionsRelayError)FunctionRegion is_http_urlis_valid_str_arg) __version__c@seZdZ    ddededeedeedeedeeddfd d Z   dd e d d e edeeeefdeee e fdee def ddZdeddfddZ ddedeedeeeffddZdS)AsyncFunctionsClientNurlheaderstimeoutverifyproxy http_clientreturncCst|stdt||_dtttdtd||_ t j dkr-t dt dd|dur8t d t dd|durCt d t dd|durNt d t dd|durVt|nd |_|durctt|nd |_|prt|j|j|d d d|_dS)Nz#url must be a valid HTTP URL stringz supabase-py/supabase_functions 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<)rrrfollow_redirectshttp2)r ValueErrorr rrplatformsystemreleasepython_versionrsys version_inforDeprecationWarningboolrintabsrr_client)selfrrrrrrr1^/home/ubuntu/.local/lib/python3.10/site-packages/supabase_functions/_async/functions_client.py__init__sX    zAsyncFunctionsClient.__init__method)GETOPTIONSHEADPOSTPUTPATCHDELETEpathjsonparamsc s|jj|}|p t}||jt|tr'|jj|t||||dIdHn|jj|t||||dIdH}z| W|St yg}zd} t |drP|j } t |dp_d|jjd| |d}~ww)N)datarr>)r=rr> status_codeerrorz9An error occurred while requesting your edge function at .)rjoinpathdictupdater isinstancestrr/requestraise_for_statusr hasattrr@rr=get) r0r4r<rr=r>rresponseexcr@r1r1r2_requestLs8        zAsyncFunctionsClient._requesttokencCsd||jd<dS)zUpdates the authorization header Parameters ---------- token : str the new jwt token sent in the authorization header zBearer AuthorizationN)r)r0rOr1r1r2set_authos zAsyncFunctionsClient.set_auth function_nameinvoke_optionsc s6t|s td|j}t}d}d}|duri||di|dd}|d}|rQt|ts@td|dd d t|}|j d krQ|j |d <| d |j }|d}t|t r`d|d<n t|t rid|d<|j d|g|||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()r ranyzx-regionforceFunctionRegionbodyz Content-Typezapplication/jsonr8)rr=r>zx-relay-headertruerAr=)rr$rr rErKrFrrvaluesetrGrDrNrr=content) r0rRrSrr>rY response_typerUrLis_relay_errorr?r1r1r2invokezsD             zAsyncFunctionsClient.invoke)NNNN)NNN)N)__name__ __module__ __qualname__rGrrr-r,rr3rlistrr r rNrQrbytesr`r1r1r1r2rsZ = #  r)r%r)typingrrrrrwarningsrhttpxrr r r yarlr errorsrrutilsrrrversionrrr1r1r1r2s