tf&dZddlmZddlmZddlmZddlmZeej GddejZ dS) z The parent class for all the SSH Channels. Currently implemented channels are session, direct-tcp, and forwarded-tcp. Maintainer: Paul Swartz ) implementer) interfaces)Logger)logceZdZUdZeZdZeed< ddZ de fdZ defdZ d Z d Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdS) SSHChannela A class that represents a multiplexed channel over an SSH connection. The channel has a local window which is the maximum amount of data it will receive, and a remote which is the maximum amount of data the remote side will accept. There is also a maximum packet size for any individual data packet going each way. @ivar name: the name of the channel. @type name: L{bytes} @ivar localWindowSize: the maximum size of the local window in bytes. @type localWindowSize: L{int} @ivar localWindowLeft: how many bytes are left in the local window. @type localWindowLeft: L{int} @ivar localMaxPacket: the maximum size of packet we will accept in bytes. @type localMaxPacket: L{int} @ivar remoteWindowLeft: how many bytes are left in the remote window. @type remoteWindowLeft: L{int} @ivar remoteMaxPacket: the maximum size of a packet the remote side will accept in bytes. @type remoteMaxPacket: L{int} @ivar conn: the connection this channel is multiplexed through. @type conn: L{SSHConnection} @ivar data: any data to send to the other side when the channel is requested. @type data: L{bytes} @ivar avatar: an avatar for the logged-in user (if a server channel) @ivar localClosed: True if we aren't accepting more data. @type localClosed: L{bool} @ivar remoteClosed: True if the other side isn't accepting more data. @type remoteClosed: L{bool} Nnamerc|pd|_|j|_|pd|_||_||_d|_||_||_||_d|_ d|_ g|_ d|_ d|_ d|_d|_dS)Niir)localWindowSizelocalWindowLeftlocalMaxPacketremoteWindowLeftremoteMaxPacket areWritingconndataavatar specificDatabufextBufclosing localClosed remoteClosedid)self localWindowr remoteWindowrrrrs X/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/conch/ssh/channel.py__init__zSSHChannel.__init__9s +4f#3,5 ,.     r returncP|dS)Nascii) __bytes__decoders r __str__zSSHChannel.__str__Ts ~~&&w///r c<|j}|sd}d||j|jfzS)zD Return a byte string representation of the channel sNones)r rr)rr s r r%zSSHChannel.__bytes__Ws9y D/    !3   r c|jdurt|jpd}|jr|jd}nd}d|d|d|jS)Nunknownr$Nonez SSHChannel z (z) on )rstrr r&r logPrefix)rrr s r r.zSSHChannel.logPrefixesrgT!2c$'ll @y 9 9##G,,DDDETEEREEdi.A.A.C.CEEEr c:|jddS)z Called when the channel is opened. specificData is any data that the other side sent us when opening the channel. @type specificData: L{bytes} z channel openN_loginfo)rrs r channelOpenzSSHChannel.channelOpenms ~&&&&&r c>|jd|dS)z Called when the open failed for some reason. reason.desc is a string descrption, reason.code the SSH error code. @type reason: L{error.ConchError} z(other side refused open reason: {reason})reasonN)r1error)rr5s r openFailedzSSHChannel.openFailedvs# CFSSSSSr c4|j|z|_|js"|jsd|_||jr#|j}d|_|||jr,|j}g|_|D]\}}|||dSdS)z Called when bytes are added to the remote window. By default it clears the data buffers. @type data: L{bytes} Tr N)rrr startWritingrwriter writeExtended)rrbtypes r addWindowByteszSSHChannel.addWindowBytess!% 5 < t| "DO       8 ADH JJqMMM ; / ADK / / d""4....  / / / /r c|ddd}t|d|zd}|r ||S|jd|dS) aJ Called when a request is sent to this channel. By default it delegates to self.request_. If this function returns true, the request succeeded, otherwise it failed. @type requestType: L{bytes} @type data: L{bytes} @rtype: L{bool} -_r$request_Nz#unhandled request for {requestType}) requestTyper)replacer&getattrr1r2)rrCrfoofs r requestReceivedzSSHChannel.requestReceivedsp!!$--44W== D*s*D 1 1  1T77N <+VVVqr c>|jd|dS)zL Called when we receive data. @type data: L{bytes} zgot data {data})rNr1debugrrs r dataReceivedzSSHChannel.dataReceiveds# )55555r c@|jd||dS)z Called when we receive extended data (usually standard error). @type dataType: L{int} @type data: L{str} z%got extended data {dataType} {data!r})dataTyperNrJrrOrs r extReceivedzSSHChannel.extReceiveds2  3hT      r c:|jddS)zD Called when the other side will send no more data. z remote eofNr0r's r eofReceivedzSSHChannel.eofReceiveds |$$$$$r cb|jd|dS)zD Called when the other side has closed the channel. z remote closeN)r1r2loseConnectionr's r closeReceivedzSSHChannel.closeReceiveds0 ~&&& r c:|jddS)z Called when the channel is closed. This means that both our side and the remote side have closed the channel. closedNr0r's r rXzSSHChannel.closeds x     r c|jr|xj|z c_dSt|}||jkrF|d|j||jdc}|_d|_||j}|j}|jj}td||}|D]}||||||z|xj|zc_|j r|js| dSdSdS)z Write some data to the channel. If there is not enough remote window available, buffer until it is. Otherwise, split the data into packets of length remoteMaxPacket and send them. @type data: L{bytes} Nr) rlenrr stopWritingrrsendDatarangerrU)rrtoprmpr:roffsets r r:zSSHChannel.writes4 8  HH HH F$ii & & &,t,,-T*,,- D$( DO      'C" " !S#   5 5F E$Vfsl23 4 4 4 4 $ < " "    ! ! ! ! ! " " " "r c|jrQ|jdd|kr|jddxx|z cc<n|j||gdSt||jkrB|d|j|||jdggc}|_d|_|t||jkre|j|||d|j||jd}|xj|jzc_t||jke|r9|j||||xjt|zc_|j r| dSdS)a Send extended data to this channel. If there is not enough remote window available, buffer until there is. Otherwise, split the data into packets of length remoteMaxPacket and send them. @type dataType: L{int} @type data: L{bytes} rr N) rappendrZrrr[rrsendExtendedDatarrUrPs r r;zSSHChannel.writeExtendeds ; {2q!X-- B"""d*"""" ""Hd#3444 F t99t, , ,,t,,-D!6!8!89:; D$+ DO      $ii$... I & &tXtR>"""""r cld|_|js#|js|j|dSdSdS)zr Close the channel if there is no buferred data. Otherwise, note the request and return. r N)rrrr sendCloser's r rUzSSHChannel.loseConnectionsN  x &  & I   % % % % % & & & &r c>|jjS)z See: L{ITransport.getPeer} @return: The remote address of this connection. @rtype: L{SSHTransportAddress}. )r transportgetPeerr's r rmzSSHChannel.getPeery"**,,,r c>|jjS)z See: L{ITransport.getHost} @return: An address describing this side of the connection. @rtype: L{SSHTransportAddress}. )rrlgetHostr's r rpzSSHChannel.getHost%rnr cdS)z Called when the remote buffer is full, as a hint to stop writing. This can be ignored, but it can be helpful. Nr's r r[zSSHChannel.stopWriting.r cdS)ze Called when the remote buffer has more room, as a hint to continue writing. Nrrr's r r9zSSHChannel.startWriting4rsr )rrrrNNN)__name__ __module__ __qualname____doc__rr1r bytes__annotations__r!r-r(r%r.r3r7r>rHrMrQrSrVrXr:r;rhrUrmrpr[r9rrr r rrs@ 688DD%  600000  5     FFF'''TTT///*$666    %%% !!!""":"""@###&&&------        r rN) rxzope.interfacertwisted.internetrtwisted.loggerrtwisted.pythonr ITransportrrrr r rs '&&&&&''''''!!!!!! Z "##c c c c c c c $#c c c r