hSrSSKJr SSKrSSKrSSKrSSKJrJr SSK r SSK J r SSK J r \(aSSKJrJr S Sjr"S S \ R$R&5rg) z9Tornado websocket handler to serve a terminal interface. ) annotationsN) TYPE_CHECKINGAny)gen)run_on_executor)PtyWithClientsTermManagerBasecR[U[5(aURS5$U$)Nzutf-8) isinstancebytesdecode)ss fC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\terminado/websocket.py _cast_unicoders#!Uxx  Hc^\rSrSrSrSSjrSSSjjrSSU4SjjjrSSjrSSjr \ RSSj5r SS jr SS jrSSS jjr\"S S 9SSj5rSrU=r$) TermSocketz Handler for a terminal websocketc XlSUlSUlSUlURUl[ R"[5Ul SUl [R[R"SS55S:HUlg)zInitialize the handler.)NNNLOG_TERMINAL_OUTPUTfalsetrue) term_manager term_namesizeterminalblocking_io_executor_blocking_io_executorlogging getLogger__name___logger _user_commandstrlowerosgetenv_enable_output_logging)selfrs r initializeTermSocket.initializesk(  /3 %1%F%F"((2 '*ii :OQX0Y&Z^d&d#rcU=(d& URRRSS5nUceURU5$)z1Deprecated: backward-compat for terminado <= 0.5.Originr)requestheadersget check_origin)r*origins r origin_checkTermSocket.origin_check,s@A4<<//33HbA!!!  ((rcJ>[TU]U5 URRSU5 [ U5nU=(d SUlUR RU5UlURRRU5 URS0/5 URRSUR 5 SnURRR5nU(dOUR5nX$- nMU(aURU5 gg)zjWebsocket connection opened. Call our terminal manager to get a terminal, and connect to it as a client. zTermSocket.open: %sttysetupzTermSocket.open: Opened %srN)superopenr#inforrr get_terminalrclientsappendsend_json_message read_buffercopypopleft on_pty_read)r* url_componentbufferedpreopen_bufferr __class__s rr:TermSocket.open2s  ]# /?%m4 &/%))66}E  $$T* }- 6G22779!&&(A MH     X & rc*URSU/5 g)z$Data read from pty; send to frontendstdoutN)r?r*texts rrCTermSocket.on_pty_readOs $/0rc[R"U5nURU5 UR(a;USS:Xa1[ US[ 5(aUR SUS35 gggg)z"Send a json message on the socket.rrJzSTDOUT: N)jsondumps write_messager)r r%log_terminal_output)r*contentjson_msgs rr?TermSocket.send_json_messageSsl::g& 8$  & &71:+AjQXYZQ[]`FaFa  $ $x |%< =Gb+A &rc## [R"U5nUSnURceUS:XapURUS5v UR(aHUSS:Xa&UR SUR 35 SUlgU=R US- slggUS:Xa%USS UlURR5 gg7f) 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. rNstdinrO zSTDIN: rset_size) rPloadsrstdin_to_ptyprocr)rSr$rresize_to_smallest)r*messagecommandmsg_types r on_messageTermSocket.on_message[s**W%1:}}((( w '' 3 3**1:%,,wt7I7I6J-KL)+D&&&'!*4& +  #! DI MM , , .$sC CcURRS5 UR(a?URRR U5 URR 5 UR RU5 g)zlHandle websocket closing. Disconnect from our terminal, and tell the terminal manager we're disconnecting. zWebsocket closedN)r#r;rr=remover^rclient_disconnectedr*s ron_closeTermSocket.on_closersZ ,- == MM ! ! ( ( . MM , , . --d3rcXURSS/5 UR5 SUlg)z9Terminal closed: tell the frontend, and close the socket. disconnectrON)r?closerrgs r on_pty_diedTermSocket.on_pty_died~s%  a01  rc:URRU5 g)zG Logs the terminal input/output :param log: log line to write :return: N)r#debug)r*logs rrSTermSocket.log_terminal_outputs 3rr)executorcjURb&URRRU5 gg)zHandles 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)rptyprocwriterKs rr]TermSocket.stdin_to_ptyprocs+ == $ MM ! ! ' ' - %r)rr)r#r$rrrr)rr returnNone)N)r3z str | Nonerxbool)rDrrxry)rLr%rxry)rTrrxry)r_r%rxry)rxry)r)rqr%rxry)r" __module__ __qualname____firstlineno____doc__r+r4r:rCr?r coroutinerbrhrmrSrr]__static_attributes__ __classcell__)rGs@rrrsf* e) '':1> ]]//, 4  56.7.rr)rz str | bytesrxr%)r~ __future__rrPr r'typingrrtornado.websockettornadortornado.concurrentrterminado.managementrr r websocketWebSocketHandlerrrrrsI #  %.D z.""33z.r