| 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 : /usr/lib/python3/dist-packages/twisted/web/test/__pycache__/ |
Upload File : |
o
5�@gx_ � @ s* d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m
Z
m Z ddl m
Z
ddlmZ ddlmZmZmZ dd lmZmZmZ dd
lmZ ddlZdd lmZ dd l m Z m Z dd
l m Z ddl!m"Z" ddl#m$Z$ ddl%m&Z&m'Z' ddl(m)Z) ddl*m+Z+ ddl,m-Z-m.Z.m/Z/ ddl0m1Z1 ddl2m Z ddl3m4Z4 ddl5m6Z6m7Z7m8Z8 ddl9m:Z:m;Z;m<Z< ddl=m>Z>m?Z?m@Z@mAZA ddlBmCZC G d d � d e)e6jD��ZEd d � ZFG d d!� d!e6jG�ZHeFeH�ZIG d"d#� d#e j4�ZJG d$d%� d%e6jG�ZKeFeK�ZLee8jM�G d&d'� d'eK��ZNeFeN�ZOG d(d)� d)eK�ZPeFeP�ZQG d*d+� d+e6jR�ZSd,d-� ZTG d.d/� d/�ZUG d0d1� d1e j4eU�ZVG d2d3� d3eV�ZWG d4d5� d5eV�ZXG d6d7� d7eV�ZYG d8d9� d9e j4eU�ZZG d:d;� d;e j4�Z[G d<d=� d=e j4�Z\G d>d?� d?e j4�Z]G d@dA� dAe j4�Z^dBdC� Z_G dDdE� dEe j4�Z`G dFdG� dGe4�ZaG dHdI� dIe j4�ZbG dJdK� dKe j4eU�ZcG dLdM� dMe j4�ZdG dNdO� dOe j4�ZeG dPdQ� dQe6jR�ZfG dRdS� dSe j4�ZgG dTdU� dUe j4eU�ZhG dVdW� dWe j4�ZiG dXdY� dYe j4eU�ZjdZd[� ZkG d\d]� d]e j4�ZlG d^d_� d_e j4�ZmG d`da� dae jn�ZoG dbdc� dce jn�ZpG ddde� dee jn�ZqdS )fz
Test HTTP support.
� N)�BytesIO)�cycle)�Sequence�Union)�skipIf�� clear_cache)�parse_qs�urlparse�
urlunsplit)�directlyProvides�
providedBy�provider)� verifyObject)�address)�ConnectionDone�ConnectionLost)�Clock)�globalLogPublisher)�loopback)� iterbytes�
networkString)�proxyForInterface)�Failure)�EventLoggingObserver�NonStreamingProducer�StringTransport)�
DummyProducer)�unittest)�TestCase)�http� http_headers�iweb)�PotentialDataLoss� _DataLoss�_IdentityTransferDecoder)� DummyChannel� bytesLinearWhitespaceComponents�sanitizedBytes� textLinearWhitespaceComponents� )�assertIsFilesystemTemporaryc @ s e Zd ZdZdS )�._IDeprecatedHTTPChannelToRequestInterfaceProxyz�
Proxy L{_IDeprecatedHTTPChannelToRequestInterface}. Used to
assert that the interface matches what L{HTTPChannel} expects.
N)�__name__�
__module__� __qualname__�__doc__� r1 r1 �</usr/lib/python3/dist-packages/twisted/web/test/test_http.pyr, 4 s r, c s � fdd�}t |t� �� |S )a�
Return a callable that proxies instances of C{clsToWrap} via
L{_IDeprecatedHTTPChannelToRequestInterface}.
@param clsToWrap: The class whose instances will be proxied.
@type cls: L{_IDeprecatedHTTPChannelToRequestInterface}
implementer.
@return: A factory that returns
L{_IDeprecatedHTTPChannelToRequestInterface} proxies.
@rtype: L{callable} whose interface matches C{clsToWrap}'s constructor.
c s � | i |��}t |�S �N)r, )�args�kwargs�instance�� clsToWrapr1 r2 �_makeRequestProxyM s z3_makeRequestProxyFactory.<locals>._makeRequestProxy)r r
)r8 r9 r1 r7 r2 �_makeRequestProxyFactory? s r: c @ � e Zd ZdZdd� ZdS )�DummyPullProducerHandlerz�
An HTTP request handler that registers a dummy pull producer to serve the
body.
The owner must call C{finish} to complete the response.
c C s& t | �| _| �d� | �| jd� d S )N�� F)r �_actualProducer�setResponseCode�registerProducer��selfr1 r1 r2 �process^ s
z DummyPullProducerHandler.processN�r- r. r/ r0 rC r1 r1 r1 r2 r< V s r< c @ � e Zd ZdZdd� Zdd� ZdS )�
DateTimeTestsz Test date parsing functions.c C s> t d�D ]}t�dd�}t�|�}t�|�}| �||� qd S )Ni' r i �5w)�range�random�randintr �datetimeToString�stringToDatetime� assertEqual)rB �i�time�timestr�time2r1 r1 r2 �
testRoundtripj s
�zDateTimeTests.testRoundtripc C sJ g d�}t �d�}|D ] }| �t�|�|� q | �t�d�t �d�� d S )N)s Sun, 06 Nov 1994 08:49:37 GMTs 06 Nov 1994 08:49:37 GMTs Sunday, 06-Nov-94 08:49:37 GMTs 06-Nov-94 08:49:37 GMTs Sunday, 06-Nov-1994 08:49:37 GMTs 06-Nov-1994 08:49:37 GMTs Sun Nov 6 08:49:37 1994s Nov 6 08:49:37 1994) i� � � � �1 �% rS rS r s Thursday, 29-Sep-16 17:15:29 GMT) i� � � � � rX � i r )�calendar�timegmrL r rK )rB � dateStrings�dateInt�
dateStringr1 r1 r2 �testStringToDatetimeq s
�z"DateTimeTests.testStringToDatetimeN)r- r. r/ r0 rQ ra r1 r1 r1 r2 rF g s rF c @ � e Zd Zdd� ZdS )�DummyHTTPHandlerc C s� | j �dd� | j �� }| �d�}|d u rt|��� }d| d | d }| �d� | �d| j� | �d| j � | �d| j
� | �d d
t |�f � | � |� | �
� d S ) Nr � content-lengths '''
�
r= s Requests Commands Version� Content-Lengths %d)�content�seek�read� getHeader�str�encoder? � setHeader�uri�method� clientproto�len�write�finish)rB �data�length�requestr1 r1 r2 rC � s
zDummyHTTPHandler.processN�r- r. r/ rC r1 r1 r1 r2 rc � � rc c @ r; )�DummyNewHTTPHandlerz�
This is exactly like the DummyHTTPHandler but it takes only one argument
in its constructor, with no default arguments. This exists to test an
alternative code path in L{HTTPChannel}.
c C s t �| |� d S r3 )rc �__init__)rB �channelr1 r1 r2 rz � � z DummyNewHTTPHandler.__init__N)r- r. r/ r0 rz r1 r1 r1 r2 ry � s ry c @ rE )�DelayedHTTPHandlerzD
Like L{DummyHTTPHandler}, but doesn't respond immediately.
c C � d S r3 r1 rA r1 r1 r2 rC � s zDelayedHTTPHandler.processc C s t �| � d S r3 )rc rC rA r1 r1 r2 �delayedProcess� � z!DelayedHTTPHandler.delayedProcessN)r- r. r/ r0 rC r r1 r1 r1 r2 r} � s r} c @ rb )�LoopbackHTTPClientc C s0 | � dd� | �dd� | �� | j�d� d S )N� GET� /foo/barrf �
�
0123456789)� sendCommand�
sendHeader�
endHeaders� transportrr rA r1 r1 r2 �connectionMade� s z!LoopbackHTTPClient.connectionMadeN)r- r. r/ r� r1 r1 r1 r2 r� � rx r� c C s |j | j_ | S )a�
Parametrizes the L{TimeoutMixin} so that it works with whatever reactor is
being used by the test.
@param protocol: A L{_GenericHTTPChannel} or something implementing a
similar interface.
@type protocol: L{_GenericHTTPChannel}
@param reactor: An L{IReactorTime} implementation.
@type reactor: L{IReactorTime}
@return: The C{channel}, with its C{callLater} method patched.
)� callLater�_channel)�protocol�reactorr1 r1 r2 �parametrizeTimeoutMixin� s
r� c @ r; )�ResponseTestMixinz�
A mixin that provides a simple means of comparing an actual response string
to an expected response string by performing the minimal parsing.
c C s� |D ]N}|dd� |d }}|d }|dd� }|� dd�\}}|�� }|�d�} | �|| � | �t|�t|�� |dt|�� }
|t|�d� }| �|
|� qdS )a(
Assert that the C{responses} matches the C{expected} responses.
@type responses: C{bytes}
@param responses: The bytes sent in response to one or more requests.
@type expected: C{list} of C{tuple} of C{bytes}
@param expected: The expected values for the responses. Each tuple
element of the list represents one response. Each byte string
element of the tuple is a full header line without delimiter, except
for the last element which gives the full response body.
N���r r* �
)�split�
splitlines�poprL �setrq ) rB � responses�expected�response�expectedHeaders�expectedContent�expectedStatus�headers�rest�statusrg r1 r1 r2 �assertResponseEquals� s
�z&ResponseTestMixin.assertResponseEqualsN)r- r. r/ r0 r� r1 r1 r1 r2 r� � � r� c @ sx e Zd ZU dZdgZeeee ef ed< dd� Z dd� Z
dd � Z d
d � Z d d
� Z
dd� Zdd� Zdd� Zdd� ZdS )� HTTP1_0Testss7 GET / HTTP/1.0
GET / HTTP/1.1
Accept: text/html
)� HTTP/1.0 200 OK�
Request: /� Command: GET� Version: HTTP/1.0� Content-Length: 13�
'''
None
'''
�expected_responsec C �` t � }t�� }t|_|�|� t| j�D ]}|�|� q|� t
d�� |� � }| � || j
� dS )zZ
Send requests over a channel and check responses match what is expected.
zall oneN�r r � HTTPChannel�DummyHTTPHandlerProxy�requestFactory�makeConnectionr �requests� dataReceived�connectionLost�IOError�valuer� r� �rB �b�a�byter� r1 r1 r2 � test_buffer
s
zHTTP1_0Tests.test_bufferc C s� t � }t� }t�� }d|_|j|_|�|� |�d� |�d� | � |j
� |�d� |�d� | � |j
� |�d� | � t |j
�d� dS )zq
L{HTTPChannel} resets its timeout whenever data from a request body is
delivered to it.
�d �& POST / HTTP/1.0
Content-Length: 2
�c � xr* N)r r r r� �timeOutr� r� r� �advance� assertFalse�
disconnectingrL rq r� )rB �clockr� r� r1 r1 r2 �test_requestBodyTimeout s
z$HTTP1_0Tests.test_requestBodyTimeoutc C sl t � }t� }t�� }|�d�}t||�}|�|� |�d� |�d� | � |j
� |�d� | � |j
� dS )zA
L{HTTPChannel}'s default timeout is 60 seconds.
Nr� �; r* ) r r r � HTTPFactory�
buildProtocolr� r� r� r� r� r� �
assertTrue�rB r� r� �factoryr� r1 r1 r2 � test_requestBodyDefaultTimeout0 s
z+HTTP1_0Tests.test_requestBodyDefaultTimeoutc C s t �| t�}t� }t� }t�� }|�d�}t||�}|� |� |�
d� | � |j � | � |j
� |�d� | �|j � | � |j
� | �dt|�� |d }| �d|d � |�d� | �|j � | � |j
� |�d� | �|j � | �|j
� | �d t|�� |d }| �d
|d � dS ) �}
If a timed out transport doesn't close after 15 seconds, the
L{HTTPChannel} will forcibly close it.
Nr� �< r* r zTiming out client: {peer}�
log_format� � z"Forcibly timing out client: {peer})r �createWithCleanupr r r r r� r� r� r� r� r� r� � disconnectedr� r� � assertEqualsrq �assertIn)rB � logObserverr� r� r� r� �eventr1 r1 r2 � test_transportForciblyClosed@ s2
z)HTTP1_0Tests.test_transportForciblyClosedc C s� t � }t� }t�� }|�d�}t||�}|�|� |�d� | �|j � | �|j
� |� d� | � |j � | �|j
� |� d� |�
d� |� d� | � |j � | �|j
� dS )z�
If a timed out transport ends up calling C{connectionLost}, it prevents
the force-closure of the transport.
Nr� r� r� r* )r r r r� r� r� r� r� r� r� r� r� r� r� r� r1 r1 r2 �+test_transportNotAbortedAfterConnectionLostc s"
z8HTTP1_0Tests.test_transportNotAbortedAfterConnectionLostc C s� t � }t� }t�� }|�d�}d|j_t||�}|�|� |� d� | �
|j � | �
|j � |�
d� | �|j � | �
|j � |�
d� | �|j � | �
|j � dS )zh
If the L{HTTPChannel} has its c{abortTimeout} set to L{None}, it never
aborts.
Nr� r� l )r r r r� r� r� � abortTimeoutr� r� r� r� r� r� r� r� r� r1 r1 r2 �,test_transportNotAbortedWithZeroAbortTimeout� s
z9HTTP1_0Tests.test_transportNotAbortedWithZeroAbortTimeoutc C s� t � }t� }t�� }|�d�}t||�}|�|� |�d� | �|j � | �|j
� |� d� |� d� | � |j � | � |j
� |�
t� dS )r� Nr� r� rZ )r r r r� r� r� r� r� r� r� r� r� r� r� r r� r1 r1 r2 �"test_connectionLostAfterForceClose� s
z/HTTP1_0Tests.test_connectionLostAfterForceClosec C r� )zf
Test that a L{http.Request} subclass with no queued kwarg works as
expected.
�all doneNr� r� r1 r1 r2 �test_noPipeliningApi� s
z!HTTP1_0Tests.test_noPipeliningApic C s� t � }t�� }t|_|�|� t| j�D ]}|�|� q|� � }| �
|d� | �
dt |j�� |jrH| �
dt |j�� |jd j }|�
� |js2|� � }| �|| j� dS )zW
Test that pipelined requests get buffered, not processed in parallel.
� r* r N)r r r� �DelayedHTTPHandlerProxyr� r� r r� r� r� rL rq �originalr r� r� )rB r� r� r� r� rv r1 r1 r2 �test_noPipelining� s
�z HTTP1_0Tests.test_noPipeliningN)r- r. r/ r� r� r r �bytes�__annotations__r� r� r� r� r� r� r� r� r� r1 r1 r1 r2 r� � s
� � # r� c @ s e Zd ZdZg d�ZdS )� HTTP1_1Testss� GET / HTTP/1.1
Accept: text/html
POST / HTTP/1.1
Content-Length: 10
0123456789POST / HTTP/1.1
Content-Length: 10
0123456789HEAD / HTTP/1.1
))� HTTP/1.1 200 OKr� r� � Version: HTTP/1.1r� r� �r� r� �
Command: POSTr� s Content-Length: 21� '''
10
0123456789'''
r� )r� r� s
Command: HEADr� r� r� N�r- r. r/ r� r� r1 r1 r1 r2 r� � s � r� c @ s e Zd ZdZdgZdS )�HTTP1_1_close_Tests�J GET / HTTP/1.1
Accept: text/html
Connection: close
GET / HTTP/1.0
)r� s Connection: closer� r� r� r� r� Nr� r1 r1 r1 r2 r� s
�
�r� c @ s$ e Zd ZdZdZdd� Zdd� ZdS )� HTTP0_9Testss GET /
� HTTP/1.1 400 Bad Request
c C s | � ||� d S r3 )rL )rB r� �expectedResponser1 r1 r2 r� 1 r| z!HTTP0_9Tests.assertResponseEqualsc C s
t �d��)NzHTTP/0.9 not supported)r �SkipTestrA r1 r1 r2 r� 4 �
z HTTP0_9Tests.test_noPipeliningN)r- r. r/ r� r� r� r� r1 r1 r1 r2 r� + s
r� c @ sL e Zd ZdZdZddgZdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dS )�PipeliningBodyTestszl
Pipelined requests get buffered and executed in the order received,
not processed in parallel.
st POST / HTTP/1.1
Content-Length: 10
0123456789POST / HTTP/1.1
Transfer-Encoding: chunked
a
0123456789
0
r� )r� r� r� r� s Content-Length: 23s '''
None
0123456789'''
c C s� t � }t�� }t|_|�|� t| j�D ]}|�|� q| � |�
� d� | � dt |j�� |jrF| � dt |j�� |jd j }|�
� |js0| �|�
� | j� dS )z�
Imitate a slow connection that delivers one byte at a time.
The request handler (L{DelayedHTTPHandler}) is puppeted to
step through the handling of each request.
r� r* r N)r r r� r� r� r� r r� r� rL r� rq r� r r� �expectedResponses)rB r� r� r� rv r1 r1 r2 �test_stepwiseTinyTube^ s
�z)PipeliningBodyTests.test_stepwiseTinyTubec C s� t � }t�� }t|_|�|� |�| j� | �|� � d� | �dt
|j�� |jr?| �dt
|j�� |jd j }|� � |js)| �
|� � | j� dS )z�
Imitate a fast connection where several pipelined
requests arrive in a single read. The request handler
(L{DelayedHTTPHandler}) is puppeted to step through the
handling of each request.
r� r* r N)r r r� r� r� r� r� r� rL r� rq r� r r� r� )rB r� r� rv r1 r1 r2 �test_stepwiseDumpTruckx s
�z*PipeliningBodyTests.test_stepwiseDumpTruckc C s` t � }t�� }t|_|�|� t| j�D ]}|�|� | � t
|j�d� q| � |� � | j
� dS )z�
Imitate a slow connection that delivers one byte at a time.
(L{DummyHTTPHandler}) immediately responds, but no more
than one
r* N)r r r� r� r� r� r r� r� �assertLessEqualrq r� r� r� )rB r� r� r� r1 r1 r2 �test_immediateTinyTube� s
z*PipeliningBodyTests.test_immediateTinyTubec C s@ t � }t�� }t|_|�|� |�| j� | �|� � | j
� dS )aR
Imitate a fast connection where several pipelined
requests arrive in a single read. The request handler
(L{DummyHTTPHandler}) immediately responds.
This doesn't check the at-most-one pending request
invariant but exercises otherwise uncovered code paths.
See GHSA-c8m8-j448-xjx7.
N) r r r� r� r� r� r� r� r� r� r� )rB r� r� r1 r1 r2 �test_immediateDumpTruck� s
z+PipeliningBodyTests.test_immediateDumpTruckc C s\ t � }t�� }t|_|�|� |jt| j� d }|� | j| � | �
|� � | j | � dS )a�
Imitate a fast connection where a so many pipelined
requests arrive in a single read that backpressure is indicated.
The request handler (L{DummyHTTPHandler}) immediately responds.
This doesn't check the at-most-one pending request
invariant but exercises otherwise uncovered code paths.
See GHSA-c8m8-j448-xjx7.
@see: L{http.HTTPChannel._optimisticEagerReadSize}
r� N)
r r r� r� r� r� �_optimisticEagerReadSizerq r� r� r� r� r� )rB r� r� �overLimitCountr1 r1 r2 �test_immediateABiggerTruck� s
z.PipeliningBodyTests.test_immediateABiggerTruckc C s� t � }t�� }t|_|�|� |jt| j� }t d|d �D ]}|�
| j� | � |j ddj
|j |d�� q |�
| j� | �|j d� dS )z�
When pipelined requests are received, we will optimistically continue
receiving data up to a specified limit, then pause the transport.
@see: L{http.HTTPChannel._optimisticEagerReadSize}
r* � producingz(state was {state!r} after {x} iterations)�state�x�pausedN)r r r� r� r� r� r� rq r� rG r� rL �
producerState�formatr� )rB r� r� �
underLimitr� r1 r1 r2 �test_pipeliningReadLimit� s
�� z,PipeliningBodyTests.test_pipeliningReadLimitN) r- r. r/ r0 r� r� r� r� r� r� r� r r1 r1 r1 r2 r� 8 s �� r� c @ s. e Zd ZdZG dd� dej�ZdZdd� ZdS )�
ShutdownTestszM
Tests that connections can be shut down by L{http.Request} objects.
c @ r; )z!ShutdownTests.ShutdownHTTPHandlerzL
A HTTP handler that just immediately calls loseConnection.
c C � | � � d S r3 )�loseConnectionrA r1 r1 r2 rC � � z)ShutdownTests.ShutdownHTTPHandler.processNrD r1 r1 r1 r2 �ShutdownHTTPHandler� � r s1 POST / HTTP/1.1
Content-Length: 10
0123456789c C sT t � }t�� }t| j�|_|�|� |�| j� | � |j
� |� � }| � |d� dS )zi
Calling L{http.Request.loseConnection} causes the transport to be
disconnected.
r� N)
r r r� r: r r� r� r� rv r� r� r� rL )rB r� r� r� r1 r1 r2 �test_losingConnection� s
z#ShutdownTests.test_losingConnectionN) r- r. r/ r0 r �Requestr rv r r1 r1 r1 r2 r � s
r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �
SecurityTestsz]
Tests that L{http.Request.isSecure} correctly takes the transport into
account.
c C �6 t �� }t�� }|�|� t�|�}| �|�� � dS )z�
Calling L{http.Request.isSecure} when the channel is backed with a
secure transport will return L{True}.
N)r& �SSLr r� r� r
r� �isSecure�rB r� r� �reqr1 r1 r2 �
test_isSecure �
zSecurityTests.test_isSecurec C r )z�
Calling L{http.Request.isSecure} when the channel is not backed with a
secure transport will return L{False}.
N)r& �TCPr r� r� r
r� r r r1 r1 r2 �test_notSecure r z SecurityTests.test_notSecurec C sT t �� }t�� }|�|� t�|�}|j�|� |�d� |� � | �
|� � � dS )zt
After a request is finished, calling L{http.Request.isSecure} will
always return L{False}.
r= N) r& r
r r� r� r
r� �appendr? rs r� r r r1 r1 r2 �test_notSecureAfterFinish' s
z'SecurityTests.test_notSecureAfterFinishN)r- r. r/ r0 r r r r1 r1 r1 r2 r s
r c @ s� e Zd ZdZdZdd� Zeej d�dd� �Z dd � Z
d
d � Z d d
� Z eej d�dd� �Z
eejd�dd� �Zdd� Zdd� Zdd� Zeej d�dd� �Zeej d�dd � �Zd S ) �GenericHTTPChannelTestsz�
Tests for L{http._genericHTTPChannelProtocol}, a L{HTTPChannel}-alike which
can handle different HTTP protocol channels.
r� c C sH t �d�}t|_|�|� t| j�D ]}|�|� q|�t d�� |j
S )z{
Run a request using the specific instance of a transport. Returns the
negotiated protocol string.
r� r� ) r �"_genericHTTPChannelProtocolFactoryr� r� r� r r� r� r� r� �_negotiatedProtocol)rB �tr� r� r1 r1 r2 �'_negotiatedProtocolForTransportInstanceF s
z?GenericHTTPChannelTests._negotiatedProtocolForTransportInstancezHTTP/2 support not presentc C s� t � }t�d�}t|_d|_|j|_t� }d|_|� |� t
� |� � t
�
t
�dt
�d���� |� � d }|�d� | �|jd� | �|j� t
� |� � t
�
t
�dt
�d���� dS )zg
When the transport is switched to H2, the HTTPChannel timeouts are
cancelled.
r� r� � h2� cancelledFr N)r r r r� r� r� r� r �negotiatedProtocolr� �hamcrest� assert_that�getDelayedCalls�contains� has_property�equal_tor� rL r r� r )rB r� r� r� �
h11Timeoutr1 r1 r2 �test_h2CancelsH11TimeoutT s<
���
���z0GenericHTTPChannelTests.test_h2CancelsH11Timeoutc C s t � }| �|�}| �|d� dS )z�
If the transport has no support for protocol negotiation (no
negotiatedProtocol attribute), HTTP/1.1 is assumed.
� http/1.1N)r r rL �rB r� r r1 r1 r2 �test_protocolUnspecified� s
z0GenericHTTPChannelTests.test_protocolUnspecifiedc C s& t � }d|_| �|�}| �|d� dS )z�
If the transport has no support for protocol negotiation (returns None
for negotiatedProtocol), HTTP/1.1 is assumed.
Nr' �r r r rL r( r1 r1 r2 �test_protocolNone� �
z)GenericHTTPChannelTests.test_protocolNonec C �& t � }d|_| �|�}| �|d� dS )zi
If the transport reports that HTTP/1.1 is negotiated, that's what's
negotiated.
r' Nr* r( r1 r1 r2 � test_http11� r, z#GenericHTTPChannelTests.test_http11c C r- )z}
If the transport reports that HTTP/2 is negotiated and HTTP/2 is
present, that's what's negotiated.
r Nr* r( r1 r1 r2 �test_http2_present� s
z*GenericHTTPChannelTests.test_http2_presentzHTTP/2 support presentc C � t � }d|_| �t| j|� dS )z�
If the transport reports that HTTP/2 is negotiated and HTTP/2 is not
present, an error is encountered.
r N)r r � assertRaises�
ValueErrorr �rB r� r1 r1 r2 �test_http2_absent� s �z)GenericHTTPChannelTests.test_http2_absentc C r0 )z�
If the transport reports that a protocol other than HTTP/1.1 or HTTP/2
is negotiated, an error occurs.
s smtpN)r r r1 �AssertionErrorr r3 r1 r1 r2 �test_unknownProtocol� s �z,GenericHTTPChannelTests.test_unknownProtocolc C s$ t �d�}d|j_| �|jd� dS )zK
The C{factory} attribute is taken from the inner channel.
r� � FooN)r r r� r� rL )rB r� r1 r1 r2 � test_factory� s
z$GenericHTTPChannelTests.test_factoryc C sB t � }tj|d�}|�d�}| �|j|j� | �|jj|j� dS )z�
If C{callLater} is patched onto the L{http._GenericHTTPChannelProtocol}
then we need to propagate it through to the backing channel.
�r� N)r r r� r� rL r� r� )rB r� r� r� r1 r1 r2 �*test_GenericHTTPChannelPropagatesCallLater� s
zBGenericHTTPChannelTests.test_GenericHTTPChannelPropagatesCallLaterc C s� t � }tj|d�}|�d�}| �|j|j� | �|jj|j� t� }d|_t |_
|� |� |� d� | �|j|j� | �|jj|j� dS )z�
If C{callLater} is patched onto the L{http._GenericHTTPChannelProtocol}
then we need to propagate it across onto a new backing channel after
upgrade.
r9 Nr � P)
r r r� r� rL r� r� r r rc r� r� r� �rB r� r� r� r� r1 r1 r2 �'test_genericHTTPChannelCallLaterUpgrade� s
z?GenericHTTPChannelTests.test_genericHTTPChannelCallLaterUpgradec C sf t � }d|_t�d�}t|_|�|� |j}| �|j |� |�
d� | � |j |� | �|j |j� dS )z�
The L{_GenericHTTPChannelProtocol} will unregister its proxy channel
from the transport if upgrade is negotiated.
r r� r; N) r r r r r� r� r� r� �assertIs�producerr� � assertIsNot)rB r� �genericProtocol�originalChannelr1 r1 r2 �test_unregistersProducer� s
z0GenericHTTPChannelTests.test_unregistersProducerN)r- r. r/ r0 r� r r r �
H2_ENABLEDr& r) r+ r. r/ r4 r6 r8 r: r= rC r1 r1 r1 r2 r 7 s* �
1
r c @ sZ e Zd Zddddd�ZdZdZdZdZdd� Zd d
� Z d d � Z
d
d� Z dd� Z dd� Z
dS )�HTTPLoopbackTestsr� r� � HTTP/1.0s 21)s requests commands versionrd r c C s" d| _ | �|d� | �|d� d S )Nr* rF � 200)� gotStatusrL �rB �versionr� �messager1 r1 r2 �
_handleStatus! s z HTTPLoopbackTests._handleStatusc C s d| _ | �|d� d S )Nr* r� )� gotResponserL )rB rt r1 r1 r2 �_handleResponse& s z!HTTPLoopbackTests._handleResponsec C s& | j d | _ | �| j|�� |� d S �Nr* )�
numHeadersrL r� �lower)rB �keyr� r1 r1 r2 �
_handleHeader* s z HTTPLoopbackTests._handleHeaderc C s d| _ | �| jd� d S )Nr* � )�
gotEndHeadersrL rP rA r1 r1 r2 �_handleEndHeaders. s z#HTTPLoopbackTests._handleEndHeadersc C sP t �� }t|_t� }| j|_| j|_| j |_
| j |_ t
�||�}|�| j� |S r3 )r r� r� r� r� rN �handleResponserS � handleHeaderrV �handleEndHeadersrL � handleStatusr �
loopbackAsync� addCallback�_cbTestLoopback)rB �server�client�dr1 r1 r2 � testLoopback2 s z HTTPLoopbackTests.testLoopbackc C s@ | j r | jr | jstd�| j | j| jg���| `| `| ` | `d S )Nzdidn't get all callbacks {})rH rM rU � RuntimeErrorr rP )rB �ignoredr1 r1 r2 r] > s ��z!HTTPLoopbackTests._cbTestLoopbackN)r- r. r/ r� rP rH rM rU rL rN rS rV ra r] r1 r1 r1 r2 rE s � rE c K s6 t �t� d�}| �� D ]
\}}|j�t|�|� q |S )zR
Make a request with the given request headers for the persistence tests.
F)r r
r& �items�requestHeaders�
setRawHeadersr )r� rv �
headerName�vr1 r1 r2 � _prequestK s ri c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
�PersistenceTestsz0
Tests for persistent HTTP connections.
c C s t �� | _t� | _d S r3 )r r� r{ ri rv rA r1 r1 r2 �setUpZ �
zPersistenceTests.setUpc C �6 | j �| jd�}| �|� | �g t| jj�� �� dS )zl
After being used for an I{HTTP/0.9} request, the L{HTTPChannel} is not
persistent.
s HTTP/0.9N�r{ �checkPersistencerv r� rL �list�responseHeaders�getAllRawHeaders�rB �persistr1 r1 r2 � test_http09^ �
z PersistenceTests.test_http09c C rm )zl
After being used for an I{HTTP/1.0} request, the L{HTTPChannel} is not
persistent.
rF Nrn rs r1 r1 r2 � test_http10g rv z PersistenceTests.test_http10c C rm )zh
After being used for an I{HTTP/1.1} request, the L{HTTPChannel} is
persistent.
� HTTP/1.1N)r{ ro rv r� rL rp rq rr rs r1 r1 r2 r. p rv z PersistenceTests.test_http11c C sF t dgd�}| j�|d�}| �|� | �ddgfgt|j�� �� dS )z�
After being used for an I{HTTP/1.1} request with a I{Connection: Close}
header, the L{HTTPChannel} is not persistent.
s close)�
connectionrx s
ConnectionN)ri r{ ro r� rL rp rq rr )rB rv rt r1 r1 r2 �test_http11Closey s
�z!PersistenceTests.test_http11CloseN) r- r. r/ r0 rk ru rw r. rz r1 r1 r1 r2 rj U s rj c @ s` e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dS )� IdentityTransferEncodingTestsz0
Tests for L{_IdentityTransferDecoder}.
c C s. g | _ g | _d| _t| j| j j| jj�| _dS )z�
Create an L{_IdentityTransferDecoder} with callbacks hooked up so that
calls to them can be inspected.
r� N)rt rs �
contentLengthr% r �decoderrA r1 r1 r2 rk � s
�z#IdentityTransferEncodingTests.setUpc C s< | j �d| j � | �| jd| j g� | �| jdg� dS )aC
If L{_IdentityTransferDecoder.dataReceived} is called with a byte string
with length equal to the content length passed to
L{_IdentityTransferDecoder}'s initializer, the data callback is invoked
with that string and the finish callback is invoked with a zero-length
string.
r� r� N�r} r� r| rL rt rs rA r1 r1 r2 �test_exactAmountReceived� s z6IdentityTransferEncodingTests.test_exactAmountReceivedc C sp | j �d� | �| jdg� | �| jg � | j �d| jd � | �| jdd| jd g� | �| jdg� dS )a3
If L{_IdentityTransferDecoder.dataReceived} is called multiple times
with byte strings which, when concatenated, are as long as the content
length provided, the data callback is invoked with each string and the
finish callback is invoked only after the second call.
r� � yr* r� N)r} r� rL rt rs r| rA r1 r1 r2 �test_shortStrings� s z/IdentityTransferEncodingTests.test_shortStringsc C s@ | j �d| j d � | �| jd| j g� | �| jdg� dS )a3
If L{_IdentityTransferDecoder.dataReceived} is called with a byte string
with length greater than the provided content length, only the prefix
of that string up to the content length is passed to the data callback
and the remainder is passed to the finish callback.
r� r� Nr~ rA r1 r1 r2 �test_longString� s z-IdentityTransferEncodingTests.test_longStringc sj g �� �fdd�}t d| jj|�� � �d� | ��g � � �d� �d �t� | �t�d j�d� dS ) z�
If data is passed to L{_IdentityTransferDecoder.dataReceived} after the
finish callback has been invoked, C{RuntimeError} is raised.
c s2 z� � d� W d S ty ��t� � Y d S w )N� foo)r� �
BaseExceptionr r �r� �r} �failuresr1 r2 rs � s
�zJIdentityTransferEncodingTests.test_rejectDataAfterFinished.<locals>.finish� s xxxxr� r z;_IdentityTransferDecoder cannot decode data after finishingN) r% rt r r� rL �traprb rk r� )rB rs r1 r� r2 � test_rejectDataAfterFinished� s
�z:IdentityTransferEncodingTests.test_rejectDataAfterFinishedc C sZ g }g }t d|j|j�}|�d� | �|dg� |�d� | �|ddg� | �|g � dS )z�
If L{_IdentityTransferDecoder} is constructed with L{None} for the
content length, it passes all data delivered to it through to the data
callback.
Nr� r� )r% r r� rL )rB rt rs r} r1 r1 r2 �test_unknownContentLength� s
z7IdentityTransferEncodingTests.test_unknownContentLengthc C s | � |jd� | � |jd� dS )z�
Check the decoder's data and finish callbacks and make sure they are
None in order to help avoid references cycles.
N)�assertIdentical� dataCallback�finishCallback)rB r} r1 r1 r2 � _verifyCallbacksUnreferenced� s z:IdentityTransferEncodingTests._verifyCallbacksUnreferencedc C s6 | j �d| jd � | �t| j j� | �| j � dS )z�
L{_IdentityTransferDecoder.noMoreData} raises L{_DataLoss} if it is
called and the content length is known but not enough bytes have been
delivered.
r� r* N)r} r� r| r1 r$ �
noMoreDatar� rA r1 r1 r2 �test_earlyConnectionLose� s z6IdentityTransferEncodingTests.test_earlyConnectionLosec C sN g }g }t d|j|j�}| �t|j� | �|g � | �|dg� | �|� dS )z�
L{_IdentityTransferDecoder.noMoreData} calls the finish callback and
raises L{PotentialDataLoss} if it is called and the content length is
unknown.
Nr� )r% r r1 r# r� rL r� )rB �body�finishedr} r1 r1 r2 �'test_unknownContentLengthConnectionLose� s zEIdentityTransferEncodingTests.test_unknownContentLengthConnectionLosec C s, | j �d| j � | j �� | �| j � dS )z�
L{_IdentityTransferDecoder.noMoreData} does not raise any exception if
it is called when the content length is known and that many bytes have
been delivered.
r� N)r} r� r| r� r� rA r1 r1 r2 �test_finishedConnectionLose s
z9IdentityTransferEncodingTests.test_finishedConnectionLoseN)r- r. r/ r0 rk r r� r� r� r� r� r� r� r� r1 r1 r1 r2 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*S )+� ChunkedTransferEncodingTestsz�
Tests for L{_ChunkedTransferDecoder}, which turns a byte stream encoded
using HTTP I{chunked} C{Transfer-Encoding} back into the original byte
stream.
c C s: g }t �|jd�}|�d� |�d� | �|g d�� dS )z�
L{_ChunkedTransferDecoder.dataReceived} decodes chunked-encoded data
and passes the result to the specified callback.
Ns 3
abc
5
12345
s a
0123456789
)� abc� 12345r� �r �_ChunkedTransferDecoderr r� rL �rB �L�pr1 r1 r2 �
test_decoding s
z*ChunkedTransferEncodingTests.test_decodingc C sR g }g }t �|j|j�}td�D ]}|�|� q| �|g d�� | �|dg� dS )z{
L{_ChunkedTransferDecoder.dataReceived} decodes chunks broken up and
delivered in multiple calls.
� 3
abc
5
12345
0
�� a� b� c� 1� 2� 3� 4� 5r� N)r r� r r r� rL )rB r� r� r� �sr1 r1 r2 �
test_short s z'ChunkedTransferEncodingTests.test_shortc C sX g }g }t �|j|j�}|�d� |�d� |�d� | �|ddg� | �|dg� dS )zx
L{_ChunkedTransferDecoder.dataReceived} delivers partial chunk data as
soon as it is received.
s a;
12345s 67890s
0;
...r� s ...Nr� )rB rt r� r� r1 r1 r2 � test_long- s
z&ChunkedTransferEncodingTests.test_longc C sf g }g }t �|j|j�}|�d� td�D ] }|�|� |�d� q| �|g d�� | �|dg� dS )zr
L{_ChunkedTransferDecoder.dataReceived} is robust against receiving
a zero-length input.
r� r� r� N)r r� r r� r rL )rB �chunksr� r� r� r1 r1 r2 �
test_empty; s
z'ChunkedTransferEncodingTests.test_emptyc C �. g }t �|jd�}|�d� | �|dg� dS )z
L{_ChunkedTransferDecoder.dataReceived} doesn't treat CR LF pairs
embedded in chunk bodies specially.
Ns 2
�
r� r� r1 r1 r2 �
test_newlinesJ �
z*ChunkedTransferEncodingTests.test_newlinesc C r� )zd
L{_ChunkedTransferDecoder.dataReceived} disregards chunk-extension
fields.
Ns 3; x-foo=bar
abc
r� r� r� r1 r1 r2 �test_extensionsT r� z,ChunkedTransferEncodingTests.test_extensionsc C sZ d}d}d}|| | D ] }dt |f� d }t�dd� dd� �}| �tj|j|� q d S )
z�
L{_ChunkedTransferDecoder.dataReceived} raises
L{_MalformedChunkedDataError} when the chunk extension fields contain
invalid characters.
This is a potential request smuggling vector: see GHSA-c2jg-hw38-jrqq.
s
� \� s 3; �
abc
c S r~ r3 r1 �r� r1 r1 r2 �<lambda>o � zGChunkedTransferEncodingTests.test_extensionsMalformed.<locals>.<lambda>c S r~ r3 r1 r� r1 r1 r2 r� p r� N)r� r r� r1 �_MalformedChunkedDataErrorr� )rB �invalidControl�invalidDelimiter�
invalidDelr� rt r� r1 r1 r2 �test_extensionsMalformed^ s ���z5ChunkedTransferEncodingTests.test_extensionsMalformedc C s0 t �dd�}| �t j|jddt j d � dS )a(
L{_ChunkedTransferDecoder.dataReceived} raises
L{_MalformedChunkedDataError} when the chunk size line exceeds 4 KiB.
This applies even when the data has already been received and buffered
so that behavior is consistent regardless of how bytes are framed.
Ns 3;� .r� �r r� r1 r� r� �maxChunkSizeLineLength�rB r� r1 r1 r2 �test_oversizedChunkSizeLinet s �z8ChunkedTransferEncodingTests.test_oversizedChunkSizeLinec C s, t �dd�}| �t j|jdt jd � dS )a
L{_ChunkedTransferDecoder.dataReceived} raises
L{_MalformedChunkedDataError} when the amount of data buffered while
looking for the end of the chunk size line exceeds 4 KiB so
that buffering does not continue without bound.
Nr� r* r� r� r1 r1 r2 �"test_oversizedChunkSizeLinePartial� s �z?ChunkedTransferEncodingTests.test_oversizedChunkSizeLinePartialc C �* t �dd� dd� �}| �t j|jd� dS )z�
L{_ChunkedTransferDecoder.dataReceived} raises
L{_MalformedChunkedDataError} when the chunk size can't be decoded as
a base-16 integer.
c S r~ r3 r1 r� r1 r1 r2 r� � r� zFChunkedTransferEncodingTests.test_malformedChunkSize.<locals>.<lambda>c S r~ r3 r1 r� r1 r1 r2 r� � r� s bloop
abc
N�r r� r1 r� r� r� r1 r1 r2 �test_malformedChunkSize� � �
�z4ChunkedTransferEncodingTests.test_malformedChunkSizec C r� )z�
L{_ChunkedTransferDecoder.dataReceived} raises
L{_MalformedChunkedDataError} when the chunk size is negative.
c S r~ r3 r1 r� r1 r1 r2 r� � r� zNChunkedTransferEncodingTests.test_malformedChunkSizeNegative.<locals>.<lambda>c S r~ r3 r1 r� r1 r1 r2 r� � r� s -3
abc
Nr� r� r1 r1 r2 � test_malformedChunkSizeNegative� s �
�z<ChunkedTransferEncodingTests.test_malformedChunkSizeNegativec C r� )a
L{_ChunkedTransferDecoder.dataReceived} raises
L{_MalformedChunkedDataError} when the chunk size is prefixed with
"0x", as if it were a Python integer literal.
This is a potential request smuggling vector: see GHSA-c2jg-hw38-jrqq.
c S r~ r3 r1 r� r1 r1 r2 r� � r� zIChunkedTransferEncodingTests.test_malformedChunkSizeHex.<locals>.<lambda>c S r~ r3 r1 r� r1 r1 r2 r� � r� s
0x3
abc
Nr� r� r1 r1 r2 �test_malformedChunkSizeHex� s �
�z7ChunkedTransferEncodingTests.test_malformedChunkSizeHexc C r� )z�
L{_ChunkedTransferDecoder.dataReceived} raises
L{_MalformedChunkedDataError} when the chunk is followed by characters
other than C{\r\n}.
c S r~ r3 r1 r� r1 r1 r2 r� � r� zEChunkedTransferEncodingTests.test_malformedChunkEnd.<locals>.<lambda>c S r~ r3 r1 r� r1 r1 r2 r� � r� s
3
abc!!!!Nr� r� r1 r1 r2 �test_malformedChunkEnd� r� z3ChunkedTransferEncodingTests.test_malformedChunkEndc C r� )z�
L{_ChunkedTransferDecoder.dataReceived} raises
L{_MalformedChunkedDataError} when the terminal zero-length chunk is
followed by characters other than C{\r\n}.
c S r~ r3 r1 r� r1 r1 r2 r� � r� zJChunkedTransferEncodingTests.test_malformedChunkEndFinal.<locals>.<lambda>c S r~ r3 r1 r� r1 r1 r2 r� � r� s
3
abc
0
!!Nr� r� r1 r1 r2 �test_malformedChunkEndFinal� r� z8ChunkedTransferEncodingTests.test_malformedChunkEndFinalc C �. g }t �d|j�}|�d� | �|dg� dS )z�
L{_ChunkedTransferDecoder.dataReceived} interprets a zero-length
chunk as the end of the chunked data stream and calls the completion
callback.
N� 0
r� r� �rB r� r� r1 r1 r2 � test_finish� s
z(ChunkedTransferEncodingTests.test_finishc C r� )z�
L{_ChunkedTransferDecoder.dataReceived} passes any bytes which come
after the terminating zero-length chunk to the completion callback.
Ns
0
hello� hellor� r� r1 r1 r2 �
test_extra� r� z'ChunkedTransferEncodingTests.test_extrac C s. t �ddd� �}|�d� | �t|jd� dS )z�
L{_ChunkedTransferDecoder.dataReceived} raises C{RuntimeError} if it
is called after it has seen the last chunk.
Nc S r~ r3 r1 r� r1 r1 r2 r� � r� zAChunkedTransferEncodingTests.test_afterFinished.<locals>.<lambda>r� r� )r r� r� r1 rb r� r1 r1 r2 �test_afterFinished� s
z/ChunkedTransferEncodingTests.test_afterFinishedc C s< t �ddd� �}|�d� | �t|j�}| �t|�d� dS )z�
L{_ChunkedTransferDecoder.noMoreData} raises L{_DataLoss} if it is
called and the end of the last trailer has not yet been received.
Nc S r~ r3 r1 r� r1 r1 r2 r� � r� zGChunkedTransferEncodingTests.test_earlyConnectionLose.<locals>.<lambda>s 0
zYChunked decoder in 'TRAILER' state, still expecting more data to get to 'FINISHED' state.)r r� r� r1 r$ r� rL rk )rB �parser�excr1 r1 r2 r� � s
�z5ChunkedTransferEncodingTests.test_earlyConnectionLosec C s& t �ddd� �}|�d� |�� dS )z�
L{_ChunkedTransferDecoder.noMoreData} does not raise any exception if
it is called after the terminal zero length chunk is received.
Nc S r~ r3 r1 r� r1 r1 r2 r� r� zJChunkedTransferEncodingTests.test_finishedConnectionLose.<locals>.<lambda>r� )r r� r� r� )rB r� r1 r1 r2 r� s
z8ChunkedTransferEncodingTests.test_finishedConnectionLosec sL g � g �� ��fdd�}t �d|����d� | �� g � | ��dg� dS )z�
L{_ChunkedTransferDecoder.noMoreData} can be called from the finished
callback without raising an exception.
c s< z�� � W n ty � �t� � Y d S w ��d� d S �NT)r� r� r r )�extra��errorsr� � successesr1 r2 r� s �zOChunkedTransferEncodingTests.test_reentrantFinishedNoMoreData.<locals>.finishedNr� T)r r� r� rL )rB r� r1 r� r2 � test_reentrantFinishedNoMoreData s
z=ChunkedTransferEncodingTests.test_reentrantFinishedNoMoreDataN)r- r. r/ r0 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r1 r1 r1 r2 r� s,
r� c @ s> e Zd Zg d�Zdd� Zdd� Zdd� Zdd
d �Zd d
� ZdS )�
ChunkingTests)s abcvr� s fdfsd423s Ffasfas
s 523523
fsdfs 4234c C sf | j D ]}d�t�|��}| �|dft�|�� q| �ttjd� | �ttjd� | �ttjd� d S )Nr� s -5
malformed!
s 0xa
malformed!
s 0XA
malformed!
)�strings�joinr �toChunkrL � fromChunkr1 r2 )rB r� �chunkedr1 r1 r2 �
testChunks& s
zChunkingTests.testChunksc C st d� dd� | jD ��}g }d}t|�D ] }|| }zt�|�\}}|�|� W q ty0 Y qw | �|| j� d S )Nr� c S s g | ]
}d � t�|���qS )r� )r� r r� )�.0r r1 r1 r2 �
<listcomp>/ s z8ChunkingTests.testConcatenatedChunks.<locals>.<listcomp>)r� r� r r r� r r2 rL )rB r� �result�buffer�crt r1 r1 r2 �testConcatenatedChunks. s �z$ChunkingTests.testConcatenatedChunksc C sn t � }t�� }|�|� t�|d�}|�d� d|_|j�ddg� |� d� |� d� | �
|� � dg� d S )
zV
Test that the L{HTTPChannel} correctly chunks responses when needed.
Fr= rx � test� lemur� Hello� World!�r� � Test: lemur� Transfer-Encoding: chunkeds 5
Hello
6
World!
N) r r r� r� r
r? rp rq rf rr r� r� )rB �transr{ r r1 r1 r2 �test_chunkedResponses; s
��z#ChunkingTests.test_chunkedResponsesNr* c C s� t �� }|r t|�|_|�dd�}|�dd�\}}t� }|�|� |�|d � t t
|�| d �D ] }|j j r: n|�d�
t �||| |d | � ��� q2|�d�
t �d��� |�td�� |S )z�
Execute a web request based on plain text content, chunking
the request payload.
This is a stripped-down, chunking version of ParsingTests.runRequest.
re r� r� r* r� r� )r r� r: r� �replacer� r r� r� rG rq r� r� r� r� r� r� ) rB � httpRequestr� � chunkSizer{ �headerr� r� �posr1 r1 r2 �runChunkedRequestW s"
"�z ChunkingTests.runChunkedRequestc �l g � G � fdd�dt j�}d}| j||dd�}| �|j�� d� | �t� �d� | �� d jd d
gi� d S ) a
Test that chunked uploads are actually processed into args.
This is essentially a copy of ParsingTests.test_multipartFormData,
just with chunking put in.
This fails as of twisted version 18.9.0 because of bug #9678.
c � e Zd Z� fdd�ZdS )z7ChunkingTests.test_multipartFormData.<locals>.MyRequestc � � � | � | �d� | �� d S �Ns done�r rr rs rA �� processedr1 r2 rC � �
z?ChunkingTests.test_multipartFormData.<locals>.MyRequest.processNrw r1 r� r1 r2 � MyRequest� � r� s� POST / HTTP/1.0
Content-Type: multipart/form-data; boundary=AaB03x
Transfer-Encoding: chunked
--AaB03x
Content-Type: text/plain
Content-Disposition: form-data; name="text"
Content-Transfer-Encoding: quoted-printable
abasdfg
--AaB03x--
r� )r� � HTTP/1.0 200 OK
doner* r � text� abasdfgN)r r
r� rL r� r� rq r4 �rB r� r r{ r1 r� r2 �test_multipartFormDataw s
z$ChunkingTests.test_multipartFormDatarO ) r- r. r/ r� r� r� r� r� r r1 r1 r1 r2 r� " s
r� c @ s: e Zd ZdZdd� ZdNdd�Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Z d6d7� Z d8d9� Z d:d;� Z d<d=� Z d>d?� Z!d@dA� Z"dBdC� Z#dDdE� Z$dFdG� Z%dHdI� Z&dJdK� Z'dLdM� Z(dS )O� ParsingTestsz7
Tests for protocol parsing in L{HTTPChannel}.
c C s
d| _ d S )NF��
didRequestrA r1 r1 r2 rk � r� zParsingTests.setUpNTc C s� |st �� }|r
t|�|_|�dd�}t� }|�|� t|�D ]
}|jj r' n|�
|� q |� t d�� |r>| �
| j� |S | �| j� |S )a�
Execute a web request based on plain text content.
@param httpRequest: Content for the request which is processed. Each
L{"
"} will be replaced with L{"
"}.
@type httpRequest: C{bytes}
@param requestFactory: 2-argument callable returning a Request.
@type requestFactory: C{callable}
@param success: Value to compare against I{self.didRequest}.
@type success: C{bool}
@param channel: Channel instance over which the request is processed.
@type channel: L{HTTPChannel}
@return: Returns the channel used for processing the request.
@rtype: L{HTTPChannel}
re r� r� )r r� r: r� r� r r� r r� r� r� r� r� r� r r� )rB r� r� �successr{ r� r� r1 r1 r2 �
runRequest� s"
�zParsingTests.runRequestc sd d� |�}g � G � fdd�dtj�}| j||dd�}| �|j�� d� | �|jj� | �� g � dS )aJ
Execute a HTTP request and assert that it is rejected with a 400 Bad
Response and disconnection.
@param requestLines: Plain text lines of the request. These lines will
be joined with newlines to form the HTTP request that is processed.
@type requestLines: C{list} of C{bytes}
re c r� )z5ParsingTests.assertRequestRejected.<locals>.MyRequestc � � � | � | �� d S r3 �r rs rA r� r1 r2 rC � rl z=ParsingTests.assertRequestRejected.<locals>.MyRequest.processNrw r1 r� r1 r2 r� � r r� F�r r� N) r� r r
r
rL r� r� r� r� )rB � requestLinesr� r� r{ r1 r� r2 �assertRequestRejected� s
�z"ParsingTests.assertRequestRejectedc s\ g � G � fdd�dt j�}d}| �||d�}| �|j�� d� | �|jj� | �� g � dS )z�
When client sends invalid HTTP method containing
non-ascii characters HTTP 400 'Bad Request' status will be returned.
c r� )z:ParsingTests.test_invalidNonAsciiMethod.<locals>.MyRequestc r r3 r rA r� r1 r2 rC � rl zBParsingTests.test_invalidNonAsciiMethod.<locals>.MyRequest.processNrw r1 r� r1 r2 r� � r r� s GE© / HTTP/1.1
r r� N)r r
r
rL r� r� r� r� )rB r� �badRequestLiner{ r1 r� r2 �test_invalidNonAsciiMethod� s z'ParsingTests.test_invalidNonAsciiMethodc st g � G � fdd�dt j�}dD ](\}}t�d�||f��}d| d }| �||d� � �� }| �||f|j� qdS ) z�
L{HTTPChannel} provides username and password information supplied in
an I{Authorization} header to the L{Request} which makes it available
via its C{getUser} and C{getPassword} methods.
c r� )z,ParsingTests.test_basicAuth.<locals>.Requestc � | � � | �� f| _� �| � d S r3 ��getUser� getPassword� credentialsr rA �r� r1 r2 rC � z4ParsingTests.test_basicAuth.<locals>.Request.processNrw r1 r r1 r2 r
r r
))r� � bar)r� s there:z� :�$ GET / HTTP/1.0
Authorization: Basic �
r N) r r
�base64� b64encoder� r
r� rL r )rB r
�ur� r� �fr r1 r r2 �test_basicAuth� s �zParsingTests.test_basicAuthc sn g � G � fdd�dt j�}g d�}| �d�|�|d� � \}| �|j�d�dg� | �|j�d�d d
g� d S ) zo
Headers received by L{HTTPChannel} in a request are made available to
the L{Request}.
c r� )z,ParsingTests.test_headers.<locals>.MyRequestc r r3 r rA r� r1 r2 rC rl z4ParsingTests.test_headers.<locals>.MyRequest.processNrw r1 r� r1 r2 r� r r� )� GET / HTTP/1.0� Foo: bars baz: Quuxs baz: quuxr� r� re r r� r s bAzs Quux� quuxN�r r
r
r� rL re �
getRawHeaders�rB r� r rv r1 r� r2 � test_headers
s �zParsingTests.test_headersc s� g � G � fdd�dt j�}g d�}| �d�|�|d� � \}| �|j�d�dg� | �|j�d�dg� | �|j�d �d
g� | �|j�d �d g� d
S )aC
Line folded headers are handled by L{HTTPChannel} by replacing each
fold with a single space by the time they are made available to the
L{Request}. Any leading whitespace in the folded lines of the header
value is replaced with a single space, per:
A server that receives an obs-fold in a request message ... MUST
... replace each received obs-fold with one or more SP octets prior
to interpreting the field value or forwarding the message
downstream.
See RFC 7230 section 3.2.4.
c r� )z5ParsingTests.test_headersMultiline.<locals>.MyRequestc r r3 r rA r� r1 r2 rC : rl z=ParsingTests.test_headersMultiline.<locals>.MyRequest.processNrw r1 r� r1 r2 r� 9 r r� )
r" s nospace: s nospace s space:spaces spaces spaces: spacess spacess spacess tab: ts as br� r� re r s nospaces spaces space space� spacess spaces spaces spacess tabs t a bNr% r' r1 r� r2 �test_headersMultiline) s*
�
�
�
�z"ParsingTests.test_headersMultilinec s� g � G � fdd�dt j�}g d�}| �d�|�|d� � \}| �|j�d�dg� | �|j�d�d g� | �|j�d
�d g� | �|j�d �d
g� | �|j�d�dg� dS )z�
Leading and trailing space and tab characters are stripped from
headers. Other forms of whitespace are preserved.
See RFC 7230 section 3.2.3 and 3.2.4.
c r� )z:ParsingTests.test_headerStripWhitespace.<locals>.MyRequestc r r3 r rA r� r1 r2 rC m rl zBParsingTests.test_headerStripWhitespace.<locals>.MyRequest.processNrw r1 r� r1 r2 r� l r r� )r" s! spaces: spaces were stripped s tabs: tabs were stripped s5 spaces-and-tabs: spaces and tabs were stripped s* line-tab: vertical tab was preserved s( form-feed: form feed was preserved r� r� re r r) s spaces were strippeds tabss tabs were strippeds spaces-and-tabss spaces and tabs were strippeds line-tabs vertical tab was preserved s form-feeds form feed was preserved Nr% r' r1 r� r2 �test_headerStripWhitespacec s2
�
�
�
�
�z'ParsingTests.test_headerStripWhitespacec C sL dg}t tjjd �D ] }|�t|� d��� q |�ddg� | �|� dS )z�
C{HTTPChannel} enforces a limit of C{HTTPChannel.maxHeaders} on the
number of headers received per request.
r" r� z: foor� N)rG r r� �
maxHeadersr r �extendr )rB r rM r1 r1 r2 �test_tooManyHeaders� s
z ParsingTests.test_tooManyHeadersc C � | � g d�� dS )z�
If a I{Content-Length} header with a non-integer value is received,
a 400 (Bad Request) response is sent to the client and the connection
is closed.
)r" s Content-Length: xr� r� N�r rA r1 r1 r2 � test_invalidContentLengthHeader� � �z,ParsingTests.test_invalidContentLengthHeaderc C r/ )z�
If a header without colon is received a 400 (Bad Request) response
is sent to the client and the connection is closed.
)r" s HeaderName r� r� Nr0 rA r1 r1 r2 �test_invalidHeaderNoColon� � �z&ParsingTests.test_invalidHeaderNoColonc C r/ )z�
C{HTTPChannel} rejects a request with an empty header name (i.e.
nothing before the colon). It produces a 400 (Bad Request) response is
generated and closes the connection.
)r" s : foor� r� Nr0 rA r1 r1 r2 �test_invalidHeaderOnlyColon� r2 z(ParsingTests.test_invalidHeaderOnlyColonc C r/ )z�
C{HTTPChannel} rejects a request containing a header with whitespace
between the header name and colon as requried by RFC 7230 section
3.2.4. A 400 (Bad Request) response is generated and the connection
closed.
)r" s HeaderName : foor� r� Nr0 rA r1 r1 r2 �'test_invalidHeaderWhitespaceBeforeColon� � �z4ParsingTests.test_invalidHeaderWhitespaceBeforeColonc s� g � G � fdd�dt j�}| �t jdd� g d�}| �d�|�|d�}� \}}| �|�d�d � | �|�d �d
� | �|j� � d � d S )
z�
C{HTTPChannel} enforces the limit of C{HTTPChannel.maxHeaders} per
request so that headers received in an earlier request do not count
towards the limit when processing a later request.
c r� )z:ParsingTests.test_headerLimitPerRequest.<locals>.MyRequestc r r3 r rA r� r1 r2 rC � rl zBParsingTests.test_headerLimitPerRequest.<locals>.MyRequest.processNrw r1 r� r1 r2 r� � r r� r, r* )� GET / HTTP/1.1r# r� r� r8 s Bar: bazr� r� re r r� r � baz�h HTTP/1.1 200 OK
Transfer-Encoding: chunked
0
HTTP/1.1 200 OK
Transfer-Encoding: chunked
0
N)
r r
�patchr� r
r� rL rj r� r� )rB r� r r{ �first�secondr1 r� r2 �test_headerLimitPerRequest� s �z'ParsingTests.test_headerLimitPerRequestc �` g � G � fdd�dt j�}t �� }d|_d}| j|||dd�}| �� g � | �|j�� d� dS ) z�
Enforces a limit of C{HTTPChannel.totalHeadersSize}
on the size of headers received per request starting from initial
command line.
c r� )z@ParsingTests.test_headersTooBigInitialCommand.<locals>.MyRequestc r r3 r rA r� r1 r2 rC rl zHParsingTests.test_headersTooBigInitialCommand.<locals>.MyRequest.processNrw r1 r� r1 r2 r� r r� r� s" GET /path/longer/than/10 HTTP/1.1
F�r� r� r{ r r� N�r r
r� �totalHeadersSizer
rL r� r� �rB r� r{ r� r1 r� r2 � test_headersTooBigInitialCommand � � z-ParsingTests.test_headersTooBigInitialCommandc r? ) z�
Enforces a limit of C{HTTPChannel.totalHeadersSize}
on the size of headers received per request counting first line
and total headers.
c r� )z>ParsingTests.test_headersTooBigOtherHeaders.<locals>.MyRequestc r r3 r rA r� r1 r2 rC , rl zFParsingTests.test_headersTooBigOtherHeaders.<locals>.MyRequest.processNrw r1 r� r1 r2 r� + r r� �( s5 GET /less/than/40 HTTP/1.1
Some-Header: less-than-40
Fr@ r� NrA rC r1 r� r2 � test_headersTooBigOtherHeaders# rE z+ParsingTests.test_headersTooBigOtherHeadersc C sP G dd� dt j�}t �� }d|_||_d}| j||dd�}| �|j�� d� dS ) z�
Enforces total size of headers per individual request and counter
is reset at the end of each request.
c @ rb )z@ParsingTests.test_headersTooBigPerRequest.<locals>.SimpleRequestc S r r3 )rs rA r1 r1 r2 rC E r zHParsingTests.test_headersTooBigPerRequest.<locals>.SimpleRequest.processNrw r1 r1 r1 r2 �
SimpleRequestD rx rH r� sZ GET / HTTP/1.1
Some-Header: total-less-than-60
GET / HTTP/1.1
Some-Header: less-than-60
F)r� r{ r r: N) r r
r� rB r� r
rL r� r� )rB rH r{ r� r1 r1 r2 � test_headersTooBigPerRequest> s � ��z)ParsingTests.test_headersTooBigPerRequestc sH d}i � | �G � �fdd�dt j�}| �||� | �� dddd�� dS ) z3
Test cookies parsing and reading.
sK GET / HTTP/1.0
Cookie: rabbit="eat carrot"; ninja=secret; spam="hey 1=1!"
c s e Zd Z� �fdd�ZdS )z+ParsingTests.testCookies.<locals>.MyRequestc s* dD ] }| � |�� |< qd�_| �� d S )N�s rabbits ninjas spamT)� getCookier rs )rB �name��cookies�testcaser1 r2 rC s s z3ParsingTests.testCookies.<locals>.MyRequest.processNrw r1 rM r1 r2 r� r s r� s "eat carrot"s secrets
"hey 1=1!"rJ N�r r
r
rL �rB r� r� r1 rM r2 � testCookiesf s
�zParsingTests.testCookiesc sb d}g �g � | �G � ��fdd�dt j�}| �||� | ��dg� | �� dgdgddgg� d S ) NsJ GET /?key=value&multiple=two+words&multiple=more%20words&empty= HTTP/1.0
c s e Zd Z� ��fdd�ZdS )z'ParsingTests.testGET.<locals>.MyRequestc s@ �� | j� � �| jd | jd | jd g� d�_| �� d S �Ns keys emptys multipleT)r ro r- r4 r rs rA �r4 ro rO r1 r2 rC � s � z/ParsingTests.testGET.<locals>.MyRequest.processNrw r1 rT r1 r2 r� � s r� r� � valuer� � two words�
more wordsrP rQ r1 rT r2 �testGET� s zParsingTests.testGETc sp d}g �g �g � | �G � ���fdd�dt j�}| �||� | ��dg� | ��dg� | �� dgdgg� dS ) z�
While only a single '?' is allowed in an URL, several other servers
allow several and pass all after the first through as part of the
query arguments. Test that we emulate this behavior.
s" GET /foo?bar=?&baz=quux HTTP/1.0
c � e Zd Z� ���fdd�ZdS )z6ParsingTests.test_extraQuestionMark.<locals>.MyRequestc sD �� | j� �� | j� � �| jd | jd g� d�_| �� d S )Nr r9 T)r ro �pathr- r4 r rs rA �r4 ro rZ rO r1 r2 rC � s
z>ParsingTests.test_extraQuestionMark.<locals>.MyRequest.processNrw r1 r[ r1 r2 r� � � r� r� s /foo� ?r$ NrP rQ r1 r[ r2 �test_extraQuestionMark� s z#ParsingTests.test_extraQuestionMarkc s� d}t dt|�|f �}g �g � g �| �G � ���fdd�dtj�}| �||� | ��dg� | �� dgdgdd gg� | ��t |�g� d
S ) a]
The request body of a I{POST} request with a I{Content-Type} header
of I{application/x-www-form-urlencoded} is parsed according to that
content type and made available in the C{args} attribute of the
request object. The original bytes of the request may still be read
from the C{content} attribute.
z9key=value&multiple=two+words&multiple=more%20words&empty=zVPOST / HTTP/1.0
Content-Length: %d
Content-Type: application/x-www-form-urlencoded
%sc rY )z4ParsingTests.test_formPOSTRequest.<locals>.MyRequestc sP �� | j� � �| jd | jd | jd g� �� | j�� � d�_| �� d S rS )r ro r- r4 rg ri r rs rA �r4 rg ro rO r1 r2 rC � s � z<ParsingTests.test_formPOSTRequest.<locals>.MyRequest.processNrw r1 r_ r1 r2 r� � r\ r� s POSTrU r� rV rW N)r rq r r
r
rL )rB �queryr� r� r1 r_ r2 �test_formPOSTRequest� s
��
z!ParsingTests.test_formPOSTRequestc C s, d}| j |tjdd�}| �|j�� d� dS )zX
When the multipart processing fails the client gets a 400 Bad Request.
s POST / HTTP/1.0
Content-Type: multipart/form-data; boundary=☃
Content-Length: 103
--☃
Content-Type: text/plain
Content-Length: 999999999999999999999999999999999999999999999999999999999999999
Content-Transfer-Encoding: quoted-printable
abasdfg
--☃--
Fr
r� N)r
r r
rL r� r� )rB r r{ r1 r1 r2 � test_multipartProcessingFailure� s
z,ParsingTests.test_multipartProcessingFailurec sV g � G � fdd�dt j�}d}| j||dd�}| �|j�� d� | �� d ji � dS ) zS
When the multipart does not contain a header is should be skipped
c r� )zJParsingTests.test_multipartEmptyHeaderProcessingFailure.<locals>.MyRequestc r� r� r� rA r� r1 r2 rC � r� zRParsingTests.test_multipartEmptyHeaderProcessingFailure.<locals>.MyRequest.processNrw r1 r� r1 r2 r� � r r� sr POST / HTTP/1.0
Content-Type: multipart/form-data; boundary=AaBb1313
Content-Length: 14
--AaBb1313
--AaBb1313--
Fr
r r N)r r
r
rL r� r� r4 r r1 r� r2 �*test_multipartEmptyHeaderProcessingFailure� s z7ParsingTests.test_multipartEmptyHeaderProcessingFailurec r� ) z�
If the request has a Content-Type of C{multipart/form-data}, and the
form data is parseable, the form arguments will be added to the
request's args.
c r� )z6ParsingTests.test_multipartFormData.<locals>.MyRequestc r� r� r� rA r� r1 r2 rC r� z>ParsingTests.test_multipartFormData.<locals>.MyRequest.processNrw r1 r� r1 r2 r� r r� s� POST / HTTP/1.0
Content-Type: multipart/form-data; boundary=AaB03x
Content-Length: 149
--AaB03x
Content-Type: text/plain
Content-Disposition: form-data; name="text"
Content-Transfer-Encoding: quoted-printable
abasdfg
--AaB03x--
Fr
r r* r r r N)r r
r
rL r� r� rq r4 r r1 r� r2 r
s
z#ParsingTests.test_multipartFormDatac s� g � G � fdd�dt j�}d}dtt|�dd��� d }| j|�d�| |d d
�}| �|j� � d � | �t� �d � | �� d
j
ddgi� dS )z�
If the request has a Content-Type of C{multipart/form-data},
and the form data is parseable and contains files, the file
portions will be added to the request's args.
c r� )z6ParsingTests.test_multipartFileData.<locals>.MyRequestc r� r� r� rA r� r1 r2 rC 3 r� z>ParsingTests.test_multipartFileData.<locals>.MyRequest.processNrw r1 r� r1 r2 r� 2 r r� s� -----------------------------738837029596785559389649595
Content-Disposition: form-data; name="uploadedfile"; filename="test"
Content-Type: application/octet-stream
abasdfg
-----------------------------738837029596785559389649595--
z�POST / HTTP/1.0
Content-Type: multipart/form-data; boundary=---------------------------738837029596785559389649595
Content-Length: re r� z
�asciiFr
r r* r s uploadedfiler N) r r
rk rq r� r
rl rL r� r� r4 )rB r� r� r r{ r1 r� r2 �test_multipartFileData* s ��� z#ParsingTests.test_multipartFileDatac s� d}g �g �g � g �| �G � ����fdd�dt j�}| �||� | �� d j� t| � d � | �� d d� | ��dg� | ��dg� | ��d g� d S )
z�
If a request uses the I{chunked} transfer encoding, the request body is
decoded accordingly before it is made available on the request.
sh GET / HTTP/1.0
Content-Type: text/plain
Transfer-Encoding: chunked
6
Hello,
14
spam,eggs spam spam
0
c s e Zd Z� ����fdd�ZdS )z4ParsingTests.test_chunkedEncoding.<locals>.MyRequestc s\ � � | j� � � | j�� � t� | _�� | j� �� | j� �� | jj� d�_| � � d S r� )
r rg ri r ro rZ r{ �_transferDecoderr rs rA �rg r} ro rZ rO r1 r2 rC h s z<ParsingTests.test_chunkedEncoding.<locals>.MyRequest.processNrw r1 rg r1 r2 r� g s r� r r* s Hello, spam,eggs spam spamr� � /N)r r
r
�
addCleanup�closer+ rL rQ r1 rg r2 �test_chunkedEncodingP s
z!ParsingTests.test_chunkedEncodingc s^ d}g � G � fdd�dt j�}| j||dd�}| �� d� | �|j�� d� | �|jj� dS ) z�
If a request uses the I{chunked} transfer encoding, but provides an
invalid chunk length value, the request fails with a 400 error.
s� GET / HTTP/1.1
Content-Type: text/plain
Transfer-Encoding: chunked
MALFORMED_LINE_THIS_SHOULD_BE_'6'
Hello,
14
spam,eggs spam spam
0
c r� )z=ParsingTests.test_malformedChunkedEncoding.<locals>.MyRequestc s � � d� d S r� �r rA r r1 r2 rC � s zEParsingTests.test_malformedChunkedEncoding.<locals>.MyRequest.processNrw r1 r r1 r2 r� � r r� Fr
zRequest.process calledr� N) r r
r
r� rL r� r� r� r� )rB r� r� r{ r1 r r2 � test_malformedChunkedEncoding� s z*ParsingTests.test_malformedChunkedEncodingc s� t �| t�}g � G � fdd�dtj�}d}d}t�d�||f��}d| d }| �tdd d
� � | � ||d � � �
� }| � d |j � | �
d
t|�� |d }|d }| �|jt� | �t� dS )z�
A L{Request} that throws an exception processing basic authorization
logs an error and uses an empty username and password.
c r� )z5ParsingTests.test_basicAuthException.<locals>.Requestc r r3 r rA r r1 r2 rC � r z=ParsingTests.test_basicAuthException.<locals>.Request.processNrw r1 r r1 r2 r
� r r
r� r r r r � b64decodec S s g S r3 r1 )r� r1 r1 r2 r� � r� z6ParsingTests.test_basicAuthException.<locals>.<lambda>r )r� r� r* � log_failureN)r r� r r r
r r r� r; r
r� rL r r� rq �assertIsInstancer� �AttributeError�flushLoggedErrors) rB r� r
r r� r� r r r� r1 r r2 �test_basicAuthException� s z$ParsingTests.test_basicAuthExceptionc C r/ )z�
A request which includes multiple C{content-length} headers
fails with a 400 response without calling L{Request.process}.
)� GET /a HTTP/1.1� Content-Length: 56� Content-Length: 0� Host: host.invalidr� r� Nr0 rA r1 r1 r2 � test_duplicateContentLengths� r4 z)ParsingTests.test_duplicateContentLengthsc C s | � ddddddd g� dS )z�
A request with a non-integer C{Content-Length} header fails with a 400
response without calling L{Request.process}.
rt s( Content-Length: MORE THAN NINE THOUSAND!rw r� r� i)# Nr0 rA r1 r1 r2 �test_contentLengthMalformed� s ��z(ParsingTests.test_contentLengthMalformedc C r/ )z�
A request with a C{Content-Length} header that begins with a L{+} fails
with a 400 response without calling L{Request.process}.
This is a potential request smuggling vector: see GHSA-c2jg-hw38-jrqq.
)rt s Content-Length: +100rw r� r� sd xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxNr0 rA r1 r1 r2 � test_contentLengthTooPositive� r7 z*ParsingTests.test_contentLengthTooPositivec C r/ )z�
A request with a C{Content-Length} header that is negative fails with
a 400 response without calling L{Request.process}.
This is a potential request smuggling vector: see GHSA-c2jg-hw38-jrqq.
)rt s Content-Length: -100rw r� r� s� xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxNr0 rA r1 r1 r2 �test_contentLengthNegative� r7 z'ParsingTests.test_contentLengthNegativec C r/ )z�
Two pipelined requests, the first of which includes multiple
C{content-length} headers, trigger a 400 response without
calling L{Request.process}.
)
rt ru rv rw r� r� rt rw r� r� Nr0 rA r1 r1 r2 �1test_duplicateContentLengthsWithPipelinedRequests� r2 z>ParsingTests.test_duplicateContentLengthsWithPipelinedRequestsc C r/ )z�
A request that includes both C{content-length} and
C{transfer-encoding} headers fails with a 400 response without
calling L{Request.process}.
)rt r� rv rw r� r� Nr0 rA r1 r1 r2 �%test_contentLengthAndTransferEncoding
r2 z2ParsingTests.test_contentLengthAndTransferEncodingc C r/ )z�
Two pipelined requests, the first of which includes both
C{content-length} and C{transfer-encoding} headers, triggers a
400 response without calling L{Request.process}.
)
rt r� rv rw r� r� rt rw r� r� Nr0 rA r1 r1 r2 �:test_contentLengthAndTransferEncodingWithPipelinedRequests#
r2 zGParsingTests.test_contentLengthAndTransferEncodingWithPipelinedRequestsc C r/ )z�
A request whose C{transfer-encoding} header includes a value
other than C{chunked} or C{identity} fails with a 400 response
without calling L{Request.process}.
)rt s Transfer-Encoding: unknownrw r� r� Nr0 rA r1 r1 r2 � test_unknownTransferEncoding8
r2 z)ParsingTests.test_unknownTransferEncodingc sP g � G � fdd�dt j�}d}| �||d�}| �� dg� | �|j�� d� dS )z�
A request with a valid C{content-length} and a
C{transfer-encoding} whose value is C{identity} succeeds.
c s e Zd ZdZ� fdd�ZdS )zEParsingTests.test_transferEncodingIdentity.<locals>.SuccessfulRequestFc s( � � | j�� � | �dd� | �� d S )Nrd � 0)r rg ri rm rs rA �r� r1 r2 rC R
s zMParsingTests.test_transferEncodingIdentity.<locals>.SuccessfulRequest.processN)r- r. r/ r� rC r1 r� r1 r2 �SuccessfulRequestO
s r� sT GET / HTTP/1.1
Host: host.invalid
Content-Length: 2
Transfer-Encoding: identity
ok
Fs oks& HTTP/1.1 200 OK
Content-Length: 0
N)r r
r
rL r� r� )rB r� rv r{ r1 r� r2 � test_transferEncodingIdentityH
s �z*ParsingTests.test_transferEncodingIdentity)NTN))r- r. r/ r0 rk r
r r r! r( r* r+ r. r1 r3 r5 r6 r> rD rG rI rR rX r^ ra rb rc r re rk rm rs rx ry rz r{ r| r} r~ r r� r1 r1 r1 r2 r � sN
+ :2 +() &0 r c @ s4 e Zd Zeejdkd�dd� �Zdd� Zdd� Zd S )
�QueryArgumentsTests)r[ rS �
z(newer py3.6 parse_qs treat ; differentlyc C sb | � td�t�d�� | jttjddd� | � tddd�tjddd�� | � td�t�d�� d S )Ns a=b&d=c;+=fs blahT)�strict_parsings a=&b=cr* )�keep_blank_values)rL r r r1 r2 rA r1 r1 r2 � testParseqsj
s
�z QueryArgumentsTests.testParseqsc s� dd� }� fdd�}t � |� D ] }||d� ||d� qt � |� D ] }||d� ||d� q#|� D ]}t � ||d� t � ||d� q3dS )z�
For a given URL, L{http.urlparse} should behave the same as L{urlparse},
except it should always return C{bytes}, never text.
c
s s^ � dD ])} dD ]$}dD ] }dD ]}|d ur)|d t t|�� }t| ||ddf�V qq qqd S )N)s https https)� example.com)Nr� )r� s pathr r� )r rk r )�scheme�host�portrZ r1 r1 r2 �urlsz
s ������z/QueryArgumentsTests.test_urlparse.<locals>.urlsc s� | }|r | � d�}t|�}t|jt�r4|j�d�|j�d�|j�d�|j�d�|j �d�|j
�d�f}n|j|j|j|j|j |j
f}t �| �\}}}}} }
� � ||||| |
f|� � �
|t� � �
|t� � �
|t� � �
|t� � �
| t� � �
|
t� dS )z�
Verify that C{url} is parsed into the same objects by both
L{http.urlparse} and L{urlparse}.
rd zutf-8N)�decoder
�
isinstancer� rk rl �netlocrZ �paramsr` �fragmentr rL rp r� ) �urlr� �urlToStandardImplementation�standardResultr� r� r� rZ r� r` r� rA r1 r2 �assertSameParsing�
s6
�
� z<QueryArgumentsTests.test_urlparse.<locals>.assertSameParsingTFNr )rB r� r� r� r1 rA r2 �
test_urlparset
s ,
�z!QueryArgumentsTests.test_urlparsec C s | � ttjd� dS )zE
L{http.urlparse} should reject unicode input early.
zhttp://example.org/pathN)r1 � TypeErrorr r
rA r1 r1 r2 �test_urlparseRejectsUnicode�
s z/QueryArgumentsTests.test_urlparseRejectsUnicodeN) r- r. r/ r �sys� version_infor� r� r� r1 r1 r1 r2 r� g
s
Mr� c @ rb )� ClientDriverc C s || _ || _|| _d S r3 )rJ r� rK rI r1 r1 r2 rZ �
s
zClientDriver.handleStatusN)r- r. r/ rZ r1 r1 r1 r2 r� �
rx r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�ClientStatusParsingTestsc C �> t � }|�d� | �|jd� | �|jd� | �|jd� d S )Ns HTTP/1.0 201 foorF � 201r� �r� � lineReceivedrL rJ r� rK �rB r� r1 r1 r2 � testBaseline�
�
z%ClientStatusParsingTests.testBaselinec C r� )N� HTTP/1.0 201rF r� r� r� r� r1 r1 r2 �
testNoMessage�
r� z&ClientStatusParsingTests.testNoMessagec C r� )Ns
HTTP/1.0 201 rF r� r� r� r� r1 r1 r2 �testNoMessage_trailingSpace�
r� z4ClientStatusParsingTests.testNoMessage_trailingSpaceN)r- r. r/ r� r� r� r1 r1 r1 r2 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+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z d<d=� Z!d>d?� Z"d@dA� Z#dBdC� Z$dDdE� Z%dFdG� Z&dHdI� Z'dJdK� Z(dLdM� Z)dNdO� Z*dPdQ� Z+dRdS� Z,dTdU� Z-dVdW� Z.dXdY� Z/dZd[� Z0d\d]� Z1d^d_� Z2d`da� Z3dbdc� Z4ddde� Z5dfdg� Z6dhdi� Z7djdk� Z8dldm� Z9dndo� Z:dpdq� Z;drds� Z<dtdu� Z=dvdw� Z>dxdy� Z?dzd{� Z@d|d}� ZAd~d� ZBd�d�� ZCd�d�� ZDd�d�� ZEd�d�� ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�S )�� RequestTestsz#
Tests for L{http.Request}
c C s� t �t� d�}t||��ddg� | �t||�d d� t||ddi� | �tt||��� �ddgfg� t||t �
� � | �t||�i � dS )a0
Verify that each of two different attributes which are associated with
the same state properly reflect changes made through the other.
This is used to test that the C{headers}/C{responseHeaders} and
C{received_headers}/C{requestHeaders} pairs interact properly.
Fr� r� r� r r7 N) r r
r& �getattrrf rL �setattrrp rr r! �Headers)rB �oldName�newNamer r1 r1 r2 �_compatHeadersTest�
s �z RequestTests._compatHeadersTestc C s4 t �t� d�}|j�ddg� | �|�d�d� dS )zb
L{http.Request.getHeader} returns the value of the named request
header.
Fr� r� N�r r
r& re rf rL rj �rB r r1 r1 r2 �test_getHeader�
s zRequestTests.test_getHeaderc sz t �t� d�� � �fdd�}|dd� |dd� |dd� |dd� |dd � |d
d � |d d
� |dd
� |dd � dS )z�
L{http.Request.getRequestHostname} returns the hostname portion of the
request, based on the C{Host:} header.
Fc s$ � j �d| g� ��� �� |� d S )N� host)re rf rL �getRequestHostname)r� � expectedHost�r rB r1 r2 �check
s z3RequestTests.test_getRequestHostname.<locals>.checkr� s example.com:8443s 192.168.1.1s 192.168.1.1:19289s [2607:f0d0:1002:51::4]s 2607:f0d0:1002:51::4s) [2607:f0d0:1002:0051:0000:0000:0000:0004]s' 2607:f0d0:1002:0051:0000:0000:0000:0004s [::1]s ::1s
[::1]:8080s [2607:f0d0:1002:51::4]:9443N)r r
r& )rB r� r1 r� r2 �test_getRequestHostname s
�
z$RequestTests.test_getRequestHostnamec C s6 t �t� d�}|j�dddg� | �|�d�d� dS )z�
When there are multiple values for a single request header,
L{http.Request.getHeader} returns the last value.
Fr� r� � pandaNr� r� r1 r1 r2 � test_getHeaderReceivedMultiples s z,RequestTests.test_getHeaderReceivedMultiplesc C s$ t �t� d�}| �|�d�d� dS )z�
L{http.Request.getHeader} returns L{None} when asked for the value of a
request header which is not present.
Fr� N)r r
r& rL rj r� r1 r1 r2 �test_getHeaderNotFound' s z#RequestTests.test_getHeaderNotFoundc C s6 t �t� d�}|j�ddg� | �|�� ddi� dS )z�
L{http.Request.getAllheaders} returns a C{dict} mapping all request
header names to their corresponding values.
Fr� r� N�r r
r& re rf rL �
getAllHeadersr� r1 r1 r2 �test_getAllHeaders/ s z RequestTests.test_getAllHeadersc C s" t �t� d�}| �|�� i � dS )zq
L{http.Request.getAllHeaders} returns an empty C{dict} if there are no
request headers.
FN)r r
r& rL r� r� r1 r1 r2 �test_getAllHeadersNoHeaders8 s z(RequestTests.test_getAllHeadersNoHeadersc C s8 t �t� d�}|j�dddg� | �|�� ddi� dS )z�
When there are multiple values for a single request header,
L{http.Request.getAllHeaders} returns only the last value.
Fr� r� r� Nr� r� r1 r1 r2 �!test_getAllHeadersMultipleHeaders@ s z.RequestTests.test_getAllHeadersMultipleHeadersc C sF t � }t�|d�}|�d� |�d� | �|jj�� � � d d� dS )z~
L{http.Request.setResponseCode} takes a status code and causes it to be
used as the response status.
F�� r� r s (no clientproto yet) 201 CreatedN�
r& r r
r? rr rL r� �written�getvaluer� �rB r{ r r1 r1 r2 �test_setResponseCodeI s
�z!RequestTests.test_setResponseCodec C sH t � }t�|d�}|�dd� |�d� | �|jj�� � � d d� dS )z�
L{http.Request.setResponseCode} takes a status code and a message and
causes them to be used as the response status.
F�� s happily acceptedr� r s) (no clientproto yet) 202 happily acceptedNr� r� r1 r1 r2 � test_setResponseCodeAndMessageW s
�z+RequestTests.test_setResponseCodeAndMessagec C s( t � }t�|d�}| �t|jdd� dS )z�
L{http.Request.setResponseCode} accepts C{bytes} for the message
parameter and raises L{TypeError} if passed anything else.
Fr� znot happily acceptedN)r& r r
r1 r� r? r� r1 r1 r2 �&test_setResponseCodeAndMessageNotBytese s z3RequestTests.test_setResponseCodeAndMessageNotBytesc C s, t �t� d�}|�d� | �t|jd� dS )z�
L{http.Request.setResponseCode} accepts C{int} for the code parameter
and raises L{TypeError} if passed anything else.
Fr* �1N)r r
r& r? r1 r� r� r1 r1 r2 �#test_setResponseCodeAcceptsIntegersn s
z0RequestTests.test_setResponseCodeAcceptsIntegersc C s t �t� d�}|�d� dS )z`
L{http.Request.setResponseCode} accepts L{int} for the code
parameter.
Fr* N)r r
r& r? r� r1 r1 r2 �'test_setResponseCodeAcceptsLongIntegersw s z4RequestTests.test_setResponseCodeAcceptsLongIntegersc C s* t �t� d�}|�d� | �|jd� dS )z�
When no previous value was set and no 'if-modified-since' value was
requested, L{http.Request.setLastModified} takes a timestamp in seconds
since the epoch and sets the request's lastModified attribute.
F�* N�r r
r& �setLastModifiedrL � lastModifiedr� r1 r1 r2 � test_setLastModifiedNeverSet s
z)RequestTests.test_setLastModifiedNeverSetc C s4 t �t� d�}|�d� |�d� | �|jd� dS )z�
If the supplied timestamp is later than the lastModified attribute's
value, L{http.Request.setLastModified} updates the lastModifed
attribute.
Fr r* Nr� r� r1 r1 r2 �test_setLastModifiedUpdate� s
z'RequestTests.test_setLastModifiedUpdatec C s4 t �t� d�}|�d� |�d� | �|jd� dS )z�
If the supplied timestamp occurs earlier than the current lastModified
attribute, L{http.Request.setLastModified} ignores it.
Fr* r Nr� r� r1 r1 r2 �test_setLastModifiedIgnore� s
z'RequestTests.test_setLastModifiedIgnorec C s> t �t� d�}|j�td�dg� |�d�}| �|t j� dS )z�
If the resource is older than the if-modified-since date in the request
header, L{http.Request.setLastModified} returns L{http.CACHED}.
F�if-modified-sinces 02 Jan 1970 00:00:00 GMTr� N� r r
r& re rf r r� rL �CACHED�rB r r� r1 r1 r2 �test_setLastModifiedCached� s
�
z'RequestTests.test_setLastModifiedCachedc C s< t �t� d�}|j�td�dg� |�d�}| �|d� dS )z�
If the resource is newer than the if-modified-since date in the request
header, L{http.Request.setLastModified} returns None
Fr� s 01 Jan 1970 00:00:00 GMT�@B N�r r
r& re rf r r� rL r� r1 r1 r2 � test_setLastModifiedNotCached� s
�
z*RequestTests.test_setLastModifiedNotCachedc C sF t �t� d�}|j�td�dg� |�d� |�d�}| �|d� dS )z�
When L{http.Request.setLastModified} is called multiple times, the
highest supplied value is honored. If that value is higher than the
if-modified-since date in the request header, the method returns None.
Fr� s 01 Jan 1970 00:00:01 GMTr� r Nr� r� r1 r1 r2 �"test_setLastModifiedTwiceNotCached� s
�
z/RequestTests.test_setLastModifiedTwiceNotCachedc C sH t �t� d�}|j�td�dg� |�d� |�d�}| �|t j� dS )a
When L{http.Request.setLastModified} is called multiple times, the
highest supplied value is honored. If that value is lower than the
if-modified-since date in the request header, the method returns
L{http.CACHED}.
Fr� s 01 Jan 1999 00:00:01 GMTr* r Nr� r� r1 r1 r2 � test_setLastModifiedTwiceCached� s
�
z,RequestTests.test_setLastModifiedTwiceCachedc C s4 t �t� d�}|�dd� | �|j�d�dg� dS )��
L{http.Request.setHost} sets the value of the host request header.
The port should not be added because it is the default.
Fr� �P r� N�r r
r& �setHostrL re r& r� r1 r1 r2 � test_setHost� � zRequestTests.test_setHostc C sB t � }t �� |_t�|d�}|�dd� | �|j�d�dg� dS )r� Fr� i� r� N� r& r
r� r r
r� rL re r& �rB r` r r1 r1 r2 �test_setHostSSL� �
z RequestTests.test_setHostSSLc C s4 t �t� d�}|�dd� | �|j�d�dg� dS �z�
L{http.Request.setHost} sets the value of the host request header.
The port should be added because it is not the default.
Fr� �Q r� s example.com:81Nr� r� r1 r1 r2 �test_setHostNonDefaultPort� r� z'RequestTests.test_setHostNonDefaultPortc C sB t � }t �� |_t�|d�}|�dd� | �|j�d�dg� dS r� r� r� r1 r1 r2 � test_setHostSSLNonDefaultPort� r� z*RequestTests.test_setHostSSLNonDefaultPortc C s4 t �t� d�}|�dd� | �|j�d�dg� dS )zX
L{http.Request.setHeader} sets the value of the given response header.
Fr� r� N)r r
r& rm rL rq r& r� r1 r1 r2 �test_setHeader s zRequestTests.test_setHeaderc O s� t � }t�|d�}|j|i |�� | �|jd |� |�d� |jj� � �
d�}dd� |D �}| �t |�d� | �|d d| � d S )
z�
Call L{http.Request.addCookie} with C{*args} and C{**kwargs}, and check
that the cookie value is equal to C{expectedCookieValue}.
Fr r� r� c S s g | ] }|� d �r|�qS )s
Set-Cookie)�
startswith)r� r� r1 r1 r2 r� s z-RequestTests._checkCookie.<locals>.<listcomp>r* s Set-Cookie: N) r& r r
� addCookierL rN rr r� r� r� r� rq )rB �expectedCookieValuer4 r5 r{ r � writtenLines�addCookieLinesr1 r1 r2 � _checkCookie s
zRequestTests._checkCookiec C � d}| � |dd� dS )z�
L{http.Request.addCookie} adds a new cookie to be sent with the
response, and can be called with just a key and a value. L{unicode}
arguments are encoded using UTF-8.
� foo=bar�foo�barN�r� �rB r� r1 r1 r2 �)test_addCookieWithMinimumArgumentsUnicode$ � z6RequestTests.test_addCookieWithMinimumArgumentsUnicodec C �& d}| j |dddddddd d d
�
d S ) z�
L{http.Request.addCookie} adds a new cookie to be sent with the
response. L{unicode} arguments are encoded using UTF-8.
�} foo=bar; Expires=Fri, 31 Dec 9999 23:59:59 GMT; Domain=.example.com; Path=/; Max-Age=31536000; Comment=test; Secure; HttpOnlyr� r� z Fri, 31 Dec 9999 23:59:59 GMTz .example.com�/�31536000�testT��expires�domainrZ �max_age�comment�secure�httpOnlyNr� r� r1 r1 r2 �%test_addCookieWithAllArgumentsUnicode. � �
�z2RequestTests.test_addCookieWithAllArgumentsUnicodec C r� )z�
L{http.Request.addCookie} adds a new cookie to be sent with the
response, and can be called with just a key and a value. L{bytes}
arguments are not decoded.
r� r� r Nr� r� r1 r1 r2 �'test_addCookieWithMinimumArgumentsBytesF r� z4RequestTests.test_addCookieWithMinimumArgumentsBytesc C r� ) z�
L{http.Request.addCookie} adds a new cookie to be sent with the
response. L{bytes} arguments are not decoded.
r� r� r s Fri, 31 Dec 9999 23:59:59 GMTs .example.comrh s 31536000r� Tr� Nr� r� r1 r1 r2 �#test_addCookieWithAllArgumentsBytesP r z0RequestTests.test_addCookieWithAllArgumentsBytesc C s� dd� }g d�}t ttt ttg���}ddgddgg}|D ]/\}}| �|||�||� |D ] \}}d�|||�|||�g�}| j|||fi ||i�� q.q dS ) zq
L{http.Request.addCookie} replaces linear whitespace and
semicolons with single spaces.
c S s d� | |g�S )N� =)r� )rR r� r1 r1 r2 � cookieValuen r� z<RequestTests.test_addCookieSanitization.<locals>.cookieValue))r s Expires)r s Domain)rZ s Path)r s Max-Age)r s CommentzFoo; bars Foo bars Foo; bars ; N)rp �zipr) r' r r( r� r� ) rB r � arguments�inputsAndOutputs�
inputValue� outputValue�argument� parameterr� r1 r1 r2 �test_addCookieSanitizationh s8 ��� � ������z'RequestTests.test_addCookieSanitizationc C sR | j ddddd� | j ddddd� | j ddddd� | jt| j d ddd
d� d S ) zL
L{http.Request.setCookie} supports a C{sameSite} argument.
s foo=bar; SameSite=laxr� r �lax)�sameSite�Laxs foo=bar; SameSite=strict�strictr� z
anything-elseN)r� r1 r2 rA r1 r1 r2 �test_addCookieSameSite� s �
�z#RequestTests.test_addCookieSameSitec C s^ t � }t�|d�}t� }||_|�d� d|_|j�ddg� |� d� | �
|� � dg� dS ) z�
For an HTTP 1.0 request, L{http.Request.write} sends an HTTP 1.0
Response-Line and whatever response headers are set.
Fr= rF r� r� r� )r� r� r� N� r& r r
r r� r? rp rq rf rr r� r� �rB r{ r r� r1 r1 r2 �test_firstWrite� s
�z RequestTests.test_firstWritec C sh t � }t�|d�}t� }||_|�d� d|_|j�ddg� |� d� |� d� | �
|� � dg� d S )
z�
For an HTTP 1.1 request, L{http.Request.write} sends an HTTP 1.1
Response-Line, whatever response headers are set, and uses chunked
encoding for the response body.
Fr= rx r� r� r� r� r� Nr r r1 r1 r2 � test_firstWriteHTTP11Chunked� s
��z)RequestTests.test_firstWriteHTTP11Chunkedc C sd t � }t�|d�}t� }||_|�d� d|_d|_|j� ddg� |�
d� | � |� � dg� d S )
z�
For an HTTP 1.0 request for a resource with a known last modified time,
L{http.Request.write} sends an HTTP Response-Line, whatever response
headers are set, and a last-modified header with that time.
Fr= rF r r� r� r� )r� r� �, Last-Modified: Thu, 01 Jan 1970 00:00:00 GMTr� N)
r& r r
r r� r? rp r� rq rf rr r� r� r r1 r1 r2 �test_firstWriteLastModified� s
��z(RequestTests.test_firstWriteLastModifiedc C s� t �| t�}t� }t�|d�}t� }||_|�d� d|_ d|_
|j � ddg� |�
d� | �|�� dg� | �d t|�� |d
}| �d |d � d
S )z�
If the last-modified header already exists in the L{http.Request}
response headers, the lastModified attribute is ignored and a message
is logged.
Fr= rF i ʚ;s
last-modifieds Thu, 01 Jan 1970 00:00:00 GMTr� )r� r r� r* r zPWarning: last-modified specified both in header list and lastModified attribute.r� N)r r� r r& r r
r r� r? rp r� rq rf rr r� r� r� rq )rB r� r{ r r� r� r1 r1 r2 � test_lastModifiedAlreadyWritten� s.
�
��
�z,RequestTests.test_lastModifiedAlreadyWrittenc C s t �t� d�}| �|ji � dS )zP
L{http.Request.received_cookies} defaults to an empty L{dict}.
FN)r r
r& rL �received_cookiesr� r1 r1 r2 �test_receivedCookiesDefault
s z(RequestTests.test_receivedCookiesDefaultc C �> t �t� d�}|j�ddg� |�� | �|jddd�� dS )z�
L{http.Request.parseCookies} extracts cookies from C{requestHeaders}
and adds them to C{received_cookies}.
F� cookies test="lemur"; test2="panda"� "lemur"� "panda"�r� s test2N�r r
r& re rf � parseCookiesrL r r� r1 r1 r2 �test_parseCookies
s �z RequestTests.test_parseCookiesc C s@ t �t� d�}|j�dddg� |�� | �|jddd�� dS ) zh
L{http.Request.parseCookies} can extract cookies from multiple Cookie
headers.
Fr# s test="lemur"s
test2="panda"r$ r% r& Nr' r� r1 r1 r2 � test_parseCookiesMultipleHeaders,
s �z-RequestTests.test_parseCookiesMultipleHeadersc C s( t �t� d�}|�� | �|ji � dS )zj
L{http.Request.parseCookies} can be called on a request without a
cookie header.
FN)r r
r& r( rL r r� r1 r1 r2 �test_parseCookiesNoCookie8
s z&RequestTests.test_parseCookiesNoCookiec C s6 t �t� d�}|j�dg � |�� | �|ji � dS )zn
L{http.Request.parseCookies} can be called on a request with an
empty cookie header.
Fr# Nr' r� r1 r1 r2 � test_parseCookiesEmptyCookieA
s z)RequestTests.test_parseCookiesEmptyCookiec C s8 t �t� d�}|j�ddg� |�� | �|ji � dS )z`
L{http.Request.parseCookies} ignores cookies which don't have a
value.
Fr# s foo; bar; baz;Nr' r� r1 r1 r2 � test_parseCookiesIgnoreValuelessK
s z-RequestTests.test_parseCookiesIgnoreValuelessc C �< t �t� d�}|j�ddg� |�� | �|jddi� dS )zR
L{http.Request.parseCookies} parses cookies with an empty value.
Fr# s foo=r� r� Nr' r� r1 r1 r2 �test_parseCookiesEmptyValueU
s z(RequestTests.test_parseCookiesEmptyValuec C r. )zf
L{http.Request.parseCookies} leaves trailing whitespace in the
cookie value.
Fr# s foo=bar r� s bar Nr' r� r1 r1 r2 �!test_parseCookiesRetainRightSpace^
� z.RequestTests.test_parseCookiesRetainRightSpacec C r. )zc
L{http.Request.parseCookies} strips leading whitespace in the
cookie key.
Fr# s foo=barr� r Nr' r� r1 r1 r2 � test_parseCookiesStripLeftSpaceh
r1 z,RequestTests.test_parseCookiesStripLeftSpacec C r" )zr
L{http.Request.parseCookies} parses valid cookies set before or
after malformed cookies.
Fr# s0 12345; test="lemur"; 12345; test2="panda"; 12345r$ r% r& Nr' r� r1 r1 r2 �-test_parseCookiesContinueAfterMalformedCookier
s � �z:RequestTests.test_parseCookiesContinueAfterMalformedCookiec C sX t �t� d�}|�d� |j}|�d� |�ttd��� | � |j
� | � |j d� dS )z�
L{http.Request.connectionLost} closes L{Request.content} and drops the
reference to the L{HTTPChannel} to assist with garbage collection.
Fr� r� �FinishedN)
r r
r& � gotLengthrg �handleContentChunkr� r r r� �closedr� r{ )rB r rg r1 r1 r2 �test_connectionLost�
s
z RequestTests.test_connectionLostc C s4 t �t� d�}|�t� d� | �t|jt� d� dS )zv
Calling L{Request.registerProducer} when a producer is already
registered raises ValueError.
FTN)r r
r& r@ r r1 r2 r� r1 r1 r2 � test_registerProducerTwiceFails�
s z,RequestTests.test_registerProducerTwiceFailsc C s: t �t� d�}t� }|�|d� | �|dfg|jj� dS )z�
Calling L{Request.registerProducer} with an IPushProducer when the
request is not queued registers the producer as a push producer on the
request's transport.
FTN�r r
r& r r@ rL r� � producers�rB r r? r1 r1 r2 �7test_registerProducerWhenNotQueuedRegistersPushProducer�
� zDRequestTests.test_registerProducerWhenNotQueuedRegistersPushProducerc C s: t �t� d�}t� }|�|d� | �|dfg|jj� dS )z�
Calling L{Request.registerProducer} with an IPullProducer when the
request is not queued registers the producer as a pull producer on the
request's transport.
FNr: r< r1 r1 r2 �7test_registerProducerWhenNotQueuedRegistersPullProducer�
r> zDRequestTests.test_registerProducerWhenNotQueuedRegistersPullProducerc C sF t � }t�|d�}|�� }|�ttd��� | �|jd� | � |t�S )z
L{Request.connectionLost} triggers all finish notification Deferreds
and cleans up per-request state.
TzConnection doneN)
r& r r
� notifyFinishr� r r r� r{ �
assertFailure)rB r` rv r� r1 r1 r2 � test_connectionLostNotification�
s z,RequestTests.test_connectionLostNotificationc C s, t �t� d�}|�� }|�d� |�� |S )zO
L{Request.finish} triggers all finish notification Deferreds.
Fr* )r r
r& r@ r5 rs �rB rv r� r1 r1 r2 �test_finishNotification�
s
z$RequestTests.test_finishNotificationc C sF t �t� d�}|�� }|�d� |�d� |�� | �t|jd� |S )z�
Calling L{Request.write} after L{Request.finish} has been called results
in a L{RuntimeError} being raised.
Fr* � foobar) r r
r& r@ r5 rr rs r1 rb rC r1 r1 r2 �test_writeAfterFinish�
s
z"RequestTests.test_writeAfterFinishc C s6 t � }t�|d�}|�ttd��� | �t|j� dS )z�
Calling L{Request.finish} after L{Request.connectionLost} has been
called results in a L{RuntimeError} being raised.
F�The end.N) r& r r
r� r r r1 rb rs r� r1 r1 r2 � test_finishAfterConnectionLost�
s z+RequestTests.test_finishAfterConnectionLostc C s@ t � }t�|d�}|�ttd��� |�d� | �t|j � dS )z�
Calling L{Request.write} after L{Request.connectionLost} has been
called does not raise an exception. L{RuntimeError} will be raised
when finish is called on the request.
FrG rE N)
r& r r
r� r r rr r1 rb rs r� r1 r1 r2 � test_writeAfterConnectionLost�
s
z*RequestTests.test_writeAfterConnectionLostc C s, t �t� d�}| �t|�dt|�f � dS )z�
L{Request.__repr__} returns the class name, object address, and
dummy-place holder values when used on a L{Request} which has not yet
been initialized.
FzZ<Request at 0x%x method=(no method yet) uri=(no uri yet) clientproto=(no clientproto yet)>N�r r
r& rL �repr�id�rB rv r1 r1 r2 �test_reprUninitialized�
s ��z#RequestTests.test_reprUninitializedc C s> t �t� d�}d|_d|_d|_| �t|�dt|�f � dS )a
L{Request.__repr__} returns, as a L{str}, the class name, object
address, and the method, uri, and client protocol of the HTTP request
it represents. The string is in the form::
<Request at ADDRESS method=METHOD uri=URI clientproto=PROTOCOL>
FrF r� r� z><Request at 0x%x method=GET uri=/foo/bar clientproto=HTTP/1.0>N) r r
r& rp ro rn rL rK rL rM r1 r1 r2 �test_reprInitialized�
s ��z!RequestTests.test_reprInitializedc C s< G dd� dt j�}|t� d�}| �t|�dt|�f � dS )z�
Subclasses of L{Request} inherit a C{__repr__} implementation which
includes the subclass's name in place of the string C{"Request"}.
c @ s e Zd ZdS )z1RequestTests.test_reprSubclass.<locals>.OtherwiseN)r- r. r/ r1 r1 r1 r2 � Otherwise s rP Fz\<Otherwise at 0x%x method=(no method yet) uri=(no uri yet) clientproto=(no clientproto yet)>NrJ )rB rP rv r1 r1 r2 �test_reprSubclass s ��z RequestTests.test_reprSubclassc C sF t �t� d�}t� |_|�t� d� |�� | �d|j |jj f� dS )z�
L{Request.unregisterProducer} unregisters a non-queued non-streaming
producer from the request and the request's transport.
F�NNN�
r r
r& r r� r@ r �unregisterProducerrL r? r� r1 r1 r2 �,test_unregisterNonQueuedNonStreamingProducer �
z9RequestTests.test_unregisterNonQueuedNonStreamingProducerc C sF t �t� d�}t� |_|�t� d� |�� | �d|j |jj f� dS )z�
L{Request.unregisterProducer} unregisters a non-queued streaming
producer from the request and the request's transport.
FTrR NrS r� r1 r1 r2 �)test_unregisterNonQueuedStreamingProducer+ rV z6RequestTests.test_unregisterNonQueuedStreamingProducerc C s� t �� }d|_d|_d|_|�� t� |_|�d�}ddg}t � }|�
|� |D ]}|� |� q(|j j
d �� | �d|j�� � dS )zj
L{http.Request.finish} will call the channel's factory to produce a log
message.
N�sometimeT� GET /path HTTP/1.1
r� r s sometime "GET /path HTTP/1.1")r r� r� � _logDateTime�_logDateTimeCall� startFactoryr �logFiler� r r� r� r� r� rs r� r� �rB r� �proto�valr� r� r1 r1 r2 �test_finishProducesLog6 s
z#RequestTests.test_finishProducesLogc C s� t � }tjd|d�}|�� |�d�}t� }t||�}| �|jd� |� |� |�
d� |� d� | � |j
� |� d� | �|j
� dS )z�
L{HTTPChannel} timeouts whenever data from a request body is not
delivered to it in time, even when it gets built from a L{HTTPFactory}.
r� )�timeoutr� Nr� r� r� )r r r� r\ r� r r� rL r� r� r� r� r� r� r� r< r1 r1 r2 �"test_requestBodyTimeoutFromFactoryP s
z/RequestTests.test_requestBodyTimeoutFromFactoryc C s� t �� }d|_d|_d|_|�� t� |_|�d�}d|j _
ddg}t � }|� |� | �
|jd� |D ]}|�|� q3|�d� | �
|jd � |j jd �� | �
|jd� dS )
z�
L{http.Request.finish} will notify the channel that it is finished, and
will put the transport back in the producing state so that the reactor
can close the connection.
NrX Tr rY r� r� s GET r� )r r� r� rZ r[ r\ r r] r� r� r� r r� rL r� r� r� rs r^ r1 r1 r2 �test_finishCleansConnectionf s$
z(RequestTests.test_finishCleansConnectionc C s t �t� d�}tt j|� dS )z�
L{http.Request} provides
L{http._IDeprecatedHTTPChannelToRequestInterface}, which
defines the interface used by L{http.HTTPChannel}.
FN)r r
r& r �)_IDeprecatedHTTPChannelToRequestInterfacer� r1 r1 r2 �6test_provides_IDeprecatedHTTPChannelToRequestInterface� s zCRequestTests.test_provides_IDeprecatedHTTPChannelToRequestInterfacec C s t �t� d�}| �||� dS )z7
A L{http.Request} is equal to itself.
FN�r r
r& rL r� r1 r1 r2 �test_eq� s zRequestTests.test_eqc C s( t �t� d�}| �|t �t� d�� dS )zC
A L{http.Request} is not equal to another object.
FN)r r
r& �assertNotEqualr� r1 r1 r2 �test_ne� s zRequestTests.test_nec C s t �t� d�}t|� dS )z0
A L{http.Request} is hashable.
FN)r r
r& �hashr� r1 r1 r2 �
test_hashable� s zRequestTests.test_hashablec sD g � G � fdd�d�}t �t� d�}| �||� � | �� |g� dS )z�
A L{http.Request} on the left hand side of an equality
comparison to an instance that is not a L{http.Request} hands
the comparison off to that object's C{__eq__} implementation.
c �" e Zd Zdedef� fdd� ZdS )z8RequestTests.test_eqWithNonRequest.<locals>._NotARequest�other�returnc � � � |� dS r� rl �rB rn ��eqCallsr1 r2 �__eq__� �
z?RequestTests.test_eqWithNonRequest.<locals>._NotARequest.__eq__N)r- r. r/ �object�boolrt r1 rr r1 r2 � _NotARequest� � rx FNrg �rB rx r r1 rr r2 �test_eqWithNonRequest� �
z"RequestTests.test_eqWithNonRequestc sD g � G � fdd�d�}t �t� d�}| �||� � | �� |g� dS )z�
A L{http.Request} on the left hand side of an inequality
comparison to an instance that is not a L{http.Request} hands
the comparison off to that object's C{__ne__} implementation.
c rm )z8RequestTests.test_neWithNonRequest.<locals>._NotARequestrn ro c rp r� rl rq rr r1 r2 �__ne__� ru z?RequestTests.test_neWithNonRequest.<locals>._NotARequest.__ne__N)r- r. r/ rv rw r} r1 rr r1 r2 rx � ry rx FN)r r
r& ri rL rz r1 rr r2 �test_neWithNonRequest� r| z"RequestTests.test_neWithNonRequestc C sl t �| t�}t�t� d�}|�t� d� |�� | � dt
|�� |d }|d }| � |j t
� | �t
� dS )zy
A RuntimeError is logged if a producer is still registered
when an L{http.Request} is finished.
FTr* r ro N)r r� r r r
r& r@ r rs r� rq rp r� rb rr )rB r� rv r� r r1 r1 r2 �"test_finishProducerStillRegistered� s z/RequestTests.test_finishProducerStillRegisteredc C �. t �tt�ddd�d��}| �|�� d� dS )z}
L{http.Request.getClientIP} returns the host part of the
client's address when connected over IPv4.
r � 127.0.0.1�80 ��peerN�r r
r& r � IPv6AddressrL � getClientIPrM r1 r1 r2 �test_getClientIPWithIPv4� � �z%RequestTests.test_getClientIPWithIPv4c C r� )z}
L{http.Request.getClientIP} returns the host part of the
client's address when connected over IPv6.
r z::1r� r� Nr� rM r1 r1 r2 �test_getClientIPWithIPv6� r� z%RequestTests.test_getClientIPWithIPv6c C s* t �tt�d�d��}| �|�� d� dS )z�
L{http.Request.getClientIP} returns L{None} for the client's
IP address when connected over a non-TCP transport.
�/path/to/socketr� N)r r
r& r � UNIXAddressrL r� rM r1 r1 r2 � test_getClientIPWithNonTCPPeer� s �z+RequestTests.test_getClientIPWithNonTCPPeerc C s. t �d�}t�t|d��}| �|�� |� dS )zs
L{http.Request.getClientAddress} returns the client's address
as an L{IAddress} provider.
r� r� N)r r� r r
r& r> �getClientAddress)rB r_ rv r1 r1 r2 �test_getClientAddress� s
z"RequestTests.test_getClientAddressN)Nr- r. r/ r0 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r r r! r) r* r+ r, r- r/ r0 r2 r3 r8 r9 r= r? rB rD rF rH rI rN rO rQ rU rW ra rc rd rf rh rj rl r{ r~ r r� r� r� r� r1 r1 r1 r2 r� �
s�
, '
r� c @ sL e Zd ZdZdd� Zdddd�Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
dS )�MultilineHeadersTestsa
Tests to exercise handling of multiline headers by L{HTTPClient}. RFCs 1945
(HTTP 1.0) and 2616 (HTTP 1.1) state that HTTP message header fields can
span multiple lines if each extra line is preceded by at least one space or
horizontal tab.
c C s d| _ d| _dS )zv
Initialize variables used to verify that the header-processing functions
are getting called.
FN)�handleHeaderCalled�handleEndHeadersCalledrA r1 r1 r2 rk s
zMultilineHeadersTests.setUp� 10s
line-0 line-1s
line-2 line-3)rf s X-Multilines X-Multiline2c C s d| _ | �|| j| � dS )zE
Dummy implementation of L{HTTPClient.handleHeader}.
TN)r� rL r� )rB rR r` r1 r1 r2 �ourHandleHeader s z%MultilineHeadersTests.ourHandleHeaderc C s
d| _ dS )zI
Dummy implementation of L{HTTPClient.handleEndHeaders}.
TN)r� rA r1 r1 r2 �ourHandleEndHeaders s
z)MultilineHeadersTests.ourHandleEndHeadersc C s� t � }| j|_| j|_|�d� |�d� | �|jd� | �| j � | �| j
� |�d� | � | j � | � | j
� | � |jd� dS )z�
A header isn't processed by L{HTTPClient.extractHeader} until it is
confirmed in L{HTTPClient.lineReceived} that the header has been
received completely.
r� � Content-Length: 10Nr� r� )
r� r� rX r� rY r� r� ru r� r� r� r� rL r� r1 r1 r2 �test_extractHeader# s
z(MultilineHeadersTests.test_extractHeaderc C sb t � }| j|_| j|_|�d� |�d� | �| j� | �| j � | �
|j d� | �
|j d� dS )z�
An HTTP request with no headers will not cause any calls to
L{handleHeader} but will cause L{handleEndHeaders} to be called on
L{HTTPClient} subclasses.
r� r� rF r� N)
r� r� rX r� rY r� r� r� r� r� rL rJ r� r� r1 r1 r2 �test_noHeaders: s
z$MultilineHeadersTests.test_noHeadersc C s� t � }| j|_| j|_|�d� |�d� | �| j� |�d� |�d� | �| j� |�d� |�d� |�d� | �| j � | �
|j d� | �
|j d � | �
|j
d
� d S ) z�
L{HTTPClient} parses multiline headers by buffering header lines until
an empty line or a line that does not start with whitespace hits
lineReceived, confirming that the header has been received completely.
r� s X-Multiline: line-0s line-1s X-Multiline2: line-2s line-3r� r� rF r� r� N)r� r� rX r� rY r� r� r� r� r� rL rJ r� ru r� r1 r1 r2 �test_multilineHeadersM s
z+MultilineHeadersTests.test_multilineHeadersN) r- r. r/ r0 rk r� r� r� r� r� r� r1 r1 r1 r2 r� � s � r� c @ rE )� Expect100ContinueServerTestsai
Test that the HTTP server handles 'Expect: 100-continue' header correctly.
The tests in this class all assume a simplistic behavior where user code
cannot choose to deny a request. Once ticket #288 is implemented and user
code can run before the body of a POST is processed this should be
extended to support overriding this behavior.
c C s� t � }t�� }t|_|�|� |�d� |�d� |�d� |�d� |�d� | �|�� d� |�d� | � |�� dg� d S )
z�
HTTP/1.0 requests do not get 100-continue returned, even if 'Expect:
100-continue' is included (RFC 2616 10.1.1).
s GET / HTTP/1.0
� Host: www.example.com
� Content-Length: 3
� Expect: 100-continue
r� r� r� )r� r� r� r� r� �
'''
3
abc'''
N)
r r r� r� r� r� r� rL r� r� )rB r� r{ r1 r1 r2 � test_HTTP10v s
��z(Expect100ContinueServerTests.test_HTTP10c C s� t � }t�� }t|_|�|� |�d� |�d� |�d� |�d� | �|�� d� |�d� | �|�� d� |�d� |�� }| � |�
d�� |t d�d � }| � |d
g� d S ) a!
If a HTTP/1.1 client sends a 'Expect: 100-continue' header, the server
responds with a 100 response code before handling the request body, if
any. The normal resource rendering code will then be called, which
will send an additional response code.
s GET / HTTP/1.1
r� r� r� r� r� s HTTP/1.1 100 Continue
r� N)r� r� r� r� r� r� )
r r r� r� r� r� r� rL r� r� r� rq r� )rB r� r{ r� r1 r1 r2 � test_expect100ContinueHeader� s(
��z9Expect100ContinueServerTests.test_expect100ContinueHeaderN)r- r. r/ r0 r� r� r1 r1 r1 r2 r� l s r� c s � fdd�| D �S )a�
Create a new dict containing only a subset of the items of an existing
dict.
@param keys: An iterable of the keys which will be added (with values from
C{d}) to the result.
@param d: The existing L{dict} from which to copy items.
@return: The new L{dict} with keys given by C{keys} and values given by the
corresponding values in C{d}.
@rtype: L{dict}
c s i | ]}|� | �qS r1 r1 )r� �k�r` r1 r2 �
<dictcomp>� s zsub.<locals>.<dictcomp>r1 )�keysr` r1 r� r2 �sub� s r� c @ rE )� DeprecatedRequestAttributesTestszI
Tests for deprecated attributes of L{twisted.web.http.Request}.
c C s~ t �tt�ddd�d��}|�d� |�ddd� |�� | j| j gd �}| �
d
t |�� | �
t d d �t
d
dg|d �� dS )zg
L{Request.getClientIP} is deprecated in favor of
L{Request.getClientAddress}.
r r� i90 r� r r� rh rx ��offendingFunctionsr* zjtwisted.web.http.Request.getClientIP was deprecated in Twisted 18.4.0; please use getClientAddress instead��categoryrK r� rK N)r r
r& r r� r5 �requestReceivedr� �
flushWarnings�test_getClientIPrL rq �DeprecationWarningr� )rB rv �warningsr1 r1 r2 r� � s �
��z1DeprecatedRequestAttributesTests.test_getClientIPc C s\ t � }t�|�}|�� | j| jgd�}| �dt|�� | �tdd�t ddg|d �� dS ) zs
L{Request.noLongerQueued} is deprecated, as we no longer process
requests simultaneously.
r� r* zHtwisted.web.http.Request.noLongerQueued was deprecated in Twisted 16.3.0r� r� rK r N)
r& r r
�noLongerQueuedr� �test_noLongerQueuedrL rq r� r� )rB r{ rv r� r1 r1 r2 r� � s
��z4DeprecatedRequestAttributesTests.test_noLongerQueuedN)r- r. r/ r0 r� r� r1 r1 r1 r2 r� � s r� c @ s| e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd � Zd S ) �ChannelProductionTestsz=
Tests for the way HTTPChannel manages backpressure.
s# GET / HTTP/1.1
Host: localhost
c C s( |}t �� }t|�|_|�|� ||fS )a
Setup a L{HTTPChannel} and a transport and associate them.
@param transport: A transport to back the L{HTTPChannel}
@param requestFactory: An object that can construct L{Request} objects.
@return: A tuple of the channel and the transport.
)r r� r: r� r� )rB r� r� r{ r1 r1 r2 �buildChannelAndTransport s
z/ChannelProductionTests.buildChannelAndTransportc C s0 | � t� t�\}}| �|j|� | �|j� dS )zu
L{HTTPChannel} registers itself as a producer with its transport when a
connection is made.
N)r� r rc rL r? r� � streaming�rB r{ r� r1 r1 r2 �test_HTTPChannelIsAProducer s
�z2ChannelProductionTests.test_HTTPChannelIsAProducerc C s: | � t� t�\}}|�� | �|jd� | �|jd� dS )zV
L{HTTPChannel} unregisters itself when it has loseConnection called.
N)r� r rc r r> r? r� r� r1 r1 r2 �8test_HTTPChannelUnregistersSelfWhenCallingLoseConnection' s �zOChannelProductionTests.test_HTTPChannelUnregistersSelfWhenCallingLoseConnectionc C s8 | � t� t�\}}|�t� d� | �t|jt� d� dS )z�
If two producers are registered on a L{HTTPChannel} without the first
being unregistered, a L{RuntimeError} is thrown.
TN)r� r rc r@ r r1 rb r� r1 r1 r2 �(test_HTTPChannelRejectsMultipleProducers3 s
�z?ChannelProductionTests.test_HTTPChannelRejectsMultipleProducersc C �, | � t� t�\}}|�� | �|jd� dS )zr
If there is no producer, the L{HTTPChannel} can still have
C{unregisterProducer} called.
N�r� r rc rT r> �_requestProducerr� r1 r1 r2 �+test_HTTPChannelCanUnregisterWithNoProducer? �
�zBChannelProductionTests.test_HTTPChannelCanUnregisterWithNoProducerc C r� )zn
If there is no request producer currently registered, C{stopProducing}
does nothing.
Nr� r� r1 r1 r2 �,test_HTTPChannelStopWithNoRequestOutstandingK r� zCChannelProductionTests.test_HTTPChannelStopWithNoRequestOutstandingc C sf | � t� t�\}}|�| j� |jd j}t� }|�|d� | � |j
g � |� � | � |j
dg� dS )z�
If there is a request producer registered with L{HTTPChannel}, calling
C{stopProducing} causes that producer to be stopped as well.
r T�stopN) r� r r} r� rv r� r� r r@ rL �events�
stopProducing�rB r{ r� rv r? r1 r1 r2 �#test_HTTPChannelStopRequestProducerW s � z:ChannelProductionTests.test_HTTPChannelStopRequestProducerc C sP | � t� t�\}}| �|jd� |�� | �|jd� |�� | �|jd� dS )z�
When L{HTTPChannel} has C{pauseProducing} called on it by the transport
it will call C{pauseProducing} on the transport. When unpaused, the
L{HTTPChannel} will call C{resumeProducing} on its transport.
r� r� N)r� r rc rL r� �pauseProducing�resumeProducingr� r1 r1 r2 �;test_HTTPChannelPropagatesProducingFromTransportToTransporto s �zRChannelProductionTests.test_HTTPChannelPropagatesProducingFromTransportToTransportc C s� | � t� t�\}}d|_|�| j� |�d� |jd j}t� }|� |d� | �
|j d� | �
|j g � |�
� | �
|j d� | �
|j dg� |�� | �
|j d� | �
|j ddg� |�� |�� | �
|j d� dS ) z�
If a L{Request} object has registered itself as a producer with a
L{HTTPChannel} object, and the L{HTTPChannel} object is paused, both
the transport and L{Request} objects get paused.
r s 123Tr� �pause�resumer� N)r� r r} r� r� rv r� r� r r@ rL r� r� r� r� rT r r� r1 r1 r2 �3test_HTTPChannelPropagatesPausedProductionToRequest� s( �
zJChannelProductionTests.test_HTTPChannelPropagatesPausedProductionToRequestc C s� | � t� t�\}}d|_|�| j� |�d� |jd j}t� }|� |d� | �
|j d� | �
|j g � |�
� | �
|j d� | �
|j dg� |�� |�� | �
|j d� |�� | �
|j d� dS )z�
If a L{Request} object completes its response while the transport is
paused, the L{HTTPChannel} does not resume the transport.
r s extraTr� r� r� N)r� r r} r� r� rv r� r� r r@ rL r� r� r� rT r r� r� r1 r1 r2 �/test_HTTPChannelStaysPausedWhenRequestCompletes� s& �
zFChannelProductionTests.test_HTTPChannelStaysPausedWhenRequestCompletesc C s� G dd� dt �}|� }|�� | �t|j� | �|� t�\}}| �|jd� |�� | �|jd� |�| j � | �|jd� | �
|� � � d�� |�
� | �|jd� dS )z�
If the L{HTTPChannel} has paused the transport, it still tolerates
receiving data, and does not attempt to pause the transport again.
c @ r; )zgChannelProductionTests.test_HTTPChannelToleratesDataWhenTransportPaused.<locals>.NoDoublePauseTransportz|
A version of L{StringTransport} that fails tests if it is paused
while already paused.
c S s | j dkr td��t�| � d S )Nr� zTransport was paused twice!)r� rb r r� rA r1 r1 r2 r� � s
zvChannelProductionTests.test_HTTPChannelToleratesDataWhenTransportPaused.<locals>.NoDoublePauseTransport.pauseProducingN)r- r. r/ r0 r� r1 r1 r1 r2 �NoDoublePauseTransport� r� r� r� r� s HTTP/1.1 200 OK
N)r r� r1 rb r� rc rL r� r� rv r� r� r� r� )rB r� r� r{ r1 r1 r2 �0test_HTTPChannelToleratesDataWhenTransportPaused� s � zGChannelProductionTests.test_HTTPChannelToleratesDataWhenTransportPausedc sh � � t� t�\}�t� �t�� }t|_|��� |�� j � |j
d j }|j j
}� �fdd�}|�|�S )z�
If the L{HTTPChannel} has a L{IPullProducer} registered with it it can
adapt that producer into an L{IPushProducer}.
r c s( �� � �dd�d }d}� �||� d S )Nr� r* s< 1
0
1
1
1
2
1
3
1
4
1
5
1
6
1
7
1
8
1
9
)r� r� rL )�ign� responseBody�expectedResponseBody�rB r� r1 r2 �validate s � zOChannelProductionTests.test_HTTPChannelToleratesPullProducers.<locals>.validate)r� r r< r r� � DummyPullProducerHandlerProxyr� r� r� rv r� r� r> r� r\ )rB r{ rv �responseCompleter� r1 r� r2 �&test_HTTPChannelToleratesPullProducers s �
z=ChannelProductionTests.test_HTTPChannelToleratesPullProducersc C s| t � }t� }t�� }d|_|j|_|�|� |�d� | �|j |� | �|j
d� |�d� | �|j d� | �|j
d� dS )zS
L{HTTPChannel} unregisters itself when it times out a connection.
r� r� Tr* N) r r r r� r� r� r� r� r> r? r� )rB r� r� r{ r1 r1 r2 �,test_HTTPChannelUnregistersSelfWhenTimingOut* s
zCChannelProductionTests.test_HTTPChannelUnregistersSelfWhenTimingOutN)r- r. r/ r0 rv r� r� r� r� r� r� r� r� r� r� r� r� r� r1 r1 r1 r2 r� s ,*- #r� c @ r; )� HTTPChannelSanitizationTestsz8
Test that L{HTTPChannel} sanitizes its output.
c C sl t D ]1}t� }t�� }|�|� |jddd||fgd� d�ttg�d }| �|� � d�d|dg�� qd S )
z�
L{HTTPChannel.writeHeaders} removes linear whitespace from the
list of header names and values it receives.
rx rG s OK)rJ �code�reasonr� � : r� r� r� N)
r' r r r� r� � writeHeadersr� r( rL r� )rB � componentr� r{ �sanitizedHeaderLiner1 r1 r2 �*test_writeHeadersSanitizesLinearWhitespaceG s8
�����
����zGHTTPChannelSanitizationTests.test_writeHeadersSanitizesLinearWhitespaceN)r- r. r/ r0 r� r1 r1 r1 r2 r� B r r� c @ r; )�HTTPClientSanitizationTestsz<
Test that L{http.HTTPClient} sanitizes its output.
c C sR t D ]$}t� }t�� }|�|� |�||� | �|�� �� d� t
t
g�g� qdS )z�
L{HTTPClient.sendHeader} replaces linear whitespace in its
header keys and values with a single space.
r� N) r' r r �
HTTPClientr� r� rL r� r� r� r( )rB r� r� r_ r1 r1 r2 �(test_sendHeaderSanitizesLinearWhitespaces s
��zDHTTPClientSanitizationTests.test_sendHeaderSanitizesLinearWhitespaceN)r- r. r/ r0 r� r1 r1 r1 r2 r� n r r� c @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd S ) �HexHelperTestszM
Test the L{http._hexint} and L{http._ishexdigits} helper functions.
)r� s 0x1234s fedss -123+123c C s dD ] }| � dt�|�� qdS )zr
L{_ishexdigits()} returns L{True} for nonempy bytestrings containing
hexadecimal digits.
)r� s abcdefs AB1234s feds 123467890TN)r> r � _ishexdigits�rB r� r1 r1 r2 �
test_isHex� s �zHexHelperTests.test_isHexc C s: | � dt�d�� | � dt�d�� | � dt�d�� dS )zK
L{_hexint()} returns the integer equivalent of the input.
r� r� � r� i#Ѽ
s abCD123N)rL r �_hexintrA r1 r1 r2 � test_decodes� s zHexHelperTests.test_decodesc C s" | j D ] }| �dt�|�� qdS )z�
L{_ishexdigits()} returns L{False} for bytestrings that don't contain
hexadecimal digits, including the empty string.
FN)�
badStringsr> r r� r� r1 r1 r2 �
test_isNotHex� s
�z HexHelperTests.test_isNotHexc C s | j D ]
}| �ttj|� qdS )zb
L{_hexint()} raises L{ValueError} for bytestrings that can't
be decoded.
N)r� r1 r2 r r� r� r1 r1 r2 �test_decodeNotHex� s
�z HexHelperTests.test_decodeNotHexN) r- r. r/ r0 r� r� r� r� r� r1 r1 r1 r2 r� � s r� )rr0 r r\ rH r� �ior � itertoolsr �typingr r r r � urllib.parser r r
r �zope.interfacer r
r �zope.interface.verifyr r �twisted.internetr �twisted.internet.errorr r �twisted.internet.taskr �twisted.loggerr �twisted.protocolsr �twisted.python.compatr r �twisted.python.componentsr �twisted.python.failurer �twisted.test.proto_helpersr r r �twisted.test.test_internetr �
twisted.trial�twisted.trial.unittestr � twisted.webr r! r" �twisted.web.httpr# r$ r% � twisted.web.test.requesthelperr& r' r( r) �_utilr+ re r, r: r
r< r� rF rc r� �INonQueuedRequestFactoryry �DummyNewHTTPHandlerProxyr} r� r� r� r� r� r� r� r� r� r� r r r rE ri rj r{ r� r� r r� r� r� r� r� r� r� r� r� �SynchronousTestCaser� r� r� r1 r1 r1 r2 �<module> s�
�� $ g4
2", ^7
2 y Sa nQ7 ?,