`1hIUddlZddlZddlZddlZddlZddlZddlmZddlm Z ddlm Z ddl m Z ddl mZddl mZddl mZdd l mZdd l mZdd l mZddlZdd lmZdd lmZej2dZedZdZdadadZej@da!ej@e"d<ej@da#ej@e"d<dZ$dZ%e dZ&e dZ'dZ(dZ)Gdde*Z+GddeZ,Gd d!e*Z-e Gd"d#Z.Gd$d%Z/Gd&d'e/Z0Gd(d)e/ejbjdZ3e d*ee3fd+Z4d*e3fd,Z5y)-N) defaultdict)asynccontextmanager)contextmanager) dataclass)Any)AsyncGenerator) AsyncIterator) Generator)Type)TypeVar)ConnectionClosed)connect_websocket_urltrio_cdpTic|ad} tj||atS#t$rt j tjdjd}td|jD}td|D}tjt}|j!d|tj||atcYSwxYw)z^Attempt to load the current latest available devtools into the module cache for use later.z$selenium.webdriver.common.devtools.vdevtoolsc3VK|]!}|js|j#ywN)is_dirname).0fs `/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/selenium/webdriver/common/bidi/cdp.py z"import_devtools..FsOAAHHJOs))c38K|]}t|ddyw)rN)int)rxs rrz"import_devtools..Gs2AS12Z2sz'Falling back to loading `devtools`: v%s)version importlib import_modulerModuleNotFoundErrorpathlibPath__file__parentsjoinpathtupleiterdirmaxlogging getLogger__name__debug)verbase devtools_pathversionslatestselenium_loggers rimport_devtoolsr58s G 1D **dVC5>:   X.66q9BB:N O)>)>)@OO222!++H5GP**dVF8+<= s%B:C"!C"connection_context_connection_contextsession_context_session_contextcb tjS#t$rt|dwxYw)zLook up the current connection. If there is no current connection, raise a ``RuntimeError`` with a helpful message. z*() must be called in a connection context.)r7get LookupError RuntimeErrorfn_names rget_connection_contextr@Rs; S"&&(( SgY&PQRRS.cb tjS#t$rt|dwxYw)z{Look up the current session. If there is no current session, raise a ``RuntimeError`` with a helpful message. z'() must be called in a session context.)r9r;r<r=r>s rget_session_contextrC^s; P##%% PgY&MNOOPrAc#Ktj|} dtj|y#tj|wxYww)zbThis context manager installs ``connection`` as the session context for the current Trio task.N)r7setreset) connectiontokens rr6r6js= # #J /E) !!%(!!%(A 3A A  A c#Ktj|} dtj|y#tj|wxYww)z_This context manager installs ``session`` as the session context for the current Trio task.N)r9rErF)sessionrHs rr8r8us=   )E& u%u%rIc2tjd|ay)zInstall ``connection`` in the root context so that it will become the default connection for all tasks. This is generally not recommended, except it may be necessary in certain use cases such as running inside Jupyter notebook. r7defaultN) contextvars ContextVarr7)rGs rset_global_connectionrQs&001FPZ[c2tjd|ay)zInstall ``session`` in the root context so that it will become the default session for all tasks. This is generally not recommended, except it may be necessary in certain use cases such as running inside Jupyter notebook. r9rMN)rOrPr9)rKs rset_global_sessionrTs#--.@'RrRceZdZdZdZdZy) BrowserErrorzgThis exception is raised when the browser's response to a command indicates that an error occurred.c|jd|_|jd|_|jd|_y)Ncodemessagedata)r;rXrYdetail)selfobjs r__init__zBrowserError.__init__s0GGFO wwy) ggfo rRcTd|jd|jd|jS)NzBrowserError )rXrYr[r\s r__str__zBrowserError.__str__s'#DII;i ~R }UUrRN)r- __module__ __qualname____doc__r^rarRrrVrVs)& VrRrVceZdZdZdZdZy)CdpConnectionClosedzARaised when a public method is called on a closed CDP connection.c||_y)zfConstructor. :param reason: :type reason: wsproto.frame_protocol.CloseReason N)reason)r\ris rr^zCdpConnectionClosed.__init__s  rRcN|jjd|jdS)zReturn representation.<>) __class__r-rir`s r__repr__zCdpConnectionClosed.__repr__s$..))*!DKK=::rRN)r-rbrcrdr^rnrerRrrgrgsK;rRrgceZdZdZy) InternalErrorzfThis exception is only raised when there is faulty logic in TrioCDP or the integration with PyCDP.N)r-rbrcrdrerRrrprps#rRrpc eZdZUdZdZeed<y) CmEventProxyzA proxy object returned by :meth:`CdpBase.wait_for()``. After the context manager executes, this proxy object will have a value set that contains the returned event. Nvalue)r-rbrcrdrsr__annotations__rerRrrrrrs E3rRrrcxeZdZdZdeeeefdefdZdddZ e dde ede e d ffd Zd Zd Zd Zy )CdpBasec||_||_||_tt|_t j|_i|_ i|_ yr) ws session_id target_idrrEchannels itertoolscountid_iter inflight_cmdinflight_result)r\rxryrzs rr^zCdpBase.__init__sA$"#C(  ( !rRcmdreturncKt|j}tj}||f|j|<t|}||d<|j r|j |d<t j|}tjtjrtjd|d|d| |jj|d{|j%d{|j&j)|}tjtjrtjd|t+|t,rStjtjr.tjd|d t/|j0||S7#t$r}t!|j"dd}~wwxYw7w) zExecute a command on the server and wait for the result. :param cmd: any CDP command :returns: a CDP result id sessionIdzSending CDP message:  z: NzReceived CDP message: zException raised by z message: )nextr~trioEventrryjsondumpslogger isEnabledForr+DEBUGr.rx send_messageWsConnectionClosedrgriwaitrpop isinstance Exceptiontyper-)r\rcmd_id cmd_eventrequest request_strwccresponses rexecutezCdpBase.executes{ dll#JJL $'N&!s) ??#'??GK jj)   w}} - LL0)B{mT U <''&&{3 3 3nn''++F3   w}} - LL1(< = h *""7==1 3I;jhI`I`HabcN 4! <%cjj1t ; <sIBs5 -;;(<\}}|j jD]\}}|D]}|j#@yw)zxRuns in the background and handles incoming messages: dispatching responses to commands and events to listeners.NiDzClient received invalid JSON)rXrYrZzReceived message %rrz-Browser sent a message for an invalid session)rx get_messagerrloadsJSONDecodeErrorrVrr.rr SessionIDrrritemsr{close)r\rYrZryrKrsendersrs r _reader_taskzCdpConnection._reader_tasksm  $ 3 3 55 qzz'* LL. 5d"%__66tK7HI  "mmJ7G$$T*!!$'95%    '' q"F?]gn#opp q &$*'V'1n----/ #JAw%..446 # 7%#FLLN# # #saEB/B-B/B>#C!!E$C>>AE)rr) r-rbrcrdr^rrr rrrrrrs@rrr~s<   }Z/H  %#rRrrcKtj4d{}t||d{} t|5|ddd|j d{dddd{y7[7I#1swY6xYw7%#|j d{7wxYw75#1d{7swYyxYww)aThis async context manager opens a connection to the browser specified by ``url`` before entering the block, then closes the connection when the block exits. The context manager also sets the connection as the default connection for the current task, so that commands like ``await target.get_targets()`` will run on this connection automatically. If you want to use multiple connections concurrently, it is recommended to open each on in a separate task. N)r open_nursery connect_cdpr6r)urlnurseryconns ropen_cdprs  "  g #.. #D)   ++-      .   $++-       sB>A7B>B)A9B) B A;B B)!B"B)& B>1B'2B>9B);B B B) B$B B$$B)'B>)B;/B2 0B;7B>cKt||td{}t|}|j|j|S7,w)aConnect to the browser specified by ``url`` and spawn a background task in the specified nursery. The ``open_cdp()`` context manager is preferred in most situations. You should only use this function if you need to specify a custom nursery. This connection is not automatically closed! You can either use the connection object as a context manager (``async with conn:``) or else call ``await conn.aclose()`` on it when you are done with it. If ``set_context`` is True, then the returned connection will be installed as the default connection for the current task. This argument is for unusual use cases, such as running inside of a notebook. )max_message_sizeN)rMAX_WS_MESSAGE_SIZEr start_soonr)rrrxcdp_conns rrrsC%WcDWX XBR H x,,- O YsAA-A)6rOr r|rr+r# collectionsr contextlibrr dataclassesrtypingrrr r r r rtrio_websocketr rrr,rrrrrr5rPr7rtr9r@rCr6r8rQrTrrVrgrprrrvrabc AsyncResourcerrrrerRrrs6 #*%!!  A0   : & CL  ,/Ek.D.DEY.Z[++Z+A;+A+ABS+T+((T S P))&&\S V9 V ;, ; #I#   x4x4v=<=<@Z#GTXX33Z#z =7  *}rR