֛h SrSSKrSSKJr SSKJr SSKJr SSK J r SSK J r J r SSKrSSKJrJrJr SS KJr SS KJr SS KJr SS KJr SS KJrJrJrJr SSK J!r!J"r"J#r#J$r$ SSK%J&r&J'r' SSK(J)r)J*r* SSK+J,r,J-r-J.r. SSK/J0r0J1r1 SSK2J3r3 SSK4J5r5 SSK6J7r7 SSK8J9r9 SSK:J;r; SSKJ?r? SSK@JArAJBrB SSKCJDrDJErE SSKFJGrGJHrHJIrIJJrJJKrKJLrL SSKMJNrN SSKOJPrP SS KQJRrR SS!KSJTrT SS"KUJVrV SS#KWJXrX SS$KYJZrZ SS%K[J\r\ SS&K]J^r^J_r_J`r`Jara OS'rb\crV\cr\\crT\crX\crR\crP\crE\crB\cr?SS(KdJereJfrf "S)S*\e5rg"S+S,\R5rh"S-S.\R5ri"S/S0\R5rj"S1S25rk"S3S4\)5rl"S5S65rm"S7S8\\5rn"S9S:\V5ro\ "\&5"S;S<55rp\ "\'5"S=S>55rq"S?S@5rr"SASB\=\r5rs"SCSD\=\r5rt"SESF\=5ru"SGSH\5rv"SISJ5rw"SKSL\=5rxg)Mz' Tests for L{twisted.conch.endpoints}. N)BytesIO)pack)IO) implementer) verifyClass verifyObject) ConchErrorHostKeyChangedUserRejectedKey) IConchUser)'InMemoryUsernamePasswordDatabaseDontUse)Portal) IPv4Address)CancelledErrorDeferredfailsucceed)ConnectingCancelledErrorConnectionDoneConnectionRefusedErrorProcessTerminated)IAddressIStreamClientEndpoint)FactoryProtocol)EventLoggingObserverMemoryReactorClockStringTransport)LogLevelglobalLogPublisher) networkString)Failure)FilePath)msg) requireModule)TestCase cryptography) ConchUser)InMemorySSHKeyDBSSHPublicKeyChecker) ConsoleUIKnownHostsFile)AuthenticationFailedSSHCommandAddressSSHCommandClientEndpoint_ExistingConnectionHelper_ISSHConnectionCreator_NewConnectionHelper)common)SSHAgentServer) SSHChannel) SSHConnection) SSHFactory)Key)SSHClientTransport)SSHUserAuthServer)privateDSA_opensshprivateRSA_openssh privateRSA_openssh_encrypted_aespublicRSA_opensshzcan't run w/o cryptography) FakeTransportconnectc"\rSrSrSrSrSrSrg)AbortableFakeTransportVz; A L{FakeTransport} with added C{abortConnection} support. FcSUlg)ze Abort the connection in a fake manner. This should really be implemented in the underlying module. TNabortedselfs eC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/conch/test/test_endpoints.pyabortConnection&AbortableFakeTransport.abortConnection]s  rEN)__name__ __module__ __qualname____firstlineno____doc__rFrJ__static_attributes__rLrIrBrBVsGrLrBc\rSrSrSrSrSrg)BrokenExecSessionfzG L{BrokenExecSession} is a session on which exec requests always fail. cg)z Fail all exec requests. @param data: Information about what is being executed. @type data: L{bytes} @return: C{0} to indicate failure @rtype: L{int} rrSrHdatas rI request_execBrokenExecSession.request_execkrLrSNrMrNrOrPrQrZrRrSrLrIrUrUf  rLrUc\rSrSrSrSrSrg)WorkingExecSessionxzK L{WorkingExecSession} is a session on which exec requests always succeed. cg)z Succeed all exec requests. @param data: Information about what is being executed. @type data: L{bytes} @return: C{1} to indicate success @rtype: L{int} rSrXs rIrZWorkingExecSession.request_exec}r\rLrSNr]rSrLrIr`r`xr^rLr`c\rSrSrSrSrSrg)UnsatisfiedExecSessionz} L{UnsatisfiedExecSession} is a session on which exec requests are always delayed indefinitely, never succeeding or failing. c[5$)z Delay all exec requests indefinitely. @param data: Information about what is being executed. @type data: L{bytes} @return: A L{Deferred} which will never fire. @rtype: L{Deferred} )rrXs rIrZ#UnsatisfiedExecSession.request_execs zrLrSNr]rSrLrIrfrfs  rLrfc \rSrSrSrSrSrg) TrivialRealmc0UlgN channelLookuprGs rI__init__TrivialRealm.__init__s rLcL[5nURUl[US4$)NcgrnrSrSrLrI,TrivialRealm.requestAvatar..sDrL)r(rpr )rHavatarIdmind interfacesavatars rI requestAvatarTrivialRealm.requestAvatars$#11FL11rLroN)rMrNrOrPrqr{rRrSrLrIrkrks  2rLrkc\rSrSrSrSrSrg)AddressSpyFactoryNc:Xl[R"X5$rn)addressr buildProtocol)rHrs rIrAddressSpyFactory.buildProtocols $$T33rL)r)rMrNrOrPrrrRrSrLrIr~r~s G4rLr~c&\rSrSrSrSrSrSrg)FixedResponseUIcXlgrnresult)rHrs rIrqFixedResponseUI.__init__s rLc,[UR5$rn)rrrHtexts rIpromptFixedResponseUI.promptst{{##rLcgrnrSrs rIwarnFixedResponseUI.warns rLrN)rMrNrOrPrqrrrRrSrLrIrrs$ rLrc4\rSrSr\S5r\S5rSrg)FakeClockSSHUserAuthServercBURRR$)za Use the C{attemptsBeforeDisconnect} value defined by the factory to make it easier to override. ) transportfactoryattemptsBeforeDisconnectrGs rIr3FakeClockSSHUserAuthServer.attemptsBeforeDisconnects ~~%%>>>rLcBURRR$)z Use the reactor defined by the factory, rather than the default global reactor, to simplify testing (by allowing an alternate implementation to be supplied by tests). )rrreactorrGs rIclock FakeClockSSHUserAuthServer.clocks~~%%---rLrSN)rMrNrOrPpropertyrrrRrSrLrIrrs( ??..rLrcB\rSrSr\S5r\S5r\\S.r Sr Sr g)CommandFactoryc6S[R"[S90$Nssh-rsa)rY)r8 fromStringr>rGs rI publicKeysCommandFactory.publicKeyssCNN0ABCCrLc6S[R"[S90$r)r8rr<rGs rI privateKeysCommandFactory.privateKeyssCNN0BCDDrL)s ssh-userauthsssh-connectionrrSN) rMrNrOrPrrrrr6servicesrrRrSrLrIrrsC DDEE4(H !rLrc\rSrSrSrg) MemoryAddressrSN)rMrNrOrPrRrSrLrIrrsrLrc$\rSrSrSrSrSrSrg)SingleUseMemoryEndpointaA L{SingleUseMemoryEndpoint} is a client endpoint which allows one connection to be set up and then exposes an API for moving around bytes related to that connection. @ivar pump: L{None} until a connection is attempted, then a L{IOPump} instance associated with the protocol which is connected. @type pump: L{IOPump} cSUlXlg)zx @param server: An L{IProtocol} provider to which the client will be connected. @type server: L{IProtocol} provider N)pump_server)rHservers rIrq SingleUseMemoryEndpoint.__init__s   rLc URb [S5eUR[55n[ UR [ UR SS9U[ USS95Ul[U5$![a [5s$f=f)Nz(SingleUseMemoryEndpoint was already usedTisServerF) r Exceptionrrr@rrBr BaseExceptionr)rHrprotocols rIr@SingleUseMemoryEndpoint.connects 99 FG G %,,]_=H  &t||dC&x%@ DI 8$ $ 6M sA55B  B )rrN)rMrNrOrPrQrqr@rRrSrLrIrrs%rLrc\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSSjrSrSrSrg)"SSHCommandClientEndpointTestsMixinia Tests for L{SSHCommandClientEndpoint}, an L{IStreamClientEndpoint} implementations which connects a protocol with the stdin and stdout of a command running in an SSH session. These tests apply to L{SSHCommandClientEndpoint} whether it is constructed using L{SSHCommandClientEndpoint.existingConnection} or L{SSHCommandClientEndpoint.newConnection}. Subclasses must override L{create}, L{assertClientTransportState}, and L{finishConnection}. cSUlSUlSUlSUl[ 5Ul[ 5Ul[UR5Ul [5Ul URRURUR5 URRUR5 [5UlUR URlURURl URR!5 UR#URR$5 ['SSS5Ul['SSS 5Ulg) Nsssh.example.comi&suserspasswordTCPz10.0.0.1i90z192.168.100.200i1)hostnameportuserpasswordrrrkrealmrportalr passwdDBaddUserregisterCheckerrrdoStart addCleanupdoStopr clientAddress serverAddressrGs rIsetUp(SSHCommandClientEndpointTestsMixin.setUps*   # )+ !^ TZZ( ?A  dii7 ##DMM2%' #|| "kk    ++,( EB(0A5IrLcH[URR<S35e)z Create and return a new L{SSHCommandClientEndpoint} to be tested. Override this to implement creation in an interesting way the endpoint. z did not implement createNotImplementedError __class__rMrGs rIcreate)SSHCommandClientEndpointTestsMixin.create1s' "~~&&))B C  rLcH[URR<S35e)aa Make an assertion about the connectedness of the given protocol's transport. Override this to implement either a check for the connection still being open or having been closed as appropriate. @param client: The client whose state is being checked. @param immediateClose: Boolean indicating whether the connection was closed immediately or not. z- did not implement assertClientTransportStaterrHclientimmediateCloses rIassertClientTransportState=SSHCommandClientEndpointTestsMixin.assertClientTransportState:s#"~~&& )  rLcH[URR<S35e)zp Do any remaining work necessary to complete an in-memory connection attempted initiated using C{self.reactor}. z# did not implement finishConnectionrrGs rIfinishConnection3SSHCommandClientEndpointTestsMixin.finishConnectionJs' "~~&&))L M  rLcURS5nURS5n[USURURS9n[USURURS9n[ XFX55nXCU4$)a? Set up an in-memory connection between protocols created by C{serverFactory} and C{clientFactory}. @return: A three-tuple. The first element is the protocol created by C{serverFactory}. The second element is the protocol created by C{clientFactory}. The third element is the L{IOPump} connecting them. NF)r hostAddress peerAddressT)rrBrrr@)rH serverFactory clientFactoryclientProtocolserverProtocolclientTransportserverTransportrs rIconnectedServerAndClient;SSHCommandClientEndpointTestsMixin.connectedServerAndClientSs'44T:&44T:0 ****   1 ****  ~Xt33rLc6UR5n[5n[UlUR U5nUR 5upEnUR [5nURSUSRRUSRR45 URS[U55 URU5nUR[5 URSURR5 URUS5 g)z If a channel cannot be opened on the authenticated SSH connection, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping the reason given by the server. unknown channelrrcunknown channelFN)rrrrr@rflushLoggedErrorsr assertInvaluerY assertEquallenfailureResultOftrapr) rHendpointr connectedrrrerrorsfs rItest_channelOpenFailure:SSHCommandClientEndpointTestsMixin.test_channelOpenFailureps ;;=)#$$W- #446'' 3 '&)//*>*>q @U@U)VW CK(   + z +QWW]]; ''6rLc[URRS'UR5n[ 5n[ UlURU5nUR5upEnURU5nUR[5 URSURR5 URUS5 g)z If execution of the command fails, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping the reason given by the server. sessionzchannel request failedFN)rUrrprrrrr@rrrr rrrrHrrrrrrrs rItest_execFailure3SSHCommandClientEndpointTestsMixin.test_execFailures 0A   ,;;=)#$$W- #446   + z 1177==A ''6rLc`[URRS'UR5n[ 5n[ UlURU5nUR5upEnUR5 URU5nUR[5 URUS5 g)z If execution of the command is cancelled via the L{Deferred} returned by L{SSHCommandClientEndpoint.connect}, the connection is closed immediately. rTN)rfrrprrrrr@rcancelrrrrrs rItest_execCancelled5SSHCommandClientEndpointTestsMixin.test_execCancelleds 0F   ,;;=)#$$W- #446   + ~ ''5rLc8[URRS'UR5n[ 5n[ UlURU5 UR5up4nURUR[5 URURR5URR5 URUR URR"5 URSURR$5 g)a Once the necessary SSH actions have completed successfully, L{SSHCommandClientEndpoint.connect} uses the factory passed to it to construct a protocol instance by calling its C{buildProtocol} method with an address object representing the SSH connection and command executed. r /bin/ls -lN)r`rrprr~rrr@rassertIsInstancerr.rrgetHostrrusernamecommand)rHrrrrrs rItest_buildProtocol5SSHCommandClientEndpointTestsMixin.test_buildProtocols0B   ,;;=#%#!#446 goo/@A ))113W__5K5KL GOO$<$<= (?(?@rLc([URRS'UR5n[ 5n[ UlURU5nUR5upEnURU5nURUR5 g)z L{SSHCommandClientEndpoint} establishes an SSH connection, creates a channel in it, runs a command in that channel, and uses the protocol's C{makeConnection} to associate it with a protocol representing that command's stdin and stdout. rN) r`rrprrrrr@rsuccessResultOfassertIsNotNonerrHrrrrrrrs rItest_makeConnection6SSHCommandClientEndpointTestsMixin.test_makeConnectionsz0B   ,;;=)#$$W- #446'' 2 X//0rLc[URRS'UR5n[ 5n[ UlURU5nUR5upEnURU5n/nURUl URRn URRU R!S5 UR#5 UR%SSR'U55 g)z After establishing the connection, when the command on the SSH server produces output, it is delivered to the protocol's C{dataReceived} method. r hello, worldrLN)r`rrprrrrr@rrappend dataReceivedridservicechannelswriterrjoin) rHrrrrrrrr channelIds rItest_dataReceived4SSHCommandClientEndpointTestsMixin.test_dataReceiveds 0B   ,;;=)#$$W- #446'' 2 , 3 3&&))  *00A  #((<*@ArLc[URRS'UR5n[ 5n[ UlURU5nUR5upEnURU5n/nURUl URRn URRU R!5 UR#5 USR%[&5 UR)US5 g)zY When the command closes the channel, the protocol's C{connectionLost} method is called. rrFN)r`rrprrrrr@rrrconnectionLostrrrrloseConnectionrrrr) rHrrrrrrrr!rs rItest_connectionLost6SSHCommandClientEndpointTestsMixin.test_connectionLosts 0B   ,;;=)#$$W- #446'' 2"0"7"7&&))  *99; q~. ''6rLc[URRS'UR5n[ 5n[ UlURU5nUR5upgnURU5n /n U RU l U RRn URRU n URR!XU5 U R#5 UR%5 UR'US5 U S$)z: Test handling of non-zero exit statuses or exit signals. rFr)r`rrprrrrr@rrrr!rrrr sendRequestr"rr) rHrequest requestArgrrrrrrrr!rchannels rI_exitStatusTest2SSHCommandClientEndpointTestsMixin._exitStatusTests0B   ,;;=)#$$W- #446'' 2"0"7"7 &&)) ..)))4""7Z@   ''6a  rLcjSnURS[SU55nUR[5 g) When the command exits with a non-zero status, the protocol's C{connectionLost} method is called with a L{Failure} wrapping an exception which encapsulates that status. r exit-status>LN)r*rrr)rHexitCodeexcs rItest_zeroExitCode4SSHCommandClientEndpointTestsMixin.test_zeroExitCode2s. "">4h3GH  rLcSnSnURS[SU55nUR[5 UR XR R 5 UR X#R R5 g)r-{Nr.r/)r*rrrrrr0signal)rHr0r6r1s rItest_nonZeroExitStatus9SSHCommandClientEndpointTestsMixin.test_nonZeroExitStatus<sd "">4h3GH "# 99#5#56 !1!12rLc[5n[R"U5 UR[RU5 SnSnSR [ R"S5S[ R"S5[ R"S5/5nURSU5nUR[5 URX%RR5 URX5RR5 S n[R "U[R""[R$"[R&"[(R*5USS S SS .555 g) z When the command exits with a non-zero signal, the protocol's C{connectionLost} method is called with a L{Failure} wrapping an exception which encapsulates that status. Additional packet contents are logged at the C{info} level. NrLsTERMsmessagesen-USs exit-signalz'twisted.conch.endpoints._CommandChannelTmessage) log_level log_namespaceshortSignalName coreDumped errorMessage languageTag)rr addObserverrremoveObserverrr3NSr*rrrrr0r6hamcrest assert_thathas_item has_entriesequal_torinfo)rH logObserverr0r6packetr1 logNamespaces rItest_nonZeroExitSignal9SSHCommandClientEndpointTestsMixin.test_nonZeroExitSignalIs+, &&{3 *99;G '" *% (#   "">6: "# 99#5#56 !1!12@     $$%-%6%6x}}%E)5+2&*(1'/    rLc^URRn/mU(aU4SjnO TRn[URR UX65 T$)z Hook into and record events which happen to C{protocol}. @param server: The SSH server protocol over which C{protocol} is running. @type server: L{IProtocol} provider @param protocol: @param event: @param noArgs: c&>TRS5$rn)r)recordersrIru;SSHCommandClientEndpointTestsMixin.record..s-rL)rrrsetattrrr)rHrreventnoArgsrrrSs @rIrecord)SSHCommandClientEndpointTestsMixin.recordwsJ &&))  -AA'' 2E=rLc[URRS'UR5n[ 5n[ UlURU5nUR5upEnURU5nURXGS5nURRS5 UR5 URSSRU55 g)z The transport connected to the protocol has a C{write} method which sends bytes to the input of the command executing on the SSH server. rrrrLN)r`rrprrrrr@rrrXrrrrr rHrrrrrrrrs rI test_write-SSHCommandClientEndpointTestsMixin.test_writes 0B   ,;;=)#$$W- #446'' 2{{6^D   1  #((<*@ArLc[URRS'UR5n[ 5n[ UlURU5nUR5upEnURU5nURXGS5nURRS/5 UR5 URSSRU55 g)z The transport connected to the protocol has a C{writeSequence} method which sends bytes to the input of the command executing on the SSH server. rrrrLN)r`rrprrrrr@rrrXr writeSequencerrrr[s rItest_writeSequence5SSHCommandClientEndpointTestsMixin.test_writeSequences 0B   ,;;=)#$$W- #446'' 2{{6^D ((/):;  #((<*@ArL) rrrrrrrrrrrN)F)rMrNrOrPrQrrrrrrrrr rrr#r*r2r7rOrXr\r`rRrSrLrIrrsl J(   4:747*6*A.1&B678!:! 3, \6B*BrLrc\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrSrSrSrSrSrg)NewConnectionTestsizT Tests for L{SSHCommandClientEndpoint} when using the C{newConnection} constructor. c[RU5 [UR55Ul[ UR5UlUR RURURRS5 UR R[URR5URRS5 UR R5 g)g Configure an SSH server with password authentication enabled for a well-known (to the tests) account. rN)rrr#mktemp hostKeyPathr, knownHosts addHostKeyrrrr!rhostsaverGs rIrNewConnectionTests.setUps +006#DKKM2()9)9: ""4==$,,2I2I*2UV "" $,,11 2DLL4K4KJ4W  rLc [R"URSURURUR UR UR[S5S9$)z] Create and return a new L{SSHCommandClientEndpoint} using the C{newConnection} constructor. rFrrhui) r/ newConnectionrrrrrrhrrGs rIrNewConnectionTests.createsL (55 LL  II MM II]]u%  rLcnURURURRSS5$)ze Establish the first attempted TCP connection using the SSH server which C{self.factory} can create. r)rrr tcpClientsrGs rIr#NewConnectionTests.finishConnections4 ,, LL$,,11!4Q7  rLcURXSSS9nURR5 UR5 UR S/U5 UR5 URR 5 g)a_ Lose the connection to a server and pump the L{IOPump} sufficiently for the client to handle the lost connection. Asserts that the client disconnects its transport. @param server: The SSH server protocol over which C{protocol} is running. @type server: L{IProtocol} provider @param client: The SSH client protocol over which C{protocol} is running. @type client: L{IProtocol} provider @param protocol: The protocol created by calling connect on the ssh endpoint under test. @type protocol: L{IProtocol} provider @param pump: The L{IOPump} connecting client to server. @type pump: L{IOPump} closedT)rWN)rXrr"rrreportDisconnect)rHrrrrrws rIloseConnectionToServer)NewConnectionTests.loseConnectionToServersd*VxE))+  $(  ))+rLcU(a&URURR5 gURURR5 g)z Assert that the transport for the given protocol has been disconnected. L{SSHCommandClientEndpoint.newConnection} creates a new dedicated SSH connection and cleans it up after the command exits. N) assertTruerrF disconnectingrs rIr-NewConnectionTests.assertClientTransportStates7  OOF,,44 5 OOF,,:: ;rLc[R"URSSURUR5nUR [ [U55 g)zI L{SSHCommandClientEndpoint} instances provide L{IStreamClientEndpoint}. dummy command dummy userN)r/rprrrr|rrrHrs rItest_interface!NewConnectionTests.test_interfacesB,99 LL*M4==$))   %:HEFrLc[R"URSSUR5nUR SUR R 5 g)zn L{SSHCommandClientEndpoint} uses the default port number for SSH when the C{port} argument is not specified. rrNr/rprrr_creatorrrs rItest_defaultPort#NewConnectionTests.test_defaultPort$sD ,99 LL*M4==  X..334rLc[R"URSSURSS9nUR SUR R 5 g)zE L{SSHCommandClientEndpoint} uses the C{port} argument if specified. rri)rNrrs rItest_specifiedPort%NewConnectionTests.test_specifiedPort.sF,99 LL*M4==t  x00556rLc *[R"URSURURUR UR UR[S5S9n[5n[Ul URU5 URRSup4p%nURUR[U55 URUR U5 URS[!URR55 g)z L{SSHCommandClientEndpoint} uses the L{IReactorTCP} passed to it to attempt a connection to the host/port address also passed to it. rFrnrrcN)r/rprrrrrrhrrrrr@rtrr!r)rHrrrjrtimeout bindAddresss rItest_destination#NewConnectionTests.test_destination7s ,99 LL  II MM II]]u%  )#!48LL4K4KA4N1Gk  d(;< D) C 7 789rLc [R"URSSURURUR [ S5S9n[5n[Ul URU5nURRSSnURS[[555 URU5R![5 g)z If a connection cannot be established, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} representing the reason for the connection setup failure. rrFrhrorrsN)r/rprrrrhrrrrr@rtclientConnectionFailedr"rrrrHrrds rItest_connectionFailed(NewConnectionTests.test_connectionFailedOs ,99 LL   MM IIu% )#   W %,,))!,Q/&&tW5K5M-NO Q$$%;>"45<<>#HT[[]$;< mD,>,>,C,CDhO~~ , &(  dmm\: T "+99 LL   MM II&!  )#$$W- #<< LL$,,11!4Q7    + ~rLc [R"URSSURURUR [ S5S9n[5n[Ul URU5n[5nURRSSnURS5nURU5 UR[![#555 UR%U5R'["5 g)a% If the connection closes at any point before the SSH transport layer has finished key exchange (ie, gotten to the point where we may attempt to authenticate), the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping the reason for the lost connection. rrFrrrsN)r/rprrrrhrrrrr@rrtrmakeConnectionr!r"rrrrHrrrrrs rI!test_connectionClosedBeforeSecure4NewConnectionTests.test_connectionClosedBeforeSecures,99 LL   MM IIu% )#   W %#% ,,))!,Q/&&t,i(gn&678 Q$$^4rLc X[R"URSSURURUR [ S5S9n[5n[Ul URU5n[SSS9nURRSSnURS5nURU5 UR5 UR!U5R#[$5 UR'UR(5 UR+[-[/555 g) a+ If the connection is cancelled before the SSH transport layer has finished key exchange (ie, gotten to the point where we may attempt to authenticate), the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping L{CancelledError} and the connection is aborted. rrFrNrrrs)r/rprrrrhrrrrr@rBrtrrrrrrr|rFr!r"rrs rI$test_connectionCancelledBeforeSecure7NewConnectionTests.test_connectionCancelledBeforeSecures,99 LL   MM IIu% )#   W %*4%@ ,,))!,Q/&&t,i(   Q$$^4  ))* gn&678rLc [R"URSSURURUR [ S5S9n[5n[Ul URU5nUR5 URU5R[5 URURR SR"5 g)zb If the connection is cancelled before it finishes connecting, the connection attempt is stopped. rrFrrN)r/rprrrrhrrrrr@rrrrr| connectorsstoppedConnectingrs rI'test_connectionCancelledBeforeConnected:NewConnectionTests.test_connectionCancelledBeforeConnecteds ,99 LL   MM IIu% )#   W %   Q$$%=>  //2DDErLc H[R"URSSURURSUR [ S5S9n[5n[Ul URU5nURURURRSS5upEnURRURR 5 UR#5 UR%U5nUR'[(5 UR+US5 g) z If the SSH server rejects the password presented during authentication, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping L{AuthenticationFailed}. rrrFrnrrsN)r/rprrrrhrrrrr@rrrtadvancer passwordDelayflushrrr-rrs rI"test_passwordAuthenticationFailure5NewConnectionTests.test_passwordAuthenticationFailures ,99 LL   MM II&u%  )#$$W- #<< LL$,,11!4Q7  V^^99:   + #$ ''6rLcUR5VVs0sH+up4U[R"U5R5/_M- nnn[ [ U55nUR U5 gs snnf)at Create an L{ISSHPrivateKey} checker which recognizes C{users} and add it to C{portal}. @param portal: A L{Portal} to which to add the checker. @type portal: L{Portal} @param users: The users and their keys the checker will recognize. Keys are byte strings giving user names. Values are byte strings giving OpenSSH-formatted private keys. @type users: L{dict} N)itemsr8rrr*r)r)rHruserskvmappingcheckers rIsetupKeyChecker"NewConnectionTests.setupKeyChecker-s`@E{{}M}tq1s~~a(//122}M%&6w&?@w'Ns2A/c [R"[5nURURUR [ 05 [R"URSUR URURU/UR[S5S9n[5n[UlUR#U5nUR%UR&URR(SS5upVnUR+U5nUR-[.5 UR1UR2R45 g)z If the SSH server rejects the key pair presented during authentication, the L{Deferred} returned by L{SSHCommandClientEndpoint.connect} fires with a L{Failure} wrapping L{AuthenticationFailed}. rFkeysrhrorrsN)r8rr<rrrr;r/rprrrrhrrrrr@rrrtrrr-r|rr}) rHbadKeyrrrrrrrs rI#test_publicKeyAuthenticationFailure6NewConnectionTests.test_publicKeyAuthenticationFailure>s  23 T[[4996H*IJ+99 LL  II MM IIu%  )#$$W- #<< LL$,,11!4Q7    + #$ ((667rLc 6[R"[5nURURUR [ 05 [R"URSUR URURU/URUR[S5S9 n[5n[ UlUR%U5nUR&=R(S- slUR+UR&URR,SS5upVnUR/5 UR1[25nUR5SUSR6R8USR6R645 UR;S[=U55 UR?U5n U RA[25 UR;SU R6R65 URCURDRF5 g ) zc If the SSH server does not accept any of the specified SSH keys, the specified password is tried. rF)rrrhrorcrrsrrN)$r8rr<rrrr;r/rprrrrrhrrrrr@rrrrtrrr rrrYrrrrr|rr}) rHrrrrrrrrrs rItest_authenticationFallback.NewConnectionTests.test_authenticationFallbackcs  23 T[[4996H*IJ+99 LL  II MM II]]u%  )#$$W-  --2-#<< LL$,,11!4Q7  '' 3 '&)//*>*>q @U@U)VW CK(   + z +QWW]]; ((667rLc [R"[5nURURUR [05 [ URRS'[R"URSUR URURU/UR[S5S9n[!5n["UlUR'U5nUR)UR*URR,SS5upVnUR/U5nUR1UR25 g)z If L{SSHCommandClientEndpoint} is initialized with any private keys, it will try to use them to authenticate with the SSH server. rrFrrrsN)r8rr;rrrr`rrpr/rprrrrhrrrrr@rrrtrrr) rHkeyrrrrrrrs rItest_publicKeyAuthentication/NewConnectionTests.test_publicKeyAuthentications nn/0 T[[4996H*IJ/A   ,+99 LL  II MM IIu%  )#$$W- #<< LL$,,11!4Q7 '' 2 X//0rLc "[R"URSURURUR UR [S5S9n[5n[Ul URU5nURURURRSS5upEnUR5 UR!U5nUR#[$5 UR'UR(R*5 g)zn If the password is not specified, L{SSHCommandClientEndpoint} doesn't try it as an authentication mechanism. rFrrrsN)r/rprrrrrhrrrrr@rrrtrrrr-r|rr}rs rItest_skipPasswordAuthentication2NewConnectionTests.test_skipPasswordAuthentications ,99 LL  II MM IIu% )#$$W- #<< LL$,,11!4Q7     + #$ ((667rLc ^[R"[5n[5n[ 5UlUR 5US40UR lURURUR[05 [U5n[R"URSURURUR UR"[%S5US9n[&UR(R*S'[ 5n[,UlUR1U5nUR3UR URR4SS5upxn [7S5H-n UR8R95 U R95 M/ UR;U5n UR=U R>5 URAXxX5 URCUR>RD5 URCUR8RFRD5 g ) z If L{SSHCommandClientEndpoint} is initialized with an L{SSHAgentClient}, the agent is used to authenticate with the SSH server. Once the connection with the SSH server has concluded, the connection to the agent is disconnected. rLrF)rhro agentEndpointrrrsN)$r8rr<r4rrblobrrrrrr/rprrrrhrr`rrprrr@rrtrangerrrrryr|r}clientIO) rHr agentServerrrrrrrrirs rItest_agentAuthentication+NewConnectionTests.test_agentAuthenticationsnn/0$& %i $'HHJc #;   T[[4996H*IJ/ < +99 LL  II MM IIu%'  0B   ,)#$$W- #<< LL$,,11!4Q7  rA    # # % IIK'' 2 X//0 ##FHC ((667  **33AABrLc`[URRS'UR5n[ 5n[ UlURU5nUR5upEnURU5nURXEXv5 URURR5 g)z The transport connected to the protocol has a C{loseConnection} method which causes the channel in which the command is running to close and the overall connection to be closed. rN)r`rrprrrrr@rrryr|rr}rs rItest_loseConnection&NewConnectionTests.test_loseConnections 0B   ,;;=)#$$W- #446'' 2 ##FHC ((667rL)rgrhN)rMrNrOrPrQrrrryrrrrrrrrrrrrrrrrrrrrRrSrLrIrcrcs   !,F <G57:0=0 8*X5< 9DF,&7P("#8J.8`1>8B1Cf8rLrcc0\rSrSrSrSrSrSrSrSr g) ExistingConnectionTestsizY Tests for L{SSHCommandClientEndpoint} when using the C{existingConnection} constructor. c [RU5 [[UR 555nUR UR URRS5 UR [URR5URRS5 [R"URSURUR UR UR"U[%S5S9Ulg)rerrFrnN)rrr,r#rfrirrrr!rrjr/rprrrrrr)rHrhs rIrExistingConnectionTests.setUp#s +006#HT[[]$;< dmmT\\-D-DZ-PQ $,,11 2DLL4K4KJ4W 1>> LL  II MM II]]!u%   rLc&[5n[UlURR U5nUR R R5n[UR R S'URURURRSS5upEnUR R R5 UR R RU5 X@lXPlX`lUR%U5nUR&R(n[*R,"US5$!UR R R5 UR R RU5 f=f)zb Create and return a new L{SSHCommandClientEndpoint} using the C{existingConnection} constructor. rrrsr)rrrrr@rrpcopyr`rrrrtclearupdater_client_pumprrconnr/existingConnection) rHrrrprrrr connections rIrExistingConnectionTests.create;s1 )#MM))'2  00557  ;3EDJJ $ $Z 0#'#@#@ dll55a8;$ FD JJ $ $ * * , JJ $ $ + +M :   '' 2'',, ':::}UU JJ $ $ * * , JJ $ $ + +M :sAEA FcURR5 URR5 URR5 URR5 URURUR4$)zw Give back the connection established in L{create} over which the new command channel being tested will exchange data. )rrrrrGs rIr(ExistingConnectionTests.finishConnectionYsU    ||T\\4::55rLcURURR5 URURR5 g)z Assert that the transport for the given protocol is still connected. L{SSHCommandClientEndpoint.existingConnection} re-uses an SSH connected created by some other code, so other code is responsible for cleaning it up. N) assertFalserr}rFrs rIr2ExistingConnectionTests.assertClientTransportStategs8 ))778 ))112rL)rrrrN) rMrNrOrPrQrrrrrRrSrLrIrrs  0V< 63rLrc0\rSrSrSrSrSrSrSrSr g) ExistingConnectionHelperTestsirz) Tests for L{_ExistingConnectionHelper}. cJUR[[[55 g)zD L{_ExistingConnectionHelper} implements L{_ISSHConnectionCreator}. N)r|rr1r0rGs rIr,ExistingConnectionHelperTests.test_interfacews  $:T$rnrS)clsignoredrs rIruANewConnectionHelperTests.test_defaultKnownHosts..sVrLN)rpatchr2rrh)rHrrs @rItest_defaultKnownHosts/NewConnectionHelperTests.test_defaultKnownHostss\  '8ST%             ff//0rLc[5RSn[UR55n[ U5nUR SU5 UR 5 [SUR<35 [RRS5nURRUS5nUR[SU5 [SU<35 [R"5nURUR!SU55 g)z Existing entries in the I{known_hosts} file are reflected by the L{KnownHostsFile} created by L{_NewConnectionHelper} when none is supplied to it. rs 127.0.0.1zCreated known_hosts file at z~/rzPatched _KNOWN_HOSTS with N)rrr#rfr,rirkr$pathos expanduserreplacer%r2r r| hasHostKey)rHrr)rhhomedefaultloadeds rItest_readExisting*NewConnectionHelperTests.test_readExistings ))*5 &#D) lC0 *499- 89ww!!$'))##D$/ 'A ( 45%113 )),<=rLc l[SSSSSSSSSS5 nURUR[5 g)zb If L{None} is passed for the C{ui} parameter to L{_NewConnectionHelper}, a L{ConsoleUI} is used. N)r2rror+rs rItest_defaultConsoleUI.NewConnectionHelperTests.test_defaultConsoleUIs9 & $dD$dD$  fii3rLc [S5n[SSSSSSSSSSU5 nURURR S55nUR U5 g)z If L{None} is passed for the C{ui} parameter to L{_NewConnectionHelper} and /dev/tty is available, the L{ConsoleUI} used is associated with /dev/tty. syesNsdoes this work?)r r2rrorr|rHttyrrs rItest_ttyConsoleUI*NewConnectionHelperTests.test_ttyConsoleUIs] v% $dD$dD$ %%fii&6&67I&JK rLc [UR55n[SSSSSSSSSSU5 nURURR S55nUR U5 g)z If L{None} is passed for the C{ui} parameter to L{_NewConnectionHelper} and /dev/tty is not available, the L{ConsoleUI} used is associated with some file which always produces a C{b"no"} response. Nsdid this break?)r#rfr2rrorrr7s rI test_nottyUI%NewConnectionHelperTests.test_nottyUIse t{{}%% $dD$dD$ %%fii&6&67I&JK  rLc v[SSSSSSSSSS5 nUR[S5UR5 g)za If not passed the name of a tty in the filesystem, L{_NewConnectionHelper} uses C{b"/dev/tty"}. Ns/dev/tty)r2rr#r8rs rItest_defaultTTYFilename0NewConnectionHelperTests.test_defaultTTYFilename"s> & $dD$dD$  +. ;rLc [SSSSSSSSSS5 n[5n[5UlUR US5 UR URR 5 g)zu L{_NewConnectionHelper.cleanupConnection} closes the transport cleanly if called with C{immediate} set to C{False}. NF)r2r6rrrr|r})rHrrs rIr=NewConnectionHelperTests.test_cleanupConnectionNotImmediately,s_ & $dD$dD$ #_ .0   U3  ,,::;rLc  "SS5n[SSSSSSSSSS5 n[5n[5UlU"5URlUR US5 UR URRR 5 g)z L{_NewConnectionHelper.cleanupConnection} closes the transport with C{abortConnection} if called with C{immediate} set to C{True}. c\rSrSrSrSrSrg)MNewConnectionHelperTests.test_cleanupConnectionImmediately..Abortablei?FcSUlg)z Abort the connection. TNrErGs rIrJ]NewConnectionHelperTests.test_cleanupConnectionImmediately..Abortable.abortConnectionBs  $ rLrEN)rMrNrOrPrFrJrRrSrLrI AbortablerE?s G $rLrHNT)r2r6r9rrr|rF)rHrHrrs rIr:NewConnectionHelperTests.test_cleanupConnectionImmediately9s  $ $& $dD$dD$ #_ 13 )2 &  T2  ,,66>>?rLrS)rN)rMrNrOrPrQrrr&r1r4r9r<r?rrrRrSrLrIrrs<S R 1.>.4   !< <@rLr)yrQos.pathr*iorstructrtypingrzope.interfacerzope.interface.verifyrrrFtwisted.conch.errorr r r twisted.conch.interfacesr twisted.cred.checkersr twisted.cred.portalrtwisted.internet.addressrtwisted.internet.deferrrrrtwisted.internet.errorrrrrtwisted.internet.interfacesrrtwisted.internet.protocolrrtwisted.internet.testingrrrtwisted.loggerrr twisted.python.compatr!twisted.python.failurer"twisted.python.filepathr#twisted.python.logr$twisted.python.reflectr%twisted.trial.unittestr&twisted.conch.avatarr(twisted.conch.checkersr)r*twisted.conch.client.knownhostsr+r,twisted.conch.endpointsr-r.r/r0r1r2twisted.conch.sshr3twisted.conch.ssh.agentr4twisted.conch.ssh.channelr5twisted.conch.ssh.connectionr6twisted.conch.ssh.factoryr7twisted.conch.ssh.keysr8twisted.conch.ssh.transportr9twisted.conch.ssh.userauthr:twisted.conch.test.keydatar;r<r=r>skiprtwisted.test.iosimr?r@rBrUr`rfrkr~rrrrrrrcrrrr rrSrLrIrps&;KK/I&0JJ H7 8/*,"0+  .LI)64:4*>< (DJM CJNN I5 ]   $$Z&2244  .!2.(!Z!* X    "##%#%$#%LkBkB\ ] 8#E] 8@R3h(JR3j)1H)1Xg..0P@xP@rL