di^@ddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZmZmZmZddlZddlmZmZddlmZmZmZmZmZdd lmZej<Zej@d Z!ej@d Z"e r Gd d Z#Gdde$Z%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.ej^d"dZ0d#d$dZ1d%dZ2ej^dZ3dZ4ej^dZ5d&dZ6GddZ7Gd d!Z8y)') annotationsN) SimpleCookie)Path) TYPE_CHECKINGAnyLiteralOptionalUnioncast)ffilib) CurlECodeCurlHttpVersionCurlInfoCurlOpt CurlWsFlag)CurlCffiWarningsHTTP/\d\.\d [0-9]{3} (.*)sHTTP/(\d\.\d) ([0-9]{3}) (.*)c@eZdZUded<ded<ded<ded<ded<y) CurlWsFrameintageflagsoffset bytesleftlenN)__name__ __module__ __qualname____annotations__E/root/funda.leads/venv/lib/python3.12/site-packages/curl_cffi/curl.pyrrs    r"rc&eZdZdZddfd ZxZS) CurlErrorz$Base exception for curl_cffi packagec:t||g|i|||_yN)super__init__code)selfmsgr*argskwargs __class__s r#r)zCurlError.__init__#s! .t.v.26 r")r)r*zUnion[CurlECode, Literal[0]])rrr__doc__r) __classcell__)r/s@r#r%r% s.77r"r%ilcrtj|}tj||dd}|||y)z ffi callback for curl debug infoNr)r from_handlebuffer)curltype_datasizeclientpcallbacktexts r#debug_functionrA4s4w'H ::dD !! $D UD r"cD|rdnddjfd|DS)u Convert a bytes object to a space-separated hex string, e.g. "0a ff 3c". If uppercase=True, letters will be A–F instead of a–f. z{:02X}z{:02x} c3@K|]}j|ywr')format).0bytefmts r# zbytes_to_hex..Cs3CJJt$3s)join)b uppercaserHs @r# bytes_to_hexrM=s#  (XC 8833 33r"ctdtdtdtdtdt dt di}d}|j|d}|t t fvrTt|d|}t||krd nd }tjj|d t|d ||d y |jd}tjj|d||tttfvr tjjd yy#t$rVt|d|}t||krd nd }tjj|d t|d ||d YywxYw)N*<>z< DATAz> DATAz< SSLz> SSL(z...z [z bytes]:  zutf-8rC) CURLINFO_TEXTCURLINFO_HEADER_INCURLINFO_HEADER_OUTCURLINFO_DATA_INCURLINFO_DATA_OUTCURLINFO_SSL_DATA_INCURLINFO_SSL_DATA_OUTgetrMrsysstderrwritedecodeUnicodeDecodeError)r;r<PREFIXESMAX_SHOW_BYTESprefixhex_strpostfixr@s r#debug_function_defaultrgFs_sCS(8gwHN \\% %F %'<==tO^45D ^3" F82c$i[ '7)2NO T;;w'D JJ  xq/ 0],>@STT   &U! T"4#89GI7bUG JJ  xr#d)IgYwirR S  Ts$A'D AE,+E,ctj|}|jtj||dd||zS)zAffi callback for curl write function, directly writes to a bufferN)r r8r_r9)ptrr=nmembuserdatar9s r#buffer_callbackrles8__X &F LLC'*+ 4<r"c|syt|SNr)r)ss r# ensure_intrpns  q6Mr"ctj|}|tj||dd}t|}|tk(s |t k(r|S|||zk7rt jdtd||zS)zHffi callback for curl write function, calls the callback python functionNzWrote bytes != received bytes.r2 stacklevel) r r8r9rpCURL_WRITEFUNC_PAUSECURL_WRITEFUNC_ERRORwarningswarnr)rir=rjrkr?wrotes r#write_callbackrytstx(H SZZU+A. /E u E $$1E(E    6TUV 4<r"cg}|}|r=|jtj|j|j}|r=t j ||S)z%Converts curl slist to a python list.)appendr stringr<nextrcurl_slist_free_all)headresultris r# slist_to_listrsK F C  cjj*+hh D! Mr"ceZdZdZdZdddZddZddZddZddZ dd Z d d Z d!d Z d"d Z d#d$d ZddZd%d&dZd'dZ d% d&dZd(dZddZd)dZed*dZed+dZddZd,dZej8fd-dZd.d/dZy)0Curlz; Wrapper for ``curl_easy_*`` functions of libcurl. iNcj|r|ntj|_tj|_tj|_tj|_|xst|_ d|_ d|_ d|_ d|_ d|_tjdd|_||_|j%tjd|j&|_tjd|_tjd|_tjd|_y)z Parameters: cacert: CA cert path to use, by default, certs from ``certifi`` are used. debug: whether to show curl debug messages. handle: a curl handle instance from ``curl_easy_init``. FNzchar[]zsize_t *zstruct curl_ws_frame **)rcurl_easy_init_curlr NULL_headers_proxy_headers_resolveDEFAULT_CACERT_cacert _is_cert_set _write_handle_header_handle _debug_handle _body_handlenew _error_buffer_debug_set_error_buffer_WS_RECV_BUFFER_SIZE_ws_recv_buffer_ws_recv_n_recv_ws_recv_p_frame_ws_send_n_sent)r+cacertdebughandles r#r)z Curl.__init__s &V3+=+=+?  !hh / !"&#'"&!% WWXs3    #wwx1J1JK"wwz2 #(A B"wwz2r"ctj|jtj|j }|dk7rt jdtd|jr|jyy)NrzFailed to set error bufferr2rr) r_curl_easy_setoptrr ERRORBUFFERrrvrwrrrr+rets r#rzCurl._set_error_buffersT##DJJ0C0CTEWEWX !8 MM6TU V ;; JJL r"c|jtjd|jtjdy)zSet debug to Truer TN)setoptrVERBOSE DEBUGFUNCTIONr+s r#rz Curl.debugs( GOOQ' G))40r"c$|jyr'closers r#__del__z Curl.__del__  r"c>|dk(ry|j|g|}||yrn) _get_error)r+errcoder-errors r# _check_errorzCurl._check_errors1 a< /$/  K r"c |dk7r|tj|jjd}dj |Dcgc] }t |c}}t d|d|d|dtt| Sycc}w) NrbackslashreplaceerrorsrCz Failed to z , curl: (z) zK. See https://curl.se/libcurl/c/libcurl-errors.html first for more details.)r*) r r|rr`rJstrr%r r)r+rr-errmsgaactions r#rzCurl._get_errors a<ZZ 2 23::BT:UFXXt4!s1v45FVHIgYbA)W-   4sBc |jydddddd}|j|dzdz}|dk(s|dk(rtj||}n|tj k(r[tj |}||_tj|jtjtjne|tjk(r[tj |}||_ tj|jtjtjn|tjk(rktj |}||_tj|jtjtjtj }ny|tjk(rktj |}||_ tj|jtjtjtj}n|tj k(ru|durt"}tj |}||_tj|jtj tj&tj(}ns|dk(r_t+|t,r1tj.tj0tj2tj4tj6tj8tj:tj<tj>tj@tjBtjDtjFtjHh}tJjLjOd r-||vr)tQjRd }|jU|d }n|jU}n|}|tjVk(r||_,nt[d ||tj\k(rY|D]'}tj^|j`||_0)tj|j||j`} n|tjbk(rX|D]'} tj^|jd| |_2)tj|j||jd} n|tjfk(rx|D]G} t+| t,r| jU} tj^|jh| |_4Itj|j||jh} n!tj|j||} |jk| d|||tj.k(rd|_6| S)aWrapper for ``curl_easy_setopt``. Args: option: option to set, using constants from CurlOpt enum value: value to set, strings will be handled automatically Returns: 0 if no error, see ``CurlECode``. rlong*zchar*zvoid*int64_t*)r'i Ni0ui@rTwinFstrictrzOption unsupported: r)7rr\r rr WRITEDATA new_handlerrr WRITEFUNCTIONrl HEADERDATArHEADERFUNCTIONryrrgrrA DEBUGDATA isinstancerCAINFOCAPATH PROXY_CAINFO PROXY_CAPATHSSLCERTSSLKEYCRLFILE ISSUERCERTSSH_PUBLIC_KEYFILESSH_PRIVATE_KEYFILE COOKIEFILE COOKIEJAR NETRC_FILEUNIX_SOCKET_PATHr]platform startswithlocalegetpreferredencodingencode POSTFIELDSrNotImplementedError HTTPHEADERcurl_slist_appendr PROXYHEADERrRESOLVErrr) r+optionvalue input_option value_typec_value filepath_optsencheaderr proxy_headerresolves r#rz Curl.setopts^ ::  "%%v%&?@  J*$<ggj%0G w(( (nnU+G!(D   ! ! G1133F3F w)) )nnU+G")D   ! ! G22C4G4G w,, ,nnU+G!(D   ! !$**g.C.CSEWEW X&&F w-- -nnU+G")D   ! ! G22C4F4F ''F w,, ,}.nnU+G!(D   ! !$**g.C.CSEWEW X&&F 7 "%% NNNN((((OONNOO&&..//&&%%&&,,! <<**51f 6M 55e >,,TZZ8  DKK Kr"cd|_|j/tj|j|j t j |_y)z8Reset all curl options, wrapper for ``curl_easy_reset``.FN)rrrcurl_easy_resetrr rrrs r#resetz Curl.resets=! :: !    +  " " $ r"ct}|D]D}|jjds#|j|ddj F|S)zExtract ``cookies.SimpleCookie`` from header lines. Parameters: headers: list of headers in bytes. Returns: A parsed cookies.SimpleCookie instance. s set-cookie: N)rlowerrloadr`)r+headerscookiers r#parse_cookie_headerszCurl.parse_cookie_headerssP ,~ 2F||~((9 F23K..01 2 r"cVtj|}|r|jdSdS)zTExtract reason phrase, like ``OK``, ``Not Found`` from response status line.r r")REASON_PHRASE_REmatchgroup) status_linems r#get_reason_phrasezCurl.get_reason_phrases)  " "; /qwwqz'C'r"ctj|}|stjddfS|j ddk(rtj }nZ|j ddk(rtj }n5|j ddk(rtj}ntj}t|j d}|j d}|||fS) zfParse status line. Returns: http_version, status_code, and reason phrase rr"r z2.0z1.1z1.0r2r3) STATUS_LINE_RErrV1_0rV2_0V1_1NONEr)rr http_version status_codereasons r#parse_status_linezCurl.parse_status_lines   -"''C/ / 771: *//L WWQZ5 *//L WWQZ5 *//L*//L!''!*o [&00r"c,|j|jr&tj|jd|_t j |j |j't j |jd|_yy)zAClose and cleanup curl handle, wrapper for ``curl_easy_cleanup``.N)rrrcurl_easy_cleanupr releaserrrs r#rz Curl.closesk &&( ::  ! !$** -DJ D&&'    + KK,, -#'D  ,r"cj|j tdtj|j|j|j |j |j}|j|d|jd}tj|jd|j d|fS)zReceive a frame from a websocket connection. Returns: a tuple of frame content and curl frame meta struct. Raises: CurlError: if failed. Nz/Cannot receive websocket data on closed handle.WS_RECVr) rr%r curl_ws_recvrrrrrr r9)r+rframes r#ws_recvz Curl.ws_recvs :: MN N JJ   % %   ! !   #y)%%a(zz$../0I$2F2Fq2IJEQQr"c |j tdtj|}t j |j|t ||jd|}|j|d|jdS)a Send data to a websocket connection. Args: payload: content to send. flags: websocket flag to set for the frame, default: binary. Returns: 0 if no error. Raises: CurlError: if failed. z,Cannot send websocket data on closed handle.rWS_SEND) rr%r from_bufferr curl_ws_sendrrr)r+payloadrr9rs r#ws_sendz Curl.ws_send-sv :: JK K) JJG d.B.BAu  #y)##A&&r"cvtjd||z}|j|tjS)aClose a websocket connection. Shorthand for :meth:`ws_send` with close code and message. Note that to completely close the connection, you must close the curl handle after this call with :meth:`close`. Args: code: close code. message: close message. Returns: 0 if no error. Raises: CurlError: if failed. z!H)r)structpackr5rCLOSE)r+r*messager4s r#ws_closez Curl.ws_closeDs2++dD)G3||G:+;+;|<)rrr-rr=r>)rrr-r)rrrrr=r)rrr=zUnion[bytes, int, float, list])r=bytes)T)rrrr<r=r)TT)rr<rr<r=r>)r=r)r=r)r list[bytes]r=r)rr@r=r@)rr@r=z"tuple[CurlHttpVersion, int, bytes])r=ztuple[bytes, CurlWsFrame])r4r@rrr=r)ir")r*rr:r@r=r)rrrr0rr)rrrrrrrrrrrrrr rr staticmethodrr'rr/rBINARYr5r;r!r"r#rrs&381  tl+8Z. 7I20 AE+!+9=+ +0 ! (( 11, (R0;E:K:K'.=r"rcpeZdZdZd d dZddddd d dZed dZd ddZddZ dd Z y)CurlMimez#Wrapper for the ``curl_mime_`` API.Nc|r|n t|_tj|jj|_y)z? Args: curl: Curl instance to use. N)rrrcurl_mime_init_form)r+r:s r#r)zCurlMime.__init__Zs- "Ttv '' (8(89 r") content_typefilename local_pathr<cptj|j}tj||j }|dk7r t d|4tj ||j }|dk7r t d|4tj||j }|dk7r t d|r |r t d|t|tr t|}n#t|tr|j}n|}t|jstd|tj||j }|dk7r t d|Jt|tst|j }tj ||t#|}yy)aAdd a mime part for a mutlipart html form. Note: You can only use either local_path or data, not both. Args: name: name of the field. content_type: content_type for the field. for example: ``image/png``. filename: filename for the server. local_path: file to upload on local disk. data: file content to upload. rzAdd field failed.Nz1Can not use local_path and data at the same time.zFile not found at )rcurl_mime_addpartrHcurl_mime_namerr%curl_mime_typecurl_mime_filenamerrrr@r`existsFileNotFoundErrorcurl_mime_filedatacurl_mime_datar) r+namerIrJrKr<partrlocal_path_strs r#addpartzCurlMime.addpartbs($$TZZ0  t{{}5 !8/0 0  #$$T<+>+>+@ACax 344  ((x/@ACax 344 $OP P  !*d+!$ZJ.!+!2!2!4!+'..0'*<^)r[z list[dict])r:rer=r>r?) rrrr0r)rX classmethodr^rarrr!r"r#rErEWs{-:'+"&8< $;<;<$ ;<  ;< 6 ;<;< ;)r=rA)9 __future__rrerr7r]rv http.cookiesrpathlibrtypingrrrr r r certifi_wrapperr rconstrrrrrutilsrwherercompilerrr Exceptionr%rUrVrWrXrYrZr[rtru def_externrArMrgrlrpryrrrEr!r"r#rus7" %EELL"2::;<=>7 7 !!  4T>   E=E=P\\r"