h) SrSSKrSSKrSSKJrJrJrJr SSKJ r SSK J r SSK J r Jr SSKJrJrJrJrJrJr SSKJr SS KJr SS KJr SS KJr SS KJr SS K J!r! SSKJ"r# \#RH(dSr"O\#r"\"cSr&OSr&\RNRQ\5(dSr)OSr)\RTRVr,"SS\RZ5r."SS\R^5r0"SS\15r2"SS\15r3"SS\15r4"SS\Rj5r6"SS\Rn5r8"SS \85r9"S!S"\Rn5r:"S#S$\Rn5r;"S%S&\Rn5r<"S'S(\Rn5r="S)S*\Rn5r>"S+S,\Rn5r?"S-S.\Rn5r@"S/S0\Rn5rA"S1S2\R5rC"S3S4\R5rES5rF"S6S7\15rG"S8S9\R^5rH"S:S;\H5rI"S<S=\I5rJ"S>S?\I5rK"S@SA\I5rL\0\04SBjrM"SCSD\RZ5rN"SESF\R^5rO"SGSH\!5rP"SISJ\!5rQ"SKSL5rR"SMSN5rS"SOSP\!5rT"SQSR\Rn5rU"SSST\R5rW"SUSV\W5rX"SWSX\X5rY"SYSZ\R^5rZ"S[S\\!5r[S]r\S^r]"S_S`\!5r^"SaSb\!5r_"ScSd5r`"SeSf5ra"SgSh\a5rb"SiSj\a5rc"SkSl\a5rd"SmSn\H5re\ "\&So5\ "\)Sp5"SqSr\!555rf"SsSt\!5rg"SuSv\15rh"SwSx\15ri"SySz\Rn5rj"S{S|\j5rk"S}S~\j5rl"SS\R^5rm"SS\R^5rn"SS\R^5ro"SS\!5rpSrq"SS5rrSrsSrt\"b\t"5ru\ "\&So5\ "\)Sp5"SS\r\!555rv"SS\I5rw\ "\&So5\ "\)Sp5"SS\r\!555rx\ "\&So5\ "\)Sp5"SS\r\!555ry"SS\Rj5rz"SS\Rn5r{"SS\Rn5r|"SS\R^5r}\"S5r~\"S5r"SS\\~\45r"SS\{5r"SS\!5r"SS5r"SS\!\5r"SS\!\5r"SS\!\5r"SS\!\5r"SS\!\5r"SS\!5r"SS\!5r"SS\!\5r"SS\!5r\ "\GR5"SS55r\ "\GR\5 \ "\GR\5 "SS\!5r"SS\!5r"SS\!5r"SS\!5rg!\%a Sr"GNf=f)z% Tests for L{twisted.protocols.amp}. N)ClassVarDictTypeTypeVar)skipIf) implementer) verifyClass verifyObject)addressdefererror interfacesprotocolreactor)StringTransport)amp)filepath)Failure)iosim)TestCasesslTFcB\rSrSrSrSrSrSrSrSr S\ 4S jr S r g ) TestProto2z A trivial protocol for use in testing where a L{Protocol} is expected. @ivar instanceId: the id of this instance @ivar onConnLost: deferred that will fired when the connection is lost @ivar dataToSend: data to send on the protocol rc[U[5(d[U55eXlX l[ R Ul[ R S-[ lg)N) isinstancebytesrepr onConnLost dataToSendr instanceCount instanceId)selfr!r"s \/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/test_amp.py__init__TestProto.__init__=sI*e,,>d:.>>,$$#11"+"9"9A"= c\/UlURRUR5 gN)data transportwriter"r%s r&connectionMadeTestProto.connectionMadeDs  T__-r)c:URRU5 gr+)r,append)r%rs r& dataReceivedTestProto.dataReceivedHs r)cNURRUR5 gr+)r!callbackr,r%reasons r&connectionLostTestProto.connectionLostKs   +r)returnc"SUR4-$)z Custom repr for testing to avoid coupling amp tests with repr from L{Protocol} Returns a string which contains a unique identifier that can be looked up using the instanceId property:: z)r$r/s r&__repr__TestProto.__repr__Ns!DOO#555r))r,r"r$r!N) __name__ __module__ __qualname____firstlineno____doc__r#r'r0r4r:strr>__static_attributes__r)r&rr2s.M>. , 6# 6r)rc \rSrSrSrSrSrg)SimpleSymmetricProtocol[c"URSUS9$Nhellohello)callRemoteStringr%texts r& sendHello!SimpleSymmetricProtocol.sendHello\s$$XT$::r)c0[R"USS9$rLrBoxr%boxs r& amp_HELLO!SimpleSymmetricProtocol.amp_HELLO_swwS]++r)rGN)r@rArBrCrSrZrFrGr)r&rIrI[s ;,r)rIc\rSrSrSrSrg)UnfriendlyGreetingc!Greeting was insufficiently kind.rGNr@rArBrCrDrFrGr)r&r]r]c+r)r]c\rSrSrSrSrg) DeathThreatgr_rGNr`rGr)r&rcrcgrar)rcc\rSrSrSrSrg)UnknownProtocolkz&Asked to switch to the wrong protocol.rGNr`rGr)r&rfrfks0r)rfc&\rSrSrSrSrSrSrg) TransportPeerocg)Nr)rG)r%dnameprotos r&retrieveTransportPeer.retrieversr)c6URR5$r+)r-getPeer)r% notAStringrns r&fromStringProtoTransportPeer.fromStringProtous&&((r)cgr+rG)r%rmstringsobjectsrns r&toBoxTransportPeer.toBoxxsr)rGN)r@rArBrCrortryrFrGr)r&ririos)r)ric \rSrSr%SrS\R "54S\R"SS94S\R"SS94S\ "SS94S\R "SS94S \R "SS94S \R "SS94/r S\R "54S\R"SS94/r \ S 0r \\\\\4\S '\S 0r\\\\\4\S'Srg)Hello|rMoptionalToptionalprintfrom mixedCasedash-argunderscore_arg UNFRIENDLYerrorssDEAD fatalErrorsrGN)r@rArBrC commandNamerStringBooleanUnicoderi argumentsresponser]rrrr Exceptionr__annotations__rcrrFrGr)r&r|r||sK 3::< ckk401 3;;-. -./ szz401 cjj$/0 CJJ56I3::<(8S[[$5O*PQH6H-5XFHT$y/501 2X;F:PK$tI567Pr)r|c0\rSrSr\R rSrSrg) NoAnswerHelloFrGN)r@rArBrCr|rrequiresAnswerrFrGr)r&rrs##KNr)rc \rSrSrSrS\R "54S\R"SS94S\R"SS94S\ "SS94S\R "SS94/r S\R "54S\R"SS94/r \ S 0r S rg ) FutureHellorMr~TrrrsbonusrrGN)r@rArBrCrrrrrrirrr]rrFrGr)r&rrsK 3::< ckk401 3;;-. -./ 3::t,- I3::<(8S[[$5O*PQH - 0Fr)rc\rSrSrSrSrg)WTFz# An example of an invalid command. rGNr`rGr)r&rrr)rc\rSrSrSrSrSrg) BrokenReturnzSAn example of a perfectly good command, but the handler is going to return None... s broken_returnrGN)r@rArBrCrDrrFrGr)r&rrs#Kr)rcT\rSrSrS\R "54/r\RrSr g)GoodbyesgoodbyerGN) r@rArBrCrrrQuitBox responseTyperFrGr)r&rrsSZZ\*+H;;Lr)rc\rSrSrSrSrg) WaitForevers wait_foreverrGN)r@rArBrCrrFrGr)r&rrs!Kr)rc\rSrSrSrS\R "54/rS\R"S\R "54/54/r Sr g)GetListsgetlistslengthbodyxrGN) r@rArBrCrrIntegerrAmpListrrFrGr)r&rrs>KS[[]+,I#++ckkm'<&=>?@Hr)rc\rSrSrSrS\R "54S\R"S\R "54/SS94/rS\R "54/r S r g ) DontRejectMes dontrejectmes magicWordslistnameTrsresponserGN) r@rArBrCrrrrrrrFrGr)r&rrsR!K s{{}% #++784HIIckkm,-Hr)rc<\rSrSrS\R "54/rSrg) SecuredPingspingedrGN)r@rArBrCrrrrFrGr)r&rrsCKKM*+Hr)rcH\rSrSrSrS\R "54/r\S0r Sr g)TestSwitchProtos Switch-ProtorsUNKNOWNrGN) r@rArBrCrrrrrfrrFrGr)r&rrs*!K #**,Iz *Fr)rc*\rSrSrSrSrSrSrSrg)SingleUseFactoryc0XlXRlgr+)rnfactory)r%rns r&r'SingleUseFactory.__init__s ! r)c,URSso lU$r+)rn)r%addrps r& buildProtocolSingleUseFactory.buildProtocols D :r)NcX lgr+) reasonFailedr% connectorr9s r&clientConnectionFailed'SingleUseFactory.clientConnectionFaileds "r))rnr) r@rArBrCr'rrrrFrGr)r&rrs"Lr)rs gwebol nargoc\rSrSrSrg)ThingIDontUnderstandErrorrGN)r@rArBrCrFrGr)r&rrsr)rcF\rSrSrSrSrSr\R\5 Sr g)FactoryNotifierNcURbRXRl[URS5(a&URRR S5 ggg)NonMade)rtheProtohasattrrr7r/s r&r0FactoryNotifier.connectionMadesI << #$(LL !t||X.. ##,,T2/ $r)clSSKJn URUR5(d [ S5eSS0$)Nr) ISSLTransportz+only send secure pings over secure channelspingedT)twisted.internet.interfacesr providedByr-rc)r%rs r&emitpongFactoryNotifier.emitpongs1=''77KL L$r)rG) r@rArBrCrr0rr responderrFrGr)r&rrs!G3  (#r)rcf\rSrSrSrSSjrSrSrSrSSjr \ R\ 5 Sr \ R\ 5 SS jr\R\5 S r\R\5 S r\R\5 SS jrS r\R\5 Sr\R\5 Srg)SimpleSymmetricCommandProtocoliNcN[RRU5 Xlgr+)rAMPr'r!)r%r!s r&r''SimpleSymmetricCommandProtocol.__init__ s $r)c*UR[US9$)NrN callRemoter|rQs r&rS(SimpleSymmetricCommandProtocol.sendHellosuD11r)c*UR[XS9$)NrOPrintr)r%rR translations r&sendUnicodeHello/SimpleSymmetricCommandProtocol.sendUnicodeHellosuDDDr)Fc&X RR5:XdeU[:Xa [5eUR S5(a [ S5eUS:Xa [ S5e[US9nUbUR[US95 SUl U$)NsfuckDon't be a dick.die aieeeeeeeeerN)rT) r-rrTHING_I_DONT_UNDERSTANDr startswithr]rcdictupdategreeted) r%rOFromrr mixedCasedash_argunderscore_argresults r&cmdHello'SimpleSymmetricCommandProtocol.cmdHellos~~--//// + ++- -   G $ $$%78 8 F?m, ,E"   MM$U+ ,  r)c S[SS9/U-0$)Nbodyr)xr)r%lengths r& cmdGetlist)SimpleSymmetricCommandProtocol.cmdGetlist/s f,--r)c6UcSnO SUSS-n[US9$)N list omittedz %s acceptedrrm)rr)r% magicWordlistrs r&okiwont&SimpleSymmetricCommandProtocol.okiwont4s) <%H$Q8HX&&r)cN[R"5UlUR$r+)r Deferredwaitingr/s r& waitforit(SimpleSymmetricCommandProtocol.waitforit=s~~' ||r)c[SS9$)Neveryone)goodbyerr/s r&saybye%SimpleSymmetricCommandProtocol.saybyeCs K((r)c^U(aSnOSn[UR[5mUR[[ T5US9R U4Sj5$)Nsno-proto test-proto)rmc>T$r+rG)ignrs r&ESimpleSymmetricCommandProtocol.switchToTestProtocol..Ps!r))rr!SWITCH_CLIENT_DATArrr addCallback)r%failrmrs @r&switchToTestProtocol3SimpleSymmetricCommandProtocol.switchToTestProtocolHsN D D doo'9 : -a0t +m $ %r)cXUS:Xa[UR[5$[U5eNr)rr!SWITCH_SERVER_DATArfr%rms r&switchit'SimpleSymmetricCommandProtocol.switchitRs' = T__.@A Ad##r)cgr+rGr/s r& donothing(SimpleSymmetricCommandProtocol.donothingYr))rr!r r+NNNNN)F)r@rArBrC maybeLaterr'rSrrrr|rrrrrr rrrrr!rr$rrFrGr)r&rrsJ%2EG . OOH. j!'7#)$) f%$ h'9%r)rc<\rSrSrSr\R \5 Srg) DeferredSymmetricCommandProtocoli_cUS:XaE[UR[5Ul[R "5UlUR $gr)rr!rmaybeLaterProtor r r(r s r&r!)DeferredSymmetricCommandProtocol.switchit`s; = #,T__>P#QD #nn.DO?? " !r))r(r,N)r@rArBrCr!rrrFrGr)r&r*r*_s# h'r)r*cJ\rSrSrSSjr\R \5 Srg)BadNoAnswerCommandProtocoliiNcg)zA This responder does nothing and forgets to return a dictionary. NrGr%rOrrrrrrs r& badResponder'BadNoAnswerCommandProtocol.badResponderjsr)rGr')r@rArBrCr2rrrFrGr)r&r/r/is(   L)r)r/cJ\rSrSrSSjr\R \5 Srg)NoAnswerCommandProtocoli{Nc[US-S9$)Ns -noanswerrNrr1s r&goodNoAnswerResponder-NoAnswerCommandProtocol.goodNoAnswerResponder|s%,.//r)rGr')r@rArBrCr7rrrFrGr)r&r5r5{s)  012r)r5c6[R"X/UQ70UD6$)z)Returns a 3-tuple: (client, server, pump))rconnectedServerAndClient) ServerClass ClientClassakws r&r:r:s  ) )+ MQ M" MMr)c\rSrSrSrSrSrg)TotallyDumbProtocolir)c.U=RU- slgr+)bufr%r,s r&r4 TotallyDumbProtocol.dataReceiveds Dr)rGN)r@rArBrCrBr4rFrGr)r&r@r@s Cr)r@c \rSrSrSrSrSrg) LiteralAmpic/Ulgr+boxesr/s r&r'LiteralAmp.__init__s  r)c:URRU5 gr+rIr3rXs r&ampBoxReceivedLiteralAmp.ampBoxReceiveds #r)rHN)r@rArBrCr'rMrFrGr)r&rFrFs r)rFc*\rSrSrSrSrSrSrSrg) AmpBoxTestsiza Test a few essential properties of AMP boxes, mostly with respect to serialization correctness. c[R"SS9nUR[UR 55[ 5 g)z( Make sure that strs serialize to strs. svaluekeyN)rAmpBox assertEqualtype serializerr%r=s r&test_serializeStrAmpBoxTests.test_serializeStrs- JJ8 $ akkm,e4r)ct[R"S0SS0D6nUR[UR5 g)zH Verify that TypeError is raised when trying to serialize Unicode keys. rSvalueNrGrrT assertRaises TypeErrorrWrXs r&test_serializeUnicodeKeyRaises*AmpBoxTests.test_serializeUnicodeKeyRaisess. JJ *%) * )Q[[1r)cl[R"SS9nUR[UR5 g)zJ Verify that TypeError is raised when trying to serialize Unicode values. r\rRNr]rXs r& test_serializeUnicodeValueRaises,AmpBoxTests.test_serializeUnicodeValueRaisess& JJ7 # )Q[[1r)rGN) r@rArBrCrDrYr`rcrFrGr)r&rPrPs 522r)rPc,\rSrSrSrSrSrSrSrg) ParsingTestsic[R"5nURURS55 UR URS55 UR [ URS5 UR [ URS5 UR [ URS5 URURS5S5 URURS5S5 g) zM Verify that the Boolean parser parses 'True' and 'False', but nothing else. sTruesFalsesninjastruesTRUETFN) rr assertTrue fromString assertFalser^r_rUtoString)r%bs r&test_booleanValuesParsingTests.test_booleanValuess KKM  W-. h/0 )Q\\8< )Q\\7; )Q\\7; D)73 E*H5r)c[R"UR55n[R"5nUR U5nUR U5nURX5 URX5 g)z< Verify the 'Path' argument can parse and emit a file path. N) rFilePathmktemprPathrkri assertIsNotrU)r%fprsvs r&test_pathValueRoundTrip$ParsingTests.test_pathValueRoundTrips[  t{{} - HHJ JJrN LLO  r)c[R"5nUR[RUR[R "55$)zS Test that empty boxes raise an error; they aren't supposed to be sent on purpose. )rrr^ NoEmptyBoxesrMrWrXs r&test_sillyEmptyThing!ParsingTests.test_sillyEmptyThings6 GGI  !1!113C3CSWWYOOr)c f[[[S9upnSnSnSnSnSnSn Sn U/XJ/XE/XF/XEXg/XVU/XHXY/XU//n U Hrn [R"5n U R [ U 55 U R U5 UR5 URURS U 5 Mt g ) zY Verify that various kinds of data make it through the encode/parse round-trip unharmed. )r<r;)simplestest)sceqs: )scrteststest )slftestshello )snewlinestest one two)snewline2stest one two)rsblah testtestN) r:rFrrWrr_sendToflushrUrI)r%crurSIMPLECECRLFNEWLINENEWLINE2BODYTESTtestDatatestjbs r&test_ParsingRoundTrip"ParsingTests.test_ParsingRoundTrips +"  a&  # $585H   L L  RL b + w '  DB IId4j ! JJqM GGI   QWWR[" - r)rGN) r@rArBrCrmrwr{rrFrGr)r&rfrfs 6  P!.r)rfc$\rSrSrSrSrSrSrg) FakeLocatorizN This is a fake implementation of the interface implied by L{CommandLocator}. c0Ulg)z> Remember the given keyword arguments as a set of responders. Ncommandsr/s r&r'FakeLocator.__init__ s  r)c URU$)zb Look up and return a function passed as a keyword argument of the given name to the constructor. r)r%rs r&locateResponderFakeLocator.locateResponders }}[))r)rN)r@rArBrCrDr'rrFrGr)r&rrs  *r)rc0\rSrSrSrSrSrSrSrSr g) FakeSenderizP This is a fake implementation of the 'box sender' interface implied by L{AMP}. c./Ul/UlSUlg)zV Create a fake sender and initialize the list of received boxes and unhandled errors. rN) sentBoxesunhandledErrorsexpectedErrorsr/s r&r'FakeSender.__init__s !r)c.U=RS- slg)z2 Expect one error, so that the test doesn't fail. rN)rr/s r& expectErrorFakeSender.expectError(s q r)c:URRU5 g)z& Accept a box, but don't do anything. N)rr3rXs r&sendBoxFakeSender.sendBox.s c"r)cU=RS-slURS:aUR5 gURRU5 g)zG Deal with failures by instantly re-raising them for easier debugging. rrN)rraiseExceptionrr3)r%failures r&unhandledErrorFakeSender.unhandledError4sC q     "  " " $  ' ' 0r))rrrN) r@rArBrCrDr'rrrrFrGr)r&rrs  ! # 1r)rcH\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) CommandDispatchTestsi?a The AMP CommandDispatcher class dispatches converts AMP boxes into commands and responses using Command.responder decorator. Note: Originally, AMP's factoring was such that many tests for this functionality are now implemented as full round-trip tests in L{AMPTests}. Future tests should be written at this level instead, to ensure API compatibility and to provide more granular, readable units of test coverage. c[5Ul[5Ul[R "UR5UlUR RUR5 g)z Create a dispatcher to use. N)rlocatorrsenderr BoxDispatcher dispatcherstartReceivingBoxesr/s r&setUpCommandDispatchTests.setUpKsB#}  l ++DLL9 ++DKK8r)c^/mU4Sjn[R"SSSS9nXRRS'URR U5 UR TU/5 g)z} L{CommandDispatcher.ampBoxReceived} should locate the appropriate command in its responder lookup, based on the '_ask' key. cV>TRU5 [R"SS05$)NrOr)r3rrW)rYreceiveds r&thunk4CommandDispatchTests.test_receivedAsk..thunk[s# OOC 77GY/0 0r)rOtest-command-idworld_command_askrON)rrWrrrrMrU)r%rinputrs @r&test_receivedAsk%CommandDispatchTests.test_receivedAskTsZ  1/@P). g& &&u- E7+r)cZ[S5nURR5 URR [ U55 UR [URR5S5 UR URRSRU5 g)za L{CommandDispatcher} should relay its unhandled errors in responding to boxes to its boxSender. zsomething went wrong, oh norrN) RuntimeErrorrrrrrrUlenrr\)r%errs r&test_sendUnhandledError,CommandDispatchTests.test_sendUnhandledErrordsy 89 ! &&ws|4 T[[8891= 44Q7==sCr)c^[S5mU4SjnXRRS'[R"SSSS9nUR R 5 URRU5 UR[UR R5S5 URUR RSRT5 g ) zX Errors during serialization ought to be relayed to the sender's unhandledError method. zsomething undefined went wrongcJ>"U4SjS[R5nU"5$)Nc">\rSrSrU4SjrSrg)WCommandDispatchTests.test_unhandledSerializationError..thunk..BrokenBoxiwc>Ter+rG)r%rnrs r&r_CommandDispatchTests.test_unhandledSerializationError..thunk..BrokenBox._sendToxsIr)rGN)r@rArBrCrrF)rsr& BrokenBoxrws r)rrV)rrrs r&rDCommandDispatchTests.test_unhandledSerializationError..thunkvs CGG ; r)rOrrrrrN) rrrrrWrrrrMrUrrr\)r%rrrs @r& test_unhandledSerializationError5CommandDispatchTests.test_unhandledSerializationErroros ;< */ g&/@P ! &&u- T[[8891= 44Q7==sCr)c URR[SS9nURURR [ R"SSSS9/5 /nURUR5 URU/5 URR[ R"SSSS.55 URU[SS S 9/5 g ) a+ L{CommandDispatcher.callRemote} should emit a properly formatted '_ask' box to its boxSender and record an outstanding L{Deferred}. When a corresponding '_answer' packet is received, the L{Deferred} should be fired, and the results translated via the given L{Command}'s response de-serialization. worldrNrM1ryayignoredrMrs_answerignoredrN) rrr|rUrrrrTrr3rMr)r%Danswerss r&test_callRemote$CommandDispatchTests.test_callRemotes OO & &uH & =  KK ! ! ZZH E F  gnn% "% && JJ&JDQ R  4fI#F"GHr)c0/nURUR5 URS[URR 55 UR URR SR[5 URS/U5 g)zh Verify that C{callResult} completes with a L{None} result and that an unhandled error has been logged. rrN) addBothr3rUrrrassertIsInstancer\ZeroDivisionError)r% callResult finalResults r&_localCallbackErrorLoggingTest3CommandDispatchTests._localCallbackErrorLoggingTestst  ;--. C ; ;<= dkk99!<BBDUV $-r)c URR5 URR[SS9nUR S5 URR [R"SSSS.55 URU5 g) z If the last callback on the L{Deferred} returned by C{callRemote} (added by application code calling C{callRemote}) fails, the failure is passed to the sender's C{unhandledError} method. rrNc SS-$NrrrGrs r&rVCommandDispatchTests.test_callRemoteSuccessLocalCallbackErrorLogging..sa1fr)rrrrN) rrrrr|rrMrrTrr%rs r&/test_callRemoteSuccessLocalCallbackErrorLoggingDCommandDispatchTests.test_callRemoteSuccessLocalCallbackErrorLoggingsq !__//X/F 45 && JJ&JDQ R  ++J7r)c URR5 URR[SS9nUR S5 URR [R"SSSS.55 URU5 g) z Like L{test_callRemoteSuccessLocalCallbackErrorLogging}, but for the case where the L{Deferred} returned by C{callRemote} fails. rrNc SS-$rrGrs r&rTCommandDispatchTests.test_callRemoteErrorLocalCallbackErrorLogging..sQ!Vr)rsbugssstuff)_error _error_code_error_descriptionN) rrrrr| addErrbackrMrrTrrs r&-test_callRemoteErrorLocalCallbackErrorLoggingBCommandDispatchTests.test_callRemoteErrorLocalCallbackErrorLoggingsx !__//X/F 34 && JJ#$++3   ++J7r))rrrN)r@rArBrCrDrrrrrrrrrFrGr)r&rr?s2 9, DD*I* .8"8r)rc\rSrSrSrSrS\R"54S\R"54/r S\R"54/r Sr g) SimpleGreetingizF A very simple greeting command that uses a few basic argument types. r~sgreetingscookies cookieplusrGN) r@rArBrCrDrrrrrrrFrGr)r&rrsAKs{{}- 3;;=/IJI ./Hr)rcF\rSrSrSrSrSr\R\5rSr g) TestLocatorizA A locator which implements a responder to the 'simple' command. c/Ulgr+ greetingsr/s r&r'TestLocator.__init__s r)cRURRX45 [US-S9$N cookieplusrr3rr%greetingcookies r&greetingResponderTestLocator.greetingResponder& x01vz**r)rN) r@rArBrCrDr'rrrrFrGr)r&rrs%+'001BCr)rc@\rSrSrSrSr\R\5rSrg)OverridingLocatorizB A locator which overrides the responder to the 'simple' command. cRURRX45 [US-S9$)zF Return a different cookieplus than L{TestLocator.greetingResponder}. rrrs r&r#OverridingLocator.greetingResponders( x01vz**r)rGN) r@rArBrCrDrrrrFrGr)r&r r s +'001BCr)r c\rSrSrSrSrg)InheritingLocatorizF This locator should inherit the responder from L{OverridingLocator}. rGNr`rGr)r&rrrr)rcV^\rSrSrSrU4SjrSr\R\5rSr U=r $)OverrideLocatorAMPic[RRU5 [5UlSUR0Ul/UlgNscustom)rrr'objectcustomResponder expectationsrr/s r&r'OverrideLocatorAMP.__init__s8 %x&(<(<=r)cb>XR;aURUnU$[TU] U5$)z2 Override the deprecated lookupFunction function. )rsuperlookupFunction)r%rmr __class__s r&r!OverrideLocatorAMP.lookupFunctions6 $$ $&&t,FM7)$/ /r)cRURRX45 [US-S9$rrrs r&r$OverrideLocatorAMP.greetingResponder rr))rrr) r@rArBrCr'rrrrrF __classcell__)rs@r&rrs& 0+'001BCr)rc<\rSrSrSrSrSrSrSrSr Sr S r g ) CommandLocatorTestsiz The CommandLocator should enable users to specify responders to commands as functions that take structured objects, annotated with metadata. c^^U"5nURS5nU"[R"SSS95nUU4SjnURU5$)z Check that a locator of type C{locatorClass} finds a responder for command named I{simple} and that the found responder answers with the C{expected} result to a C{SimpleGreeting<"ni hao", 5>} command. r~ni hao5rrcV>TRU[R"ST4-S95 g)Ns%drrUrrT)valuesexpectedr%s r&done6CommandLocatorTests._checkSimpleGreeting..done%s#   VSZZ5H;;N%O Pr))rrrWr)r% locatorClassr)rresponderCallablerr*s` ` r&_checkSimpleGreeting(CommandLocatorTests._checkSimpleGreetingsK.#33I>"377Id#KL Q!!$''r)c.UR[S5$)z A method on a L{CommandLocator} subclass decorated with a L{Command} subclass's L{responder} decorator should be returned from locateResponder, wrapped in logic to serialize and deserialize its arguments. )r.rr/s r&test_responderDecorator+CommandLocatorTests.test_responderDecorator*s((a88r)c.UR[S5$)z L{CommandLocator} subclasses can override a responder inherited from a base class by using the L{Command.responder} decorator to register a new responder method. )r.r r/s r&test_responderOverriding,CommandLocatorTests.test_responderOverriding3s (():A>>r)c.UR[S5$)zr Responder lookup follows the same rules as normal method lookup rules, particularly with respect to inheritance. r5)r.rr/s r&test_responderInheritance-CommandLocatorTests.test_responderInheritance;s (():A>>r)c6^^[5mTR[S[U4Sj5nTR TR U5 TR[S[U4Sj5nU"[ R"SSS95nU4SjnURU5$)a Subclasses which override locateResponder under its old name, lookupFunction, should have the override invoked instead. (This tests an AMP subclass, because in the version of the code that could invoke this deprecated code path, there was no L{CommandLocator}.) z-Override locateResponder, not lookupFunction.c&>TRS5$rrrsr&rKCommandLocatorTests.test_lookupFunctionDeprecatedOverride..NG++I6r)c&>TRS5$Nr~r=r>sr&rr?Vr@r)r#r$r%cN>TRU[R"SS95 gN8rr'r(r%s r&r*GCommandLocatorTests.test_lookupFunctionDeprecatedOverride..doneZ   VSZZ4%@ Ar)) r assertWarnsPendingDeprecationWarning__file__rUrrrWr)r%customResponderObjectnormalResponderObjectrr*rs` @r&%test_lookupFunctionDeprecatedOverride9CommandLocatorTests.test_lookupFunctionDeprecatedOverrideBs%& $ 0 0 % ;  6 !  002GH $ 0 0 % ;  6 !  'sww $'OP B!!$''r)c^^[5mTR[S[U4Sj5nU"[R "SSS95nU4SjnUR U5$)zx Invoking locateResponder under its old name, lookupFunction, should emit a deprecation warning, but do the same thing. z)Call locateResponder, not lookupFunction.c&>TRS5$rB)rr>sr&rICommandLocatorTests.test_lookupFunctionDeprecatedInvoke..isG**95r)r#r$r%cN>TRU[R"SS95 grDr'rFs r&r*ECommandLocatorTests.test_lookupFunctionDeprecatedInvoke..donemrHr))rrIrJrKrrWr)r%r-rr*rs` @r&#test_lookupFunctionDeprecatedInvoke7CommandLocatorTests.test_lookupFunctionDeprecatedInvoke_sY - ,, % 7  5   #377Id#KL B!!$''r)rGN) r@rArBrCrDr.r2r6r9rNrUrFrGr)r&r!r!s% ( 9??(:(r)r!sSuccess!sNo, really. Success.c\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrg)BinaryProtocolTestsiwz Tests for L{amp.BinaryBoxProtocol}. @ivar _boxSender: After C{startReceivingBoxes} is called, the L{IBoxSender} which was passed to it. c /Ul/Ulg)zb Keep track of all boxes received by this test in its capacity as an L{IBoxReceiver} implementor. N)rIr,r/s r&rBinaryProtocolTests.setUps   r)cXlg)zU Implement L{IBoxReceiver.startReceivingBoxes} to just remember the value passed in. N) _boxSenderr%rs r&r'BinaryProtocolTests.startReceivingBoxess !r)c:URRU5 g)z% A box was received by the protocol. NrLrXs r&rM"BinaryProtocolTests.ampBoxReceiveds #r)NcXlg)z4 Record the reason that we stopped receiving boxes. N) stopReasonr8s r&stopReceivingBoxes&BinaryProtocolTests.stopReceivingBoxess !r)cg)Nzno peerrGr/s r&rrBinaryProtocolTests.getPeerr)cg)Nzno hostrGr/s r&getHostBinaryProtocolTests.getHostrgr)cfURU[5 URRU5 gr+)rrr,r3rCs r&r.BinaryProtocolTests.writes$ dE* r)c[R"U5nUR"S5 URURU5 g)z When L{amp.BinaryBoxProtocol} is connected to a transport, it calls C{startReceivingBoxes} on its L{IBoxReceiver} with itself as the L{IBoxSender} parameter. N)rBinaryBoxProtocolmakeConnectionassertIsr\r%rs r&test_startReceivingBoxes,BinaryProtocolTests.test_startReceivingBoxess4 ((.% doox0r)c"SS5n[5n[R"U"55nUR"U5 UR UR 5S5 g)z The L{IBoxReceiver} which is started when L{amp.BinaryBoxProtocol} is connected to a transport can call C{sendBox} on the L{IBoxSender} passed to it before C{startReceivingBoxes} returns and have that box sent. c\rSrSrSrSrg)[BinaryProtocolTests.test_sendBoxInStartReceivingBoxes..SynchronouslySendingReceivericRUR[R"SS055 g)Nfoobar)rrrWr]s r&roBinaryProtocolTests.test_sendBoxInStartReceivingBoxes..SynchronouslySendingReceiver.startReceivingBoxesssww'789r)rGN)r@rArBrCrrFrGr)r&SynchronouslySendingReceiverrvs :r)r{s foobarN)rrrnrorUr\)r%r{r-rs r&!test_sendBoxInStartReceivingBoxes5BinaryProtocolTests.test_sendBoxInStartReceivingBoxessP : :$% (()E)GH * *,MNr)c[R"U5nURS5 URS5 URS5 URUR[R "SS9/5 g)z When a binary box protocol receives: * a key * a value * an empty string it should emit a box and send it to its boxReceiver. rMrr)rNN)rrnstringReceivedrUrIrTrXs r&test_receiveBoxStateMachine/BinaryProtocolTests.test_receiveBoxStateMachines^  ! !$ ' " "  cjjx&@%ABr)c[5n[R"U5nUR"U5 UR"S5 UR UR 5 g)zx L{amp.BinaryBoxProtocol} drops its connection if the length prefix for the first a key it receives is larger than 255. N)rrrnror4rh disconnectingr%r-rs r&$test_firstBoxFirstKeyExcessiveLength8BinaryProtocolTests.test_firstBoxFirstKeyExcessiveLengthsJ $% ((. *k*  //0r)c[5n[R"U5nUR"U5 UR"S5 UR UR 5 UR"S5 URUR 5 g)z L{amp.BinaryBoxProtocol} drops its connection if the length prefix for a subsequent key in the first box it receives is larger than 255. skvrNrrrnror4rjrrhrs r&)test_firstBoxSubsequentKeyExcessiveLength=BinaryProtocolTests.test_firstBoxSubsequentKeyExcessiveLengthsm $% ((. *34 001k*  //0r)c[5n[R"U5nUR"U5 UR"S5 UR UR 5 UR"S5 URUR 5 g)z L{amp.BinaryBoxProtocol} drops its connection if the length prefix for the first key in a subsequent box it receives is larger than 255. skvrNrrs r&)test_subsequentBoxFirstKeyExcessiveLength=BinaryProtocolTests.test_subsequentBoxFirstKeyExcessiveLengthsm $% ((. *;< 001k*  //0r)c[R"U5nUR"[55 UR"S5 UR "[ [R"S555 URR[R5 URURRR5 URURRR 5 UR#URRR5 UR#URRR$5 g)z If L{amp.BinaryBoxProtocol} disconnects because it received a key length prefix which was too large, the L{IBoxReceiver}'s C{stopReceivingBoxes} method is called with a L{TooLong} failure. rzsimulated connection doneN)rrnrorr4r:rr ConnectionDonerbtrapTooLongrhr\isKeyrjisLocal assertIsNonekeyNamerqs r&test_excessiveKeyFailure,BinaryProtocolTests.test_excessiveKeyFailures ((. 12k* E(()DE F  S[[) --334 ..667 $////556 $////778r)cB[5n[R"U5nUR"U5 UR"[ [ S555 URS[UR[ 555 URUR5 g)zf L{amp.BinaryBoxProtocol.unhandledError} logs the failure passed to it and disconnects its transport. Fake errorrN) rrrnrorrrrUrflushLoggedErrorsrhrrs r& test_unhandledErrorWithTransport4BinaryProtocolTests.test_unhandledErrorWithTransportst $% ((. * \(B CD C 6 6| DEF  //0r)cP[R"U5nUR"[55 UR"[ [ S555 UR"[ [S555 URS[UR[555 g)zh L{amp.BinaryBoxProtocol.unhandledError} completes without error when there is no associated transport. SimulatedrrN) rrnrorr:rrrrrUrrrqs r&#test_unhandledErrorWithoutTransport7BinaryProtocolTests.test_unhandledErrorWithoutTransportsu ((. 12 +(> ?@ \(B CD C 6 6| DEFr)c[R"U5nUR[R"SSS.5R 55 UR UR [R"SSS.5/5 g)zy When a binary box protocol receives the serialized form of an AMP box, it should emit a similar box to its boxReceiver. valueTests anotherValue)testKeys anotherKeyN)rrnr4rWrWrUrIrXs r&test_receiveBoxData'BinaryProtocolTests.test_receiveBoxDatasf  ! !$ '  GG)/J ik  JJ WW,O P Q r)c~SnSU-n[5n[R"U5nUR"U5 UR"[R "SU05R 55 URUR[R "SU05/5 URUR5 g)zh An L{amp.BinaryBoxProtocol} can receive serialized AMP boxes with values of up to (2 ** 16 - 1) bytes. irkN) rrrnror4rWrWrUrIrjr)r%rr\r-rs r&test_receiveLongerBoxData-BinaryProtocolTests.test_receiveLongerBoxData.s v #% ((. *cggsEl3==?@ cggsEl&;%<= 001r)c:[R"U5nURU5 [R"SSS.5nURU5 UR U5 UR SR UR5UR55 g)zk When a binary box protocol sends a box, it should emit the serialized bytes of that box to its transport. rrM)rssomeDatar)N) rrnrorWrrUjoinr,rW)r%r=aBoxs r& test_sendBox BinaryProtocolTests.test_sendBox<sr  ! !$ ' wwLxHI  $ $)),dnn.>?r)c[R"U5nURU5 [[ 55nUR U5 UR URU5 g)zy When a binary box protocol loses its connection, it should notify its box receiver that it has stopped receiving boxes. N)rrnrorrr:rprb)r%r=connectionFailures r&#test_connectionLostStopSendingBoxes7BinaryProtocolTests.test_connectionLostStopSendingBoxesHsQ  ! !$ ' #LN3 *+ doo'89r)c^^^[SS5mUm"UUU4SjS5n[R"U"55m[R"SSS.5nTR U5 UR 5S-nTR U5 URTRU5 URS RTR5S5 URURS/5 TR S 5 URS RTR5S 5 UR[RTRU5 g) z L{BinaryBoxProtocol} has the capacity to switch to a different protocol on a box boundary. When a protocol is in the process of switching, it cannot receive traffic. N outgoing datac0>\rSrSrSrSrUUU4SjrSrg)@BinaryProtocolTests.test_protocolSwitch..SwitchyReceiveri\Fcgr+rGr]s r&rTBinaryProtocolTests.test_protocolSwitch..SwitchyReceiver.startReceivingBoxes_sr)c>TRURS5 SUlTR5 TRT5 g)NzShould only receive one box!T)rjswitched_lockForSwitch _switchTo)r%rYr= otherProtors r&rMOBinaryProtocolTests.test_protocolSwitch..SwitchyReceiver.ampBoxReceivedbs7  0NO $   " J'r))rN)r@rArBrCrrrMrF)r=rrsr&SwitchyReceiverr\sH  ( (r)rslotsdata)sincludesofsHello, world!r)s more datasHello, world!more data)rrrnrWrorWr4rpr-rUrr,r^ProtocolSwitchedr)r%r anyOldBoxmoreThanOneBoxr=rrs @@@r&test_protocolSwitch'BinaryProtocolTests.test_protocolSwitchSs  t%56  ( (  ! !/"3 4GGAB  #,,.1II ~& j**D1 *//24LM %5$67 |$ *//24UV #.. 9Er)c[R"U5nURU5 [SS5nUR U5 UR UR /5 g)z After switching to a different protocol, if no extra bytes beyond the switch box were delivered, an empty string is not passed to the switched protocol's C{dataReceived} method. Nr))rrnrorrrUr,)r%r=rs r&test_protocolSwitchEmptyBuffer2BinaryProtocolTests.test_protocolSwitchEmptyBufferwsN  ! !$ ' tS)  J "-r)cZ[R"U5nURU5 [R"SS05nUR 5 UR [R URU5 UR5 URU5 URSRUR5UR55 UR 5 [SS5nURU5 UR [R UR5 g)a In order to make sure the protocol never gets any invalid data sent into the middle of a box, it must be locked for switching before it is switched. It can only be unlocked if the switch failed, and attempting to send a box while it is locked should raise an exception. ssomerr)Nr)rrnrorWrr^rr_unlockFromSwitchrUrr,rWrr)r%r= sampleBoxrs r& test_protocolSwitchInvalidStates4BinaryProtocolTests.test_protocolSwitchInvalidStatess  ! !$ ' GGWg./   #.. 9E  ) $)),i.A.A.CD t%56  J #..0C0CDr)cT"SS[R5nU"5n[R"U5nUR U5 UR 5 UR U5 [[55nURU5 URURU5 g)zW When the protocol is switched, it should notify its nested protocol of disconnection. c\rSrSrSrSrSrg)DBinaryProtocolTests.test_protocolSwitchLoseConnection..LoseriNcXlgr+r9r8s r&r:SBinaryProtocolTests.test_protocolSwitchLoseConnection..Loser.connectionLost$ r)r)r@rArBrCr9r:rFrGr)r&Loserr F %r)rN) rProtocolrrnrorrrrr:rUr9)r%rconnectionLoserr=rs r&!test_protocolSwitchLoseConnection5BinaryProtocolTests.test_protocolSwitchLoseConnections  %H%% %  '  ! !$ '   O$#LN3 *+ //1BCr)c`"SS5n[R"U5n[R"5nU"5nUR U5 UR 5 UR X45 [[55nURU5 URURU5 g)zf When the protocol is switched, it should notify its nested client protocol factory of disconnection. c\rSrSrSrSrSrg)PBinaryProtocolTests.test_protocolSwitchLoseClientConnection..ClientLoseriNcX lgr+rrs r&clientConnectionLosteBinaryProtocolTests.test_protocolSwitchLoseClientConnection..ClientLoser.clientConnectionLostrr)r)r@rArBrCr9rrFrGr)r& ClientLoserrrr)rN) rrnrrrorrrrr:rUr9)r%rr=r clientLoserrs r&'test_protocolSwitchLoseClientConnection;BinaryProtocolTests.test_protocolSwitchLoseClientConnections  % %  ! !$ '"++-!m    O1#LN3 *+ ++->?r))r\rIr,rb) r@rArBrCrDrrrMrbrcrrrir.rrr|rrrrrrrrrrrrrrrrrFrGr)r&rXrXws! J!1O" C 1 1 19$ 1 G 2 @ :"FH .E(D*@r)rXc \rSrSrSrSrSrSrSrSr Sr S r S r S r S rS r\"\S5S5rSrSrSrSrSrSrSrSrSrSrSrSrSrSr Sr!Sr"S r#\$S!S!4S"jr%S#r&\$4S$jr'S%r(S&r)S'r*S(r+S)r,S*r-g+),AMPTestsic[R[R4[R[R4[R [R 4[R [R4[R[R4[R[R4[R [R44H,upURURU5USUS35 M. g)zf The classes in the amp module ought to implement the interfaces that are declared for their benefit. z does not implements()N) r IBoxSenderrn IBoxReceiverrIResponderLocatorCommandLocatorSimpleStringLocatorrrh implementedBy)r% interfaceimplementations r&test_interfaceDeclarations#AMPTests.test_interfaceDeclarationss ^^S22 3   s00 1  " "C$6$6 7  " "C$;$; < ^^SWW %   sww '  " "CGG ,* %I OO''7!""7 {!D * r)c[5upn/nSnURU5RUR5 UR 5 UR USSU5 g)zp Verify that a simple command can be sent and its response received with the simple low-level string-based API. rrrMNr:rSrr3rrUr%rrurLHELLOs r&test_helloWorldAMPTests.test_helloWorldV +,a  E&&qxx0   1h/r)c[5upn/nSnURU5RUR5 UR 5 UR USSU5 g)ze Verify that mixed-case, underscored and dashed arguments are mapped to their python names properly. rrrMNrrs r&test_wireFormatRoundTrip!AMPTests.test_wireFormatRoundTriprr)c[[[S9upn/nSnSnURXV5RUR5 UR 5 UR USSU5 UR USSU5 g)z; Verify that unicode arguments can be encoded and decoded. r;r<ruworሴldrrOrN)r:rrrr3rrU)r%rrurrr HELLO_UNICODEs r&test_helloWorldUnicodeAMPTests.test_helloWorldUnicodes+66 a %  50< #r)c[5upn/nSnURS5RU5RUR5 UR 5 UR UR5S5 SnURU5RUR5 UR 5 UR USSU5 g)zz Verify that unknown commands using low-level APIs will be rejected with an error, but will NOT terminate the connection. cBUR[R5 gz" You can't propagate the error... OKrrUnhandledCommandes r& clearAndAdd4AMPTests.test_unknownCommandLow..clearAndAdd FF3'' (r)rr rrrMN) r:rPrrr3rrUpoprSr%rrurrrrs r&test_unknownCommandLowAMPTests.test_unknownCommandLows +,a   6"--k:FFqxxP   $' E&&qxx0   1h/r)c[5upn/nSnUR[5RU5R UR 5 UR 5 URUR5S5 SnURU5R UR 5 UR 5 URUSSU5 g)z{ Verify that unknown commands using high-level APIs will be rejected with an error, but will NOT terminate the connection. cBUR[R5 gr r rs r&r5AMPTests.test_unknownCommandHigh..clearAndAdd'rr)r rrrMN) r:rrrrr3rrUrrSrs r&test_unknownCommandHigh AMPTests.test_unknownCommandHighs +,a   S$$[1==ahhG   $' E&&qxx0   1h/r)c@/n[5R[R"[R S95R UR5 USR[R5 URS[USR55 g)z It can be very confusing if you write some code which responds to a command, but gets the return value wrong. Most commonly you end up returning None instead of a dictionary. Verify that if that happens, the framework logs a useful error. )rrNoneN) rdispatchCommandrrTrrrr3rBadLocalReturn failUnlessInr r\)r%rs r&test_brokenReturnValueAMPTests.test_brokenReturnValue6sm &(88 JJ 8 8 9 *QXX  ! #$$% &$qtzz"23r)c[[[S9upn/nSnUR[USS9R UR 5 UR 5 URUSSU5 g)zi Verify that unknown arguments are ignored, and not passed to a Python function which can't accept them. rrsI'm not in the book!)rObonusrrON)r:rrrrr3rrUrs r&test_unknownArgumentAMPTests.test_unknownArgumentEsl +66 a  u,C  +ahh    1g.r)c UR[[[R"S555[ 5 UR[[[R "555[ 5 UR[[[R"555[ 5 URS[[R"555 g)zC Verify that the various Box objects repr properly, for debugging. r=rTN) rUrVr r _SwitchBoxrErrTassertInr/s r&test_simpleReprsAMPTests.test_simpleReprsWs d3>>##678#> d3;;=12C8 d3::<0137 hSZZ\ 23r)c[SS5n[R"5nXlUR [ U5SUR [U54-5 g)zA Verify that L{AMP} objects output their innerProtocol when set. Nrz# at 0x%x>)rrr innerProtocolrUr r$id)r%rr=s r&test_innerProtocolInRepr!AMPTests.test_innerProtocolInRepr`sMt%56 GGI$  G 1Z5J5JBqE4R R r)c[R"5nUR[U5S[ U5SS35 g)zP Verify that L{AMP} objects do not output 'inner' when no innerProtocol is set. z N)rrrUr r/rXs r&test_innerProtocolNotInRepr$AMPTests.test_innerProtocolNotInReprms2 GGI aJr!uQiq"9:r)SSL not availableczUR[[[R"555[ 5 g)z+ L{amp._TLSBox.__repr__} returns a string. N)rUrVr r_TLSBoxrEr/s r&test_simpleSSLReprAMPTests.test_simpleSSLReprus$ d3;;=12C8r)c[5upnSnUR"[RURS40US0D6nUR UR 5 UR UR5 URUR5 URURURS55 UR[[U55[!U55 URS[!U55 g)zT Verify that a key that is too long will immediately raise a synchronous exception. HHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHHsHelloshiasciirSN)r:r^rrrPrhrrrrrUr\encoder*rErr r%rrurrtls r&test_keyTooLongAMPTests.test_keyTooLong|s +,a    s{{A,>,> WQPUJ W !  # "**% 188G#45 c#a&k48, eT"X&r)c@[5upnSS-nUR[RURU5nUR 5 UR UR5 URUR5 URURS5 URURU5 UR[[!U55[#U55 URS[#U55 URS[#U55 g)z[ Verify that attempting to send value longer than 64k will immediately raise an exception. HirMr\rON)r:r^rrrSrrjrrhrrUrfailUnlessIdenticalr\r*rErr r?s r&test_valueTooLongAMPTests.test_valueTooLongs +,a J    s{{AKK ;   "  # X.   1- c#a&k48, gtBx( gtBx(r)c[[[S9upn/nSnURU5RUR5 UR 5 UR USSU5 g)zk Verify that a simple command can be sent and its response received with the high-level value parsing API. rrrrON)r:rrSrr3rrUrs r&test_helloWorldCommandAMPTests.test_helloWorldCommands` +66 a  E&&qxx0   1g.r)c*/n[[[S9up#nSnURU5RUR5 UR 5 USR [5 UR[USR5S5 g)z Verify that if a known error type is raised and handled, it will be properly relayed to the other end of the connection and translated into an exception, and no error will be logged. rfuck yourrN) r:rrSrr3rrr]rUrEr\r%rrrurrs r&test_helloErrorHandling AMPTests.test_helloErrorHandlingsv *66 a E%%ahh/   ! $% QqTZZ*<=r)c/n[[[S9up#nSnURU5RUR5 UR 5 UR 5R[5 URU5RUR5 UR 5 UR 5R[R5 g)z Verify that if a known, fatal error type is raised and handled, it will be properly relayed to the other end of the connection and translated into an exception, no error will be logged, and the connection will be terminated. rrN) r:rrSrr3rrrrcr rrMs r&test_helloFatalErrorHandling%AMPTests.test_helloFatalErrorHandlings *66 a E%%ahh/    [! E%%ahh/    U))*r)c /n[[[S9up#n[nURU5R UR 5 UR 5 UR5nUR[R5 URU5R UR 5 UR5nUR[R5 URUR[55 g)z Verify that if an unknown error type is raised, it will be relayed to the other end of the connection and translated into an exception, it will be logged, and then the connection will be dropped. rN)r:rrrSrr3rrrrUnknownRemoteErrorr rrhrr)r%rrrurrurecls r&test_helloNoErrorHandling"AMPTests.test_helloNoErrorHandlings *66 a( E%%ahh/  eeg ''( E%%ahh/ UUW $$% ../HIJr)c[[[S9upn/nUR[5R UR 5 UR 5 URU/5 URR5 UR 5 UR5R[R5 URR05 UR$)zs Verify that a command that does not get answered until after the connection terminates will not cause any errors. r)r:rrrrr3rrUr-loseConnectionrrr rr r7r%rrurrs r&test_lateAnswerAMPTests.test_lateAnswers +66 a  [!,,QXX6   B ""$    U))* 2yyr)c[[[S9upnSnUR[US9 UR 5 UR UR 5 g)z7 Verify that a command that requires no answer is run. rrrNN)r:rrrrrhr)r%rrurrs r&test_requiresNoAnswerAMPTests.test_requiresNoAnswersH+66 a ]% 0    "r)c/n[[[S9up#nSnUR[US9 UR 5 UR UR [R55 SnUR[US9RUR5 UR 5 UR5R[R5 UR!UR"5 g)zM Verify that commands sent after a failed no-answer request do not complete. rrLrNrN)r:rrrrrhrrRemoteAmpErrorr|rr3rrr rrjrrMs r&test_requiresNoAnswerFail"AMPTests.test_requiresNoAnswerFails *66 a ]% 0   ..s/A/ABC U% (33AHH=    U))* #r)c[[[S9upnURR5 UR 5 UR [ SS9nURUS5 g)z^ No-answer commands sent after the connection has been torn down do not return a L{Deferred}. rrrNN)r:rr-rZrrrrp)r%rrurrs r&test_requiresNoAnswerAfterFail'AMPTests.test_requiresNoAnswerAfterFailsS +66 a ""$  m:> fd#r)c[[[S9upnUR[SS9 UR 5 UR [R5nUR[U5S5 g)z Verify that responders of requiresAnswer=False commands have to return a dictionary anyway. (requiresAnswer is a hint from the _client_ - the server may be called upon to answer commands in any case, if the client wants to know when they complete.) rrMrNrN) r:r/rrrrrrr rUr)r%rrurles r&test_noAnswerResponderBadAnswer(AMPTests.test_noAnswerResponderBadAnswer)s]+26 a ]( 3   # #C$6$6 7 R!$r)c[[[S9upn/nUR[SS9R UR 5 UR5 UR[U5S5 URU[SSS9/5 g)z Verify that responders with requiresAnswer=False will actually respond if the client sets requiresAnswer=True. In other words, verify that requiresAnswer is a hint honored only by the client. rsHello!rNrsHello!-noanswerNr) r:r5rrr|rr3rrUrrr[s r&$test_noAnswerResponderAskedForAnswer-AMPTests.test_noAnswerResponderAskedForAnswer;sy +/6 a  U) ,88B   Q#  -T:; r)c[[[S9upn/nUR[SS9R UR 5 UR 5 UR5RS5nURUSS0/S-5 g)z> Test encoding of an argument that uses the AmpList encoding. r )rrrrN) r:rrrrr3rrgetrU)r%rrurrr(s r&test_ampListCommandAMPTests.test_ampListCommandMsu+66 a  WR (44QXX>  V$ 3(b1r)c[[[S9upn/nUR[SS9R UR 5 UR 5 UR5RS5nURUS5 g)z} Sending a command with an omitted AmpList argument that is designated as optional does not raise an InvalidSignature error. rplease)rrrN r:rrrrr3rrrqrUr%rrurrrs r&test_optionalAmpListOmitted$AMPTests.test_optionalAmpListOmitted[sk +66 a  \X 6BB188L  557;;z* >2r)c[[[S9upn/nUR[SSS0/S9R UR 5 UR 5 UR5RS5nURUS5 g) zF Sanity check that optional AmpList arguments are processed normally. rrurmfoo)rrrz foo acceptedNrvrws r&test_optionalAmpListPresent$AMPTests.test_optionalAmpListPresentjsy+66 a  HVUO3D  +ahh   557;;z* >2r)cLUR[R[5 g)zf Verify that if we pass an invalid argument list (omitting an argument), an exception will be raised. N)r^rInvalidSignaturer|r/s r&test_failEarlyOnArgSending#AMPTests.test_failEarlyOnArgSendingzs #..6r)cX^^^^[R"5n[U5m[R"5n[U5m[U4SjU4SjS9ump4UU4SjnTR 5R U5 UR 5 TRTR5 g)z As a debugging aid, a protocol system should raise a L{ProtocolSwitched} exception when asked to switch a protocol that is already switched. c>T$r+rG serverProtosr&r4AMPTests.test_doubleProtocolSwitch.. r)c>T$r+rG clientProtosr&rrr)rch>TR[RTR5 STlgNT)r^rrr testSucceeded)rrr%s r&r4AMPTests.test_doubleProtocolSwitch..switcheds'   c22A4J4J K!%D r)N) r r rr:rrrrhr) r%serverDeferredclientDeferredrurrrrrs ` @@@r&test_doubleProtocolSwitch"AMPTests.test_doubleProtocolSwitchs~ )4^D )4^D *+9L 1 &  ,,X6   **+r)Fc^^ ^ ^ ^ ^STl[R"5m U"T 5m[R"5m U"T 5m [U4SjU 4SjS9upEnU(a0/nUR [ 5R UR5 UR5nU(a+TR[RURS5 U4Sjm U U U 4Sjn URU 5 UR5 TRb5TRR!TR"5 UR5 U(acU(a1UR$R'[R("S S 55 OUR$R!05 UR5 UR*R-5 UR5 TR/TR5 g) zk Verify that it is possible to switch to another protocol mid-connection and send data to it successfully. Fc>T$r+rGrsr&r.AMPTests.test_protocolSwitch..rr)c>T$r+rGrsr&rrrr)rrc>Uuupup4TRU5 TRU5 TRSRU5[5 TRSRU5[5 STlg)Nr)T)rhrUrrrr)info serverSuccess serverData clientSuccess clientDatar%s r& cbConnsLost1AMPTests.test_protocolSwitch..cbConnsLostsgIM F (m*E= OOM * OOM *   SXXj13E F   SXXj13E F!%D r)cR>[R"TT/5RT5$r+)r DeferredListr)rnrrrs r&cbSwitch.AMPTests.test_protocolSwitch..cbSwitchs)%%~~&FGSS r)NsSPURIOUSz,Here's some traffic in the form of an error.)rr r r:rrrr3rr^rrrSrrr(r7r,r errbackrbr-rZrh)r%switcherspuriousTraffic spuriousErrorrrurwfdrswitchDeferredrrrrrrs` @@@@@r&rAMPTests.test_protocolSwitchsg#)~. )~. *+9L a D LL % 0 0 =//1    c22AKK J &  ""8,   ! ! -  " " + +K,G,G H GGI  !!&&#%S  ""2& GGI ""$   **+r)c(UR[S9$)zt Verify that protocol-switching even works if the value returned from the command that does the switch is deferred. )r)rr*r/s r&test_protocolSwitchDeferred$AMPTests.test_protocolSwitchDeferreds ''1Q'RRr)c^^^ SUl[R"5nU"U5m [R"5nU"U5m[U 4SjU4SjS9upEn/nUR SS9R UR 5 UR5 UR5R[5 URUR5 URS5RUR 5 UR5 URUR5SS5 g ) zu Verify that if we try to switch protocols and it fails, the connection stays up and we can go back to speaking AMP. Fc>T$r+rGrsr&r2AMPTests.test_protocolSwitchFail..rr)c>T$r+rGrsr&rrrr)rT)rrrON)rr r r:rrr3rrrrfrjrSrrU) r%rrrrrurrrrs @@r&test_protocolSwitchFail AMPTests.test_protocolSwitchFails #)~. )~. *+9L a  D)44QXX>    _% ++, H))!((3   )84r)c URSS9$)z[ Verify that attempts to send traffic after a switch will not corrupt the nested protocol. T)rrr/s r&test_trafficAfterSwitch AMPTests.test_trafficAfterSwitchs '''==r)c"URSSS9$)zP Returning an error after a protocol switch should record the underlying error. T)rrrr/s r&test_errorAfterSwitchAMPTests.test_errorAfterSwitchs ''D'QQr)cd[[[S9upn/nSnSnURU5RUR5 UR 5 UR UR5SU5 UR[5RUR5 UR 5 UR UR5SU5 URU5RUR5 UR5R[R5 g)z\ Verify that commands with a responseType of QuitBox will in fact terminate the connection. rrrrOrN)r:rrSrr3rrUrrrrrr r)r%rrurrrGOODBYEs r&test_quitBoxQuitsAMPTests.test_quitBoxQuitss +66 a  E&&qxx0   )51 W))!((3   +W5 E%%ahh/  U))*r)c[5upn/nURUlUR[SSSSS9 UR 5 UR [U5S5 S[R4SS S S 4H)upVUR US RU5U5 M+ US RS 5 UR US 05 g)zh Verify that the command dictionaries for a callRemoteN look correct after being serialized and parsed. hello testmixed case arg testryrOrrrr_command)rMr)rr)rr)rrr_askN) r:r3rMrr|rrUrrr)r%rrurrrrvs r&test_basicLiteralEmitAMPTests.test_basicLiteralEmits +,a 88 ,     Q# %++ , % 2  %  DA   QrUYYq\1 -  " ' 2#r)c^/m"U4SjS[R5n[US9up#nUR[SSSSS9R TR 5 UR5 UR[T5S 5 URTS S [SSSSURR5S S S 945 URTS[S SS95 g )z Verify that a call similar to basicLiteralEmit's is handled properly with high-level quoting and passing to Python methods, and that argument names are correctly handled. cD>\rSrSrU4Sjr\R \5 Srg):AMPTests.test_basicStructuredEmit..StructuredHelloi<c:>TRX45 [SS9$)NaaarN)r3r)r%r=rrs r&h.StructuredHello.h=s! &))r)rGN)r@rArBrCrr|rrF)rsr&StructuredHellor<s * OOA r)r)r;rrrrrrrGN)rOrrrrrrrr)rrO) rrr:rr|rr3rrUrrr-rr)r%rrrurrs @r&test_basicStructuredEmit!AMPTests.test_basicStructuredEmit4s  cgg +Ga ,  +ahh    Q#  aD'4!#',,.!   $ 1t$f=>r))rN).r@rArBrCrrrrrrrr"r&r+r0r4rskipSSLr9rArFrIrNrQrWr\r_rcrfrjrmrrrxr|rrrrrrrrrrrrFrGr)r&rrs& 0 07 0.0. 4/$4  ; G()9*9 ')" />"+(K,( #$( $%$ $ 2 33 7,00 ;,zS0N52>R+,$8+?r)rc\rSrSrSrSrg)!PretendRemoteCertificateAuthorityibcgrrGr/s r&checkIsPretendRemote6PretendRemoteCertificateAuthority.checkIsPretendRemotecr&r)rGN)r@rArBrCrrFrGr)r&rrbsr)rc$\rSrSrSrSrSrSrg) IOSimCertigrcU$r+rG)r%rs r&optionsIOSimCert.optionsjs r)c:XLdeU=RS- slg)z This isn't a real certificate, and wouldn't work on a real socket, but iosim specifies a different API so that we don't have to do any crypto math to demonstrate that the right functions get called in the right places. rT verifyCountr% otherCerts r& iosimVerifyIOSimCert.iosimVerifyms$    Ar)rGN)r@rArBrCrrrrFrGr)r&rrgsK r)rc\rSrSrSrSrg)OKCertiyc4UR5(deU$r+)r)r%rs r&rOKCert.optionszs%%'''' r)rGN)r@rArBrCrrFrGr)r&rrysr)rc\rSrSrSrSrg) GrumpyCertic.U=RS- slg)NrFrrs r&rGrumpyCert.iosimVerifys Ar)rGN)r@rArBrCrrFrGr)r&rrsr)rc \rSrSrSrSrSrg) DroppyCerticXlgr+toDrop)r%rs r&r'DroppyCert.__init__s r)cbU=RS- slURR5 g)NrT)rrrZrs r&rDroppyCert.iosimVerifys& A ""$r)rN)r@rArBrCr'rrFrGr)r&rrs r)rcZ\rSrSrSrSrSr\RR\5 Sr g)SecurableProtoiNc[5/$r+)rr/s r& verifyFactorySecurableProto.verifyFactorys1344r)cTUR5nUR5n[XS9$)Ntls_localCertificatetls_verifyAuthorities) certFactoryrr)r%certverifys r& getTLSVarsSecurableProto.getTLSVarss)!##%LLr)rG) r@rArBrCrrrrStartTLSrrFrGr)r&rrs&G5M LL:&r)rr6z2This test case requires SSL support in the reactorc,\rSrSrSrSrSrSrSrg)TLSTestsic^[[[S9upn[5mU4SjUlUR [ R T[5/S9 /nUR [5RUR5 UR5 URTRS5 /nUR [5RUR5 UR5 URUSSS05 g) zm Verify that starting TLS and succeeding at handshaking sends all the notifications to all the right places. rc>T$r+rGokcsr&r+TLSTests.test_startingTLS..#r)rrrrTN)r:rrrrrrrrrr3rrUr)r%clisvrrrr s @r&test_startingTLSTLSTests.test_startingTLSs /&N !h%  LL!$#D#F"G    {#//9   !,  {#//9   1$/0r)c\^[[[S9upn[5mU4SjUlUR [ R T[5/S9 UR5 SUl UR[ RUR[ R T[5/S9 g)zb Verify that the protocol will complain if we attempt to renegotiate TLS, which we don't support. rc>T$r+rGrsr&r1TLSTests.test_startTooManyTimes..r r)rTN) r:rrrrrrrrnoPeerCertificater^ OnlyOneTLSr%r r rr s @r&test_startTooManyTimesTLSTests.test_startTooManyTimess /&N !h%  LL!$#D#F"G   $  NN NN LL!$#D#F"G  r)cx^[5m[[[S9upnU4SjUlUR [ R TS9 UR5 URTRS5 UR [5nUR5 URU[R5 g)z Verify that starting TLS and failing on both sides at handshaking sends notifications to all the right places and terminates the connection. rc>T$r+rG)badCertsr&r1TLSTests.test_negotiationFailed..s'r)rrN)rr:rrrrrrrUrr assertFailurerNativeOpenSSLError)r%r r rrlrs @r&test_negotiationFailedTLSTests.test_negotiationFaileds ,.&N !* s||'B   ,,a0 NN; '   1e667r)c^[[[S9upn[UR5mU4SjUlUR [ RTS9 UR5 URTRS5 UR [5nUR5 URU[R5 g)zn Verify that starting TLS and failing by way of a lost connection notices that it is probably an SSL problem. rc>T$r+rG) droppyCertsr&r:TLSTests.test_negotiationFailedByClosing..s*r)rrN)r:rrr-rrrrrrUrrrr PeerVerifyError)r%r r rrlr#s @r&test_negotiationFailedByClosing(TLSTests.test_negotiationFailedByClosings /&N !  . , s||*E   //3 NN; '   1e334r)rGN) r@rArBrCrrrr&rFrGr)r&rrs1: 68,5r)rc0\rSrSrSrSrSrSrSrSr g) TLSNotAvailableTestsizH Tests what happened when ssl is not available in current installation. cD[RUlS[lg)z Disable ssl in amp. N)rrr/s r&rTLSNotAvailableTests.setUp s77r)c.UR[lg)z Restore ssl module. N)rrr/s r&tearDownTLSNotAvailableTests.tearDowns((r)c^[[[S9upn[5mU4SjUlUR UR [ RT[5/S9[5$)zO Check that callRemote raises an exception when called with a L{amp.StartTLS}. rc>T$r+rGrsr&r;TLSNotAvailableTests.test_callRemoteError..$r r)r) r:rrrrrrrrrrs @r&test_callRemoteError)TLSNotAvailableTests.test_callRemoteErrorsd /&N !h%!! NN %('H'J&K      r)c*^[5n[5mU4SjUl[R"5nSUS'SUS'/nUR UlUR[55 URU5 URUSSSS./5 g ) zd When a client with SSL enabled talks to a server without SSL, it should return a meaningful error. c>T$r+rGrsr&r@TLSNotAvailableTests.test_messageReceivedError..6r r)sStartTLSrrrs TLS_ERRORsTLS not available)rrrN) rrrrrWr3rrorrMrU)r%r rYrIr s @r&test_messageReceivedError.TLSNotAvailableTests.test_messageReceivedError/s h%ggi&KG ll  ?,- 3  %1#+?  r)rN) r@rArBrCrDrr-r2r7rFrGr)r&r)r)s  * r)r)c\rSrSrSrSrg)InheritedErroriJz* This error is used to check inheritance. rGNr`rGr)r&r:r:Jrr)r:c\rSrSrSrSrg)OtherInheritedErroriPz4 This is a distinct error for checking inheritance. rGNr`rGr)r&r<r<Prr)r<cB\rSrSr%Sr\S0r\\\ \ \ 4\ S'Sr g) BaseCommandiVz2 This provides a command that will be subclassed. sINHERITED_ERRORrrGN)r@rArBrCrDr:rrrrrrrrFrGr)r&r>r>Vs0 *6FHT$y/501 2r)r>c\rSrSrSrSrg)InheritedCommandi`zT This is a command which subclasses another command but does not override anything. rGNr`rGr)r&r@r@`sr)r@cj\rSrSr%SrS\R "54/r\S0r \ \ \ \ \4\S'Srg)AddErrorsCommandigzQ This is a command which subclasses another command but adds errors to the list. sothersOTHER_INHERITED_ERRORrrGN)r@rArBrCrDrrrr<rrrrrrrrFrGr)r&rBrBgsC CKKM*+I56FHT$y/501 2r)rBc@\rSrSrSrSr\R\5 Srg)NormalCommandProtocolisz This is a protocol which responds to L{BaseCommand}, and is used to test that inheritance does not interfere with the normal handling of errors. c[5er+r:r/s r&respNormalCommandProtocol.respy r)rGN) r@rArBrCrDrGr>rrFrGr)r&rDrDss $r)rDc@\rSrSrSrSr\R\5 Srg)InheritedCommandProtocoliz This is a protocol which responds to L{InheritedCommand}, and is used to test that inherited commands inherit their bases' errors if they do not respond to any of their own. c[5er+rFr/s r&rGInheritedCommandProtocol.resprIr)rGN) r@rArBrCrDrGr@rrFrGr)r&rKrKs t$r)rKc@\rSrSrSrSr\R\5 Srg)AddedCommandProtocoliz This is a protocol which responds to L{AddErrorsCommand}, and is used to test that inherited commands can add their own new types of errors, but still respond in the same way to their parents types of errors. c8U(a [5e[5er+)r<r:)r%others r&rGAddedCommandProtocol.resps %' ' " "r)rGN) r@rArBrCrDrGrBrrFrGr)r&rOrOs # t$r)rOc6\rSrSrSrSrSrSrSrSr Sr g ) CommandInheritanceTestsizE These tests verify that commands inherit error conditions properly. c [X"S9upVnUR"U40UD6nURX5n UR5 U $)zf Check that the appropriate kind of error is raised when a given command is sent to a given protocol. r)r:rfailUnlessFailurer) r%rrncmdr>rrurrld2s r& errorCheck"CommandInheritanceTests.errorChecksC +uPa LL # #  # #A +   r)c@UR[[[5$)z` Verify that errors specified in a superclass are respected normally even if it has subclasses. )rYr:rDr>r/s r&test_basicErrorPropagation2CommandInheritanceTests.test_basicErrorPropagations ~/DkRRr)c@UR[[[5$)zX Verify that errors specified in a superclass command are propagated to its subclasses. )rYr:rKr@r/s r&test_inheritedErrorPropagation6CommandInheritanceTests.test_inheritedErrorPropagations  46F  r)c>UR[[[SS9$)z Verify that new errors specified in a subclass of an existing command are honored even if the superclass defines some errors. TrQ)rYr<rOrBr/s r&test_inheritedErrorAddition3CommandInheritanceTests.test_inheritedErrorAdditions%  !57Gt  r)c>UR[[[SS9$)zv Verify that errors specified in a command's superclass are respected even if that command defines new errors itself. Frb)rYr:rOrBr/s r&test_additionWithOriginalError6CommandInheritanceTests.test_additionWithOriginalErrors%  02B%  r)rGN) r@rArBrCrDrYr\r_rcrfrFrGr)r&rTrTs! S   r)rTcUR[R[R5 U?UR U5 gr+)rr ConnectionLostrr:)rrns r& _loseAndPassrjs0HHU ! !5#7#78  r)c$\rSrSrSrSrSrSrg) LiveFireBaseiz, Utility for connected reactor-using tests. c^SSKJn [R"5TlTR TRl[R "5TlTRTRl[R"5TRl [R"5TRl UR"STR5Tl TRTRR5 UR "STRR#5R$TR5TlTRTR&R(5 U4Sjn[R*"TRRTRR/5nUR-U5$)z2 Create an amp server and connect a client to it. r)rz 127.0.0.1cr>TRRTlTRRTlgr+) clientFactoryrr  serverFactoryr )rlstr%s r& getProtos%LiveFireBase.setUp..getProtoss)))22DH))22DHr))twisted.internetrr ServerFactoryrpr ClientFactoryrorr r r listenTCP serverPort addCleanup stopListening connectTCPriport clientConn disconnectrr)r%rrrdls` r&rLiveFireBase.setUps9 -%335&*&6&6#%335&*&6&6#$)NN$4!$)NN$4!!++At/A/AB 556!,, 002779K9K  223 3  !3!3!:!:D. su{{?U?Ur)) r r r-r r rrjrr:rZr3 gatherResults)r%rconnrls r&r-LiveFireBase.tearDowns HHdhh&D~~)NN$// dC&'ii#--/ '""1%001UVVr))r r}rorprxr N)r@rArBrCrDrr-rFrGr)r&rlrls)4 Wr)rlc|SSKnURRUS-5 URR5 g)Nr )sysstdoutr.r)rrs r&showr s+JJQXJJr)cSSKJn URSS9nURR 5nUR U5nUR XSS5nURU5nU$)Nrrshared)CNcgrrG)dns r&r tempSelfSigned.. sr)i)rtrDNKeyPairgeneratecertificateRequestsignCertificateRequestnewCertificate)rsharedDNrScrsscrdrs r&tempSelfSignedr s`$vvv"H ++   C   )B  & &x_g NE   e $D Kr)c"\rSrSr\r\rSrSrg)LiveFireTLSTestsi c^^[mU4SjTRlU4SjTRlUU4SjnTRR [ RTT/S9RU5$)a Using real, live TLS, actually negotiate a connection. This also looks at the 'peerCertificate' attribute's correctness, since that's actually loaded using OpenSSL calls, but the main purpose is to make sure that we didn't miss anything obvious in iosim about TLS negotiations. c >T/$r+rGrsr&r9LiveFireTLSTests.test_liveFireCustomTLS..- s$r)c>T$r+rGrsr&rr. str)c>^TR5mUU4SjnTRR[5R U5$)Nc>TRTTRRR55 TRTTRRR55 TRTTR RR55 TRTTR RR55 gr+)rUr hostCertificatedigestpeerCertificater )rslt2r%rs r&rHLiveFireTLSTests.test_liveFireCustomTLS..secured..pinged4 s   DHH$<$<$C$C$EF  DHH$<$<$C$C$EF  DHH$<$<$C$C$EF  DHH$<$<$C$C$EFr))rr rrr)rsltrrrr%s @r&secured8LiveFireTLSTests.test_liveFireCustomTLS..secured1 s6 A G88&&{3??G Gr)r) tempcertr rrr rrrr)r%rrs` @r&test_liveFireCustomTLS'LiveFireTLSTests.test_liveFireCustomTLS! s]!/+ Hxx"" LLtD6# +g  r)rGN) r@rArBrCrrrrrFrGr)r&rr s!K K!r)rcT\rSrSrSrSr\RR\5 Sr g)SlightlySmartTLSiE zS Specific implementation of server side protocol with different management of TLS. c[[S9$)zC @return: the global C{tempcert} certificate as local certificate. r)rrr/s r&rSlightlySmartTLS.getTLSVarsK s22r)rGN) r@rArBrCrDrrrrrFrGr)r&rrE s  3 LL:&r)rc"\rSrSr\r\rSrSrg)PlainVanillaLiveFireTestsiT c^U4SjnTRR[R5R U5$)z Verify that out of the box, we can start TLS to at least encrypt the connection, even if we don't have any certificates to use. cB>TRR[5$r+r rrrr%s r&rBPlainVanillaLiveFireTests.test_liveFireDefaultTLS..secured` 88&&{3 3r))r rrrrr%rs` r&test_liveFireDefaultTLS1PlainVanillaLiveFireTests.test_liveFireDefaultTLSZ s.  4xx""3<<0<TRR[5$r+rrs r&rMWithServerTLSVerificationTests.test_anonymousVerifyingClient..securedq rr))r)r rrrrrrs` r&test_anonymousVerifyingClient)r%objridents r& toStringProto'ProtocolIncludingArgument.toStringProto s*2c7BxL11||G$$r)rGN)r@rArBrCrDrtrrFrGr)r&rry s " %r)rc@\rSrSrSrS\"54/rS\"54/rSrg)ProtocolIncludingCommandi zZ A command that has argument and response schemas which use L{ProtocolIncludingArgument}. weirdrGN) r@rArBrCrDrrrrFrGr)r&rr s+ 5789I4678Hr)rcH\rSrSrSr\S5r\S5r\S5rSr g)MagicSchemaCommandi zU A command which overrides L{parseResponse}, L{parseArguments}, and L{makeResponse}. cX4UlU$)z Don't do any parsing, just jam the input strings and protocol onto the C{protocol.parseResponseArguments} attribute as a two-tuple. Return the original strings. )parseResponseArguments)r%rwrs r& parseResponse MagicSchemaCommand.parseResponse ,3*='r)cX4UlU$)z Don't do any parsing, just jam the input strings and protocol onto the C{protocol.parseArgumentsArguments} attribute as a two-tuple. Return the original strings. )parseArgumentsArguments)clsrwrs r&parseArguments!MagicSchemaCommand.parseArguments s-4+>(r)cX4UlU$)z Don't do any serializing, just jam the input strings and protocol onto the C{protocol.makeArgumentsArguments} attribute as a two-tuple. Return the original strings. )makeArgumentsArguments)rrxrs r& makeArguments MagicSchemaCommand.makeArguments rr)rGN) r@rArBrCrD classmethodrrrrFrGr)r&rr sC r)rcB\rSrSrSrSr\RS5 Srg)NoNetworkProtocoli a An L{amp.AMP} subclass which overrides private methods to avoid testing the network. It also provides a responder for L{MagicSchemaCommand} that does nothing, so that tests can test aspects of the interaction of L{amp.Command}s and L{amp.AMP}. @ivar parseArgumentsArguments: Arguments that have been passed to any L{MagicSchemaCommand}, if L{MagicSchemaCommand} has been handled by this protocol. @ivar parseResponseArguments: Responses that have been returned from a L{MagicSchemaCommand}, if L{MagicSchemaCommand} has been handled by this protocol. @ivar makeArgumentsArguments: Arguments that have been serialized by any L{MagicSchemaCommand}, if L{MagicSchemaCommand} has been handled by this protocol. c.[R"U5$)z: Return a Deferred which fires with the original strings. )r succeed)r%rrwrs r&_sendBoxCommand!NoNetworkProtocol._sendBoxCommand s}}W%%r)c0$r+rG)ruweirds r&rNoNetworkProtocol. s"r)rGN) r@rArBrCrDrrrrFrGr)r&rr s&&   !45r)r_KT_VTc\rSrSrSrSrg)MyBoxi z A unique dict subclass. rGNr`rGr)r&rr rr)rc\rSrSrSr\rSrg)0ProtocolIncludingCommandWithDifferentCommandTypei zF A L{ProtocolIncludingCommand} subclass whose commandType is L{MyBox} rGN)r@rArBrCrDr commandTyperFrGr)r&rr sKr)rc\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrSrSrSrg) CommandTestsi z/ Tests for L{amp.Argument} and L{amp.Command}. c|UR[[R[R"555 g)z5 L{Argument} instances provide L{amp.IArgumentType}. N)rhr r IArgumentTypeArgumentr/s r&test_argumentInterface#CommandTests.test_argumentInterface s#  S%6%6 GHr)ct[5nSnSU0nUR[RX15SX!405 g)z There should be a class method of Command which accepts a mapping of argument names to serialized forms and returns a similar mapping whose values have been parsed via the Command's response schema. whateverrrN)rrUrrr%rrrws r&test_parseResponseCommandTests.test_parseResponse sA8V$  $ 2 27 E v( ) r)c~^^^[5mSmTR[TS9nUUU4SjnURU5 U$)z Making a remote call on a L{amp.Command} subclass which overrides the C{parseResponse} method should call that C{parseResponse} method to get the response. sweeoorcF>TRTRST0T45 gNr)rUr)rclientr%thingys r& gotResponseCCommandTests.test_callRemoteCallsParseResponse..gotResponse s$   V::gv=NPVTRTRST0T45$r)rUr)rargumentrr%s r&r@CommandTests.test_responderCallsParseArguments..6 s%((00GX3F2Qr))rrrrrrr)r%rrrrs` @@r&!test_responderCallsParseArguments.CommandTests.test_responderCallsParseArguments+ sT %&,,-?-K-KL 8T12  r)c[5n[5nSU0nS[U5[U54-nUR[R X15SUR S505 g)z There should be a class method of L{amp.Command} which accepts a mapping of argument names to objects and returns a similar mapping whose values have been serialized via the command's argument schema. rrrr=N)rr/rUrrr>)r%rrrxrs r&test_makeArgumentsCommandTests.test_makeArguments< s`88H%2h<H66  $ 2 27 E u||G, - r)c[5nSS0n[RX!5nUR[ U5[ 5 g)zl L{amp.Command.makeArguments}'s return type should be the type of the result of L{amp.Command.commandType}. rrN)rrrrprVr)r%rrxrs r&!test_makeArgumentsUsesCommandType.CommandTests.test_makeArgumentsUsesCommandTypeL s< 8K(AOO   d6lE*r)c^^^[5m[5mTR[TS9nUUU4SjnUR U5 U$)z Making a remote call on a L{amp.Command} subclass which overrides the C{makeArguments} method should call that C{makeArguments} method to get the response. rcF>TRTRST0T45 gr)rUr)rrrr%s r&r CCommandTests.test_callRemoteCallsMakeArguments..gotResponsec s&   --(0CV/L r))rrrrr)r%rr rrs` @@r&!test_callRemoteCallsMakeArguments.CommandTests.test_callRemoteCallsMakeArgumentsY sD #$8$$%7x$H  [)r)c UR[R[R[ S[ 5S9S5 g)z L{Command.makeArguments} raises L{amp.InvalidSignature} if the objects dictionary passed to it includes a key which does not correspond to the Python identifier for a defined argument. rO)rO bogusArgumentN)r^rrr|rrrr/s r&test_extraArgumentsDisallowed*CommandTests.test_extraArgumentsDisallowedk s3      wfh 7   r)c ~UR[R[R[ SSS0SS0D6S5 g)a If a command argument conflicts with a Python keyword, the untransformed argument name is not allowed as a key in the dictionary passed to L{Command.makeArguments}. If it is supplied, L{amp.InvalidSignature} is raised. This may be a pointless implementation restriction which may be lifted. The current behavior is tested to verify that such arguments are not silently dropped on the floor (the previous behavior). rOrequiredprintz print valueNrG)r^rrr|rrr/s r&test_wireSpellingDisallowed(CommandTests.test_wireSpellingDisallowedx s<       >z >g}%= >   r)cn"SS[R5nURSUR5 g)zR A L{Command} subclass without a defined C{commandName} that's not a byte string. c\rSrSrSrSrg)PCommandTests.test_commandNameDefaultsToClassNameAsByteString..NewCommandi z A new command. rGNr`rGr)r& NewCommandr, s r)r-s NewCommandN)rCommandrUrr%r-s r&/test_commandNameDefaultsToClassNameAsByteString(>?r)cUR[[S[R4SS05nUR [ U5S5 g)zY A L{Command} subclass cannot be defined with a C{commandName} that's not a byte string. r-rFOOz2^Command names must be byte strings, got: u?'FOO'$Nr^r_rVrr. assertRegexrEr%r s r&!test_commandNameMustBeAByteString.CommandTests.test_commandNameMustBeAByteString sD !! t\CKK>M5;Q   JL r)cUR[[S[R4SS/05nUR [ U5S5 g)zC A L{Command} subclass's C{arguments} must have byte string names. r-rr{Nz3^Argument names must be byte strings, got: u?'foo'$Nr4r6s r&/test_commandArgumentsMustBeNamedWithByteStringsJ;X   JM r)cz"SS[R5nUR[S0UR5 g)z> A L{Command} subclass's C{errors} is coerced into a C{dict}. c\rSrSr\S4/rSrg)DCommandTests.test_commandErrorsIsConvertedToDict..NewCommandi ZDErGN)r@rArBrCrrrFrGr)r&r-rB s(&12Fr)r-rCN)rr.rUrrr/s r&#test_commandErrorsIsConvertedToDict0CommandTests.test_commandErrorsIsConvertedToDict s0  3 3 +V4j6G6GHr)c UR[[S[R4S[ S4/05nUR [U5S5 g)zH A L{Command} subclass's C{errors} must map exceptions to byte strings. r-rr{z0^Error names must be byte strings, got: u?'foo'$Nr^r_rVrr.rr5rEr6s r&5test_commandErrorsMustUseBytesForOnWireRepresentationBCommandTests.test_commandErrorsMustUseBytesForOnWireRepresentation sN!!    [[N *E23 4   U%WXr)cz"SS[R5nUR[S0UR5 g)zC A L{Command} subclass's C{fatalErrors} is coerced into a C{dict}. c\rSrSr\S4/rSrg)ICommandTests.test_commandFatalErrorsIsConvertedToDict..NewCommandi rCrGN)r@rArBrCrrrFrGr)r&r-rL s-v67Kr)r-rCN)rr.rUrrr/s r&(test_commandFatalErrorsIsConvertedToDict5CommandTests.test_commandFatalErrorsIsConvertedToDict s0  8 8 +V4j6L6LMr)c UR[[S[R4S[ S4/05nUR [U5S5 g)zM A L{Command} subclass's C{fatalErrors} must map exceptions to byte strings. r-rr{z6^Fatal error names must be byte strings, got: u?'foo'$NrGr6s r&:test_commandFatalErrorsMustUseBytesForOnWireRepresentationGCommandTests.test_commandFatalErrorsMustUseBytesForOnWireRepresentation sQ !!    [[N /78 9    JS r)rGN)r@rArBrCrDrrr rrrrrr#r(r0r7r;r>rDrHrMrPrFrGr)r&rr sfI    " +$   $ @      I YN r)rc$\rSrSrSrSrSrSrg)ListOfTestsMixini a Base class for testing L{ListOf}, a parameterized zero-or-more argument type. @ivar elementType: Subclasses should set this to an L{Argument} instance. The tests will make a L{ListOf} using this. @ivar strings: Subclasses should set this to a dictionary mapping some number of keys -- as BYTE strings -- to the correct serialized form for some example values. These should agree with what L{elementType} produces/accepts. @ivar objects: Subclasses should set this to a dictionary with the same keys as C{strings} -- as NATIVE strings -- and with values which are the lists which should serialize to the values in the C{strings} dictionary. c>[R"UR5n[R"5nURH=nUR UR S5X RR5S5 M? URX R5 g)ai L{ListOf.toBox} extracts the list of objects from the C{objects} dictionary passed to it, using the C{name} key also passed to it, serializes each of the elements in that list using the L{Argument} instance previously passed to its initializer, combines the serialized results, and inserts the result into the C{strings} dictionary using the same C{name} key. r=N) rListOf elementTyperTrxryr>copyrUrw)r% stringListrwrSs r& test_toBoxListOfTestsMixin.test_toBox slZZ 0 01 **,<rwrxrFrGr)r&rsrs] s-++-K!8A ooe$224;;GD E ooh'557>>wG H G??5)* OOJ ' OOK (  OOI & OOJ ' OOJ ' OOJ ' OOK ( OOK (   OOE " OOH % 'Gr)rsc\rSrSrSr\R "5rSS0rS\ R "S5\ R "S5\ R "S5\ R "S 5/0r S r S r g ) ListOfDecimalNanTestsi zK Tests for L{ListOf} combined with L{amp.Decimal} for not-a-number values. snansNaN-NaNsNaN-sNaNnanNaNz-NaNsNaNz-sNaNcTSnSnSn[R"UR5n0nURH.nUR X`RR 5US5 M0 USnUR U"US5=(a U"US5(+5 UR U"US5=(a U"US55 UR U"US5=(a U"US5(+5 UR U"US 5=(a U"US 55 g) r\cHS[U5;=(a S[U5;$)NrrrErzs r&is_qnan3ListOfDecimalNanTests.test_fromBox..is_qnan sCL(GV3w<-G Gr)cS[U5;$)Nrrrs r&is_snan3ListOfDecimalNanTests.test_fromBox..is_snan sS\) )r)cS[U5;$)N-rrs r& is_signed5ListOfDecimalNanTests.test_fromBox..is_signed s#g,& &r)Nr~rrrr)rrUrVrwr]rWrh)r%rrrrXrxrSns r&r^"ListOfDecimalNanTests.test_fromBox s H * ' ZZ 0 01 < ! 9)AaD/: ! =i!o*=> ! 9)AaD/:r)rGN) r@rArBrCrDrryrVrwrzrxr^rFrGr)r&r}r} si++-K CG  OOE " OOF # OOF # OOG $  G;r)r}c\rSrSrSrSrSrg) DecimalTestsi z Tests for L{amp.Decimal}. c[R"5nUR[URS5 UR[URS5 UR[URS5 g)zr L{amp.Decimal.toString} raises L{ValueError} if passed an object which is not an instance of C{decimal.Decimal}. 1.234X9v?N)rryr^ ValueErrorrkr%rs r&test_nonDecimalDecimalTests.test_nonDecimal sW ;;= *h&7&7A *h&7&7? *h&7&7>r)rGN)r@rArBrCrDrrFrGr)r&rr s ?r)rc$\rSrSrSrSrSrSrg) FloatTestsi z Tests for L{amp.Float}. c[R"5nUR[URS5 UR[URS5 UR[URS5 g)zY L{amp.Float.toString} raises L{ValueError} if passed an object which is not a L{float}. r1.234rN)rFloatr^rrkrs r& test_nonFloatFloatTests.test_nonFloat sW 99; *h&7&7A *h&7&7B *h&7&7>r)cp[R"5nURURS5S5 g)zI L{amp.Float.toString} returns a bytestring when it is given a L{float}. rrN)rrrUrkrs r& test_floatFloatTests.test_float s*99; **518ListOfOptionalTests.test_optionalArgumentWithKeyMissingOmitted9 s9 ZZ = SZZ\OQ3GNr)c[R"[R"5SS9n0nURS0US5 UR USS05 g)zi L{ListOf.fromBox} correctly reverses the operation performed by L{ListOf.toBox} for optional arguments. TrrNr)rrUrr]rU)r%rXrxs r&.test_omittedOptionalArgumentDeserializesAsNoneBListOfOptionalTests.test_omittedOptionalArgumentDeserializesAsNoneA sH ZZ = :r7D9 9d"34r)rGN) r@rArBrCrDrrrrrrFrGr)r&rr s!  &  O5r)rcB\rSrSrSrSrSrSrSrSr Sr S r S r g ) UNIXStringTransportiL aZ An in-memory implementation of L{interfaces.IUNIXTransport} which collects all data given to it for later inspection. @ivar _queue: A C{list} of the data which has been given to this transport, eg via C{write} or C{sendFileDescriptor}. Elements are two-tuples of a string (identifying the destination of the data) and the data itself. cXl/Ulg)zX @param descriptorFuzz: An offset to apply to descriptors. @type descriptorFuzz: C{int} N_fuzz_queue)r%descriptorFuzzs r&r'UNIXStringTransport.__init__W s $  r)cVURRSXR-45 g)NfileDescriptorReceived)rr3r)r% descriptors r&sendFileDescriptor&UNIXStringTransport.sendFileDescriptor_ s! 4j::6MNOr)c>URRSU45 g)Nr4)rr3rCs r&r.UNIXStringTransport.writeb s ND12r)c8UHnURU5 M gr+)r.)r%seqr,s r& writeSequence!UNIXStringTransport.writeSequencee sD JJt r)cvURRS[[R"5545 g)Nr:)rr3rr rir/s r&rZ"UNIXStringTransport.loseConnectioni s( ,ge6J6J6L.MNOr)c.[R"S5$)Nz/tmp/some-pathr UNIXAddressr/s r&riUNIXStringTransport.getHostl s""#344r)c.[R"S5$)Nz/tmp/another-pathrr/s r&rrUNIXStringTransport.getPeero s""#677r)rN) r@rArBrCrDr'rr.rrZrirrrFrGr)r&rrL s,P3P58r)rc0\rSrSrSrSrSrSrSrSr g) DescriptorTestsix z Tests for L{amp.Descriptor}, an argument type for passing a file descriptor over an AMP connection over a UNIX domain socket. cSUl[URS9Ul[R"[R "[R "555UlURRUR5 g)Nr)r) fuzzrr-rrnrrrror/s r&rDescriptorTests.setUp~ sU ,DIIF--c.?.?@R@R@T.UV  $$T^^4r)c$[R"5nURRS5 URRS5 URRS5 UR SUR SUR55 UR SUR SUR55 UR SUR SUR55 UR 0URR 5 g)aD L{Descriptor.fromStringProto} constructs a file descriptor value by extracting a previously received file descriptor corresponding to the wire value of the argument from the L{_DescriptorExchanger} state of the protocol passed to it. This is a whitebox test which involves direct L{_DescriptorExchanger} state inspection. rrr012N)r DescriptorrrrUrt _descriptorsrs r&test_fromStringProto$DescriptorTests.test_fromStringProto s>># ,,Q/ ,,Q/ ,,Q/ H44S$--HI H44S$--HI H44S$--HI T]]778r)c[R"5nURSURSUR55 URSSUR -4UR RRS55 URSURSUR55 URSSUR -4UR RRS55 URSURSUR55 URSSUR -4UR RRS55 UR0URR5 g ) a To send a file descriptor, L{Descriptor.toStringProto} uses the L{IUNIXTransport.sendFileDescriptor} implementation of the transport of the protocol passed to it to copy the file descriptor. Each subsequent descriptor sent over a particular AMP connection is assigned the next integer value, starting from 0. The base ten string representation of this value is the byte encoding of the argument. This is a whitebox test which involves direct L{_DescriptorExchanger} state inspection and mutation. 0rrrrr 2rN) rrrUrrrr-rrrrs r&test_toStringProto"DescriptorTests.test_toStringProto s5>># x55aGH  %q499} 5t~~7L7L7P7PQR7S  x55aGH  %q499} 5t~~7L7L7P7PQR7S  x55aGH  %q499} 5t~~7L7L7P7PQR7S  T]]778r)cSnURS5n0nSnX0n[R"5nURX#UR 5UR 5 [R "[R"[R"555nURRHn[XxS5"USS6 M 0n URX#R 5X5 URX@R-X5 g)z L{amp.Descriptor.fromBox} can interpret an L{amp.AmpBox} constructed by L{amp.Descriptor.toBox} to reconstruct a file descriptor value. alphar=rrN)r>rrryrWrrnrrr-rgetattrr]rUr) r%rm nameAsBytesrwr sendObjectsrreceivereventreceiveObjectss r&test_roundTripDescriptorTests.test_roundTrip s kk'*  ( >>#{[-=-=-?O(():):3;M;M;O)PQ^^**E HAh 'qr 3+llnnO ii/1EFr))rrr-N) r@rArBrCrDrrrrrFrGr)r&rrx s 5 9&96Gr)rc z\rSrSrSrSr\"SSS5r\R"SSSSS S S \5r S r S r Sr Sr Srg) DateTimeTestsi zG Tests for L{amp.DateTime}, L{amp._FixedOffsetTZInfo}, and L{amp.utc}. s 9876-01-23T12:34:56.054321-01:23rri&r"8i1cp[R"5nUR[URS5 g)z L{amp.DateTime.fromString} raises L{ValueError} when passed a string which does not represent a timestamp in the proper format. abcN)rrr^rrir%rls r&test_invalidString DateTimeTests.test_invalidString s% LLN *allE:r)c [R"5nUR[UR[ R "SSSSSS55 g)zw L{amp.DateTime.toString} raises L{ValueError} when passed a naive datetime (a datetime with no timezone information). rrrrN)rrr^rrkrr s r&test_invalidDatetime"DateTimeTests.test_invalidDatetime s= LLN   H$5$5dBAq!$L r)c[R"5nURUR5nUR X R 5 g)zz L{amp.DateTime.fromString} returns a C{datetime.datetime} with all of its fields populated from the string passed to it. N)rrrirrUrr%rr\s r&test_fromStringDateTimeTests.test_fromString s5 <<>##DKK0  ,r)c[R"5nURUR5nUR X R 5 g)z L{amp.DateTime.toString} returns a C{str} in the wire format including all of the information from the C{datetime.datetime} passed into it, including the timezone offset. N)rrrkrrUrrs r& test_toStringDateTimeTests.test_toString s5 <<>!!$++.  ,r)rGN)r@rArBrCrDrrrrrr rrrrFrGr)r&rr sM1F Q^F   tQBBv FF; --r)rc0\rSrSrSrSrSrSrSrSr g) UTCTestsi z Tests for L{amp.utc}. cbUR[RRS5S5 g)z( L{amp.utc.tzname} returns C{"+00:00"}. Nz+00:00)rUrrtznamer/s r& test_tznameUTCTests.test_tzname s! -x8r)cUR[RRS5[R "S55 g)z* L{amp.utc.dst} returns a zero timedelta. Nr)rUrrdstr timedeltar/s r&test_dstUTCTests.test_dst s, T*H,>,>q,ABr)cUR[RRS5[R "S55 g)z0 L{amp.utc.utcoffset} returns a zero timedelta. Nr)rUrr utcoffsetrr r/s r&test_utcoffsetUTCTests.test_utcoffset s. **40(2D2DQ2GHr)c>UR[[SSS5 g)z{ L{amp._FixedOffsetTZInfo.fromSignHoursMinutes} raises L{ValueError} if passed an offset sign other than C{'+'} or C{'-'}. ?rN)r^rrr/s r& test_badSignUTCTests.test_badSign s *b#q!4r)rGN) r@rArBrCrDrr!r%r)rFrGr)r&rr s9 C I 5r)rc*\rSrSrSrSrSrSrSrg)RemoteAmpErrorTestsi z" Tests for L{amp.RemoteAmpError}. ch[R"SS5nURS[U55 g)zj L{amp.RemoteAmpError} renders the given C{errorCode} (C{bytes}) and C{description} into a native string. BROKENSomething has brokenz"Code: Something has brokenNrrbrUrEr6s r&test_stringMessage&RemoteAmpErrorTests.test_stringMessage s, ""9.DE =s5zJr)ch[R"SS5nURS[U55 g)zt When C{errorCode} contains non-ASCII characters, L{amp.RemoteAmpError} renders then as backslash-escape sequences. sBROKEN-r/z'Code: Something has brokenNr0r6s r&&test_stringMessageReplacesNonAsciiText:RemoteAmpErrorTests.test_stringMessageReplacesNonAsciiText( s, "">3IJ CSZPr)c[[S55n[R"SSUS9nUR [ U5S5 g)z[ L{amp.RemoteAmpError} renders local errors with a "(local)" marker and a brief traceback. zSomething came looser.r/)localz}^Code [(]local[)]: Something has broken Traceback [(]failure with no frames[)]: <.+Exception.>: Something came loose N)rrrrbr5rE)r%rr s r&"test_stringMessageWithLocalFailure6RemoteAmpErrorTests.test_stringMessageWithLocalFailure0 sC )$:;<""9.DGT  J9 r)rGN) r@rArBrCrDr1r4r8rFrGr)r&r,r, sKQ r)r,)rDrrztypingrrrrunittestrzope.interfacerzope.interface.verifyr r rtr r r rrrtwisted.internet.testingrtwisted.protocolsrtwisted.pythonrtwisted.python.failurer twisted.testrtwisted.trial.unittestrr_ssl supported ImportErrorr IReactorSSLrreactorLacksSSL_FixedOffsetTZInfofromSignHoursMinutesrrrrrIrr]rcrfrrir.r|rrrrrrrrrProtocolSwitchCommandrrvrrrrrr*r/r5r:r@rFrPrfrrrrrrr rrr!rrrXrrrrrrrrr)r:r<r>r@rBrDrKrOrTrjrlrrrrrrrrrrrrrrrrrSrarlrqrsr}rrrrIUNIXTransportr ITransportrrrr,rGr)r&rNs  00&;QQ4!#*+, >>;GG((11OO 00&6!!&6R,cgg,,,,),1i1 CLL QCKKQ(E 1#++1&#++ #3;;#ckk "#++"AckkA .3;;.,#++, +c//+ x--  *  $cgg$&U&_U&p('E(*!?*$ 3< 3"(5LN(++2(2:C.8C.L**(#1#1LL88L8^0S[[0 D#$$ D D D) DD0\((\(~!-I@(I@X \ ?x\ ?~ $Y   '_ '$%MNf5xf5O&f5R? 8? DY ) #++{ {   CGG   %sww % %377 % 0 h0 f,W,W^?H$%MN%|X%O&%P '5 '$%MN F h FO& F $%MN\8O&"% %69s{{9""J66:en enDcN 7Oz 8z z*0*0Z W#3 W ($4:#3(,#3,^/;H&6/;d ?8 ? ==.#($4#L>5(>5B Z & &'#8#8(#8N J ! !#67 J % %':;RGhRGj,-H,-^5x5># (# g Cs X??Y  Y