+ Dfj$Rt^RIt^RIHt^RIHt^RIHt^RI H t ^RI H t H t ^RIt^RIHtHtHt^RIHt^R IHt^R IHt^R IHt^R IHtHtHtHt^R I H!t!H"t"H#t#H$t$^RI%H&t&H't'^RI(H)t)H*t*^RI+H,t,H-t-H.t.^RI/H0t0H1t1^RI2H3t3^RI4H5t5^RI6H7t7^RI8H9t9^RI:H;t;^RIH?t?^RI@HAtAHBtB^RICHDtDHEtE^RIFHGtGHHtHHItIHJtJHKtKHLtL^RIMHNtN^RIOHPtP^RIQHRtR^R ISHTtT^R!IUHVtV^R"IWHXtX^R#IYHZtZ^R$I[H\t\^R%I]H^t^H_t_H`t`HataMR&tb]ctV]ct\]ctT]ctX]ctR]ctP]ctE]ctB]ct?^R'IdHeteHftf!R(R)]e4tg!R*R+]R4th!R,R-]R4ti!R.R/]R4tj!R0R14tk!R2R3])4tl!R4R54tm!R6R7]\4tn!R8R9]V4to] !]&4!R:R;44tp] !]'4!R<R=44tq!R>R?4tr!R@RA]=]r4ts!RBRC]=]r4tt!RDRE]=4tu!RFRG]4tv!RHRI4tw!RJRK]=4txR#)Lz' 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.a]tRt^VtoRtRtRtRtVtR#)AbortableFakeTransportz; A L{FakeTransport} with added C{abortConnection} support. Fc RVnR#)ze Abort the connection in a fake manner. This should really be implemented in the underlying module. TNabortedselfs&C/usr/lib/python3/dist-packages/twisted/conch/test/test_endpoints.pyabortConnection&AbortableFakeTransport.abortConnection]s  rCN) __name__ __module__ __qualname____firstlineno____doc__rDrH__static_attributes____classdictcell__ __classdict__s@rGrArAVsGrJrAc*a]tRt^ftoRtRtRtVtR#)BrokenExecSessionzG L{BrokenExecSession} is a session on which exec requests always fail. c ^#)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} rFdatas&&rG request_execBrokenExecSession.request_execkrJrWNrKrLrMrNrOrZrPrQrRs@rGrUrUf  rJrUc*a]tRt^xtoRtRtRtVtR#)WorkingExecSessionzK L{WorkingExecSession} is a session on which exec requests always succeed. c ^#)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} rWrXs&&rGrZWorkingExecSession.request_exec}r\rJrWNr]rRs@rGr`r`xr^rJr`c*a]tRt^toRtRtRtVtR#)UnsatisfiedExecSessionz} L{UnsatisfiedExecSession} is a session on which exec requests are always delayed indefinitely, never succeeding or failing. c \4#)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&&rGrZ#UnsatisfiedExecSession.request_execs zrJrWNr]rRs@rGrdrds  rJrdc,a]tRt^toRtRtRtVtR#) TrivialRealmc/VnR#N channelLookuprEs&rG__init__TrivialRealm.__init__s rJcL\4pVPVn\VR3#)cR#rjrWrWrJrG,TrivialRealm.requestAvatar..sDrJ)r'rlr )rFavatarIdmind interfacesavatars&&&* rG requestAvatarTrivialRealm.requestAvatars$#11FL11rJrkN)rKrLrMrNrmrwrPrQrRs@rGrhrhs 22rJrhc*a]tRt^toRtRtRtVtR#)AddressSpyFactoryNc:Wn\P!W4#rj)addressr buildProtocol)rFr|s&&rGr}AddressSpyFactory.buildProtocols $$T33rJ)r|)rKrLrMrNr|r}rPrQrRs@rGrzrzsG44rJrzc2a]tRt^toRtRtRtRtVtR#)FixedResponseUIcWnR#rjresult)rFrs&&rGrmFixedResponseUI.__init__s rJc,\VP4#rj)rrrFtexts&&rGpromptFixedResponseUI.promptst{{##rJcR#rjrWrs&&rGwarnFixedResponseUI.warns rJrN) rKrLrMrNrmrrrPrQrRs@rGrrs$  rJrc@a]tRt^to]R4t]R4tRtVtR#)FakeClockSSHUserAuthServerc BVPPP#)za Use the C{attemptsBeforeDisconnect} value defined by the factory to make it easier to override. ) transportfactoryattemptsBeforeDisconnectrEs&rGr3FakeClockSSHUserAuthServer.attemptsBeforeDisconnects ~~%%>>>rJc BVPPP#)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). )rrreactorrEs&rGclock FakeClockSSHUserAuthServer.clocks~~%%---rJrWN) rKrLrMrNpropertyrrrPrQrRs@rGrrs+ ??..rJrcPa]tRt^to]R4t]R4tR]R]/t ^t Rt Vt R#)CommandFactoryc<R\P!\R7/#ssh-rsa)rY)r7 fromStringr=rEs&rG publicKeysCommandFactory.publicKeyssCNN0ABCCrJc<R\P!\R7/#r)r7rr;rEs&rG privateKeysCommandFactory.privateKeyssCNN0BCDDrJs ssh-userauthsssh-connectionrWN) rKrLrMrNrrrrr5servicesrrPrQrRs@rGrrsK DDEE 3=H !rJrc]tRt^tRtR#) MemoryAddressrWN)rKrLrMrNrPrWrJrGrrsrJrc0a]tRt^toRtRtRtRtVtR#)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} c RVnWnR#)zx @param server: An L{IProtocol} provider to which the client will be connected. @type server: L{IProtocol} provider N)pump_server)rFservers&&rGrm SingleUseMemoryEndpoint.__init__s   rJc .VPe \R4hVP\44p\ VP \ VP RR7V\ VRR74Vn\V4# \d\4u#i;i)Nz(SingleUseMemoryEndpoint was already usedTisServerF) r Exceptionr}rr?rrAr BaseExceptionr)rFrprotocols&& rGr?SingleUseMemoryEndpoint.connects 99 FG G %,,]_=H  &t||dC&x%@ DI 8$ $ 6M sA<<BB)rrN) rKrLrMrNrOrmr?rPrQrRs@rGrrs%%rJrca]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtRtRtRRltRtRtRtVtR#)"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}. cRVnRVnRVnRVn\ 4Vn\ 4Vn\VP4Vn \4Vn VPPVPVP4VPPVP4\4VnVP VPnVPVPn VPP!4VP#VPP$4\'RRR4Vn\'RRR4VnR #) sssh.example.comi&suserspasswordTCPz10.0.0.1i90z192.168.100.200i1N)hostnameportuserpasswordrrrhrealmr portalr passwdDBaddUserregisterCheckerrrdoStart addCleanupdoStopr clientAddress serverAddressrEs&rGsetUp(SSHCommandClientEndpointTestsMixin.setUps*   # )+ !^ TZZ( ?A  dii7 ##DMM2%' #|| "kk    ++,( EB(0A5IrJc H\VPP: R24h)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__rKrEs&rGcreate)SSHCommandClientEndpointTestsMixin.create1s' "~~&&))B C  rJc H\VPP: R24h)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 assertClientTransportStaterrFclientimmediateCloses&&&rGassertClientTransportState=SSHCommandClientEndpointTestsMixin.assertClientTransportState:s#"~~&& )  rJc H\VPP: R24h)zp Do any remaining work necessary to complete an in-memory connection attempted initiated using C{self.reactor}. z# did not implement finishConnectionrrEs&rGfinishConnection3SSHCommandClientEndpointTestsMixin.finishConnectionJs' "~~&&))L M  rJc VPR4pVPR4p\VRVPVPR7p\VRVPVPR7p\ WFW54pWCV3#)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)r}rArrr?)rF serverFactory clientFactoryclientProtocolserverProtocolclientTransportserverTransportrs&&& rGconnectedServerAndClient;SSHCommandClientEndpointTestsMixin.connectedServerAndClientSs'44T:&44T:0 ****   1 ****  ~Xt33rJc HVP4p\4p\VnVP V4pVP 4wrEpVP \4pVPRV^,PPV^,PP34VP^\V44VPV4pVP\4VPRVPP4VPVR4R#)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 channelunknown channelFN)rrrrr?rflushLoggedErrorsrassertInvaluerY assertEquallenfailureResultOftrapr) rFendpointr connectedrrrerrorsfs & rGtest_channelOpenFailure:SSHCommandClientEndpointTestsMixin.test_channelOpenFailureps ;;=)#$$W- #446'' 3 '&)//*>*>q @U@U)VW CK(   + z +QWW]]; ''6rJc \VPPR&VP4p\ 4p\ VnVPV4pVP4wrEpVPV4pVP\4VPRVPP4VPVR4R#)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)rUrrlrrrrr?rrrrrrrrFrrrrrrrs& rGtest_execFailure3SSHCommandClientEndpointTestsMixin.test_execFailures 0A   ,;;=)#$$W- #446   + z 1177==A ''6rJc b\VPPR&VP4p\ 4p\ VnVPV4pVP4wrEpVP4VPV4pVP\4VPVR4R#)z If execution of the command is cancelled via the L{Deferred} returned by L{SSHCommandClientEndpoint.connect}, the connection is closed immediately. rTN)rdrrlrrrrr?rcancelrrrrrs& rGtest_execCancelled5SSHCommandClientEndpointTestsMixin.test_execCancelleds 0F   ,;;=)#$$W- #446   + ~ ''5rJc :\VPPR&VP4p\ 4p\ VnVPV4VP4wr4pVPVP\4VPVPP4VPP4VPVP VPP"4VPRVPP$4R#)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`rrlrrzrrr?rassertIsInstancer|r-rrgetHostrrusernamecommand)rFrrrrrs& rGtest_buildProtocol5SSHCommandClientEndpointTestsMixin.test_buildProtocols0B   ,;;=#%#!#446 goo/@A ))113W__5K5KL GOO$<$<= (?(?@rJc *\VPPR&VP4p\ 4p\ VnVPV4pVP4wrEpVPV4pVPVP4R#)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`rrlrrrrr?rsuccessResultOfassertIsNotNonerrFrrrrrrrs& rGtest_makeConnection6SSHCommandClientEndpointTestsMixin.test_makeConnectionsz0B   ,;;=)#$$W- #446'' 2 X//0rJc \VPPR&VP4p\ 4p\ VnVPV4pVP4wrEpVPV4p.pVPVn VPPp VPPV ,P!R4VP#4VP%RRP'V44R#)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, worldrJN)r`rrlrrrrr?rrappend dataReceivedridservicechannelswriterrjoin) rFrrrrrrrr  channelIds & rGtest_dataReceived4SSHCommandClientEndpointTestsMixin.test_dataReceiveds 0B   ,;;=)#$$W- #446'' 2 , 3 3&&))  *00A  #((<*@ArJc \VPPR&VP4p\ 4p\ VnVPV4pVP4wrEpVPV4p.pVPVn VPPp VPPV ,P!4VP#4V^,P%\&4VP)VR4R#)zY When the command closes the channel, the protocol's C{connectionLost} method is called. rFN)r`rrlrrrrr?rrr connectionLostrrrrloseConnectionrrrr) rFrrrrrrrrrs & rGtest_connectionLost6SSHCommandClientEndpointTestsMixin.test_connectionLosts 0B   ,;;=)#$$W- #446'' 2"0"7"7&&))  *99; q~. ''6rJc *\VPPR&VP4p\ 4p\ VnVPV4pVP4wrgpVPV4p .p V PV n V PPp VPPV ,p VPP!WV4V P#4VP%4VP'VR4V ^,#)z: Test handling of non-zero exit statuses or exit signals. rF)r`rrlrrrrr?rrr rrrrr sendRequestrrr) rFrequest requestArgrrrrrrrrrchannels &&& rG_exitStatusTest2SSHCommandClientEndpointTestsMixin._exitStatusTests0B   ,;;=)#$$W- #446'' 2"0"7"7 &&)) ..)))4""7Z@   ''6a  rJc l^pVPR\RV44pVP\4R#) 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. exit-status>LN)r rrr)rFexitCodeexcs& rGtest_zeroExitCode4SSHCommandClientEndpointTestsMixin.test_zeroExitCode2s. "">4h3GH  rJc ^{pRpVPR\RV44pVP\4VP WP P 4VP W#P P4R#)r#Nr$r%)r rrrrrr&signal)rFr&r+r's& rGtest_nonZeroExitStatus9SSHCommandClientEndpointTestsMixin.test_nonZeroExitStatus<sd "">4h3GH "# 99#5#56 !1!12rJc \4p\P!V4VP\PV4Rp^pRP \ P!R4R\ P!R4\ P!R4.4pVPRV4pVP\4VPW%PP4VPW5PP4Rp\P !V\P"!\P$!R \P&!\(P*4R VR RR R RRRR/444R#)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. NrJsTERMsmessagesen-USs exit-signalz'twisted.conch.endpoints._CommandChannel log_level log_namespaceshortSignalName coreDumpedT errorMessagemessage languageTag)rr addObserverrremoveObserverrr2NSr rrrrr&r+hamcrest assert_thathas_item has_entriesequal_torinfo)rF logObserverr&r+packetr' logNamespaces& rGtest_nonZeroExitSignal9SSHCommandClientEndpointTestsMixin.test_nonZeroExitSignalIs(+, &&{3 *99;G '" *% (#   "">6: "# 99#5#56 !1!12@     $$#X%6%6x}}%E')7$d& %x    rJc aVPPp.oV'dV3RlpM SPp\VPP V,W64S#)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&<SPR4#rj)r )recordersrGrq;SSHCommandClientEndpointTestsMixin.record..s-rJ)rrr setattrrr)rFrreventnoArgsrrrGs&&&&& @rGrecord)SSHCommandClientEndpointTestsMixin.recordwsJ &&))  -AA'' 2E=rJc \VPPR&VP4p\ 4p\ VnVPV4pVP4wrEpVPV4pVPWGR4pVPPR4VP4VPRRPV44R#)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. rr r rJN)r`rrlrrrrr?rrrLrrrrr rFrrrrrrrr s & rG test_write-SSHCommandClientEndpointTestsMixin.test_writes 0B   ,;;=)#$$W- #446'' 2{{6^D   1  #((<*@ArJc \VPPR&VP4p\ 4p\ VnVPV4pVP4wrEpVPV4pVPWGR4pVPPR.4VP4VPRRPV44R#)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. rr r rJN)r`rrlrrrrr?rrrLr writeSequencerrrrOs & rGtest_writeSequence5SSHCommandClientEndpointTestsMixin.test_writeSequences 0B   ,;;=)#$$W- #446'' 2{{6^D ((/):;  #((<*@ArJ) rrrrrrrrrrrN)F)rKrLrMrNrOrrrrrrrrrrrrr r(r,rCrLrPrTrPrQrRs@rGrrsu J(   4:747*6*A.1&B678!:! 3, \6B*BBrJrca]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtRtRtRtRtRtRtRtRtRtRtVtR#)NewConnectionTestsizT Tests for L{SSHCommandClientEndpoint} when using the C{newConnection} constructor. c \PV4\VP44Vn\ VP4VnVP PVPVPPR,4VP P\VPP4VPPR,4VP P4R#)g Configure an SSH server with password authentication enabled for a well-known (to the tests) account. rN)rrr"mktemp hostKeyPathr+ knownHosts addHostKeyrrrr rhostsaverEs&rGrNewConnectionTests.setUps +006#DKKM2()9)9: ""4==$,,2I2I*2UV "" $,,11 2DLL4K4KJ4W  rJc  \P!VPRVPVPVP VP VP\R4R7#)z] Create and return a new L{SSHCommandClientEndpoint} using the C{newConnection} constructor. rFrr\ui) r. newConnectionrrrrrr\rrEs&rGrNewConnectionTests.createsL (55 LL  II MM II]]u%  rJc ~VPVPVPP^,^,4#)ze Establish the first attempted TCP connection using the SSH server which C{self.factory} can create. )rrr tcpClientsrEs&rGr#NewConnectionTests.finishConnections4 ,, LL$,,11!4Q7  rJc VPWRRR7pVPP4VP4VP R.V4VP4VPP 4R#)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)rKN)rLrrrrreportDisconnect)rFrrrrrjs&&&&& rGloseConnectionToServer)NewConnectionTests.loseConnectionToServersd*VxE))+  $(  ))+rJc V'd(VPVPP4R#VPVPP4R#)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) assertTruerrD disconnectingrs&&&rGr-NewConnectionTests.assertClientTransportStates7  OOF,,44 5 OOF,,:: ;rJc \P!VPRRVPVP4pVP \ \V44R#)zI L{SSHCommandClientEndpoint} instances provide L{IStreamClientEndpoint}. dummy command dummy userN)r.rdrrrrorrrFrs& rGtest_interface!NewConnectionTests.test_interfacesB,99 LL*M4==$))   %:HEFrJc \P!VPRRVP4pVP ^VP P 4R#)zn L{SSHCommandClientEndpoint} uses the default port number for SSH when the C{port} argument is not specified. rsrtNr.rdrrr_creatorrrus& rGtest_defaultPort#NewConnectionTests.test_defaultPort$sD ,99 LL*M4==  X..334rJc \P!VPRRVPRR7pVP RVP P 4R#)zE L{SSHCommandClientEndpoint} uses the C{port} argument if specified. rsrti)rNryrus& rGtest_specifiedPort%NewConnectionTests.test_specifiedPort.sF,99 LL*M4==t  x00556rJc  :\P!VPRVPVPVP VP VP\R4R7p\4p\Vn VPV4VPP^,wr4r%pVPVP\V44VPVP V4VP^\!VPP44R#)z L{SSHCommandClientEndpoint} uses the L{IReactorTCP} passed to it to attempt a connection to the host/port address also passed to it. rFrbN)r.rdrrrrrr\rrrrr?rgrr r)rFrrr^rtimeout bindAddresss& rGtest_destination#NewConnectionTests.test_destination7s ,99 LL  II MM II]]u%  )#!48LL4K4KA4N1Gk  d(;< D) C 7 789rJc  \P!VPRRVPVPVP \ R4R7p\4p\Vn VPV4pVPP^,^,pVPR\\444VPV4P!\4R#)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. rrtFr\rcN)r.rdrrrr\rrrrr?rgclientConnectionFailedr!rrrrFrrds& rGtest_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    + ~rJc  \P!VPRRVPVPVP \ R4R7p\4p\Vn VPV4p\4pVPP^,^,pVPR4pVPV4VP\!\#444VP%V4P'\"4R#)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. rrtFrN)r.rdrrrr\rrrrr?rrgr}makeConnectionrr!rrrrFrrrrrs& rG!test_connectionClosedBeforeSecure4NewConnectionTests.test_connectionClosedBeforeSecures,99 LL   MM IIu% )#   W %#% ,,))!,Q/&&t,i(gn&678 Q$$^4rJc  v\P!VPRRVPVPVP \ R4R7p\4p\Vn VPV4p\RRR7pVPP^,^,pVPR4pVPV4VP4VP!V4P#\$4VP'VP(4VP+\-\/444R#)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. rrtFrNr)r.rdrrrr\rrrrr?rArgr}rrrrrrorDrr!rrs& rG$test_connectionCancelledBeforeSecure7NewConnectionTests.test_connectionCancelledBeforeSecures,99 LL   MM IIu% )#   W %*4%@ ,,))!,Q/&&t,i(   Q$$^4  ))* gn&678rJc  \P!VPRRVPVPVP \ R4R7p\4p\Vn VPV4pVP4VPV4P\4VPVPP ^,P"4R#)zb If the connection is cancelled before it finishes connecting, the connection attempt is stopped. rrtFrN)r.rdrrrr\rrrrr?rrrrro connectorsstoppedConnectingrs& rG'test_connectionCancelledBeforeConnected:NewConnectionTests.test_connectionCancelledBeforeConnecteds ,99 LL   MM IIu% )#   W %   Q$$%=>  //2DDErJc  `\P!VPRRVPVPRVP \ R4R7p\4p\Vn VPV4pVPVPVPP^,^,4wrEpVPPVPP 4VP#4VP%V4pVP'\(4VP+VR4R#)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}. rrtrFrbN)r.rdrrrr\rrrrr?rrrgadvancer passwordDelayflushrrr,rrs& rG"test_passwordAuthenticationFailure5NewConnectionTests.test_passwordAuthenticationFailures ,99 LL   MM II&u%  )#$$W- #<< LL$,,11!4Q7  V^^99:   + #$ ''6rJc VP4UUu/uF+wr4V\P!V4P4.bK- ppp\ \ V44pVP V4R#uuppi)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)itemsr7rrr)r(r)rFruserskvmappingcheckers&&& rGsetupKeyChecker"NewConnectionTests.setupKeyChecker-s`@E{{}M}tq1s~~a(//122}M%&6w&?@w'Ns1A/c  \P!\4pVPVPVP \ /4\P!VPRVP VPVPV.VP\R4R7p\4p\VnVP#V4pVP%VP&VPP(^,^,4wrVpVP+V4pVP-\.4VP1VP2P44R#)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}. rFkeysr\rcN)r7rr;rrrr:r.rdrrrr\rrrrr?rrrgrrr,rorrp) rFbadKeyrrrrrrrs & rG#test_publicKeyAuthenticationFailure6NewConnectionTests.test_publicKeyAuthenticationFailure>s  23 T[[4996H*IJ+99 LL  II MM IIu%  )#$$W- #<< LL$,,11!4Q7    + #$ ((667rJc  f\P!\4pVPVPVP \ /4\P!VPRVP VPVPV.VPVP\R4R7 p\4p\ VnVP%V4pVP&;P(^, unVP+VP&VPP,^,^,4wrVpVP/4VP1\24pVP5RV^,P6P8V^,P6P634VP;^\=V44VP?V4p V PA\24VP;RV P6P64VPCVPDPF4R#)zc If the SSH server does not accept any of the specified SSH keys, the specified password is tried. rF)rrr\rcrrN)$r7rr;rrrr:r.rdrrrrr\rrrrr?rrrrgrrrrrrYrrrrrorrp) rFrrrrrrrrrs & rGtest_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]]; ((667rJc  \P!\4pVPVPVP \/4\ VPPR&\P!VPRVP VPVPV.VP\R4R7p\!4p\"VnVP'V4pVP)VP*VPP,^,^,4wrVpVP/V4pVP1VP24R#)z If L{SSHCommandClientEndpoint} is initialized with any private keys, it will try to use them to authenticate with the SSH server. rrFrN)r7rr:rrrr`rrlr.rdrrrr\rrrrr?rrrgrrr) rFkeyrrrrrrrs & rGtest_publicKeyAuthentication/NewConnectionTests.test_publicKeyAuthentications nn/0 T[[4996H*IJ/A   ,+99 LL  II MM IIu%  )#$$W- #<< LL$,,11!4Q7 '' 2 X//0rJc  :\P!VPRVPVPVP VP \R4R7p\4p\Vn VPV4pVPVPVPP^,^,4wrEpVP4VP!V4pVP#\$4VP'VP(P*4R#)zn If the password is not specified, L{SSHCommandClientEndpoint} doesn't try it as an authentication mechanism. rFrN)r.rdrrrrr\rrrrr?rrrgrrrr,rorrprs& rGtest_skipPasswordAuthentication2NewConnectionTests.test_skipPasswordAuthentications ,99 LL  II MM IIu% )#$$W- #<< LL$,,11!4Q7     + #$ ((667rJc  v\P!\4p\4p\ 4VnVP 4VR3/VP nVPVPVP\/4\V4p\P!VPRVPVPVP VP"\%R4VR7p\&VP(P*R&\ 4p\,VnVP1V4pVP3VP VPP4^,^,4wrxp \7^4F-p VP8P94V P94K/ VP;V4p VP=V P>4VPAWxW4VPCVP>PD4VPCVP8PFPD4R#)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. rJrF)r\rc agentEndpointrN)$r7rr;r3rrblobrrrrrr.rdrrrr\rr`rrlrrr?rrgrangerrrrrlrorpclientIO) rFr agentServerrrrrrrrirs & rGtest_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  **33AABrJc b\VPPR&VP4p\ 4p\ VnVPV4pVP4wrEpVPV4pVPWEWv4VPVPP4R#)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`rrlrrrrr?rrrlrorrprs& rGtest_loseConnection&NewConnectionTests.test_loseConnections 0B   ,;;=)#$$W- #446'' 2 ##FHC ((667rJ)r[r\N)rKrLrMrNrOrrrrlrrvr{r~rrrrrrrrrrrrrrrrPrQrRs@rGrWrWs   !,F <G57:0=0 8*X5< 9DF,&7P("#8J.8`1>8B1Cf88rJrWc<a]tRtRtoRtRtRtRtRtRt Vt R#) ExistingConnectionTestsizY Tests for L{SSHCommandClientEndpoint} when using the C{existingConnection} constructor. c  2\PV4\\VP 444pVP VP VPPR,4VP \VPP4VPPR,4\P!VPRVPVP VP VP"V\%R4R7VnR#)rYrrFrbN)rrr+r"rZr]rrrr rr^r.rdrrrrrr)rFr\s& rGrExistingConnectionTests.setUp#s +006#HT[[]$;< dmmT\\-D-DZ-PQ $,,11 2DLL4K4KJ4W 1>> LL  II MM II]]!u%   rJc 6\4p\VnVPP V4pVP P P4p\VP P R&VPVPVPP^,^,4wrEpVP P P4VP P PV4W@nWPnW`nVP%V4pVP&P(p\*P,!VR4# TP P P4TP P PT4i;i)zb Create and return a new L{SSHCommandClientEndpoint} using the C{existingConnection} constructor. rr)rrrrr?rrlcopyr`rrrrgclearupdater_client_pumprrconnr.existingConnection) rFrrrlrrrr connections & rGrExistingConnectionTests.create;s1 )#MM))'2  00557  ;3EDJJ $ $Z 0#'#@#@ dll55a8;$ FD JJ $ $ * * , JJ $ $ + +M :   '' 2'',, ':::}UU JJ $ $ * * , JJ $ $ + +M :sAE A Fc VPP4VPP4VPP4VPP4VPVPVP3#)zw Give back the connection established in L{create} over which the new command channel being tested will exchange data. )rrrrrEs&rGr(ExistingConnectionTests.finishConnectionYsU    ||T\\4::55rJc VPVPP4VPVPP4R#)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) assertFalserrprDrs&&&rGr2ExistingConnectionTests.assertClientTransportStategs8 ))778 ))112rJ)rrrrN) rKrLrMrNrOrrrrrPrQrRs@rGrrs$  0V< 633rJrc<a]tRtRtoRtRtRtRtRtRt Vt R#) ExistingConnectionHelperTestsirz) Tests for L{_ExistingConnectionHelper}. c LVP\\\44R#)zD L{_ExistingConnectionHelper} implements L{_ISSHConnectionCreator}. N)rorr0r/rEs&rGrv,ExistingConnectionHelperTests.test_interfacews  $:VR8XgQh\VP4#)z If the mode is r+, return a file with the given contents as a line. @return: a buffer of the given contents, which will discard any writes given to it. zr+)rr)rFr s&&rGopen _PTYPath.openst||t}}--rJrN) rKrLrMrNrOrmrrPrQrRs@rGrrs !!..rJrcla]tRtRtoRtRtRtV3RlRltRtRt R t R t R t R t R tRtVtR#)NewConnectionHelperTestsiz$ Tests for L{_NewConnectionHelper}. c LVP\\\44R#)z? L{_NewConnectionHelper} implements L{_ISSHConnectionCreator}. N)rorr0r1rEs&rGrv'NewConnectionHelperTests.test_interfaces  $:.sVrJN)rpatchr1rr\)rFrrs& @rGtest_defaultKnownHosts/NewConnectionHelperTests.test_defaultKnownHostss\  '8ST%             ff//0rJc (\4PR,p\VP44p\ V4pVP RV4VP 4\RVP: 24\PPR4pVPPVR4pVP\RV4\RV: 24\P!4pVPVP!RV44R#)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"rZr+r]r_r#pathos expanduserreplacer r1rro hasHostKey)rFrr$r\homedefaultloadeds& rGtest_readExisting*NewConnectionHelperTests.test_readExistings ))*5 &#D) lC0 *499- 89ww!!$'))##D$/ 'A ( 45%113 )),<=rJc  n\RRRRRRRRRR4 pVPVP\4R#)zb If L{None} is passed for the C{ui} parameter to L{_NewConnectionHelper}, a L{ConsoleUI} is used. N)r1rrcr*rs& rGtest_defaultConsoleUI.NewConnectionHelperTests.test_defaultConsoleUIs9 & $dD$dD$  fii3rJc  \R4p\RRRRRRRRRRV4 pVPVPP R44pVP V4R#)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?)rr1rrcrrorFttyrrs& rGtest_ttyConsoleUI*NewConnectionHelperTests.test_ttyConsoleUIs] v% $dD$dD$ %%fii&6&67I&JK rJc  \VP44p\RRRRRRRRRRV4 pVPVPP R44pVP V4R#)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"rZr1rrcrrr2s& rG test_nottyUI%NewConnectionHelperTests.test_nottyUIse t{{}%% $dD$dD$ %%fii&6&67I&JK  rJc  x\RRRRRRRRRR4 pVP\R4VP4R#)za If not passed the name of a tty in the filesystem, L{_NewConnectionHelper} uses C{b"/dev/tty"}. Ns/dev/tty)r1rr"r3rs& rGtest_defaultTTYFilename0NewConnectionHelperTests.test_defaultTTYFilename"s> & $dD$dD$  +. ;rJc  \RRRRRRRRRR4 p\4p\4VnVP VR4VP VPP 4R#)zu L{_NewConnectionHelper.cleanupConnection} closes the transport cleanly if called with C{immediate} set to C{False}. NF)r1r5rrrrorp)rFrrs& rGr=NewConnectionHelperTests.test_cleanupConnectionNotImmediately,s_ & $dD$dD$ #_ .0   U3  ,,::;rJc  "!RR4p\RRRRRRRRRR4 p\4p\4VnV!4VPnVP VR4VP VPPP 4R#)z L{_NewConnectionHelper.cleanupConnection} closes the transport with C{abortConnection} if called with C{immediate} set to C{True}. c*a]tRtRtoRtRtRtVtR#)MNewConnectionHelperTests.test_cleanupConnectionImmediately..Abortablei?Fc RVnR#)z Abort the connection. TNrCrEs&rGrH]NewConnectionHelperTests.test_cleanupConnectionImmediately..Abortable.abortConnectionBs  $ rJrCN)rKrLrMrNrDrHrPrQrRs@rG Abortabler@?sG $ $rJrCNT)r1r5r8rrrorD)rFrCrrs& rGr:NewConnectionHelperTests.test_cleanupConnectionImmediately9s  $ $& $dD$dD$ #_ 13 )2 &  T2  ,,66>>?rJrWN)rKrLrMrNrOrvrr!r,r/r4r7r:rrrPrQrRs@rGrrsJS R 11.>.4   !< <@@rJr)yrOos.pathr%iorstructrtypingrzope.interfacerzope.interface.verifyrrr:twisted.conch.errorrr r twisted.conch.interfacesr twisted.cred.checkersr twisted.cred.portalr twisted.internet.addressrtwisted.internet.deferrrrrtwisted.internet.errorrrrrtwisted.internet.interfacesrrtwisted.internet.protocolrrtwisted.internet.testingrrrtwisted.loggerrrtwisted.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.r/r0r1twisted.conch.sshr2twisted.conch.ssh.agentr3twisted.conch.ssh.channelr4twisted.conch.ssh.connectionr5twisted.conch.ssh.factoryr6twisted.conch.ssh.keysr7twisted.conch.ssh.transportr8twisted.conch.ssh.userauthr9twisted.conch.test.keydatar:r;r<r=skiprtwisted.test.iosimr>r?rArUr`rdrhrzrrrrrrrWrrrrrrWrJrGrks&;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@rJ