0x1949 Team - FAZEMRX - MANAGER
Edit File: test_web.cpython-310.pyc
o ��f � @ s( d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl mZmZ dd lmZ dd lmZmZ dd lmZmZ dd lmZ dd lmZ ddl m Z m Z ddl m Z ddl!m"Z"m#Z#m$Z$m%Z%m&Z& ddl'm(Z( ddl)m*Z*m+Z+m,Z, ddl-m.Z. ddl/m0Z0m1Z1 ddl2m3Z3 G dd� de j4�Z5G dd� de%j(�Z6G dd � d e%j(�Z7G d d � d e%j(�Z8G d d � d e j4�Z9G d!d"� d"e j4�Z:d#d$� Z;d%d&� Z<d'd(� Z=G d)d*� d*e j4�Z>G d+d,� d,e j4�Z?G d-d.� d.e j4�Z@G d/d0� d0e%j(�ZAG d1d2� d2e j4�ZBG d3d4� d4e%j(�ZCee%jD�G d5d6� d6��ZEG d7d8� d8e j4�ZFG d9d:� d:e%j(�ZGG d;d<� d<e j4�ZHG d=d>� d>e1�ZIG d?d@� d@�ZJG dAdB� dBeJe j4�ZKG dCdD� dDeJe j4�ZLG dEdF� dFe j4�ZMG dGdH� dHe j4�ZNG dIdJ� dJe j4�ZOG dKdL� dLe j4�ZPG dMdN� dNe j4�ZQG dOdP� dPe(�ZRG dQdR� dRe j4�ZSdS )Sz, Tests for various parts of L{twisted.web}. � N)�BytesIO)�List)� implementer)� verifyObject)� interfaces)� IPv4Address� IPv6Address)�Clock)�LogLevel�globalLogPublisher)�failure�reflect)� iterbytes)�FilePath)�EventLoggingObserver�StringTransport)�unittest)�error�http�iweb�resource�server)�Resource)� NOT_DONE_YET�Request�Site)�Data)� DummyChannel� DummyRequest� )�assertIsFilesystemTemporaryc @ s e Zd Zdd� ZdS )� ResourceTestsc C s t �� }| �g |�� � d S �N)r r � assertEqual� listEntities)�self�r� r' �;/usr/lib/python3/dist-packages/twisted/web/test/test_web.py�testListEntities" s z ResourceTests.testListEntitiesN)�__name__� __module__� __qualname__r) r' r' r' r( r! ! s r! c @ s" e Zd ZdZddd�Zdd� ZdS )�SimpleResourcez� @ivar _contentType: L{None} or a C{str} giving the value of the I{Content-Type} header in the response this resource will render. If it is L{None}, no I{Content-Type} header will be set in the response. Nc C s t j�| � || _d S r" )r r �__init__� _contentType)r% � contentTyper' r' r( r. . s zSimpleResource.__init__c C s> | j d ur|j�d| j g� tj|�d�|�d�fv r dS dS )N� content-type� � MatchingTag� � correct)r/ �responseHeaders� setRawHeadersr �CACHED�setLastModified�setETag�r% �requestr' r' r( �render2 s �zSimpleResource.renderr" )r* r+ r, �__doc__r. r= r' r' r' r( r- ' s r- c @ � e Zd ZdZdd� ZdS )�ZeroLengthResourcez@ A resource that always returns a zero-length response. c C � dS �Nr4 r' r; r' r' r( r= D � zZeroLengthResource.renderN�r* r+ r, r> r= r' r' r' r( r@ ? � r@ c @ r? )�NoContentResourcezf A resource that always returns a 204 No Content response without setting Content-Length. c C s |� tj� dS rB )�setResponseCoder � NO_CONTENTr; r' r' r( r= N � zNoContentResource.renderNrD r' r' r' r( rF H s rF c @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dS )�SiteTestz( Unit tests for L{server.Site}. c C s |� � }| �|j� |S )z� Create a new session which auto expires at cleanup. @param site: The site on which the session is created. @type site: L{server.Site} @return: A newly created session. @rtype: L{server.Session} )� makeSession� addCleanup�expire�r% �site�sessionr' r' r( �getAutoExpiringSessionX s z SiteTest.getAutoExpiringSessionc C s@ t � }t � }|�d|� t�|�}| �|�tdg��|d� dS )z� L{Site.getResourceFor} returns the C{b""} child of the root resource it is constructed with when processing a request for I{/}. r4 zGot the wrong resource.N)r- �putChildr r �assertIdentical�getResourceForr )r% �sres1�sres2rO r' r' r( �test_simplestSiteg s �zSiteTest.test_simplestSitec C s" t jt� d�}| �t j|j� dS )zC L{server.Request} is the default request factory. )r N)r r r- �assertIsr �requestFactory�r% rO r' r' r( �test_defaultRequestFactoryt � z#SiteTest.test_defaultRequestFactoryc C s( t � }tjt� |d�}| �||j� dS )zB Can be initialized with a custom requestFactory. )r rY N)�objectr r r- rX rY )r% � customFactoryrO r' r' r( � test_constructorRequestFactory| s z'SiteTest.test_constructorRequestFactoryc C s8 t �t� �}|�d�}| �||j� | �|j|j� dS )z� Returns a C{Channel} whose C{site} and C{requestFactory} attributes are assigned from the C{site} instance. N)r r r- � buildProtocolrX rO rY )r% rO �channelr' r' r( �test_buildProtocol� s zSiteTest.test_buildProtocolc C s8 t �t�� �}| �|�}| �|t j� | �|jt� dS )zn L{site.getSession} generates a new C{Session} instance with an uid of type L{bytes}. N) r r r r rQ �assertIsInstance�Session�uid�bytesrN r' r' r( �test_makeSession� s zSiteTest.test_makeSessionc s� t �t�� �}| �|jtj� � fdd�� d� _| � |d� � | � |�}| � |�}| � |j d� | � |j d� | � |j d� dS ) z} L{site.getSession} generates L{Session} objects with distinct UIDs from a secure source of entropy. c s" � j d7 _ t� j �| �d�S )Nr �charmap)�x�chr�encode)�n��predictableEntropyr' r( rn � s z>SiteTest.test_sessionUIDGeneration.<locals>.predictableEntropyr �_entropys@ 0101010101010101010101010101010101010101010101010101010101010101s@ 0202020202020202020202020202020202020202020202020202020202020202� N)r r r r rS ro �os�urandomri �patchrQ r# re �counter)r% rO �a�br' rm r( �test_sessionUIDGeneration� s z"SiteTest.test_sessionUIDGenerationc C s4 t �t�� �}| �|�}|�|j�}| �||� dS )zc L{site.getSession} gets a previously generated session, by its unique ID. N)r r r r rQ � getSessionre rX )r% rO �createdSession�retrievedSessionr' r' r( �test_getSessionExistent� s z SiteTest.test_getSessionExistentc C s" t �t�� �}| �t|jd� dS )zV L{site.getSession} raises a L{KeyError} if the session is not found. s no-such-uidN)r r r r � assertRaises�KeyErrorrx rZ r' r' r( �test_getSessionNonExistent� r\ z#SiteTest.test_getSessionNonExistentN) r* r+ r, r> rQ rW r[ r_ rb rg rw r{ r~ r' r' r' r( rJ S s rJ c @ sP e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dS )� SessionTestsz& Tests for L{server.Session}. c C sJ t � | _d| _tjt�� | jd�| _t�| j| j�| _ | j | jj | j< dS )zo Create a site with one active session using a deterministic, easily controlled clock. s unique��reactorN) r �clockre r r r r rO rd rP �sessions�r% r' r' r( �setUp� s zSessionTests.setUpc C s4 t jt�� t� d�}t �|d�}| �|j|j� dS )z| If no value is passed to L{server.Session.__init__}, the reactor associated with the site is used. r� � 123N) r r r r r rd rS �_reactorr� rN r' r' r( �test_defaultReactor� s z SessionTests.test_defaultReactorc C s6 t �t�� �}t� }t j|d|d�}| �|j|� dS )zG L{Session} accepts the reactor to use as a parameter. r� r� N)r r r r r rd rS r� )r% rO � otherReactorrP r' r' r( �test_explicitReactor� s z!SessionTests.test_explicitReactorc C s` | j �� | j�| j jd � | �| j| jj� | j�d� | � | j| jj� | � | jj � dS )z� L{server.Session.startCheckingExpiration} causes the session to expire after L{server.Session.sessionTimeout} seconds without activity. r N) rP �startCheckingExpirationr� �advance�sessionTimeout�assertInre rO r� � assertNotIn� assertFalse�callsr� r' r' r( � test_startCheckingExpiration� s z)SessionTests.test_startCheckingExpirationc C s. | j �� | �| j| jj� | �| jj� dS )z? L{server.Session.expire} expires the session. N) rP rM r� re rO r� r� r� r� r� r' r' r( � test_expire s zSessionTests.test_expirec C s | j �� | �� dS )zn L{server.Session.expire} expires the session even if the timeout call isn't due yet. N)rP r� r� r� r' r' r( �test_expireWhileChecking s z%SessionTests.test_expireWhileCheckingc s: dg� � fdd�}| j �|� | j �� | �� d � dS )zy A function registered with L{server.Session.notifyOnExpire} is called when the session expires. Fc s d� d< d S )NTr r' r' �� callbackRanr' r( �expired s z1SessionTests.test_notifyOnExpire.<locals>.expiredr N)rP �notifyOnExpirerM � assertTrue)r% r� r' r� r( �test_notifyOnExpire s z SessionTests.test_notifyOnExpirec C s� | j �d� | j�� | �| jjd� | j�� | j �| jjd � | j�� | j �| jjd � | �| j | j j � | j �d� | � | j | j j � dS )zt L{server.Session.touch} updates L{server.Session.lastModified} and delays session timeout. � r N) r� r� rP �touchr# � lastModifiedr� r� r� re rO r� r� r� r' r' r( � test_touch" s zSessionTests.test_touchN) r* r+ r, r> r� r� r� r� r� r� r� r� r' r' r' r( r � s r c C s | � dd�d S )N� r )�split)�wholer' r' r( �httpBodyB � r� c C sR |� � }| �dd�d }|�d�D ]}|� � �|�r&|�dd�d �� S qd S )Nr� r r � � :)�lowerr� � startswith�strip)r� �key�headers�headerr' r' r( � httpHeaderF s �r� c C s | � dd�d }t|� � d �S )Nr� r r )r� �int)r� �l1r' r' r( �httpCodeO s r� c @ sr e Zd ZdZdd� Zdd� Zddd�Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� ZdS ) �ConditionalTestszM web.server's handling of conditional requests for cache validation. c C s� t � | _| j�d| j� | j�dt d�� t�| j�| _| j�� | �| jj� | j� d �| _ t � � | _ dd� | j _dd� | j _dd� | j _dd� | j _| j �| j � d S ) Nr4 s with-content-type� image/jpegc _ � d S r" r' �ru �kwr' r' r( �<lambda>d � z(ConditionalTests.setUp.<locals>.<lambda>c _ rA )Nr r' r� r' r' r( r� e r� c _ rA )N�peerr' r� r' r' r( r� f r� c _ rA )N�hostr' r� r' r' r( r� g r� )r- �resrcrR r r rO � startFactoryrL � stopFactoryr` ra r r � transport�close� disconnecting�getPeer�getHost�makeConnectionr� r' r' r( r� Y s zConditionalTests.setUpc C s | j �d � d S r" )ra �connectionLostr� r' r' r( �tearDownj r� zConditionalTests.tearDownNc C s| |dur d| }nd| }d|dfD ] }| j �|d � q| j�� }| �t|�tj� | �t|�d� | �t |d�d � dS ) a Given the value C{modifiedSince} for the I{If-Modified-Since} header or the value C{etag} for the I{If-Not-Match} header, verify that a response with a 200 code, a default Content-Type, and the resource as the body is returned. N� If-Modified-Since: s If-Not-Match: � GET / HTTP/1.1r4 r� r5 � Content-Types text/html) ra � dataReceivedr� �getvaluer# r� r �OKr� r� )r% � modifiedSince�etag� validator�line�resultr' r' r( � _modifiedTestm s z ConditionalTests._modifiedTestc C s | j t�d�d� dS )a If a request is made with an I{If-Modified-Since} header value with a timestamp indicating a time before the last modification of the requested resource, a 200 response is returned along with a response body containing the resource. r �r� N)r� r �datetimeToStringr� r' r' r( � test_modified s z ConditionalTests.test_modifiedc C sl ddt �d� dfD ] }| j�|d � q | j�� }| �t|�t j� | �t |�d� | �t |d�d� dS )a= If a request is made with an I{If-Modified-Since} header value with a timestamp indicating a time after the last modification of the request resource, a 304 response is returned along with an empty response body and no Content-Type header if the application does not set one. r� r� �d r4 r� r� N) r r� ra r� r� r� r# r� � NOT_MODIFIEDr� r� �r% r� r� r' r' r( �test_unmodified� s � z ConditionalTests.test_unmodifiedc C � | j dd� dS )a If a request is made with an I{If-Modified-Since} header value which cannot be parsed, the header is treated as not having been present and a normal 200 response is returned with a response body containing the resource. s like, maybe a week ago, I guess?r� N�r� r� r' r' r( �test_invalidTimestamp� � z&ConditionalTests.test_invalidTimestampc C r� )a3 If a request is made with an I{If-Modified-Since} header value which contains a string in the year position which is not an integer, the header is treated as not having been present and a normal 200 response is returned with a response body containing the resource. s Thu, 01 Jan blah 00:00:10 GMTr� Nr� r� r' r' r( �test_invalidTimestampYear� r� z*ConditionalTests.test_invalidTimestampYearc C r� )a If a request is made with an I{If-Modified-Since} header value which contains a year before the epoch, the header is treated as not having been present and a normal 200 response is returned with a response body containing the resource. s Thu, 01 Jan 1899 00:00:10 GMTr� Nr� r� r' r' r( � test_invalidTimestampTooLongAgo� r� z0ConditionalTests.test_invalidTimestampTooLongAgoc C r� )aQ If a request is made with an I{If-Modified-Since} header value which contains a string in the month position which is not a recognized month abbreviation, the header is treated as not having been present and a normal 200 response is returned with a response body containing the resource. s Thu, 01 Blah 1970 00:00:10 GMTr� Nr� r� r' r' r( �test_invalidTimestampMonth� s z+ConditionalTests.test_invalidTimestampMonthc C r� )a" If a request is made with an I{If-None-Match} ETag which does not match the current ETag of the requested resource, the header is treated as not having been present and a normal 200 response is returned with a response body containing the resource. s unmatchedTag)r� Nr� r� r' r' r( �test_etagMatchedNot� r� z$ConditionalTests.test_etagMatchedNotc C s\ dD ] }| j �|d � q| j�� }| �t|d�d� | �t|�tj� | �t |�d� dS )z� If a request is made with an I{If-None-Match} ETag which does match the current ETag of the requested resource, a 304 response is returned along with an empty response body. )r� � If-None-Match: MatchingTagr4 r� s ETagr3 r4 N) ra r� r� r� r# r� r� r r� r� r� r' r' r( �test_etagMatched� s z!ConditionalTests.test_etagMatchedc C s\ dD ] }| j �|d � q| j�� }| �t|�tj� | �t|�d� | �t |d�d� dS )aL Similar to L{test_etagMatched}, but the response should include a I{Content-Type} header if the application explicitly sets one. This I{Content-Type} header SHOULD NOT be present according to RFC 2616, section 10.3.5. It will only be present if the application explicitly sets it. )s GET /with-content-type HTTP/1.1r� r4 r� r4 r� r� N) ra r� r� r� r# r� r r� r� r� r� r' r' r( � test_unmodifiedWithContentType� s z/ConditionalTests.test_unmodifiedWithContentType)NN)r* r+ r, r> r� r� r� r� r� r� r� r� r� r� r� r� r' r' r' r( r� T 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<S )=� RequestTestsz> Tests for the HTTP request class, L{server.Request}. c C s | � ttjt�t� d��� dS )zG L{server.Request} instances provide L{iweb.IRequest}. TN)r� r r �IRequestr r r r� r' r' r( �test_interface� s �zRequestTests.test_interfacec C s t �t� d�}t|� dS )zY L{server.Request} instances are hashable, thus can be put in a mapping. TN)r r r �hashr; r' r' r( � test_hashable� s zRequestTests.test_hashablec C st t �t� d�}|�d� |�ddd� | �|�d�d� t �t� d�}|�d� |�ddd� | �|�d�d� d S ) Nr r � GET� /foo/bar� HTTP/1.0s bazs bar/baz� /foo/bar/)r r r � gotLength�requestReceivedr# � childLinkr; r' r' r( � testChildLink s zRequestTests.testChildLinkc C sF t �t� d�}|�d� |�ddd� |�dd� | �|�� d� d S ) Nr r r� r� r� � example.com�P s http://example.com/foo/bar)r r r r� r� �setHostr# � prePathURLr; r' r' r( �testPrePathURLSimple s z!RequestTests.testPrePathURLSimplec C �R t � }d|j_t�|d�}|�dd� |�d� |�ddd� | �|� � d� d S ) N�Q r r� r r� r� r� s http://example.com:81/foo/bar� r r� �portr r r� r� r� r# r� �r% �dr< r' r' r( �testPrePathURLNonDefault � z%RequestTests.testPrePathURLNonDefaultc C r� ) N� r r� r r� r� r� s http://example.com:443/foo/barr� r� r' r' r( �testPrePathURLSSLPort r� z"RequestTests.testPrePathURLSSLPortc C �\ t � }t �� |_d|j_t�|d�}|�dd� |�d� |�ddd� | � |� � d� d S ) Nr� r r� r r� r� r� s https://example.com/foo/bar� r �SSLr� r� r r r� r� r� r# r� r� r' r' r( �testPrePathURLSSLPortAndSSL$ � z(RequestTests.testPrePathURLSSLPortAndSSLc C r� ) Nr� r r� r r� r� r� s https://example.com:80/foo/barr� r� r' r' r( � testPrePathURLHTTPPortAndSSL. r z)RequestTests.testPrePathURLHTTPPortAndSSLc C r� ) Nr� r r� r r� r� r� s https://example.com:81/foo/barr� r� r' r' r( �testPrePathURLSSLNonDefault8 r z(RequestTests.testPrePathURLSSLNonDefaultc C sT t � }d|j_t�|d�}|�ddd� |�d� |�ddd� | �|� � d� d S ) Nr� r s foo.comr r� r� r� s https://foo.com:81/foo/barr� r� r' r' r( �testPrePathURLSetSSLHostB s z%RequestTests.testPrePathURLSetSSLHostc C sJ t � }t�|d�}|�dd� |�d� |�ddd� | �|�� d� d S ) z L{Request.prePathURL} quotes special characters in the URL segments to preserve the original meaning. r r� r� r r� s /foo%2Fbarr� s http://example.com/foo%2FbarN)r r r r� r� r� r# r� r� r' r' r( �test_prePathURLQuotingK s z#RequestTests.test_prePathURLQuotingc C s� t �| t�}t� }t�|d�}t�t�� �|_ t � t d��}|� |� | �d|jj�� � | �d|jj�� � | �dt|�� |d }|d }| �|jt � | �|�� d� | �dt| �� �� dS )z� By default, L{Request.processingFailed} does not write out the failure, but give a generic error message, as L{Site.displayTracebacks} is disabled by default. r �Oh no!� Oh no!� Processing Failedr � log_failureN)r �createWithCleanupr r r r r r r rO r �Failure� Exception�processingFailedr� r� �writtenr� r� � assertEquals�lenrc �value�getErrorMessager# �flushLoggedErrors�r% � logObserverr� r< �fail�event�fr' r' r( �)test_processingFailedNoTracebackByDefaultW s z6RequestTests.test_processingFailedNoTracebackByDefaultc C s� t �| t�}t� }t�|d�}t�t�� �|_ d|j _ t � t d��}|�|� | �d|jj�� � | �d|jj�� � | �dt|�� |d }|d }| �|jt � | �|�� d� | �dt| �� �� dS ) z� L{Request.processingFailed} when the site has C{displayTracebacks} set to C{False} does not write out the failure, but give a generic error message. r Fr r r r r N)r r r r r r r r r rO �displayTracebacksr r r r r� r� r r� r� r r rc r r r# r r r' r' r( � test_processingFailedNoTracebackr s z-RequestTests.test_processingFailedNoTracebackc C s� t �| t�}t� }t�|d�}t�t�� �|_ d|j _ t � t d��}|�|� | �d|jj�� � |d }|d }| �|jt � | �|�� d� | �dt| �� �� dS )z� L{Request.processingFailed} when the site has C{displayTracebacks} set to C{True} writes out the failure. r Tr r r r N)r r r r r r r r r rO r r r r r r� r� r r� rc r r r r# r r r r' r' r( �%test_processingFailedDisplayTraceback� s z2RequestTests.test_processingFailedDisplayTracebackc C s� t �| t�}t� }t�|d�}t�t�� �|_ d|j _ t � t d��}|�|� | �d|jj�� � | �t� |d }|d }| �|jt � | �dt| �� �� dS )z� L{Request.processingFailed} when the site has C{displayTracebacks} set to C{True} writes out the failure, making UTF-8 items into HTML entities. r Tu ☃s ☃r r N)r r r r r r r r r rO r r r r r r� r� r r� r � UnicodeErrorrc r r# r r r' r' r( �3test_processingFailedDisplayTracebackHandlesUnicode� s z@RequestTests.test_processingFailedDisplayTracebackHandlesUnicodec C s� t � }t �� |_t�|d�}t�t�� �|_g |_ |� � }| � |� | � |j � | �|jd �d�d d� |j dd�}| � |� | �|jd �d�d d� | � |j � | �|j|j� dS ) z� L{Request.session} and L{Request.secure_session} should be two separate sessions with unique ids and different cookies. r r � =s TWISTED_SECURE_SESSIONT��forceNotSecure� TWISTED_SESSIONN)r r r� r r r r r rO �sitepathrx �assertIsNotNonerL rM r# �cookiesr� �assertNotEqualre )r% r� r< � secureSessionrP r' r' r( �&test_sessionDifferentFromSecureSession� s z3RequestTests.test_sessionDifferentFromSecureSessionc C s� t �t�� �}t� }t�� |_t �|d�}||_g |_ | � |j d� |j dd�}| � |j� | � |j d� |� � }| � |j� | �|d� | �||� | � |j |� dS )z� On a L{Request}, the C{session} attribute retrieves the associated L{Session} only if it has been initialized. If the request is secure, it retrieves the secure session. r NTr! )r r r r r r r� r rO r$ rX rP rx rL rM � assertIsNot)r% rO r� r< �insecureSessionr( r' r' r( �test_sessionAttribute� s z"RequestTests.test_sessionAttributec C sX t �t�� �}t� }t �|d�}||_g |_|�� }| � |j � |�� }| � ||� dS )z� L{Request.getSession} creates the session object only once per request; if it is called twice it returns the identical result. r N) r r r r r r rO r$ rx rL rM rX )r% rO r� r< �session1�session2r' r' r( �test_sessionCaching� s z RequestTests.test_sessionCachingc C sd t �t�� �}t� }t �|d�}||_g |_t �|d�}||j |j < |j |j d< | � |� � |� dS )z� L{Request.getSession} retrieves an existing session if the relevant cookie is set in the incoming request. r s special-idr# N)r r r r r r rO r$ rd r� re �received_cookiesrX rx )r% rO r� r< � mySessionr' r' r( � test_retrieveExistingSession� s z)RequestTests.test_retrieveExistingSessionc C s� t �t�� �}t� }t �|d�}||_g |_d|jd< |� � }| � |� | � |j � | � |jd �d�� | �d|jd � dS )z� L{Request.getSession} generates a new session if the session ID advertised in the cookie from the incoming request is not found. r s does-not-existr# r s TWISTED_SESSION=N)r r r r r r rO r$ r0 rx r% rL rM r� r& r� r� )r% rO r� r< rP r' r' r( � test_retrieveNonExistentSession s z,RequestTests.test_retrieveNonExistentSessionc s� t � � t�t�� �}t� }t�|d�}||_g |_� �fdd�}|j �||_ |� � }� � �j � |� � }| � |j� | �||� | �|j|j� dS )zn L{Request.getSession} generates a new session when the previous session has expired. r c s �| |�}� |_ |S )ap Forward to normal session factory, but inject the clock. @param site: The site on which the session is created. @type site: L{server.Site} @param uid: A unique identifier for the session. @type uid: C{bytes} @return: A newly created session. @rtype: L{server.Session} )r� )rO re rP �r� �sessionFactoryr' r( �sessionFactoryWithClock* s zDRequestTests.test_getSessionExpired.<locals>.sessionFactoryWithClockN)r r r r r r r rO r$ r5 rx r� r� rL rM r* r' re )r% rO r� r< r6 �initialSession� newSessionr' r4 r( �test_getSessionExpired s z#RequestTests.test_getSessionExpiredc C sb t � }t�|d�}|�dd� |�d� |�ddd� |jj�� }| � |� d�� | � d |� d S ) zf L{Request} handles OPTIONS * requests by doing a fast-path return of 200 OK. r r� r� r s OPTIONS� *� HTTP/1.1s HTTP/1.1 200 OK� Content-Length: 0 N� r r r r� r� r� r� r r� r� r� r� �r% r� r< �responser' r' r( �test_OPTIONSStarJ s z RequestTests.test_OPTIONSStarc C sn t � }t�|d�}|�dd� |�d� |�ddd� |jj�� }| � |� d�� | � d |� | � d |� d S ) z� L{Request} handles any non-OPTIONS verb requesting the * path by doing a fast-return 405 Method Not Allowed, indicating only the support for OPTIONS. r r� r� r r� r: r; s HTTP/1.1 405 Method Not Allowedr< s Allow: OPTIONS Nr= r> r' r' r( �test_rejectNonOPTIONSStarY s z&RequestTests.test_rejectNonOPTIONSStarc C sz t � }|�d|� t�|�}t� }||_t�|d�}||_|�dd� |�d� |� ddd� | � d |j j � � �� � d S ) zV Responses with no length do not have a default content-type applied. r4 r r� r� r r� � /r; r1 N)r@ rR r r r rO r r� r� r� r� r� r r� r� )r% r� rO r� r< r' r' r( �-test_noDefaultContentTypeOnZeroLengthResponsej s z:RequestTests.test_noDefaultContentTypeOnZeroLengthResponsec C s� t � }|�d|� t�|�}t� }||_t�|d�}||_|�dd� |�d� |� ddd� |j j � � }| � |�d �� | �d |�� � d S ) zX Responses with a 204 status code have no default content-type applied. r4 r r� r� r r� rB r; s HTTP/1.1 204 No Content r1 N)rF rR r r r rO r r� r� r� r� r r� r� r� r� r� )r% r� rO r� r< r? r' r' r( �&test_noDefaultContentTypeOn204Response{ s z3RequestTests.test_noDefaultContentTypeOn204Responsec C s( t �t� �}|�d� | �|jt� dS )z� L{http.Request} creates a L{BytesIO} if the content length is small and the site doesn't offer to create one. i�� N)r r r r� rc �contentr r; r' r' r( � test_defaultSmallContentFile� s z)RequestTests.test_defaultSmallContentFilec C s& t �t� �}|�d� t| |j� dS )z� L{http.Request} creates a temporary file on the filesystem if the content length is larger and the site doesn't offer to create one. i�� N�r r r r� r rE r; r' r' r( � test_defaultLargerContentFile� � z*RequestTests.test_defaultLargerContentFilec C s& t �t� �}|�d� t| |j� dS )z� L{http.Request} creates a temporary file on the filesystem if the content length is not known and the site doesn't offer to create one. NrG r; r' r' r( �"test_defaultUnknownSizeContentFile� rI z/RequestTests.test_defaultUnknownSizeContentFilec sl g �t � � t�t�� �}� �fdd�}||_t� }||_t�|�}|� d� | � dg�� | � � |j � dS )z� L{http.Request} uses L{Site.getContentFile}, if it exists, to get a file-like object for the request content. c s �� | � � S r" )�append)�length�� contentFile�lengthsr' r( �getContentFile� s zARequestTests.test_siteSuppliedContentFile.<locals>.getContentFile�90 N) r r r r r rP r rO r r� r# rX rE )r% rO rP ra r< r' rM r( � test_siteSuppliedContentFile� s z)RequestTests.test_siteSuppliedContentFileN)!r* r+ r, r> r� r� r� r� r� r� r r r r r r r r r r) r, r/ r2 r3 r9 r@ rA rC rD rF rH rJ rR r' r' r' r( r� � s> , r� c @ �L e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )�GzipEncoderTestsc C s: t � | _tdd�}t�|t�� g�}| jjj�d|� d S )N� Some dataz text/plain� foo) r ra r r �EncodingResourceWrapperr �GzipEncoderFactoryrO rR )r% �staticResource�wrappedr' r' r( r� � s �zGzipEncoderTests.setUpc C sb t �| jd�}|�d� |j�ddg� t �� }| �tt j |�� |� |�}| �tt j |�� dS )z� L{server.GzipEncoderFactory} implements the L{iweb._IRequestEncoderFactory} and its C{encoderForRequest} returns an instance of L{server._GzipEncoder} which implements L{iweb._IRequestEncoder}. Fr � Accept-Encoding� gzip,deflateN) r r ra r� �requestHeadersr7 rX r� r r �_IRequestEncoderFactory�encoderForRequest�_IRequestEncoder)r% r< �factory�encoderr' r' r( �test_interfaces� s z GzipEncoderTests.test_interfacesc C � t �| jd�}|�d� |j�ddg� |�ddd� | jjj� � }| � d|� | � d |� ||� d �d d � }| � d t�|dtj �� d S )z� If the client request passes a I{Accept-Encoding} header which mentions gzip, L{server._GzipEncoder} automatically compresses the data. Fr r[ r\ r� � /foor� � Content-Length� Content-Encoding: gzip r� � NrU � �r r ra r� r] r7 r� r� r r� r� r� �findr# �zlib� decompress� MAX_WBITS�r% r< �data�bodyr' r' r( � test_encoding� s z GzipEncoderTests.test_encodingc C rd )z� If the client request passes a I{Accept-Encoding} header which mentions gzip, with whitespace inbetween the encoding name and the commas, L{server._GzipEncoder} automatically compresses the data. Fr r[ s deflate, gzipr� re r� rf rg r� rh NrU ri rj ro r' r' r( � test_whitespaceInAcceptEncoding� s z0GzipEncoderTests.test_whitespaceInAcceptEncodingc C s� t �| jd�}|�d� |j�ddg� |�ddd� | jjj� � }| � d|� | � d |� ||� d �d d � }| � d |� d S )z� L{server.GzipEncoderFactory} doesn't return a L{server._GzipEncoder} if the I{Accept-Encoding} header doesn't mention gzip support. Fr r[ s foo,barr� re r� rf rg r� rh NrU )r r ra r� r] r7 r� r� r r� r� r� rk r# ro r' r' r( �test_nonEncoding� s z!GzipEncoderTests.test_nonEncodingc C s� t �| jd�}|�d� |j�dddg� |�ddd� | jjj� � }| � d |� | � d |� ||� d �d d � }| � dt�|dtj �� d S )z� If there are multiple I{Accept-Encoding} header, L{server.GzipEncoderFactory} reads them properly to detect if gzip is supported. Fr r[ � deflate� gzipr� re r� rf rg r� rh NrU ri rj ro r' r' r( �test_multipleAccept s z$GzipEncoderTests.test_multipleAcceptc C s� t �| jd�}|�d� |j�dddg� |j�ddg� |�ddd � | jjj � � }| � d |� | � d |� ||� d �d d� }| �dt�|dtj �� dS )z� If the content is already encoded and the I{Content-Encoding} header is set, L{server.GzipEncoderFactory} properly appends gzip to it. Fr r[ ru rv � Content-Encodingr� re r� rf s Content-Encoding: deflate,gzip r� rh NrU ri �r r ra r� r] r7 r6 r� r� r r� r� r� rk r# rl rm rn ro r' r' r( �test_alreadyEncoded s z$GzipEncoderTests.test_alreadyEncodedc C s� t �| jd�}|�d� |j�dddg� |j�dddg� |�d d d � | jjj � � }| � d |� | � d |� ||� d�d d� }| �dt�|dtj �� dS )z� If there are several I{Content-Encoding} headers, L{server.GzipEncoderFactory} normalizes it and appends gzip to the field value. Fr r[ ru rv rx rV � barr� re r� rf s Content-Encoding: foo,bar,gzip r� rh NrU ri ry ro r' r' r( �test_multipleEncodingLines( s z+GzipEncoderTests.test_multipleEncodingLinesN) r* r+ r, r� rc rr rs rt rw rz r| r' r' r' r( rT � s rT c @ � e Zd ZdZdd� Zdd� ZdS )� RootResourcer c C s |� � tj�| ||�S r" )�rememberRootURLr r �getChildWithDefault�r% �namer< r' r' r( r� = s z RootResource.getChildWithDefaultc C rA )N� r' r; r' r' r( r= A rC zRootResource.renderN)r* r+ r, �isLeafr� r= r' r' r' r( r~ : s r~ c @ �( e Zd ZdZdd� Zdd� Zdd� ZdS ) �RememberURLTestszB Tests for L{server.Site}'s root request URL calculation. c C s t � }t�|�|_|S )a Create a L{server.Site} bound to a L{DummyChannel} and the given resource as its root. @param r: The root resource. @type r: L{resource.Resource} @return: The channel to which the site is bound. @rtype: L{DummyChannel} )r r r rO )r% r& �chanr' r' r( � createServerJ s z RememberURLTests.createServerc C s� t �� }d|_t� }|�d|� |�d|� |�dt �� � | �|�}dD ]"}t�|d�}|�dd� |� d� |� d |d � | � |� � d � q%d S ) z� The path component of the root URL of a L{server.Site} whose root resource is below C{/} is that resource's path, and the netloc component is the L{site.Server}'s own host and port. r rV r4 r{ )s /foo/r� s /foo/bar/bazr� r r� r� r� r� s http://example.com:81/fooN) r r r� r~ rR r� r r r� r� r� r# � getRootURL)r% r& �rrr� �urlr< r' r' r( � testSimpleY s �zRememberURLTests.testSimplec C sz t � }|�d|� |�dt�� � | �|�}dD ]"}t�|d�}|�dd� |�d� |� d|d � | � |� � d � qd S ) z� The path component of the root URL of a L{server.Site} whose root resource is at C{/} is C{/}, and the netloc component is the L{site.Server}'s own host and port. r4 r{ )rB s /bars /bar/bazs /bar/r r� r� r r� r� s http://example.com:81/N) r~ rR r r r� r r r� r� r� r# r� )r% r� r� r� r< r' r' r( �testRootm s �zRememberURLTests.testRootN)r* r+ r, r> r� r� r� r' r' r' r( r� E s r� c @ s e Zd Zdd� Zdd� ZdS )�NewRenderResourcec C rA )N� hi hir' r; r' r' r( � render_GET� rC z NewRenderResource.render_GETc C rA )N� ho hor' r; r' r' r( � render_HEH� rC z NewRenderResource.render_HEHN)r* r+ r, r� r� r' r' r' r( r� s r� c @ s6 e Zd ZdZdgZdd� Zdd� Zdd� Zd d � Zd S ) �HeadlessResourcez6 A resource that implements GET but not HEAD. r� c C s0 || _ |j| jvrt�| j��| j �d� tjS )z; Leave the request open for future writes. s some data)r< �method�allowedMethodsr �UnsupportedMethod�writer r r; r' r' r( r= � s zHeadlessResource.renderc C � t � �)z$ # IResource.isLeaf ��NotImplementedErrorr� r' r' r( r� � � zHeadlessResource.isLeafc C r� )z1 # IResource.getChildWithDefault r� r� r' r' r( r� � r� z$HeadlessResource.getChildWithDefaultc C r� )z& # IResource.putChild r� )r% �path�childr' r' r( rR � r� zHeadlessResource.putChildN) r* r+ r, r> r� r= r� r� rR r' r' r' r( r� � s r� c @ sJ e Zd ZdZddd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )�NewRenderTestsz- Tests for L{server.Request.render}. Nc C sR t � }|du r t� }|jj�d|� d|j_t�|d�}|� dd� |� d� |S )z� Create a request object with a stub channel and install the passed resource at /newrender. If no resource is passed, create one. Ns newrenderr� r r� r ) r r� rO r rR r� r� r r r� r� )r% r r� r< r' r' r( �_getReq� s zNewRenderTests._getReqc C sh | � � }|�ddd� | �|jj�� �� d d� | � � }|�ddd� | �|jj�� �� d d� d S )Nr� � /newrenderr� ���r� � HEHr� )r� r� r# r� r r� � splitlines�r% �reqr' r' r( �testGoodMethods� s z NewRenderTests.testGoodMethodsc C sL | � � }|�ddd� | �|jd� | � � }|�ddd� | �|jd� d S )Ns CONNECTr� r� � s hlalauguG)r� r� r# �coder� r' r' r( �testBadMethods� s z NewRenderTests.testBadMethodsc C sr | � � }|�ddd� | �|jd� | �|j�d�� |j�d�d }tdd� |� d �D ��}| �g d �|� d S ) z� When trying to invoke a method not in the allowed method list, we get a response saying it is not allowed. � POSTr� r� � � allowr c s s � | ]}|� � V qd S r" )r� )�.0�hr' r' r( � <genexpr>� s � z7NewRenderTests.test_notAllowedMethod.<locals>.<genexpr>� ,)r� � HEADr� N) r� r� r# r� r� r6 � hasHeader� getRawHeaders�sortedr� )r% r� � raw_header�allowedr' r' r( �test_notAllowedMethod� s z$NewRenderTests.test_notAllowedMethodc C sx t �| t�}| �� }|�ddd� | �|jd� | �d|jj� � � d�� | � dt |�� |d }| � |d t j� d S ) Nr� r� r� �� r� r� r r � log_level)r r r r� r� r# r� r� r r� rk r r r �info)r% r r� r r' r' r( �testImplicitHead� s z NewRenderTests.testImplicitHeadc C sn t �| t�}t� }| �|�}|�ddd� |jj�� � d�\}}| � |j d� | � |d� | � dt |�� dS ) z� HEAD requests against resource that only claim support for GET should not include a body in the response. r� r� r� r� r� r4 rp N)r r r r� r� r� r� r r� r� r# r� r r )r% r r r� r� rq r' r' r( �test_unsupportedHead� s z#NewRenderTests.test_unsupportedHeadc s� G dd� d�}|� � t �� }� fdd�|_| �|�}|�ddd� |jj�� �d�\}}| � |j d � d d d d ddt � |�dd� t � |�dd� f ddd g }| � d� |��d�|� dS )zw When implemented C{render} method does not return bytes an internal server error is returned. c @ s e Zd Zdefdd�ZdS )z5NewRenderTests.test_noBytesResult.<locals>.RiggedRepr�returnc S rA )Nzmy>reprr' r� r' r' r( �__repr__ rC z>NewRenderTests.test_noBytesResult.<locals>.RiggedRepr.__repr__N)r* r+ r, �strr� r' r' r' r( � RiggedRepr s r� c s � S r" r' )r< �r� r' r( r� r� z3NewRenderTests.test_noBytesResult.<locals>.<lambda>r� r� r� r� i� r� z<html>z@ <head><title>500 - Request did not return bytes</title></head>z <body>z) <h1>Request did not return bytes</h1>zp <p>Request: <pre><%s></pre><br />Resource: <pre><%s></pre><br />Value: <pre>my>repr</pre></p>r r� z </body>z</html>� �asciiN)r r r= r� r� r� r r� r� r# r� r � safe_repr�joinrk )r% r� �no_bytes_resourcer< r� rq �expectedr' r� r( �test_noBytesResult� s. ��� z!NewRenderTests.test_noBytesResultr" ) r* r+ r, r> r� r� r� r� r� r� r� r' r' r' r( r� � s r� c @ r} )�GettableResourcezD Used by AllowedMethodsTests to simulate an allowed method. c C r� r" r' r� r' r' r( r� ( rC zGettableResource.render_GETc C rA )z� The unusual method name is designed to test the culling method in C{twisted.web.resource._computeAllowedMethods}. Nr' r� r' r' r( �render_fred_render_ethel+ s z)GettableResource.render_fred_render_ethelN)r* r+ r, r> r� r� r' r' r' r( r� # s r� c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �AllowedMethodsTestsz� 'C{twisted.web.resource._computeAllowedMethods} is provided by a default should the subclass not provide the method. c C sF t � }|jj�dt� � d|j_t�|d�}|� dd� |� d� |S )zU Generate a dummy request for use by C{_computeAllowedMethod} tests. s gettableresourcer� r r� r ) r rO r rR r� r� r� r r r� r� r� r' r' r( r� 9 s zAllowedMethodsTests._getReqc C s( t � }t�|�}| �t|�h d�� dS )a3 C{_computeAllowedMethods} will search through the 'gettableresource' for all attributes/methods of the form 'render_{method}' ('render_GET', for example) and return a list of the methods. 'HEAD' will always be included from the resource.Resource superclass. � � fred_render_ethelr� r� N)r� r �_computeAllowedMethodsr# �set)r% �resr� r' r' r( �test_computeAllowedMethodsE s z.AllowedMethodsTests.test_computeAllowedMethodsc C sN | � � }|�ddd� | �|jd� | �t|j�d�d �d��h d�� d S ) a7 When an unsupported method is requested, the default L{_computeAllowedMethods} method will be called to determine the allowed methods, and the HTTP 405 'Method Not Allowed' status will be returned with the allowed methods will be returned in the 'Allow' header. r� � /gettableresourcer� r� r� r s , r� N)r� r� r# r� r� r6 r� r� r� r' r' r( �test_notAllowedQ s �z#AllowedMethodsTests.test_notAllowedc C sL | � � }|�ddd� | �|jd� |jj�� }| �d|� | �d|� dS )a When an unsupported method response is generated, an HTML message will be displayed. That message should include a quoted form of the URI and, since that value come from a browser and shouldn't necessarily be trusted. r� s# /gettableresource?value=<script>badr� r� s <script>bads <script>badN� r� r� r# r� r� r r� r� r� �r% r� � renderedPager' r' r( �test_notAllowedQuotinga s � z*AllowedMethodsTests.test_notAllowedQuotingc C sL | � � }|�ddd� | �|jd� |jj�� }| �d|� | �d|� dS )a When an not-implemented method response is generated, an HTML message will be displayed. That message should include a quoted form of the requested method, since that value come from a browser and shouldn't necessarily be trusted. s <style>badr� r� r� s <style>badNr� r� r' r' r( �test_notImplementedQuotingq s z.AllowedMethodsTests.test_notImplementedQuotingN) r* r+ r, r> r� r� r� r� r� r' r' r' r( r� 3 s r� c @ s0 e Zd ZdZdZdZdZeddd�Zdd � Z dS ) �DummyRequestForLogTests /dummy�{ r� N�TCP�1.2.3.4rQ c C � t d��)zS As L{getClientIP} is deprecated, no log formatter should call it. zDCall to deprecated getClientIP method (use getClientAddress instead)r� r� r' r' r( � getClientIP� s �z"DummyRequestForLogTest.getClientIP) r* r+ r, �urir� � clientproto� sentLengthr �clientr� r' r' r' r( r� � s r� c @ r� ) �AccessLogTestsMixinzp A mixin for L{TestCase} subclasses defining tests that apply to L{HTTPFactory} and its subclasses. c O r� )zq Get the factory class to apply logging tests to. Subclasses must override this method. z#Subclass failed to override factoryr� �r% �args�kwargsr' r' r( ra � s zAccessLogTestsMixin.factoryc C sl t � }|�d� | �� }| j||d�}|�� z |�t|�� W |�� n|�� w | �dt |�� � � dS )zu The factory's C{log} method writes a I{combined log format} line to the factory's log file. ���I)�logPathr� sO "1.2.3.4" - - [13/Feb/2009:23:31:30 +0000] "GET /dummy HTTP/1.0" 123 - "-" "-" N) r r� �mktempra r� �logr� r� r# r � getContent)r% r� r� ra r' r' r( �test_combinedLogFormat� s �z*AccessLogTestsMixin.test_combinedLogFormatc C sz dd� }t � }|�d� | �� }| j||d�}||_|�� z |�t|�� W |�� n|�� w | � dt |�� � � dS )z� If the factory is initialized with a custom log formatter then that formatter is used to generate lines for the log file. c S rA )Nzthis is a bad log formatr' )� timestampr< r' r' r( �notVeryGoodFormatter� rC zHAccessLogTestsMixin.test_logFormatOverride.<locals>.notVeryGoodFormatterr� )r� � logFormatters this is a bad log format N) r r� r� ra r� r� r� r� r� r# r r� )r% r� r� r� ra r' r' r( �test_logFormatOverride� s z*AccessLogTestsMixin.test_logFormatOverrideN)r* r+ r, r> ra r� r� r' r' r' r( r� � s (r� c @ s e Zd ZdZejZdS )�HTTPFactoryAccessLogTestsz, Tests for L{http.HTTPFactory.log}. N)r* r+ r, r> r � HTTPFactoryra r' r' r' r( r� � s r� c @ r? )�SiteAccessLogTestsz' Tests for L{server.Site.log}. c O s t jt�� g|�R i |��S r" )r r r r r� r' r' r( ra � s zSiteAccessLogTests.factoryN)r* r+ r, r> ra r' r' r' r( r� � rE r� c @ �0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �CombinedLogFormatterTestsz= Tests for L{twisted.web.http.combinedLogFormatter}. c C � | � ttjtj�� dS )zJ L{combinedLogFormatter} provides L{IAccessLogFormatter}. N)r� r r �IAccessLogFormatterr �combinedLogFormatterr� r' r' r( r� � � �z(CombinedLogFormatterTests.test_interfacec C s� t � }|�d� t�|�� �}ttj|d��}tddd�|_d|_ d|_ |j � dd � |j � d d � t� ||�}| �d |� d S )zo Bytes in fields of the request which are not part of ASCII are escaped in the result. r� r� r� s evil x-forwarded-for �rQ s POS�s HTTP/1.�� referers evil �� user-agents evil �zt"evil x-forwarded-for \x80" - - [13/Feb/2009:23:31:30 +0000] "POS\x81 /dummy HTTP/1.0" 123 - "evil \x83" "evil \x84"N)r r� r �datetimeToLogString�secondsr� r� r r� r� �protocolr] � addRawHeaderr� r# �r% r� r� r< r� r' r' r( � test_nonASCII� s �z'CombinedLogFormatterTests.test_nonASCIIc C sX t � }|�d� t�|�� �}ttj|d��}tddd�|_t� ||�}| � d|� dS )zO A request from an IPv6 client is logged with that IP address. r� r� r� s ::1rQ zJ"::1" - - [13/Feb/2009:23:31:30 +0000] "GET /dummy HTTP/1.0" 123 - "-" "-"N) r r� r r� r� r� r� r r� r� r# r r' r' r( �test_clientAddrIPv6 s �z-CombinedLogFormatterTests.test_clientAddrIPv6c C sn t tj�G dd� d��}t� }|�d� t�|�� �}ttj |d��}|� |_ t� ||�}| � |� d�� dS )zR A request made from an unknown address type is logged as C{"-"}. c @ s e Zd ZdZdS )zKCombinedLogFormatterTests.test_clientAddrUnknown.<locals>.UnknowableAddresszp An L{IAddress} which L{combinedLogFormatter} cannot have foreknowledge of. N)r* r+ r, r> r' r' r' r( �UnknowableAddress+ s r r� r� z"-" N)r r �IAddressr r� r r� r� r� r� r� r� r� r� )r% r r� r� r< r� r' r' r( �test_clientAddrUnknown& s z0CombinedLogFormatterTests.test_clientAddrUnknownN)r* r+ r, r> r� r r r r' r' r' r( r� � s r� c @ r� ) �ProxiedLogFormatterTestsz< Tests for L{twisted.web.http.proxiedLogFormatter}. c C r� )zI L{proxiedLogFormatter} provides L{IAccessLogFormatter}. N)r� r r r� r �proxiedLogFormatterr� r' r' r( r� B r� z'ProxiedLogFormatterTests.test_interfacec C sn t � }|�d� t�|�� �}ttj|d��}t�||��dd�}|j � d|g� t� ||�}| � ||� dS )a� Assert that a request with the given value in its I{X-Forwarded-For} header is logged by L{proxiedLogFormatter} the same way it would have been logged by L{combinedLogFormatter} but with 172.16.1.2 as the client address instead of the normal value. @param header: An I{X-Forwarded-For} header with left-most address of 172.16.1.2. r� r� r� z 172.16.1.2s x-forwarded-forN) r r� r r� r� r� r� r� �replacer] r7 r r# )r% r� r� r� r< r� r� r' r' r( �_xforwardedforTestJ s � z+ProxiedLogFormatterTests._xforwardedforTestc C � | � d� dS )z� L{proxiedLogFormatter} logs the value of the I{X-Forwarded-For} header in place of the client address field. s! 172.16.1.2, 10.0.0.3, 192.168.1.4N�r r� r' r' r( �test_xforwardedfora � z+ProxiedLogFormatterTests.test_xforwardedforc C r )z� Any extra spaces around the address in the I{X-Forwarded-For} header are stripped and not included in the log string. s# 172.16.1.2 , 10.0.0.3, 192.168.1.4Nr r� r' r' r( �test_extraForwardedSpacesh r z2ProxiedLogFormatterTests.test_extraForwardedSpacesN)r* r+ r, r> r� r r r r' r' r' r( r = s r c @ rS )�LogEscapingTestsc C s4 | � � | _t�| j�| _| j�� t| jd�| _d S )NF)r� r� r r� rO r� r� r< r� r' r' r( r� q s zLogEscapingTests.setUpc C sH z| j �| j� W | j �� n| j �� w t| j��� }| �||� dS )aF Assert that if C{self.request} is logged using C{self.site} then C{line} is written to the site's access log file. @param line: The expected line. @type line: L{bytes} @raise self.failureException: If the log file contains something other than the expected line. N)rO r� r< r� r r� r� r# )r% r� �loggedr' r' r( � assertLogsw s zLogEscapingTests.assertLogsc C s dd | j _| �d� dS )zC A I{GET} request is logged with no extra escapes. �#[%02d/%3s/%4d:%02d:%02d:%02d +0000]�� �Octi� � � �; sO "1.2.3.4" - - [25/Oct/2004:12:31:59 +0000] "GET /dummy HTTP/1.0" 123 - "-" "-" N)rO � _logDateTimer r� r' r' r( � test_simple� s �z LogEscapingTests.test_simplec C �" dd | j _d| j_| �d� dS )zT If the HTTP request method includes a quote, the quote is escaped. r r s G"TsP "1.2.3.4" - - [25/Oct/2004:12:31:59 +0000] "G\"T /dummy HTTP/1.0" 123 - "-" "-" N)rO r r< r� r r� r' r' r( �test_methodQuote� � �z!LogEscapingTests.test_methodQuotec C r )zR If the HTTP request path includes a quote, the quote is escaped. r r s /dummy"withquotesZ "1.2.3.4" - - [25/Oct/2004:12:31:59 +0000] "GET /dummy\"withquote HTTP/1.0" 123 - "-" "-" N)rO r r< r� r r� r' r' r( �test_requestQuote� r z"LogEscapingTests.test_requestQuotec C r )zU If the HTTP request version includes a quote, the quote is escaped. r r s HT"P/1.0sP "1.2.3.4" - - [25/Oct/2004:12:31:59 +0000] "GET /dummy HT\"P/1.0" 123 - "-" "-" N)rO r r< r� r r� r' r' r( �test_protoQuote� r z LogEscapingTests.test_protoQuotec C �* dd | j _| jj�dd� | �d� dS )zg If the value of the I{Referer} header contains a quote, the quote is escaped. r r r� s# http://malicious" ".website.invalidss "1.2.3.4" - - [25/Oct/2004:12:31:59 +0000] "GET /dummy HTTP/1.0" 123 - "http://malicious\" \".website.invalid" "-" N�rO r r< r] r� r r� r' r' r( �test_refererQuote� s ��z"LogEscapingTests.test_refererQuotec C r )zj If the value of the I{User-Agent} header contains a quote, the quote is escaped. r r r� s Malicious Web" Evilsb "1.2.3.4" - - [25/Oct/2004:12:31:59 +0000] "GET /dummy HTTP/1.0" 123 - "-" "Malicious Web\" Evil" Nr! r� r' r' r( �test_userAgentQuote� s �z$LogEscapingTests.test_userAgentQuoteN) r* r+ r, r� r r r r r r" r# r' r' r' r( r p s r c @ r} )�ServerAttributesTestszw Tests that deprecated twisted.web.server attributes raise the appropriate deprecation warnings when used. c C �R t j | j| jgd�}| �t|�d� | �|d d t� | �|d d d� dS )z� twisted.web.server.date_time_string should not be used; instead use twisted.web.http.datetimeToString directly ��offendingFunctionsr r �category�messagezztwisted.web.server.date_time_string was deprecated in Twisted 12.1.0: Please use twisted.web.http.datetimeToString insteadN)r �date_time_string� flushWarnings�&test_deprecatedAttributeDateTimeStringr# r �DeprecationWarning�r% �warningsr' r' r( r, � � �z<ServerAttributesTests.test_deprecatedAttributeDateTimeStringc C r% )z� twisted.web.server.string_date_time should not be used; instead use twisted.web.http.stringToDatetime directly r& r r r( r) zztwisted.web.server.string_date_time was deprecated in Twisted 12.1.0: Please use twisted.web.http.stringToDatetime insteadN)r �string_date_timer+ �&test_deprecatedAttributeStringDateTimer# r r- r. r' r' r( r2 r0 z<ServerAttributesTests.test_deprecatedAttributeStringDateTimeN)r* r+ r, r> r, r2 r' r' r' r( r$ � s r$ c @ r} )�ExplicitHTTPFactoryReactorzA L{http.HTTPFactory} accepts explicit reactor selection. c C s" d}t j|d�}| �|j|� dS )z~ L{http.HTTPFactory.__init__} accepts a reactor argument which is set on L{http.HTTPFactory.reactor}. zI am a reactor!r� N)r r� rX r� �r% r� ra r' r' r( r� . s z/ExplicitHTTPFactoryReactor.test_explicitReactorc C s& ddl m} t�� }| �|j|� dS )z} Giving no reactor argument to L{http.HTTPFactory.__init__} means it will select the global reactor. r r� N)�twisted.internetr� r r� rX r4 r' r' r( r� 7 s z.ExplicitHTTPFactoryReactor.test_defaultReactorN)r* r+ r, r> r� r� r' r' r' r( r3 ) s r3 c s8 e Zd ZdZdZd � fdd� Zdedefdd �Z� Z S ) � QueueResourcez� Add all requests to an internal queue, without responding to the requests. You can access the requests from the queue and handle their response. Tr� Nc s t � �� g | _d S r" )�superr. �dispatchedRequestsr� �� __class__r' r( r. K s zQueueResource.__init__r< c C s | j �|� tS r" )r8 rK r r; r' r' r( r� O rI zQueueResource.render_GET�r� N) r* r+ r, r> r� r. r r� r� � __classcell__r' r' r9 r( r6 B s r6 c @ s$ e Zd ZdZddd�Zddd�ZdS ) �TestRFC9112Section932z= Verify that HTTP/1.1 request ordering is preserved. r� Nc C sh t � }t|�}|�d�}t� }|�|� |�d� | �t|j�d� |jd � � | �t|j�d� dS )zq Twisted MUST NOT respond to a second HTTP/1.1 request while the first is still pending. N�A GET /first HTTP/1.1 Host: a GET /second HTTP/1.1 Host: a r r rp ) r6 r r` r r� r� r# r r8 �finish)r% �qrrO �proto�serverTransportr' r' r( �!test_multipleRequestsInOneSegmentY s �z7TestRFC9112Section932.test_multipleRequestsInOneSegmentc C sz t � }t|�}|�d�}t� }|�|� d}t|�D ]}|�|� q| �t|j �d� |j d � � | �t|j �d� dS )z� Twisted MUST NOT respond to a second HTTP/1.1 request while the first is still pending, even if the second request is received in a separate TCP package. Nr> r r rp ) r6 r r` r r� r r� r# r r8 r? )r% r@ rO rA rB �raw_data�chunkr' r' r( �(test_multipleRequestsInDifferentSegmentsp s � z>TestRFC9112Section932.test_multipleRequestsInDifferentSegmentsr; )r* r+ r, r> rC rF r' r' r' r( r= T s r= )Tr> rq rl �ior �typingr �zope.interfacer �zope.interface.verifyr r5 r �twisted.internet.addressr r �twisted.internet.taskr �twisted.loggerr r �twisted.pythonr r �twisted.python.compatr �twisted.python.filepathr �twisted.test.proto_helpersr r � twisted.trialr � twisted.webr r r r r �twisted.web.resourcer �twisted.web.serverr r r �twisted.web.staticr � twisted.web.test.requesthelperr r �_utilr �TestCaser! r- r@ rF rJ r r� r� r� r� r� rT r~ r� r� � IResourcer� r� r� r� r� r� r� r� r� r r r$ r3 r6 r= r' r' r' r( �<module> st yv Wy :$wMN M3 /