tf,HdZddlZddlZddlZddlmZmZmZmZm Z ddl m Z ddl Z ddl mZddlmZe rddlmZej&eZej&edzZej&ed zZGd d e ZGd d e ZdedededefdZdededefdZy)z%Connection/Session management module.N) AwaitableCallableDictUnion TYPE_CHECKING) EventEmitter)connect) NetworkError)Optionalz .Connectionz .CDPSessionc eZdZdZ ddedej deddffd Ze defdZ dd Z d ed eddfd Z dd ede defdZd e ddfdZd e ddfdZdegdfddfdZdeddfdZddZddZdeddfdZxZS) ConnectionzConnection management class.urlloopdelayreturnNcjt|||_d|_t |_|dz |_||_t |_|d|_ t|jd|jdd|_ |jj|j|_d|_y)zMake connection. :arg str url: WebSocket url to connect devtool. :arg int delay: delay to wait before processing received messages. riFN)max_sizer ping_interval ping_timeout)super__init___url_lastIddict _callbacks_delay_loop _sessions _connected ws_connect_ws create_task _recv_loop _recv_fut_closeCallback)selfrrr __class__s ^/var/www/html/software/conda/envs/higlass/lib/python3.12/site-packages/pyppeteer/connection.pyrzConnection.__init__s   59Vdl  04 dii$TZZW[jno//0AB<@c|jS)zGet connected WebSocket url.)rr&s r(rzConnection.url0syyr)clK|j4d{}d|_||_|jrh |jjd{}|r|j |d{tjdd{|jrhdddd{|jr*|jj|jyy777y#t j tf$rtjdY}wxYw77w#1d{7swYxYww)NTzconnection closedr)r!r connectionrecv _on_message websocketsConnectionClosedConnectionResetErrorloggerinfoasynciosleeprr"dispose)r&r-resps r(r#zConnection._recv_loop5s88 ' 'z"DO(DO//!%!5!5!77D"..t444mmA&&&// ' ' ?? JJ " "4<<> 2  ' 84"335IJKK 34' ' ' ' 'sD4C!D4DC'C#C'+C%,C'0DD D D4%D&|js,|jd|jd{7YyYyYywxYww)Nzconnection unexpectedly closed)rr5r6rr-sendr0r1r3errorrgetdone set_resultr7)r&r9r:callbacks r( _async_sendzConnection._async_sendEs//-- , , ,// %//&&s+ + + - +** % LL9 :**;=H ##D)lln$$!0x %sR/C6A(C6A,"A*#A,'C6*A,,A:C3&C)'C3,C62C33C6methodparamsc|jr|js td| t}|xjdz c_|j}t j t|||}t jd||jj|j|||jj}||j|<t|_||_|S)z Send message via the connection.zConnection is closedidrCrDSEND: )rrConnectionErrorrjsondumpslogger_connectiondebugrr"rB create_futurerr r=rC)r&rCrD_idr9rAs r(r<zConnection.sendQs <<!"89 9 >VF  lljj   &/ t//S9:::++-'$0N%r)c|jj|jdd}|jdr1|jt |j |j |y|j|jdy)NrHr=result)rpopr> set_exception_createProtocolErrorr=rCr@)r&r9rAs r( _on_responsezConnection._on_responsegsm??&&swwtR'89 777   " "$NNOO     1 2r)c|jdi}|jdd}|jd}|dk(r?|jj|}|r!|j|jdyy|dk(r<|jj|}|r|j|j|=yy|j ||y)NrDrC sessionId Target.receivedMessageFromTargetmessagezTarget.detachedFromTarget)r>rr/ _on_closedemit)r&r9rDrCrZsessions r( _on_queryzConnection._on_queryts2&2&JJ{+ 7 7nn((3G##FJJy$9: 2 2nn((3G""$NN9- IIff %r)rAc||_y)zSet closed callback.N)r%)r&rAs r(setClosedCallbackzConnection.setClosedCallbacks &r)r\c8Ktj|jd{tj d|t j |}|jd|jvr|j|y|j|y7rw)NRECV: rH) r5r6rrMrNrKloadsr>rrWr`)r&r\r9s r(r/zConnection._on_messagesrmmDKK(((& 23jj! 774=DOO +   c " NN3  )s#BBA3Bc K|jr|jd|_|jjD]5}|jt |j d|j d7|jj|jjD]}|j|jjt|dr"|jjd{|jjs|jjyy7:w)NProtocol error : Target closed.r-)r%rvaluesrU _rewriteErrorr=rCclearrr]hasattrr-closer$r?cancel)r&cbr_s r( _on_closezConnection._on_closes       !"&D //((* B   ]!")),<=   ~~,,. !G     !  4 &//'') ) )~~""$ NN ! ! #% *sDED?;EcNKd|_|jd{y7w)zClose all connection.FN)rrpr+s r(r7zConnection.disposesnns %#% targetInfo CDPSessioncK|jdd|did{}|jd}t||d||j}||j|<|S7Aw)zCreate new session.zTarget.attachToTargettargetIdNrZtype)r<r>rsrr)r&rrr8rZr_s r( createSessionzConnection.createSessionsjYY # J/ 0  HH[) T:f#5y$**M$+y! sA!AAA!)rrNN)__name__ __module__ __qualname____doc__strr5AbstractEventLoopintrpropertyrr#rBrrr<rWr`rrbr/rpr7rrw __classcell__r's@r(r r s& ACAw'@'@AA$(A(S3 %S %s %t %3 , 3 3 3&T&d& '(2t8*<''   $, d | r)r c eZdZdZdeedfdededejddf fd Z dd ed e de fd Z d eddfd Z ddZddZdededdfdZxZS)rsa|Chrome Devtools Protocol Session. The :class:`CDPSession` instances are used to talk raw Chrome Devtools Protocol: * protocol methods can be called with :meth:`send` method. * protocol events can be subscribed to with :meth:`on` method. Documentation on DevTools Protocol can be found `here `__. r- targetTyperZrrNct|d|_i|_||_||_||_t|_||_ y)zMake new session.rN) rrrr _connection _targetType _sessionIdrrr)r&r-rrZrr's r(rzCDPSession.__init__sE  571;%#04 r)rCrDc|jstd|d|jd|xjdz c_|j}t j t |||}tjd||jj}||j|<t|_ ||_ |jjd|j|d|S#t $rg}||jvrN|j|}|j|=|j#t%|j|j&d Yd }~|Sd }~wwxYw) zSend message to the connected session. :arg str method: Protocol method name. :arg dict params: Optional method parameters. zProtocol Error (z#): Session closed. Most likely the z has been closed.rFrGrIzTarget.sendMessageToTarget)rZr\rN)rr rrrKrLrlogger_sessionrNrrOrr=rCr<r ExceptionrUrjargs)r&rCrDrPr9rAe _callbacks r(r<zCDPSession.sendsF "6(*M##$$57   lljjVFCDvcU^,::++-'$0N%     ! !">!__A  doo% OOC0 OOC('' OOFF1I) s)C.. E7AEEr9ctjd|tj|}|j d}|r|j j |}|r|j |=|j dr1|j t|j|j|y|j d}|r#|js|j|yyyy|j di}|j ddk(rM|jj |j d}|r|j|j d n_|j dd k(rK|j d}|jj |}|r|j|j|=|j|j d|j dy) NrdrHr=rSrDrCr[rZr\Target.detachFromTarget)rrNrKrer>rrUrVr=rCr?r@rr/r]r^) r&r9objrPrArSrDr_rZs r(r/zCDPSession._on_messagesvcU^,jjoggdm **3/HOOC(777#**+?  , !WWX.F  ++F3)8xWWXr*Fwwx $FF..,,VZZ -DE'' 9(=>"&??"JJ{3 ..,,Y7&&(y1 IIcggh'): ;r)cK|js td|jjdd|jid{y7w)zDetach session from target. Once detached, session won't emit any events and can't be used to send messages. zConnection already closed.rrZN)rr r<rr+s r(detachzCDPSession.detachsM ;< <##$=%0$//$BD D DsAA A A c |jjD]5}|jt|jd|j d7|jj d|_y)Nrgrh)rrirUrjr=rCrkr)r&ros r(r]zCDPSession._on_closed!se//((* B   ]!")),<=   r)cTt||||j}||j|<|Sry)rsrr)r&rrZr_s r(_createSessionzCDPSession._createSession*s)T:y$**E$+y!r)ryrx)rzr{r|r}rr r~r5rrrrr<r/rr]rrrs@r(rsrss  5\)A#B   -0 00 59 "3"" "Hrs, BB:)   8 $%G%%h&>?"""8m#;<\\~uup) )3)T)')SYr)