Xh# UddlZddlZddlZddlmZddlmZddlmZm Z ddl m Z m Z ddl mZddlmZmZdd lmZd gZej*d k(r+eZeed <d Zdej2dej2fdZndej2dej2fdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%e jLde'dd fdZ(e jLde'de'dd defdZ)Gdd Z*y)N)suppress)Any)WeakKeyDictionaryWeakSet)ffilib)CurlMOpt)DEFAULT_CACERTCurl)CurlCffiWarning 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()) asyncio_loopreturnc tvr tStttdt dsSt j ttdddl 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. ProactorEventLoopN stacklevelr)AddThreadSelectorEventLoopc`_tjdjyN)closerpop)r loop_close selector_loopsE/home/Script/Script_env/lib/python3.12/site-packages/curl_cffi/aio.py_close_selector_and_loopz.get_selector.._close_selector_and_loop7s'",L  NN< .    !) r isinstancegetattrasynciotypewarningswarnPROACTOR_WARNINGr _asyncio_selectorrr)rrr rrs` @@r get_selectorr*s : %l+ + ''+>T K   &AFA3M 4  <0 "''  "6 r!loopc|Sr)r+s rr*r*Cs r!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?Ws )JR'' E LLN $Y **    # #     u%r!sockfdwhatdatactj|}|j}||jvr"|j ||j ||t zr=|j||j|t|jj||tzr=|j||j|t|jj||tzr|jj|yyr)rr4r+_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_functionrPms)J ??D$$$ 6" 6" l  7 7Q' m  7 7AQR' ""6*r!ceZdZdZddefdZdZdZdZde 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, certs from ``certifi`` are used. 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"%%  $D'*B*B*D   --d.A.A.CD 5,>? H++S-@-@ANN40 H''):):; H&&(9(9:r!cK|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:((*"($&* # r!r@ ev_bitmaskrcztjd}tj|j||||dS)z#Call libcurl socket_action functionint *r)rnewr curl_multi_socket_actionrU)r_r@r}running_handles rrvzAsyncCurl.socket_actions3) $$T[[&*nUa  r!c|jstjdtdy|j ||t j d} tj|j|}|t jk(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.z0Curlm already closed! quitting from process_datarrNrrperformzNOT DONE)rUr&r'r rvrrr curl_multi_info_readNULLmsg CURLMSG_DONErX easy_handlerBresultrq set_exception _get_errorprint)r_r@r} msg_in_queuecurl_msgrOretcodes rr8zAsyncCurl.process_datas{{ MMB   6:.www' // \JH388#|||+x';';<"--..a<OOD)&&tT__Wi-PQj!r!ctj|j|j|jj |jd|j j |dSr)r rmrUrnrXrrW)r_rOs r _pop_futurezAsyncCurl._pop_futuresK $$T[[$**= DJJ-  $$T400r!c|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-6r!c|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-6r!c|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-6r!cDtj|j||S)z!Wrapper around curl_multi_setopt.)r curl_multi_setoptrU)r_optionvalues rrbzAsyncCurl.setopt s$$T[[&%@@r!)N)__name__ __module__ __qualname____doc__strr`r^rr\r r|intrvr8rrrqrrbr-r!rrrss$;6D t !C!S!S! "3"C"<11 $ $t$ ,$, Ar!)+r$sysr& contextlibrtypingrweakrefrr_wrapperrr constr rOr r utilsr __all__platformr__annotations__r(AbstractEventLoopr*r:rGrJCURL_POLL_INOUTrMr9CURL_SOCKET_BADrIrLCURL_CSELECT_ERRr def_externrr?rPrr-r!rrs< .&" -<<7$5$7J!7&//&  " "&T7449R9R   &c&K&&*+#+S+;+c++&JAJAr!