File: //proc/self/root/lib/python3/dist-packages/twisted/web/test/__pycache__/test_xmlrpc.cpython-38.pyc
U
W[^v � @ s� d Z ddlmZmZ ddlmZmZmZ ddlm Z ddl
Z
ddl m Z ddl
mZ ddlmZmZmZ dd lmZmZmZ dd
l
mZmZmZmZ dd lmZm Z dd l m Z dd
l m Z ddl!m"Z" ddl#m$Z$m%Z% ddl&m'Z' ddl(m)Z)m*Z*m+Z+m,Z, z e"d� W n e-k
�r" dZ.Y nX dZ.G dd� de j/�Z0G dd� de1�Z2G dd� de3�Z4G dd� de�Z5G d d � d e�Z6G d d � d e�Z7G d d!� d!e5�Z8G d"d#� d#ej9�Z:G d$d%� d%ej�Z;G d&d'� d'ej�Z<G d(d)� d)e j/�Z=G d*d+� d+e=�Z>G d,d-� d-e j/�Z?G d.d/� d/�Z@G d0d1� d1e@e j/�ZAG d2d3� d3e@e j/�ZBG d4d5� d5e=�ZCG d6d7� d7e=�ZDG d8d9� d9e j/�ZEG d:d;� d;e j/�ZFG d<d=� d=e j/�ZGdS )>z6
Tests for XML-RPC support in L{twisted.web.xmlrpc}.
� )�division�absolute_import)� nativeString�
networkString�NativeStringIO)�BytesION)�unittest)�xmlrpc)�XMLRPC�payloadTemplate�addIntrospection)�
_QueryFactory� withRequest� xmlrpclib)�server�client�http�static)�reactor�defer)�ConnectionDone)�failure)� namedModule)�
MemoryReactor�EventLoggingObserver)� DummyRequest)�globalLogPublisher�FilteringLogObserver�LogLevelFilterPredicate�LogLevelztwisted.internet.sslzOpenSSL not presentc @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �AsyncXMLRPCTestsz5
Tests for L{XMLRPC}'s support of Deferreds.
c s\ t dg�| _d| j_ttdt�d�f �| j_t� � � | _
G � fdd�dt �}|� | _ d S )N� �POST�async� c s e Zd Z� fdd�ZdS )z-AsyncXMLRPCTests.setUp.<locals>.AsyncResourcec s � S �Nr$ ��self��resultr$ �>/usr/lib/python3/dist-packages/twisted/web/test/test_xmlrpc.py� xmlrpc_async1 s z:AsyncXMLRPCTests.setUp.<locals>.AsyncResource.xmlrpc_asyncN)�__name__�
__module__� __qualname__r+ r$ r( r$ r* �
AsyncResource0 s r/ )
r �request�methodr r r �dumps�contentr ZDeferredr) r
�resource)r' r/ r$ r( r* �setUp) s �zAsyncXMLRPCTests.setUpc C s^ | j �| j� | �| jjg � | j�d� t�d� | jj��}| �|d� | �| jj
d� dS )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( N� N) r4 �renderr0 � assertEqual�writtenr) �callbackr �loads�join�finished)r' Zrespr$ r$ r* �test_deferredResponse7 s z&AsyncXMLRPCTests.test_deferredResponsec C sT | j �| j� | j�t�td��� | j�d� | � | jj
g � | � | jj d� dS )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.
Z Simulatedr) r N) r4 r8 r0 ZprocessingFailedr �Failurer r) r; r9 r: r> r& r$ r$ r* � test_interruptedDeferredResponseF s � z1AsyncXMLRPCTests.test_interruptedDeferredResponseN)r, r- r. �__doc__r5 r? rA r$ r$ r$ r* r % s r c @ s e Zd ZdS )�TestRuntimeErrorN�r, r- r. r$ r$ r$ r* rC V s rC c @ s e Zd ZdS )�TestValueErrorNrD r$ r$ r$ r* rE [ s rE c @ s� e Zd ZdZdZdZdd� Zdd� Zdddgd d d gge_d
d � Z d d
dgge _dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd e_ed d � �Zd!d"� Zd#S )$�Test� � �* c C s |S r% r$ )r' �argr$ r$ r* � xmlrpc_echoi s zTest.xmlrpc_echoc C s || S )z0
This function add two numbers.
r$ )r' �a�br$ r$ r* �
xmlrpc_addm s zTest.xmlrpc_add�int�doublec C s ||gS )zC
This function puts the two arguments in an array.
r$ )r' �stringZnumr$ r$ r* � xmlrpc_pairw s zTest.xmlrpc_pair�arrayrQ c C s
t �|�S )�Help for defer.)r Zsucceed�r' �xr$ r$ r* � xmlrpc_defer� s zTest.xmlrpc_deferc C s t �t� �S r% )r �failrE r& r$ r$ r* �xmlrpc_deferFail� s zTest.xmlrpc_deferFailc C s t �d S r% )rC r& r$ r$ r* � xmlrpc_fail� s zTest.xmlrpc_failc C s t �dd�S )N� �hello�r �Faultr& r$ r$ r* � xmlrpc_fault� s zTest.xmlrpc_faultc C s t �t�dd��S )N� �hi)r rX r r^ r& r$ r$ r* �xmlrpc_deferFault� s zTest.xmlrpc_deferFaultc C s d}||krt �dd�S |S )z8
Used to test that we can pass Unicode.
� ☃�
zPayload not unicode snowmanr] )r' Zpayload�snowmanr$ r$ r* �xmlrpc_snowman� s zTest.xmlrpc_snowmanc C s dddg gdd�S )NrM �cr[ �foo�rL �Dr$ r& r$ r$ r* �xmlrpc_complex� s zTest.xmlrpc_complexc C s || S r% r$ )r' �map�keyr$ r$ r* � xmlrpc_dict� s zTest.xmlrpc_dict�Help for dict.c C s |j d | S )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.
� )r1 )r' r0 �otherr$ r$ r* �xmlrpc_withRequest� s ���zTest.xmlrpc_withRequestc C sF zt �| |�W S tjk
r@ |�d�r:t�| jd��n� Y nX d S )NZSESSIONz Session non-existent/expired.)r
�lookupProcedurer �NoSuchFunction�
startswithr^ �SESSION_EXPIRED)r' Z
procedurePathr$ r$ r* rs � s
�zTest.lookupProcedureN)r, r- r. �FAILURE� NOT_FOUNDrv rK rN Z signaturerR rW rY rZ r_ rb rf rk rn �helpr rr rs r$ r$ r$ r* rF ` s, �
rF c @ s e Zd ZdZdd� Zdd� ZdS )�TestLookupProcedurez}
This is a resource which customizes procedure lookup to be used by the tests
of support for this customization.
c C s |S r% r$ rU r$ r$ r* �echo� s zTestLookupProcedure.echoc C s& |dkr| j S t�| jd|f ��dS )zs
Lookup a procedure from a fixed set of choices, either I{echo} or
I{system.listeMethods}.
r{ zprocedure %s not foundN)r{ r rt rx )r' Z
procedureNamer$ r$ r* rs � s �z#TestLookupProcedure.lookupProcedureN)r, r- r. rB r{ rs r$ r$ r$ r* rz � s rz c @ s e Zd ZdZdd� ZdS )�TestListProceduresz�
This is a resource which customizes procedure enumeration to be used by the
tests of support for this customization.
c C s dgS )zW
Return a list of a single method this resource will claim to support.
rh r$ r& r$ r$ r* �listProcedures� s z!TestListProcedures.listProceduresN)r, r- r. rB r} r$ r$ r$ r* r| � s r| c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �TestAuthHeaderzU
This is used to get the header info so that we can test
authentication.
c C s t �| � d | _d S r% )rF �__init__r0 r& r$ r$ r* r � s
zTestAuthHeader.__init__c C s || _ t�| |�S r% )r0 rF r8 )r' r0 r$ r$ r* r8 � s zTestAuthHeader.renderc C s | j �� | j �� fS r% )r0 ZgetUserZ getPasswordr& r$ r$ r* �xmlrpc_authinfo� s z TestAuthHeader.xmlrpc_authinfoN)r, r- r. rB r r8 r� r$ r$ r$ r* r~ � s r~ c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �TestQueryProtocolz_
QueryProtocol for tests that saves headers received and sent,
inside the factory.
c C s | j | j_ tj�| � d S r% )� transport�factoryr �
QueryProtocol�connectionMader& r$ r$ r* r� � s
z TestQueryProtocol.connectionMadec C s || j j|�� < d S r% )r� �headers�lower�r' rm �valr$ r$ r* � handleHeader� s z TestQueryProtocol.handleHeaderc C s$ || j j|�� < tj�| ||� dS )zA
Keep sent headers so we can inspect them later.
N)r� � sent_headersr� r r� �
sendHeaderr� r$ r$ r* r� � s z TestQueryProtocol.sendHeaderN)r, r- r. rB r� r� r� r$ r$ r$ r* r� � s r� c @ s e Zd ZdZeZdd� ZdS )�TestQueryFactoryzE
QueryFactory using L{TestQueryProtocol} for saving headers.
c O s$ i | _ i | _tjj| f|�|� d S r% )r� r� r r
r )r' �args�kwargsr$ r$ r* r s zTestQueryFactory.__init__N)r, r- r. rB r� Zprotocolr r$ r$ r$ r* r� s r� c @ s e Zd ZdZdd� ZdS )�TestQueryFactoryCancelz{
QueryFactory that saves a reference to the
L{twisted.internet.interfaces.IConnector} to test connection lost.
c C s
|| _ d S r% )� connector)r' r� r$ r$ r* �startedConnecting s z(TestQueryFactoryCancel.startedConnectingN)r, r- r. rB r� r$ r$ r$ r* r� s r� c @ s� e Zd Zdd� Zdd� Zdd� Zd dd �Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zee_dS )!� XMLRPCTestsc C s2 t jdt�t� �dd�| _| j�� j| _g | _d S �Nr � 127.0.0.1�Z interface) r � listenTCPr �SiterF �p�getHost�port� factoriesr& r$ r$ r* r5 s
�zXMLRPCTests.setUpc C s g | _ | j�� S r% )r� r� �
stopListeningr& r$ r$ r* �tearDown# s zXMLRPCTests.tearDownc O s t ||�}| j�|� |S )zw
Specific queryFactory for proxy that uses our custom
L{TestQueryFactory}, and save factories.
)r� r� �append)r' r� r� r� r$ r$ r* � queryFactory' s
zXMLRPCTests.queryFactoryNc C s0 t �td| j ��}|dkr&| j|_n||_|S )z�
Return a new xmlrpc.Proxy for the test site created in
setUp(), using the given factory as the queryFactory, or
self.queryFactory if no factory is provided.
�http://127.0.0.1:%d/N�r �Proxyr r� r� �r' r� r� r$ r$ r* �proxy0 s
zXMLRPCTests.proxyc C s� dddddidfdfddddgfdd d
d d d
g gdd�fg}g }|D ]6\}}}| � � j|f|�� }|�| j|� |�|� qDtj|dd�S )N)�add)� � � )r )rL rL �dictrL r7 �pair)rL r7 )re rc rc �complexr$ rM rg r[ rh ri T�ZfireOnOneErrback�r� �
callRemote� addCallbackr9 r� r � DeferredList)r' Z inputOutput�dl�methr� Zoutp�dr$ r$ r* � test_results= s � zXMLRPCTests.test_resultsc s@ � � � �dd�}� fdd�}� fdd�}|�|� |�|� |S )z�
Verify that headers sent from the client side and the ones we
get back from the server side are correct.
re rc c s4 � � � jd jd d� � � � jd jd d� d S )Nr � content-type� text/xml; charset=utf-8� content-lengths 129)r9 r� r� )Zingr& r$ r* �check_server_headersV s � �z6XMLRPCTests.test_headers.<locals>.check_server_headersc sL � � � jd jd d� � � � jd jd d� � � � jd jd d� d S )Nr s
user-agents Twisted/XMLRPClibr� r� r� s 155)r9 r� r� )�ignr& r$ r* �check_client_headers] s �� �z6XMLRPCTests.test_headers.<locals>.check_client_headers�r� r� r� )r' r� r� r� r$ r& r* � test_headersN s
zXMLRPCTests.test_headersc s� t � �t�ttjd�g�� t�� � ��� fdd�� g }dD ]D\}}��� � |�}��
|t j �}|�
|f�fdd� � |�|� q>tj|dd�}��fdd �}|�
|� |S )
z�
Verify that for each way a method exposed via XML-RPC can fail, the
correct 'Content-type' header is set in the response and that the
client-side Deferred is errbacked with an appropriate C{Fault}
instance.
�ZdefaultLogLevelc s
t �� �S r% �r ZremoveObserverr$ ��filteredr$ r* �<lambda>y r6 z)XMLRPCTests.test_errors.<locals>.<lambda>))rG rX )rG � deferFail)r[ �fault)rH Z noSuchMethod)r` �
deferFault)rI Z SESSION_TESTc s � � | j|�S r% )r9 Z faultCode)�exc�coder& r$ r* r� � s Tr� c s� �j D ]}��|jd d� q��dt� �� � d d j}� d d j}t|t�rb��|t � n��|t � ��|t� ��
t t� d S )Nr� r� r� r � log_failurer7 ) r� r9 r� � assertEquals�len�value�
isinstancerE �assertIsInstancerC �flushLoggedErrors)r� r� �f1�f2�� logObserverr' r$ r* �cb� s
�
z#XMLRPCTests.test_errors.<locals>.cb)r r r r �criticalr � addObserver�
addCleanupr� r� �
assertFailurer r^ r� r� r r� )r' r� r� Z
methodNamer� r� r$ �r� r� r' r* � test_errorsl s" �
zXMLRPCTests.test_errorsc s^ � fdd�� | � � ��ddd�}| �� jjjd� |�� | �� jjjd� | �|t j
�}|S )z�
A deferred from the Proxy can be cancelled, disconnecting
the L{twisted.internet.interfaces.IConnector}.
c s t | |�� _� jS r% )r� �f)r� �kw�r� r$ r* r� � s z(XMLRPCTests.test_cancel.<locals>.factoryr� r� r� � disconnected) r� r� ZassertNotEqualr� r� �stateZcancelr9 r� r ZCancelledError�r' r� r$ r� r* � test_cancel� s zXMLRPCTests.test_cancelc s< t �t�}|�dtd� jf ��}� fdd�}|�|� |S )zN
A classic GET on the xml server should return a NOT_ALLOWED.
s GETr� c s � � | jtj� d S r% )r9 r� r Z NOT_ALLOWED)Zresponser& r$ r* �
checkResponse� s z0XMLRPCTests.test_errorGet.<locals>.checkResponse)r �Agentr r0 r r� r� )r' �agentr� r� r$ r& r* �
test_errorGet� s
zXMLRPCTests.test_errorGetc sV t �t�}|jtd� jf �dt �td��d�}|�t j � � fdd�}|�|� |S )zL
Test that an invalid XML input returns an L{xmlrpc.Fault}.
r� s POSTs foo)Zurir1 Z bodyProducerc s � � tjtj| � d S r% )Z assertRaisesr r^ r r< r( r& r$ r* r� � s z,XMLRPCTests.test_errorXMLContent.<locals>.cb)
r r� r r0 r r� ZFileBodyProducerr r� ZreadBody)r' r� r� r� r$ r& r* �test_errorXMLContent� s
�
z XMLRPCTests.test_errorXMLContentc C s* t �� }| �� �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{ )r ZDateTimer� r� r� r9 )r' Zwhenr� r$ r$ r* �test_datetimeRoundtrip� s z"XMLRPCTests.test_datetimeRoundtripc s� t � �t�ttjd�g�� t�� � ��� fdd�� ��� � dd�}dd� }��
t d|� �� |t
�}��fd d
�}|�|� |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.
r� c s
t �� �S r% r� r$ r� r$ r* r� � r6 z6XMLRPCTests.test_doubleEncodingError.<locals>.<lambda>r{ r! c _ s t d��d S )Nz Cannot encode anything at all!)� RuntimeError)r� r� r$ r$ r* � fakeDumps� s z7XMLRPCTests.test_doubleEncodingError.<locals>.fakeDumpsr2 c s@ �� dt� �� ��� d d jt� ��t��t��d� d S )Nr7 r r� )r� r� r� r� r� r9 r� )�ignoredr� r$ r* �cbFailed� s �z6XMLRPCTests.test_doubleEncodingError.<locals>.cbFailed)r r r r r� r r� r� r� r� Zpatchr r� � Exceptionr� )r' r� r� r� r$ r� r* �test_doubleEncodingError� s �
z$XMLRPCTests.test_doubleEncodingErrorc s& � � � �dd�}� fdd�}|�|�S )zV
The connection to the web server is closed when the request is done.
r{ r! c s( � j \}� �|jj� � �|jj� d S r% )r� Z assertFalser� Z connectedZ
assertTruer� )r� r� r& r$ r* � responseDone� s zBXMLRPCTests.test_closeConnectionAfterRequest.<locals>.responseDoner� )r' r� r� r$ r& r* � test_closeConnectionAfterRequest� s z,XMLRPCTests.test_closeConnectionAfterRequestc C s: t � }tjdd|d�}|�d� | �|jd d d� dS )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.
s http://127.0.0.1:69g @�ZconnectTimeoutr �
someMethodr r� N)r r r� r� r9 Z
tcpClients�r' r r� r$ r$ r* �test_tcpTimeout s �
zXMLRPCTests.test_tcpTimeoutc C s: t � }tjdd|d�}|�d� | �|jd d d� dS )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.
s https://127.0.0.1:69g @r� r� r � N)r r r� r� r9 Z
sslClientsr� r$ r$ r* �test_sslTimeout s �
zXMLRPCTests.test_sslTimeout)N)r, r- r. r5 r� r� r� r� r� r� r� r� r� r� r� r� r� r� �sslSkip�skipr$ r$ r$ r* r� s
+
&
r� c @ s e Zd ZdZddd�ZdS )� XMLRPCProxyWithoutSlashTestsz3
Test with proxy that doesn't add a slash.
Nc C s0 t �td| j ��}|d kr&| j|_n||_|S )N�http://127.0.0.1:%dr� r� r$ r$ r* r� " s
z"XMLRPCProxyWithoutSlashTests.proxy)N)r, r- r. rB r� r$ r$ r$ r* r� s r� c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) � XMLRPCPublicLookupProcedureTestszr
Tests for L{XMLRPC}'s support of subclasses which override
C{lookupProcedure} and C{listProcedures}.
c C sN t jdt�|�dd�| _| �| jj� | j�� j| _t �
t d| j ��| _ d S )Nr r� r� r� )
r r� r r� r� r� r� r� r� r r� r r� )r' r4 r$ r$ r* � createServer2 s � �z-XMLRPCPublicLookupProcedureTests.createServerc C s0 | � t� � d}| j�d|�}|�| j|� |S )z�
A subclass of L{XMLRPC} can override C{lookupProcedure} to find
procedures that are not defined using a C{xmlrpc_}-prefixed method name.
r\ r{ )r� rz r� r� r� r9 )r' Zwhatr� r$ r$ r* �test_lookupProcedure; s
z5XMLRPCPublicLookupProcedureTests.test_lookupProcedurec C s, | � t� � | j�dd�}| �|tj�}|S )z�
A subclass of L{XMLRPC} can override C{lookupProcedure} to raise
L{NoSuchFunction} to indicate that a requested method is not available
to be called, signalling a fault to the XML-RPC client.
Zxxxxr\ )r� rz r� r� r� r r^ r� r$ r$ r* r� G s z,XMLRPCPublicLookupProcedureTests.test_errorsc s> t � }t|� � �|� � j�d�}� fdd�}|�|� |S )z�
A subclass of L{XMLRPC} can override C{listProcedures} to define
Overriding listProcedures should prevent introspection from being
broken.
�system.listMethodsc s � � d| � d S )Nrh )ZassertIn)Z
proceduresr& r$ r* �listed] s zAXMLRPCPublicLookupProcedureTests.test_listMethods.<locals>.listed)r| r r� r� r� r� )r' r4 r� r� r$ r& r* �test_listMethodsS s
z1XMLRPCPublicLookupProcedureTests.test_listMethodsN)r, r- r. rB r� r� r� r� r$ r$ r$ r* r� , s
r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �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 C sd | j di}tjdt�tf |��dd�| _| �| jj� | j� � j
| _
t j t
d| j
f �f|�| _dS )zO
Create a new XML-RPC server with C{allowNone} set to C{True}.
Tr r� r� r� N)�flagNamer r� r r� rF r� r� r� r� r� r r� r r� )r' r� r$ r$ r* r5 v s
���z SerializationConfigMixin.setUpc C s$ | j �d| j�}|�| j| j� |S )zY
C{self.value} can be round-tripped over an XMLRPC method call/response.
r �r� r� r� r� r9 r� r$ r$ r* �test_roundtripValue� s z,SerializationConfigMixin.test_roundtripValuec C s, | j �dd| ji�}|�| jd| ji� |S )zz
A C{dict} which contains C{self.value} can be round-tripped over an
XMLRPC method call/response.
r rL r r� r$ r$ r* �test_roundtripNestedValue� s z2SerializationConfigMixin.test_roundtripNestedValueN)r, r- r. rB r5 r r r$ r$ r$ r* r� g s
r� c @ s e Zd ZdZdZdZdS )�XMLRPCAllowNoneTestszF
Tests for passing L{None} when the C{allowNone} flag is set.
� allowNoneN)r, r- r. rB r r� r$ r$ r$ r* r � s r c @ s( e Zd ZdZdZe�dddddd�Zd S )
�XMLRPCUseDateTimeTestszd
Tests for passing a C{datetime.datetime} instance when the C{useDateTime}
flag is set.
Z useDateTimei� r[ � r� �- �; N)r, r- r. rB r �datetimer� r$ r$ r$ r* r � s r c @ s@ e Zd ZdZdZdZdd� Zdd� Zdd � Zd
d � Z d d
� Z
dS )�XMLRPCAuthenticatedTestsz]
Test with authenticated proxy. We run this with the same input/output as
above.
s usernames asecretc C s2 t jdt�t� �dd�| _| j�� j| _g | _d S r� ) r r� r r� r~ r� r� r� r� r& r$ r$ r* r5 � s
�z XMLRPCAuthenticatedTests.setUpc C sN dt | j�t | j�| jf }t�t|��}|�d�}|�| j | j| jg� |S )Nzhttp://%s:%s@127.0.0.1:%d/�authinfo)
r �user�passwordr� r r� r r� r� r9 )r' Zurlr� r� r$ r$ r* �test_authInfoInURL� s �
z+XMLRPCAuthenticatedTests.test_authInfoInURLc C sB t �td| jf �| j| j�}|�d�}|�| j| j| jg� |S )Nr� r � r r� r r� r
r r� r� r9 �r' r� r� r$ r$ r* �test_explicitAuthInfo� s � �
z.XMLRPCAuthenticatedTests.test_explicitAuthInfoc C sH | j d }t�td| jf �| 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.
�( r� r ) r r r� r r� r
r� r� r9 )r' Z longPasswordr� r� r$ r$ r* �test_longPassword� s
� �
z*XMLRPCAuthenticatedTests.test_longPasswordc C sB t �td| jf �| j| j�}|�d�}|�| j| j| jg� |S )Nz http://wrong:info@127.0.0.1:%d/r r r r$ r$ r* � test_explicitAuthInfoOverride� s � �
z6XMLRPCAuthenticatedTests.test_explicitAuthInfoOverrideN) r, r- r. rB r
r r5 r r r r r$ r$ r$ r* r � s r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�XMLRPCIntrospectionTestsc C s> t � }t|� tjdt�|�dd�| _| j�� j| _g | _ d S r� )
rF r r r� r r� r� r� r� r� )r' r r$ r$ r* r5 � s
z XMLRPCIntrospectionTests.setUpc s( � fdd�}� � � �d�}|�|� |S )Nc s6 | � � � �| ddddddddd d
d d d
ddg� d S )Nr� r� r r� r� r� r{ rX r� r� re r� �system.methodHelp�system.methodSignaturer )�sortr9 )Zmethsr& r$ r* � cbMethods� s" ��z<XMLRPCIntrospectionTests.test_listMethods.<locals>.cbMethodsr� r� )r' r r� r$ r& r* r� � s
z)XMLRPCIntrospectionTests.test_listMethodsc C sR dddg}g }|D ]0\}}| � � �d|�}|�| j|� |�|� qtj|dd�S )N)r rT )rX r! )r� ro r Tr� r� �r' Z inputOutputsr� r� Zexpectedr� r$ r$ r* �test_methodHelp� s � z(XMLRPCIntrospectionTests.test_methodHelpc C sr dddddgdddggfddddggfg}g }|D ]0\}}| � � �d|�}|�| j|� |�|� q2tj|d d
�S ) N)r r! r� rO rP r� rS rQ r Tr� r� r r$ r$ r* �test_methodSignature s
�� z-XMLRPCIntrospectionTests.test_methodSignatureN)r, r- r. r5 r� r r r$ r$ r$ r* r � s
r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � XMLRPCClientErrorHandlingTestsz3
Test error handling on the xmlrpc client.
c C s4 t �dd�| _d| j_tjdt�| j�dd�| _d S )Ns* This text is not a valid XML-RPC response.s
text/plainTr r� r� ) r ZDatar4 ZisLeafr r� r r� r� r& r$ r$ r* r5 s ��z$XMLRPCClientErrorHandlingTests.setUpc C s
| j �� S r% )r� r� r& r$ r$ r* r� s z'XMLRPCClientErrorHandlingTests.tearDownc C s. t �td| j�� jf ��}| �|�d�t�S )zj
Test that calling the xmlrpc client on a static http server raises
an exception.
r� r� )r r� r r� r� r� r� �
ValueError)r' r� r$ r$ r* �test_erroneousResponse# s �z5XMLRPCClientErrorHandlingTests.test_erroneousResponseN)r, r- r. rB r5 r� r r$ r$ r$ r* r s r c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
� QueryFactoryParseResponseTestsz?
Test the behaviour of L{_QueryFactory.parseResponse}.
c C s< t d d dd d ddd�| _t�d�| _d| _t�t� �| _ d S )Nr" Fr$ )�pathZhostr1 r
r r r� )r! z invalid xml)
r
r� r r2 � goodContents� badContentsr r@ r �reasonr& r$ r$ r* r5 3 s � z$QueryFactoryParseResponseTests.setUpc C s, | j j}|�| j j| j� | j �| j� |S )z�
We can safely call L{_QueryFactory.clientConnectionLost} as a callback
of L{_QueryFactory.parseResponse}.
)r� �deferredr� �clientConnectionLostr% �
parseResponser# r� r$ r$ r* � test_parseResponseCallbackSafetyB s z?QueryFactoryParseResponseTests.test_parseResponseCallbackSafetyc C s, | j j}|�| j j| j� | j �| j� |S )z�
We can safely call L{_QueryFactory.clientConnectionLost} as an errback
of L{_QueryFactory.parseResponse}.
)r� r& �
addErrbackr' r% r( r$ r� r$ r$ r* � test_parseResponseErrbackSafetyP s z>QueryFactoryParseResponseTests.test_parseResponseErrbackSafetyc C s, | j j}|�| j j| j� | j �dd� |S )z
We can safely call L{_QueryFactory.clientConnectionLost} as an errback
of L{_QueryFactory.badStatus}.
Zstatus�message)r� r& r* r' r% Z badStatusr� r$ r$ r* �test_badStatusErrbackSafety^ s z:QueryFactoryParseResponseTests.test_badStatusErrbackSafetyc C s$ d}| j j}| j �|� | �|t�S )z�
Some server can send a response without any data:
L{_QueryFactory.parseResponse} should catch the error and call the
result errback.
zM
<methodResponse>
<params>
<param>
</param>
</params>
</methodResponse>)r� r& r( r� �
IndexError)r' r3 r� r$ r$ r* � test_parseResponseWithoutDatak s z<QueryFactoryParseResponseTests.test_parseResponseWithoutDataN) r, r- r. rB r5 r) r+ r- r/ r$ r$ r$ r* r! . s
r! c @ s e Zd Zdd� Zdd� ZdS )�XMLRPCWithRequestTestsc C s t � | _d S r% )rF r4 r& r$ r$ r* r5 � s z XMLRPCWithRequestTests.setUpc sL t d�}d|_tt�dd��|_� fdd�}|�� �||�}� j� |� |S )z�
When an XML-RPC method is called and the implementation is
decorated with L{withRequest}, the request object is passed as
the first argument.
z/RPC2r" )rh r c s t �|jd �}� �|d� d S )Nr ))zPOST fooN)r r< r: r9 )�nr0 �datar& r$ r* �valid� s z6XMLRPCWithRequestTests.test_withRequest.<locals>.valid)
r r1 r r r2 r3 Z notifyFinishr� r4 Z render_POST)r' r0 r3 r� r$ r& r* �test_withRequest� s � z'XMLRPCWithRequestTests.test_withRequestN)r, r- r. r5 r4 r$ r$ r$ r* r0 ~ s r0 )HrB Z
__future__r r Ztwisted.python.compatr r r �ior r
Z
twisted.trialr Z twisted.webr Ztwisted.web.xmlrpcr
r r r
r r r r r r Ztwisted.internetr r Ztwisted.internet.errorr Ztwisted.pythonr Ztwisted.python.reflectr Ztwisted.test.proto_helpersr r Ztwisted.web.test.test_webr Ztwisted.loggerr r r r � ImportErrorr� ZTestCaser r� rC r rE rF rz r| r~ r� r� r� r� r� r� r� r� r r r r r r! r0 r$ r$ r$ r* �<module> sX
1[
;0 65P