>OOf" UddlZddlZddlZddlmZddlmZmZmZddl m Z m Z ddl m Z mZddlmZddlmZmZd gZej*d k(re Ze ed <d Zd ej2fdZnd ej2fdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%e jLde'dd fdZ(e jLde'de'dd defdZ)Gdd Z*y)N)suppress)AnyDictSet)WeakKeyDictionaryWeakSet)ffilib)CurlMOpt)DEFAULT_CACERTCurl AsyncCurlwin32 _selectorsa Proactor event loop does not implement add_reader family of methods required. Registering an additional selector thread for add_reader support. To avoid this warning use: asyncio.set_event_loop_policy(WindowsSelectorEventLoopPolicy()) returnc tvr tStttdt dsSt j ttddl m }|xt<jfd}|_ S)zGet selector-compatible loop Returns an object with ``add_reader`` family of methods, either the loop itself or a SelectorThread instance. Workaround Windows proactor removal of *reader methods. ProactorEventLoopNr )AddThreadSelectorEventLoopc`_tjdjyN)closerpop) asyncio_loop loop_close selector_loopsN/var/www/premiumrankchecker/venv/lib/python3.12/site-packages/curl_cffi/aio.py_close_selector_and_loopz/_get_selector.._close_selector_and_loop0s'",L  NN< .    !) r isinstancegetattrasynciotypewarningswarnPROACTOR_WARNINGRuntimeWarning_asyncio_selectorrr)rrrrrs` @@r _get_selectorr)s : %l+ +,9LdSWj(YZ  &7A3Ml3[[ <0"''  "6 rc|Sr)loops rr)r)<s r timeout_msclientpc6tj|}|dk(r1|jD]}|jt |_y|j j |dz |jtt}|jj|y)zD see: https://curl.se/libcurl/c/CURLMOPT_TIMERFUNCTION.html r0iN) r from_handle_timerscancelrr, call_later process_dataCURL_SOCKET_TIMEOUTCURL_POLL_NONEadd)curlmr1r2 async_curltimers rtimer_functionr?Ps )JR'' E LLN $Y **    # #     u%rsockfdwhatdatactj|}|j}||jvr"|j ||j ||t zr=|j||j|t|jj||tzr=|j||j|t|jj||tzr|jj|yyr)r r4r,_sockfds remove_reader remove_writer CURL_POLL_IN add_readerr8CURL_CSELECT_INr; CURL_POLL_OUT add_writerCURL_CSELECT_OUTCURL_POLL_REMOVEremove)curlr@rAr2rBr=r,s rsocket_functionrPfs)J ??D$$$ 6" 6" l  7 7Q' m  7 7AQR' ""6*rceZdZdZddefdZdZdZdZde fd Z d e d e d e fd Z d e d e fdZ de fdZde fdZde fdZde fdZdZy)rzhWrapper around curl_multi handle to provide asyncio support. It uses the libcurl socket_action APIs.Ncacertcttj|_|xst|_i|_i|_t|_t||ntj|_ |jj|j|_t!|_|j%y)z Parameters: cacert: CA cert path to use, by default, curl_cffi uses certs from ``certifi``. loop: EventLoop to use. N)r curl_multi_init_curlmr _cacert _curl2future _curl2curlsetrDr)r"get_running_loopr, create_task_force_timeout_checkerrr5_setup)selfrRr,s r__init__zAsyncCurl.__init__~s ))+ / 8:13"%% !$*:$@X@X@Z[  --d.A.A.CD 5,>? H++S-@-@ANN40 H''):):; H&&(9(9:rcK|jjttj5|jd{ddd|j j D]b\}}tj|j|j|jrA|jrR|jddtj|jd|_ |jD]8}|j j#||j j%|:|j&D]}|jy7#1swYxYww)z?Close and cleanup running timers, readers, writers and handles.N)r]r6rr"CancelledErrorrWitemsr curl_multi_remove_handlerU_curldone cancelled set_resultcurl_multi_cleanuprDr,rErFr5)r_rOfuturer@r>s rrzAsyncCurl.closes  g,, - --   !--335 (LD&  ( (djj A;;=)9)9);!!$' ( t{{+ mm ,F II # #F + II # #F + , \\ E LLN %   s<4E1E$E!E$ A"E1.E1?B"E1!E$$E.)E1cK |jsytjdd{|jtt E7w)Nr )rUr"sleep socket_actionr9r:ris rr\zAsyncCurl._force_timeouts@;;--" " "   2N C  #s'A A  A rOc|jtj|j|j|j j }||j|<||j|j<|S)znAdd a curl handle to be managed by curl_multi. This is the equivalent of `perform` in the async world.) _ensure_cacertr curl_multi_add_handlerUrnr, create_futurerWrXr_rOrss r add_handlezAsyncCurl.add_handlesa  !!$++tzz:((*"($&* # rr@ ev_bitmaskrcztjd}tj|j||||dS)z#Call libcurl socket_action functionint *r)r newr curl_multi_socket_actionrU)r_r@r}running_handles rrvzAsyncCurl.socket_actions3) $$T[[&*nUa  rc|jstjdy|j||t j d} t j|j|}|tjk(ry|jtk(ri|j|j}|jj}|dk(r|j|n.|j!||j#|dn t%d)z8Call curl_multi_info_read to read data for given socket.z/Curlm alread closed! quitting from process_dataNrrperformzNOT DONE)rUr$r%rvr rr curl_multi_info_readNULLmsg CURLMSG_DONErX easy_handlerBresultrq set_exception _get_errorprint)r_r@r} msg_in_queuecurl_msgrOretcodes rr8zAsyncCurl.process_datas{{ MMK L  6:.www' // \JH388#|||+x';';<"--..a<OOD)&&tT__Wi-PQj!rctj|j|j|jj |jd|j j |dSr)r rmrUrnrXrrW)r_rOs r _pop_futurezAsyncCurl._pop_futuresK $$T[[$**= DJJ-  $$T400rc|j|}|r3|js"|js|jyyyy)z&Cancel a future for given curl handle.N)rrorpr6r{s r remove_handlezAsyncCurl.remove_handles;!!$' &++-0@0@0B MMO1C-6rc|j|}|r4|js#|js|jdyyyy)z,Mark a future as done for given curl handle.N)rrorprqr{s rrqzAsyncCurl.set_results@!!$' &++-0@0@0B   d #1C-6rc|j|}|r4|js#|js|j|yyyy)z2Raise exception of a future for given curl handle.N)rrorpr)r_rO exceptionrss rrzAsyncCurl.set_exceptions@!!$' &++-0@0@0B   +1C-6rcDtj|j||S)z!Wrapper around curl_multi_setopt.)r curl_multi_setoptrU)r_optionvalues rrbzAsyncCurl.setopts$$T[[&%@@r)N)__name__ __module__ __qualname____doc__strr`r^rr\rr|intrvr8rrrqrrbr+rrrrzss ;6D t !C!S!S! "3"C"411 $ $t$ ,$, Ar)+r"sysr$ contextlibrtypingrrrweakrefrr_wrapperr r constr rOr r__all__platformr__annotations__r&AbstractEventLoopr)r:rGrJCURL_POLL_INOUTrMr9CURL_SOCKET_BADrIrLCURL_CSELECT_ERRr def_externrr?rPrr+rrrs  !!.& -<<7$5$7J!7 w'@'@ Hw88   &c&K&&*+#+S+;+c++&BABAr