כh'SrSSKJr SSKJr SSKJrJr SSKJ r SSK J r SSK J r SSKJr SS KJr SS KJrJrJrJr SS KJr SS KJr SS KJr \rSrSSKJr SSKJ r Sr""SS\RF5r$"SS\RF5r%"SS\RF5r&"SS\'5r("SS\RF5r)"SS\RF5r*"S S!\RF5r+"S"S#\RF5r,"S$S%\RZ5r."S&S'\RF5r/"S(S)\RF5r0"S*S+5r1"S,S-\Rd5r3"S.S/\Rd5r4"S0S1\RF5r5"S2S3\RF5r6"S4S5\RF5r7"S6S7\5r8g!\!a SrSrGNkf=f)8z8 Tests for L{twisted.words.protocols.jabber.xmlstream}. )skipIf) verifyObject)defertask)ConnectionLost)IProtocolFactory)failure) proto_helpers)unittest)errorijabberjid xmlstream)!GenericXmlStreamFactoryTestsMixin)domish)ssl)F)ClientTLSOptions)CertificateOptionsN)TzSSL not availableurn:ietf:params:xml:ns:xmpp-tlsc0\rSrSrSrSrSrSrSrSr g) HashPasswordTests$z& Tests for L{xmlstream.hashPassword}. cV[R"SS5nURSU5 g)zC The sid and secret are concatenated to calculate sha1 hex digest. 12345secret(99567ee91b2c7cabf607f10cb9f4a3634fa820e0Nr hashPassword assertEqualselfhashs kC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/words/test/test_jabberxmlstream.py test_basicHashPasswordTests.test_basic)s'%%gx8 CTJcPUR[[RSS5 g)z2 The session identifier must be a unicode object. s¹2345rN assertRaises TypeErrorrrr"s r$test_sidNotUnicode$HashPasswordTests.test_sidNotUnicode0s )Y%;%;_hWr'cPUR[[RSS5 g)z( The password must be a unicode object. rssecrétNr)r,s r$test_passwordNotUnicode)HashPasswordTests.test_passwordNotUnicode6s )Y%;%;WFVWr'cV[R"SS5nURSU5 g)zL The concatenated sid and password must be encoded to UTF-8 before hashing. rusecrét(659bf88d8f8e179081f7f3b4a8e7d224652d2853Nrr!s r$test_unicodeSecret$HashPasswordTests.test_unicodeSecret<s'%%g}= CTJr'N) __name__ __module__ __qualname____firstlineno____doc__r%r-r0r4__static_attributes__r6r'r$rr$sKX X Kr'rc`\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrg)IQTestsDz? Tests both IQ and the associated IIQResponseTracker callback. c[R"S5nSUl[R"U5Ul[R "5UlUR RURlURR[R"55 URRS5 [R"URS5Ulg)N otherhosttestnszmget)rConnectAuthenticator namespace XmlStreamrClockclock callLater _callLatermakeConnectionr StringTransport dataReceivedIQiq)r" authenticators r$setUp IQTests.setUpIs!66{C "* ",,];ZZ\ $(JJ$8$8! %%m&C&C&EF ## = ,,t~~u5r'c~URURSS5 URURS5 g)NtyperCid)r rO assertTruer,s r$ testBasicIQTests.testBasicVs. %0  &r'c@URRR5 URR 5 URSR S5nUR URRR5SU-S-SU-S-/5 g)NrUzutf-8ss)r transportclearrOsendencodeassertInvalue)r"idBytess r$testSendIQTests.testSendZs   &&(  ''$-&&w/ NN $ $ * * ,&069g%(99  r'c^U4SjnTRR5nURU5 TRnUR STRS-5 U$)Nc0>TRUSS5 g)NrTresult)r )rer"s r$cb&IQTests.testResultResponse..cbgs   VF^X 6r'rU)rOr\ addCallbackrrM)r"rfdxss` r$testResultResponseIQTests.testResultResponsefsM 7 GGLLN b ^^ 5 EFr'cURR5nURU[R5 UR nUR SURS-5 U$)NzrU)rOr\ assertFailurer StanzaErrorrrMr"rjrks r$testErrorResponseIQTests.testErrorResponseqsO GGLLN 1e//0 ^^ 4twwt}DEr'c^TRn[R"U5 TRUR5 U4SjnUR SUS5 UR S5 g)z Test that untracked iq responses don't trigger any action. Untracked means that the id of the incoming response iq is not in the stream's C{iqDeferreds} dictionary. c>>TR[USS55 g)NhandledF) assertFalsegetattr)rOr"s r$rf*IQTests.testNonTrackedResponse..cbs   WRE: ;r'z/iqzN)rupgradeWithIQResponseTrackerrw iqDeferreds addObserverrM)r"rkrfs` r$testNonTrackedResponseIQTests.testNonTrackedResponseysV^^..r2 (  < ub"% 78r'cURR5nURnURSURS-5 UR URSUR 5 U$)z Test if the deferred associated with an iq request is removed from the list kept in the L{XmlStream} object after it has been fired. rhrU)rOr\rrM assertNotInr|rqs r$ testCleanupIQTests.testCleanupsW GGLLN ^^ 5 EF 7r'cURR5nURnURS5 UR U[ 5 U$)zq Test if deferreds for iq's that haven't yet received a response have their errback called on stream disconnect. Closed by peer)rOr\rconnectionLostrorrqs r$testDisconnectCleanupIQTests.testDisconnectCleanups@ GGLLN ^^ *+ 1n-r'c^^UU4SjmTRR5nURT5 TRR S5 U$)zf Test to make sure the errbacks cannot cause the iteration of the iqDeferreds to blow up in our face. c>[R"TR5R5nURT5 gN)rrNr\ addErrback)r rjebr"s r$r'IQTests.testNoModifyingDict..ebs* T^^,113A LL r'r)rOr\rrr)r"rjrs` @r$testNoModifyingDictIQTests.testNoModifyingDicts=   GGLLN R %%&67r'cjSURlURR5nURU[R 5 UR RSS/5 URUR R5 URURR5 U$)z; Test that an iq request with a defined timeout times out. <) rOtimeoutr\ror TimeoutErrorrHpumprwcallsr|r"rjs r$testRequestTimingOutIQTests.testRequestTimingOuts} GGLLN 1i445 B  ))* 334r'cbSURlURR5nURR SUR R SURS-5 URRSS/5 URURR5 U$)z Test that an iq request with a defined timeout does not time out when a response was received before the timeout period elapsed. rrrhrU) rOrr\rHrIrrMrrwrrs r$testRequestNotTimingOutIQTests.testRequestNotTimingOuts  GGLLN  NN ' ' )DGGDM 9 A ))*r'c SURlURR5nURnUR S5 UR U[ 5 URURR5 U$)zd Test if timeouts for iq's that haven't yet received a response are cancelled on stream disconnect. rr) rOrr\rrrorrwrHrrqs r$!testDisconnectTimeoutCancellation)IQTests.testDisconnectTimeoutCancellationsc  GGLLN ^^ *+ 1n- ))*r')rHrOrN)r7r8r9r:r;rQrWrarlrrr~rrrrrrr<r6r'r$r>r>DsC 6'   90     r'r>ct\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSrg)XmlStreamTestscSUlgNT)gotStreamStartr"objs r$ onStreamStartXmlStreamTests.onStreamStart "r'cSUlgr) gotStreamEndrs r$ onStreamEndXmlStreamTests.onStreamEnds  r'cSUlgr)gotStreamErrorrs r$ onStreamErrorXmlStreamTests.onStreamErrorrr'cSUlSUlSUl[R"[R "55nUR SUR5 UR SUR5 UR SUR5 UR[R"55 XRlSUlSUlXlg)z) Set up XmlStream and several observers. Fz//event/stream/start//event/stream/endz//event/stream/errorrBrrN)rrrrrF Authenticatorr}rrrrKr StringTransportWithDisconnectionrZprotocolrEversionr"rks r$rQXmlStreamTests.setUps$!#  !8!8!: ; -t/A/AB +T-=-=> -t/A/AB -HHJK "   r'cnURnUR5 URRR5SSR S5nUR SU5 UR SU5 UR SU5 UR SU5 UR UR5 g) z. Basic test on the header sent by sendHeader. rrz zN)rrMrVrrrs r$test_receiveStreamError&XmlStreamTests.test_receiveStreamError9sQ^^  ; )* ++, ))*r'cRURnSUlUR5 URR 5 UR [ R"S55 URSURR55 URUR5 g)z{ Test sendStreamError on an initiating xmlstream with a header sent. An error should be sent out and the connection lost. Tversion-unsupportedr'N rrrrZr[sendStreamErrorr StreamErrorassertNotEqualr_rVrrs r$test_sendStreamErrorInitiating-XmlStreamTests.test_sendStreamErrorInitiatingGsv ^^    5,,-BCD C!3!3!56 ))*r'chURnSUlURR5 UR [ R "S55 URUR5 URSURR55 URUR5 g)z Test sendStreamError on an initiating xmlstream without having sent a header. In this case, no header should be generated. Also, the error should not be sent out on the stream. Just closing the connection. Trr'N) rrrZr[rr r assertNotrr r_rVrrs r$&test_sendStreamErrorInitiatingNoHeader5XmlStreamTests.test_sendStreamErrorInitiatingNoHeaderUs}^^   5,,-BCD r~~& bll0023 ))*r'cRURnSUlUR5 URR 5 UR [ R"S55 URSURR55 URUR5 g)zy Test sendStreamError on a receiving xmlstream with a header sent. An error should be sent out and the connection lost. Frr'Nrrs r$test_sendStreamErrorReceiving,XmlStreamTests.test_sendStreamErrorReceivingesv ^^    5,,-BCD C!3!3!56 ))*r'chURnSUlURR5 UR [ R "S55 URUR5 URSURR55 URUR5 g)z Test sendStreamError on a receiving xmlstream without having sent a header. In this case, a header should be generated. Then, the error should be sent out on the stream followed by closing the connection. Frr'N) rrrZr[rr rrVrrr_rrs r$%test_sendStreamErrorReceivingNoHeader4XmlStreamTests.test_sendStreamErrorReceivingNoHeaderss}^^   5,,-BCD ' C!3!3!56 ))*r'cURnUR5 URnUR5 UR X!R5 UR UR 5 g)z5 Test resetting the XML stream to start a new layer. N)rrstreamresetrrr)r"rkrs r$ test_resetXmlStreamTests.test_resetsJ^^    FII. r~~&r'c>URnURS5 URURR 5S5 URR 5 [ R"S5nURU5 URURR 5S5 URR 5 [ R"S5nURU5 URURR 5S5 g)z* Test send with various types of objects. )rBpresence)z http://etherx.jabber.org/streamsfeaturessN)rr\r rZr_r[rElement)r"rkels r$ test_sendXmlStreamTests.test_sends^^   ++-~>  ^^2 3   ++-~>  ^^L M   ++-/DEr'cx^^^/m/m/m"UUU4SjS5nU"5n[R"U5nURU/T5 UR5 URS/T5 UR S5 URS[ T55 UR 5 URS/T5 g)z= Test that the associated authenticator is correctly called. c:>\rSrSrU4SjrU4SjrU4SjrSrg).TestAuthenticatoric(>TRS5 grappend)r"connectionMadeCallss r$connectionMadeKXmlStreamTests.test_authenticator..TestAuthenticator.connectionMades#**40r'c(>TRU5 grr)r" rootElementstreamStartedCallss r$ streamStartedJXmlStreamTests.test_authenticator..TestAuthenticator.streamStarteds"))+6r'c(>TRU5 grr)r"rkassociateWithStreamCallss r$associateWithStreamPXmlStreamTests.test_authenticator..TestAuthenticator.associateWithStreams(//3r'r6N)r7r8r9r:r rrr<)rr rsr$TestAuthenticatorrs 1 7 4 4r'rNsr)rrFr r rMlenr)r"rarkrr rs @@@r$test_authenticator!XmlStreamTests.test_authenticators!#%  4 4     # "78  $!45  - C 234   $!45r')rrrrN)r7r8r9r:rrrrQrrrrrrrrrrrrr<r6r'r$rrsS#!#" ( ( 7 6 + ++ ++ 'F$6r'rc\rSrSrSrg) TestErrorir6N)r7r8r9r:r<r6r'r$rrsr'rc2\rSrSrSrSrSrSrSrSr g) AuthenticatorTestsic[R"5Ul[R"UR5Ulgr)rrrPrFr,s r$rQAuthenticatorTests.setUps+&446",,T-?-?@r'cURnUR[R"55 UR S5 UR SUR 5 URSUR5 UR SUR5 URSUR5 UR SUR5 g)M Test streamStart to fill the appropriate attributes from the stream header. rNinvalid) rrKr rLrMr rassertIdenticalrrErrrs r$test_streamStart#AuthenticatorTests.test_streamStarts ^^ -779:   , T266* BLL1 T2>>2 r}}-r'cURnUR[R"55 UR S5 UR SUR 5 g)zg Test streamStart to fill the appropriate attributes from the stream header for a pre-XMPP-1.0 header. rrrNrrKr rLrMr rrs r$test_streamStartLegacy)AuthenticatorTests.test_streamStartLegacysK ^^ -779:  - ,r'cURnUR[R"55 UR S5 UR SUR 5 g)zo Test streamStart to fill the appropriate attributes from the stream header for a version with only one digit. zr)Nr*rs r$test_streamBadVersionOneDigit0AuthenticatorTests.test_streamBadVersionOneDigitsK ^^ -779:  9 ,r'cURnUR[R"55 UR S5 UR SUR 5 g)ze Test streamStart to fill the appropriate attributes from the stream header for a malformed version. zr)Nr*rs r$test_streamBadVersionNoNumber0AuthenticatorTests.test_streamBadVersionNoNumbersK ^^ -779:  < ,r'rPrN) r7r8r9r:rQr&r+r.r1r<r6r'r$rrsA.& - - -r'rc8\rSrSrSrSrSrSrSrSr Sr g ) ConnectAuthenticatorTestsic8SUlSUl[R"S5Ul[R "UR5UlURR SUR5 URR SUR5 g)NFr//event/stream/authd//event/xmpp/initfailed) gotAuthenticated initFailurerrDrPrFr}onAuthenticated onInitFailedr,s r$rQConnectAuthenticatorTests.setUp ss %&;;KH",,T-?-?@ ""#94;O;OP ""#O>OPr'cSUlgr)r9rs r$r;)ConnectAuthenticatorTests.onAuthenticateds $r'cXlgr)r:)r"r s r$r<&ConnectAuthenticatorTests.onInitFaileds"r'c"SS5nU"5nU/URlURR5 UR /URR5 UR UR 5 g)z7 Test successful completion of an initialization step. c\rSrSrSrSrg)9ConnectAuthenticatorTests.testSucces..Initializericgrr6r,s r$ initializeDConnectAuthenticatorTests.testSucces..Initializer.initializesr'r6Nr7r8r9r:rFr<r6r'r$ InitializerrDs r'rIN)r initializersrPinitializeStreamr rVr9r"rIinits r$ testSucces$ConnectAuthenticatorTests.testSuccessa   }'+f# ++- T^^889 --.r'c"SS5nU"5nU/URlURR5 UR U/URR5 UR UR 5 URSUR5 URURR[55 g)z) Test failure of an initialization step. c\rSrSrSrSrg):ConnectAuthenticatorTests.testFailure..Initializeri,c[er)rr,s r$rFEConnectAuthenticatorTests.testFailure..Initializer.initialize-sr'r6NrHr6r'r$rIrR,s r'rIN) rrJrPrKr rwr9assertNotIdenticalr:rVcheckrrLs r$ testFailure%ConnectAuthenticatorTests.testFailure's   }'+f# ++- $!rr example.comNz9rBtest)rPrErrKr rLrMr rrrhostr%rrr9r^rrVrs r$r&*ConnectAuthenticatorTests.test_streamStart9s (0$ ^^ -779:   , "&&) 2<<0 (;(;< T2==1 t,,-  M  ("++6 --.r')rPr9r:rN) r7r8r9r:rQr;r<rNrWr&r<r6r'r$r5r5s!Q%#/ ;$/r'r5c*\rSrSrSrSrSrSrSrg)ListenAuthenticatorTestsiTz, Tests for L{xmlstream.ListenAuthenticator} c[R"5Ul[R"UR5Ulgr)rListenAuthenticatorrPrFr,s r$rQListenAuthenticatorTests.setUpYs+&::<",,T-?-?@r'c"URnUR[R"55 UR SUR 5 UR S5 URSUR5 URSUR 5 URSUR 5 URSUR5 UR SUR5 URSURR5 g)r"Nr#rr jabber:clientrZ)rrKr rLr%rrMr rrUrrErrr]rs r$r&)ListenAuthenticatorTests.test_streamStart]s ^^ -779: T266*   , bff- GRVV, ",,7 T2>>2  (:(:;r'cURnUR[R"55 UR S5 UR UR [5 g)z4 The generated session id must be a unicode object. r#N)rrKr rLrMassertIsInstancerstrrs r$ test_streamStartUnicodeSessionID9ListenAuthenticatorTests.test_streamStartUnicodeSessionIDrsK^^ -779:   bffc*r'r3N) r7r8r9r:r;rQr&rjr<r6r'r$r`r`TsA<* +r'r`c\rSrSrSrSrSr\"\6S5r \"\6S5r \"\6S5r Sr S r S rS rS rS rg)TLSInitiatingInitializerTestsic/Ul/Ul[RUl[R "S5Ul[R"UR 5UlURRURl URR5 URRS5 [R"UR5Ul g)NrZr)outputdonerrsavedSSLrDrPrFrr\r rMTLSInitiatingInitializerrMr,s r$rQ#TLSInitiatingInitializerTests.setUps  !  &;;MJ",,T-?-?@"kk00 %%' ## ; 66t~~F r'c.UR[lgr)rqrrr,s r$tearDown&TLSInitiatingInitializerTests.tearDowns  r'c[R"URSS9UlURURR5 g)z. Passing required sets the instance variable. T)requiredN)rrrrMrVrxr,s r$test_initRequired/TLSInitiatingInitializerTests.test_initRequireds366t~~PTU   **+r'c^[R"5TRlU4SjTRRlU4SjTRlU4SjTRlTRR5nURTR[R5 TRS[TR55 TRSnTRSUR5 TR[UR 5 TRR#S[-5 TR/SQTR$5 U$) z> When TLS is wanted and SSL available, StartTLS is initiated. c:>TRRS5$NTLSrpr)ctxr"s r$DTLSInitiatingInitializerTests.test_wantedSupported..s 8H8H8Or'c:>TRRS5$Nrrr,sr$rrtyy'7'7'@r'c:>TRRS5$Nheaderrr,sr$rrDII,<,r~rr)r rLrrZstartTLSrrrMstartrir Resetrroname NS_XMPP_TLSurirMrp)r"rjrs` r$test_wantedSupported2TLSInitiatingInitializerTests.test_wantedSupporteds $1#@#@#B ,O  )@$F! IIOO  d&& 8 C ,-;;q> X]]3 hll3 ##$;k$IJ 3TYY?r'c^U4Sjn[R"5TRlUTRRlU4SjTRlU4SjTRlTRR5nTRRS[-5 TR/SQTR5 U$)z* The server certificate will be verified. c>TRU[5 TRURS5 TRR S5 g)NrZr~)rhrr _hostnamerpr)contextFactoryr"s r$ fakeStartTLSJTLSInitiatingInitializerTests.test_certificateVerify..fakeStartTLSs<  ! !.2B C   ^55} E II  U #r'c:>TRRS5$rrr,sr$rFTLSInitiatingInitializerTests.test_certificateVerify..rr'c:>TRRS5$rrr,sr$rrrr'rr) r rLrrZrrrrMrrMrr rp)r"rrjs` r$test_certificateVerify4TLSInitiatingInitializerTests.test_certificateVerifys  $ $1#@#@#B ,8  )@$F! IIOO  ##$;k$IJ 3TYY?r'c^^[5m[R"TRTS9TlTTRlUU4Sjn[ R "5TRlUTRRlU4SjTRl U4SjTRl TRR5nTRRS[-5 TR/SQTR5 U$)z8 A custom contextFactory is passed through to startTLS. )configurationForTLSc`>TRTU5 TRRS5 gr})assertIsrpr)rrr"s r$rQTLSInitiatingInitializerTests.test_certificateVerifyContext..fakeStartTLSs# MM#~ . II  U #r'c:>TRRS5$rrr,sr$rMTLSInitiatingInitializerTests.test_certificateVerifyContext..rr'c:>TRRS5$rrr,sr$rrrr'rr)rrrrrMrr rLrZrrrrrMrr rp)r"rrjrs` @r$test_certificateVerifyContext;TLSInitiatingInitializerTests.test_certificateVerifyContexts !"66 NN  $'   $$1#@#@#B ,8  )@$F! IIOO  ##$;k$IJ 3TYY?r'cS[lSURlURR 5nUR UR S5 UR S[UR55 U$)zH No StartTLS is initiated when wanted, not required, SSL not available. NFr) rrrMrxrrir rrors r$"test_wantedNotSupportedNotRequired@TLSInitiatingInitializerTests.test_wantedNotSupportedNotRequiredsY "  IIOO  d&&- C ,-r'cS[lSURlURR 5nUR U[R 5 URS[UR55 U$)zC TLSNotSupported is raised when TLS is required but not available. NTr) rrrMrxrroTLSNotSupportedr rrors r$test_wantedNotSupportedRequired=TLSInitiatingInitializerTests.test_wantedNotSupportedRequireds[ !  IIOO  1i778 C ,-r'c[R"S5nURS5 URUR4U0UR lSURlURR5nURS[UR55 URU[ R5 U$)zG TLSRequired is raised when TLS is not wanted, but required by server. rrrxFr)rr addElementrrrrrMwantedrr rroro TLSRequiredr"tlsrjs r$test_notWantedRequired4TLSInitiatingInitializerTests.test_notWantedRequiredsnnLM z"$'GGSXX#6"<   IIOO  C ,- 1i334r'c~[R"S5nURUR4U0URlSUR lSUR lUR R5nURURS5 URS[UR55 U$)z< No StartTLS is initiated when not wanted and not required. rFNr)rrrrrrrMrrxrrir rrors r$test_notWantedNotRequired7TLSInitiatingInitializerTests.test_notWantedNotRequired snnLM$'GGSXX#6"<  "  IIOO  d&&- C ,-r'cS[lURR5nUR U[R 5 URR S[-5 U$)z> TLSFailed is raised when the server responds with a failure. rz)rrrMrro TLSFailedrMrrs r$ test_failed)TLSInitiatingInitializerTests.test_failedsN IIOO  1i112 ##$;k$IJr')rPrprMrorqrN)r7r8r9r:rQruryr skipWhenNoSSLrrrrrrrrr<r6r'r$rmrmsvG"&, ]( ]( ]2     r'rmc\rSrSrSrSrSrg)TestFeatureInitializeri'r[c.[R"S5$r)rsucceedr,s r$rTestFeatureInitializer.start*s}}T""r'r6N)r7r8r9r:featurerr<r6r'r$rr's  G#r'rc,\rSrSrSrSrSrSrSrg)%BaseFeatureInitiatingInitializerTestsi.c[R"[R"55Ul[UR5Ulgr)rrFrrrMr,s r$rQ+BaseFeatureInitiatingInitializerTests.setUp/s-",,Y-D-D-FG*4>>: r'cURR[R"URR50URlURR 5$)zG Test that an advertized feature results in successful initialization. )rMrrrrrrFr,s r$testAdvertized4BaseFeatureInitiatingInitializerTests.testAdvertized3sE$(99#4#4fnnTYYEVEV6W"Xyy##%%r'cSURlUR[RURR 5 g)zh Test that when the feature is not advertized, but required by the initializer, an exception is raised. TN)rMrxr*rFeatureNotAdvertizedrFr,s r$testNotAdvertizedRequired?BaseFeatureInitiatingInitializerTests.testNotAdvertizedRequired:s0 "  )88$)):N:NOr'czSURlURSURR55 g)zw Test that when the feature is not advertized, and not required by the initializer, the initializer silently succeeds. FN)rMrxr%rFr,s r$testNotAdvertizedNotRequiredBBaseFeatureInitiatingInitializerTests.testNotAdvertizedNotRequiredBs- #  T499#7#7#9:r')rMrN) r7r8r9r:rQrrrr<r6r'r$rr.s;&P;r'rc8\rSrSrSrSrSrSrSrSr Sr g ) ToResponseTestsiKcP[R"S5nSUS'SUS'SUS'SUS '[R"US 5nUR X5 UR USS5 UR USS5 UR USS 5 UR US S5 g ) zC Test that a response stanza is generated with addressing swapped. rerOrCrTuser1@example.comtouser2@example.com/resourcefromstanza1rUreN)rrr toResponserUr r"stanzaresponses r$test_toResponseToResponseTests.test_toResponseLs 78v*t 5v t ''9 1 &)+>? $)EF &)84 $3r'c[R"S5nSUS'SUS'[R"U5nUR USS5 UR UR S55 g)zI Test that a response is generated from a stanza without a from address. rrCrTrrrN)rrrrr rw hasAttributers r$test_toResponseNoFrom%ToResponseTests.test_toResponseNoFrom\sd 78v*t ''/ &)+>? ..t45r'c[R"S5nSUS'SUS'[R"U5nUR UR S55 UR USS5 g)zG Test that a response is generated from a stanza without a to address. rrCrTrrrN)rrrrrwrr rs r$test_toResponseNoTo#ToResponseTests.test_toResponseNoTogsc 78v5v''/ ..v67 $)EFr'c[R"S5nSUS'[R"U5nUR UR S55 UR UR S55 g)zI Test that a response is generated from a stanza without any addressing. remessagechatrTrrNrrrrrwrrs r$test_toResponseNoAddressing+ToResponseTests.test_toResponseNoAddressingrs^ <=v''/ ..t45 ..v67r'c[R"S5n[R"U5nUR UR S55 g)z@ Test that a proper response is generated without id attribute. rrUNrrs r$ test_noIDToResponseTests.test_noID|s< <=''/ ..t45r'c[R"S5n[R"U5nUR UR S55 g)zB Test that a proper response is generated without type attribute. rrTNrrs r$ test_noTypeToResponseTests.test_noTypes< <=''/ ..v67r'r6N) r7r8r9r:rrrrrrr<r6r'r$rrKs!4 6 G868r'rc$\rSrSrSrSrSrSrg) DummyFactoryizB Dummy XmlStream factory that only registers bootstrap observers. c0Ulgr callbacksr,s r$__init__DummyFactory.__init__s r'c X RU'grr)r"eventcallbacks r$ addBootstrapDummyFactory.addBootstraps (ur'rN)r7r8r9r:r;rrr<r6r'r$rrs)r'rc6\rSrSrSrSrSrSrSrSr Sr g ) DummyXMPPHandlerizG Dummy XMPP subprotocol handler to count the methods are called on it. c.SUlSUlSUlg)Nr)doneMadedoneInitializeddoneLostr,s r$rDummyXMPPHandler.__init__s   r'c$UR5 gr)r rs r$rKDummyXMPPHandler.makeConnections r'c.U=RS- slgNrr r,s r$r DummyXMPPHandler.connectionMade  r'c.U=RS- slgr)r r,s r$connectionInitialized&DummyXMPPHandler.connectionInitializeds !r'c.U=RS- slgr)r r"reasons r$rDummyXMPPHandler.connectionLostrr')r r r N) r7r8r9r:r;rrKr rrr<r6r'r$rrs  "r'rc$\rSrSrSrSrSrSrg)FailureReasonXMPPHandleriz6 Dummy handler specifically for failure Reason tests. cSUlg)NFgotFailureReasonr,s r$r!FailureReasonXMPPHandler.__init__s %r'cR[U[R5(aSUlggr) isinstancer Failurerrs r$r'FailureReasonXMPPHandler.connectionLosts fgoo . .$(D ! /r'rN)r7r8r9r:r;rrr<r6r'r$rrs&)r'rc0\rSrSrSrSrSrSrSrSr g) XMPPHandlerTestsiz% Tests for L{xmlstream.XMPPHandler}. c^[[R[R"55 g)z> L{xmlstream.XMPPHandler} implements L{ijabber.IXMPPHandler}. N)rr IXMPPHandlerr XMPPHandlerr,s r$test_interfaceXMPPHandlerTests.test_interfaces W))9+@+@+BCr'c"SS5n[R"5nU"5UlURS5 UR S/URR 5 g)z@ Test that data is passed on for sending by the stream manager. c \rSrSrSrSrSrg)6XMPPHandlerTests.test_send..DummyStreamManageric/Ulgroutlistr,s r$r?XMPPHandlerTests.test_send..DummyStreamManager.__init__s ! r'c:URRU5 gr)r1r)r"datas r$r\;XMPPHandlerTests.test_send..DummyStreamManager.sends ##D)r'r0N)r7r8r9r:rr\r<r6r'r$DummyStreamManagerr.s  " *r'r6rN)rr)parentr\r r1)r"r6handlers r$rXMPPHandlerTests.test_sendsN  * *'')+- ]# -'..*@*@Ar'c$"SS[R5nU"5n[R"[R"55nUR U5 UR UR 5 URX2R5 g)zI Test that makeConnection saves the XML stream and calls connectionMade. c\rSrSrSrSrg)=XMPPHandlerTests.test_makeConnection..TestXMPPHandlericSUlgrrr,s r$r LXMPPHandlerTests.test_makeConnection..TestXMPPHandler.connectionMades $ r'rN)r7r8r9r:r r<r6r'r$TestXMPPHandlerr<s %r'r?N)rr)rFrrKrVr r%)r"r?r8rks r$test_makeConnection$XMPPHandlerTests.test_makeConnectionsk  %i33 %"#  !8!8!: ;r" (() R!2!23r'c [R"5n[R"[R"55nUR U5 UR [ 55 URSUR5 g)z2 Test that connectionLost forgets the XML stream. N)rr)rFrrKr Exceptionr%)r"r8rks r$test_connectionLost$XMPPHandlerTests.test_connectionLosts_'')  !8!8!: ;r"y{+ T7#4#45r'r6N) r7r8r9r:r;r*rr@rDr<r6r'r$r&r&sD B" 46r'r&c0\rSrSrSrSrSrSrSrSr g) XMPPHandlerCollectionTestsiz/ Tests for L{xmlstream.XMPPHandlerCollection}. c8[R"5Ulgr)rXMPPHandlerCollection collectionr,s r$rQ XMPPHandlerCollectionTests.setUps#99;r'cL[[RUR5 g)zJ L{xmlstream.StreamManager} implements L{ijabber.IXMPPHandlerCollection}. N)rr IXMPPHandlerCollectionrJr,s r$r*)XMPPHandlerCollectionTests.test_interfaces W33T__Er'c[5nURUR5 URXR5 UR URUR 5 g)z* Test the addition of a protocol handler. N)rsetHandlerParentrJr^r%r7r"r8s r$test_addHandler*XMPPHandlerCollectionTests.test_addHandlersF#$  1 g/ T__gnn=r'c[5nURUR5 URUR5 UR XR5 UR SUR 5 g)z% Test removal of a protocol handler. N)rrPrJdisownHandlerParentrr%r7rQs r$test_removeHandler-XMPPHandlerCollectionTests.test_removeHandler sV#$  1##DOO4 //2 T7>>2r')rJN) r7r8r9r:r;rQr*rRrVr<r6r'r$rGrGs<F >3r'rGcl\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrg)StreamManagerTestsiz' Tests for L{xmlstream.StreamManager}. cN[5n[R"U5Ulgr)rr StreamManager streamManager)r"factorys r$rQStreamManagerTests.setUps.&44W=r'c$URnURSUR5 UR/UR5 URUR UR RS5 URURUR RS5 URURUR RS5 URURUR RS5 g)z= Test correct initialization and setup of factory observers. Nz//event/stream/connectedr7rr8) r\r%rr handlers _connectedr]r_authd _disconnectedinitializationFailed)r"sms r$r%StreamManagerTests.test_basics   T2<<0 R[[)  MM2:://0JK  BJJ$8$89O$PQ ))2::+?+?@T+UV   # #RZZ%9%9:S%T r'cnURn[5nURU5 [R"[R "55nUR U5 URSUR5 URSUR5 URSUR5 g)zg Test that protocol handlers have their connectionMade method called when the XML stream is connected. rrN) r\rrPrrFrrar r r r r"rer8rks r$test_connected!StreamManagerTests.test_connected.s   "$  $  !8!8!: ; b G,,- G334 G,,-r'c6URn[5nURU5 [R"[R "55nUR U5 URSUR5 URSUR5 g)z@ Test raw data functions unset when logTraffic is set to False. N) r\rrPrrFrrar% rawDataInFn rawDataOutFnrhs r$test_connectedLogTrafficFalse0StreamManagerTests.test_connectedLogTrafficFalse<sr  "$  $  !8!8!: ; b T2>>2 T2??3r'cDURnSUl[5nURU5 [R "[R "55nURU5 URSUR5 URSUR5 g)z= Test raw data functions set when logTraffic is set to True. TN) r\ logTrafficrrPrrFrrarUrlrmrhs r$test_connectedLogTrafficTrue/StreamManagerTests.test_connectedLogTrafficTrueHsy   "$  $  !8!8!: ; b bnn5 boo6r'cnURn[5nURU5 [R"[R "55nUR U5 URSUR5 URSUR5 URSUR5 g)zp Test that protocol handlers have their connectionInitialized method called when the XML stream is initialized. rrN) r\rrPrrFrrbr r r r rhs r$ test_authdStreamManagerTests.test_authdUs   "$  $  !8!8!: ; "  G,,- G334 G,,-r'cnURn[5nURU5 [R"[R "55nUR U5 URSUR5 URSUR5 URSUR5 g)zj Test that protocol handlers have their connectionLost method called when the XML stream is disconnected. rrN) r\rrPrrFrrcr r r r rhs r$test_disconnected$StreamManagerTests.test_disconnectedcs   "$  $  !8!8!: ;  G,,- G334 G,,-r'cURn[5nURU5 UR[R "[ S555 URSUR5 g)z A L{STREAM_END_EVENT} results in L{StreamManager} firing the handlers L{connectionLost} methods, passing a L{failure.Failure} reason. z no reasonTN) r\rrPrcr r#rCr rr"rer8s r$test_disconnectedReason*StreamManagerTests.test_disconnectedReasonqsW   *,  $ ;)?@A w778r'cURn[5nURU5 URSUR5 URSUR 5 URSUR 5 g)z> Test the addition of a protocol handler while not connected. rN)r\rrPr r r r r{s r$rR"StreamManagerTests.test_addHandler|sg  "$  $ G,,- G334 G,,-r'cURn[R"[R"55nUR U5 UR U5 [ 5nURU5 URSUR5 URSUR5 URSUR5 g)z Test the addition of a protocol handler after the stream have been initialized. Make sure that the handler will have the connected stream passed via C{makeConnection} and have C{connectionInitialized} called. rrN) r\rrFrrarbrrPr r r r )r"rerkr8s r$test_addHandlerInitialized-StreamManagerTests.test_addHandlerInitializeds    !8!8!: ; b " "$  $ G,,- G334 G,,-r'c[R"[R"55n[R"U5nUR S5n[ R "5UlUR5 URS5 URUS5 URS5 URSURR55 g)zh Test send when the stream has been initialized. The data should be sent directly over the XML stream. Nrr7rr)rXmlStreamFactoryrr[ buildProtocolr rLrZr rMdispatchr\r r_r"r]rerks r$test_sendInitialized'StreamManagerTests.test_sendInitializeds ,,Y-D-D-FG  $ $W -  " "4 ($446    - B./   ););)=>r'cD[R"[R"55n[R"U5n[ 5nUR U5 UR S5n[R"5Ul URS5 URSURR55 URSURS5 UR5 URSURR55 URSURS5 URS5 UR!US5 URSURR55 UR#UR5 g)z Test send when there is no established XML stream. The data should be cached until an XML stream has been established and initialized. Nrr'rrr7r)rrrr[r addHandlerrr rLrZr\r r_ _packetQueuer rMrrwr"r]rer8rks r$test_sendNotConnected(StreamManagerTests.test_sendNotConnecteds6,,Y-D-D-FG  $ $W -"$ g  " "4 ($446    bll0023 (:;  bll0023 (:;  - B./ ););)=> )r'c[R"[R"55n[R"U5nUR S5n[ R "5UlUR5 URS5 URS5 URSURR55 URSURS5 g)z Test send when the stream is connected but not yet initialized. The data should be cached until the XML stream has been initialized. Nrrr'r)rrrr[rr rLrZr rMr\r r_rrs r$test_sendNotInitialized*StreamManagerTests.test_sendNotInitializeds ,,Y-D-D-FG  $ $W -  " "4 ($446    -   bll0023 (:;r'c[R"[R"55n[R"U5n[ 5nUR U5 UR S5nUR5 [R"5Ul URS5 URS5 URSURR55 URSURS5 g)z Test send after XML stream disconnection. The data should be cached until a new XML stream has been established and initialized. Nrr'r)rrrr[rrrr r rLrZrr\r r_rrs r$test_sendDisconnected(StreamManagerTests.test_sendDisconnecteds,,Y-D-D-FG  $ $W -"$ g  " "4 ( $446  $   bll0023 (:;r')r\N)r7r8r9r:r;rQr%rirnrrrurxr|rRrrrrrr<r6r'r$rYrYsN> . 4 7 . . 9 ..(?(*@<(.TestAuthenticatoric/Ulgr xmlstreamsr,s r$rEXmlStreamServerFactoryTests.setUp..TestAuthenticator.__init__s "$r'c:URRU5 gr)rrrs r$rPXmlStreamServerFactoryTests.setUp..TestAuthenticator.associateWithStreams&&r*r'rN)r7r8r9r:rrr<r6r'r$rrs  % +r'rc>T"5$rr6)rsr$authenticatorFactory?XmlStreamServerFactoryTests.setUp..authenticatorFactory s $& &r'N)rXmlStreamServerFactoryr])r"rrs @r$rQ!XmlStreamServerFactoryTests.setUps'  + + '!778LM r'c8[[UR5 g)z, L{XmlStreamServerFactory} is a L{Factory}. N)rrr]r,s r$r**XmlStreamServerFactoryTests.test_interfaces %t||4r'cURRS5nURU/URR5 g)aS The authenticator factory should be used to instantiate the authenticator and pass it to the protocol. The default protocol, L{XmlStream} stores the authenticator it is passed, and calls its C{associateWithStream} method. so we use that to check whether our authenticator factory is used and the protocol instance gets an authenticator. N)r]rr rPrrs r$,test_buildProtocolAuthenticatorInstantiationHXmlStreamServerFactoryTests.test_buildProtocolAuthenticatorInstantiations6\\ ' ' - "r//::;r'czURRS5nURU[R5 g)zF The protocol factory creates Jabber XML Stream protocols by default. N)r]rrhrrFrs r$test_buildProtocolXmlStream7XmlStreamServerFactoryTests.test_buildProtocolXmlStream#s.\\ ' ' - b)"5"56r'cURRS5nURRS5nURX5 URURUR5 g)zz Subsequent calls to buildProtocol should result in different instances of the protocol, as well as their authenticators. N)r]rrUrP)r"xs1xs2s r$test_buildProtocolTwice3XmlStreamServerFactoryTests.test_buildProtocolTwice*sV ll((.ll((. )  1 133D3DEr')r]N) r7r8r9r:r;rQr*rrrr<r6r'r$rrs"N"5 <7Fr'r)9r;r rzope.interface.verifyrtwisted.internetrrtwisted.internet.errorrtwisted.internet.interfacesrtwisted.pythonr twisted.testr twisted.trialtwisted.words.protocols.jabberr r rr!twisted.words.test.test_xmlstreamrtwisted.words.xishrr_sslrtwisted.internet._sslverifyrtwisted.internet.sslr ImportErrorrTestCaserr>rrCrrr5r`rm BaseFeatureInitiatingInitializerrrrrr)rrr&rGrYrr6r'r$rs.(18"&"IIO% 8, CM<7/ K))K@_h_DX6X&&X6v  @-**@-FI/ 1 1I/X*+x00*+ZcH$5$5cL#YGG#;H,=,=;:?8h''?8D ) )y,,. )y44 )36x((36l3!2!23Db<**b