^hSrSSKJr SSKrSSKrSSKJr SSKJrJrJ r J r J r SSK r SSK JrJr SSKJr SSKJrJr SS KJr S S /r"S S \ R05r"S S \ R45rg)zI Utility for running a prompt_toolkit application in an asyncssh server. ) annotationsN)get_running_loop)AnyCallable CoroutineTextIOcast) AppSessioncreate_app_session)Size) PipeInputcreate_pipe_input) Vt100_OutputPromptToolkitSSHSessionPromptToolkitSSHServerc\rSrSrS SjrS SjrSSjrSSjrSSjrSSjr SSjr SS jr S r g )rc^UTlUTlSTlSTlSTlSTlSTl"U4SjS5n[[U"55Tl g)NcT>\rSrSrSU4SjjrS SjrS Sjr\S U4Sjj5rSr g) 0PromptToolkitSSHSession.__init__..Stdout+c>TRb,TRRURSS55 gg![a gf=f)N z )_chanwritereplaceBrokenPipeError)sdataselfs [/home/james-whalen/.local/lib/python3.13/site-packages/prompt_toolkit/contrib/ssh/server.pyr6PromptToolkitSSHSession.__init__..Stdout.write,sFzz- ((dF)CD.&s8= A  A cgNTrs r!isatty7PromptToolkitSSHSession.__init__..Stdout.isatty3scgNr%r&s r!flush6PromptToolkitSSHSession.__init__..Stdout.flush6sr)c>TRce[TRRR5S5$)Nr)rstr _orig_chan get_encoding)rr s r!encoding9PromptToolkitSSHSession.__init__..Stdout.encoding9s6zz---4::00==?BCCr)r%N)rr/returnNoner4boolr4r5)r4r/) __name__ __module__ __qualname____firstlineno__rr'r,propertyr2__static_attributes__r sr!Stdoutr+s(    D Dr)r@) interact enable_cpr interact_taskr app_session_input_outputr rstdout)r rArBr@s` r!__init__ PromptToolkitSSHSession.__init__sX ! $8<!% .2 )- ,0  D D&668, r)c|URc [SSS9$URR5upp4[X!S9$)zE Callable that returns the current `Size`, required by Vt100_Output. O)rowscolumns)rr get_terminal_sizer widthheightpixwidth pixheights r! _get_size!PromptToolkitSSHSession._get_size@s= :: R, ,151M1M1O .E8V3 3r)cXlgr+)r)r chans r!connection_made'PromptToolkitSSHSession.connection_madeJs r)cgr$r%r?s r!shell_requested'PromptToolkitSSHSession.shell_requestedMsr)c\[5RUR55Ulgr+)r create_task _interactrCr?s r!session_started'PromptToolkitSSHSession.session_startedPs-/;;DNNCallable[[PromptToolkitSSHSession], Coroutine[Any, Any, None]]rBr7r4r5)r4r )rXrr4r5r6r8) rQintrRr}rSobjectrTr~r4r5)rr/ryr~r4r5) r9r:r;r<rHrUrYr\rar`rurzr>r%r)r!rrsp'-P'- '-  '-R4N(8.."%.17.DJ. .$r)cH\rSrSrSrSS.S SjjrS SjrS SjrSrg ) r~a Run a prompt_toolkit application over an asyncssh server. This takes one argument, an `interact` function, which is called for each connection. This should be an asynchronous function that runs the prompt_toolkit applications. This function runs in an `AppSession`, which means that we can have multiple UI interactions concurrently. Example usage: .. code:: python async def interact(ssh_session: PromptToolkitSSHSession) -> None: await yes_no_dialog("my title", "my text").run_async() prompt_session = PromptSession() text = await prompt_session.prompt_async("Type something: ") print_formatted_text('You said: ', text) server = PromptToolkitSSHServer(interact=interact) loop = get_running_loop() loop.run_until_complete( asyncssh.create_server( lambda: MySSHServer(interact), "", port, server_host_keys=["/etc/ssh/..."], ) ) loop.run_forever() :param enable_cpr: When `True`, the default, try to detect whether the SSH client runs in a terminal that responds to "cursor position requests". That way, we can properly determine how much space there is available for the UI (especially for drop down menus) to render. TrBcXlX lgr+)rArB)r rArBs r!rHPromptToolkitSSHServer.__init__s ! $r)cg)NFr%)r usernames r! begin_auth!PromptToolkitSSHServer.begin_authsr)c>[URURS9$)Nr)rrArBr?s r!session_requested(PromptToolkitSSHServer.session_requesteds&t}}QQr))rBrANr|)rr/r4r7)r4r) r9r:r;r<__doc__rHrrr>r%r)r!rr~s9#R %P% %  %Rr))r __future__rasynciormrtypingrrrrr asyncssh"prompt_toolkit.application.currentr r prompt_toolkit.data_structuresr prompt_toolkit.inputr rprompt_toolkit.output.vt100r__all__SSHServerSessionr SSHServerrr%r)r!rsa#$99M/=4 $&> ?e$h77e$P4RX//4Rr)