tf3JdZddlZddlmZddlmZmZmZddlm Z m Z m Z m Z ddl mZddlmZddlmZdd lmZmZmZdd lmZdd lmZmZdd lmZdd lmZedZ e rddl!m"Z"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(n GddZ"GddZ)Gdde"j*Z+GddZ,ddlm-Z-e re-j.e,e+e(j/Gddej0Z1GddZ2GddZ3Gd d!Z4Gd"d#Z5e dd$l!m6Z6dd%l$m7Z7m8Z8m9Z9m:Z:m;Z;mZ?Gd*d+e9j@ZAGd,d-ZBGd.d/eBe;jCZDGd0d1eBe;jEZFGd2d3eejNZQGd?d@ejNZRdS)Az! Tests for L{twisted.conch.ssh}. N)chain)DictListTuple)privateDSA_opensshprivateRSA_opensshpublicDSA_opensshpublicRSA_openssh) LoopbackRelay)portal)UnauthorizedLogin)deferprotocolreactor)ProcessTerminated)failurelog) requireModule)unittest cryptography)avatarerror)_kexcommon forwardingsessionc(eZdZGddZdS)rceZdZdS)avatar.ConchUserN)__name__ __module__ __qualname__Z/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/conch/test/test_ssh.py ConchUserr$s Dr$r&N)r r!r"r&r#r$r%rr#s<          r$rc"eZdZdZdZdZdZdS)ConchTestRealma" A realm which expects a particular avatarId to log in once and creates a L{ConchTestAvatar} for that request. @ivar expectedAvatarID: The only avatarID that this realm will produce an avatar for. @ivar avatar: A reference to the avatar after it is requested. Nc||_dSN)expectedAvatarID)selfr+s r%__init__zConchTestRealm.__init__5s 0r$c||jkrC|jtdt|_|d|j|jjfStd|jd|)z Return a new L{ConchTestAvatar} if the avatarID matches the expected one and this is the first avatar request. NzOnly one login allowedrzOnly z may log in, not )r+rr ConchTestAvatarlogout)r,avatarIDmind interfacess r% requestAvatarzConchTestRealm.requestAvatar8sv t, , ,{&'(@AAA)++DKa=$+t{/AA A JD) J Jh J J   r$)r r!r"__doc__rr-r4r#r$r%r(r((sCF111      r$r(cBeZdZdZesdZdZdZdZdZ dZ dZ d Z d S) r/z An avatar against which various SSH features can be tested. @ivar loggedOut: A flag indicating whether the avatar logout method has been called. cannot run without cryptographyFctj|i|_i|_|jtjtj d|j dtidS)N)sessions direct-tcpipcrazy) rr&r- listenersglobalRequests channelLookupupdater SSHSessionropenConnectForwardingClientsubsystemLookupCrazySubsystemr,s r%r-zConchTestAvatar.__init__Ts}!!$'''  !!#.!+!G     ##X~$>?????r$c||jd<dS)Nfoor<r,datas r% global_foozConchTestAvatar.global_foo`s%)E"qr$c||jd<dS)Nfoo_2)rFdatarGrHs r% global_foo_2zConchTestAvatar.global_foo_2ds'+G$zr$ctj|\}} tj|tj|j||ftj|}||j||f<dS#t$rtj ddYdSwxYw)N) interfacerFz2something went wrong with remote->local forwardingr) runpackGlobal_tcpip_forwardr listenTCPSSHListenForwardingFactoryconn SSHListenServerForwardingChannelr; BaseExceptionrerrr,rIhostportlisteners r%global_tcpip_forwardz$ConchTestAvatar.global_tcpip_forwardhs:4@@ d (5Id|Z-X H,4DND$< (1     GDN O O O11 s%%tTlD99 1 ND$< (   qr$cd|_|jD]-}tjd|z|.dS)NTzstopListening %s) loggedOutr;valuesrmsgr_)r,r[s r%r0zConchTestAvatar.logouts[--// % %H G&1 2 2 2  " " $ $ $ $ % %r$N) r r!r"r5rskiprbr-rJrNr\r`r0r#r$r%r/r/Gs 10I @ @ @"%%%%%r$r/c6eZdZdZdZdZdZdZdZdZ dS) ConchSessionForTestAvatarz2 An ISession adapter for ConchTestAvatar. c||_||j_d|_d|_d|_d|_t j|_dS)zq Initialize the session and create a reference to it on the avatar for later inspection. NFr) r _testSessioncmdprotoptyReqeofrDeferredonClose)r,rs r%r-z"ConchSessionForTestAvatar.__init__sD  #'    ~'' r$cXtjd||_||_d|_dS)Nzpty reqT)rrd _terminalType _windowSizerl)r,term windowSizeattrss r%getPtyz ConchSessionForTestAvatar.getPtys-  !% r$chtjd||_t|d|_dS)Nz opening shellshell)rrdrk EchoTransportrj)r,rks r% openShellz#ConchSessionForTestAvatar.openShells2     er$c||_||_|d}|dkr*t|}t jd|jn|dkrAt|}||dd|n|dkrAt|}||dd|n[|dkrAt|}||dd|ntj dd |j jj_dS) Nrfalsesechossechoseechobad execrF)rjrksplitFalseTransportr callLaterloseConnectionrywriteSuperEchoTransportErrEchoTransportr ConchErrorrrT transportexpectedLoseConnection)r,rkrjfts r% execCommandz%ConchSessionForTestAvatar.execCommandsH IIKKN ==u%%A  a!1 2 2 2 2 '\\e$$A GGCG          (]]"5))A GGCG          (]] ''A GGCG         ":.. .<= "999r$cd|_dSNrF)rmrCs r% eofReceivedz%ConchSessionForTestAvatar.eofReceiveds r$ctjd|jz|jjj|_|jddS)Nzclosed cmd "%s") rrdrjrkrremoteWindowLeftremoteWindowLeftAtCloserocallbackrCs r%closedz ConchSessionForTestAvatar.closedsF !DH,---'+z'9'J$ d#####r$N) r r!r"r5r-rvrzrrrr#r$r%rgrgsx ( ( (  >>>2$$$$$r$rg) componentsceZdZdZdZdS)rBcdSr*r#)r,argskws r%r-zCrazySubsystem.__init__s r$cdS)z good ... good Nr#rCs r%connectionMadezCrazySubsystem.connectionMadesr$N)r r!r"r-rr#r$r%rBrBs2        r$rBceZdZdZdZdZdS)ra False transport should act like a /bin/false execution, i.e. just exit with nonzero status, writing nothing to the terminal. @ivar proto: The protocol associated with this transport. @ivar closed: A flag tracking whether C{loseConnection} has been called yet. cL||_||d|_dS)zY @type p L{twisted.conch.ssh.session.SSHSessionProcessProtocol} instance rNrkmakeConnectionrr,ps r%r-zFalseTransport.__init__s*   r$c 2|jrdSd|_|j|j|j|jt jtddddS)zI Disconnect the protocol associated with this transport. NrF rrkinConnectionLostoutConnectionLosterrConnectionLost processEndedrFailurerrCs r%rzFalseTransport.loseConnections ;  F  ##%%% $$&&& $$&&& 0A#tT0R0R S STTTTTr$N)r r!r"r5r-rr#r$r%rrsA U U U U Ur$rc eZdZdZdZdZdS)rycL||_||d|_dSNrrrs r%r-zEchoTransport.__init__(   r$ctjt||j||jdd|vr|dSdS)N )rrdreprrk outReceivedrrHs r%rzEchoTransport.writesl T  t$$$ w''' d??    ! ! ! ! ! ?r$c 2|jrdSd|_|j|j|j|jt jtddddSNrFrrrCs r%rzEchoTransport.loseConnection ;  F  ##%%% $$&&& $$&&& 0A!T40P0P Q QRRRRRr$Nr r!r"r-rrr#r$r%ryrysF """SSSSSr$ryc eZdZdZdZdZdS)rcL||_||d|_dSrrrs r%r-zErrEchoTransport.__init__rr$cn|j||jddSNr)rk errReceivedrHs r%rzErrEchoTransport.writes4 t$$$ w'''''r$c 2|jrdSd|_|j|j|j|jt jtddddSrrrCs r%rzErrEchoTransport.loseConnectionrr$Nrr#r$r%rrsF (((SSSSSr$rc eZdZdZdZdZdS)rcL||_||d|_dSrrrs r%r-zSuperEchoTransport.__init__%rr$c|j||jd|j||jddSr)rkrrrHs r%rzSuperEchoTransport.write*s` t$$$ w''' t$$$ w'''''r$c 2|jrdSd|_|j|j|j|jt jtddddSrrrCs r%rz!SuperEchoTransport.loseConnection0rr$Nrr#r$r%rr$sF ((( SSSSSr$r)checkers)channel connectionfactorykeysruserauthc$eZdZejfZdZdS)ConchTestPasswordCheckerc|jdkr$|jdkrtj|jStjt dS)NtestusertestpasszBad credentials)usernamepasswordrsucceedfail Exception)r, credentialss r%requestAvatarIdz(ConchTestPasswordChecker.requestAvatarIdHsJ$ 33(K77}[%9::::i(9::;; ;r$N)r r!r"rIUsernamePasswordcredentialInterfacesrr#r$r%rrEs/ ( :< < < < < K|]}|VdSr*)supportedSignatureAlgorithms).0keys r% z7ConchTestServerFactory.buildProtocol..asB$$4466$$$$$$r$r) ConchTestServerlistr from_iterable privateKeysrcsupportedPublicKeysrhasattrrrk)r,addrrks r% buildProtocolz$ConchTestServerFactory.buildProtocol^s#%%E(,#$$#/6688$$$))E % !EMt566 K/3/J,DJLr$ctjttjtdSN)ssh-rsassh-dssrKey fromStringr r rCs r% getPublicKeysz$ConchTestServerFactory.getPublicKeysns9 H//0ABB H//0ABB r$ctjttjtdSrrrrrrrCs r%getPrivateKeysz%ConchTestServerFactory.getPrivateKeysts9 H//0BCC H//0BCC r$returnc0dtjdgiS)a% Diffie-Hellman primes that can be used for the diffie-hellman-group-exchange-sha1 key exchange. @return: The primes and generators. @rtype: L{dict} mapping the key size to a C{list} of C{(generator, prime)} tupple. isdiffie-hellman-group14-sha1)rgetDHGeneratorAndPrimerCs r% getPrimesz ConchTestServerFactory.getPrimeszs467UVVWX Xr$cDtj|||Sr*)r SSHFactory getService)r,transnames r%rz!ConchTestServerFactory.getServices%00udCC Cr$N)r r!r"noisyrSSHUserAuthServerr SSHConnectionservicesrrrrintrrrrr#r$r%rrVs&7)7               YtCeCHo)>$>? Y Y Y Y D D D D Dr$rc$eZdZdZdZdZdZdS) ConchTestBasercz|jrdSt|dstjd|d|d|_dS)Nrzunexpectedly lost connection  rF)donerrFailTestr,reasons r%connectionLostzConchTestBase.connectionLostsYy 4!9:: 'DDDDFDDDIIIr$c d|_|tjkr*tjt d|d|d||dS)NrFzgot disconnect for z : reason z, desc: )rrDISCONNECT_BY_APPLICATIONrrWrr)r, reasonCodedescs r% receiveErrorzConchTestBase.receiveErrorsm*+D ' Y@@@I44TT3    ! ! ! ! !r$c0tjd|)Nzgot unimplemented: seqid )rr )r,seqIDs r%receiveUnimplementedz"ConchTestBase.receiveUnimplementeds#$G$G$GHH Hr$N)r r!r"r rrrr#r$r%rrsK    " " "  I I I I Ir$rceZdZdZdS)rc|t||tj||dSr*)rrrSSHServerTransportr s r%rzConchTestServer.connectionLost7  ( (v 6 6 6  ( 7 7f E E E E Er$N)r r!r"rr#r$r%rrs( F F F F Fr$rc*eZdZdZdZdZdZdZdS)ConchTestClientz @ivar _channelFactory: A callable which accepts an SSH connection and returns a channel which will be attached to a new channel on that connection. c||_dSr*)_channelFactoryr,channelFactorys r%r-zConchTestClient.__init__s#1D r$c|t||tj||dSr*)rrrSSHClientTransportr s r%rzConchTestClient.connectionLostrr$c|tjtk}|dk}|r|rt jdSt jtdS)Ns/85:25:04:32:58:55:96:9f:57:ee:fb:a8:1a:ea:69:darFzKey or fingerprint mismatch) rrrr blobrrrr)r,rfpkeyMatchfingerprintMatchs r% verifyHostKeyzConchTestClient.verifyHostKeysndh112CDDIIKKKH!%WW  (, (}Q''':i(EFFGG Gr$cp|tdt|jdS)Nr)requestServiceConchTestClientAuthConchTestClientConnectionrrCs r%connectionSecurez ConchTestClient.connectionSecuresB   #!:4;O!P!P     r$N)r r!r"r5r-rr)r.r#r$r%rrs`   2 2 2 F F F H H H     r$rc2eZdZdZdZdZdZdZdZdZ dS)r,rc|js|jrtjdtj||dS)Nz2got USERAUTH_SUCCESS before password and publickey)canSucceedPasswordcanSucceedPublicKeyrr rSSHUserAuthClientssh_USERAUTH_SUCCESS)r,packets r%r4z(ConchTestClientAuth.ssh_USERAUTH_SUCCESSsP* t/G 'H  & ; ;D& I I I I Ir$c8d|_tjdS)NrFr)r1rrrCs r% getPasswordzConchTestClientAuth.getPasswords&'D #=-- -r$c|d|_tjtjt Sr)r2rrrrrrrCs r% getPrivateKeyz!ConchTestClientAuth.getPrivateKeys+'(D $=!4!45G!H!HII Ir$cJtjtSr*)rrrr rCs r% getPublicKeyz ConchTestClientAuth.getPublicKeys8&&'899 9r$N) r r!r" hasTriedNoner2r1r4r7r9r;r#r$r%r,r,sg  J J J . . . J J J : : : : :r$r,c*eZdZdZdZdZdZdZdZdS)r-z @ivar _completed: A L{Deferred} which will be fired when the number of results collected reaches C{totalResults}. rrcRtj|||_dSr*)rrr-rr s r%r-z"ConchTestClientConnection.__init__s'  $ - -d 3 3 3#1D r$cX|||dS)N)rT) openChannelrrCs r%serviceStartedz(ConchTestClientConnection.serviceStarteds-   T11t1<< = = = = =r$N) r r!r"r5rresults totalResultsr-rBr#r$r%r-r-sM  !  2 2 2 > > > > >r$r-c>eZdZdZdZdZdZdZdZdZ dZ d S) SSHTestChannelc||_||_g|_g|_t j|_tjj |g|Ri|dSr*) r_openedreceived receivedExtrrnror SSHChannelr-)r,ropenedrkwargss r%r-zSSHTestChannel.__init__sXDI!DLDM!D  >++DL   ' >t > > >v > > > > >r$c:|j|dSr*)rHerrbackr s r% openFailedzSSHTestChannel.openFaileds L  ( ( ( ( (r$c:|j|dSr*)rHr)r,ignores r% channelOpenzSSHTestChannel.channelOpen L ! !$ ' ' ' ' 'r$c:|j|dSr*)rIappendrHs r% dataReceivedzSSHTestChannel.dataReceiveds M  & & & & &r$c|tjkr|j|dSt jd|dS)NzUnrecognized extended data: )rEXTENDED_DATA_STDERRrJrVrrd)r,dataTyperIs r% extReceivedzSSHTestChannel.extReceivedsL:::: ''-----CxCCDDDDDr$c>tjd|\|_dS)Nz>L)structunpackstatus)r,r_s r%request_exit_statusz"SSHTestChannel.request_exit_status s"M$77MT[[[r$cd|_dS)NT) eofCalledrCs r%rzSSHTestChannel.eofReceiveds !DNNNr$c:|jddSr*)rorrCs r%rzSSHTestChannel.closedrTr$N) r r!r"r-rPrSrWr[r`rrr#r$r%rFrFs ? ? ? ) ) ) ( ( ( ' ' ' E E E  8 8 8 " " " ( ( ( ( (r$rFctjdtjt gi}tj|S)z Produces a SSHPublicKeyChecker with an in-memory key mapping with a single use: 'testuser' @return: L{twisted.conch.checkers.SSHPublicKeyChecker} r)rInMemorySSHKeyDBrrrr SSHPublicKeyChecker)conchTestPublicKeyDBs r%conchTestPublicKeyCheckerrhsG (8 48../@AAB C  +,@AAAr$cReZdZdZesdZddZdZdZdZ dZ d Z d Z d Z d Zd S)SSHProtocolTestsz^ Tests for communication between L{SSHServerTransport} and L{SSHClientTransport}. can't run without cryptographyr9c tjtd|_t j|j}t }|t|t||t}||_| | d|_ t|j |_t!fd|_t|j|_|j |j|j|jS)z Create a connected SSH client and server protocol pair and return a L{Deferred} which fires with an L{SSHTestChannel} instance connected to a channel on that SSH connection. rNc$tfd|iS)NrT)rF)rTrMrresults r%z:SSHProtocolTests._ourServerOurClientTest..>sfJJ4J6JJr$)rrnr(realmr PortalrregisterCheckerrrhr startFactoryrserverr clientTransportrclientserverTransportr)r,rrMrsshpcfacrns `` @r%_ourServerOurClientTestz(SSHProtocolTests._ourServerOurClientTest+sB !!#K00 M$* % %#%% 688999 799::: %   $&&  ''-- ,T[99% J J J J J J    -T[99 ""4#7888 ""4#7888 r$c}fd}|j|fd}|j|fd}|j|fd}|j||S)z Run the Conch server against the Conch client. Set up several different channels which exercise different behaviors and wait for them to complete. Verify that the channels with errors log them. c |_|j|dt jddt S)N subsystems not-crazyrFr assertFailurerT sendRequestrNSrrr,s r% cbSubsystemzFSSHProtocolTests.test_subsystemsAndGlobalRequests..cbSubsystemOsO"DL%% ((\69\+B+BA  r$cpj}|j|dtjddS)Nr}r:rFrrTrrrignoredrr,s r%cbNotCrazyFailedzKSSHProtocolTests.test_subsystemsAndGlobalRequests..cbNotCrazyFailedZs7lG<++vy':':A r$cPj}|jddd}|jddd}|jd|jdddt }tj|||gS)NfoobarrFsfoo-2bar2rM) rrTsendGlobalRequest addCallback assertEqualrrr gatherResults)rrd1d2d3r,s r%cbGlobalRequestszKSSHProtocolTests.test_subsystemsAndGlobalRequests..cbGlobalRequestsbslG//BBB//'1EEB NN4+W 5 5 5## ..vvqAA9B&B|44 4r$cjjjdddj}d|jj_|j|j dS)Nrr)rErLT) rrprr<rrTrrserviceStoppedrrs r% disconnectzESSHProtocolTests.test_subsystemsAndGlobalRequests..disconnectqsq    !0&72S2S   lG<@GL " 9 L ' ' ) ) ) "G " $ $ $ $ $r$rzr)r,rrrrrs` r% test_subsystemsAndGlobalRequestsz1SSHProtocolTests.test_subsystemsAndGlobalRequestsGs ..00      K(((      ,--- 5 5 5 5 5 ,--- % % % % % J'''r$c}tjdddfd}|j|fd}|j|fd}|j|fd}|j||S)z L{SSHChannel.sendRequest} can open a shell with a I{pty-req} request, specifying a terminal type and window size. conch-test-termPrrr$cL|_|j|ddS)Nspty-reqrF)rrTr)rrIr,s r% cbChannelz.SSHProtocolTests.test_shell..cbChannels&"DL<++GZqII Ir$cxjjjjdj}|jjj|jd|jd |j j }|j |dddS)Nrrrrxr$rF) rprrTchannelsrassertIsrrqrr assertTruerlrr)rrrr,s r%cbPtyz*SSHProtocolTests.test_shell..cbPtysj',5a8@G MM'.$**; < < <   W24F G G G   W0. A A A OOGN + + +lG<++GXsAFF Fr$cjdjjjt jjjjjj jgS)Nstesting the shell!) rrrTsendEOFrrrorprrirr,s r%cbShellz,SSHProtocolTests.test_shell..cbShellsb L  8 9 9 9 L  % %dl 3 3 3&%tz'8'E'MN r$cbjjdkr"tjdjjfzdjjdjjj j j j dS)Nrzshell exit status was not 0: %ir$stesting the shell! ) rr_rrdrjoinrIrrbrprrirmrs r%cbExitedz-SSHProtocolTests.test_shell..cbExiteds|"a''9T\=P ? ? ? ? ?r$)rzrpackRequest_pty_reqr)r,rrrrrrIs` @r% test_shellzSSHProtocolTests.test_shell~s ..00*+=~sSS J J J J J J I&&& G G G G G E"""      G$$$ @ @ @ @ @ H%%%r$c}fd}|j|fd}|j||S)z If L{SSHChannel.sendRequest} issues an exec which the server responds to with an error, the L{Deferred} it returns fires its errback. c |_|j|dt jddt S)Nexecs jumboliahrFr~rs r%rz3SSHProtocolTests.test_failedExec..cbChannelsI"DL%% (('69\;R;RTUVV r$ctj}|djjddS)Nr)rN)flushLoggedErrorsrrrvaluerrerrorsr,s r%cbFailedz2SSHProtocolTests.test_failedExec..cbFailedsA++E,<==F   VAY_13E F F F F Fr$r)r,rrrs` r%test_failedExecz SSHProtocolTests.test_failedExecs| ..00      I&&& G G G G G H%%%r$c}fd}|j|fd}|j|fd}|j||S)z When the process started by a L{SSHChannel.sendRequest} exec request exits, the exit status is reported to the channel. cp|_|j|dtjddS)Nrr|rFrrs r%rz5SSHProtocolTests.test_falseChannel..cbChannels1"DL<++GWfi>Q>QSTUU Ur$cjjSr*rrors r%cbExecz2SSHProtocolTests.test_falseChannel..cbExec<' 'r$cjjgjjddSr)rrrIassertNotEqualr_rs r%cbClosedz4SSHProtocolTests.test_falseChannel..cbCloseds?   T\2B 7 7 7    3Q 7 7 7 7 7r$rr,rrrrs` r%test_falseChannelz"SSHProtocolTests.test_falseChannels ..00 V V V V V I&&& ( ( ( ( ( F### 8 8 8 8 8 H%%%r$cdd}fd}|j|fd}|j|fd}|j||S)z Bytes sent over the extended channel for stderr data are delivered to the channel's C{extReceived} method. r} localWindowlocalMaxPacketcp|_|j|dtjddS)Nrs eecho hellorFrrs r%rz5SSHProtocolTests.test_errorChannel..cbChannel7"DL<++&)N";";Q r$cltjjjjjjjgSr*rrrrorprrirs r%rz2SSHProtocolTests.test_errorChannel..cbExec0&%tz'8'E'MN r$cjjgdjjdjjdjjjjdjjj j j j dS)Nr$hello rr) rrrIrrJr_rrblocalWindowLeftrprrirrs r%rz4SSHProtocolTests.test_errorChannel..cbCloseds   T\2B 7 7 7   SXXdl&>?? N N N   T\0! 4 4 4 OODL2 3 3 3   T\91 = = =    , !.F     r$rrs` r%test_errorChannelz"SSHProtocolTests.test_errorChannels ..1Q.OO      I&&&      F###      H%%%r$cdt}fd}|||S)z When an attempt is made to open an unknown channel type, the L{Deferred} returned by L{SSHChannel.sendRequest} fires its errback. scrazy-unknown-channelctj}|djjdt |ddS)Nr)zunknown channelrF)rrrrrrrrs r%rz6SSHProtocolTests.test_unknownChannel..cbFaileds[++E,<==F   VAY_13I J J J   S[[! , , , , ,r$)rrzrr)r,drs` r%test_unknownChannelz$SSHProtocolTests.test_unknownChannels`     ( ()A B BI   - - - - - hr$cdd}fd}|j|fd}|j|fd}|j||S)zc An L{SSHChannel} can be configured with a maximum packet size to receive. rFrcp|_|j|dtjddS)Nrs secho hellorFrrs r%rz2SSHProtocolTests.test_maxPacket..cbChannelrr$cjjSr*rrs r%rz/SSHProtocolTests.test_maxPacket..cbExec'rr$cjjddjjddjjdjjdjjdS)Nrr$rr) rrr_rrIrJrrrbrs r%rz1SSHProtocolTests.test_maxPacket..cbClosed,s   T\0! 4 4 4   SXXdl&;<?? N N N   T\92 > > > OODL2 3 3 3 3 3r$rrs` r%test_maxPacketzSSHProtocolTests.test_maxPackets..2a.PP      I&&& ( ( ( ( ( F### 4 4 4 4 4 H%%%r$cdd}fd}|j|fd}|j|fd}|j||S)ze Normal standard out bytes are sent to the channel's C{dataReceived} method. rr}rcp|_|j|dtjddS)Nrs echo hellorFrrs r%rz-SSHProtocolTests.test_echo..cbChannel=s7"DL<++&)M":":A r$cltjjjjjjjgSr*rrs r%cbEchoz*SSHProtocolTests.test_echo..cbEchoErr$cjjddjjdjjdjjjjjj j j dS)Nrr$rr) rrr_rrIrrrbrprrirrs r%rz,SSHProtocolTests.test_echo..cbClosedLs   T\0! 4 4 4   SXXdl&;<.`svr$cNdtjtiSNr)rrrr r#r$r%roz0SSHFactoryTests.makeSSHFactory..as ++,=>>, r$cNdtjtiSr)rrrrr#r$r%roz0SSHFactoryTests.makeSSHFactory..ds ++,>??- r$)rrrrrrs)r,r sshFactorys ` r%makeSSHFactoryzSSHFactoryTests.makeSSHFactory^sW')) -~~~ $ $  % % ! !!!r$c|}|jd}||tjdS)zc By default, buildProtocol() constructs an instance of SSHServerTransport. N)rrassertIsInstancerr)r,rrs r%test_buildProtocolz"SSHFactoryTests.test_buildProtocoljsF %%''(7(.. h (DEEEEEr$cgfd}|}||_|jd|dgdS)zc buildProtocol() calls 'self.protocol()' to construct a protocol instance. cT|tjSr*)rVrr)rcallss r% makeProtocolzHSSHFactoryTests.test_buildProtocolRespectsProtocol..makeProtocolzs$ LL   /11 1r$Nr#)rrrr)r,rrrs @r%"test_buildProtocolRespectsProtocolz2SSHFactoryTests.test_buildProtocolRespectsProtocolsso  2 2 2 2 2%%'''d### "u%%%%%r$ctj}d|_d|_||d}|gd|jdS)zq buildProtocol() sets supportedPublicKeys to the list of supported signature algorithms. ctjttjtdSrrr#r$r%rozGSSHFactoryTests.test_buildProtocolSignatureAlgorithms..s6++,=>>++,=>># # r$ctjttjtdSrrr#r$r%rozGSSHFactoryTests.test_buildProtocolSignatureAlgorithms..s6++,>??++,>??$ $ r$N)s rsa-sha2-512s rsa-sha2-256rr)rrrrrsrrr)r,rrs r%%test_buildProtocolSignatureAlgorithmsz5SSHFactoryTests.test_buildProtocolSignatureAlgorithmss         OOD ! !  F F F !     r$c|d}|d}|d|j|d|jdS)zg Group key exchanges are not supported when we don't have the primes database. Nr"diffie-hellman-group-exchange-sha1$diffie-hellman-group-exchange-sha256)rr assertNotInsupportedKeyExchanges)r,f1p1s r%test_buildProtocolNoPrimesz*SSHFactoryTests.test_buildProtocolNoPrimessy   - -   d # #  123K     3R5M     r$c|ddi}|d}|d|j|d|jdS)zU Group key exchanges are supported when we have the primes database. rF)rrrNrr)rrassertInrr,f2p2s r%test_buildProtocolWithPrimesz,SSHFactoryTests.test_buildProtocolWithPrimessg F 4 4   d # # ;R=UVVV =r?WXXXXXr$c|}|d}|dd|jdS)z_ ECDSA key exchanges are listed with 256 having a higher priority among ECDSA. Ns8ecdh-sha2-nistp256,ecdh-sha2-nistp384,ecdh-sha2-nistp521,)rrrrrrs r%test_buildProtocolKexECDSAz*SSHFactoryTests.test_buildProtocolKexECDSAs_ " "   d # # G IIb. / /     r$r*) r r!r"rrerrrrrrr r#r$r%rrZs 0/    FFF&&&    *   Y Y Y      r$rc\eZdZdZesdZereejZdZ dZ dZ dZ dZ dS) MPTestszs Tests for L{common.getMP}. @cvar getMP: a method providing a MP parser. @type getMP: C{callable} rkcX||dddS)z L{common.getMP} should parse the a multiple precision integer from a string: a 4-byte length followed by length bytes of the integer. s)rFr$NrgetMPrCs r% test_getMPzMPTests.test_getMPs- $GHH(SSSSSr$cX||dddS)zv L{common.getMP} should be able to parse a big enough integer (that doesn't fit on one byte). s)ir$NrrCs r%test_getMPBigIntegerzMPTests.test_getMPBigIntegers8  JJ: ; ;_     r$cZ||ddddS)zg L{common.getMP} has the ability to parse multiple integer in the same string. sr)rFrr$NrrCs r%test_multipleGetMPzMPTests.test_multipleGetMPsB  JJW         r$cX||dddS)zu When more data than needed is sent to L{common.getMP}, it should return the remaining data. s foo)rFrNrrCs r%test_getMPRemainingDatazMPTests.test_getMPRemainingDatas8  JJ= > >      r$cR|tj|jddS)z When the string passed to L{common.getMP} doesn't even make 5 bytes, it should raise a L{struct.error}. sN) assertRaisesr]rrrCs r%test_notEnoughDatazMPTests.test_notEnoughDatas& &, K@@@@@r$N)r r!r"r5rre staticmethodrrrrrrrr#r$r%r r s 0/+ V\**TTT          AAAAAr$r c eZdZdZesdZdZdS)GMPYInstallDeprecationTestszI Tests for the deprecation of former GMPY accidental public API. r7ctj||jg}|t |d||ddddS)zD L{twisted.conch.ssh.common.install} is deprecated. rFrmessagezAtwisted.conch.ssh.common.install was deprecated in Twisted 16.5.0N)rinstall flushWarningstest_deprecatedrr)r,warningss r%r!z+GMPYInstallDeprecationTests.test_deprecatedsx %%t';&<== X***  QK " O     r$N)r r!r"r5rrer!r#r$r%rrs< 10      r$r)Sr5r] itertoolsrtypingrrrtwisted.conch.test.keydatarrr r twisted.conch.test.loopbackr twisted.credr twisted.cred.errorr twisted.internetrrrtwisted.internet.errorrtwisted.pythonrrtwisted.python.reflectr twisted.trialrr twisted.conchrrtwisted.conch.sshrrrrr(r&r/rgrregisterAdapterISessionProtocolrBrryrrrrrrrrrrSSHProtocolCheckerrrrrrrr#rr3r,rr-rKrFrhTestCaserjrr rr#r$r%r5sO  $$$$$$$$$$ 6555550000005555555555444444''''''''000000""""""}^,, ++++++++CCCCCCCCCCCCC         >?%?%?%?%?%f&?%?%?%D=$=$=$=$=$=$=$=$@&%%%%%J!?G4D      X&   UUUUUUUU<SSSSSSSS.SSSSSSSS(SSSSSSSS,&&&&&& < < < < < < < <h9 4D4D4D4D4D!34D4D4DlIIIIIIII>FFFFF-)EFFF -)E8:::::h8:::.>>>>>J$<>>>"(((((+(((B B B Buuuuux(uuup f f f f f h'f f f R9A9A9A9A9Ah9A9A9Ax     ("3     r$