&th,JdZddlZddlZddlZddlmZmZmZmZm Z ddl m Z ddl Z ddl mZddlmZe rddlmZejeZejedzZejed zZGd d e ZGd d e ZdedededefdZdededefdZdS)z%Connection/Session management module.N) AwaitableCallableDictUnion TYPE_CHECKING) EventEmitter)connect) NetworkError)Optionalz .Connectionz .CDPSessionc eZdZdZ ddedejdeddffd Ze defd Z dd Z d ed eddfd Z ddede defdZd e ddfdZd e ddfdZdegdfddfdZdeddfdZddZddZdeddfdZxZS) ConnectionzConnection management class.rurlloopdelayreturnNct||_d|_t |_|dz |_||_t |_|d|_ t|jd|jdd|_ |j | |_d|_dS)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 h/var/www/html/mycamper/aliexpress-site/backend/venv/lib/python3.11/site-packages/pyppeteer/connection.pyrzConnection.__init__s   59VVdl  04 #di$TZW[jnooo//0A0ABB<@c|jS)zGet connected WebSocket url.)rr&s r(rzConnection.url0s yr)c,K|j4d{V}d|_||_|jr |jd{V}|r||d{Vn6#t jtf$rt dYn%wxYwtj dd{V|j dddd{Vn#1d{VswxYwY|jr.|j |dSdS)NTzconnection closedr)r!r connectionrecv _on_message websocketsConnectionClosedConnectionResetErrorloggerinfoasynciosleeprr"dispose)r&r-resps r(r#zConnection._recv_loop5s8 ' ' ' ' ' ' 'z"DO(DO/ '!%!5!5!7!7777777D5"..t444444444"35IJKK 3444EmA&&&&&&&&&/ ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ? 3 J " "4<<>> 2 2 2 2 2 3 3s4CVVF  lj      /// t//S99::::++--'$0NN%r)c<|j|dd}|dr0|t |j|j|dS||ddS)NrHr=result)rpopr> set_exception_createProtocolErrorr=rCr@)r&r9rAs r( _on_responsezConnection._on_responsegs?&&swwtR'8'899 777   3  " "$NO         1 1 2 2 2 2 2r)c|di}|dd}|d}|dkrH|j|}|r*||ddSdS|dkr<|j|}|r||j|=dSdS|||dS)NrDrC sessionId Target.receivedMessageFromTargetmessagezTarget.detachedFromTarget)r>rr/ _on_closedemit)r&r9rDrCrZsessions r( _on_queryzConnection._on_queryts2&&2&&JJ{++ 7 7 7n((33G ;##FJJy$9$9::::: ; ; 2 2 2n((33G .""$$$N9--- . . IIff % % % % %r)rAc||_dS)zSet closed callback.N)r%)r&rAs r(setClosedCallbackzConnection.setClosedCallbacks&r)r\c:Ktj|jd{Vtd|t j|}|d|jvr| |dS| |dS)NRECV: rH) r5r6rrMrNrKloadsr>rrWr`)r&r\r9s r(r/zConnection._on_messagesmDK((((((((( 2 2 2333j!! 774==DO + +   c " " " " " NN3     r)c rK|jr|d|_|jD]3}|t |jd|jd4|j|jD]}| |jt|dr|j d{V|j s|j dSdS)NProtocol error : Target closed.r-)r%rvaluesrU _rewriteErrorr=rCclearrr]hasattrr-closer$r?cancel)r&cbr_s r( _on_closezConnection._on_closesV   '    ! ! !"&D /((**  B   ]=")===     ~,,.. ! !G      4 & & */'')) ) ) ) ) ) ) )~""$$ $ N ! ! # # # # # $ $r)cLKd|_|d{VdS)zClose all connection.FN)rrpr+s r(r7zConnection.disposes5nnr) targetInfo CDPSessioncK|dd|did{V}|d}t||d||j}||j|<|S)zCreate new session.zTarget.attachToTargettargetIdNrZtype)r<r>rsrr)r&rrr8rZr_s r( createSessionzConnection.createSessionsYY # J/ 0        HH[)) T:f#5y$*MM$+y!r))rrNN)__name__ __module__ __qualname____doc__strr5AbstractEventLoopintrpropertyrr#rBrrr<rWr`rrbr/rpr7rrw __classcell__r's@r(r r s&& AACAw'@AA$(AAAAAA(SX3333 %S %s %t % % % %3 , 3 3 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- targetTyperZrrNctd|_i|_||_||_||_t|_||_ dS)zMake new session.rN) rrrr _connection _targetType _sessionIdrrr)r&r-rrZrr's r(rzCDPSession.__init__sV  571;%#04 r)rCrDc|jstd|d|jd|xjdz c_|j}t jt |||}td||j }||j |<t|_ ||_ |jd|j|dnh#t $r[}||j vrH|j |}|j |=|t%|j |jd Yd }~nd }~wwxYw|S) 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.sends  7677#777   ljVFCCCDD^c^^,,,:++--'$0NN%    ! !">!_AA       do%% OC0 OC('' OF1I))  s9#C E'AD==Er9cJtd|tj|}|d}|r|j|}|r|j|=|dr0|t|j|j |dS|d}|r-| s| |dSdSdSdS|di}|ddkrX|j |d}|r(| |d nf|dd krM|d}|j |}|r||j |=||d|ddS) NrdrHr=rSrDrCr[rZr\Target.detachFromTarget)rrNrKrer>rrUrVr=rCr?r@rr/r]r^) r&r9objrPrArSrDr_rZs r(r/zCDPSession._on_messages$^c^^,,,jooggdmm  <**3//H 4OC(777## 4**+?  ,, !WWX..F4 4 ++F33333 4 44444WWXr**Fwwx  $FFF.,,VZZ -D-DEE?'' 9(=(=>>>""&???"JJ{33 .,,Y772&&(((y1 IIcggh''):): ; ; ; ; ;r)cK|jstd|jdd|jid{VdS)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.detachs}  =;<< <##$=%0$/$BDD D D D D D D D D Dr)c |jD]3}|t|jd|jd4|jd|_dS)Nrgrh)rrirUrjr=rCrkr)r&ros r(r]zCDPSession._on_closed!s/((**  B   ]=")===     r)cHt||||j}||j|<|Sry)rsrr)r&rrZr_s r(_createSessionzCDPSession._createSession*s(T:y$*EE$+y!r)ryrx)rzr{r|r}rr r~r5rrrrr<r/rr]rrrs@r(rsrss"   5\)A#B   -0 0 59      ""3"" """"Hrs,+ BBBBBBBBBBBBBB::::::))))))   8 $ $%G%h&>??""8m#;<<\\\\\\\\~uuuuuuuup) )3)T)'))))SYr)