o g( @sddlZddlZddlZddlmZddlZddlZd\ZZzddlZWney8Z ze ZWYdZ [ ndZ [ wwddl m Z ddl m Z Gddde ZdS)N)select)NN)ProxyCommandFailure)ClosingContextManagerc@sPeZdZdZddZddZddZdd Zed d Z ed d Z ddZ dS) ProxyCommanda Wraps a subprocess running ProxyCommand-driven programs. This class implements a the socket-like interface needed by the `.Transport` and `.Packetizer` classes. Using this class instead of a regular socket makes it possible to talk with a Popen'd command that will proxy traffic between the client and a server hosted in another machine. Instances of this class may be used as context managers. cCs@tdurtt||_tj|jtjtjtjdd|_d|_dS)a Create a new CommandProxy instance. The instance created by this class can be passed as an argument to the `.Transport` class. :param str command_line: the command that should be executed and used as the proxy. Nr)stdinstdoutstderrbufsize) subprocesssubprocess_import_errorshlexsplitcmdPopenPIPEprocesstimeout)self command_linerH/var/www/html/api-tag/env/lib/python3.10/site-packages/paramiko/proxy.py__init__3s  zProxyCommand.__init__c CsFz |jj|Wt|Sty"}z td|j|jd}~ww)z Write the content received from the SSH client to the standard input of the forked command. :param str content: string to be sent to the forked command  N) rrwriteIOErrorrjoinrstrerrorlen)rcontenterrrsendGszProxyCommand.sendc CszWd}t}t||krUd}|jdur(t|}||jkr#t|j|}t|jjggg|\}}}|rO|d|jjkrO|t|jj |t|7}t||ks |WStjyf|re|YSt y{} z t d |j | jd} ~ ww)z Read from the standard output of the forked program. :param int size: how many chars should be read :return: the string of bytes read, which may be shorter than requested Nrr)timerrsocketrrrosreadfilenorrrrr) rsizebufferstartselect_timeoutelapsedrwxrrrrrecvXs2       zProxyCommand.recvcCst|jjtjdSN)r$killrpidsignalSIGTERMrrrrcloseyszProxyCommand.closecCs |jjduSr0)r returncoder5rrrclosed|s zProxyCommand.closedcCs|jSr0)r8r5rrr_closedszProxyCommand._closedcCs ||_dSr0)r)rrrrr settimeouts zProxyCommand.settimeoutN) __name__ __module__ __qualname____doc__rr r/r6propertyr8r9r:rrrrr's !   r)r$r r3rr#r"r r ImportErrorrparamiko.ssh_exceptionr paramiko.utilrrrrrrs