gddlmZmZmZmZmZddlmZddlm Z m Z ddl m Z m Z ddlmZmZmZmZmZddlmZGdd Zy ) )AnyDictLiteralOptionalUnion)warn) HTTPErrorResponse)FunctionsHttpErrorFunctionsRelayError) AsyncClientFunctionRegion is_http_url is_valid_jwtis_valid_str_arg) __version__c eZdZ ddededededeef dZ dde d dedeeeefd eee e fd e f d Z d ed dfdZ ddedeed eeeffdZy)AsyncFunctionsClientNurlheaderstimeoutverifyproxyc t|s td||_ddti||_t |j|jt |tt||dd|_ y)Nz#url must be a valid HTTP URL stringz User-Agentzsupabase-py/functions-py vT)base_urlrrrrfollow_redirectshttp2) r ValueErrorrrrrboolintabs_client)selfrrrrrs U/var/www/openai/venv/lib/python3.12/site-packages/supafunc/_async/functions_client.py__init__zAsyncFunctionsClient.__init__sr3 < = 6{mD   #XXLL<G %!  method)GETOPTIONSHEADPOSTPUTPATCHDELETEjsonreturnc.K|jj||||d{} |j|S7#t$rJ}t |j j dxsd|jjd|d}~wwxYww)N)r0rerrorz9An error occurred while requesting your edge function at .)r#requestraise_for_statusr r r0getr)r$r(rrr0responseexcs r%_requestzAsyncFunctionsClient._request+s--fcg-VV   % % 'W $ ##G,dNs{{Naabc  s/#B=B?B BAB  BBtokencTt|s tdd||jd<y)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$r;s r%set_authzAsyncFunctionsClient.set_auth=s*E" N O*1%(9 _%r' function_nameinvoke_optionsc(Kt|s td|j}d}d}||j|j di|j dd}|j d}|rHt |t std|dt |}|jd k7r|j|d <|j d }t |trd|d <nt |trd |d <|jd|jd|||d{}|jj d}|r-|dk(r(t|jj d|dk(r|j} | S|j} | S7sw)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,/)rr0zx-relay-headertruer3r0)rrrupdater7 isinstancerrvaluestrdictr:rr r0content) r$r?r@rrF response_typerCr8is_relay_errordatas r%invokezAsyncFunctionsClient.invokeKs .GH H,,$  % NN>--i< =*..~|LM#''1F!&.9.vha89+F3F<<5(*0,,GJ'!%%f-D$$*6'D$'*<' txxj-17'  "))--.>? n6%hmmo&9&9'&BC C F "==?D ##D  sDFFA4F)TN)NN)N)__name__ __module__ __qualname__rLrr!r rr&rrr r:r>rbytesrRr'r%rrs #        }  :-1)- RS$sCx.)  tCH~&   $ :c :d :DH1 12:4.1 tU{ 1r'rN)typingrrrrrwarningsrhttpxr r errorsr r utilsrrrrrversionrrrWr'r%r^s/66%<"kkr'