%j]dZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddl mZmZddlmZmZmZmZmZddlmZdd lmZmZmZmZmZddlZej<rdd lmZm Z ejBd Z"ejFd Z$Gd deZ%GddeZ&e'dk(rejPe%eyy)z5Non-blocking HTTP client implementation using pycurl.N)BytesIO)httputil)ioloop)utf8 native_str) HTTPRequest HTTPResponse HTTPErrorAsyncHTTPClientmain)app_log)DictAnyCallableUnionOptional)DequeTupleztornado.curl_httpclients | c eZdZ d%dedeeeefddffd Zd&fd Z de de e gdfddfd Z d ed ed ed eddf dZdeddfdZd ededdfdZd&dZd&dZd&dZ d'dej,deedeeddfdZdeddfdZdej,fdZdej,de dedej8ddf dZdej8de egdfd eddfd!Zd"ed#eddfd$ZxZ S)(CurlAsyncHTTPClientN max_clientsdefaultsreturnct||tj|_|jj tj |j|jj tj|jt|Dcgc]}|jc}|_ |jdd|_ tj|_i|_d|_tj&}|jj)||jj+|ycc}w)N)r)super initializepycurl CurlMulti_multisetoptM_TIMERFUNCTION _set_timeoutM_SOCKETFUNCTION_handle_socketrange _curl_create_curls _free_list collectionsdeque _requests_fds_timeoutCurl add_handle remove_handle)selfrridummy_curl_handle __class__s 7lib/python3.12/site-packages/tornado/curl_httpclient.pyrzCurlAsyncHTTPClient.initialize4s H-&&(  61143D3DE 622D4G4GH49+4FG4Fqt((*4FG ++a.       #KKM 01 !!"34Hs Ec|j%|jj|j|jD]}|j |j j t |d|_yN)r-io_loopremove_timeoutr'closerr)r1curlr4s r5r:zCurlAsyncHTTPClient.closeMs\ == $ LL ' ' 6KKD JJL      requestcallbackc|jj|||jjf|j |j dy)Nr)r+appendr8time_process_queuer")r1r=r>s r5 fetch_implzCurlAsyncHTTPClient.fetch_implZsD w$,,2C2C2EFG  !r<eventfdmultidatac tjtjjtj tjj tjtjjtjtjj tjjzi}|tjk(r8||jvr)|jj||j|=yy||}||jvr|jj||jj||j|||j|<y)z_Called by libcurl when it wants to change the file descriptors it cares about. N)r POLL_NONErIOLoopNONEPOLL_INREADPOLL_OUTWRITE POLL_INOUT POLL_REMOVEr,r8remove_handler add_handler_handle_events)r1rDrErFrG event_map ioloop_events r5r$z"CurlAsyncHTTPClient._handle_socketas   fmm00 NNFMM.. OOV]]00   v}}11FMM4G4GG  F&& &TYY ++B/IIbM%U+LTYY ++B/ LL $ $R)<) $E7H T" (0$ff T662)1z r<c d}|jr|jr|dz }|jj}|jj\}}}t j t |||tj|jjjd|_ |j|||jd|jd|jj||jr|jr|sy##t$rI}|j|jj!||t#|d|Yd}~ld}~wwxYw)Nr)headersbufferr=r>queue_start_timecurl_start_timecurl_start_ioloop_timerwrvW)r=coder`)r(r+poppopleftr HTTPHeadersrrAr8currentinfo_curl_setup_requestrr/ Exceptionresetr@r )r1startedr;r=r>rxrgs r5rBz"CurlAsyncHTTPClient._process_queues<G//dnn1 **,8<8N8N8P5($4 (335%i& ((8'+yy{.2ll.B.B.D.I.I.K 1,, (+ ), &KK**40E//dnnHO.! OJJLOO**40\'1MNN Os=.D%% E7.?E22E7r; curl_error curl_messagec|j}d|_|jj||d}|r5|Jt||}|J|j}d}|j d}nQd}|j tj}|j tj}|jdt|d|dz |j tj|j tj|j tj|j tj|j tj |j tj"|j tj$} |dt'|d||d||||dj)d d|j*j-|dz |d | |j3|j4j7|y#t.$r|j1|dYKwxYw) Nrwrrzrx)queue namelookupconnect appconnect pretransfer starttransfertotalredirectr>r=rvz X-Http-Reasonry) r=r|rvrw effective_urlr`reason request_time start_time time_info)rrr0 CurlErrorr|r:getinfor HTTP_CODE EFFECTIVE_URLseekdictNAMELOOKUP_TIME CONNECT_TIMEAPPCONNECT_TIMEPRETRANSFER_TIMESTARTTRANSFER_TIME TOTAL_TIME REDIRECT_TIMEr getr8rArhandle_callback_exceptionrr(r@) r1r;rrrrwr`r|rrs r5rnzCurlAsyncHTTPClient._finishs yy  !!$'h + ++j,7E$ $$::D M LLNFE<< 0 01D LL)=)=>M KKN/048J3KK||F$:$:;LL!4!45||F$:$:; V%<%<=,,v'@'@A,,v001\\&"6"67   = D  O O!"/ ?..E!%!2!2!4ts r5rz-CurlAsyncHTTPClient.handle_callback_exception$s 0(TJr<c*tjSr7)rr.)r1s r5r&z CurlAsyncHTTPClient._curl_create's{{}r<rwrvc &tjtjrJ|j t j d|j t jjtt dr~|j t jt jt jz|j t jt jt jz|j t jtj dj"vrdj"d<dj"vrdj"d<j"j%Dcgc]<\}}dt|j'dt|j'dfz>}}}|D]%}t(j+|st-d |z|j t j.||j t j0t3j4j6|j8j:r!d t<t>t@fd tBffd } n |jD} |j t jF| |j t jHjJ|j t jLjNjPJ|j t jRtCd jPzjTJ|j t jVtCd jTzjXr4|j t jZtjXn |j t jZdj\r*|j t j^j\j`r!|j t jbdn |j t jbdjdrejfrX|j t jhjd|j t jjjfjlrXjnJtqjrjljn} |j t jt| jvjvdk(r/|j t jxt jznjvdk(r/|j t jxt j|nWt-djvz |jt jh|jt jtjrA|j t jd|j t jdn@|j t jd|j t jdj+|j t jjn jdur/|j t jt jn.|j t jt jt jt jt jt jd} hd} | jD]} |j | dj| vr?|jt j|j | jdn]jsj| vr+|j t jjntdjzjdv}jdu}js(|r|r|r"|s t-d|rdnddjd|s|r<jdk(r t-d ttjxsdd!tBd"tBd tBffd# }|j t jj|j t j|jd$k(r8|j t jtjxsdnW|j t jd|j t jtjxsdj/jJjjdk(r/|j t jt jznVjdk(r/|j t jt j|nt-d%jztqjrjj}|j t j|tjd&jj jnJ|jt jtjd'jj j*|j t jjj*|j t jjj t-d(tjdkDr |j t jdjj|yycc}}w#t$r$|j t jhdYwxYw))Nru PROTOCOLSExpectPragmas%s: %sASCIIz ISO8859-1z+Illegal characters in header (CR or LF): %rbrcjJjjj|t|Sr7)streaming_callbackr8 add_callbacklen)rr=r1s r5write_functionz?CurlAsyncHTTPClient._curl_setup_request..write_function]s811=== ))'*D*DaH1v r<iz Mozilla/5.0 (compatible; pycurl)z gzip,deflatebasicdigestzUnsupported proxy_auth_mode %srF)GETPOSTPUTHEAD>PATCHDELETEOPTIONSTzunknown method )rrrz Body must znot zbe None for method z+ (unless allow_nonstandard_methods is true)rz!Body must be None for GET requestoffsetorigincHj||tjSr7)rr SEEKFUNC_OK)rrrequest_buffers r5rz5CurlAsyncHTTPClient._curl_setup_request..seeks##FF3)))r<rzUnsupported auth_mode %sz%s %s (username: %r)%s %sz,ssl_options not supported in curl_httpclient)kcurl_log isEnabledForloggingDEBUGr rVERBOSE DEBUGFUNCTION _curl_debughasattrr PROTO_HTTP PROTO_HTTPSREDIR_PROTOCOLSURLrurlrvget_allencode CR_OR_LF_REsearch ValueError HTTPHEADERHEADERFUNCTION functoolspartial_curl_header_callbackheader_callbackrrbytes bytearrayintwrite WRITEFUNCTIONFOLLOWLOCATIONfollow_redirects MAXREDIRS max_redirectsconnect_timeoutCONNECTTIMEOUT_MSrequest_timeout TIMEOUT_MS user_agent USERAGENTnetwork_interface INTERFACEdecompress_responseENCODING proxy_host proxy_portPROXY PROXYPORTproxy_usernameproxy_passwordrencode_username_password PROXYUSERPWDproxy_auth_mode PROXYAUTHHTTPAUTH_BASICHTTPAUTH_DIGESTunsetopt TypeError validate_certSSL_VERIFYPEERSSL_VERIFYHOSTca_certsCAINFO allow_ipv6 IPRESOLVE IPRESOLVE_V4IPRESOLVE_WHATEVERHTTPGETrUPLOADNOBODYvaluesmethod CUSTOMREQUESTallow_nonstandard_methodsKeyErrorbodyrr READFUNCTIONread SEEKFUNCTION POSTFIELDSIZEr INFILESIZE auth_username auth_password auth_modeHTTPAUTHUSERPWDdebug client_certSSLCERT client_keySSLKEY ssl_options threading active_countNOSIGNALprepare_curl_callback)r1r;r=rwrvkvencoded_headersliner credentials curl_optionscustom_methodso body_expected body_presentruserpwdrs` ` @r5rz'CurlAsyncHTTPClient._curl_setup_request*s    / KK * KK,,d.>.> ?  K  KK((&*;*;f>P>P*P Q KK..0A0AFDVDV0V W FJJ 7;; 78 7?? *(*GOOH % 7?? *(*GOOH %  //1 21 !}##G,jm.B.B;.OP Q1  $D!!$' !NQU!UVV$ F%%7  ! !   **GW5L5L   % % %y(8"9 c  $\\N F((.9 F))7+C+CD F$$g&;&;<&&222 F,,c$9P9P2P.QR&&222 F%%s4'2I2I+I'JK    KK((*W5G5G*H I KK((*L M  $ $ KK(('*C*C D  & & KK 8 KK .   '"4"4 KK g&8&8 9 KK(('*<*< =%%--999&??**G,B,B  F//=&&.'2I2IW2T F,,f.C.CD((H4 F,,f.D.DE 4w7N7NN . fll+ MM&-- .  KK--q 1 KK--q 1 KK--q 1 KK--q 1    ' KK w'7'7 8     & KK((&*=*= > KK((&*C*C D >>KK==MM  8$$&A KK5 !' >>\ ) MM&.. / KK W^^4d ;  . .'..N2R KK,,gnn =,w~~=> >*BB ||4/ 00l] "/vB6H L~~& !!DEE$T',,*<"%=>N *S *# *# * KK++^-@-@ A KK++T 2~~' F00#gll6Hb2IJ FMM40 F--s7<<3E2/FG  ,((4 44  (G,=,=,H FOOV-B-BC""h. FOOV-C-CD !;g>O>O!OPP77%%w'<'<G KK 0 NN& %%   MM&.. ) NN7GNNGKK @    * KK(;(; <    ) KK w'9'9 :    *KL L  ! ! #a ' KK +  ( ( 4  ) )$ / 5y ~ . FLL"- .s Aq+q##)rrrheader_line_bytescnt|jd}||jj|||j }|j dr/|j  tj|\}}}d|z}|sy|j|y#tj$rYywxYw)Nlatin1zHTTP/zX-Http-Reason: %s) rdecoder8rrstrip startswithclearrparse_response_start_lineHTTPInputError parse_line)r1rvrr. header_line_version_coders r5rz)CurlAsyncHTTPClient._curl_header_callback s !!2!9!9(!CD  & LL % %o{ C"((*  ! !' * MMO ,4,N,N-)5&2F:  ;' **  s+BB43B4 debug_type debug_msgc0d}|dk(r0t|}tjd|jy|dvr;t|}|j D]}tjd|||y|dk(rtjd|||yy)N)I<>r?r@rz%s)rurrz%s %r)rrrstrip splitlines)r1r;r< debug_typesr&s r5rzCurlAsyncHTTPClient._curl_debug#s/ ?"9-I NN4!2 3 6 !"9-I!,,.w J(?F/ 1_ NN7K $;Y Gr<) N)rN)NN)!__name__ __module__ __qualname__rrrstrrrr:rrr rCrr$r"rTrZrcrBrr.rnrr&rrrrrr __classcell__)r4s@r5rr3sJN55/7S#X/G5 52 ".6 ~t7K.L )C)S))E)d): # $ ((c(d($+: (Z%)&* 5%kk5%SM5%sm 5%  5%nK#K$Kfkk^0kk^0^0 ^0 %% ^0  ^0@(%%("3%+.(! (  (2 Hc Hc Hd Hr<rc eZdZdededdfdZy)rerrnomessagerNc@tj|d|||_y)Nr{)r __init__rL)r1rLrMs r5rOzCurlError.__init__1s4g. r<)rFrGrHrrIrOr<r5rr0scCDr<r__main__))__doc__r)rrrrerrAiortornadorrtornado.escaperrtornado.httpclientrr r r r tornado.logr typingrrrrr TYPE_CHECKINGrr getLoggerrcompilerrrrF configurerPr<r5r^s <  + 77  # 7  6 7bjj" zH/zHz   zO12Fr<