YfhwdZddlZddlmZmZddlmZddlmZm Z ddl m Z ddl m Z mZddlmZmZmZmZdd lmZdd lmZmZdd lmZdd lmZdd lmZmZmZm Z m!Z!ddl"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z* eddZ+n #e,$rdZ+YnwxYwGddej-Z.Gdde/Z0Gdde1Z2Gdde%Z3Gdde%Z4Gdde%Z5Gdd e3Z6Gd!d"e!j7Z8Gd#d$e!j&Z9Gd%d&e!j&Z:Gd'd(ej-Z;Gd)d*e;Z<Gd+d,ej-Z=Gd-d.Z>Gd/d0e>ej-Z?Gd1d2e>ej-Z@Gd3d4e;ZAGd5d6e;ZBGd7d8ej-ZCGd9d:ej-ZDGd;d.AsyncResourcecSNr&)selfresults N/var/www/html/env/lib/python3.11/site-packages/twisted/web/test/test_xmlrpc.py xmlrpc_asyncz:AsyncXMLRPCTests.setUp..AsyncResource.xmlrpc_async=s N)__name__ __module__ __qualname__r.r,sr- AsyncResourcer(<s.       r/r4) rrequestmethodrrrdumpscontentrDeferredr,rresource)r+r4r,s @r-setUpzAsyncXMLRPCTests.setUp3s#RD)) $ ' w (;(;< <    %~///       F   &  r/c|j|j||jjg|jdtjd |jj}||d||jj ddS)z If an L{XMLRPC} C{xmlrpc_*} method returns a L{defer.Deferred}, the response to the request is the result of that L{defer.Deferred}. r,r/)r3NN) r:renderr5 assertEqualwrittenr,callbackrloadsjoinfinished)r+resps r-test_deferredResponsez&AsyncXMLRPCTests.test_deferredResponseBs T\*** -r222 X&&&sxx (<==>> 2333 .22222r/cj|j|j|jt jt d|jd| |jj g| |jj ddS)a While waiting for the L{Deferred} returned by an L{XMLRPC} C{xmlrpc_*} method to fire, the connection the request was issued over may close. If this happens, neither C{write} nor C{finish} is called on the request. Simulatedr,rN) r:r>r5processingFailedrFailurerr,rAr?r@rDr+s r- test_interruptedDeferredResponsez1AsyncXMLRPCTests.test_interruptedDeferredResponsePs T\*** %%gon[6Q6Q&R&RSSS X&&& -r222 .22222r/N)r0r1r2__doc__r;rFrLr&r/r-r!r!.sK ( ( ( 3 3 3 3 3 3 3 3r/r!ceZdZdS)TestRuntimeErrorNr0r1r2r&r/r-rOrO^Dr/rOceZdZdS)TestValueErrorNrPr&r/r-rSrSbrQr/rSceZdZdZdZdZdZdZgdgdge_dZ gd ge _d Z d Z d Z d Z dZdZdZdZde_edZdZdS)Test*c|Sr*r&)r+args r- xmlrpc_echozTest.xmlrpc_echons r/c ||zS)z0 This function add two numbers. r&)r+abs r- xmlrpc_addzTest.xmlrpc_addrs 1u r/intraradoublercrcc ||gS)zC This function puts the two arguments in an array. r&)r+stringnums r- xmlrpc_pairzTest.xmlrpc_pair~s}r/arrayrerac*tj|S)Help for defer.)rsucceedr+xs r- xmlrpc_deferzTest.xmlrpc_defers}Qr/cBtjtSr*)rfailrSrKs r-xmlrpc_deferFailzTest.xmlrpc_deferFailsz.**+++r/ctr*)rOrKs r- xmlrpc_failzTest.xmlrpc_failsr/c,tjddS)N hellorFaultrKs r- xmlrpc_faultzTest.xmlrpc_faults|B(((r/cPtjtjddS)Nhi)rrqrryrKs r-xmlrpc_deferFaultzTest.xmlrpc_deferFaultsz&,r400111r/c@d}||krtjddS|S)z8 Used to test that we can pass Unicode. ☃ zPayload not unicode snowmanrx)r+payloadsnowmans r-xmlrpc_snowmanzTest.xmlrpc_snowmans, g  <$ABB Br/cdddggddS)Nr^crvfoor]Dr&rKs r-xmlrpc_complexzTest.xmlrpc_complexs3B'e444r/c||Sr*r&)r+mapkeys r- xmlrpc_dictzTest.xmlrpc_dicts 3xr/Help for dict.c|jdz|zS)z A method decorated with L{withRequest} which can be called by a test to verify that the request object really is passed as an argument.  )r6)r+r5others r-xmlrpc_withRequestzTest.xmlrpc_withRequests" N     r/c tj||S#tj$r1|drtj|jdwxYw)NSESSIONzSession non-existent/expired.)rlookupProcedurerNoSuchFunction startswithrySESSION_EXPIRED)r+ procedurePaths r-rzTest.lookupProceduresp )$ >> >$   '' 22 l(*I  s AAN)r0r1r2FAILURE NOT_FOUNDrr[r_ signaturergrorrrtrzr~rrrhelprrrr&r/r-rUrUfs-GIO &&&J  8778K   ,,,)))222555(K   [       r/rUceZdZdZdZdZdS)TestLookupProcedurez} This is a resource which customizes procedure lookup to be used by the tests of support for this customization. c|Sr*r&rms r-echozTestLookupProcedure.echosr/cX|dkr|jStj|jd|d)zs Lookup a procedure from a fixed set of choices, either I{echo} or I{system.listeMethods}. rz procedure z not found)rrrr)r+ procedureNames r-rz#TestLookupProcedure.lookupProcedures? F " "9 # NBBBB   r/N)r0r1r2rMrrr&r/r-rrs<       r/rceZdZdZdZdS)TestListProceduresz This is a resource which customizes procedure enumeration to be used by the tests of support for this customization. cdgS)zW Return a list of a single method this resource will claim to support. rr&rKs r-listProceduresz!TestListProcedures.listProceduress wr/N)r0r1r2rMrr&r/r-rrs- r/rc$eZdZdZdZdZdZdS)TestAuthHeaderzU This is used to get the header info so that we can test authentication. cHt|d|_dSr*)rU__init__r5rKs r-rzTestAuthHeader.__init__s d r/cF||_t||Sr*)r5rUr>)r+r5s r-r>zTestAuthHeader.renders {{4)))r/cf|j|jfSr*)r5getUser getPasswordrKs r-xmlrpc_authinfozTestAuthHeader.xmlrpc_authinfos)|##%%t|'?'?'A'AAAr/N)r0r1r2rMrr>rr&r/r-rrsP ***BBBBBr/rc$eZdZdZdZdZdZdS)TestQueryProtocolz_ QueryProtocol for tests that saves headers received and sent, inside the factory. cf|j|j_tj|dSr*) transportfactoryr QueryProtocolconnectionMaderKs r-rz TestQueryProtocol.connectionMades+!% ++D11111r/cH||jj|<dSr*)rheaderslowerr+rvals r- handleHeaderzTestQueryProtocol.handleHeaders,/ SYY[[)))r/c||jj|<tj|||dS)zA Keep sent headers so we can inspect them later. N)r sent_headersrrr sendHeaderrs r-rzTestQueryProtocol.sendHeaders<25 !#))++.''c377777r/N)r0r1r2rMrrrr&r/r-rrsK 22200088888r/rceZdZdZeZdZdS)TestQueryFactoryzE QueryFactory using L{TestQueryProtocol} for saving headers. cVi|_i|_tjj|g|Ri|dSr*)rrrrr)r+argskwargss r-rzTestQueryFactory.__init__s; $T;D;;;F;;;;;r/N)r0r1r2rMrprotocolrr&r/r-rrs4!H<<<<.check_server_headers^s^   q!)/:.check_client_headersds   q!.}=?S      q!.?*      T^A.;z)XMLRPCTests.test_errors..~ 2 A( K Kr/))rVrq)rV deferFail)rvfault)rW noSuchMethod)r| deferFault)rX SESSION_TESTc:|j|Sr*)r? faultCode)exccoder+s r-rz)XMLRPCTests.test_errors..s1A1A#-QU1V1Vr/TrcjD]#}|jdd$dt ddj}ddj}t |tr|tn6|t|t ttdS)Nrrrr log_failurer=) rr?r assertEqualslenvalue isinstancerSassertIsInstancerOflushLoggedErrors)rrf1f2 logObserverr+s r-cbz#XMLRPCTests.test_errors..cbs>    OO46P   a[!1!1 2 2 2Q .4BQ .4B"n-- :%%b*:;;;;%%b*:;;;%%b.999  " "#3^ D D D D Dr/)r r r r criticalr addObserver addCleanuprr assertFailurerryrrrr)r+rr methodNamerr$r r#s` @@r- test_errorszXMLRPCTests.test_errorsrs:+,, ' 1(BSTTTU   &x000 KKKKLLL !   D* '' 33A""1fl33A MM4VVVVV W W W IIaLLLL  rD 9 9 9 E E E E E E" br/cbfd|ddd}|jjjd||jjjd||tj }|S)z A deferred from the Proxy can be cancelled, disconnecting the L{twisted.internet.interfaces.IConnector}. c4t|i|_jSr*)rf)rkwrs r-rz(XMLRPCTests.test_cancel..factorys.;;;GI9 r/rrr disconnected) rrassertNotEqualr-rstatecancelr?r(rCancelledError)r+rrs @r- test_cancelzXMLRPCTests.test_cancels       JJw   * *5!Q 7 7 GI/5~FFF   ,2NCCC   q%"6 7 7r/ctjt}|dt djfz}fd}|||S)zN A classic GET on the xml server should return a NOT_ALLOWED. sGETrcR|jtjdSr*)r?rr NOT_ALLOWED)responser+s r- checkResponsez0XMLRPCTests.test_errorGet..checkResponses$   X]D,< = = = = =r/)rAgentrr5rrr)r+agentrr9s` r- test_errorGetzXMLRPCTests.test_errorGetsk W%% MM&-0F$)0U"V"V W W > > > > > m$$$r/c Ftjt}|t djfzdtjtd}|tj fd}|||S)zL Test that an invalid XML input returns an L{xmlrpc.Fault}. rsPOSTsfoo)urir6 bodyProducerc^tjtj|dSr*) assertRaisesrryrrB)r,r+s r-r$z,XMLRPCTests.test_errorXMLContent..cbs%   flIOV D D D D Dr/) rr:rr5rrFileBodyProducerrrreadBody)r+r;rr$s` r-test_errorXMLContentz XMLRPCTests.test_errorXMLContents W%% MM4 |CDD0AA    fo&&& E E E E E br/ctj}|d|}||j||S)z If an L{xmlrpclib.DateTime} is passed as an argument to an XML-RPC call and then returned by the server unmodified, the result should be equal to the original object. r)rDateTimerrrr?)r+whenrs r-test_datetimeRoundtripz"XMLRPCTests.test_datetimeRoundtripsK !## JJLL # #FD 1 1 d&---r/cttttjgt jfd dd}d} td| |t}fd}|||S)a. If it is not possible to encode a response to the request (for example, because L{xmlrpclib.dumps} raises an exception when encoding a L{Fault}) the exception which prevents the response from being generated is logged and the request object is finished anyway. rc,tjSr*r r sr-rz6XMLRPCTests.test_doubleEncodingError..rr/rr#c td)NzCannot encode anything at all!) RuntimeError)rrs r- fakeDumpsz7XMLRPCTests.test_doubleEncodingError..fakeDumpss?@@ @r/r7cdtddjtttddS)Nr=rr)rrrrrLr?r )ignoredr#r+s r-cbFailedz6XMLRPCTests.test_doubleEncodingError..cbFailedsu   a[!1!1 2 2 2  ! !+a."?"E| T T T   S!7!7 !E!EFF J J J J Jr/)r r r r r%rr&r'rrpatchrr( Exceptionr)r+rrMrPr r#s` @@r-test_doubleEncodingErrorz$XMLRPCTests.test_doubleEncodingErrors+,, ' 1(BSTTTU   &x000 KKKKLLL JJLL # #FB / / A A A 9gy111   q) , , K K K K K K hr/cdd}fd}||S)zV The connection to the web server is closed when the request is done. rr#cj\}|jj|jjdSr*)r assertFalser connected assertTruer/)rOrr+s r- responseDonezBXMLRPCTests.test_closeConnectionAfterRequest..responseDonesDIW   W.8 9 9 9 OOG-: ; ; ; ; ;r/r)r+rrYs` r- test_closeConnectionAfterRequestz,XMLRPCTests.test_closeConnectionAfterRequestsO JJLL # #FB / / < < < < < }}\***r/ct}tjdd|}|d||jddddS)z For I{HTTP} URIs, L{xmlrpc.Proxy.callRemote} passes the value it received for the C{connectTimeout} parameter as the C{timeout} argument to the underlying connectTCP call. shttp://127.0.0.1:69g@connectTimeoutr someMethodrrN)r rrrr? tcpClientsr+rrs r-test_tcpTimeoutzXMLRPCTests.test_tcpTimeout si  // "3    &&& +A.q1377777r/zOpenSSL not presentct}tjdd|}|d||jddddS)z For I{HTTPS} URIs, L{xmlrpc.Proxy.callRemote} passes the value it received for the C{connectTimeout} parameter as the C{timeout} argument to the underlying connectSSL call. shttps://127.0.0.1:69g@r\r^rN)r rrrr? sslClientsr`s r-test_sslTimeoutzXMLRPCTests.test_sslTimeoutsi // #C    &&& +A.q1377777r/r*)r0r1r2r;rrrrrr*r4r<rDrHrSrZrarsslSkiprer&r/r-rr%s &&&    ==="8...`"   $   !!!F + + + 8 8 8 VG*++ 8 8,+ 8 8 8r/rceZdZdZddZdS)XMLRPCProxyWithoutSlashTestsz3 Test with proxy that doesn't add a slash. Nctjtd|jz}| |j|_n||_|S)Nhttp://127.0.0.1:%drrs r-rz"XMLRPCProxyWithoutSlashTests.proxy.s> L'.listedds MM% , , , , ,r/)rrrnrrr)r+r:rrzs` r-test_listMethodsz1XMLRPCPublicLookupProcedureTests.test_listMethodsYsz &''""" (### J ! !"6 7 7 - - - - - fr/N)r0r1r2rMrnrqr*r{r&r/r-rlrl7s] TTT      r/rlc$eZdZdZdZdZdZdS)SerializationConfigMixinas Mixin which defines a couple tests which should pass when a particular flag is passed to L{XMLRPC}. These are not meant to be exhaustive serialization tests, since L{xmlrpclib} does all of the actual serialization work. They are just meant to exercise a few codepaths to make sure we are calling into xmlrpclib correctly. @ivar flagName: A C{str} giving the name of the flag which must be passed to L{XMLRPC} to allow the tests to pass. Subclasses should set this. @ivar value: A value which the specified flag will allow the serialization of. Subclasses should set this. c f|jdi}tjdtjt di|d|_||jj|j j |_ tj td|j fzfi||_dS)zO Create a new XML-RPC server with C{allowNone} set to C{True}. TrrrrNr&)flagNamerrrrrUrr'rrrrrrr)r+rs r-r;zSerializationConfigMixin.setUp~s-&" v{4>>&>>**k    ,---FNN$$) \ 0DI<? @ @  DJ   r/c|jd|j}||j|j|S)zY C{self.value} can be round-tripped over an XMLRPC method call/response. rrrrrr?rts r-test_roundtripValuez,SerializationConfigMixin.test_roundtripValues; J ! !'4: 6 6 d& 333r/c|jdd|ji}||jd|ji|S)zz A C{dict} which contains C{self.value} can be round-tripped over an XMLRPC method call/response. rr]rrts r-test_roundtripNestedValuez2SerializationConfigMixin.test_roundtripNestedValuesE J ! !'C+< = = d&dj(9:::r/N)r0r1r2rMr;rrr&r/r-r}r}nsK      r/r}ceZdZdZdZdZdS)XMLRPCAllowNoneTestszF Tests for passing L{None} when the C{allowNone} flag is set. allowNoneN)r0r1r2rMrrr&r/r-rrs$H EEEr/rc@eZdZdZdZejddddddZd S) XMLRPCUseDateTimeTestszd Tests for passing a C{datetime.datetime} instance when the C{useDateTime} flag is set. useDateTimeirvr-;N)r0r1r2rMrdatetimerr&r/r-rrs; H H dBAr2 6 6EEEr/rc8eZdZdZdZdZdZdZdZdZ dZ d S) XMLRPCAuthenticatedTestsz] Test with authenticated proxy. We run this with the same input/output as above. susernamesasecretctjdtjt d|_|jj|_g|_dSr) rrrrrrrrrrKs r-r;zXMLRPCAuthenticatedTests.setUpsU" v{>++,,    FNN$$) r/c"dt|jt|j|jfz}t jt |}|d}||j |j|jg|S)Nzhttp://%s:%s@127.0.0.1:%d/authinfo) ruserpasswordrrrrrrr?)r+urlrrs r-test_authInfoInURLz+XMLRPCAuthenticatedTests.test_authInfoInURLs*  # #  ' ' I.   Ls++ , , LL $ $ d&DM(BCCCr/ctjtd|jfz|j|j}|d}||j|j|jg|S)Nrr rrrrrrrrr?r+rrs r-test_explicitAuthInfoz.XMLRPCAuthenticatedTests.test_explicitAuthInfosj L 0DI<? @ @ I M   LL $ $ d&DM(BCCCr/c|jdz}tjtd|jfz|j|}|d}||j|j|g|S)z C{QueryProtocol} uses the C{base64.b64encode} function to encode user name and password in the I{Authorization} header, so that it doesn't embed new lines when using long inputs. (rr) rrrrrrrrr?)r+ longPasswordrrs r-test_longPasswordz*XMLRPCAuthenticatedTests.test_longPasswordst }r) L 0DI<? @ @ I    LL $ $ d&L(ABBBr/ctjtd|jfz|j|j}|d}||j|j|jg|S)Nzhttp://wrong:info@127.0.0.1:%d/rrrs r-test_explicitAuthInfoOverridez6XMLRPCAuthenticatedTests.test_explicitAuthInfoOverridesj L ;tylJ K K I M   LL $ $ d&DM(BCCCr/N) r0r1r2rMrrr;rrrrr&r/r-rrsu DH    r/rc&eZdZdZdZdZdZdS)XMLRPCIntrospectionTestsct}t|tjdt j|d|_|jj|_g|_ dSr) rUrrrrrrrrr)r+rs r-r;zXMLRPCIntrospectionTests.setUps]   "1fk&&9&9[QQQFNN$$) r/cfd}d}|||S)Nc`||gddS)N)rrrrrrrrqrrrrvsystem.methodHelpsystem.methodSignaturer)sortr?)methsr+s r- cbMethodsz.cbMethodssD JJLLL        r/rvr)r+rrs` r-r{z)XMLRPCIntrospectionTests.test_listMethodssQ     . JJLL # #$8 9 9 i   r/cgd}g}|D]]\}}|d|}||j|||^t j|dS)N))rrk)rqr#)rrrTrrr+ inputOutputsrrexpectedrs r-test_methodHelpz(XMLRPCIntrospectionTests.test_methodHelps   *  ND( ''(;TBBA MM$*H 5 5 5 IIaLLLL!"t<<< Test the behaviour of L{QueryFactory.parseResponse}. c tddddddd|_tjd|_d|_t jt|_ dS)Nr$Fr&)pathhostr6rrrr)r#z invalid xml) rrrr7 goodContents badContentsrrJrreasonrKs r-r;z$QueryFactoryParseResponseTests.setUpTsi)   &OE22(on&6&677 r/c|jj}||jj|j|j|j|S)z We can safely call L{QueryFactory.clientConnectionLost} as a callback of L{QueryFactory.parseResponse}. )rdeferredrclientConnectionLostr parseResponserrts r- test_parseResponseCallbackSafetyz?QueryFactoryParseResponseTests.test_parseResponseCallbackSafetyhsL   & d'QueryFactoryParseResponseTests.test_parseResponseErrbackSafetyusL   & T&;T[III ''(8999r/c|jj}||jj|j|jdd|S)z} We can safely call L{QueryFactory.clientConnectionLost} as an errback of L{QueryFactory.badStatus}. statusmessage)rrrrr badStatusrts r-test_badStatusErrbackSafetyz:QueryFactoryParseResponseTests.test_badStatusErrbackSafetysK   & T&;T[III ##Hi888r/cd}|jj}|j|||tS)z Some server can send a response without any data: L{QueryFactory.parseResponse} should catch the error and call the result errback. zM )rrrr( IndexError)r+r8rs r-test_parseResponseWithoutDataz.valids6?7?1#566D   T#8 9 9 9 9 9r/) rr6rrr7r8 notifyFinishrr: render_POST)r+r5rrs` r-test_withRequestz'XMLRPCWithRequestTests.test_withRequests w''"9?8]#K#KLL : : : : :  " " . .ug > > !!'***r/N)r0r1r2r;rr&r/r-rrs2r/r)FrMriorrrrtwisted.internetrrtwisted.internet.errorrtwisted.internet.testingr r twisted.loggerr r r rtwisted.pythonrtwisted.python.compatrrtwisted.python.reflectr twisted.trial twisted.webrrrrrtwisted.web.test.test_webrtwisted.web.xmlrpcrrrrrrrf ImportErrorTestCaser!rLrOrrSrUrrrrrrrrrhrlr}rrrrrrrr&r/r-rs   ++++++++111111HHHHHHHH #"""""========......""""""<<<<<<<<<<<<<<222222K&'''GGGGG -3-3-3-3-3x(-3-3-3`     |        Z   \\\\\6\\\~     &   *        BBBBBTBBB$88888,888* < < < < =>=>=>=>={>=>=>=BNNNNNX%6NNN:O1O1O1O1O1X%6O1O1O1dX.s6 BB B