| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/web/test/__pycache__/ |
Upload File : |
o
�b�� � @ sz d Z ddlZddlmZ ddlmZ ddlmZmZm Z m
Z
ddl m Z m
Z
ddlmZ ddlmZ dd lmZ dd
lmZmZ dd lmZmZ dd lmZm Z m Z dd
l m Z m Z ddl!m"Z"m#Z#m$Z$ ddl%m&Z& ddl'm(Z(m)Z) ddl*m+Z+ ddl,m-Z- ddl.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7m8Z8 ddl9m:Z:m;Z;m<Z<m=Z= ddl>m?Z? ddl@mAZAmBZB ddlCmDZDmEZEmFZF dd lGmHZHmIZImJZJmKZKmLZLmMZMmNZN dd lOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZW dd lXmYZY dd lZm[Z[ dd l\m]Z]m^Z^m_Z_m`Z`maZambZb dd!lcmdZdmeZe e�reBZfegZhnegZfeBZhzdd"lmiZj W n ek�y. dZid#ZlY n&w ejZid$Zldd%lmmnZnmoZo dd&lpmqZq dd'lrmsZsmtZt eeo�G d(d)� d)��ZuG d*d+� d+e)�ZvG d,d-� d-�ZwG d.d/� d/eB�Zxd0Zyd1Zzd2Z{d3Z|d4Z}d5Z~G d6d7� d7�ZG d8d9� d9�Z�G d:d;� d;�Z�G d<d=� d=e(�Z�G d>d?� d?eBe�Z�G d@dA� dA�Z�G dBdC� dC�Z�ee_�G dDdE� dE��Z�G dFdG� dGeBee�e��Z�G dHdI� dIeedeA�Z�G dJdK� dKeeeeA�Z�e
el dL�G dMdN� dNeBee���Z�G dOdP� dPeB�Z�G dQdR� dReBe�Z�G dSdT� dT�Z�G dUdV� dVeBe��Z�G dWdX� dXeBe�ee��Z�G dYdZ� dZe1eb��Z�G d[d\� d\e��Z�G d]d^� d^eBee��Z�G d_d`� d`e)�Z�G dadb� dbeBe�Z�G dcdd� ddeBee��Z�g de�Z�G dfdg� dgef�Z�G dhdi� diee�e�eh�Z�G djdk� dkee�e�eh�Z�G dldm� dme=�Z�G dndo� do�Z�G dpdq� dqe��Z�G drds� dseB�Z�e
el dL�G dtdu� dueB��Z�G dvdw� dwedeA�Z�G dxdy� dyedeA�Z�G dzd{� d{eeeA�Z�G d|d}� d}eeeA�Z�dS )~zD
Tests for L{twisted.web.client.Agent} and related new client APIs.
� N)� CookieJar)�BytesIO)�
TYPE_CHECKING�List�Optional�Tuple)�SkipTest�skipIf�� implementer)� verifyObject)�Version)�defer�task)� IPv4Address� IPv6Address)�CancelledError�Deferred�succeed)�HostnameEndpoint�TCP4ClientEndpoint)�ConnectionDone�ConnectionLost�ConnectionRefusedError)� IOpenSSLClientConnectionCreator)�Factory�Protocol)�Clock)� deterministicResolvingReactor)�globalLogPublisher)�proxyForInterface)�getDeprecationWarningString)�Failure)�
FakeTransport�IOPump)�AccumulatingProtocol�EventLoggingObserver�MemoryReactorClock�StringTransport)�!certificatesForAuthorityAndServer)�SynchronousTestCase�TestCase)�client�error� http_headers)�HTTP11ClientProtocol�PotentialDataLoss�RequestNotSent�RequestTransmissionFailed�Response�ResponseFailed�ResponseNeverReceived)�URI�BrowserLikePolicyForHTTPS�FileBodyProducer�HostnameCachingHTTPSPolicy�HTTPConnectionPool�Request� ResponseDone�_HTTP11ClientFactory)�SchemeNotSupported)�Headers)�UNKNOWN_LENGTH�IAgent�IAgentEndpointFactory�
IBodyProducer�IPolicyForHTTPS� IResponse)�MethodInjectionTestsMixin�URIInjectionTestsMixin)�sslFT)�ClientTLSOptions�IOpenSSLTrustRoot)�optionsForClientTLS)�TLSMemoryBIOFactory�TLSMemoryBIOProtocolc @ s e Zd ZdZdZdd� ZdS )�CustomOpenSSLTrustRootFNc C s d| _ || _d S �NT)�called�context)�selfrQ � rS �=/usr/lib/python3/dist-packages/twisted/web/test/test_agent.py�_addCACertsToContextj �
z+CustomOpenSSLTrustRoot._addCACertsToContext)�__name__�
__module__� __qualname__rP rQ rU rS rS rS rT rN e s rN c @ s" e Zd ZdZddd�Zdd� ZdS ) �StubHTTPProtocolaR
A protocol like L{HTTP11ClientProtocol} but which does not actually know
HTTP/1.1 and only collects requests in a list.
@ivar requests: A C{list} of two-tuples. Each time a request is made, a
tuple consisting of the request and the L{Deferred} returned from the
request method is appended to this list.
�returnNc C s g | _ d| _d S )N� QUIESCENT)�requests�state�rR rS rS rT �__init__y rV zStubHTTPProtocol.__init__c C s t � }| j�||f� |S )z�
Capture the given request for later inspection.
@return: A L{Deferred} which this code will never fire.
)r r] �append)rR �request�resultrS rS rT rb } s zStubHTTPProtocol.request�r[ N)rW rX rY �__doc__r` rb rS rS rS rT rZ o s
rZ c @ s e Zd Zdd� Zdd� ZdS )� FileConsumerc C s
|| _ d S �N)�
outputFile)rR rh rS rS rT r` � s
zFileConsumer.__init__c C � | j �|� d S rg )rh �write)rR �bytesrS rS rT rj � � zFileConsumer.writeN)rW rX rY r` rj rS rS rS rT rf � s rf c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd S ) �FileBodyProducerTestszq
Tests for the L{FileBodyProducer} which reads bytes from a file and writes
them to an L{IConsumer}.
c C s dd� S )al
This method can be used as the C{terminationPredicateFactory} for a
L{Cooperator}. It returns a predicate which immediately returns
C{False}, indicating that no more work should be done this iteration.
This has the result of only allowing one iteration of a cooperative
task to be run per L{Cooperator} iteration.
c S � dS rO rS rS rS rS rT �<lambda>� � z4FileBodyProducerTests._termination.<locals>.<lambda>rS r_ rS rS rT � _termination� s z"FileBodyProducerTests._terminationc C s g | _ t�| j| j j�| _dS )z�
Create a L{Cooperator} hooked up to an easily controlled, deterministic
scheduler to use with L{FileBodyProducer}.
N)�
_scheduledr �
Cooperatorrq ra �
cooperatorr_ rS rS rT �setUp� s zFileBodyProducerTests.setUpc C s | � ttttd���� dS )zI
L{FileBodyProducer} instances provide L{IBodyProducer}.
� N)�
assertTruer rC r8 r r_ rS rS rT �test_interface� s z$FileBodyProducerTests.test_interfacec C sP G dd� d�}G dd� d�}t |� �}| �t|j� t |� �}| �t|j� dS )z�
If the L{FileBodyProducer} is constructed with a file-like object
without either a C{seek} or C{tell} method, its C{length} attribute is
set to C{UNKNOWN_LENGTH}.
c @ � e Zd Zdd� ZdS )z9FileBodyProducerTests.test_unknownLength.<locals>.HasSeekc S � d S rg rS )rR �offset�whencerS rS rT �seek� � z>FileBodyProducerTests.test_unknownLength.<locals>.HasSeek.seekN)rW rX rY r} rS rS rS rT �HasSeek� � r c @ ry )z9FileBodyProducerTests.test_unknownLength.<locals>.HasTellc S rz rg rS r_ rS rS rT �tell� r~ z>FileBodyProducerTests.test_unknownLength.<locals>.HasTell.tellN)rW rX rY r� rS rS rS rT �HasTell� r� r� N)r8 � assertEqualr@ �length)rR r r� �producerrS rS rT �test_unknownLength� s
z(FileBodyProducerTests.test_unknownLengthc C sH d}t |�}|�d� t|�}| �t|�d |j� | �|�� d� dS )z�
If the L{FileBodyProducer} is constructed with a file-like object with
both C{seek} and C{tell} methods, its C{length} attribute is set to the
size of the file as determined by those methods.
s here are some bytes� N)r r} r8 r� �lenr� r� )rR �
inputBytes� inputFiler� rS rS rT �test_knownLength� s
z&FileBodyProducerTests.test_knownLengthc C s t td��}| �tj|j� dS )zw
If no L{Cooperator} instance is passed to L{FileBodyProducer}, the
global cooperator is used.
rv N)r8 r r� r � cooperate�
_cooperate)rR r� rS rS rT �test_defaultCooperator� s z,FileBodyProducerTests.test_defaultCooperatorc C s� d}d}t � }t|�}tt |�| j|�}|�|�}tt|�| d �D ] }| j�d�� q#| � g | j� | � ||�
� � | � d| � |�� dS )z�
L{FileBodyProducer.startProducing} starts writing bytes from the input
file to the given L{IConsumer} and returns a L{Deferred} which fires
when they have all been written.
� hello, world� � r N) r rf r8 rt �startProducing�ranger� rr �popr� �getvalue�successResultOf)rR �expectedResult�readSize�output�consumerr� �complete�irS rS rT �test_startProducing� s
z)FileBodyProducerTests.test_startProducingc C sj d}d}t |�}t|| j|�}tt � �}|�|� tt|�| d �D ] }| j�d�� q#| � |j
� dS )z
When L{FileBodyProducer} reaches end-of-file on the input file given to
it, the input file is closed.
� s some friendly bytes� r N) r r8 rt rf r� r� r� rr r� rw �closed)rR r� r� r� r� r� r� rS rS rT �test_inputClosedAtEOF� s
z+FileBodyProducerTests.test_inputClosedAtEOFc C sN G dd� d�}t |� | j�}|�tt� ��}| j�d�� | �|��t � dS )z�
If a read from the input file fails while producing bytes to the
consumer, the L{Deferred} returned by
L{FileBodyProducer.startProducing} fires with a L{Failure} wrapping
that exception.
c @ ry )zGFileBodyProducerTests.test_failedReadWhileProducing.<locals>.BrokenFilec S � t d��)NzSimulated bad thing)�OSError)rR �countrS rS rT �read � zLFileBodyProducerTests.test_failedReadWhileProducing.<locals>.BrokenFile.readN)rW rX rY r� rS rS rS rT �
BrokenFile r� r� r N)
r8 rt r� rf r rr r� �failureResultOf�trap�IOError)rR r� r� r� rS rS rT � test_failedReadWhileProducing� s
z3FileBodyProducerTests.test_failedReadWhileProducingc C sv d}d}t � }t|�}t |�}t|| j|�}|�|�}|�� | �|j� | j� d�� | �
d|� � � | � |� dS )z�
When the L{Deferred} returned by L{FileBodyProducer.startProducing} is
cancelled, the input file is closed and the task is stopped.
r� r� r rv N)
r rf r8 rt r� �cancelrw r� rr r� r� r� �assertNoResult�rR r� r� r� r� r� r� r� rS rS rT �test_cancelWhileProducing s
z/FileBodyProducerTests.test_cancelWhileProducingc C sv d}d}t � }t|�}t |�}t|| j|�}|�|�}|�� | �|j� | j� d�� | �
d|� � � | � |� dS )a
L{FileBodyProducer.stopProducing} stops the underlying L{IPullProducer}
and the cooperative task responsible for calling C{resumeProducing} and
closes the input file but does not cause the L{Deferred} returned by
C{startProducing} to fire.
r� r� r rv N�
r rf r8 rt r� �
stopProducingrw r� rr r� r� r� r� r� rS rS rT �test_stopProducing s
z(FileBodyProducerTests.test_stopProducingc C s� d}d}t � }t|�}tt |�| j|�}|�|�}| j�d�� | �|�� |dd� � |� � | j�d�� | �|�� |dd� � | �g | j� | �
|� dS )z�
L{FileBodyProducer.pauseProducing} temporarily suspends writing bytes
from the input file to the given L{IConsumer}.
r� r� r N) r rf r8 rt r� rr r� r� r� �pauseProducingr� )rR r� r� r� r� r� r� rS rS rT �test_pauseProducing/ s
z)FileBodyProducerTests.test_pauseProducingc C s� d}d}t � }t|�}tt |�| j|�}|�|� | j�d�� | �|d|� |�� � |� � |�
� | j�d�� | �|d|d � |�� � dS )z�
L{FileBodyProducer.resumeProducing} re-commences writing bytes from the
input file to the given L{IConsumer} after it was previously paused
with L{FileBodyProducer.pauseProducing}.
r� r� r Nr� ) r rf r8 rt r� rr r� r� r� r� �resumeProducing)rR r� r� r� r� r� rS rS rT �test_resumeProducingI s
z*FileBodyProducerTests.test_resumeProducingc C s~ d}d}t � }t|�}t |�}t|| j|�}|�|�}|�� |�� | �|j� | j� d�� | �
d|� � � | � |� dS )zv
L{FileBodyProducer.stopProducing} can be called more than once without
raising an exception.
s testr� r rv Nr� r� rS rS rT �test_multipleStop\ s
z'FileBodyProducerTests.test_multipleStopN)rW rX rY re rq ru rx r� r� r� r� r� r� r� r� r� r� r� rS rS rS rT rm � s
rm � 127.0.0.7�::7z 127.0.0.8z 127.0.0.9z
127.0.0.10z
127.0.0.11c @ s6 e Zd ZdZdd� ZG dd� d�Zdd� Zdd � Zd
S ) �FakeReactorAndConnectMixinz�
A test mixin providing a testable C{Reactor} class and a dummy C{connect}
method which allows instances to pretend to be endpoints.
c C sH t � }t|tgtgtgtgtgtgdgdgd�d�}|j|_|j |_ |S )af
Create a L{MemoryReactorClock} and give it some hostnames it can
resolve.
@return: a L{MemoryReactorClock}-like object with a slightly limited
interface (only C{advance} and C{tcpClients} in addition to its
formally-declared reactor interfaces), which can resolve a fixed
set of domains.
r� r� )� example.comzipv6.example.comz example.netz example.org�foozfoo.comr� r� )�hostMap)
r' r �EXAMPLE_COM_IP�EXAMPLE_COM_V6_IP�EXAMPLE_NET_IP�EXAMPLE_ORG_IP� FOO_LOCAL_IP�
FOO_COM_IP�
tcpClients�advance)rR �mrc�drrrS rS rT �
createReactor~ s
��z(FakeReactorAndConnectMixin.createReactorc @ s e Zd ZdZdd� Zdd� ZdS )z'FakeReactorAndConnectMixin.StubEndpointz�
Endpoint that wraps existing endpoint, substitutes StubHTTPProtocol, and
resulting protocol instances are attached to the given test case.
c sB |� _ |� _dd� }t|t� j ��� _t� � _� fdd�� j_d S )Nc S rn )zthis function does nothingNrS rS rS rS rT �nothing� rp zAFakeReactorAndConnectMixin.StubEndpoint.__init__.<locals>.nothingc s � j S rg ��protocol)�addrr_ rS rT ro � s zBFakeReactorAndConnectMixin.StubEndpoint.__init__.<locals>.<lambda>)�endpoint�testCaser= �repr�factoryrZ r� �
buildProtocol)rR r� r� r� rS r_ rT r` � s z0FakeReactorAndConnectMixin.StubEndpoint.__init__c C s" | j | j_ | j�| j� t| j �S rg )r� r� r� �connectr� r )rR �ignoredFactoryrS rS rT r� � s
z/FakeReactorAndConnectMixin.StubEndpoint.connectN)rW rX rY re r` r� rS rS rS rT � StubEndpoint� s r� c s$ t �|�}|j� � �fdd�|_|S )z�
Return an Agent suitable for use in tests that wrap the Agent and want
both a fake reactor and StubHTTPProtocol.
c s �� � | � ��S rg )r� ��args��_oldGetEndpointrR rS rT ro � rl zEFakeReactorAndConnectMixin.buildAgentForWrapperTest.<locals>.<lambda>)r, �Agent� _getEndpoint)rR �reactor�agentrS r� rT �buildAgentForWrapperTest� s
z3FakeReactorAndConnectMixin.buildAgentForWrapperTestc C s t � }|�d� || _t|�S )z�
Fake implementation of an endpoint which synchronously
succeeds with an instance of L{StubHTTPProtocol} for ease of
testing.
N)rZ �makeConnectionr� r �rR r� r� rS rS rT r� � s
z"FakeReactorAndConnectMixin.connectN)rW rX rY re r� r� r� r� rS rS rS rT r� x s r� c @ � e Zd ZdZdd� ZdS )�
DummyEndpointz1
An endpoint that uses a fake transport.
c C � |� d �}|�t� � t|�S rg �r� r� r( r r� rS rS rT r� � �
zDummyEndpoint.connectN�rW rX rY re r� rS rS rS rT r� � � r� c @ r� )� BadEndpointz/
An endpoint that shouldn't be called.
c C r� )Nz(This endpoint should not have been used.)� RuntimeError�rR r� rS rS rT r� � r� zBadEndpoint.connectNr� rS rS rS rT r� � r� r� c @ s e Zd ZdZdd� ZeZdS )� DummyFactoryz/
Create C{StubHTTPProtocol} instances.
c C rz rg rS )rR �quiescentCallback�metadatarS rS rT r` � r~ zDummyFactory.__init__N)rW rX rY re r` rZ r� rS rS rS rT r� � s r� c @ sp e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� ZdS )�HTTPConnectionPoolTestsz4
Tests for the L{HTTPConnectionPool} class.
c C s* | � � | _t| j�| _t| j_d| j_d S �NF)r� � fakeReactorr: �poolr� �_factory�retryAutomaticallyr_ rS rS rT ru � s
z HTTPConnectionPoolTests.setUpc s: � � � jji � � fdd�}d}� j�|t� �}|�|�S )z{
If there are no cached connections,
L{HTTPConnectionPool.getConnection} returns a new connection.
c s$ � � | t� � �| � jj�� � d S rg )�assertIsInstancerZ � assertNotInr� � _connections�values��connr_ rS rT �
gotConnection� s zMHTTPConnectionPoolTests.test_getReturnsNewIfCacheEmpty.<locals>.gotConnection��/ )r� r� r� �
getConnectionr� � addCallback)rR r� �
unknownKey�drS r_ rT � test_getReturnsNewIfCacheEmpty� s
z6HTTPConnectionPoolTests.test_getReturnsNewIfCacheEmptyc C s� t � }|�t� � | j�d|� | �|jjd� | �|| jj d � | j
� d� | �|jjd� | �|| jj d � | �|| jj � | j
� d� | �|jjd� | �
|| jj d � | �
|| jj � dS )z�
If a connection is put back to the pool, a 240-sec timeout is started.
When the timeout hits, the connection is closed and removed from the
pool.
��http� example.com�P F�� g�������?TN)rZ r� r( r� �_putConnectionr� � transport�
disconnecting�assertInr� r� r� � _timeoutsr� �rR r� rS rS rT �test_putStartsTimeout s z-HTTPConnectionPoolTests.test_putStartsTimeoutc C s� | j }t� t� g}|D ]}|�t� � |�d|� q | �|jd |� |j�� }t� }|�t� � |�d|� |jd }| �t |�d� | �||d |g� | �dd� |D �ddg� | �|d j
j d� | � ||d j
� | �|d |j� d S )
z�
If an idle connection is put back in the cache and the max number of
persistent connections has been exceeded, one of the connections is
closed and removed from the cache.
r r� r� c S s g | ]}|j j�qS rS )r r )�.0�prS rS rT �
<listcomp>; � zHHTTPConnectionPoolTests.test_putExceedsMaxPersistent.<locals>.<listcomp>Fr TN)r� rZ r� r( r r� r� r �copyr� r r rw � cancelledr� )rR r� �
origCachedr
�timeouts� newProtocol� newCachedrS rS rT � test_putExceedsMaxPersistent" s"
z4HTTPConnectionPoolTests.test_putExceedsMaxPersistentc s� � fdd�}g }|� |ddd�� |� |ddd�� |ddd� |ddd� � �� jjd |� � �t� jjd
�d � � �t� jjd �d � d
S )z�
C{maxPersistentPerHost} is enforced per C{(scheme, host, port)}:
different keys have different max connections.
c s* t � }|�t� � � j�| ||f|� |S rg )rZ r� r( r� r ��scheme�host�portr
r_ rS rT � addProtocolF s zFHTTPConnectionPoolTests.test_maxPersistentPerHost.<locals>.addProtocolr r r �https� � www2.example.comr )r r r r� )r r r N)ra r� r� r� r� )rR r �
persistentrS r_ rT �test_maxPersistentPerHost@ s ��z1HTTPConnectionPoolTests.test_maxPersistentPerHostc sD t � � � �t� � �j�d� � � �fdd�}�j�dt� ��|�S )z�
Getting an address which has a cached connection returns the cached
connection, removes it from the cache and cancels its timeout.
r c sP �� � | � ��| �jjd � �j�d� ��| jjd� ��| �jj � d S )Nr �� F)
�assertIdenticalr� r� r� r� r� r� r r r r� �r� rR rS rT r� d s
zGHTTPConnectionPoolTests.test_getCachedConnection.<locals>.gotConnection)rZ r� r( r� r r� r� r� )rR r� rS r# rT �test_getCachedConnectionZ s ��z0HTTPConnectionPoolTests.test_getCachedConnectionc sN t � ���t� � d� �j�� �� � ��fdd�}�j�� t� �}|�|�S )zR
The pool's C{_newConnection} method constructs a new connection.
r� c s8 �� �| � ����jj� � ��| �jj�� � d S rg )�assertNotIdenticalr r� r� r� r� )�
newConnection��keyr� rR rS rT r� | s zAHTTPConnectionPoolTests.test_newConnection.<locals>.gotConnection)rZ r� r( r� r �_newConnectionr� r� )rR r� r� rS r' rT �test_newConnectionr s
z*HTTPConnectionPoolTests.test_newConnectionc C s� | j }d}t� t� g}|D ]}|�t� � |�||� q
| �|j| |� d|d _g }| j �|t � ��
|j � | � |d |d � | �|j| g � | �|j
i � dS )z{
When getting connections out of the cache, disconnected connections
are removed and not returned.
r � DISCONNECTEDr r� N)r� rZ r� r( r r� r� r^ r� r� r� ra r" r )rR r� r( r r
rc rS rS rT �test_getSkipsDisconnected� s
z1HTTPConnectionPoolTests.test_getSkipsDisconnectedc C s� t � }| �|jd� t�| t�}d|_| j�d|� | �dt |�� |d }|d }| �
|j t � | �|�
� d� | �d| jj�d�� | �t � dS ) ze
If a non-quiescent connection is put back in the cache, an error is
logged.
r\ � NOTQUIESCENTr r� r � log_failurez5BUG: Non-quiescent protocol added to connection pool.N)rZ r� r^ r& �createWithCleanupr r� r � assertEqualsr� r� �valuer� �getErrorMessager" r� �get�flushLoggedErrors)rR r� � logObserver�event�frS rS rT �test_putNotQuiescent� s ��z,HTTPConnectionPoolTests.test_putNotQuiescentc C s� G dd� d�}t | jd�}d|_g }d}|�||� ��|j� |d }| �|t� d|_|� |� g }|�||� ��|j� | �
|d |� dS ) aI
When L{HTTPConnectionPool.getConnection} connects, it returns a
C{Deferred} that fires with an instance of L{HTTP11ClientProtocol}
that has the correct quiescent callback attached. When this callback
is called the protocol is returned to the cache correctly, using the
right key.
c @ ry )zMHTTPConnectionPoolTests.test_getUsesQuiescentCallback.<locals>.StringEndpointc S r� rg r� )rR r� r
rS rS rT r� � r� zUHTTPConnectionPoolTests.test_getUsesQuiescentCallback.<locals>.StringEndpoint.connectN�rW rX rY r� rS rS rS rT �StringEndpoint� r� r: TFza keyr r\ N) r: r� r� r� r� ra r� r/ �_state�_quiescentCallbackr" )rR r: r� rc r( r� �result2rS rS rT � test_getUsesQuiescentCallback� s
z5HTTPConnectionPoolTests.test_getUsesQuiescentCallbackc s� g � � �fdd�}|ddd� |ddd� �j �� }� D ]
}��|jjd� q ���j ji � �j�� D ] }��|jd� q4���j j i � g }|�
|j � ��|g � � d � t
t� �� ��|g � � d � t
t� �� ��|d
g� d
S ) z�
L{HTTPConnectionPool.closeCachedConnections} closes all cached
connections and removes them from the cache. It returns a Deferred
that fires when they have all lost their connections.
c s4 t � }|�t� � �j�| ||f|� � �|� d S rg )r/ r� r( r� r ra r �r rR rS rT r � s zHHTTPConnectionPoolTests.test_closeCachedConnections.<locals>.addProtocolr r r r Tr r� N)r� �closeCachedConnectionsr� r r r� r� �getDelayedCallsr r r� ra �connectionLostr" r )rR r � doneDeferredr
�dcrc rS r? rT �test_closeCachedConnections� s$
z3HTTPConnectionPoolTests.test_closeCachedConnectionsc sX | � | jji � t� � G � fdd�d�}| j�d|� �}|�� | � | �� �jt� dS )z�
Cancelling the C{Deferred} returned from
L{HTTPConnectionPool.getConnection} cancels the C{Deferred} returned
by opening a new connection with the given endpoint.
c � e Zd Z� fdd�ZdS )zXHTTPConnectionPoolTests.test_cancelGetConnectionCancelsEndpointConnect.<locals>.Endpointc � � S rg rS r� ��connectionResultrS rT r� r~ z`HTTPConnectionPoolTests.test_cancelGetConnectionCancelsEndpointConnect.<locals>.Endpoint.connectNr9 rS rH rS rT �Endpoint s rJ i90 N) r� r� r� r r� r� r� �typer )rR rJ r� rS rH rT �.test_cancelGetConnectionCancelsEndpointConnect s zFHTTPConnectionPoolTests.test_cancelGetConnectionCancelsEndpointConnectN)rW rX rY re ru r� r r r r$ r* r, r8 r> rE rL rS rS rS rT r� � s # $r� c @ r� )�AgentTestsMixinz1
Tests for any L{IAgent} implementation.
c C s | � tt| �� �� dS )z6
The agent object provides L{IAgent}.
N)rw r rA � makeAgentr_ rS rS rT rx s z AgentTestsMixin.test_interfaceN)rW rX rY re rx rS rS rS rT rM r� rM c @ sF e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � ej d fd
d�Z
dS )�IntegrationTestingMixinzG
Transport-to-Agent integration tests for both HTTP and HTTPS.
c C � | � dtt� dS )z+
L{Agent} works over IPv4.
r N)�integrationTestr� r r_ rS rS rT �test_integrationTestIPv4( � z0IntegrationTestingMixin.test_integrationTestIPv4c C � | � ddt� dS )zL
L{Agent} works over IPv4 when hostname is an IPv4 address.
s 127.0.0.7r� N)rQ r r_ rS rS rT � test_integrationTestIPv4Address. rS z7IntegrationTestingMixin.test_integrationTestIPv4Addressc C rP )z+
L{Agent} works over IPv6.
s ipv6.example.comN)rQ r� r r_ rS rS rT �test_integrationTestIPv64 rS z0IntegrationTestingMixin.test_integrationTestIPv6c C rT )zL
L{Agent} works over IPv6 when hostname is an IPv6 address.
s [::7]r� N)rQ r r_ rS rS rT � test_integrationTestIPv6Address: rS z7IntegrationTestingMixin.test_integrationTestIPv6Addressc C s | S rg rS ��serverrS rS rT ro E rp z IntegrationTestingMixin.<lambda>� httpc sp | � � }||�}|�d|d | d �} |jd \}
} } }
}| �|
|� |d|
| �}| �|�}t|d|d�}|�|� tj� fdd ��� d
� _ d
� _
|� ��d
�}t|d �}|�|� t ||||d�}|� � | �
| � � j j�d �}| �|d �d
�|d � tdd� |dd
� D ��}| �|d |� | �
| � � j j�d� |� � | �| �}| �|j�d�d d� d
S )a�
L{Agent} will make a TCP connection, send an HTTP request, and return a
L{Deferred} that fires when the response has been received.
@param hostName: The hostname to interpolate into the URL to be
requested.
@type hostName: L{bytes}
@param expectedAddress: The expected address string.
@type expectedAddress: L{bytes}
@param addressType: The class to construct an address out of.
@type addressType: L{type}
@param serverWrapper: A callable that takes a protocol factory and
returns a protocol factory; used to wrap the server / responder
side in a TLS server.
@type serverWrapper:
serverWrapper(L{twisted.internet.interfaces.IProtocolFactory}) ->
L{twisted.internet.interfaces.IProtocolFactory}
@param createAgent: A callable that takes a reactor and produces an
L{IAgent}; used to construct an agent with an appropriate trust
root for TLS.
@type createAgent: createAgent(reactor) -> L{IAgent}
@param scheme: The scheme to test, C{http} or C{https}
@type scheme: L{bytes}
� GET� ://� /r �TCPF)� peerAddressc s t � } | � _| S rg )r% �currentProtocol)�ap�� accumulatorrS rT rc p s z<IntegrationTestingMixin.integrationTest.<locals>.accumulatorNTs
s
GET / HTTPc S s g | ]
}|r|� d d��qS )s : r� )�split)r �linerS rS rT r � s z;IntegrationTestingMixin.integrationTest.<locals>.<listcomp>r� � HostsL HTTP/1.1 200 OK
X-An-Header: an-value
Content-length: 12
hello world!s x-an-headers an-value)r� rb r� r� r� r# r� r � forProtocolr` �protocolConnectionMader$ �flushr� �datard rw �
startswith�dictr rj r� r0 �headers�
getRawHeaders)rR �hostName�expectedAddress� addressType�
serverWrapper� createAgentr r� r� �deferredr r r� �timeout�bindr_ �clientProtocol�clientTransport�wrapper�serverTransport�pump�linesrm �responserS rb rT rQ @ s@ &
�
�z'IntegrationTestingMixin.integrationTestN) rW rX rY re rR rU rV rW r, r� rQ rS rS rS rT rO # s �rO c @ r� )�StubEndpointFactoryz=
A stub L{IAgentEndpointFactory} for use in testing.
c C s |j |j|jfS )z�
Testing implementation.
@param uri: A L{URI}.
@return: C{(scheme, host, port)} of passed in URI; violation of
interface but useful for testing.
@rtype: L{tuple}
)r r r �rR �urirS rS rT �endpointForURI� s
z"StubEndpointFactory.endpointForURIN)rW rX rY re r� rS rS rS rT r~ � s r~ c @ s e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zee d,�d-d.� �Zd/d0� Z ee d,�d1d2� �Z d3d4� Z d5d6� Z d7d8� Z d9d:� Z!d;d<� Z"d=d>� Z#d?S )@�
AgentTestszA
Tests for the new HTTP client API provided by L{Agent}.
c C s t �| j�S )zE
@return: a new L{twisted.web.client.Agent} instance
)r, r� r� r_ rS rS rT rN � s zAgentTests.makeAgentc C s | � � | _| �� | _dS ��C
Create an L{Agent} wrapped around a fake reactor.
N�r� r� rN r� r_ rS rS rT ru � s
zAgentTests.setUpc C s@ t �| j�}| �|jt� | �|jjd� | �|j |jj � dS )zV
If no pool is passed in, the L{Agent} creates a non-persistent pool.
FN)
r, r� r� r� �_poolr: r� r r" �_reactor�rR r� rS rS rT �test_defaultPool� s zAgentTests.test_defaultPoolc sR t � j�}tj� j|d�}� fdd�|_|�dd� � �� jjd d j d� dS ) z�
If C{persistent} is set to C{True} on the L{HTTPConnectionPool} (the
default), C{Request}s are created with their C{persistent} flag set to
C{True}.
�r� c rG rg rS r� r_ rS rT ro � rp z,AgentTests.test_persistent.<locals>.<lambda>r[ � http://127.0.0.1r TN�
r: r� r, r� r� rb r� r� r] r �rR r� r� rS r_ rT �test_persistent� s
zAgentTests.test_persistentc sV t � jdd�}tj� j|d�}� fdd�|_|�dd� � �� jjd d j d� d S )
a�
If C{persistent} is set to C{False} when creating the
L{HTTPConnectionPool}, C{Request}s are created with their
C{persistent} flag set to C{False}.
Elsewhere in the tests for the underlying HTTP code we ensure that
this will result in the disconnection of the HTTP protocol once the
request is done, so that the connection will not be returned to the
pool.
F�r r� c rG rg rS r� r_ rS rT ro � rp z/AgentTests.test_nonPersistent.<locals>.<lambda>r[ r� r Nr� r� rS r_ rT �test_nonPersistent� s
z AgentTests.test_nonPersistentc s� t � � G � �fdd�dtj�}G � �fdd�d�}|� }|�j|d�}��||j� t�� }|�dd� t � }|j
dd ||d
� �� |jj d � d S )
z�
When a connection is made by the Agent, it uses its pool's
C{getConnection} method to do so, with the endpoint returned by
C{self._getEndpoint}. The key used is C{(scheme, host, port)}.
c s e Zd Z� �fdd�ZdS )z:AgentTests.test_connectUsesConnectionPool.<locals>.MyAgentc s �� |j|j|jfd� � S )N�rZ � foor )r� r r r )�thisr� �r� rR rS rT r� � s �zGAgentTests.test_connectUsesConnectionPool.<locals>.MyAgent._getEndpointN)rW rX rY r� rS r� rS rT �MyAgent� s r� c �" e Zd ZdZdZ� �fdd�ZdS )z<AgentTests.test_connectUsesConnectionPool.<locals>.DummyPoolFc s* d| _ ��|� � ��|d� t�t� �S )NTr� )� connectedr� r r rZ �r� r( �epr� rS rT r� � s zJAgentTests.test_connectUsesConnectionPool.<locals>.DummyPool.getConnectionN�rW rX rY r� r r� rS r� rS rT � DummyPool� � r� r� � hostr� r[ � http://foo/)� bodyProducerrm TN)
r� r, r� r� r" r� r. r? � addRawHeader�objectrb r� r� )rR r� r� r� r� rm r� rS r� rT � test_connectUsesConnectionPool� s �z)AgentTests.test_connectUsesConnectionPoolc C � | � t| jjdd� dS )zj
L{Agent.request} raises L{TypeError} when the C{method} argument isn't
L{bytes}.
�GET� http://foo.example/N�� assertRaises� TypeErrorr� rb r_ rS rS rT �test_nonBytesMethod � z AgentTests.test_nonBytesMethodc C s | � | j�dd�t�S )z�
L{Agent.request} returns a L{Deferred} which fails with
L{SchemeNotSupported} if the scheme of the URI passed to it is not
C{'http'}.
r[ s mailto:alice@example.com)�
assertFailurer� rb r> r_ rS rS rT �test_unsupportedScheme s �z!AgentTests.test_unsupportedSchemec C sV | j �dd�}| jj�� dd� \}}}|�dtt� �� | j�d� | � |t� dS )z�
The L{Deferred} returned by L{Agent.request} fires with a L{Failure} if
the TCP connection attempt fails.
r[ r� Nr� �
)
r� rb r� r� r� �clientConnectionFailedr" r r� r� )rR rc r r r� rS rS rT �test_connectionFailed s
z AgentTests.test_connectionFailedc C sN d}d}| j �t�d||f ��}| �|jd� | �|j|� | �|t� dS )zo
L{Agent._getEndpoint} return a C{HostnameEndpoint} when passed a scheme
of C{'http'}.
r �� s http://%b:%dr� N) r� r� r6 � fromBytesr� �_hostStr�_portr� r )rR � expectedHost� expectedPortr� rS rS rT �test_connectHTTP" s �zAgentTests.test_connectHTTPc C sp t �d�}d�� |_| �t��}| j�|� W d � n1 s w Y | �|j j
d dj t |j�d�� dS )z|
L{Agent._getEndpoint} when given a non-ASCII decodable URI will raise a
L{ValueError} saying such.
s http://example.com:80u ☃.comNr zaThe host of the provided URI ({reprout}) contains non-ASCII octets, it should be ASCII decodable.)�reprout)
r6 r� �encoder r� �
ValueErrorr� r� r� � exceptionr� �formatr� )rR r� �erS rS rT �test_nonDecodableURI0 s
�
��z AgentTests.test_nonDecodableURIc �H � fdd�� j _� j �dd� � jj�� \}}� �|j�d�dg� dS )z�
If L{None} is passed to L{Agent.request} for the C{headers} parameter,
a L{Headers} instance is created for the request and a I{Host} header
added to it.
c rG rg rS r� r_ rS rT ro J rp z.AgentTests.test_hostProvided.<locals>.<lambda>r[ � http://example.com/foo?barr� r N� r� r� rb r� r] r� r� rm rn �rR �req�resrS r_ rT �test_hostProvidedD s z AgentTests.test_hostProvidedc r� )z�
If an IPv6 address is used in the C{uri} passed to L{Agent.request},
the computed I{Host} header needs to be bracketed.
c rG rg rS r� r_ rS rT ro U rp z3AgentTests.test_hostIPv6Bracketed.<locals>.<lambda>r[ s
http://[::1]/r� s [::1]Nr� r� rS r_ rT �test_hostIPv6BracketedP s z!AgentTests.test_hostIPv6Bracketedc s^ t �dgdgd��}� fdd�� j_� j�dd|� � jj�� \}}� �|j �
d�dg� d S )
z�
If the headers passed to L{Agent.request} includes a value for the
I{Host} header, that value takes precedence over the one which would
otherwise be automatically provided.
� bars quux�r� r� c rG rg rS r� r_ rS rT ro b rp z.AgentTests.test_hostOverride.<locals>.<lambda>r[ r� r� N) r. r? r� r� rb r� r] r� r� rm rn )rR rm r� r� rS r_ rT �test_hostOverride[ s
z AgentTests.test_hostOverridec sT t �� }� fdd�� j_� j�dd|� � j}� �t|j�d� � �|t �� � dS )z�
If a I{Host} header must be added to the request, the L{Headers}
instance passed to L{Agent.request} is not modified.
c rG rg rS r� r_ rS rT ro n rp z3AgentTests.test_headersUnmodified.<locals>.<lambda>r[ � http://example.com/foor� N) r. r? r� r� rb r� r� r� r] )rR rm r� rS r_ rT �test_headersUnmodifiedh s z!AgentTests.test_headersUnmodifiedc C � | � | j�ddd�d� dS )z�
When passed a scheme of C{'http'} and a port of C{80},
L{Agent._computeHostValue} returns a string giving just
the host name passed to it.
rZ r r N�r� r� �_computeHostValuer_ rS rS rT �test_hostValueStandardHTTPx � �z%AgentTests.test_hostValueStandardHTTPc C � | � | j�ddd�d� dS )z�
When passed a scheme of C{'http'} and a port other than C{80},
L{Agent._computeHostValue} returns a string giving the
host passed to it joined together with the port number by C{":"}.
rZ r �1� � example.com:54321Nr� r_ rS rS rT � test_hostValueNonStandardHTTP� � �z(AgentTests.test_hostValueNonStandardHTTPc C r� )z�
When passed a scheme of C{'https'} and a port of C{443},
L{Agent._computeHostValue} returns a string giving just
the host name passed to it.
� httpsr r Nr� r_ rS rS rT �test_hostValueStandardHTTPS� r� z&AgentTests.test_hostValueStandardHTTPSc C r� )z�
When passed a scheme of C{'https'} and a port other than C{443},
L{Agent._computeHostValue} returns a string giving the
host passed to it joined together with the port number by C{":"}.
r� r r� r� Nr� r_ rS rS rT � test_hostValueNonStandardHTTPS� r� z)AgentTests.test_hostValueNonStandardHTTPSc s� � fdd�� j _t�ddgi�}t� }� j �dd||� � j}� �t|j �d� |j �
� \}}� � |t � � �|j
d� � �|jd� � �|jt�dgd gd
��� � �|j|� d S ) a_
L{Agent.request} establishes a new connection to the host indicated by
the host part of the URI passed to it and issues a request using the
method, the path portion of the URI, the headers, and the body producer
passed to it. It returns a L{Deferred} which fires with an
L{IResponse} from the server.
c rG rg rS r� r_ rS rT ro � rp z)AgentTests.test_request.<locals>.<lambda>r� r� r[ � http://example.com:1234/foo?barr� s /foo?bar� example.com:1234r� N)r� r� r. r? r� rb r� r� r� r] r� r� r; �methodr� rm r" r� )rR rm �bodyr� r� r� rS r_ rT � test_request� s �zAgentTests.test_requestc C �< t j| jdd�}|�dd� | jj�� d }| �d|� dS )z~
L{Agent} takes a C{connectTimeout} argument which is forwarded to the
following C{connectTCP} agent.
r� ��connectTimeoutr[ r� r� N�r, r� r� rb r� r� r� �rR r� ru rS rS rT �test_connectTimeout� � z AgentTests.test_connectTimeout�&SSL not present, cannot run SSL tests.c C r� )z}
L{Agent} takes a C{connectTimeout} argument which is forwarded to the
following C{connectTCP} call.
r� r� r[ � https://foo/r� Nr� r� rS rS rT �test_connectTimeoutHTTPS� � z#AgentTests.test_connectTimeoutHTTPSc C r� )zz
L{Agent} takes a C{bindAddress} argument which is forwarded to the
following C{connectTCP} call.
� 192.168.0.1�� bindAddressr[ r� r� Nr� �rR r� �addressrS rS rT �test_bindAddress� r� zAgentTests.test_bindAddressc C r� )zz
L{Agent} takes a C{bindAddress} argument which is forwarded to the
following C{connectSSL} call.
r� r� r[ r� r� Nr� r� rS rS rT �test_bindAddressSSL� r� z AgentTests.test_bindAddressSSLc C s� d}| � | j�}|�d|�}| �t| jj�d� | jj�� \}}| �|t � t
j � dddt
�
i �d|�}|�|� | �|�}| �|jj|jj|jjf|j|j|jf� dS )z�
L{Response}s returned by L{Agent.request} have a reference to the
L{Request} that was originally issued.
� http://example.com/r[ r� �s HTTPr� r� �� � OKN)r� r� rb r� r� r� r] r� r� r; r, r3 �
_constructr? �callbackr� r� � absoluteURIrm )rR r� r� r� r� r� �respr} rS rS rT � test_responseIncludesRequest� s$ �
��z'AgentTests.test_responseIncludesRequestc C s^ d}| � | j�}|�d|� | �t| jj�d� | jj�� \}}| �|t � | �|j
|� dS )zL
L{Request.absoluteURI} is the absolute URI of the request.
s$ http://example.com/foo;1234?bar#fragr[ r� N) r� r� rb r� r� r� r] r� r� r; r� )rR r� r� r� r� rS rS rT �test_requestAbsoluteURI s z"AgentTests.test_requestAbsoluteURIc C s& t �ddt �� d�}| �|jd� dS )zX
L{Request.absoluteURI} is L{None} if L{Request._parsedURI} is L{None}.
� FOOr] N)r, r; r? r" r� )rR rb rS rS rT � test_requestMissingAbsoluteURI s z)AgentTests.test_requestMissingAbsoluteURIc C s: t � }tjjd|d�}t�d�}|�|�}| �|d� dS )z|
L{Agent.usingEndpointFactory} creates an L{Agent} that uses the given
factory to create endpoints.
N)�endpointFactoryr� )rZ r r )r~ r, r� �usingEndpointFactoryr6 r� r� r� )rR r� r� r� �returnedEndpointrS rS rT �test_endpointFactory s
z AgentTests.test_endpointFactoryc C s< t j�| jt� �}|j}| �|j|j|j ft
d|j f� dS )z�
If no pool is passed in to L{Agent.usingEndpointFactory}, a default
pool is constructed with no persistent connections.
FN) r, r� r� r� r~ r� r� � __class__r r� r: )rR r� r� rS rS rT � test_endpointFactoryDefaultPool' s
�z*AgentTests.test_endpointFactoryDefaultPoolc C s, t � }tj�| jt� |�}| �||j� dS )zr
If a pool is passed in to L{Agent.usingEndpointFactory} it is used as
the L{Agent} pool.
N)r� r, r� r� r� r~ �assertIsr� r� rS rS rT �test_endpointFactoryPool3 s
�z#AgentTests.test_endpointFactoryPoolN)$rW rX rY re rN ru r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r �
sslPresentr� r� r� r� r� r� r� r r rS rS rS rT r� � sD '
r� c @ r� )�AgentMethodInjectionTestsz>
Test L{client.Agent} against HTTP method injections.
c C s* t �| �� �}d}|�||t �� d� dS )�v
Attempt a request with the provided method.
@param method: see L{MethodInjectionTestsMixin}
� http://twisted.invalidN�r, r� r� rb r? )rR r� r� r� rS rS rT �!attemptRequestWithMaliciousMethodH � z;AgentMethodInjectionTests.attemptRequestWithMaliciousMethodN�rW rX rY re r rS rS rS rT r ? � r c @ r� )�AgentURIInjectionTestsz6
Test L{client.Agent} against URI injections.
c C s* t �| �� �}d}|�||t �� d� dS )zp
Attempt a request with the provided method.
@param uri: see L{URIInjectionTestsMixin}
r[ Nr )rR r� r� r� rS rS rT � attemptRequestWithMaliciousURI\ r z5AgentURIInjectionTests.attemptRequestWithMaliciousURIN�rW rX rY re r
rS rS rS rT r S r r r� c sb e Zd ZdZddd�Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z � fdd�Z � Z
S )�AgentHTTPSTestsz@
Tests for the new HTTP client API that depends on SSL.
r r c C s" t �| �� ��t�d||f ��S )a�
Create an L{Agent} with an https scheme and return its endpoint
created according to the arguments.
@param host: The host for the endpoint.
@type host: L{bytes}
@param port: The port for the endpoint.
@type port: L{int}
@return: An endpoint of an L{Agent} constructed according to args.
@rtype: L{SSL4ClientEndpoint}
s https://%b:%d/)r, r� r� r� r6 r� )rR r r rS rS rT � makeEndpointm s �z AgentHTTPSTests.makeEndpointc C s2 ddl m} | �� }| �||� | �|jt� dS )zr
L{Agent._getEndpoint} return a L{SSL4ClientEndpoint} when passed a
scheme of C{'https'}.
r )�_WrapperEndpointN)�twisted.internet.endpointsr r r� �_wrappedEndpointr )rR r r� rS rS rT �test_endpointType s z!AgentHTTPSTests.test_endpointTypec C s | j dd�}| �|jjd� dS )z@
If a host is passed, the endpoint respects it.
r )r r� N)r r� r r� )rR r� rS rS rT � test_hostArgumentIsRespected� s z,AgentHTTPSTests.test_hostArgumentIsRespectedc C s$ d}| j |d�}| �|jj|� dS )z@
If a port is passed, the endpoint respects it.
�� )r N)r r� r r� )rR r� r� rS rS rT � test_portArgumentIsRespected� s z,AgentHTTPSTests.test_portArgumentIsRespectedc C s2 | � � }|�d�j}| �|t� | �|jd� dS )zY
L{Agent} wraps its connection creator creator and uses modern TLS APIs.
Nr� )r �_wrapperFactory�_connectionCreatorr� rI r� � _hostname)rR r� �contextFactoryrS rS rT �test_contextFactoryType� s z'AgentHTTPSTests.test_contextFactoryTypec s d}d}G dd� d�}g �t t�G ��fdd�d��� |� �t t�G � fdd�d��}|� }| �� }t�||�}|�t�d ||f ��}|� t
� t �� |j
d
d } | �d �}
|
�t� � �d
d
} | �| t� | ��d
dd � ||f� | ��j� | ��j� d S )a�
If a custom L{WebClientConnectionCreator}-like object is passed to
L{Agent.__init__} it will be used to determine the SSL parameters for
HTTPS requests. When an HTTPS request is made, the hostname and port
number of the request URL will be passed to the connection creator's
C{creatorForNetloc} method. The resulting context object will be used
to establish the SSL connection.
s example.orgi�O c @ s$ e Zd ZdZdZdd� Zdd� ZdS )zVAgentHTTPSTests.test_connectHTTPSCustomConnectionCreator.<locals>.JustEnoughConnectionFc S �
d| _ dS )zK
The handshake started. Record that fact.
TN)�handshakeStartedr_ rS rS rT � do_handshake� �
zcAgentHTTPSTests.test_connectHTTPSCustomConnectionCreator.<locals>.JustEnoughConnection.do_handshakec S r )zL
The connection started. Record that fact.
TN)� connectStater_ rS rS rT �set_connect_state� r zhAgentHTTPSTests.test_connectHTTPSCustomConnectionCreator.<locals>.JustEnoughConnection.set_connect_stateN)rW rX rY r r! r r" rS rS rS rT �JustEnoughConnection� s
r# c s" e Zd Zdd� Z� �fdd�ZdS )zSAgentHTTPSTests.test_connectHTTPSCustomConnectionCreator.<locals>.JustEnoughCreatorc S s || _ || _d S rg )�hostnamer �rR r$ r rS rS rT r` � rV z\AgentHTTPSTests.test_connectHTTPSCustomConnectionCreator.<locals>.JustEnoughCreator.__init__c s � � || j| jf� �S )z�
Implement L{IOpenSSLClientConnectionCreator}.
@param tlsProtocol: The TLS protocol.
@type tlsProtocol: L{TLSMemoryBIOProtocol}
@return: C{expectedConnection}
)ra r$ r )rR � tlsProtocol�� contextArgs�expectedConnectionrS rT �clientConnectionForTLS� s zjAgentHTTPSTests.test_connectHTTPSCustomConnectionCreator.<locals>.JustEnoughCreator.clientConnectionForTLSN)rW rX rY r` r* rS r' rS rT �JustEnoughCreator� s r+ c rF )z_AgentHTTPSTests.test_connectHTTPSCustomConnectionCreator.<locals>.StubBrowserLikePolicyForHTTPSc s
� ||�S )am
Emulate L{BrowserLikePolicyForHTTPS}.
@param hostname: The hostname to verify.
@type hostname: L{bytes}
@param port: The port number.
@type port: L{int}
@return: a stub L{IOpenSSLClientConnectionCreator}
@rtype: L{JustEnoughCreator}
rS r% �r+ rS rT �creatorForNetloc� s
zpAgentHTTPSTests.test_connectHTTPSCustomConnectionCreator.<locals>.StubBrowserLikePolicyForHTTPS.creatorForNetlocN�rW rX rY r- rS r, rS rT � StubBrowserLikePolicyForHTTPS� � r/ s
https://%b:%d���r� Nr r� )r r rD r� r, r� r� r6 r� r� r rg r r� r� r� r( r� rM r� rw r r! ) rR r� r� r# r/ �expectedCreatorCreatorr� r� r� �
tlsFactoryr& �tlsrS )r+ r( r) rT �(test_connectHTTPSCustomConnectionCreator� s0 �
z8AgentHTTPSTests.test_connectHTTPSCustomConnectionCreatorc C sT dd� }|� | � |g�}| �t|�d� |\}| �|d t� | �|d d� dS )aP
Passing something that duck-types I{like} a L{web client context
factory <twisted.web.client.WebClientContextFactory>} - something that
does not provide L{IPolicyForHTTPS} - to L{Agent} emits a
L{DeprecationWarning} even if you don't actually C{import
WebClientContextFactory} to do it.
c S s t �tt� �d� d S )Nz does-not-provide-IPolicyForHTTPS)r, r� r r' rS rS rS rT �warnMe� s �z9AgentHTTPSTests.test_deprecatedDuckPolicy.<locals>.warnMer� �category�messagez�'does-not-provide-IPolicyForHTTPS' was passed as the HTTPS policy for an Agent, but it does not provide IPolicyForHTTPS. Since Twisted 14.0, you must pass a provider of IPolicyForHTTPS.N)�
flushWarningsr� r� �DeprecationWarning)rR r6 �warnings�warningrS rS rT �test_deprecatedDuckPolicy� s �z)AgentHTTPSTests.test_deprecatedDuckPolicyc C sH t � }t|d�}|�dd�}| �|j� |�d�}| �|j|�� � dS )z�
L{BrowserLikePolicyForHTTPS.creatorForNetloc} returns an
L{IOpenSSLClientConnectionCreator} provider which will add certificates
from the given trust root.
�� trustRoots thingyr N) rN r7 r- rw rP r* r rQ � get_context)rR r? �policy�creator�
connectionrS rS rT �test_alternateTrustRoot s
z'AgentHTTPSTests.test_alternateTrustRootc sP |� d�}t|�d��\� ��fdd�}� fdd�}t� j|||||dd� d S )
zC
Wrap L{AgentTestsMixin.integrationTest} with TLS.
s []�asciic s t � �� d| �S r� )rL �options)�
serverFactoryrX rS rT �tlsify& rl z/AgentHTTPSTests.integrationTest.<locals>.tlsifyc sB ddl m} ddlm} ||�G � fdd�d��}tj| |� d�S )Nr r
)rD c rF )zAAgentHTTPSTests.integrationTest.<locals>.tlsagent.<locals>.Policyc s t |�d�� d�S )NrE r> )rK �decoder% �� authorityrS rT r- 0 s
�zRAgentHTTPSTests.integrationTest.<locals>.tlsagent.<locals>.Policy.creatorForNetlocNr. rS rJ rS rT �Policy. r0 rL )r )�zope.interfacer �twisted.web.iwebrD r, r� )r� r rD rL rJ rS rT �tlsagent) s
z1AgentHTTPSTests.integrationTest.<locals>.tlsagentr� )rr rs r N)�stripr) rI �superrQ )rR ro rp rq � certHostNamerH rO �r� )rK rY rT rQ s
�
�z AgentHTTPSTests.integrationTest)r r )rW rX rY re r r r r r r5 r= rD rQ �
__classcell__rS rS rS rT r g s
S
r c @ sZ e Zd ZdZdd� Zdd� Zeed�dd� �Zee d �d
d � �Z ee d �d d
� �Z
dS )� WebClientContextFactoryTestszr
Tests for the context factory wrapper for web clients
L{twisted.web.client.WebClientContextFactory}.
c C s& ddl m} | �tjg�| _|| _dS )zU
Get WebClientContextFactory while quashing its deprecation warning.
r )�WebClientContextFactoryN)�twisted.web.clientrV r9 rU ru �warned�webClientContextFactory)rR rV rS rS rT ru I s
z"WebClientContextFactoryTests.setUpc
C s\ | � t| j�d� | j\}| � |d t� | � |d t| jtdddd�td��dd �� d
S ) zx
L{twisted.web.client.WebClientContextFactory} is deprecated. Importing
it displays a warning.
r� r7 r8 �Twisted� r )� replacement�;�:N) r� r� rX r: r! rY r
r7 �replace)rR r< rS rS rT �test_deprecatedR s ��z,WebClientContextFactoryTests.test_deprecatedz SSL Present.c C s | � t| �� jdd� dS )zl
If C{getContext} is called and SSL is not available, raise
L{NotImplementedError}.
r r N)r� �NotImplementedErrorrY �
getContextr_ rS rS rT �test_missingSSLe s �z,WebClientContextFactoryTests.test_missingSSLr� c C s$ | � � �dd�}| �|tjj� dS )zT
If SSL is present, C{getContext} returns a L{OpenSSL.SSL.Context}.
r� r N)rY rb r� rH �SSL�Context)rR �ctxrS rS rT �test_returnsContextr s z0WebClientContextFactoryTests.test_returnsContextc C s( | � � }|�dd�}| �|jtj� dS )zd
The L{CertificateOptions} has C{trustRoot} set to the default trust
roots.
r� r N)rY �_getCertificateOptionsr� r? rH �OpenSSLDefaultPaths)rR rf �certificateOptionsrS rS rT �-test_setsTrustRootOnContextToDefaultTrustRootz s zJWebClientContextFactoryTests.test_setsTrustRootOnContextToDefaultTrustRootN) rW rX rY re ru r` r r rc rg rk rS rS rS rT rU C s
rU c @ sx e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd S ) � HTTPConnectionPoolRetryTestsz�
L{client.HTTPConnectionPool}, by using
L{client._RetryingHTTP11ClientProtocol}, supports retrying requests done
against previously cached connections.
c C s� t �d�}t �d|�}| �|�dt� d�� | �|�dt� d�� | �|�dt� d�� | �|�dt� d�� | �|�dt� d�� | �|�dt� d�� | �|�dt� d�� dS ) zO
Only GET, HEAD, OPTIONS, TRACE, DELETE methods cause a retry.
Nr[ s HEADs OPTIONSs TRACEs DELETE� POSTs MYMETHOD)r, r: � _RetryingHTTP11ClientProtocolrw � _shouldRetryr1 � assertFalse�rR r� rC rS rS rT � test_onlyRetryIdempotentMethods� s
z<HTTPConnectionPoolRetryTests.test_onlyRetryIdempotentMethodsc C s� t �d�}t �d|�}| �|�dt� d�� | �|�dtg �d�� | �|�dtg �d�� | �|�dt g �d�� | �|�dt
� d�� dS )z�
Only L{RequestNotSent}, L{RequestTransmissionFailed} and
L{ResponseNeverReceived} exceptions cause a retry.
Nr[ ) r, r: rn rw ro r1 r2 r5 rp r4 r rq rS rS rT �"test_onlyRetryIfNoResponseReceived� s
���z?HTTPConnectionPoolRetryTests.test_onlyRetryIfNoResponseReceivedc C s@ t �d�}t �d|�}ttt�� �g�}| �|�d|d�� dS )z�
If a request failed due to the operation being cancelled,
C{_shouldRetry} returns C{False} to indicate the request should not be
retried.
Nr[ ) r, r: rn r5 r" r r rp ro )rR r� rC r� rS rS rT �!test_dontRetryIfFailedDueToCancel� s
z>HTTPConnectionPoolRetryTests.test_dontRetryIfFailedDueToCancelc C s: t �d�}t �d|�}| �|�dttt� �g�d�� dS )z�
If a request failed with L{ResponseNeverReceived} due to some
arbitrary exception, C{_shouldRetry} returns C{True} to indicate the
request should be retried.
Nr[ )r, r: rn rw ro r5 r" � Exceptionrq rS rS rT �)test_retryIfFailedDueToNonCancelException� s
��zFHTTPConnectionPoolRetryTests.test_retryIfFailedDueToNonCancelExceptionc sP t �t� �}t� � � �t� � |�d� � |�dt� �}� �fdd�}|� |�S )z�
If L{client.HTTPConnectionPool.getConnection} returns a previously
cached connection, it will get wrapped in a
L{client._RetryingHTTP11ClientProtocol}.
�{ c s �� | tj� ��| j� � d S rg )r� r, rn r" �_clientProtocol�rC r# rS rT r� � s zTHTTPConnectionPoolRetryTests.test_wrappedOnPersistentReturned.<locals>.gotConnection)
r, r: r rZ r� r( r r� r� r� �rR r� r� r� rS r# rT � test_wrappedOnPersistentReturned� s
z=HTTPConnectionPoolRetryTests.test_wrappedOnPersistentReturnedc s. t �d�}|�dt� �}� fdd�}|�|�S )z|
If L{client.HTTPConnectionPool.getConnection} returns a new
connection, it will be returned as is.
Nrw c s � � | jt� d S rg )r" r� r/ ry r_ rS rT r� � s zPHTTPConnectionPoolRetryTests.test_notWrappedOnNewReturned.<locals>.gotConnection)r, r: r� r� r� rz rS r_ rT � test_notWrappedOnNewReturned� s
z9HTTPConnectionPoolRetryTests.test_notWrappedOnNewReturnedc s� g ��fdd�}t � � tjddt�� � dd�}|� �d }t�||�}� ��fdd �}||_|�|�}��t��d
� ��t�d j �d
� |j d d
�
t � � |�fS ) zP
Fail a first request, possibly retrying depending on argument.
c s t � } � �| � t�| �S rg )rZ ra r r r� )� protocolsrS rT r � s
z>HTTPConnectionPoolRetryTests.retryAttempt.<locals>.newProtocolr� r] Tr� r c s, �� | d� ��|� � ��|ttf� �S )Nr� )r� r" r� r1 r5 )�mr� �bp)r� rR � willWeRetryrS rT ro s z?HTTPConnectionPoolRetryTests.retryAttempt.<locals>._shouldRetryr� ) r� r, r; r? rn ro rb r� r� r] �errbackr1 )rR r� r rb r� �retrierro r� rS )r� r} rR r� rT � retryAttempt� s �
z)HTTPConnectionPoolRetryTests.retryAttemptc C sJ | � d�\}}| �t|�d� t� }|d jd d �|� |�| j|�S )z�
L{client._RetryingHTTP11ClientProtocol} retries when
L{client._RetryingHTTP11ClientProtocol._shouldRetry} returns C{True}.
Tr� r� r )r� r� r� r� r] r� r� r" )rR r� r} r} rS rS rT �"test_retryIfShouldRetryReturnsTrue s
z?HTTPConnectionPoolRetryTests.test_retryIfShouldRetryReturnsTruec C s* | � d�\}}| �t|�d� | �|t�S )z�
L{client._RetryingHTTP11ClientProtocol} does not retry when
L{client._RetryingHTTP11ClientProtocol._shouldRetry} returns C{False}.
Fr� )r� r� r� r� r1 �rR r� r} rS rS rT �'test_dontRetryIfShouldRetryReturnsFalse s zDHTTPConnectionPoolRetryTests.test_dontRetryIfShouldRetryReturnsFalsec C sH t �d�}t �d|�}| �|�dt� d�� | �|�dt� t� �� dS )a
L{_RetryingHTTP11ClientProtocol} only retries queries that don't have
a body.
This is an implementation restriction; if the restriction is fixed,
this test should be removed and PUT added to list of methods that
support retries.
Nr[ )r, r: rn rw ro r1 rp r� rq rS rS rT �test_onlyRetryWithoutBody* s
z6HTTPConnectionPoolRetryTests.test_onlyRetryWithoutBodyc C sV | � d�\}}| �t|�d� |d jd d �tg �� | �t|�d� | �|t�S )z�
If a L{client._RetryingHTTP11ClientProtocol} fails more than once on
an idempotent query before a response is received, it will not retry.
Tr� r� r )r� r� r� r] r� r5 r� r� rS rS rT �test_onlyRetryOnce8 s
z/HTTPConnectionPoolRetryTests.test_onlyRetryOncec sV t �t� �}d|_t� � � �t� � |�d� � |�dt � �}� �fdd�}|�
|�S )z�
If L{HTTPConnectionPool.retryAutomatically} is set to C{False}, don't
wrap connections with retrying logic.
Frw c s �� | � � d S rg )r" ry r# rS rT r� U rl z[HTTPConnectionPoolRetryTests.test_dontRetryIfRetryAutomaticallyFalse.<locals>.gotConnection) r, r: r r� rZ r� r( r r� r� r� rz rS r# rT �'test_dontRetryIfRetryAutomaticallyFalseE s
zDHTTPConnectionPoolRetryTests.test_dontRetryIfRetryAutomaticallyFalsec st t �t� �}d�t� � g ��fdd�}||_t� ���t� � |���� |� �� �}� ����fdd�}|�
|�S )z�
L{client.HTTPConnectionPool} creates
{client._RetryingHTTP11ClientProtocol} with a new connection factory
method that creates a new connection using the same key and endpoint
as the wrapped connection.
rw c s � � | |f� d S rg )ra )�kr� )�newConnectionsrS rT r& g � zOHTTPConnectionPoolRetryTests.test_retryWithNewConnection.<locals>.newConnectionc sl �� | tj� ��| j�� ���g � | �� ��t��d� ���d d �� ���d d � � d S )Nr� r )r� r, rn r" rx r� r) r� ry �r� r( r� r� rR rS rT r� u s zOHTTPConnectionPoolRetryTests.test_retryWithNewConnection.<locals>.gotConnection) r, r: r r� r) rZ r� r( r r� r� )rR r� r& r� r� rS r� rT �test_retryWithNewConnectionZ s
z8HTTPConnectionPoolRetryTests.test_retryWithNewConnectionN)rW rX rY re rr rs rt rv r{ r| r� r� r� r� r� r� r� rS rS rS rT rl � s %
rl c @ r� )�CookieTestsMixinz4
Mixin for unit tests dealing with cookies.
c C s@ t �t �dddt �d|i�d��}t �|�}|�||� ||fS )z/
Add a cookie to a cookie jar.
r� r� r� �
Set-CookieN)r, �_FakeUrllib2Responser3 r? �_FakeUrllib2Request�extract_cookies)rR � cookieJarr� �cookiesr} rb rS rS rT �
addCookies� s ��
zCookieTestsMixin.addCookiesN)rW rX rY re r� rS rS rS rT r� � r� r� c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �CookieJarTestsz�
Tests for L{twisted.web.client._FakeUrllib2Response} and
L{twisted.web.client._FakeUrllib2Request}'s interactions with
L{CookieJar} instances.
c C s t � }| �|dddg�}||fS )zB
@return: a L{CookieJar} with some sample cookies
r� s( foo=1; cow=moo; Path=/foo; Comment=hellos bar=2; Comment=goodbye)r r� )rR r� �reqresrS rS rT �
makeCookieJar� s �z CookieJarTests.makeCookieJarc C s� | � � d }dd� |D �}|d }| �|jd� | �|jd� | �|jd� | �|jd� | �|jd� | �|�d�d � |d
}| �|jd� | �|jd
� | �|jd � | �|jd � | �|jd
� | �|�d�d� dS )zx
L{CookieJar.extract_cookies} extracts cookie information from
fake urllib2 response instances.
r c S s i | ]}|j |�qS rS )�name)r �crS rS rT �
<dictcomp>� r z6CookieJarTests.test_extractCookies.<locals>.<dictcomp>r� �1z/foo�hello�cow�moo�bar�2�/�goodbyeN) r� r� �versionr� r1 �path�comment�get_nonstandard_attrr" )rR �jarr� �cookierS rS rT �test_extractCookies� s z"CookieJarTests.test_extractCookiesc C sF | � � \}\}}| �|�dd�d� |�|� | �|�dd�d� dS )zq
L{CookieJar.add_cookie_header} adds a cookie header to a fake
urllib2 request instance.
�CookieNz foo=1; bar=2)r� r" �
get_header�add_cookie_headerr� )rR r� rb r} rS rS rT �test_sendCookie� s
z CookieJarTests.test_sendCookieN)rW rX rY re r� r� r� rS rS rS rT r� � s
r� c @ s\ e Zd ZdZdd� Zdd� Zdd� Zdd � Zee d
�d d � �Z
d
d� Z dd� Z dd� Z
dS )�CookieAgentTestsz6
Tests for L{twisted.web.client.CookieAgent}.
c C s t �| �| j�t� �S )zB
@return: a new L{twisted.web.client.CookieAgent}
)r, � CookieAgentr� r� r r_ rS rS rT rN � s �zCookieAgentTests.makeAgentc C s | � � | _d S rg )r� r� r_ rS rS rT ru � s zCookieAgentTests.setUpc s� t � � ��t� �g � ���j�}t�|� �}|�dd�}� �fdd�}|�|� �j j
� � \}}�� |j
�d�d� t�ddd t�d
d gi�d�}|�|� |S ) a
L{CookieAgent.request} does not insert any C{'Cookie'} header into the
L{Request} object if there is no cookie in the cookie jar for the URI
being requested. Cookies are extracted from the response and stored in
the cookie jar.
r[ r� c s@ t � �}��t|�d� ��|d jd� ��|d jd� d S )Nr� r r� r� )�listr� r� r� r1 )�ignoredr� �r� rR rS rT � _checkCookie� s zACookieAgentTests.test_emptyCookieJarRequest.<locals>._checkCookie� cookieNr� r� r� r� � foo=1)r r� r� r� r� r, r� rb r� r� r] r� r" rm rn r3 r? r� )rR r� � cookieAgentr� r� r� r� r� rS r� rT �test_emptyCookieJarRequest� s.
����
z+CookieAgentTests.test_emptyCookieJarRequestc C s� d}d}t � }| �|||g� | �tt|��d� | �| j�}t�||�}|� d|� | j
j � � \}}| �|j
�d�|g� dS )z�
L{CookieAgent.request} inserts a C{'Cookie'} header into the L{Request}
object when there is a cookie matching the request URI in the cookie
jar.
r� r� r� r[ r� N�r r� r� r� r� r� r� r, r� rb r� r] r� rm rn �rR r� r� r� r� r� r� r� rS rS rT �test_requestWithCookie � z'CookieAgentTests.test_requestWithCookier� c C � d}d}t � }| �|||g� | �tt|��d� | �| j�}t�||�}|� d|� | j
j � � \}}| �|j
�d�dg� dS )z~
L{CookieAgent} is able to handle secure cookies, ie cookies which
should only be handled over https.
s https://example.com:1234/foo?bar� foo=1;securer� r[ r� r� Nr� r� rS rS rT �test_secureCookie" r� z"CookieAgentTests.test_secureCookiec C s~ d}d}t � }| �|||g� | �tt|��d� | �| j�}t�||�}|� d|� | j
j � � \}}| �
d|j�d�� dS )zs
If a cookie is setup as secure, it won't be sent with the request if
it's not over HTTPS.
r� r� r� r[ Nr� )r r� r� r� r� r� r� r, r� rb r� r] r� r" rm rn r� rS rS rT �%test_secureCookieOnInsecureConnection6 s z6CookieAgentTests.test_secureCookieOnInsecureConnectionc C r� )zz
L{CookieAgent} supports cookies which enforces the port number they
need to be transferred upon.
r� � foo=1;port=1234r� r[ r� r� Nr� r� rS rS rT �test_portCookieI s z CookieAgentTests.test_portCookiec C s6 d}d}t � }| �|||g� | �tt|��d� dS )z�
When creating a cookie with a port directive, it won't be added to the
L{cookie.CookieJar} if the URI is on a different port.
s http://example.com:4567/foo?barr� r N)r r� r� r� r� )rR r� r� r� rS rS rT �test_portCookieOnWrongPort\ s
z+CookieAgentTests.test_portCookieOnWrongPortN)rW rX rY re rN ru r� r� r r r� r� r� r� rS rS rS rT r� � s *
r� c @ � e Zd ZdZdS )�Decoder1�K
A test decoder to be used by L{client.ContentDecoderAgent} tests.
N�rW rX rY re rS rS rS rT r� i � r� c @ r� )�Decoder2r� Nr� rS rS rS rT r� o r� r� c @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dS )�ContentDecoderAgentTestsz2
Tests for L{client.ContentDecoderAgent}.
c C s t �| jg �S )zJ
@return: a new L{twisted.web.client.ContentDecoderAgent}
)r, �ContentDecoderAgentr� r_ rS rS rT rN z � z"ContentDecoderAgentTests.makeAgentc C s | � � | _| �| j�| _dS r� )r� r� r� r� r_ rS rS rT ru � s
z ContentDecoderAgentTests.setUpc C sf t �| jdtfdtfg�}|�dd� | j}| �t|j �d� |j �
� \}}| �|j � d�dg� dS ) z�
L{client.ContentDecoderAgent} sets the I{Accept-Encoding} header to the
names of the available decoder objects.
� decoder1� decoder2r[ r� r� � accept-encoding� decoder1,decoder2N)
r, r� r� r� r� rb r� r� r� r] r� rm rn )rR r� r� r� r� rS rS rT �test_acceptHeaders� s � �z+ContentDecoderAgentTests.test_acceptHeadersc C s� t �dgdgd��}t�| jdtfdtfg�}|jdd|d� | j}| � t
|j �d � |j � � \}}| � t
t|j�� ��d
dd gfd dgfd
dgfg� dS )z�
If there are existing I{Accept-Encoding} fields,
L{client.ContentDecoderAgent} creates a new field for the decoders it
knows about.
r� � fizz)r� r� r� r� r[ r� �rm r� s Accept-Encodingr� � Foorf r N)r. r? r, r� r� r� r� rb r� r� r� r] r� r� �sortedrm �getAllRawHeaders)rR rm r� r� r� r� rS rS rT �test_existingHeaders� s" ��
��z-ContentDecoderAgentTests.test_existingHeadersc C sb t �| jdtfdtfg�}|�dd�}| jj�� \}}t dddt
� � d�}|� |� |�
| j|�S ) z�
If the response is not encoded despited the request I{Accept-Encoding}
headers, L{client.ContentDecoderAgent} simply forwards the response.
r� r� r[ r� r� r� r� N)r, r� r� r� r� rb r� r] r� r3 r. r? r� r� r" )rR r� rt r� r� r} rS rS rT �test_plainEncodingResponse� s �
z3ContentDecoderAgentTests.test_plainEncodingResponsec C sr t �| jdtfdtfg�}|�dd�}| jj�� \}}t �
dgdgd��}t dd d
|d �}|� |� |�
| j|�S ) zz
If an encoding unknown to the L{client.ContentDecoderAgent} is found,
the response is unchanged.
r� r� r[ r� r� r� �r� � content-encodingr� r� r� N)r, r� r� r� r� rb r� r] r� r. r? r3 r� r� r" )rR r� rt r� r� rm r} rS rS rT �test_unsupportedEncoding� s � �
z1ContentDecoderAgentTests.test_unsupportedEncodingc s| t ��jdtfdtfg�}|�dd�}�jj�� \}}t �
dgdgd��}t dd d
|d �� |� � � � �fd d
�}|�
|�S )z�
When L{client.ContentDecoderAgent} encounters a decoder it doesn't know
about, it stops decoding even if another encoding is known afterwards.
r� r� r[ r� r� s decoder1,fizz,decoder2r� r� r� r� Nc s2 �� � | � ��| t� ��dg| j�d�� d S )Ns
decoder1,fizzr� )r% r� r� r� rm rn �rc �r} rR rS rT �check� s
�z<ContentDecoderAgentTests.test_unknownEncoding.<locals>.check)r, r� r� r� r� rb r� r] r� r. r? r3 r� r� )rR r� rt r� r� rm r� rS r� rT �test_unknownEncoding� s � �
z-ContentDecoderAgentTests.test_unknownEncodingN) rW rX rY re rN ru r� r� r� r� r� rS rS rS rT r� u s r� c @ �0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) �SimpleAgentProtocola
A L{Protocol} to be used with an L{client.Agent} to receive data.
@ivar finished: L{Deferred} firing when C{connectionLost} is called.
@ivar made: L{Deferred} firing when C{connectionMade} is called.
@ivar received: C{list} of received data.
c C s t � | _t � | _g | _d S rg )r �made�finished�receivedr_ rS rS rT r` s
z SimpleAgentProtocol.__init__c C � | j �d � d S rg )r� r� r_ rS rS rT �connectionMade rl z"SimpleAgentProtocol.connectionMadec C r� rg )r� r� )rR �reasonrS rS rT rB rl z"SimpleAgentProtocol.connectionLostc C ri rg )r� ra �rR rj rS rS rT � dataReceived rl z SimpleAgentProtocol.dataReceivedN)rW rX rY re r` r� rB r� rS rS rS rT r� � s
r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) � ContentDecoderAgentWithGzipTestsc C s0 | � � | _| �| j�}t�|dtjfg�| _dS )r� � gzipN)r� r� r� r, r� � GzipDecoderr� r� rS rS rT ru s
z&ContentDecoderAgentWithGzipTests.setUpc s� �j �dd�}�jj�� \}}t�dgdgd��}t� }tddd||��d �_ |�
�� t � d
t j
d t j �}|�d �|�d
� |�� � � ��fdd�}|�|� |S )z�
If the response has a C{gzip} I{Content-Encoding} header,
L{GzipDecoder} wraps the response to return uncompressed data to the
user.
r[ r� r� r� r� r� r� r� � r� � s xxxxxxs yyyyc s� �� | �� ��| jd� ��| jd� ��| jd� ��t| j�� �ddgfg� ��| jt � ��
t t | d� ��
� d d� � ��
� dd � � ��� t� }| �|� ��|jdg� t�|j|jg�S ) Nr� r� r� r� r� �unknownr� s
xxxxxxyyyy)r% r� r� �code�phraser� rm r� r� r@ r� �AttributeError�getattr�_bodyDataReceived�_bodyDataFinishedr� � deliverBodyr� r �
gatherResultsr� r� �rc r� �rj r} rR rS rT �
checkResponse2 s �
zQContentDecoderAgentWithGzipTests.test_gzipEncodingResponse.<locals>.checkResponse)r� rb r� r] r� r. r? r( r3 r� r� �zlib� compressobj�DEFLATED� MAX_WBITS�compressri r� )rR rt r� r� rm r �
compressorr� rS r� rT �test_gzipEncodingResponse s& �
���
z:ContentDecoderAgentWithGzipTests.test_gzipEncodingResponsec s� �j �dd�}�jj�� \}}t�dgdgd��}t� }tddd||��d �_ |�
�� d
� � �fd d �}|� |� �� |t
j� �fd
d�}|� |�S )z�
If the data received by the L{GzipDecoder} isn't valid gzip-compressed
data, the call to C{deliverBody} fails with a C{zlib.error}.
r[ r� r� r� r� r� r� r� r� s not gzipped contentc s �� � � | �t� � d S rg )r� r� r r� )rj r} rS rT r� ^ s
zJContentDecoderAgentWithGzipTests.test_brokenContent.<locals>.checkResponsec �$ | j d �tj� � �| jt� d S )Nr ��reasonsr� r� r- r� r} r3 �r- r_ rS rT � checkFailuref � zIContentDecoderAgentWithGzipTests.test_brokenContent.<locals>.checkFailure)r� rb r� r] r� r. r? r( r3 r� r� r� r� r, r4 )rR rt r� r� rm r r� r rS r� rT �test_brokenContentK s �
z3ContentDecoderAgentWithGzipTests.test_brokenContentc s� G dd� d�}t j}|t _��tt d|� �j�dd�}�jj�� \}}t �
ddgi�}t � }t ddd ||�� |�
� � � �fd
d �}|�|� |S ) z�
When the connection with the server is lost, the gzip protocol calls
C{flush} on the zlib decompressor object to get uncompressed data which
may have been buffered.
c @ �$ e Zd Zdd� Zdd� Zdd� ZdS )zFContentDecoderAgentWithGzipTests.test_flushData.<locals>.decompressobjc S rz rg rS �rR �wbitsrS rS rT r` t r~ zOContentDecoderAgentWithGzipTests.test_flushData.<locals>.decompressobj.__init__c S rn �N� xrS r� rS rS rT �
decompressw r~ zQContentDecoderAgentWithGzipTests.test_flushData.<locals>.decompressobj.decompressc S rn )N� yrS r_ rS rS rT ri z r~ zLContentDecoderAgentWithGzipTests.test_flushData.<locals>.decompressobj.flushN�rW rX rY r` r ri rS rS rS rT �
decompressobjs � r r[ r� r� r� r� r� r� c �F � � d� � �� t� }| �|� ��|jddg� t�|j|j g�S �Ns datar r �
r� r� r� r� r� r� r r� r� r� r� r� rS rT r� � �
zFContentDecoderAgentWithGzipTests.test_flushData.<locals>.checkResponse)r� r �
addCleanup�setattrr� rb r� r] r� r. r? r( r3 r� r� ) rR r �oldDecompressObjrt r� r� rm r r� rS r� rT �test_flushDatal s
z/ContentDecoderAgentWithGzipTests.test_flushDatac
s� G dd� d�}t j}|t _��tt d|� �j�dd�}�jj�� \}}t �
ddgi�}t � }t ddd ||�� |�
� � � �fd
d �}|�|� ��|tj� �fd d
�} |�| �S )z�
If the C{flush} call in C{connectionLost} fails, the C{zlib.error}
exception is caught and turned into a L{ResponseFailed}.
c @ r
)zGContentDecoderAgentWithGzipTests.test_flushError.<locals>.decompressobjc S rz rg rS r rS rS rT r` � r~ zPContentDecoderAgentWithGzipTests.test_flushError.<locals>.decompressobj.__init__c S rn r
rS r� rS rS rT r � r~ zRContentDecoderAgentWithGzipTests.test_flushError.<locals>.decompressobj.decompressc S s t �� �rg )r� r- r_ rS rS rT ri � r� zMContentDecoderAgentWithGzipTests.test_flushError.<locals>.decompressobj.flushNr rS rS rS rT r � r r r[ r� r� r� r� r� r� c r r r r� r� rS rT r� � r zGContentDecoderAgentWithGzipTests.test_flushError.<locals>.checkResponsec r )Nr� r r r_ rS rT r � r zFContentDecoderAgentWithGzipTests.test_flushError.<locals>.checkFailure)r� r r r r� rb r� r] r� r. r? r( r3 r� r� r� r, r4 )
rR r r rt r� r� rm r r� r rS r� rT �test_flushError� s
z0ContentDecoderAgentWithGzipTests.test_flushErrorN)rW rX rY ru r r r r rS rS rS rT r� s 2! ,r� c @ �@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�ProxyAgentTestsz)
Tests for L{client.ProxyAgent}.
c C s t �t| jdd�| j�S )zA
@return: a new L{twisted.web.client.ProxyAgent}
z 127.0.0.1r� )r, �
ProxyAgentr r� r_ rS rS rT rN � s �zProxyAgentTests.makeAgentc C s@ | � � | _t�t| jdd�| j�| _| jj}| �|| �| j_d S )Nr� �. )r� r� r, r r r� �_proxyEndpointr� )rR � oldEndpointrS rS rT ru � s
�zProxyAgentTests.setUpc C r� )zo
L{ProxyAgent.request} raises L{TypeError} when the C{method} argument
isn't L{bytes}.
r� r� Nr� r_ rS rS rT r� � r� z#ProxyAgentTests.test_nonBytesMethodc C s� t �ddgi�}t� }| j�dd||� | jj�� dd� \}}}| �|d� | �|d� | � |j
t j � | j
}| �t|j�d � |j�� \}}| � |t� | �|jd� | �|jd� | �|jt �dgd
gd ��� | �|j|� dS ) z�
L{client.ProxyAgent} issues an HTTP request against the proxy, with the
full URI as path, when C{request} is called.
r� r� r[ r� Nr� r� r r� r� r� )r. r? r� r� rb r� r� r� r� r� �_wrappedFactoryr, r= r� r� r] r; r� r� rm r" r� ) rR rm r� r r r� r� r� r� rS rS rT �test_proxyRequest� s$ �z!ProxyAgentTests.test_proxyRequestc C s | � | jjjd� dS )zJ
C{ProxyAgent} connections are not persistent by default.
FN)r� r� r� r r_ rS rS rT r�
s z"ProxyAgentTests.test_nonPersistentc s` t � � G � �fdd�d�}|� }tj� �j|d�}��||j� |�dd� ��|jjd� dS )z�
When a connection is made by the C{ProxyAgent}, it uses its pool's
C{getConnection} method to do so, with the endpoint it was constructed
with and a key of C{("http-proxy", endpoint)}.
c r� )zAProxyAgentTests.test_connectUsesConnectionPool.<locals>.DummyPoolFc s. d| _ ��|� � ��|d� f� t�t� �S )NTz
http-proxy)r� r" r� r r rZ r� r� rS rT r�
s zOProxyAgentTests.test_connectUsesConnectionPool.<locals>.DummyPool.getConnectionNr� rS r� rS rT r�
r� r� r� r[ r� TN) r� r, r r� r" r� rb r� r� )rR r� r� r� rS r� rT r�
s
z.ProxyAgentTests.test_connectUsesConnectionPoolN)
rW rX rY re rN ru r� r$ r� r� rS rS rS rT r � s r )�
authorizationr� � cookie2� proxy-authorizations www-authenticatec
@ s e Zd ZU dZeed< eed< eed< dd� Z d<d e d
e
d e
d e
d
e e de
f dd�Zdd� Zdd� Zdd� Zdd� Zdd� Z d=d ed e
ddfd d �Zd>d d!�Zd>d"d#�Zd>d$d%�Zd&d'� Zd(d)� Zd*d+� Zd,d-� Z d.d/� Z d0d1� Z d2d3� Z d4d5� Z d6d7� Z!d8d9� Z"d:d;� Z#dS )?�_RedirectAgentTestsMixinz^
Test cases mixin for L{RedirectAgentTests} and
L{BrowserLikeRedirectAgentTests}.
r� r� r� c C s| | j �dd�}| jj�� \}}t�� }tddd|d�}|�|� | � dt
| jj�� | � |�}| � ||� | � |j
d� dS )zz
L{client.RedirectAgent} behaves like L{client.Agent} if the response
doesn't contain a redirect.
r[ r� r� r� r� Nr )r� rb r� r] r� r. r? r3 r� r� r� r� r" �previousResponse)rR rt r� r� rm r} rc rS rS rT �test_noRedirect;
s
z(_RedirectAgentTestsMixin.test_noRedirectFNr� � crossScheme� crossDomain� crossPort�requestHeadersr[ c C s� d}t durdnd}|dkrdnd}| jjd|d | d |d
� | jj�� dd � \} }
| �t| � | �||
� | jj �� \} } |}
|}|}|rat du rQt
d ��|dkrWdnd}
|dkr_dnd}d
}|rid}d}|rmdn|}|
d | | d }t � d|gi�}t
d|d|d�}| �|� | jj �� \}}| �d|j� | �d|j� | jj�� dd � \} }
| �|r�tnt| � | �||
� |S )z�
When getting a redirect, L{client.RedirectAgent} follows the URL
specified in the L{Location} header field and make a new request.
@param code: HTTP status code.
r Nr� rZ r r r[ r\ s /foor� r� z;Cross-scheme redirects can't be tested without TLS support.rv i� s :8443� example.net� /bar� locationr� r� )rH r� rb r� r� r� r� r� r� r] r r. r? r3 r� r� r� r� )rR r� r+ r, r- r. � startDomain� startScheme� startPortr r r� r� � targetScheme� targetDomain�
targetPort�
portSyntax�
locationValuerm r} �req2�res2rS rS rT �_testRedirectDefaultM
sH � �
z-_RedirectAgentTestsMixin._testRedirectDefaultc C � | � d� dS )zO
L{client.RedirectAgent} follows redirects on status code 301.
�- N�r< r_ rS rS rT �test_redirect301�
r� z)_RedirectAgentTestsMixin.test_redirect301c C � | j ddd� dS )zI
L{client.RedirectAgent} follows cross-scheme redirects.
r> T�r+ Nr? r_ rS rS rT �test_redirect301Scheme�
s
�z/_RedirectAgentTestsMixin.test_redirect301Schemec C r= )zO
L{client.RedirectAgent} follows redirects on status code 302.
�. Nr? r_ rS rS rT �test_redirect302�
r� z)_RedirectAgentTestsMixin.test_redirect302c C r= )zO
L{client.RedirectAgent} follows redirects on status code 307.
�3 Nr? r_ rS rS rT �test_redirect307�
r� z)_RedirectAgentTestsMixin.test_redirect307c C r= )zO
L{client.RedirectAgent} follows redirects on status code 308.
i4 Nr? r_ rS rS rT �test_redirect308�
r� z)_RedirectAgentTestsMixin.test_redirect308r �expectedHostHeader� crossKwargsc K s� dgdgdgdgdgdgd�}dd gi}t i |�|��}| jd
|d �}d t d
tfdd�}||j�}| �|ddgi||��� | j
di |�dt i |�|��i��} || j�}
| �|
d|gi|t |���� dS )zv
L{client.RedirectAgent} scrubs sensitive headers when redirecting
between differing origins.
s sensitive-authnzs sensitive-cookie-datas sensitive-cookie2-datas sensitive-proxy-auths sensitive-authns sensitive-custom)r% r� r& r' s wWw-auThentiCates x-custom-sensitives x-random-headers x-random-valuer> )r. rm r[ c S s dd� | � � D �S )Nc S s i | ] \}}|� � |�qS rS )�lower)r r� �vrS rS rT r� �
s zW_RedirectAgentTestsMixin._sensitiveHeadersTest.<locals>.normHeaders.<locals>.<dictcomp>)r� r� rS rS rT � normHeaders�
r� zC_RedirectAgentTestsMixin._sensitiveHeadersTest.<locals>.normHeadersr� r r. N)r> )r? r< rl rm r0 ) rR rI rJ �sensitiveHeaderValues�otherHeaderValues�
allHeaders�
redirectedrM �sameOriginHeaders�redirectedElsewhere�otherOriginHeadersrS rS rT �_sensitiveHeadersTest�
sD �
������
�
��z._RedirectAgentTestsMixin._sensitiveHeadersTestc C rA )zv
L{client.RedirectAgent} scrubs sensitive headers when redirecting
between differing domains.
Tr/ )r, rI N�rU r_ rS rS rT �test_crossDomainHeaders�
s z0_RedirectAgentTestsMixin.test_crossDomainHeadersc C rA )zt
L{client.RedirectAgent} scrubs sensitive headers when redirecting
between differing ports.
Ts example.com:8443)r- rI NrV r_ rS rS rT �test_crossPortHeaders�
s
�z._RedirectAgentTestsMixin.test_crossPortHeadersc C s | j dd� dS )zv
L{client.RedirectAgent} scrubs sensitive headers when redirecting
between differing schemes.
TrB NrV r_ rS rS rT �test_crossSchemeHeaders�
� z0_RedirectAgentTestsMixin.test_crossSchemeHeadersc C sx | j �|d� | jj�� \}}t�ddgi�}td|d|d�}|�|� | jj�� \}}| � d|j
� | � d|j � dS ) z�
L{client.RedirectAgent} changes the method to I{GET} when getting
a redirect on a non-I{GET} request.
@param code: HTTP status code.
@param method: HTTP request method.
r� r1 � http://example.com/barr� r� Nr[ r0 ) r� rb r� r] r� r. r? r3 r� r� r� r� ) rR r� r� r� r� rm r} r: r; rS rS rT �_testRedirectToGet�
s
z+_RedirectAgentTestsMixin._testRedirectToGetc C � | � dd� dS )z�
L{client.RedirectAgent} changes the method to I{GET} when getting a 303
redirect on a I{POST} request.
i/ rm N�r\ r_ rS rS rT �test_redirect303 rZ z)_RedirectAgentTestsMixin.test_redirect303c C s� | j �dd�}| jj�� \}}t�� }tddd|d�}|�|� | � |t
j �}|j j
d �tj� | �d|j j
d j j� | �d|j jj� dS )z�
If no L{Location} header field is found when getting a redirect,
L{client.RedirectAgent} fails with a L{ResponseFailed} error wrapping a
L{error.RedirectWithNoLocation} exception.
r[ r� r� r> r� Nr )r� rb r� r] r� r. r? r3 r� r� r, r4 r1 r r� r- �RedirectWithNoLocationr� r� r} r� )rR rt r� r� rm r} �failrS rS rT �test_noLocationField s
z-_RedirectAgentTestsMixin.test_noLocationFieldc C s� | j �|d�}| jj�� \}}t�� }td|d|d�}|�|� | � |t
j �}|j j
d �tj� | �d|j j
d j j� | �||j jj� dS )a
When getting a redirect on an unsupported request method,
L{client.RedirectAgent} fails with a L{ResponseFailed} error wrapping
a L{error.PageRedirect} exception.
@param code: HTTP status code.
@param method: HTTP request method.
r� r� r� Nr )r� rb r� r] r� r. r? r3 r� r� r, r4 r1 r r� r- � PageRedirectr� �locationr} r� ) rR r� r� rt r� r� rm r} ra rS rS rT �_testPageRedirectFailure s
�z1_RedirectAgentTestsMixin._testPageRedirectFailurec C r] )z�
When getting a 307 redirect on a I{POST} request,
L{client.RedirectAgent} fails with a L{ResponseFailed} error wrapping
a L{error.PageRedirect} exception.
rF rm N�re r_ rS rS rT �test_307OnPost8 � z'_RedirectAgentTestsMixin.test_307OnPostc C s� | � | j�}t�|d�}|�dd�}| jj�� \}}t� ddgi�}t
ddd|d �}|� |� | jj�� \}} t
ddd|d �}
| � |
� | � |tj
�} | jjd
�tj� | �d| jjd
jj� | �d| jjj� d S ) z�
If the limit of redirects specified to L{client.RedirectAgent} is
reached, the deferred fires with L{ResponseFailed} error wrapping
a L{InfiniteRedirection} exception.
r� r[ r� r1 r[ r� rD r� Nr )r� r� r, �
RedirectAgentrb r� r] r� r. r? r3 r� r� r4 r1 r r� r- �InfiniteRedirectionr� rd r} r� ) rR r� �
redirectAgentrt r� r� rm r} r: r; � response2ra rS rS rT �test_redirectLimit@ s
�z+_RedirectAgentTestsMixin.test_redirectLimitc
C sx | j �d|� | jj�� \}}t�d|gi�}tddd|d�}|�|� | jj�� \}} | � d|j
� | � ||j � dS )a1
When L{client.RedirectAgent} encounters a relative redirect I{URI}, it
is resolved against the request I{URI} before following the redirect.
@param uri: Request URI.
@param location: I{Location} header redirect URI.
@param finalURI: Expected final URI.
r[ r1 r� rD r� N) r� rb r� r] r� r. r? r3 r� r� r� r� )
rR r� rd �finalURIr� r� rm r} r: r; rS rS rT �_testRedirectURI^ s
z)_RedirectAgentTestsMixin._testRedirectURIc C s. | � ddd� | � ddd� | � ddd� dS ) z
L{client.RedirectAgent} resolves and follows relative I{URI}s in
redirects, preserving query strings.
� http://example.com/foo/bars bazs http://example.com/foo/bazs /bazs http://example.com/baz� /baz?as http://example.com/baz?aN�ro r_ rS rS rT �test_relativeURIu s ���z)_RedirectAgentTestsMixin.test_relativeURIc C s | � ddd� | � ddd� dS )a
L{client.RedirectAgent} resolves and follows relative I{URI}s in
redirects, preserving fragments in way that complies with the HTTP 1.1
bis draft.
@see: U{https://tools.ietf.org/html/draft-ietf-httpbis-p2-semantics-22#section-7.1.2}
s http://example.com/foo/bar#fragrq s http://example.com/baz?a#fragrp s /baz?a#frag2s http://example.com/baz?a#frag2Nrr r_ rS rS rT �!test_relativeURIPreserveFragments� s ��z:_RedirectAgentTestsMixin.test_relativeURIPreserveFragmentsc C s | � ddd� | � ddd� dS )z�
L{client.RedirectAgent} resolves and follows scheme relative I{URI}s in
redirects, replacing the hostname and port when required.
rp s
//foo.com/bazs http://foo.com/bazs //foo.com:81/bazs http://foo.com:81/bazNrr r_ rS rS rT � test_relativeURISchemeRelative� s ��z7_RedirectAgentTestsMixin.test_relativeURISchemeRelativec C s� | � | j�}t�|�}|�dd�}| jj�� \}}t� ddgi�}t
ddd|d�}|� |� | jj�� \}} t
dd d|d�}
| � |
� | � |�} | �
| j|� | �
|jd� dS )
z�
L{Response.response} references the previous L{Response} from
a redirect, or L{None} if there was no previous response.
r[ r� r1 r[ r� rD r� Nr� )r� r� r, ri rb r� r] r� r. r? r3 r� r� r" r) ) rR r� rk rt � redirectReq� redirectResrm �redirectResponser� r� r} �
finalResponserS rS rT �test_responseHistory� s
z-_RedirectAgentTestsMixin.test_responseHistory)FFFN)r rd )$rW rX rY re rA �__annotations__r' rZ r* �int�boolr r? r; r< r@ rC rE rG rH rk rU rW rX rY r\ r_ rb re rg rm ro rs rt ru rz rS rS rS rT r( 1
sd
������
�> ���
�
-
r( c @ r� ) �RedirectAgentTestsz,
Tests for L{client.RedirectAgent}.
c C � t j| �| j�dgd�S )zD
@return: a new L{twisted.web.client.RedirectAgent}
s X-Custom-sensitive��sensitiveHeaderNames)r, ri r� r� r_ rS rS rT rN � �
�z RedirectAgentTests.makeAgentc C � | � � | _| �� | _d S rg r� r_ rS rS rT ru � �
zRedirectAgentTests.setUpc C r] )z�
When getting a 301 redirect on a I{POST} request,
L{client.RedirectAgent} fails with a L{ResponseFailed} error wrapping
a L{error.PageRedirect} exception.
r> rm Nrf r_ rS rS rT �test_301OnPost� rh z!RedirectAgentTests.test_301OnPostc C r] )z�
When getting a 302 redirect on a I{POST} request,
L{client.RedirectAgent} fails with a L{ResponseFailed} error wrapping
a L{error.PageRedirect} exception.
rD rm Nrf r_ rS rS rT �test_302OnPost� rh z!RedirectAgentTests.test_302OnPostN)rW rX rY re rN ru r� r� rS rS rS rT r~ � s r~ c @ r� ) � BrowserLikeRedirectAgentTestsz7
Tests for L{client.BrowserLikeRedirectAgent}.
c C r )zO
@return: a new L{twisted.web.client.BrowserLikeRedirectAgent}
s x-Custom-sensitiver� )r, �BrowserLikeRedirectAgentr� r� r_ rS rS rT rN � r� z'BrowserLikeRedirectAgentTests.makeAgentc C r� rg r� r_ rS rS rT ru � r� z#BrowserLikeRedirectAgentTests.setUpc C r] )��
L{client.BrowserLikeRedirectAgent} changes the method to I{GET} when
getting a 302 redirect on a I{POST} request.
r> rm Nr^ r_ rS rS rT �test_redirectToGet301� rZ z3BrowserLikeRedirectAgentTests.test_redirectToGet301c C r] )r� rD rm Nr^ r_ rS rS rT �test_redirectToGet302 rZ z3BrowserLikeRedirectAgentTests.test_redirectToGet302N)rW rX rY re rN ru r� r� rS rS rS rT r� � s r� c @ s e Zd ZdZdZdd� ZdS )�AbortableStringTransportzK
A version of L{StringTransport} that supports C{abortConnection}.
Fc C s d| _ | �� dS )z�
A testable version of the C{ITCPTransport.abortConnection} method.
Since this is a special case of closing the connection,
C{loseConnection} is also called.
TN)�aborting�loseConnectionr_ rS rS rT �abortConnection s z(AbortableStringTransport.abortConnectionN)rW rX rY re r� r� rS rS rS rT r� s r� c @ s. e Zd ZdZdZdZdefdd�Zdd� ZdS ) �
DummyResponsea�
Fake L{IResponse} for testing readBody that captures the protocol passed to
deliverBody and uses it to make a connection with a transport.
@ivar protocol: After C{deliverBody} is called, the protocol it was called
with.
@ivar transport: An instance created by calling C{transportFactory} which
is used by L{DummyResponse.protocol} to make a connection.
r� r� Nc C s |du rt � }|| _|� | _dS )z�
@param headers: The headers for this response. If L{None}, an empty
L{Headers} instance will be used.
@type headers: L{Headers}
@param transportFactory: A callable used to construct the transport.
N)r? rm r )rR rm �transportFactoryrS rS rT r` - s zDummyResponse.__init__c C s || _ | j �| j� dS )zt
Record the given protocol and use it to make a connection with
L{DummyResponse.transport}.
N�r� r� r r
rS rS rT r� : s zDummyResponse.deliverBody) rW rX rY re r� r� r� r` r� rS rS rS rT r� s
r� c @ r� )� AlreadyCompletedDummyResponsezE
A dummy response that has already had its transport closed.
c C s || _ | j �| j� d| j _dS )zA
Make the connection, then remove the transport.
Nr� r
rS rS rT r� H s z)AlreadyCompletedDummyResponse.deliverBodyN)rW rX rY re r� rS rS rS rT r� C r� r� c @ r )�
ReadBodyTestsz&
Tests for L{client.readBody}
c C sP t � }t�|�}|j�d� |j�d� |j�tt� �� | �| � |�d� dS )z�
L{client.readBody} returns a L{Deferred} which fires with the complete
body of the L{IResponse} provider passed to it.
� first� second� firstsecondN)
r� r, �readBodyr� r� rB r" r< r� r� )rR r} r� rS rS rT � test_successV s
zReadBodyTests.test_successc C s8 t � }t�|�}|�� | �|tj� | �|jj � dS )z�
When cancelling the L{Deferred} returned by L{client.readBody}, the
connection to the server will be aborted.
N)
r� r, r� r� r� r r rw r r� )rR r} rt rS rS rT � test_cancelb s
zReadBodyTests.test_cancelc C s| t � }t�|�}|j�d� |j�d� |j�tt� �� | �|�}|� tj
� | � |j j
|j j|j jd�dddd�� dS )a
If the full body of the L{IResponse} passed to L{client.readBody} is
not definitely received, the L{Deferred} returned by L{client.readBody}
fires with a L{Failure} wrapping L{client.PartialDownloadError} with
the content that was received.
r� r� )�statusr8 r� s 200r� r� N)r� r, r� r� r� rB r" r0 r� r� �PartialDownloadErrorr� r1 r� r8 r} )rR r} r� �failurerS rS rT �test_withPotentialDataLossm s"
���z(ReadBodyTests.test_withPotentialDataLossc C sX t � }t�|�}|j�d� |j�ttd��� | �|�}|� t� | �
|j j d� dS )z�
If there is an exception other than L{client.PotentialDataLoss} while
L{client.readBody} is collecting the response body, the L{Deferred}
returned by {client.readBody} fires with that exception.
r� �mystery problem)r� N)
r� r, r� r� r� rB r" r r� r� r� r1 r� )rR r} r� r� rS rS rT �test_otherErrors� s
z ReadBodyTests.test_otherErrorsc sD t td�� d� j_| �tdt� fdd��}|�� | �|t j
� dS )z�
Calling L{client.readBody} with a transport that does not implement
L{twisted.internet.interfaces.ITCPTransport} produces a deprecation
warning, but no exception when cancelling.
)r� NzLUsing readBody with a transport that does not have an abortConnection methodc s
t �� �S rg )r, r� rS �r} rS rT ro � s
z8ReadBodyTests.test_deprecatedTransport.<locals>.<lambda>) r� r( r r� � assertWarnsr: �__file__r� r� r r )rR r� rS r� rT �test_deprecatedTransport� s
�z&ReadBodyTests.test_deprecatedTransportc C s, t � }t�|� | �� }| �t|�d� dS )z�
Calling L{client.readBody} with a response that has already had its
transport closed (eg. for a very small request) will not trigger a
deprecation warning.
r N)r� r, r� r9 r� r� )rR r} r; rS rS rT �!test_deprecatedTransportNoWarning� s
z/ReadBodyTests.test_deprecatedTransportNoWarningN)
rW rX rY re r� r� r� r� r� r� rS rS rS rT r� Q s r� c @ r
)� HostnameCachingHTTPSPolicyTestsc C s� t � }t|d�}t|�}|�dd�}| �|j� d|_| �dt|j�� |� d�}| �
|j |� � � |�dd� | �
|j� dS )z�
Verify that the connection creator is added to the
policy's cache, and that it is reused on subsequent calls
to creatorForNetLoc.
r> r� i5 Fr� N)rN r7 r9 r- rw rP r0 r� �_cacher* r rQ r@ rp )rR r? �
wrappedPolicyrA rB rC rS rS rT �test_cacheIsUsed� s
z0HostnameCachingHTTPSPolicyTests.test_cacheIsUsedc C sV t � }t|d�}t|�}tdd�D ]}dt|� }|�|�d�d� qd}|�|�d�d� | �||j� | � dt
|j�� d }|�|�d�d� d
}| � ||j� | � dt
|j�� | �||j� | �||j� td�D ] } |�|�d�d� qmd }
|�|
�d�d � | � d
|j� | � dt
|j�� | �|
|j� | �||j� | �||j� dS )zt
Verify that when the cache is full, and a new entry is added,
the oldest entry is removed.
r> r � r rE ��! �host0�5 �new�host1�new1i �host2N� rN r7 r9 r� �strr- r� r r� r0 r� r� ) rR r? r� rA r� r$ r� �hostnr� �_�
hostNPlus1rS rS rT �test_cacheRemovesOldest� s4
z7HostnameCachingHTTPSPolicyTests.test_cacheRemovesOldestc C s� t � }t|d�}t|dd�}tdd�D ]}dt|� }|�|�d�d� qd}| �||j� | � dt
|j�� d }|�|�d�d
� | � ||j� | � dt
|j�� | �||j� d S ) z�
Verify that changing the cache size results in a policy that
respects the new cache size and not the default.
r> r� )� cacheSizer r rE r� r� r� r� Nr� )rR r? r� rA r� r$ �firstr� rS rS rT �test_changeCacheSize� s
z4HostnameCachingHTTPSPolicyTests.test_changeCacheSizeN)rW rX rY r� r� r� rS rS rS rT r� � s +r� c @ r� )�RequestMethodInjectionTestsz@
Test L{client.Request} against HTTP method injections.
c C s t j|dt�� dd� dS )r r N�r� r� rm r� �r, r; r. r? )rR r� rS rS rT r
�
�z=RequestMethodInjectionTests.attemptRequestWithMaliciousMethodNr
rS rS rS rT r�
� r� c @ r� )�"RequestWriteToMethodInjectionTests�H
Test L{client.Request.writeTo} against HTTP method injections.
c C �8 t �ddgi�}tjdd|dd�}||_|�t� � dS )r rf � twisted.invalidr[ r Nr� )r. r? r, r; r� �writeTor( )rR r� rm r� rS rS rT r -
� �zDRequestWriteToMethodInjectionTests.attemptRequestWithMaliciousMethodNr
rS rS rS rT r� %
r� r� c @ r� )�RequestURIInjectionTestsz=
Test L{client.Request} against HTTP URI injections.
c C s t jd|t�� dd� dS )zp
Attempt a request with the provided URI.
@param method: see L{URIInjectionTestsMixin}
r[ Nr� r� r rS rS rT r
F
r� z7RequestURIInjectionTests.attemptRequestWithMaliciousURINr rS rS rS rT r� >
r� r� c @ r� )� RequestWriteToURIInjectionTestsr� c C r� )zs
Attempt a request with the provided method.
@param method: see L{URIInjectionTestsMixin}
rf r� r[ r Nr� )r. r? r, r; r� r� r( )rR r� rm r� rS rS rT r
\
r� z>RequestWriteToURIInjectionTests.attemptRequestWithMaliciousURINr rS rS rS rT r� T
r� r� )�re r� �http.cookiejarr �ior �typingr r r r �unittestr r �zope.interface.declarationsr �zope.interface.verifyr � incrementalr
�twisted.internetr r �twisted.internet.addressr r �twisted.internet.deferr r r r r r �twisted.internet.errorr r r �twisted.internet.interfacesr �twisted.internet.protocolr r �twisted.internet.taskr �$twisted.internet.test.test_endpointsr �twisted.loggerr �twisted.python.componentsr �twisted.python.deprecater! �twisted.python.failurer" �twisted.test.iosimr# r$ �twisted.test.proto_helpersr% r& r' r( �twisted.test.test_sslverifyr) �twisted.trial.unittestr* r+ � twisted.webr, r- r. �twisted.web._newclientr/ r0 r1 r2 r3 r4 r5 rW r6 r7 r8 r9 r: r; r< r= �twisted.web.errorr> �twisted.web.http_headersr? rN r@ rA rB rC rD rE �!twisted.web.test.injectionhelpersrF rG �testMixinClassr� �runtimeTestCaserH �_ssl� ImportErrorr �twisted.internet._sslverifyrI rJ �twisted.internet.sslrK �twisted.protocols.tlsrL rM rN rZ rf rm r� r� r� r� r� r� r� r� r� r� r� rM rO r~ r� r r r rU rl r� r� r� r� r� r� r� r� r �SENSITIVE_HEADERSr( r~ r� r� r� r� r� r� r� r� r� r� rS rS rS rT �<module> s& $(
� aS / m
�
�
�
\B
8� ;^
�
(�&%
d
Y�
�
�
�