~i&C8ddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddlmZmZ ddl Z n#e$r edwxYwejeZGddejZd Zd ZGd d eZGd deZdS))absolute_importN) urlencode)Retry)sdk_core_loggerLogLevelz'Swagger python client requires urllib3.c"eZdZdZdZddZdS) RESTResponsec\||_|j|_|j|_|j|_dSN)urllib3_responsestatusreasondata)selfresps _/root/.openclaw/workspace/.venvs/ark-sdk/lib/python3.11/site-packages/volcenginesdkcore/rest.py__init__zRESTResponse.__init__s) $k k I c|jjS)z-Returns a dictionary of the response headers.)r headers)rs r getheaderszRESTResponse.getheaders$s$,,rNcB|jj||S)z Returns a given response header.)r rget)rnamedefaults r getheaderzRESTResponse.getheader(s$,00w???rr )__name__ __module__ __qualname__rrrrrr r sL ---@@@@@@rr ctjd|||rtjd||rtjd||rDtjd|D]\}}tjd|||rtjd||rdt|tr6 |d}n#t $rt|}YnwxYwtjd|d dSdS) Nzrequest url: %s %szrequest timeout: %szquery params: %sheaders: %s: %szpost params: %sutf-8body: %sTis_body)r debug_requestitems isinstancebytesdecode Exceptionstr) methodurl query_paramsrbody post_paramsrequest_time_outkvs r log_requestr7-sC!"6DDDO%&;=MNNNH%&8,GGG>%j111MMOO > >DAq  ),1 = = = =F%&7EEE F dE " " ! !{{7++ ! ! !4yy !%j$EEEEEEFFs:CC,+C,chtjtjd|dtjd|jtjd|jtjd| D]\}}tjd|||rtjd|j d dSd }d } t|d r| |pd }nt|d d }|r |d|}n#t$rd }YnwxYw|r_ |dd}n#t$rt!|}YnwxYwtjdt#||d dStjdd dS)Nz[Response] request id: %sz X-Tt-Logidz status: %sz reason: %sr"r#r%Tr&irpeekrr$replace)errorsz%response body (preview, %d bytes): %sz.response body (preview): )rdebugxrLOG_DEBUG_WITH_REQUEST_IDrdebug_responser rrr)rhasattrr9getattrr-r,reprlen)r_preload_contentr5r6 preview_len preview_bytescached preview_texts r log_responserIGs 8=?Z\]\g\ght\u\uvvv"<:::"<:::":... $$&&;;1&|Q::::k&z164HHHHHH   q&!! 9 !{ 3 3 :s !FC009$*EE21E2c~eZdZddZdZ ddZ ddZ ddZ dd Z dd Z dd Z dd Z dd Z dS)RESTClientObjectNcB||}|jr tj}n tj}|jr|j}nt j}i}|j |j|d<||j |j }nd}|j |j }tj |j |j}|r:tjd|||||j|j||t%dd ||_dStjd|||||j|j|t%dd||_dS) Nassert_hostnamerLconnectreadFtotal) num_poolsmaxsize cert_reqsca_certs cert_filekey_file proxy_urltimeoutretries)rTrUrVrWrXrYr[r\r )_RESTClientObject__get_proxy verify_sslssl CERT_REQUIRED CERT_NONE ssl_ca_certcertifiwhererNconnection_pool_maxsizerTurllib3Timeoutconnect_timeout read_timeout ProxyManagerrXrYr pool_manager PoolManager) r configuration pools_sizerUrZrVrWaddition_pool_argsr[s rrzRESTClientObject.__init__ls$$]33   # &)II I  $ '$0HH}H  ( 44A4Q 0 1 ?4@'?  " .&0J/!1+      ' 4 !$#!'1&/#E*** ! !% ! !D   !( 3 !$#!'1&/E*** ! !% ! !D   rc|j}|s|jdkra|jr|j}ntjdrtjd}ntjdrtjd}nk|jdkr`|jr|j}nQtjdrtjd}n(tjdrtjd}|S)Nhttp HTTP_PROXY http_proxyhttps HTTPS_PROXY https_proxy)proxyschemersosgetenvrv)rrmrZs r __get_proxyzRESTClientObject.__get_proxys!'  9#v-- +8 - 8IIY|,,8 " , 7 7IIY|,,8 " , 7 7I%00 ,9 - 9IIY}--9 " - 8 8IIY}--9 " - 8 8IrTc |}|dvsJ|r|rtd|pi}|pi}d} |rt|tjrt t fnt tt frtj |} nt|tr6t|dkr#tj |d|d} n=t|tj r|} n |j j d d} d |vrd |d <t|||||||  |d vr |r|d t!|zz }t#jd|d t"jr9d} |t)j|} |j ||| || |} n|d dkr"|j |||d|| |} n|d dkr%|d =|j |||d|| |} nkt|t.r#|} |j ||| || |} n3d} t1d| |j ||||| |} nb#tjj$rK} dt9| jt/| } t1d| d} ~ wwxYw|rZt=| } tjr| j d| _tB"d| jtG| |d| j$cxkrdksnt1| | S)aPerform requests. :param method: http request method :param url: http request url :param query_params: query parameters in the url :param headers: http request headers :param body: request json body, for `application/json` :param post_params: request post parameters, `application/x-www-form-urlencoded` and `multipart/form-data` :param _preload_content: if False, the urllib3.HTTPResponse object will be returned without reading/decoding response data. Default is True. :param _request_timeout: timeout setting for this request. If one number provided, it will be total request timeout. It can also be a pair (tuple) of (connection, read) timeouts. )GETHEADDELETEPOSTPUTPATCHOPTIONSz9body parameter cannot be used with post_params parameter.NrRrrOr[z Content-Typezapplication/json)rrrrr?jsonz{})r2preload_contentr[rz!application/x-www-form-urlencodedF)fieldsencode_multipartrr[rzmultipart/form-dataTzCannot prepare a request message for provided arguments. Please check that your arguments match declared content type.)r r)rrr[rz{0} {1}utf8zresponse body: %si+) http_resp)%upper ValueErrorr*sixPY3intfloatlongrfrgtuplerBrkconnection_pool_kwrr7rresearch IGNORECASErdumpsrequestr. ApiException exceptionsSSLErrorformattyperr rr,loggerdebugrIr )rr/r0r1rr2r3rD_request_timeoutr[ request_bodyrCmsges rrzRESTClientObject.requests#*.....  4 K "'R -R  P*CG,[S%LL#tUZI[\\ +!/0@AAA-u55 +&''1,,!/,Q/6Fq6IKKK,go>> +*':>>y$OOG  ( (&8GN #FCwk7SSS= 5FFF93N6=6= .?? !* 5 5 5##DGG$4c!ff==Ca444 4 5  6QAw /v.. LL,af 5 5 5Q()))ah%%%%#%%%%+++ +s3EI99K AKKc8|d|||||S)Nr}rrDrr1rrr0rr1rDrs rr}zRESTClientObject.GETCs-||E3$+-=-=)5 77 7rc8|d|||||S)Nr~rrrs rr~zRESTClientObject.HEADKs-||FC$+-=-=)5 77 7rc <|d|||||||S)Nrrr1r3rDrr2rrr0rr1r3r2rDrs rrzRESTClientObject.OPTIONSSs3||Is$+)5(3-=-=!% '' 'rc :|d||||||S)Nr)rr1rDrr2r)rr0rr1r2rDrs rrzRESTClientObject.DELETE]s0||Hc$+)5-=-=!% '' 'rc <|d|||||||S)Nrrrrs rrzRESTClientObject.POSTfs3||FC$+)5(3-=-=!% '' 'rc <|d|||||||S)Nrrrrs rrzRESTClientObject.PUTps3||E3$+)5(3-=-=!% '' 'rc <|d|||||||S)Nrrrrs rrzRESTClientObject.PATCHzs3||GS$+)5(3-=-=!% '' 'r)rLN)NNNNTN)NNTN)NNNTN) rrrrr]rr}r~rrrrrr rrrKrKjs3@@@@D&?C>B!%@@@@DJN!7777KO"7777IMCG''''AE7;''''FJ@D''''EI?C''''GKAE''''''rrKceZdZddZdZdS)rNc|r?|j|_|j|_|j|_||_dS||_||_d|_d|_dSr )r rrr2rr)rr rrs rrzApiException.__init__s^  #*DK#*DK!DI$//11DLLL DK DKDIDLLLrcd|j|j}|jr|d|jz }|jr|d|jz }|S)z#Custom error messages for exceptionz({0}) Reason: {1} zHTTP response headers: {0} zHTTP response body: {0} )rr rrr2)r error_messages r__str__zApiException.__str__sy((.t{DK(H(H  <  ;BB  M 9 K 8?? JJ JMr)NNN)rrrrrr rrrrs7          rr) __future__riorloggingryrr_rcrsix.moves.urllib.parserrfr(volcenginesdkcore.observability.debuggerrr ImportError getLoggerrrIOBaser r7rIobjectrKr-rr rrrs'&&&&&   ,,,,,,NNNNNNNNANNNNAAA +? @ @@A  8 $ $@@@@@29@@@"FFF4 k k kFX'X'X'X'X'vX'X'X'v9s AA