cxdZddlZddlZddlZddlZddlmZddlmZdZ Gddej j Z dS)z9Tornado websocket handler to serve a terminal interface. N)gen)run_on_executorcZt|tr|dS|S)Nzutf-8) isinstancebytesdecode)ss 3lib/python3.11/site-packages/terminado/websocket.py _cast_unicoder s+!U!xx   HceZdZdZdZddZdfd ZdZdZe j dZ d Z d Z dd ed dfdZeddZxZS) TermSocketz Handler for a terminal websocketc ||_d|_d|_d|_|j|_t jt|_ d|_ t tjdddk|_dS)N)NNLOG_TERMINAL_OUTPUTfalsetrue) term_manager term_namesizeterminalblocking_io_executor_blocking_io_executorlogging getLogger__name___logger _user_commandstrlowerosgetenv_enable_output_logging)selfrs r initializezTermSocket.initializest(   %1%F"(22 '*ii :OQX0Y0Y&Z&Z^d&d###r Ncj||p|jjdS)z1Deprecated: backward-compat for terminado <= 0.5.Origin) check_originrequestheadersget)r$origins r origin_checkzTermSocket.origin_check&s.  !M4<+?+C+CH+M+MNNNr cHt||jd|t |}|pd|_|j||_|jj || dig|jd|jd}|jj } |sn|}||z }|r||dSdS)zWebsocket connection opened. Call our terminal manager to get a terminal, and connect to it as a client. zTermSocket.open: %sttysetupzTermSocket.open: Opened %srTN)superopenrinfor rr get_terminalrclientsappendsend_json_message read_buffercopypopleft on_pty_read)r$ url_componentbufferedpreopen_bufferr __class__s r r2zTermSocket.open*s)  ]### /???%m44 &/%)66}EE  $$T*** }--- 6GGG27799 ! &&((A MH    '   X & & & & & ' 'r c4|d|gdS)z$Data read from pty; send to frontendstdoutN)r7r$texts r r;zTermSocket.on_pty_readGs! $/00000r ctj|}|||jrG|ddkr=t |dt r$|d|ddSdSdSdS)NrrAzSTDOUT: )jsondumps write_messager#rrlog_terminal_output)r$contentjson_msgs r r7zTermSocket.send_json_messageKs:g&& 8$$$  & BqzX% B*WQZ*E*E B(()@GAJ)@)@AAAAA B B B B B Br c#Ktj|}|d}|jJ|dkrp||dV|jrJ|ddkr&|d|jd|_dS|xj|dz c_dSdS|dkr*|dd |_|jdSdS) zHandle incoming websocket message We send JSON arrays, where the first element is a string indicating what kind of message this is. Data associated with the message follows. rNstdinrE zSTDIN: rset_size) rFloadsrstdin_to_ptyprocr#rIrrresize_to_smallest)r$messagecommandmsg_types r on_messagezTermSocket.on_messageSs *W%%1:}((( w  /'' 33 3 3 3* 51:%5,,-Kt7I-K-KLLL)+D&&&&&'!*4&&&&  5 5  # /! DI M , , . . . . . / /r c|jd|jr8|jj||j|j|dS)zHandle websocket closing. Disconnect from our terminal, and tell the terminal manager we're disconnecting. zWebsocket closedN)rr3rr5removerSrclient_disconnectedr$s r on_closezTermSocket.on_closejso ,--- = / M ! ( ( . . . M , , . . . --d33333r cj|ddg|d|_dS)z9Terminal closed: tell the frontend, and close the socket. disconnectrEN)r7closerr[s r on_pty_diedzTermSocket.on_pty_diedvs3  a0111  r rlogreturnc:|j|dS)zg Logs the terminal input/output :param log: log line to write :return: N)rdebug)r$ras r rIzTermSocket.log_terminal_output|s 3r r)executorcV|j!|jj|dSdS)aHandles stdin messages sent on the websocket. This is a blocking call that should NOT be performed inside the server primary event loop thread. Messages must be handled asynchronously to prevent blocking on the PTY buffer. N)rptyprocwriterBs r rRzTermSocket.stdin_to_ptyprocs7 = . M ! ' ' - - - - - . .r )N)r)r __module__ __qualname____doc__r%r-r2r;r7r coroutinerWr\r`rrIrrR __classcell__)r?s@r rrs** e e eOOOO'''''':111BBB ]//]/, 4 4 4   s D    _5666..76.....r r) rkrFrr!tornado.websockettornadortornado.concurrentrr websocketWebSocketHandlerrr r rts   ......   w.w.w.w.w."3w.w.w.w.w.r