+ Dfj3lRt^RIt^RIHt^RIHtHtHt^RIH t H t H t H t ^RI Ht^RIHt^RIHt^RIHtHtHt^R IHt^R IHtHt^R IHt^R IHt]!R 4t ] 'd^RI!H"t"H#t#^RI$H%t%H&t&H't'H(t(M !RR4t"!RR4t)!RR]"PT4t+!RR4t,^RIH-t-] 'd]-P\!],]+](P^4!RR]P`4t1!RR4t2!RR4t3!RR 4t4!R!R"4t5] e^R#I!H6t6^R$I$H7t7H8t8H9t9H:t:H;t;HR?]P4tRR#)@z! 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*]tRt^#t!RR4tRtR#)rc]tRt^$tRtR#)avatar.ConchUserN)__name__ __module__ __qualname____firstlineno____static_attributes__r=/usr/lib/python3/dist-packages/twisted/conch/test/test_ssh.py ConchUserr$s r%r'rN)r r!r"r#r'r$rr%r&rr#s   r%rc4a]tRt^(toRtRtRtRtRtVt R#)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. NcWnR#N)expectedAvatarID)selfr,s&&r&__init__ConchTestRealm.__init__5s 0r%c WP8XdSVPe \R4h\4VnV^,VPVPP3#\RVP: RV: 24h)zp Return a new L{ConchTestAvatar} if the avatarID matches the expected one and this is the first avatar request. zOnly one login allowedzOnly z may log in, not )r,rr ConchTestAvatarlogout)r-avatarIDmind interfacess&&&*r& requestAvatarConchTestRealm.requestAvatar8st ,, ,{{&'(@AA)+DKa=$++t{{/A/AA AD)),,=h\ J  r%)rr,) r r!r"r#__doc__rr.r6r$__classdictcell__ __classdict__s@r&r)r)(s F1   r%r)c`a]tRt^GtoRt]'gRtRtRtRt Rt Rt Rt R t R tVtR #) r1z 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 cryptographyFc\PPV4/Vn/VnVP P R\PR\P/4VPP R\/4R#)sessions direct-tcpipcrazyN) rr'r. listenersglobalRequests channelLookupupdater SSHSessionropenConnectForwardingClientsubsystemLookupCrazySubsystemr-s&r&r.ConchTestAvatar.__init__Tso!!$'  !!G..!G!G  ##X~$>?r%c"WPR&^#)foorBr-datas&&r& global_fooConchTestAvatar.global_foo`s%)E"r%c"WPR&R#)foo_2)datarMrNs&&r& global_foo_2ConchTestAvatar.global_foo_2ds'+G$r%c8\P!V4wr#\P!V\P!VP W#3\P 4VR7pW@PW#3&^# \d\P!RR4^#i;i)) interfaceNz2something went wrong with remote->local forwarding) runpackGlobal_tcpip_forwardr listenTCPSSHListenForwardingFactoryconn SSHListenServerForwardingChannelrA BaseExceptionrerrr-rOhostportlisteners&& r&global_tcpip_forward$ConchTestAvatar.global_tcpip_forwardhs::4@  ((55II|Z-X-X H,4NND< (   GGDN O sAA33"BBc\P!V4wr#VPPW#3R4pV'g^#VPW#3VP 4^#r+)rrZrAget stopListeningras&& r&global_cancel_tcpip_forward+ConchTestAvatar.global_cancel_tcpip_forwardysO::4@ >>%%tlD9 NND< ( r%cRVnVPP4F0p\P!RV,4VP 4K2 R#)TzstopListening %sN) loggedOutrAvaluesrmsgri)r-rds& r&r2ConchTestAvatar.logouts>--/H GG&1 2  " " $0r%)rBrArmN)r r!r"r#r8rskiprmr.rPrVrerjr2r$r9r:s@r&r1r1Gs= 0I @"%%r%r1cHa]tRt^toRtRtRtRtRtRt Rt Rt Vt R #) ConchSessionForTestAvatarz* An ISession adapter for ConchTestAvatar. c WnWPnRVnRVnRVn^Vn\ P!4VnR#)zY Initialize the session and create a reference to it on the avatar for later inspection. NF) r _testSessioncmdprotoptyReqeofr DeferredonClose)r-rs&&r&r."ConchSessionForTestAvatar.__init__s=  #'    ~~' r%cX\P!R4WnW nRVnR#)zpty reqTN)rro _terminalType _windowSizerx)r-term windowSizeattrss&&&&r&getPty ConchSessionForTestAvatar.getPtys!  !% r%cb\P!R4Wn\V4RVnR#)z opening shellshellN)rrorw EchoTransportrv)r-rws&&r& openShell#ConchSessionForTestAvatar.openShells"   er%cW nWnVP4^,pVR8Xd.\V4p\P !^VP 4MVR8Xd5\V4pVPVR,4VP 4MVR8Xd5\V4pVPVR,4VP 4MQVR8Xd5\V4pVPVR,4VP 4M\P!R4h^VPPPnR#) falsesecho:NNssecho:NNseechobad execN)rvrwsplitFalseTransportr callLaterloseConnectionrwriteSuperEchoTransportErrEchoTransportr ConchErrorrr] transportexpectedLoseConnection)r-rwrvfts&&& r& execCommand%ConchSessionForTestAvatar.execCommands IIKN =u%A   a!1!1 2 '\e$A GGCG     (]"5)A GGCG     (] 'A GGCG    "":. .<= ""9r%c^VnR#)rTN)ryrIs&r& eofReceived%ConchSessionForTestAvatar.eofReceiveds r%c\P!RVP,4VPPP VnVPPR4R#)zclosed cmd "%s"N) rrorvrwrremoteWindowLeftremoteWindowLeftAtCloser{callbackrIs&r&closed ConchSessionForTestAvatar.closedsB !DHH,-'+zz'9'9'J'J$ d#r%) r~rrrvryr{rwrxrN) r r!r"r#r8r.rrrrrr$r9r:s@r&rsrss- (  >2$$r%rs) componentsc,a]tRt^toRtRtRtVtR#)rHcR#r+r)r-argskws&*,r&r.CrazySubsystem.__init__s r%c R#)z good ... good NrrIs&r&connectionMadeCrazySubsystem.connectionMadesr%rN)r r!r"r#r.rr$r9r:s@r&rHrHs   r%rHc0a]tRt^toRtRtRtRtVtR#)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. c BWnVPV4^VnR#)zI @type p L{twisted.conch.ssh.session.SSHSessionProcessProtocol} instance NrwmakeConnectionrr-ps&&r&r.FalseTransport.__init__s   r%c  LVP'dR#^VnVPP4VPP4VPP 4VPP \ P!\^RR444R#)z9 Disconnect the protocol associated with this transport. N rrwinConnectionLostoutConnectionLosterrConnectionLost processEndedrFailurerrIs&r&rFalseTransport.loseConnectionsl ;;;   ##% $$& $$& 0A#tT0R STr%rrwN) r r!r"r#r8r.rr$r9r:s@r&rrs U Ur%rc2a]tRt^toRtRtRtRtVtR#)rcBWnVPV4^VnR#rNrrs&&r&r.EchoTransport.__init__   r%c\P!\V44VPP V4VPP R4RV9dVP 4R#R#) N)rroreprrw outReceivedrrNs&&r&rEchoTransport.writesN T  t$ w' d?    ! r%c LVP'dR#^VnVPP4VPP4VPP 4VPP \ P!\^RR444R#r+rrIs&r&rEchoTransport.loseConnectionj ;;;   ##% $$& $$& 0A!T40P QRr%rN r r!r"r#r.rrr$r9r:s@r&rrs "SSr%rc2a]tRtRtoRtRtRtRtVtR#)ricBWnVPV4^VnR#rrrs&&r&r.ErrEchoTransport.__init__rr%crVPPV4VPPR4R#rN)rw errReceivedrNs&&r&rErrEchoTransport.writes& t$ w'r%c LVP'dR#^VnVPP4VPP4VPP 4VPP \ P!\^RR444R#r+rrIs&r&rErrEchoTransport.loseConnectionrr%rNrr:s@r&rrs (SSr%rc2a]tRtRtoRtRtRtRtVtR#)ri$cBWnVPV4^VnR#rrrs&&r&r.SuperEchoTransport.__init__%rr%cVPPV4VPPR4VPPV4VPPR4R#r)rwrrrNs&&r&rSuperEchoTransport.write*sJ t$ w' t$ w'r%c LVP'dR#^VnVPP4VPP4VPP 4VPP \ P!\^RR444R#r+rrIs&r&r!SuperEchoTransport.loseConnection0rr%rNrr:s@r&rr$s ( SSr%r)checkers)channel connectionfactorykeysruserauthc@a]tRtRto]P 3tRtRtVt R#)ConchTestPasswordCheckeriEcVPR8Xd2VPR8Xd!\P!VP4#\P!\ R44#)testusertestpasszBad credentials)usernamepasswordr succeedfail Exception)r- credentialss&&r&requestAvatarId(ConchTestPasswordChecker.requestAvatarIdHsH$$ 3((K7}}[%9%9::::i(9:; ;r%rN) r r!r"r#rIUsernamePasswordcredentialInterfacesrr$r9r:s@r&rrEs ( : :< < 7ConchTestServerFactory.buildProtocol..as#$844668sr) ConchTestServerlistr from_iterable privateKeysrnsupportedPublicKeysrhasattrrrw)r-addrrws&& r& buildProtocol$ConchTestServerFactory.buildProtocol^sn#%E(,##$#//668$)E % !Mt566/3/J/J,JLr%cR\PP\4R\PP\4/#ssh-rsassh-dssrKey fromStringr rrIs&r& getPublicKeys$ConchTestServerFactory.getPublicKeysns6DHH//0ABDHH//0AB r%cR\PP\4R\PP\4/#rrrrrrrIs&r&getPrivateKeys%ConchTestServerFactory.getPrivateKeysts6DHH//0BCDHH//0BC r%c\<V^8dQhRS[S[S[S[S[S[3,,3,/#)return)rintrr)formatr;s"r& __annotate__#ConchTestServerFactory.__annotate__zs. Y YtCeCHo)>$>? Yr%c 4R\P!R4./#)z 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)rgetDHGeneratorAndPrimerIs&r& getPrimes ConchTestServerFactory.getPrimeszs4667UVWX Xr%cB\PPWV4#r+)r SSHFactory getService)r-transnames&&&r&r)!ConchTestServerFactory.getServices%%00dC Cr%)rwN)r r!r"r#noisyrSSHUserAuthServerr SSHConnectionservicesr rrr%r)r$r9r:s@r&rrVsP X77 z77        Y Y D Dr%rc6a]tRtRto^tRtRtRtRtVt R#) ConchTestBaseicVP'dR#\VR4'g\P!RV RV 24h^VnR#)Nrzunexpectedly lost connection  )doner rFailTestr-reasons&&r&connectionLostConchTestBase.connectionLostsHyyy4!9::''3D6F8DDIr%c ^VnV\P8wd,\P!\ RV: RV: RV: 244VP 4R#)rTzgot disconnect for z : reason z, desc: N)rrDISCONNECT_BY_APPLICATIONrr`rr)r- reasonCodedescs&&&r& receiveErrorConchTestBase.receiveErrorsH*+D ' Y@@@T3    !r%c4\P!RV 24h)zgot unimplemented: seqid )rr6)r-seqIDs&&r&receiveUnimplemented"ConchTestBase.receiveUnimplementeds##&?w$GH Hr%)r5rN) r r!r"r#r5r9r?rCr$r9r:s@r&r2r2s   "  I Ir%r2c&a]tRtRtoRtRtVtR#)ricn\PW4\PPW4R#r+)r2r9rSSHServerTransportr7s&&r&r9ConchTestServer.connectionLost$  ( ( 6  ( ( 7 7 Er%rN)r r!r"r#r9r$r9r:s@r&rrs F Fr%rc<a]tRtRtoRtRtRtRtRtRt Vt R#) ConchTestClientiz @ivar _channelFactory: A callable which accepts an SSH connection and returns a channel which will be attached to a new channel on that connection. cWnR#r+_channelFactoryr-channelFactorys&&r&r.ConchTestClient.__init__s#1 r%cn\PW4\PPW4R#r+)r2r9rSSHClientTransportr7s&&r&r9ConchTestClient.connectionLostrIr%cV\PP\4P 48HpVR8HpV'dV'd\ P !^4#\ P!\R44#)s/85:25:04:32:58:55:96:9f:57:ee:fb:a8:1a:ea:69:dazKey or fingerprint mismatch) rrrr blobr rrr)r-rfpkeyMatchfingerprintMatchs&&& r& verifyHostKeyConchTestClient.verifyHostKeys[dhh112CDIIKKH!%WW ,}}Q''::i(EFG Gr%cbVP\R\VP444R#)rN)requestServiceConchTestClientAuthConchTestClientConnectionrNrIs&r&connectionSecure ConchTestClient.connectionSecures)   #!:4;O;O!P r%rMN) r r!r"r#r8r.r9rZr`r$r9r:s@r&rKrKs%  2 F H  r%rKcDa]tRtRto^t^t^tRtRtRt Rt Rt Vt R#)r^icVP'g)VP'd\P!R4h\P P W4R#)z2got USERAUTH_SUCCESS before password and publickeyN)canSucceedPasswordcanSucceedPublicKeyrr6rSSHUserAuthClientssh_USERAUTH_SUCCESS)r-packets&&r&rg(ConchTestClientAuth.ssh_USERAUTH_SUCCESSsE***t/G/G/G''H  & & ; ;D Ir%c<^Vn\P!R4#)rTr)rdr rrIs&r& getPasswordConchTestClientAuth.getPasswords&'D #==- -r%c~^Vn\P!\PP \ 44#)rT)rer rrrrrrIs&r& getPrivateKey!ConchTestClientAuth.getPrivateKeys)'(D $==!4!45G!HI Ir%cH\PP\4#r+rrrr rIs&r& getPublicKey ConchTestClientAuth.getPublicKeys88&&'89 9r%)rdreN) r r!r"r# hasTriedNonererdrgrkrnrrr$r9r:s@r&r^r^s1  J . J : :r%r^c<a]tRtRtoRtRt^t^tRtRt Rt Vt R#)r_izw @ivar _completed: A L{Deferred} which will be fired when the number of results collected reaches C{totalResults}. rcP\PPV4WnR#r+)rr/r.rNrOs&&r&r."ConchTestClientConnection.__init__s  $ $ - -d 3#1 r%cHVPVPVR74R#)r]N) openChannelrNrIs&r&serviceStarted(ConchTestClientConnection.serviceStarteds   T11t1< =r%rMN) r r!r"r#r8r+results totalResultsr.r{r$r9r:s@r&r_r_s* !  2 > >r%r_cPa]tRtRtoRtRtRtRtRtRt Rt R t R t Vt R #) SSHTestChannelicWnW n.Vn.Vn\P !4Vn\PP!V.VO5/VBR#r+) r+_openedreceived receivedExtr rzr{r SSHChannelr.)r-r+openedrkwargss&&&*,r&r.SSHTestChannel.__init__sGI!LDM!D  >>+DL    ' ' >t >v >r%c<VPPV4R#r+)rerrbackr7s&&r& openFailedSSHTestChannel.openFaileds LL  (r%c<VPPV4R#r+)rr)r-ignores&&r& channelOpenSSHTestChannel.channelOpen LL ! !$ 'r%c<VPPV4R#r+)rappendrNs&&r& dataReceivedSSHTestChannel.dataReceiveds MM  &r%cV\P8XdVPPV4R#\P !RV: 24R#)zUnrecognized extended data: N)rEXTENDED_DATA_STDERRrrrro)r-dataTyperOs&&&r& extReceivedSSHTestChannel.extReceiveds8::::  ''-6xlCDr%cB\P!RV4wVnR#)z>LN)structunpackstatus)r-rs&&r&request_exit_status"SSHTestChannel.request_exit_status s"MM$7MT[r%cRVnR#)TN) eofCalledrIs&r&rSSHTestChannel.eofReceiveds !DNr%c<VPPR4R#r+)r{rrIs&r&rSSHTestChannel.closedrr%)rrr+r{rrrN)r r!r"r#r.rrrrrrrr$r9r:s@r&rrs3 ? ) ( ' E  8 " ( (r%rc\P!R\PP \ 4./4p\P !V4#)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&conchTestPublicKeyCheckerrsD (88 488../@AB C ++,@AAr%cra]tRtRtoRt]'gRtRRltRtRt Rt Rt R t R t R tR tR tVtR#)SSHProtocolTestsi"zR Tests for communication between L{SSHServerTransport} and L{SSHClientTransport}. can't run without cryptographyc aaa\P!4o\R4Vn\P !VP4p\ 4pVP\44VP\44VPV4\4pW5nVP4VPR4Vn \VP4Vn\!VVV3Rl4Vn\VP"4VnVPP'VP$4VP"P'VP4S#)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"<\SS3RV/SB#ry)r)r]rr+results&r&:SSHProtocolTests._ourServerOurClientTest..>sfJ4J6Jr%)r rzr)realmr PortalrregisterCheckerrrr startFactoryr serverr clientTransportrKclientserverTransportr)r-r+rrsshpcfacrs&fl @r&_ourServerOurClientTest(SSHProtocolTests._ourServerOurClientTest+s !#K0 MM$** %#% 689 79: % $&  ''- ,T[[9% J   -T[[9 ""4#7#78 ""4#7#78 r%c aSP4pV3RlpVP!V4V3RlpVP!V4V3RlpVP!V4V3RlpVP!V4V#)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 <VSnSPVPPVR\P !R4^4\ 4#) subsystems not-crazyr assertFailurer] sendRequestrNSrrr-s&r& cbSubsystemFSSHProtocolTests.test_subsystemsAndGlobalRequests..cbSubsystemOsF"DL%% ((\699\+BA  r%c<SPpVPPVR\P!R4^4#)rr@rr]rrrignoredrr-s& r&cbNotCrazyFailedKSSHProtocolTests.test_subsystemsAndGlobalRequests..cbNotCrazyFailedZs5llG<<++vyy':A r%cZ<SPpVPPRR^4pVPPRR^4pVPSPR4SP VPPRR^4\ 4p\P!W#V.4#)foobarsfoo-2bar2rU) rr]sendGlobalRequest addCallback assertEqualrrr gatherResults)rrd1d2d3r-s& r&cbGlobalRequestsKSSHProtocolTests.test_subsystemsAndGlobalRequests..cbGlobalRequestsbsllG//BB//'1EB NN4++W 5## ..vvqA9B&&|4 4r%c<SPSPPPRRRR/4SPpRVP P nVP P4VP!4R#)rLrrSrTN) rrrrBrr]rrserviceStoppedrrs& r& disconnectESSHProtocolTests.test_subsystemsAndGlobalRequests..disconnectqsh    !!005&'72S llG<@GLL " " 9 LL ' ' )  " " $r%rr)r-rrrrrsf r& test_subsystemsAndGlobalRequests1SSHProtocolTests.test_subsystemsAndGlobalRequestsGsn ..0  K(  ,- 5 ,- % J'r%c aaSP4p\P!RRR4oVV3RlpVP!V4V3RlpVP!V4V3RlpVP!V4V3RlpVP!V4V#)zs L{SSHChannel.sendRequest} can open a shell with a I{pty-req} request, specifying a terminal type and window size. conch-test-termr%cN<VSnVPPVRS^4#)spty-req)rr]r)rrOr-s&r& cbChannel.SSHProtocolTests.test_shell..cbChannels%"DL<<++GZqI Ir%c<SPPPP^,PpSP VPSPP4SP VPR4SP VPR4SPVP4SPpVPPVRR^4#)rrrr%Prr) rrr]channelsrassertIsrr~r assertTruerxrr)rrrr-s& r&cbPty*SSHProtocolTests.test_shell..cbPtysjj'',,55a8@@G MM'..$***;*; <   W224F G   W00. A OOGNN +llG<<++GXsAF Fr%c@<SPPR4SPPPSP4\P !SPP SPPPP .4#)stesting the shell!) rrr]sendEOFr rr{rrrurr-s&r&cbShell,SSHProtocolTests.test_shell..cbShellsm LL  8 9 LL   % %dll 3&&%%tzz'8'8'E'E'M'MN r%c<SPP^8wd3\P!RSPP3,4SP RP SPP 4R4SPSPP4SPSPPPP4R#)rzshell exit status was not 0: %ir%stesting the shell! N) rrrrorjoinrrrrrruryrs&r&cbExited-SSHProtocolTests.test_shell..cbExiteds||""a'9T\\=P=P> ?r%r)rrpackRequest_pty_reqr)r-rrrrrrOsf @r& test_shellSSHProtocolTests.test_shell~s ..0**+=~sS J I& G E"  G$ @ H%r%c aSP4pV3RlpVP!V4V3RlpVP!V4V#)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 <VSnSPVPPVR\P !R4^4\ 4#)execs jumboliahrrs&r&r3SSHProtocolTests.test_failedExec..cbChannelsB"DL%% (('699\;RTUV r%c<SP\P4pSPV^,PP R4R#)rN)rN)flushLoggedErrorsrrrvaluerrerrorsr-s& r&cbFailed2SSHProtocolTests.test_failedExec..cbFaileds:++E,<,<=F   VAY__113E Fr%r)r-rrrsf r&test_failedExec SSHProtocolTests.test_failedExecsC ..0  I& G H%r%c aSP4pV3RlpVP!V4V3RlpVP!V4V3RlpVP!V4V#)zy When the process started by a L{SSHChannel.sendRequest} exec request exits, the exit status is reported to the channel. cv<VSnVPPVR\P!R4^4#)rrrrs&r&r5SSHProtocolTests.test_falseChannel..cbChannels/"DL<<++GWfii>QSTU Ur%c0<SPP#r+rr{rs&r&cbExec2SSHProtocolTests.test_falseChannel..cbExec<<'' 'r%c<SPSPP.4SPSPP^4R#r)rrrassertNotEqualrrs&r&cbClosed4SSHProtocolTests.test_falseChannel..cbCloseds7   T\\22B 7    3 3Q 7r%rr-rrrrsf r&test_falseChannel"SSHProtocolTests.test_falseChannelsX ..0 V I& ( F# 8 H%r%c aSP^^R7pV3RlpVP!V4V3RlpVP!V4V3RlpVP!V4V#)zl Bytes sent over the extended channel for stderr data are delivered to the channel's C{extReceived} method.  localWindowlocalMaxPacketcv<VSnVPPVR\P!R4^4#)rs eecho hellorrs&r&r5SSHProtocolTests.test_errorChannel..cbChannel3"DL<<++&))N";Q r%c<\P!SPPSPP P P.4#r+r rrr{rrrurs&r&r2SSHProtocolTests.test_errorChannel..cbExec>&&%%tzz'8'8'E'E'M'MN r%c<<SPSPP.4SPRPSPP4R4SPSPP ^4SP SPP4SPSPP^4SPSPPSPPPP4R#)r%hello N) rrrrrrrrlocalWindowLeftrrrurrs&r&r4SSHProtocolTests.test_errorChannel..cbCloseds   T\\22B 7   SXXdll&>&>? N   T\\00! 4 OODLL22 3   T\\991 =    ,, !!..FF r%rrsf r&test_errorChannel"SSHProtocolTests.test_errorChannels^ ..1Q.O  I&  F#  H%r%c aSPSPR4\4pV3RlpVPV4V#)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-channelc<SP\P4pSPV^,PP R4SP\ V4^4R#)rN)zunknown channel)rrrrrrrrs& r&r6SSHProtocolTests.test_unknownChannel..cbFailedsL++E,<,<=F   VAY__113I J   S[! ,r%)rrrr)r-drsf r&test_unknownChannel$SSHProtocolTests.test_unknownChannels>     ( ()A BI  - hr%c aSP^ ^R7pV3RlpVP!V4V3RlpVP!V4V3RlpVP!V4V#)zK An L{SSHChannel} can be configured with a maximum packet size to receive. rcv<VSnVPPVR\P!R4^4#)rs secho hellorrs&r&r2SSHProtocolTests.test_maxPacket..cbChannelrr%c0<SPP#r+rrs&r&r/SSHProtocolTests.test_maxPacket..cbExec'rr%c<SPSPP^4SPRPSPP4R4SPRPSPP 4R4SPSPP ^ 4SPSPP4R#rr%r%N) rrrrrrr&rrrs&r&r1SSHProtocolTests.test_maxPacket..cbClosed,s   T\\00! 4   SXXdll&;&;&>? N   T\\992 > OODLL22 3r%rrsf r&test_maxPacketSSHProtocolTests.test_maxPackets^..2a.P  I& ( F# 4 H%r%c aSP^^R7pV3RlpVP!V4V3RlpVP!V4V3RlpVP!V4V#)zM Normal standard out bytes are sent to the channel's C{dataReceived} method. rcv<VSnVPPVR\P!R4^4#)rs echo hellorrs&r&r-SSHProtocolTests.test_echo..cbChannel=s3"DL<<++&))M":A r%c<\P!SPPSPP P P.4#r+r!rs&r&cbEcho*SSHProtocolTests.test_echo..cbEchoEr#r%c<SPSPP^4SPRPSPP4R4SPSPP ^4SP SPP4SPSPP SPPPP4R#r7) rrrrrr&rrrrrurrs&r&r,SSHProtocolTests.test_echo..cbClosedLs   T\\00! 4   SXXdll&;&;.`svr%cLR\PP\4/#rrqrr%r&rrKas ++,=>, r%cLR\PP\4/#rM)rrrrrr%r&rrKds ++,>?- r%)rr(r%rrr)r-rJ sshFactorys&f r&makeSSHFactorySSHFactoryTests.makeSSHFactory^sA'') - $  % ! !r%c VP4pVP!R4pVPV\P4R#)zK By default, buildProtocol() constructs an instance of SSHServerTransport. N)rPr assertIsInstancerrG)r-rrs& r&test_buildProtocol"SSHFactoryTests.test_buildProtocoljs8 %%'((. h (D(DEr%c a.oV3RlpVP4pWnVP!R4VPR.S4R#)zK buildProtocol() calls 'self.protocol()' to construct a protocol instance. cP<SPV4\P!4#r+)rrrG)rcallss*r& makeProtocolHSSHFactoryTests.test_buildProtocolRespectsProtocol..makeProtocolzs LL //1 1r%Nr)rPrr r)r-rYrrXs& @r&"test_buildProtocolRespectsProtocol2SSHFactoryTests.test_buildProtocolRespectsProtocolssE  2%%''d# "u%r%c \P!4pRVnRVnVP 4VP R4pVP .ROVP4R#)zY buildProtocol() sets supportedPublicKeys to the list of supported signature algorithms. cR\PP\4R\PP\4/#rrrr%r&rGSSHFactoryTests.test_buildProtocolSignatureAlgorithms..s1 ++,=> ++,=># r%cR\PP\4R\PP\4/#rrrr%r&rr_s1 ++,>? ++,>?$ r%N)s rsa-sha2-512s rsa-sha2-256rr)rr(rrrr rr )r-rrs& r&%test_buildProtocolSignatureAlgorithms5SSHFactoryTests.test_buildProtocolSignatureAlgorithmssY        OOD !  F ! ! r%c VPRR7pVPR4pVPRVP4VPRVP4R#)zO Group key exchanges are not supported when we don't have the primes database. NrI"diffie-hellman-group-exchange-sha1$diffie-hellman-group-exchange-sha256)rPr  assertNotInsupportedKeyExchanges)r-f1p1s& r&test_buildProtocolNoPrimes*SSHFactoryTests.test_buildProtocolNoPrimess[   -   d #  123K3K   3R5M5M r%c VP^R/R7pVPR4pVPRVP4VPRVP4R#)zE Group key exchanges are supported when we have the primes database. rINrdre)rr,)rPr assertInrgr-f2p2s& r&test_buildProtocolWithPrimes,SSHFactoryTests.test_buildProtocolWithPrimessU F 4   d # ;R=U=UV =r?W?WXr%c VP4pVPR4pVPRRPVP44R#)zO ECDSA key exchanges are listed with 256 having a higher priority among ECDSA. Ns8ecdh-sha2-nistp256,ecdh-sha2-nistp384,ecdh-sha2-nistp521,)rPr rmrrgrns& r&test_buildProtocolKexECDSA*SSHFactoryTests.test_buildProtocolKexECDSAsE "   d # G IIb.. / r%rr+)r r!r"r#rrqrPrTr[rarjrqrur$r9r:s@r&rFrFZs7 / F&  * Y   r%rFca]tRtRtoRt]'gRt]'d]!]P4t Rt Rt Rt Rt RtR tVtR #) MPTestsizc Tests for L{common.getMP}. @cvar getMP: a method providing a MP parser. @type getMP: C{callable} rc HVPVPR4R4R#)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. sN)rTr%rgetMPrIs&r& test_getMPMPTests.test_getMPs $GH(Sr%c HVPVPR4R4R#)z^ L{common.getMP} should be able to parse a big enough integer (that doesn't fit on one byte). sN)ir%rzrIs&r&test_getMPBigIntegerMPTests.test_getMPBigIntegers!  JJ: ;_ r%c JVPVPR^4R4R#)zO L{common.getMP} has the ability to parse multiple integer in the same string. sN)rTrr%rzrIs&r&test_multipleGetMPMPTests.test_multipleGetMPs)  JJW    r%c HVPVPR4R4R#)z] When more data than needed is sent to L{common.getMP}, it should return the remaining data. s fooN)rTrrzrIs&r&test_getMPRemainingDataMPTests.test_getMPRemainingDatas!  JJ= >  r%c \VP\PVPR4R#)zi When the string passed to L{common.getMP} doesn't even make 5 bytes, it should raise a L{struct.error}. sN) assertRaisesrrr{rIs&r&test_notEnoughDataMPTests.test_notEnoughDatas &,, K@r%rN)r r!r"r#r8rrq staticmethodrr{r|rrrrr$r9r:s@r&rxrxsF /V\\*T    AAr%rxc>a]tRtRtoRt]'gRtRtRtVt R#)GMPYInstallDeprecationTestsizA Tests for the deprecation of former GMPY accidental public API. r=c \P!4VPVP.4pVP \ V4^4VP V^,R,R4R#)z4 L{twisted.conch.ssh.common.install} is deprecated. messagezAtwisted.conch.ssh.common.install was deprecated in Twisted 16.5.0N)rinstall flushWarningstest_deprecatedrr)r-warningss& r&r+GMPYInstallDeprecationTests.test_deprecatedsX %%t';';&<= X*  QK " O r%rN) r r!r"r#r8rrqrr$r9r:s@r&rrs 0   r%r)Sr8r itertoolsrtypingrrrtwisted.conch.test.keydatarrrr twisted.conch.test.loopbackr twisted.credr twisted.cred.errorr twisted.internetr rrtwisted.internet.errorrtwisted.pythonrrtwisted.python.reflectr twisted.trialrr twisted.conchrrtwisted.conch.sshrrrrr)r'r1rsrregisterAdapterISessionProtocolrHrrrrrrrrrrrrSSHProtocolCheckerrr(rr2rGrrSrKrfr^r/r_rrrTestCaserrFrxrrr%r&rs $$ 60554'0"^, +CC   >?%f&&?%D=$=$@&!?G4D4D  X&& UU<SS.SS(SS,& < <h99 4D!3!34DlII>F-)E)EF -)E)E8:h88:.>J$<$<>"(++(B Bux((up f h''f R9Ah9Ax ("3"3 r%