֛h3dSrSSKrSSKJr SSKJrJrJr SSKJ r J r J r J r SSK Jr SSKJr SSKJr SS KJrJrJr SS KJr SS KJrJr SS KJr SS KJr \"S5r \ (aSSK!J"r"J#r# SSK$J%r%J&r&J'r'J(r( O "SS5r""SS5r)"SS\"RT5r+"SS5r,SSKJ-r- \ (a\-R\"\,\+\(R^5 "SS\R`5r1"SS5r2"SS5r3"S S!5r4"S"S#5r5\ bSS$K!J6r6 SS%K$J7r7J8r8J9r9J:r:J;r;J\R5rQ"S?S@\R5rRg)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(\rSrSr"SS5rSrg)r#c\rSrSrSrg)avatar.ConchUser$N)__name__ __module__ __qualname____firstlineno____static_attributes__r"_C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/conch/test/test_ssh.py ConchUserr $s r(r*r"N)r#r$r%r&r*r'r"r(r)rr#s   r(rc(\rSrSrSrSrSrSrSrg)ConchTestRealm(a  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. NcXlgN)expectedAvatarID)selfr0s r)__init__ConchTestRealm.__init__5s 0r(cXR:XaMURb [S5e[5UlUSURURR4$[SUR<SU<35e)zp Return a new L{ConchTestAvatar} if the avatarID matches the expected one and this is the first avatar request. zOnly one login allowedrzOnly z may log in, not )r0rr ConchTestAvatarlogout)r1avatarIDmind interfacess r) requestAvatarConchTestRealm.requestAvatar8st ,, ,{{&'(@AA)+DKa=$++t{{/A/AA AD)),,=h\ J  r()rr0) r#r$r%r&__doc__rr2r:r'r"r(r)r,r,(sF1  r(r,cR\rSrSrSr\(dSrSrSrSr Sr Sr S r S r S rg ) r5Gz 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[RRU5 0Ul0UlUR R [R[RS.5 URR S[05 g)N)sessions direct-tcpipcrazy) rr*r2 listenersglobalRequests channelLookupupdater SSHSessionropenConnectForwardingClientsubsystemLookupCrazySubsystemr1s r)r2ConchTestAvatar.__init__Tsk!!$'  !!#..!+!G!G  ##X~$>?r(c XRS'g)NfoorDr1datas r) global_fooConchTestAvatar.global_foo`s%)E"r(c XRS'g)Nfoo_2)rOdatarPrQs r) global_foo_2ConchTestAvatar.global_foo_2ds'+G$r(c,[R"U5up#[R"U[R"UR X#4[R 5US9nX@RX#4'g![a [R"SS5 gf=f)N) interfacerOz2something went wrong with remote->local forwardingr) runpackGlobal_tcpip_forwardr listenTCPSSHListenForwardingFactoryconn SSHListenServerForwardingChannelrC BaseExceptionrerrr1rRhostportlisteners r)global_tcpip_forward$ConchTestAvatar.global_tcpip_forwardhs::4@  ((55II|Z-X-X H,4NND< (   GGDN O sAA//!BBc[R"U5up#URRX#4S5nU(dgURX#4 UR 5 g)NrrO)rr\rCget stopListeningrcs r)global_cancel_tcpip_forward+ConchTestAvatar.global_cancel_tcpip_forwardysO::4@ >>%%tlD9 NND< ( r(cSUlURR5H,n[R"SU-5 UR 5 M. g)NTzstopListening %s) loggedOutrCvaluesrmsgrk)r1rfs r)r6ConchTestAvatar.logouts>--/H GG&1 2  " " $0r()rDrCroN)r#r$r%r&r<rskipror2rSrXrgrlr6r'r"r(r)r5r5Gs5 0I @"%r(r5c<\rSrSrSrSrSrSrSrSr Sr S r g ) ConchSessionForTestAvatarz* An ISession adapter for ConchTestAvatar. cXlXRlSUlSUlSUlSUl[ R"5Ulg)zY Initialize the session and create a reference to it on the avatar for later inspection. NFr) r _testSessioncmdprotoptyReqeofrDeferredonClose)r1rs r)r2"ConchSessionForTestAvatar.__init__s=  #'    ~~' r(cV[R"S5 XlX lSUlg)Nzpty reqT)rrq _terminalType _windowSizer{)r1term windowSizeattrss r)getPty ConchSessionForTestAvatar.getPtys!  !% r(c`[R"S5 Xl[U5 SUlg)Nz opening shellshell)rrqrz EchoTransportry)r1rzs r) openShell#ConchSessionForTestAvatar.openShells"   er(cbX lXlUR5SnUS:Xa-[U5n[R "SUR 5 OUS:Xa0[U5nURUSS5 UR 5 OUS:Xa0[U5nURUSS5 UR 5 OLUS:Xa0[U5nURUSS5 UR 5 O[R"S5eS URRRlg) Nrfalsesechossechoseechobad execrO)ryrzsplitFalseTransportr callLaterloseConnectionrwriteSuperEchoTransportErrEchoTransportr ConchErrorrr_ transportexpectedLoseConnection)r1rzryfts r) execCommand%ConchSessionForTestAvatar.execCommands IIKN =u%A   a!1!1 2 '\e$A GGCG     (]"5)A GGCG     (] 'A GGCG    "":. .<= ""9r(cSUlgNrO)r|rKs r) eofReceived%ConchSessionForTestAvatar.eofReceiveds r(c[R"SUR-5 URRR UlURRS5 g)Nzclosed cmd "%s") rrqryrzrremoteWindowLeftremoteWindowLeftAtCloser~callbackrKs r)closed ConchSessionForTestAvatar.closedsB !DHH,-'+zz'9'9'J'J$ d#r() rrrryr|r~rzr{rN) r#r$r%r&r<r2rrrrrr'r"r(r)rurus% (  >2$r(ru) componentsc \rSrSrSrSrSrg)rJcgr/r")r1argskws r)r2CrazySubsystem.__init__s r(cg)z good ... good Nr"rKs r)connectionMadeCrazySubsystem.connectionMadesr(r"N)r#r$r%r&r2rr'r"r(r)rJrJs   r(rJc$\rSrSrSrSrSrSrg)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@XlURU5 SUlg)zI @type p L{twisted.conch.ssh.session.SSHSessionProcessProtocol} instance rNrzmakeConnectionrr1ps r)r2FalseTransport.__init__s   r(c FUR(agSUlURR5 URR5 URR 5 URR [ R"[SSS555 g)z9 Disconnect the protocol associated with this transport. NrO rrzinConnectionLostoutConnectionLosterrConnectionLost processEndedrFailurerrKs r)rFalseTransport.loseConnectionsj ;;   ##% $$& $$& 0A#tT0R STr(rrzN)r#r$r%r&r<r2rr'r"r(r)rrs Ur(rc&\rSrSrSrSrSrSrg)rc@XlURU5 SUlgNrrrs r)r2EchoTransport.__init__   r(c[R"[U55 URR U5 URR S5 SU;aUR 5 gg)N )rrqreprrz outReceivedrrQs r)rEchoTransport.writesN T  t$ w' d?    ! r(c FUR(agSUlURR5 URR5 URR 5 URR [ R"[SSS555 gNrOrrrKs r)rEchoTransport.loseConnectionh ;;   ##% $$& $$& 0A!T40P QRr(rNr#r$r%r&r2rrr'r"r(r)rrs "Sr(rc&\rSrSrSrSrSrSrg)ric@XlURU5 SUlgrrrs r)r2ErrEchoTransport.__init__rr(cpURRU5 URRS5 gNr)rz errReceivedrQs r)rErrEchoTransport.writes& t$ w'r(c FUR(agSUlURR5 URR5 URR 5 URR [ R"[SSS555 grrrKs r)rErrEchoTransport.loseConnectionrr(rNrr"r(r)rrs (Sr(rc&\rSrSrSrSrSrSrg)ri$c@XlURU5 SUlgrrrs r)r2SuperEchoTransport.__init__%rr(cURRU5 URRS5 URRU5 URRS5 gr)rzrrrQs r)rSuperEchoTransport.write*sJ t$ w' t$ w'r(c FUR(agSUlURR5 URR5 URR 5 URR [ R"[SSS555 grrrKs r)r!SuperEchoTransport.loseConnection0rr(rNrr"r(r)rr$s ( Sr(r)checkers)channel connectionfactorykeysruserauthc4\rSrSr\R 4rSrSrg)ConchTestPasswordCheckeriEcURS:Xa0URS:Xa [R"UR5$[R"[ S55$)NtestusertestpasszBad credentials)usernamepasswordrsucceedfail Exception)r1 credentialss r)requestAvatarId(ConchTestPasswordChecker.requestAvatarIdHsH$$ 3((K7}}[%9%9::::i(9:; ;r(r"N) r#r$r%r&rIUsernamePasswordcredentialInterfacesrr'r"r(r)rrEs ( : :< 7ConchTestServerFactory.buildProtocol..as#$844668sr) ConchTestServerlistr from_iterable privateKeysrpsupportedPublicKeysrhasattrrrz)r1addrrzs r) buildProtocol$ConchTestServerFactory.buildProtocol^sn#%E(,##$#//668$)E % !Mt566/3/J/J,JLr(c[RR[5[RR[5S.$N)ssh-rsassh-dssrKey fromStringr r rKs r) getPublicKeys$ConchTestServerFactory.getPublicKeysns2 HH//0AB HH//0AB r(c[RR[5[RR[5S.$rrrrrrrKs r)getPrivateKeys%ConchTestServerFactory.getPrivateKeysts2 HH//0BC HH//0BC r(returnc4S[R"S5/0$)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)rgetDHGeneratorAndPrimerKs r) getPrimes ConchTestServerFactory.getPrimeszs4667UVWX Xr(cB[RRXU5$r/)r SSHFactory getService)r1transnames r)r,!ConchTestServerFactory.getServices%%00dC Cr()rzN)r#r$r%r&noisyrSSHUserAuthServerr SSHConnectionservicesrrr#rintrrr(r,r'r"r(r)rrVs\&77)77        YtCeCHo)>$>? Y Dr(rc*\rSrSrSrSrSrSrSrg) ConchTestBaseircUR(ag[US5(d[R"SUSU35eSUlg)Nrzunexpectedly lost connection  rO)donerrFailTestr1reasons r)connectionLostConchTestBase.connectionLostsFyy4!9::''3D6F8DDIr(c SUlU[R:wa+[R"[ SU<SU<SU<355 UR 5 g)NrOzgot disconnect for z : reason z, desc: )rrDISCONNECT_BY_APPLICATIONrrbrr)r1 reasonCodedescs r) receiveErrorConchTestBase.receiveErrorsH*+D ' Y@@@T3    !r(c4[R"SU35e)Nzgot unimplemented: seqid )rr:)r1seqIDs r)receiveUnimplemented"ConchTestBase.receiveUnimplementeds##&?w$GH Hr()r9rN) r#r$r%r&r9r=rCrGr'r"r(r)r6r6s  "  Ir(r6c\rSrSrSrSrg)ricl[RX5 [RRX5 gr/)r6r=rSSHServerTransportr;s r)r=ConchTestServer.connectionLost$  ( ( 6  ( ( 7 7 Er(r"N)r#r$r%r&r=r'r"r(r)rrs Fr(rc0\rSrSrSrSrSrSrSrSr g) 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. cXlgr/_channelFactoryr1channelFactorys r)r2ConchTestClient.__init__s#1 r(cl[RX5 [RRX5 gr/)r6r=rSSHClientTransportr;s r)r=ConchTestClient.connectionLostrMr(cU[RR[5R 5:HnUS:HnU(aU(a[ R "S5$[ R"[S55$)Ns/85:25:04:32:58:55:96:9f:57:ee:fb:a8:1a:ea:69:darOzKey or fingerprint mismatch) rrrr blobrrrr)r1r fpkeyMatchfingerprintMatchs r) verifyHostKeyConchTestClient.verifyHostKeys[dhh112CDIIKKH!%WW ,}}Q''::i(EFG Gr(c`UR[S[UR555 g)Nr)requestServiceConchTestClientAuthConchTestClientConnectionrRrKs r)connectionSecure ConchTestClient.connectionSecures)   #!:4;O;O!P r(rQN) r#r$r%r&r<r2r=r^rdr'r"r(r)rOrOs  2 F H r(rOc8\rSrSrSrSrSrSrSrSr Sr Sr g) rbircUR(d'UR(a[R"S5e[R R X5 g)Nz2got USERAUTH_SUCCESS before password and publickey)canSucceedPasswordcanSucceedPublicKeyrr:rSSHUserAuthClientssh_USERAUTH_SUCCESS)r1packets r)rk(ConchTestClientAuth.ssh_USERAUTH_SUCCESSs?**t/G/G''H  & & ; ;D Ir(c<SUl[R"S5$)NrOr)rhrrrKs r) getPasswordConchTestClientAuth.getPasswords&'D #==- -r(c~SUl[R"[RR [ 55$r)rirrrrrrrKs r) getPrivateKey!ConchTestClientAuth.getPrivateKeys)'(D $==!4!45G!HI Ir(cH[RR[5$r/rrrr rKs r) getPublicKey ConchTestClientAuth.getPublicKeys88&&'89 9r()rhriN) r#r$r%r& hasTriedNonerirhrkrorrrvr'r"r(r)rbrbs)  J . J :r(rbc0\rSrSrSrSrSrSrSrSr Sr g ) rcizw @ivar _completed: A L{Deferred} which will be fired when the number of results collected reaches C{totalResults}. rrcN[RRU5 Xlgr/)rr2r2rRrSs r)r2"ConchTestClientConnection.__init__s  $ $ - -d 3#1 r(c@URURUS95 g)N)r_) openChannelrRrKs r)serviceStarted(ConchTestClientConnection.serviceStarteds   T11t1< =r(rQN) r#r$r%r&r<r.results totalResultsr2rr'r"r(r)rcrcs" !  2 >r(rccD\rSrSrSrSrSrSrSrSr Sr S r S r g ) SSHTestChannelicXlX l/Ul/Ul[R "5Ul[RR"U/UQ70UD6 gr/) r._openedreceived receivedExtrr}r~r SSHChannelr2)r1r.openedrkwargss r)r2SSHTestChannel.__init__sGI!LDM!D  >>+DL    ' ' >t >v >r(c:URRU5 gr/)rerrbackr;s r) openFailedSSHTestChannel.openFaileds LL  (r(c:URRU5 gr/)rr)r1ignores r) channelOpenSSHTestChannel.channelOpen LL ! !$ 'r(c:URRU5 gr/)rappendrQs r) dataReceivedSSHTestChannel.dataReceiveds MM  &r(cU[R:XaURRU5 g[R "SU<35 g)NzUnrecognized extended data: )rEXTENDED_DATA_STDERRrrrrq)r1dataTyperRs r) extReceivedSSHTestChannel.extReceiveds8::::  ''-6xlCDr(c@[R"SU5uUlg)Nz>L)structunpackstatus)r1rs r)request_exit_status"SSHTestChannel.request_exit_status s"MM$7MT[r(cSUlg)NT) eofCalledrKs r)rSSHTestChannel.eofReceiveds !DNr(c:URRS5 gr/)r~rrKs r)rSSHTestChannel.closedrr()rrr.r~rrrN) r#r$r%r&r2rrrrrrrr'r"r(r)rrs+ ? ) ( ' E  8 " (r(rc[R"S[RR [ 5/05n[R "U5$)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(cd\rSrSrSr\(dSrSSjrSrSr Sr Sr S r S r S rS rS rg)SSHProtocolTestsi"zR Tests for communication between L{SSHServerTransport} and L{SSHClientTransport}. can't run without cryptographyc ^^^[R"5m[S5Ul[R "UR5n[ 5nUR[55 UR[55 URU5 [5nX5lUR5 URS5Ul [UR5Ul[!UUU4Sj5Ul[UR"5UlURR'UR$5 UR"R'UR5 T$)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">[TT4SU0TD6$)Nr_)r)r_rr.results r):SSHProtocolTests._ourServerOurClientTest..>sfJ4J6Jr()rr}r,realmr PortalrregisterCheckerrrr startFactoryrserverr clientTransportrOclientserverTransportr)r1r.rrsshpcfacrs `` @r)_ourServerOurClientTest(SSHProtocolTests._ourServerOurClientTest+s !#K0 MM$** %#% 689 79: % $&  ''- ,T[[9% J   -T[[9 ""4#7#78 ""4#7#78 r(c^TR5nU4SjnUR"U5 U4SjnUR"U5 U4SjnUR"U5 U4SjnUR"U5 U$)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 >UTlTRURRUS[R "S5S5[ 5$)N subsystems not-crazyrOr assertFailurer_ sendRequestrNSrrr1s r) cbSubsystemFSSHProtocolTests.test_subsystemsAndGlobalRequests..cbSubsystemOsF"DL%% ((\699\+BA  r(c>TRnURRUS[R"S5S5$)NrrBrOrr_rrrignoredrr1s r)cbNotCrazyFailedKSSHProtocolTests.test_subsystemsAndGlobalRequests..cbNotCrazyFailedZs5llG<<++vyy':A r(cZ>TRnURRSSS5nURRSSS5nURTRS5 TR URRSSS5[ 5n[R"X#U/5$)NfoobarrOsfoo-2bar2rW) rr_sendGlobalRequest addCallback assertEqualrrr gatherResults)rrd1d2d3r1s r)cbGlobalRequestsKSSHProtocolTests.test_subsystemsAndGlobalRequests..cbGlobalRequestsbsllG//BB//'1EB NN4++W 5## ..vvqA9B&&|4 4r(c>TRTRRRSSS.5 TRnSUR R lUR R5 UR"5 g)Nrr)rNrVT) rrrrDrr_rrserviceStoppedrrs r) disconnectESSHProtocolTests.test_subsystemsAndGlobalRequests..disconnectqsd    !!00&72S llG<@GLL " " 9 LL ' ' )  " " $r(rr)r1rrrrrs` r) test_subsystemsAndGlobalRequests1SSHProtocolTests.test_subsystemsAndGlobalRequestsGsn ..0  K(  ,- 5 ,- % J'r(c^^TR5n[R"SSS5mUU4SjnUR"U5 U4SjnUR"U5 U4SjnUR"U5 U4SjnUR"U5 U$)zs L{SSHChannel.sendRequest} can open a shell with a I{pty-req} request, specifying a terminal type and window size. conch-test-termPrrr(cN>UTlURRUSTS5$)Nspty-reqrO)rr_r)rrRr1s r) cbChannel.SSHProtocolTests.test_shell..cbChannels%"DL<<++GZqI Ir(c>TRRRRSRnTR URTRR5 TR URS5 TR URS5 TRUR5 TRnURRUSSS5$)Nrrrrr(rO) rrr_channelsrassertIsrrr assertTruer{rr)rrrr1s r)cbPty*SSHProtocolTests.test_shell..cbPtysjj'',,55a8@@G MM'..$***;*; <   W224F G   W00. A OOGNN +llG<<++GXsAF Fr(c@>TRRS5 TRRRTR5 [R "TRR TRRRR /5$)Nstesting the shell!) rrr_sendEOFrrr~rrrxrr1s r)cbShell,SSHProtocolTests.test_shell..cbShellsm LL  8 9 LL   % %dll 3&&%%tzz'8'8'E'E'M'MN r(c>TRRS:wa.[R"STRR4-5 TR SR TRR 5S5 TRTRR5 TRTRRRR5 g)Nrzshell exit status was not 0: %ir(stesting the shell! ) rrrrqrjoinrrrrrrxr|rs r)cbExited-SSHProtocolTests.test_shell..cbExiteds||""a'9T\\=P=P> ?r()rrpackRequest_pty_reqr)r1rrrrrrRs` @r) test_shellSSHProtocolTests.test_shell~s ..0**+=~sS J I& G E"  G$ @ H%r(c^TR5nU4SjnUR"U5 U4SjnUR"U5 U$)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 >UTlTRURRUS[R "S5S5[ 5$)Nexecs jumboliahrOrrs r)r3SSHProtocolTests.test_failedExec..cbChannelsB"DL%% (('699\;RTUV r(c>TR[R5nTRUSRR S5 g)Nr)rN)flushLoggedErrorsrrrvaluerrerrorsr1s r)cbFailed2SSHProtocolTests.test_failedExec..cbFaileds:++E,<,<=F   VAY__113E Fr(r)r1rrr s` r)test_failedExec SSHProtocolTests.test_failedExecsC ..0  I& G H%r(c^TR5nU4SjnUR"U5 U4SjnUR"U5 U4SjnUR"U5 U$)zy When the process started by a L{SSHChannel.sendRequest} exec request exits, the exit status is reported to the channel. cv>UTlURRUS[R"S5S5$)NrrrOrrs r)r5SSHProtocolTests.test_falseChannel..cbChannels/"DL<<++GWfii>QSTU Ur(c0>TRR$r/rr~rs r)cbExec2SSHProtocolTests.test_falseChannel..cbExec<<'' 'r(c>TRTRR/5 TRTRRS5 gr)rrrassertNotEqualrrs r)cbClosed4SSHProtocolTests.test_falseChannel..cbCloseds7   T\\22B 7    3 3Q 7r(rr1rrrrs` r)test_falseChannel"SSHProtocolTests.test_falseChannelsX ..0 V I& ( F# 8 H%r(c^TRSSS9nU4SjnUR"U5 U4SjnUR"U5 U4SjnUR"U5 U$)zl Bytes sent over the extended channel for stderr data are delivered to the channel's C{extReceived} method. r localWindowlocalMaxPacketcv>UTlURRUS[R"S5S5$)Nrs eecho hellorOrrs r)r5SSHProtocolTests.test_errorChannel..cbChannel3"DL<<++&))N";Q r(c>[R"TRRTRR R R/5$r/rrrr~rrrxrs r)r2SSHProtocolTests.test_errorChannel..cbExec>&&%%tzz'8'8'E'E'M'MN r(c:>TRTRR/5 TRSRTRR5S5 TRTRR S5 TR TRR5 TRTRRS5 TRTRRTRRRR5 g)Nr(hello rr) rrrrrrrrlocalWindowLeftrrrxrrs r)r4SSHProtocolTests.test_errorChannel..cbCloseds   T\\22B 7   SXXdll&>&>? N   T\\00! 4 OODLL22 3   T\\991 =    ,, !!..FF r(rrs` r)test_errorChannel"SSHProtocolTests.test_errorChannels^ ..1Q.O  I&  F#  H%r(c^TRTRS5[5nU4SjnURU5 U$)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>TR[R5nTRUSRR S5 TR[ U5S5 g)Nr)zunknown channelrO)rrrrrrrrs r)r 6SSHProtocolTests.test_unknownChannel..cbFailedsL++E,<,<=F   VAY__113I J   S[! ,r()rrrr)r1dr s` r)test_unknownChannel$SSHProtocolTests.test_unknownChannels>     ( ()A BI  - hr(c^TRSSS9nU4SjnUR"U5 U4SjnUR"U5 U4SjnUR"U5 U$)zK An L{SSHChannel} can be configured with a maximum packet size to receive. rOrcv>UTlURRUS[R"S5S5$)Nrs secho hellorOrrs r)r2SSHProtocolTests.test_maxPacket..cbChannelr$r(c0>TRR$r/rrs r)r/SSHProtocolTests.test_maxPacket..cbExec'rr(c>TRTRRS5 TRSRTRR5S5 TRSRTRR 5S5 TRTRR S5 TRTRR5 g)Nrr(r*r7) rrrrrrr+rrrs r)r1SSHProtocolTests.test_maxPacket..cbClosed,s   T\\00! 4   SXXdll&;&;&>? N   T\\992 > OODLL22 3r(rrs` r)test_maxPacketSSHProtocolTests.test_maxPackets^..2a.P  I& ( F# 4 H%r(c^TRSSS9nU4SjnUR"U5 U4SjnUR"U5 U4SjnUR"U5 U$)zM Normal standard out bytes are sent to the channel's C{dataReceived} method. rrrcv>UTlURRUS[R"S5S5$)Nrs echo hellorOrrs r)r-SSHProtocolTests.test_echo..cbChannel=s3"DL<<++&))M":A r(c>[R"TRRTRR R R/5$r/r&rs r)cbEcho*SSHProtocolTests.test_echo..cbEchoEr(r(c>TRTRRS5 TRSRTRR5S5 TRTRR S5 TR TRR5 TRTRR TRRRR5 g)Nrr(r*r) rrrrrr+rrrrrxrrs r)r,SSHProtocolTests.test_echo..cbClosedLs   T\\00! 4   SXXdll&;&;rHr'r"r(r)rr"sB /85n.`24"H"@!r(rcT\rSrSr\(dSrS SjrSrSrSr Sr S r S r S r g) SSHFactoryTestsiZrNc^[R"5nU4SjUlSUlSUlUR 5 U$)Nc>T$r/r"primessr)r0SSHFactoryTests.makeSSHFactory..`svr(cLS[RR[50$Nrrur"r(r)rrPas ++,=>, r(cLS[RR[50$rR)rrrrr"r(r)rrPds ++,>?- r()rr+r(rr#r)r1rO sshFactorys ` r)makeSSHFactorySSHFactoryTests.makeSSHFactory^sA'') - $  % ! !r(cUR5nUR"S5nURU[R5 g)zK By default, buildProtocol() constructs an instance of SSHServerTransport. N)rUrassertIsInstancerrK)r1rrs r)test_buildProtocol"SSHFactoryTests.test_buildProtocoljs8 %%'((. h (D(DEr(c^/mU4SjnUR5nXlUR"S5 URS/T5 g)zK buildProtocol() calls 'self.protocol()' to construct a protocol instance. cP>TRU5 [R"5$r/)rrrK)rcallss r) makeProtocolHSSHFactoryTests.test_buildProtocolRespectsProtocol..makeProtocolzs LL //1 1r(Nr")rUrrr)r1r^rr]s @r)"test_buildProtocolRespectsProtocol2SSHFactoryTests.test_buildProtocolRespectsProtocolssE  2%%''d# "u%r(c[R"5nSUlSUlUR 5 UR S5nUR /SQUR5 g)zY buildProtocol() sets supportedPublicKeys to the list of supported signature algorithms. c[RR[5[RR[5S.$rrr"r(r)rGSSHFactoryTests.test_buildProtocolSignatureAlgorithms..s-++,=>++,=># r(c[RR[5[RR[5S.$rr"r"r(r)rrds-++,>?++,>?$ r(N)s rsa-sha2-512s rsa-sha2-256rr)rr+rr#rrrr)r1rrs r)%test_buildProtocolSignatureAlgorithms5SSHFactoryTests.test_buildProtocolSignatureAlgorithmssY        OOD !  F ! ! r(cURSS9nURS5nURSUR5 URSUR5 g)zO Group key exchanges are not supported when we don't have the primes database. NrN"diffie-hellman-group-exchange-sha1$diffie-hellman-group-exchange-sha256)rUr assertNotInsupportedKeyExchanges)r1f1p1s r)test_buildProtocolNoPrimes*SSHFactoryTests.test_buildProtocolNoPrimess[   -   d #  123K3K   3R5M5M r(cURSS0S9nURS5nURSUR5 URSUR5 g)zE Group key exchanges are supported when we have the primes database. rO)rr1rNNrirj)rUrassertInrlr1f2p2s r)test_buildProtocolWithPrimes,SSHFactoryTests.test_buildProtocolWithPrimessU F 4   d # ;R=U=UV =r?W?WXr(cUR5nURS5nURSSRUR55 g)zO ECDSA key exchanges are listed with 256 having a higher priority among ECDSA. Ns8ecdh-sha2-nistp256,ecdh-sha2-nistp384,ecdh-sha2-nistp521,)rUrrrrrlrss r)test_buildProtocolKexECDSA*SSHFactoryTests.test_buildProtocolKexECDSAsE "   d # G IIb.. / r(r"r/)r#r$r%r&rrsrUrYr`rfrorvrzr'r"r(r)rKrKZs/ / F&  * Y  r(rKcz\rSrSrSr\(dSr\(a\"\R5r Sr Sr Sr Sr SrS rg ) MPTestsizc Tests for L{common.getMP}. @cvar getMP: a method providing a MP parser. @type getMP: C{callable} rcFURURS5S5 g)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)rOr(NrgetMPrKs r) test_getMPMPTests.test_getMPs $GH(Sr(cFURURS5S5 g)z^ L{common.getMP} should be able to parse a big enough integer (that doesn't fit on one byte). s)ir(NrrKs r)test_getMPBigIntegerMPTests.test_getMPBigIntegers!  JJ: ;_ r(cHURURSS5S5 g)zO L{common.getMP} has the ability to parse multiple integer in the same string. sr)rOrr(NrrKs r)test_multipleGetMPMPTests.test_multipleGetMPs)  JJW    r(cFURURS5S5 g)z] When more data than needed is sent to L{common.getMP}, it should return the remaining data. s foo)rOrNrrKs r)test_getMPRemainingDataMPTests.test_getMPRemainingDatas!  JJ= >  r(cZUR[RURS5 g)zi When the string passed to L{common.getMP} doesn't even make 5 bytes, it should raise a L{struct.error}. sN) assertRaisesrrrrKs r)test_notEnoughDataMPTests.test_notEnoughDatas &,, K@r(r"N)r#r$r%r&r<rrs staticmethodrrrrrrrr'r"r(r)r}r}s= /V\\*T    Ar(r}c0\rSrSrSr\(dSrSrSrg)GMPYInstallDeprecationTestsizA Tests for the deprecation of former GMPY accidental public API. r?c[R"5 URUR/5nUR [ U5S5 UR USSS5 g)z4 L{twisted.conch.ssh.common.install} is deprecated. rOrmessagezAtwisted.conch.ssh.common.install was deprecated in Twisted 16.5.0N)rinstall flushWarningstest_deprecatedrr)r1warningss r)r+GMPYInstallDeprecationTests.test_deprecatedsX %%t';';&<= X*  QK " O r(r"N) r#r$r%r&r<rrsrr'r"r(r)rrs 0  r(r)Sr<r 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*r5rurregisterAdapterISessionProtocolrJrrrrrrrrrrrrSSHProtocolCheckerrr+rr6rKrrWrOrjrbr2rcrrrTestCaserrKr}rr"r(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(