U W[1@sdZeZddlmZddlZddlZddlZddlm Z ddl m Z m Z m Z ddlmZddlmZddlmZdd lmZmZdd lmZdd lmZdd lmZmZdd lmZddl m!Z!m"Z"ddl#m$Z$m%Z%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,m-Z-ddl.m/Z/ddl0m1Z1m2Z2GdddZ3GdddZ4GdddeZ5GdddZ6Gddde6eZ7Gdd d e6Z8Gd!d"d"e8eZ9Gd#d$d$e8eZ:Gd%d&d&e8eZ;Gd'd(d(e8eZdS)-z Tests for L{twisted.web.wsgi}. )exc_infoN) verifyObject) intToBytesurlquote_PY3)Failure) getThreadID) ThreadPool)Deferred gatherResults)reactor)ConnectionLost)TestCaseSkipTest)http) IResourceResource)RequestSiteversion) WSGIResource) DummyChannel)globalLogPublisherLogger)EventLoggingObserver) IPv4Address IPv6Addressc@seZdZdZeZddZdS)SynchronousThreadPoola A single-threaded implementation of part of the L{ThreadPool} interface. This implementation calls functions synchronously rather than running them in a thread pool. It is used to make the tests which are not directly for thread-related behavior deterministic. cOs,z|||Wn|jdYnXdS)zp Call C{f(*a, **kw)} in this thread rather than scheduling it to be called in a thread. zsr+c@s,eZdZddZddZddZddZd S) WSGIResourceTestscCstttdd|_dS)z Create a L{WSGIResource} with synchronous threading objects and a no-op application object. This is useful for testing certain things about the resource implementation which are unrelated to WSGI. cSsdSNr$environ startResponser$r$r%Yz)WSGIResourceTests.setUp..N)rr+rresourcer r$r$r%setUpQs zWSGIResourceTests.setUpcCstt|j||jjdS)zW L{WSGIResource} implements L{IResource} and stops resource traversal. N)rrr5 assertTrueZisLeafr6r$r$r%test_interfaces\s z!WSGIResourceTests.test_interfacescCs6|t|jjdttd|t|jjdtdS)z A L{WSGIResource} cannot have L{IResource} children. Its C{getChildWithDefault} and C{putChild} methods raise L{RuntimeError}. fooFN) assertRaises RuntimeErrorr5ZgetChildWithDefaultrrputChildrr6r$r$r%test_unsupportedds z"WSGIResourceTests.test_unsupportedcst|t}GdddtGdddt}fdd}Gfddd}t|t||_|j|t d | d t ||d d }| |j |d S)z If an exception is thrown by the application, and then in the exception handling code, verify it should be propagated to the provided L{ThreadPool}. c@seZdZdZdS)zIWSGIResourceTests.test_applicationAndRequestThrow..ArbitraryErrorz; An arbitrary error for this class N)r'r(r)r*r$r$r$r%ArbitraryError~sr?c@s(eZdZdZddZddZddZdS) zPWSGIResourceTests.test_applicationAndRequestThrow..FinishThrowingRequestzL An L{IRequest} request whose finish method throws. c_s(tj|f||d|_d|_d|_dS)Nswww.example.com/stuff)r__init__ZprepathZpostpathuri)r argskwargsr$r$r%rAszYWSGIResourceTests.test_applicationAndRequestThrow..FinishThrowingRequest.__init__cSsdS)zi Return loopback address. @return: loopback ip address. 127.0.0.1r$r6r$r$r% getClientIPsz\WSGIResourceTests.test_applicationAndRequestThrow..FinishThrowingRequest.getClientIPcSs tdddS)z` Return a fake Address @return: A fake address TCPrEi0u)rr6r$r$r%getHostszXWSGIResourceTests.test_applicationAndRequestThrow..FinishThrowingRequest.getHostN)r'r(r)r*rArFrHr$r$r$r%FinishThrowingRequests rIcs dS)z An application object that throws an exception. @param environ: unused @param startResponse: unused Nr$r0r?r$r% applicationszFWSGIResourceTests.test_applicationAndRequestThrow..applicationcseZdZdZfddZdS)zQWSGIResourceTests.test_applicationAndRequestThrow..ThrowingReactorThreadszt An L{IReactorThreads} implementation whose callFromThread raises an exception. cs dS)z Raise an exception to the caller. @param f: unused @param a: unused @param kw: unused Nr$rrJr$r%r,s z`WSGIResourceTests.test_applicationAndRequestThrow..ThrowingReactorThreads.callFromThreadNr-r$rJr$r%ThrowingReactorThreadssrLFr log_failureN)rcreateWithCleanupr Exceptionrrrr5renderr assertEqualslenassertIsInstancevalueflushLoggedErrors)r logObserverrIrKrLr!r$rJr%test_applicationAndRequestThrowss$  z1WSGIResourceTests.test_applicationAndRequestThrowN)r'r(r)r7r9r>rXr$r$r$r%r.Ps r.c@sTeZdZdZeZddZdgddfddZdd Ze fd d Z d d Z dddZ dS)WSGITestsMixinz @ivar channelFactory: A no-argument callable which will be invoked to create a new HTTP channel to associate with request objects. cCst|_t|_dSr/)r threadpoolr+r r6r$r$r%r7szWSGITestsMixin.setUpNr@c sdd} t|j|j|} ||D]}t}|| || |} q&|}t| |_||d}| D]\}}|j | || |qd| d| r|j | |j dddfdd|D}|dk r|d d fd d|D7}|| || |d | ||S) a @param method: A C{str} giving the request method to use. @param version: A C{str} like C{'1.1'} giving the request version. @param resourceSegments: A C{list} of unencoded path segments which specifies the location in the resource hierarchy at which the L{WSGIResource} will be placed, eg C{['']} for I{/}, C{['foo', 'bar', '']} for I{/foo/bar/}, etc. @param requestSegments: A C{list} of unencoded path segments giving the request URI. @param query: A C{list} of two-tuples of C{str} giving unencoded query argument keys and values. @param headers: A C{list} of two-tuples of C{str} giving request header names and corresponding values. @param safe: A C{str} giving the bytes which are to be considered I{safe} for inclusion in the request URI and not quoted. @return: A L{Deferred} which will be called back with a two-tuple of the arguments passed which would be passed to the WSGI application object for this configuration and request (ie, the environment and start_response callable). cSst|tr|S|dSdS)Nz iso-8859-1) isinstancebytesencode)stringr$r$r% _toByteStrings z4WSGITestsMixin.lowLevelRender.._toByteStringFr/csg|]}t|qSr$)r).0segsafer$r% sz1WSGITestsMixin.lowLevelRender..N?&cs*g|]"\}}dt|t|gqS)=)joinr)rakvrcr$r%ressHTTP/)rr rZreverserr=rsiterequestHeaders addRawHeader gotLengthcontentwriteseekrirequestReceived)r requestFactoryapplicationFactorychannelFactorymethodrZresourceSegmentsZrequestSegmentsZqueryheadersZbodyrdr_rootrbZtmpchannelrequestrjrkrBr$rcr%lowLevelRendersD         zWSGITestsMixin.lowLevelRendercs:tfdd}|d|j}|jt||f||S)Ncsfdd}|S)Ncs$|\}}||dgtdSN200 OKr$callbackiterrCr1r2resultr$r%rKs  zFWSGITestsMixin.render..applicationFactory..applicationr$rKrr$r%rvs z1WSGITestsMixin.render..applicationFactoryrw)r poprwr}r)r r"r#rvrwr$rr%rQs zWSGITestsMixin.rendercstfdd}|fS)Ncs||}||Sr/)Z notifyFinishZ chainDeferred)r"r#r|d requestClassr$r%ru+s z.requestFactoryr )r rrur$rr%requestFactoryFactory)sz$WSGITestsMixin.requestFactoryFactorycCs|dddS)N rM)split)r responser$r$r%getContentFromResponse6sz%WSGITestsMixin.getContentFromResponsecsvtfdd}t|j|j|}t}|d||}t||_Gdddt }||dd}| d|fS) aj Prepare a L{Request} which, when a request is received, captures the C{environ} and C{start_response} callable passed to a WSGI app. @param application: An optional WSGI application callable that accepts the familiar C{environ} and C{start_response} args and returns an iterable of body content. If not supplied, C{start_response} will be called with a "200 OK" status and no headers, and no content will be yielded. @return: A two-tuple of (C{request}, C{deferred}). The former is a Twisted L{Request}. The latter is a L{Deferred} which will be called back with a two-tuple of the arguments passed to a WSGI application (i.e. the C{environ} and C{start_response} callable), or will errback with any error arising within the WSGI app. cshz*dkr|dgtd}n ||}Wn&|dgtdYSX||f|SdS)Nrr$z 500 Error)rZerrbackr)r1r2rqrKrr$r%outerApplicationMs   z7WSGITestsMixin.prepareRequest..outerApplicationsresc@seZdZdZdddZdS) z4WSGITestsMixin.prepareRequest..CannedRequestz Convenient L{Request} derivative which has canned values for all of C{requestReceived}'s arguments. GET/res1.1cSstj||||dS)N)commandpathr)rrt)r rrrr$r$r%rtjs zDWSGITestsMixin.prepareRequest..CannedRequest.requestReceivedN)rrr)r'r(r)r*rtr$r$r$r% CannedRequestes rF)Zqueuedr) r rr rZrr=rwrrmrrp)r rKrr5rzr{rr|r$rr%prepareRequest:s    zWSGITestsMixin.prepareRequest)N) r'r(r)r*rrwr7r}rQrrrrr$r$r$r%rYs D rYc@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.d/Zd0d1Zd2d3Zd4d5Zd6d7Zd8d9Zd:d;Z dd?Z"d@S)A EnvironTestsz Tests for the values in the C{environ} C{dict} passed to the application object by L{twisted.web.wsgi.WSGIResource}. csfdd}|S)Ncs|\}}|Sr/ assertEqualrr1r2keyr rUr$r%assertEnvironKeyEqual|sz;EnvironTests.environKeyEqual..assertEnvironKeyEqualr$)r rrUrr$rr%environKeyEqual{szEnvironTests.environKeyEqualcs,ddgdg}fdd}|||S)z L{WSGIResource} calls the application object with an C{environ} parameter which is exactly of type C{dict}. GET1.1r@cs2|\}}t|t|D]}|tqdSr/)ZassertIdenticaltypedictrTstr)rr1r2namer6r$r% cbRenderedsz3EnvironTests.test_environIsDict..cbRendered)rQ addCallback)r rrr$r6r%test_environIsDicts  zEnvironTests.test_environIsDictcCsT|ddgdg}||dd|ddgdg}||ddt||gS)z The C{'REQUEST_METHOD'} key of the C{environ} C{dict} passed to the application contains the HTTP method in the request (RFC 3875, section 4.1.12). rrr@REQUEST_METHODZPOSTrQrrr )r getZpostr$r$r%test_requestMethods zEnvironTests.test_requestMethodcCsHdD]>}|\}}||||dd|||tqdS)z The C{'REQUEST_METHOD'} key of the C{environ} C{dict} passed to the application is always a native string. )rrrrNrrtrrrTsuccessResultOfr)r rxr|rr$r$r% test_requestMethodIsNativeStrings   z-EnvironTests.test_requestMethodIsNativeStringcCs|ddgdg}||dd|dddgdg}||dd|dddgdg}||dd|ddddgddg}||dd|dddgdd g}||dd|ddddd gddd g}||dd t||||||gS) z The C{'SCRIPT_NAME'} key of the C{environ} C{dict} passed to the application contains the I{abs_path} (RFC 2396, section 3) to this resource (RFC 3875, section 4.1.13). rrr@ SCRIPT_NAMEr`fooz/fooz/foo/barbar /foo///barÿr)r rz emptyChildleaf containerZinternal unencodedr$r$r%test_scriptNames6 zEnvironTests.test_scriptNamecCs|\}}|jdd||dd|||ttr`|\}}|jt |jddn<|\}}|jdd||dd|||tdS)z The C{'SCRIPT_NAME'} key of the C{environ} C{dict} passed to the application is always a native string. rrrz/resN rrtrrrTrrrr; TypeErrorr r|rr$r$r%test_scriptNameIsNativeStrings     z*EnvironTests.test_scriptNameIsNativeStringc Cs|dd}|ddgdg}||dd|dddgdg}|||dddgdg}|||ddddgddg}|||dddgddg}||dd|dddgddg}||dd|ddgddd g}||dd t||||||gS) z The C{'PATH_INFO'} key of the C{environ} C{dict} passed to the application contains the suffix of the request URI path which is not included in the value for the C{'SCRIPT_NAME'} key (RFC 3875, section 4.1.5). PATH_INFOr@rrr`rrz/barrr)rrQrr ) r ZassertKeyEmptyrzrrrZ internalLeafZinternalContainerrr$r$r% test_pathInfos2     zEnvironTests.test_pathInfocCs|\}}|jdd||dd|||ttr`|\}}|jt |jddn<|\}}|jdd||dd|||tdS)z The C{'PATH_INFO'} key of the C{environ} C{dict} passed to the application is always a native string. s /res/foo/barrrz/foo/barz /res/foo/barNrrr$r$r%test_pathInfoIsNativeString s     z(EnvironTests.test_pathInfoIsNativeStringcCs|ddgdgd}||dd|ddgdgg}||dd|ddgdgdg}||dd|ddgdgdg}||dd |jddgdgd gd d }||dd t|||||gS)z The C{'QUERY_STRING'} key of the C{environ} C{dict} passed to the application contains the portion of the request URI after the first I{?} (RFC 3875, section 4.1.7). rrr@N QUERY_STRINGrrfoo=bar)r`r`z%2F=%2F)rz?barrfrczfoo=?barr)r missingemptypresentrZdoubleQuestionr$r$r%test_queryString!s4 zEnvironTests.test_queryStringcCs|\}}|jdd||dd|||ttr`|\}}|jt |jddn<|\}}|jdd||dd|||tdS)z The C{'QUERY_STRING'} key of the C{environ} C{dict} passed to the application is always a native string. s /res?foo=barrrrz /res?foo=barNrrr$r$r%test_queryStringIsNativeString?s     z+EnvironTests.test_queryStringIsNativeStringcCsZ|ddgdg}||dd|ddgdgddg}||ddt||gS)z The C{'CONTENT_TYPE'} key of the C{environ} C{dict} passed to the application contains the value of the I{Content-Type} request header (RFC 3875, section 4.1.3). rrr@ CONTENT_TYPEN) content-type x-foo/barrrr rrr$r$r%test_contentTypeVszEnvironTests.test_contentTypecCsTdD]J}|\}}|jd||||dd|||tqdS)z The C{'CONTENT_TYPE'} key of the C{environ} C{dict} passed to the application is always a native string. )s x-foo/barrs Content-TyperrN rrnrortrrrTrr)r contentTyper|rr$r$r%test_contentTypeIsNativeStringfs  z+EnvironTests.test_contentTypeIsNativeStringcCsZ|ddgdg}||dd|ddgdgddg}||ddt||gS)z The C{'CONTENT_LENGTH'} key of the C{environ} C{dict} passed to the application contains the value of the I{Content-Length} request header (RFC 3875, section 4.1.2). rrr@CONTENT_LENGTHN)content-length1234rrrr$r$r%test_contentLengthsszEnvironTests.test_contentLengthcCsTdD]J}|\}}|jd||||dd|||tqdS)z The C{'CONTENT_LENGTH'} key of the C{environ} C{dict} passed to the application is always a native string. )s1234rsContent-LengthrrNr)r Z contentLengthr|rr$r$r% test_contentLengthIsNativeStrings  z-EnvironTests.test_contentLengthIsNativeStringcCsZ|ddgdg}||dd|ddgdgddg}||ddt||gS) a_ The C{'SERVER_NAME'} key of the C{environ} C{dict} passed to the application contains the best determination of the server hostname possible, using either the value of the I{Host} header in the request or the address the server is listening on if that header is not present (RFC 3875, section 4.1.14). rrr@ SERVER_NAMEz10.0.0.1N)Zhost example.orgrrrr$r$r%test_serverNameszEnvironTests.test_serverNamecsTdD]J|\}}fdd|_|||dd|||tqdS)z The C{'SERVER_NAME'} key of the C{environ} C{dict} passed to the application is always a native string. )shost.example.comhost.example.comcsSr/r$r$Z serverNamer$r%r3r4z.rrN)rZgetRequestHostnamertrrrTrrrr$rr%test_serverNameIsNativeStrings  z*EnvironTests.test_serverNameIsNativeStringcsBdfdd}||_|ddgdg}||dt|S)z The C{'SERVER_PORT'} key of the C{environ} C{dict} passed to the application contains the port number of the server which received the request (RFC 3875, section 4.1.15). iB0cst}t|_|j_|Sr/)rrG transportZportr{Z portNumberr$r% makeChannels z1EnvironTests.test_serverPort..makeChannelrrr@ SERVER_PORT)rwrQrrr)r rrr$rr%test_serverPorts  zEnvironTests.test_serverPortcCs<|\}}|||dd|||tdS)z The C{'SERVER_PORT'} key of the C{environ} C{dict} passed to the application is always a native string. rZ80Nrrr$r$r%test_serverPortIsNativeStrings z*EnvironTests.test_serverPortIsNativeStringcCsT|ddgdg}||dd|ddgdg}||ddt||gS)z The C{'SERVER_PROTOCOL'} key of the C{environ} C{dict} passed to the application contains the HTTP version number received in the request (RFC 3875, section 4.1.16). rz1.0r@SERVER_PROTOCOLzHTTP/1.0rzHTTP/1.1r)r oldnewr$r$r%test_serverProtocols z EnvironTests.test_serverProtocolcCsTdD]J}|\}}dd|_|jdd||dd|||tqdS) z The C{'SERVER_PROTOCOL'} key of the C{environ} C{dict} passed to the application is always a native string. )rrcSsdSr/r$)datar$r$r%r3r4z@EnvironTests.test_serverProtocolIsNativeString..r)rrrN)rrrrtrrrTrr)r ZserverProtocolr|rr$r$r%!test_serverProtocolIsNativeStrings    z.EnvironTests.test_serverProtocolIsNativeStringcCs(|ddgdg}||dd|S)z The C{'REMOTE_ADDR'} key of the C{environ} C{dict} passed to the application contains the address of the client making the request. rrr@ REMOTE_ADDRz 192.168.1.1rQrrr rr$r$r%test_remoteAddrszEnvironTests.test_remoteAddrcCs4dd}|jddgdg|d}||dd|S) z The C{'REMOTE_ADDR'} key of the C{environ} C{dict} passed to the application contains the address of the client making the request when connecting over IPv6. cSsttddddS)NrG::1i)Zpeer)rrr$r$r$r%rwsz8EnvironTests.test_remoteAddrIPv6..channelFactoryrrr@)rwrrr)r rwrr$r$r%test_remoteAddrIPv6sz EnvironTests.test_remoteAddrIPv6c sddgdgdddg}fdd}||ddgdgddd g}|d d ddgdgdd g}|d dddgdgddg}|d dt||||gS)z HTTP request headers are copied into the C{environ} C{dict} passed to the application with a C{HTTP_} prefix added to their names. rrr@Nrbazquuxcs,|\}}|dd|dddS)NHTTP_FOOrZHTTP_BAZrrrr6r$r%rsz-EnvironTests.test_headers..cbRendered)rrrzbar,baz)zfoo-barrZ HTTP_FOO_BARr)rzbar bazzbar bazr)r Z singleValuerZ multiValueZ withHyphenZ multiLiner$r6r% test_headers sL  zEnvironTests.test_headerscCs(|ddgdg}||dd|S)z The C{'wsgi.version'} key of the C{environ} C{dict} passed to the application has the value C{(1, 0)} indicating that this is a WSGI 1.0 container. rrr@z wsgi.version)rMrr)r ZversionDeferredr$r$r%test_wsgiVersion&szEnvironTests.test_wsgiVersioncCs(|ddgdg}||dd|S)z| The C{'wsgi.run_once'} key of the C{environ} C{dict} passed to the application is set to C{False}. rrr@z wsgi.run_onceFr)r oncer$r$r%test_wsgiRunOnce1szEnvironTests.test_wsgiRunOncecCs(|ddgdg}||dd|S)z~ The C{'wsgi.multithread'} key of the C{environ} C{dict} passed to the application is set to C{True}. rrr@zwsgi.multithreadTr)r threadr$r$r%test_wsgiMultithread;sz!EnvironTests.test_wsgiMultithreadcCs(|ddgdg}||dd|S)z The C{'wsgi.multiprocess'} key of the C{environ} C{dict} passed to the application is set to C{False}. rrr@zwsgi.multiprocessFr)r Zprocessr$r$r%test_wsgiMultiprocessEsz"EnvironTests.test_wsgiMultiprocesscCshdd}t|_|ddgdg}||dd||_|ddgdg}||ddt||gS) z The C{'wsgi.url_scheme'} key of the C{environ} C{dict} passed to the application has the request URL scheme. cSst}t|_|Sr/)rZSSLrrr$r$r%rwVs z7EnvironTests.test_wsgiURLScheme..channelFactoryrrr@zwsgi.url_schemerZhttps)rrwrQrrr )r rwZ httpDeferredZ httpsDeferredr$r$r%test_wsgiURLSchemeOszEnvironTests.test_wsgiURLSchemecs:ttddgdg}fdd}|||S)a` The C{'wsgi.errors'} key of the C{environ} C{dict} passed to the application is a file-like object (as defined in the U{Input and Errors Streams} section of PEP 333) which converts bytes written to it into events for the logging system. rrr@cs|\}}|d}|d|dg|dddddddd d dd d ddd d td dS) N wsgi.errors some message another message rmessage)rsystemZwsgiZisErrorrM)r)rr writelinesflushrr8rS)rr1ZstartApplicationerrorsZeventsr r$r%cbErrorsts  z.EnvironTests.test_wsgiErrors..cbErrors)rrOrrQr)r rrr$rr%test_wsgiErrorsfs zEnvironTests.test_wsgiErrorsc Cstr td|\}}|||\}}|d}tjdd}|dW5QRX|dt ||t |dj |dt |dj d S) a- The C{'wsgi.errors'} file-like object from the C{environ} C{dict} expects writes of only native strings in Python 2. Some existing WSGI applications may write non-native (i.e. C{unicode}) strings so, for compatibility, these elicit only a warning in Python 2. zNot relevant in Python 3rTrecordZfredrMrz5write() argument should be str, not u'fred' (unicode)N)rrrrtrwarningscatch_warningsrrrrSUnicodeWarningcategoryrr)r r|rr1_rcaughtr$r$r%0test_wsgiErrorsExpectsOnlyNativeStringsInPython2s  z=EnvironTests.test_wsgiErrorsExpectsOnlyNativeStringsInPython2cCsZts td|\}}|||\}}|d}|t|jd}|dt |dS)z The C{'wsgi.errors'} file-like object from the C{environ} C{dict} permits writes of only native strings in Python 3, and raises C{TypeError} for writes of non-native strings. zRelevant only in Python 3rsfredz1write() argument must be str, not b'fred' (bytes)N) rrrrtrr;rrrrr)r r|rr1rrerrorr$r$r%0test_wsgiErrorsAcceptsOnlyNativeStringsInPython3s z=EnvironTests.test_wsgiErrorsAcceptsOnlyNativeStringsInPython3N)#r'r(r)r*rrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrr$r$r$r%rvs@  $        rc@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.S)/InputStreamTestMixinz A mixin for L{TestCase} subclasses which defines a number of tests against L{_InputStream}. The subclass is expected to create a file-like object to be wrapped by an L{_InputStream} under test. cCstd|jjfdS)Nz%s.getFile must be implemented)NotImplementedError __class__r'r6r$r$r% getFileTypes z InputStreamTestMixin.getFileTypec sR|Gfdddt}dd}||\}}|||tddgdgdg| |S)NcseZdZfddZdS)zLInputStreamTestMixin._renderAndReturnReaderResult..CustomizedRequestcs |_dSr/)rq)r Zlengthrr$r%rpszVInputStreamTestMixin._renderAndReturnReaderResult..CustomizedRequest.gotLengthN)r'r(r)rpr$rr$r%CustomizedRequestsrcstfdd}|fS)Ncsfdd}|S)Ncs,|\}}|d|dgtdS)Nz wsgi.inputrr$rrreaderrr$r%rKs z}InputStreamTestMixin._renderAndReturnReaderResult..appFactoryFactory..applicationFactory..applicationr$rrr$r%rvszhInputStreamTestMixin._renderAndReturnReaderResult..appFactoryFactory..applicationFactoryr)rrvr$rr%appFactoryFactoryszLInputStreamTestMixin._renderAndReturnReaderResult..appFactoryFactoryZPUTrr@)rrr}r)r rrqrrrZ appFactoryr$rr%_renderAndReturnReaderResults" z1InputStreamTestMixin._renderAndReturnReaderResultcCs&d}|dd|}||j||S)zi Calling L{_InputStream.read} with no arguments returns the entire input stream. some bytes are herecSs|Sr/readinputr$r$r%r3r4z3InputStreamTestMixin.test_readAll..rrrr r\rr$r$r% test_readAllsz!InputStreamTestMixin.test_readAllcCs&d}|dd|}||jd|S)z Calling L{_InputStream.read} with an integer returns that many bytes from the input stream, as long as it is less than or equal to the total number of bytes available. s hello, world.cSs |dSNr r"r$r$r%r3r4z4InputStreamTestMixin.test_readSome..shelr$r%r$r$r% test_readSomesz"InputStreamTestMixin.test_readSomecs*d|fdd}||j|S)z Calling L{_InputStream.read} with an integer that is greater than the total number of bytes in the input stream returns all bytes in the input stream. rcs|tdSr')r!rSr"r\r$r%r3r4z8InputStreamTestMixin.test_readMoreThan..r$rr$r*r%test_readMoreThans z&InputStreamTestMixin.test_readMoreThancCs2d}dd}|||}||j|dd|S)z Calling L{_InputStream.read} a second time returns bytes starting from the position after the last byte returned by the previous read. ssome bytes, hellocSs|d|Sr'r r"r$r$r%r!s z1InputStreamTestMixin.test_readTwice..readr(Nr$)r r\r!rr$r$r%test_readTwices  z#InputStreamTestMixin.test_readTwicecCs&d}|dd|}||j||S)zy Calling L{_InputStream.read} with L{None} as an argument returns all bytes in the input stream. sthe entire streamcSs |dSr/r r"r$r$r%r3r4z4InputStreamTestMixin.test_readNone..r$r%r$r$r% test_readNone sz"InputStreamTestMixin.test_readNonecCs&d}|dd|}||j||S)z Calling L{_InputStream.read} with a negative integer as an argument returns all bytes in the input stream. sall of the inputcSs |dSNr r"r$r$r%r3r4z8InputStreamTestMixin.test_readNegative..r$r%r$r$r%test_readNegativesz&InputStreamTestMixin.test_readNegativecCs&d}|dd|}||jd|S)zs Calling L{_InputStream.readline} with no argument returns one line from the input stream. s hello worldcSs|Sr/readliner"r$r$r%r3)r4z4InputStreamTestMixin.test_readline..shello r$r%r$r$r% test_readline"sz"InputStreamTestMixin.test_readlinecCs&d}|dd|}||jd|S)a Calling L{_InputStream.readline} with an integer returns at most that many bytes, even if it is not enough to make up a complete line. COMPATIBILITY NOTE: the size argument is excluded from the WSGI specification, but is provided here anyhow, because useful libraries such as python stdlib's cgi.py assume their input file-like-object supports readline with a size argument. If you use it, be aware your application may not be portable to other conformant WSGI servers. s goodbye worldcSs |dSr'r1r"r$r$r%r3;r4z8InputStreamTestMixin.test_readlineSome..sgoor$r%r$r$r%test_readlineSome.s z&InputStreamTestMixin.test_readlineSomecCs&d}|dd|}||jd|S)z Calling L{_InputStream.readline} with an integer which is greater than the number of bytes in the next line returns only the next line. ssome lines of textcSs |dS)Nr1r"r$r$r%r3Gr4z.s some lines r$r%r$r$r%test_readlineMoreThan@sz*InputStreamTestMixin.test_readlineMoreThancCs*d}dd}|||}||jd|S)z Calling L{_InputStream.readline} a second time returns the line following the line returned by the first call. s first line second line last linecSs||Sr/r1r"r$r$r%r2Rsz9InputStreamTestMixin.test_readlineTwice..readlines second line r$)r r\r2rr$r$r%test_readlineTwiceLs  z'InputStreamTestMixin.test_readlineTwicecCs&d}|dd|}||jd|S)z~ Calling L{_InputStream.readline} with L{None} as an argument returns one line from the input stream. s%this is one line this is another linecSs |dSr/r1r"r$r$r%r3ar4z8InputStreamTestMixin.test_readlineNone..sthis is one line r$r%r$r$r%test_readlineNoneZsz&InputStreamTestMixin.test_readlineNonecCs&d}|dd|}||jd|S)z Calling L{_InputStream.readline} with a negative integer as an argument returns one line from the input stream. sinput stream line one line twocSs |dSr.r1r"r$r$r%r3mr4z.sinput stream line one r$r%r$r$r%test_readlineNegativefsz*InputStreamTestMixin.test_readlineNegativecCs,d}|dd|}||jdddg|S)z Calling L{_InputStream.readlines} with no arguments returns a list of all lines from the input stream. salice bob carolcSs|Sr/ readlinesr"r$r$r%r3yr4z5InputStreamTestMixin.test_readlines..salice sbob scarolr$r%r$r$r%test_readlinesrsz#InputStreamTestMixin.test_readlinescs.d}dd|}fdd}|||S)z Calling L{_InputStream.readlines} with an integer as an argument returns a list of lines from the input stream with the argument serving as an approximate bound on the total number of bytes to read. s 123 456 789 0cSs |dS)Nr:r"r$r$r%r3r4z9InputStreamTestMixin.test_readlinesSome..cs|ddddgdS)Nrs123 s456 r)linesr6r$r%cbLinessz8InputStreamTestMixin.test_readlinesSome..cbLines)rr)r r\rr?r$r6r%test_readlinesSome~s  z'InputStreamTestMixin.test_readlinesSomecCs,d}|dd|}||jdddg|S)z Calling L{_InputStream.readlines} with an integer which is greater than the total number of bytes in the input stream returns a list of all lines from the input. s"one potato two potato three potatocSs |dS)Ndr:r"r$r$r%r3r4z=InputStreamTestMixin.test_readlinesMoreThan..s one potato s two potato s three potator$r%r$r$r%test_readlinesMoreThansz+InputStreamTestMixin.test_readlinesMoreThancCs.d}dd}|||}||jddg|S)z Calling L{_InputStream.readlines} after a call to L{_InputStream.read} returns lines starting at the byte after the last byte returned by the C{read} call. shello world foocSs|d|S)N)r!r;r"r$r$r%r;s z?InputStreamTestMixin.test_readlinesAfterRead..readlinessorld r:r$)r r\r;rr$r$r%test_readlinesAfterReads  z,InputStreamTestMixin.test_readlinesAfterReadcCs*d}|dd|}||jddg|S)zy Calling L{_InputStream.readlines} with L{None} as an argument returns all lines from the input. sone fish two fish cSs |dSr/r:r"r$r$r%r3r4z9InputStreamTestMixin.test_readlinesNone..s one fish s two fish r$r%r$r$r%test_readlinesNonesz'InputStreamTestMixin.test_readlinesNonecCs*d}|dd|}||jddg|S)z Calling L{_InputStream.readlines} with a negative integer as an argument returns a list of all lines from the input. sred fish blue fish cSs |dSr.r:r"r$r$r%r3r4z=InputStreamTestMixin.test_readlinesNegative..s red fish s blue fish r$r%r$r$r%test_readlinesNegativesz+InputStreamTestMixin.test_readlinesNegativecCs*d}|dd|}||jddg|S)zV Iterating over L{_InputStream} produces lines from the input stream. green eggs and ham cSst|Sr/)listr"r$r$r%r3r4z4InputStreamTestMixin.test_iterable..s green eggs and ham r$r%r$r$r% test_iterablesz"InputStreamTestMixin.test_iterablecCs.d}dd}|||}||jddg|S)z Iterating over L{_InputStream} after calling L{_InputStream.read} produces lines from the input stream starting from the first byte after the last byte returned by the C{read} call. rGcSs|dt|Sr')r!rHr"r$r$r%iterates z.iteratesen eggs rIr$)r r\rKrr$r$r%test_iterableAfterReads  z+InputStreamTestMixin.test_iterableAfterReadN)r'r(r)r*rrr&r)r+r,r-r0r3r4r6r7r8r9r<r@rBrDrErFrJrLr$r$r$r%rs.             rc@seZdZdZddZdS)InputStreamStringIOTestsz Tests for L{_InputStream} when it is wrapped around a L{StringIO.StringIO}. This is only available in Python 2. cCs6zddlm}Wntk r,tdYnX|SdS)NrStringIOz#StringIO.StringIO is not available.)rO ImportErrorrr rOr$r$r%rs z$InputStreamStringIOTests.getFileTypeNr'r(r)r*rr$r$r$r%rMsrMc@seZdZdZddZdS)InputStreamCStringIOTestsz Tests for L{_InputStream} when it is wrapped around a L{cStringIO.StringIO}. This is only available in Python 2. cCs6zddlm}Wntk r,tdYnX|SdS)NrrNz$cStringIO.StringIO is not available.) cStringIOrOrPrrQr$r$r%rs z%InputStreamCStringIOTests.getFileTypeNrRr$r$r$r%rSsrSc@seZdZdZddZdS)InputStreamBytesIOTestszO Tests for L{_InputStream} when it is wrapped around an L{io.BytesIO}. cCsddlm}|S)Nr)BytesIO)iorV)r rVr$r$r%rs z#InputStreamBytesIOTests.getFileTypeNrRr$r$r$r%rUsrUc@seZdZdZddZdS)InputStreamTemporaryFileTestszZ Tests for L{_InputStream} when it is wrapped around a L{tempfile.TemporaryFile}. cCstjSr/)tempfileZ TemporaryFiler6r$r$r%rsz)InputStreamTemporaryFileTests.getFileTypeNrRr$r$r$r%rX srXc@seZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,S)-StartResponseTestszl Tests for the I{start_response} parameter passed to the application object by L{WSGIResource}. c sZtdd}\}}fdd}||||fddddgd gd g |S) z The response status passed to the I{start_response} callable is written as the status of the response to the request. cSs dd}|S)NcSs|dgtdS)Nz107 Strange messager$rr0r$r$r%rK!s zOStartResponseTests.test_status..applicationFactory..applicationr$rr$r$r%rv sz:StartResponseTests.test_status..applicationFactorycsjjddS)NsHTTP/1.1 107 Strange messager8rwrittengetvalue startswithignoredr{r r$r%r's  z2StartResponseTests.test_status..cbRenderedcsSr/r$r$rr$r%r3/r4z0StartResponseTests.test_status..rrr@Nrrrr}r rvrrurr$rbr% test_statuss"   zStartResponseTests.test_statuscsLtrdndfdd}|\}}|fdd}|t|S)z The response status passed to the I{start_response} callable MUST be a native string in Python 2 and Python 3. s200 OKrcs|gtdS)Nr$r[r0)statusr$r%rK;s zEStartResponseTests.test_statusMustBeNativeString..applicationcs*trdt|ndt|dS)Nz)status must be str, not b'200 OK' (bytes)z+status must be str, not u'200 OK' (unicode)rrrrr6r$r% checkMessageBszFStartResponseTests.test_statusMustBeNativeString..checkMessagerrrt assertFailurerrr rKr|rrir$)r rfr%test_statusMustBeNativeString4s    z0StartResponseTests.test_statusMustBeNativeStringc srtdddtfdd}\}}fdd}||||fddd d gd gd g |S) a Verify that if the response headers given by C{appHeaders} are passed to the I{start_response} callable, then the response header lines given by C{expectedHeaders} plus I{Server} and I{Date} header lines are included in the response. ZdatetimeToStringcSsdS)NZTuesdayr$r$r$r$r%r3Ur4z1StartResponseTests._headersTest..csfdd}|S)Ncs|dtdSr~r[r0 appHeadersr$r%rKZs zPStartResponseTests._headersTest..applicationFactory..applicationr$rrnr$r%rvYs z;StartResponseTests._headersTest..applicationFactorycs`jj}|dd\}}|ddd}|ddtdg}|||dS)NrrMs s Date: TuesdaysServer: sTransfer-Encoding: chunked)rr]r^rsortrr)rarryrestZ headerLinesZallExpectedHeaders)r{expectedHeadersr r$r%r`s z3StartResponseTests._headersTest..cbRenderedcsSr/r$r$rr$r%r3pr4rrr@N)Zpatchrrrrr})r rorrrvrrurr$)ror{rrr r% _headersTestMs$    zStartResponseTests._headersTestcCs|ddgddgS)z The headers passed to the I{start_response} callable are included in the response as are the required I{Date} and I{Server} headers and the necessary connection (hop to hop) header I{Transfer-Encoding}. rrs Baz: quuxsFoo: barrsr6r$r$r%rtszStartResponseTests.test_headerscsFdgfdd}|\}}|fdd}|t|S)zb The headers passed to the I{start_response} callable MUST be a sequence. rrUcs|dttdSr~r[r0)ryr$r%rKszBStartResponseTests.test_headersMustBeSequence..applicationcst|ddS)NzKheaders must be a list, not <(list_?|sequence)iterator .+> [(]\1iterator[)]Z assertRegexrrhr6r$r%riszCStartResponseTests.test_headersMustBeSequence..checkMessagerrtrkrrrlr$)ryr r%test_headersMustBeSequences   z-StartResponseTests.test_headersMustBeSequencec Cs|dd}||\}}tjdd}|||}W5QRX|dt||t|dj|dt |dj dS) a According to PEP-3333, the headers passed to the I{start_response} callable MUST be a plain list: The response_headers argument ... must be a Python list; i.e. type(response_headers) is ListType However, for bug-compatibility, any sequence is accepted. In both Python 2 and Python 3, only a warning is issued when a sequence other than a list is encountered. cSs|ddtdS)Nr))notrHr$r[r0r$r$r%rKs zEStartResponseTests.test_headersShouldBePlainList..applicationTr rMrz8headers should be a list, not (('not', 'list'),) (tuple)N rr r rtrrrSRuntimeWarningrrrr rKr|rrr$r$r%test_headersShouldBePlainLists  z0StartResponseTests.test_headersShouldBePlainListcsDdfdd}|\}}|fdd}|t|S)zb Each header passed to the I{start_response} callable MUST be a sequence. rucs|dtgtdSr~r[r0)headerr$r%rKszFStartResponseTests.test_headersMustEachBeSequence..applicationcst|ddS)Nz[header must be a [(]str, str[)] tuple, not <(tuple_?|sequence)iterator .+> [(]\1iterator[)]rvrhr6r$r%riszGStartResponseTests.test_headersMustEachBeSequence..checkMessagerwrlr$)r~r r%test_headersMustEachBeSequences   z1StartResponseTests.test_headersMustEachBeSequencec Cs|dd}||\}}tjdd}|||}W5QRX|dt||t|dj|dt |dj dS) a According to PEP-3333, each header passed to the I{start_response} callable should be a tuple: The response_headers argument is a list of (header_name, header_value) tuples However, for bug-compatibility, any 2 element sequence is also accepted. In both Python 2 and Python 3, only a warning is issued when a sequence other than a tuple is encountered. cSs|dddggtdS)Nrrytupler$r[r0r$r$r%rKszEStartResponseTests.test_headersShouldEachBeTuple..applicationTr rMrz@header should be a (str, str) tuple, not ['not', 'tuple'] (list)Nrzr|r$r$r%test_headersShouldEachBeTuples  z0StartResponseTests.test_headersShouldEachBeTuplecs<dd}|\}}|fdd}|t|S)z Each header passed to the I{start_response} callable MUST hold a key and a value, and ONLY a key and a value. cSs|ddgtdS)Nr)ZtooZmanyZcooksr$r[r0r$r$r%rKs zMStartResponseTests.test_headersShouldEachHaveKeyAndValue..applicationcsdt|dS)Nz?header must be a (str, str) tuple, not ('too', 'many', 'cooks')rrrhr6r$r%riszNStartResponseTests.test_headersShouldEachHaveKeyAndValue..checkMessagerwrlr$r6r%%test_headersShouldEachHaveKeyAndValues  z8StartResponseTests.test_headersShouldEachHaveKeyAndValuecsNtrdndfdd}|\}}|fdd}|t|S)z Each header key passed to the I{start_response} callable MUST be at native string in Python 2 and Python 3. skeyrcs|ddfgtdS)NrrUr$r[r0)rr$r%rKszHStartResponseTests.test_headerKeyMustBeNativeString..applicationcsdft|dS)Nz2header must be (str, str) tuple, not (%r, 'value')rrhrr r$r%riszIStartResponseTests.test_headerKeyMustBeNativeString..checkMessagerjrlr$rr% test_headerKeyMustBeNativeStrings   z3StartResponseTests.test_headerKeyMustBeNativeStringcsNtrdndfdd}|\}}|fdd}|t|S)z Each header value passed to the I{start_response} callable MUST be at native string in Python 2 and Python 3. svaluerUcs|ddfgtdS)Nrrr$r[r0)rUr$r%rKszJStartResponseTests.test_headerValueMustBeNativeString..applicationcsdft|dS)Nz0header must be (str, str) tuple, not ('key', %r)rrhr rUr$r%riszKStartResponseTests.test_headerValueMustBeNativeString..checkMessagerjrlr$rr%"test_headerValueMustBeNativeString s   z5StartResponseTests.test_headerValueMustBeNativeStringcCs|dgdgS)z If I{Content-Type} is included in the headers passed to the I{start_response} callable, one I{Content-Type} header is included in the response. )rzmonkeys are greatsContent-Type: monkeys are greatrtr6r$r$r%#test_applicationProvidedContentType#sz6StartResponseTests.test_applicationProvidedContentTypecCs|ddddggS)z If either I{Server} or I{Date} is included in the headers passed to the I{start_response} callable, they are disregarded. )Zserverr)ZServerr)dater)ZdATErrtr6r$r$r%%test_applicationProvidedServerAndDate.sz8StartResponseTests.test_applicationProvidedServerAndDatec sptgfddfdd}\}}fdd}||||fddd d gd gd g |S) a Nothing is written in response to a request when the I{start_response} callable is invoked. If the iterator returned by the application object produces only empty strings, the response is written after the last element is produced. csjjdSr/appendrr]r^r$r{intermediateValuesr$r%r Csz:StartResponseTests.test_delayedUntilReturn..recordcsfdd}|S)Nc3s|dddgdVdS)Nrrrr4r$r0r r$r%rKGsz[StartResponseTests.test_delayedUntilReturn..applicationFactory..applicationr$rr r$r%rvFs zFStartResponseTests.test_delayedUntilReturn..applicationFactorycsdgdS)Nr4rr`rr r$r%rNsz>StartResponseTests.test_delayedUntilReturn..cbRenderedcsSr/r$r$rr$r%r3Tr4z.rrr@Nrcrdr$r{rr r r%test_delayedUntilReturn9s&    z*StartResponseTests.test_delayedUntilReturnc sptgfddfdd}\}}fdd}||||fddd d gd gd g |S) a Nothing is written in response to a request when the I{start_response} callable is invoked. Once a non-empty string has been produced by the iterator returned by the application object, the response status and headers are written. csjjdSr/rr$rr$r%r csz;StartResponseTests.test_delayedUntilContent..recordcsfdd}|S)Nc3s(|ddgdVdVdS)Nrrr4r:r$r0r r$r%rKgs  z\StartResponseTests.test_delayedUntilContent..applicationFactory..applicationr$rr r$r%rvfs zGStartResponseTests.test_delayedUntilContent..applicationFactorycs dddS)NrrM) assertFalser8r`rr$r%rpsz?StartResponseTests.test_delayedUntilContent..cbRenderedcsSr/r$r$rr$r%r3wr4z=StartResponseTests.test_delayedUntilContent..rrr@Nrcrdr$rr%test_delayedUntilContentYs&   z+StartResponseTests.test_delayedUntilContentc sptgfddfdd}\}}fdd}||||fddd d gd gd g |S) z Content produced by the iterator returned by the application object is written to the request as it is produced. csjjdSr/rr$rr$r%r sz/StartResponseTests.test_content..recordcsfdd}|S)Nc3s(|ddgdVdVdS)Nrr6r:barr$r0r r$r%rKs  zPStartResponseTests.test_content..applicationFactory..applicationr$rr r$r%rvs z;StartResponseTests.test_content..applicationFactorycs0dddddSNrr:rMsfoobarrrr`rr$r%rs  z3StartResponseTests.test_content..cbRenderedcsSr/r$r$rr$r%r3r4z1StartResponseTests.test_content..rrr@Nrcrdr$rr% test_content|s&   zStartResponseTests.test_contentc sZtdd}\}}fdd}||||fddddgd gd g |S) z If the I{start_response} callable is invoked multiple times before a data for the response body is produced, the values from the last call are used. cSs dd}|S)NcSs|dg|dgtdS)N100 Fooz200 Barr$r[r0r$r$r%rKs  z^StartResponseTests.test_multipleStartResponse..applicationFactory..applicationr$rr$r$r%rvszIStartResponseTests.test_multipleStartResponse..applicationFactorycsjjddS)NsHTTP/1.1 200 Bar r\r`rbr$r%rs  zAStartResponseTests.test_multipleStartResponse..cbRenderedcsSr/r$r$rr$r%r3r4z?StartResponseTests.test_multipleStartResponse..rrr@Nrcrdr$rbr%test_multipleStartResponses"   z-StartResponseTests.test_multipleStartResponsec sZtdd}\}}fdd}||||fddddgd gd g |S) z If the I{start_response} callable is invoked with a third positional argument before the status and headers have been written to the response, the status and headers become the newly supplied values. cSs dd}|S)NcSs|dgttddftdS)Nrrr$)rPrr0r$r$r%rKszcStartResponseTests.test_startResponseWithException..applicationFactory..applicationr$rr$r$r%rvszNStartResponseTests.test_startResponseWithException..applicationFactorycsjjddS)NsHTTP/1.1 100 Foo r\r`rbr$r%rs  zFStartResponseTests.test_startResponseWithException..cbRenderedcsSr/r$r$rr$r%r3r4zDStartResponseTests.test_startResponseWithException..rrr@Nrcrdr$rbr%test_startResponseWithExceptions"   z2StartResponseTests.test_startResponseWithExceptionc stGdddt}z |WntYnXgfdd}\}}fdd}||||fddd d gd gd g |S) z If the I{start_response} callable is invoked with a third positional argument after the status and headers have been written to the response, the supplied I{exc_info} values are re-raised to the application. c@s eZdZdS)zPStartResponseTests.test_startResponseWithExceptionTooLate..SomeExceptionN)r'r(r)r$r$r$r% SomeExceptionsrcsfdd}|S)Nc3s>|dgdVz|dgWntYnXdS)Nrr:z500 ERR)rrr0excInforeraisedr$r%rKs  zjStartResponseTests.test_startResponseWithExceptionTooLate..applicationFactory..applicationr$rrr$r%rvszUStartResponseTests.test_startResponseWithExceptionTooLate..applicationFactorycsjjdddddddddj}d}t|t t krvdndt|ddS)NsHTTP/1.1 200 OK rrMr) r8rr]r^r_rtb_next traceback extract_tbrr\)raZtb1Ztb2r{rrr r$r%rs  zMStartResponseTests.test_startResponseWithExceptionTooLate..cbRenderedcsSr/r$r$rr$r%r3 r4zKStartResponseTests.test_startResponseWithExceptionTooLate..rrr@N)rrPrrrr})r rrvrrurr$rr%&test_startResponseWithExceptionTooLates.     z9StartResponseTests.test_startResponseWithExceptionTooLatec sptgfddfdd}\}}fdd}||||fddd d gd gd g |S) z I{start_response} returns the I{write} callable which can be used to write bytes to the response body without buffering. csjjdSr/rr$rr$r%r sz-StartResponseTests.test_write..recordcsfdd}|S)Ncs0|ddg}|d|dtdS)Nrrr:rr$r[r1r2rrr r$r%rKs  zNStartResponseTests.test_write..applicationFactory..applicationr$rr r$r%rvs z9StartResponseTests.test_write..applicationFactorycs0dddddSrrr`rr$r%r(s  z1StartResponseTests.test_write..cbRenderedcsSr/r$r$rr$r%r33r4z/StartResponseTests.test_write..rrr@Nrcrdr$rr% test_writes&   zStartResponseTests.test_writecs<dd}|\}}|fdd}|t|S)zj The C{write} callable returned from C{start_response} only accepts byte strings. cSs|dg}|dtdS)NrZbogusr$r[rr$r$r%rK=s zHStartResponseTests.test_writeAcceptsOnlyByteStrings..applicationcs*trdt|ndt|dS)Nz0Can only write bytes to a transport, not 'bogus'z1Can only write bytes to a transport, not u'bogus'rgrhr6r$r%riEszIStartResponseTests.test_writeAcceptsOnlyByteStrings..checkMessagerwrlr$r6r% test_writeAcceptsOnlyByteStrings8s  z3StartResponseTests.test_writeAcceptsOnlyByteStringsN)r'r(r)r*rermrsrrxr}rrrrrrrrrrrrrrrr$r$r$r%rZs,'    #%8&rZc@sxeZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZddZdS)ApplicationTestszd Tests for things which are done to the application object and the iterator it returns. cCs*t|_t|_|j||jjdSr/)r r rZstartZ addCleanupstopr6r$r$r% enableThreadsXs zApplicationTests.enableThreadsc sptGddd}|fdd}\}}fdd}||||fddd d gd g|S) z If the application object returns an iterator which also has a I{close} method, that method is called after iteration is complete. c@s$eZdZddZddZddZdS)z+ApplicationTests.test_close..ResultcSs d|_dS)NTopenr6r$r$r%rAgsz4ApplicationTests.test_close..Result.__init__css"tdD]}|jrt|VqdSr')rangerr)r ir$r$r%__iter__js z4ApplicationTests.test_close..Result.__iter__cSs d|_dS)NFrr6r$r$r%closeosz1ApplicationTests.test_close..Result.closeNr'r(r)rArrr$r$r$r%Resultfsrcsfdd}|S)Ncs|ddgS)Nrr3r$r0rr$r%rKts zLApplicationTests.test_close..applicationFactory..applicationr$rrr$r%rvss z7ApplicationTests.test_close..applicationFactorycs*jjdjdS)Ns012)rrrr]r^rrr`r{rr r$r%rzs z/ApplicationTests.test_close..cbRenderedcsSr/r$r$rr$r%r3r4z-ApplicationTests.test_close..rrr@rc)r rrvrrurr$rr% test_close_s"     zApplicationTests.test_closec sXgfdd}\}}fdd}||||tddgdg|S)zu The application object is invoked and iterated in a thread which is not the reactor thread. csfdd}|S)Ncs*fdd}t|ddg|S)Nc3s(tdD]}tt|VqdSr')rrrr)rinvokedr$r%rs  zpApplicationTests.test_applicationCalledInThread..applicationFactory..application..resultrr)rr)r1r2rrr$r%rKs   z`ApplicationTests.test_applicationCalledInThread..applicationFactory..applicationr$rrr$r%rvs zKApplicationTests.test_applicationCalledInThread..applicationFactorycs&tttddS)NrM)Z assertNotInrrrSsetr`rr r$r%rszCApplicationTests.test_applicationCalledInThread..cbRenderedrrr@)rrrr}rrdr$rr%test_applicationCalledInThreads   z/ApplicationTests.test_applicationCalledInThreadc sjgGfdddt}dd}|\}}fdd}||||tddgd g|S) z The I{write} callable returned by I{start_response} calls the request's C{write} method in the reactor thread. cseZdZfddZdS)zCApplicationTests.test_writeCalledFromThread..ThreadVerifiercstt||Sr/rrrrrr r\rr$r%rrs zIApplicationTests.test_writeCalledFromThread..ThreadVerifier.writeNr'r(r)rrr$rr$r%ThreadVerifiersrcSs dd}|S)NcSs|dg}|dtdS)Nrr:r$r[rr$r$r%rKs z\ApplicationTests.test_writeCalledFromThread..applicationFactory..applicationr$rr$r$r%rvszGApplicationTests.test_writeCalledFromThread..applicationFactorycstttgdSr/rrrr`rr$r%rsz?ApplicationTests.test_writeCalledFromThread..cbRenderedrrr@rrrrr}rr rrvrrurr$rr%test_writeCalledFromThreads" z+ApplicationTests.test_writeCalledFromThreadc sjgGfdddt}dd}|\}}fdd}||||tddgd g|S) z Strings produced by the iterator returned by the application object are written to the request in the reactor thread. cseZdZfddZdS)zMApplicationTests.test_iteratedValuesWrittenFromThread..ThreadVerifiercstt||Sr/rrrr$r%rrs zSApplicationTests.test_iteratedValuesWrittenFromThread..ThreadVerifier.writeNrr$rr$r%rsrcSs dd}|S)Ncss|dgdVdS)Nrr:r$r0r$r$r%rKs zfApplicationTests.test_iteratedValuesWrittenFromThread..applicationFactory..applicationr$rr$r$r%rvszQApplicationTests.test_iteratedValuesWrittenFromThread..applicationFactorycstttgdSr/rr`rr$r%rszIApplicationTests.test_iteratedValuesWrittenFromThread..cbRenderedrrr@rrr$rr%$test_iteratedValuesWrittenFromThreads" z5ApplicationTests.test_iteratedValuesWrittenFromThreadc sjgGfdddt}dd}|\}}fdd}||||tddgd g|S) zY The response status is set on the request object in the reactor thread. cseZdZfddZdS)zEApplicationTests.test_statusWrittenFromThread..ThreadVerifiercstt|||Sr/)rrrsetResponseCode)r coderrr$r%rs zUApplicationTests.test_statusWrittenFromThread..ThreadVerifier.setResponseCodeN)r'r(r)rr$rr$r%rsrcSs dd}|S)NcSs|dgtdSr~r[r0r$r$r%rKs z^ApplicationTests.test_statusWrittenFromThread..applicationFactory..applicationr$rr$r$r%rvszIApplicationTests.test_statusWrittenFromThread..applicationFactorycstttgdSr/rr`rr$r%rszAApplicationTests.test_statusWrittenFromThread..cbRenderedrrr@rrr$rr%test_statusWrittenFromThreads" z-ApplicationTests.test_statusWrittenFromThreadc svGdddt}d_fddfdd}|\}}fdd }||||td d gd g|tS) z If the request connection is lost while the application object is being iterated, iteration is stopped. c@seZdZdZddZdS)zSApplicationTests.test_connectionClosedDuringIteration..UnreliableConnectionz This is a request which pretends its connection is lost immediately after the first write is done to it. cSs|ttddS)NzNo more connection)connectionLostrr rr$r$r%rrszYApplicationTests.test_connectionClosedDuringIteration..UnreliableConnection.writeN)r'r(r)r*rrr$r$r$r%UnreliableConnection srFc3sdVd_tddS)Nr:TzShould not have gotten here)badIterrPr$r6r$r%appIterszFApplicationTests.test_connectionClosedDuringIteration..appItercsfdd}|S)Ncs|dgSNrr$r0rr$r%rKs zfApplicationTests.test_connectionClosedDuringIteration..applicationFactory..applicationr$rrr$r%rvs zQApplicationTests.test_connectionClosedDuringIteration..applicationFactorycsjddS)Nz!Should not have resumed iteration)rrr`r6r$r%r szIApplicationTests.test_connectionClosedDuringIteration..cbRenderedrrr@)rrrrr}rrkr )r rrvrrurr$)rr r%$test_connectionClosedDuringIterations"    z5ApplicationTests.test_connectionClosedDuringIterationc s^tfdd}\}}fdd}||||fddddgd gdg |S) NcsSr/r$r$rr$r%rv.szEApplicationTests._internalServerErrorTest..applicationFactorycs6t}t|djjddS)NrMs"HTTP/1.1 500 Internal Server Error) rVr<rrSr8rr]r^r_)rarrbr$r%r2s  z=ApplicationTests._internalServerErrorTest..cbRenderedcsSr/r$r$rr$r%r3=r4z;ApplicationTests._internalServerErrorTest..rrr@rc)r rKrvrrurr$)rKr{r r%_internalServerErrorTest+s"    z)ApplicationTests._internalServerErrorTestcCsdd}||S)z If the application raises an exception before calling I{start_response} then the response status is I{500} and the exception is logged. cSs tddSN This application had some error.r<r0r$r$r%rKGszRApplicationTests.test_applicationExceptionBeforeStartResponse..applicationrr rKr$r$r%,test_applicationExceptionBeforeStartResponseBsz=ApplicationTests.test_applicationExceptionBeforeStartResponsecCsdd}||S)z If the application calls I{start_response} but then raises an exception before any data is written to the response then the response status is I{500} and the exception is logged. cSs|dgtddSNrrrr0r$r$r%rKRs zQApplicationTests.test_applicationExceptionAfterStartResponse..applicationrrr$r$r%+test_applicationExceptionAfterStartResponseLsz.applicationFactorycs||dSr.)r)r"r#)rurequestsr$r%requestFactoryWrappergszEApplicationTests._connectionClosedTest..requestFactoryWrappercsddtd}|d}|jttjj} | d |dS)NrMrrNsHTTP/1.1 200 OK) rRrSrTrUr<rVrr]r^r8r_ZassertIn)raZeventr!r)r{rWresponseContentr r$r% ebRenderedks  z:ApplicationTests._connectionClosedTest..ebRenderedcsSr/r$r$rr$r%r3zr4z8ApplicationTests._connectionClosedTest..rrr@rzAll gone) rrrOrrZ addErrbackr}r8rZ disconnectedrrr )r rKrrvrrrr$)rKr{rWrurrr r%_connectionClosedTestXs2    z&ApplicationTests._connectionClosedTestcsdfdd}||S)z If the application raises an exception after the response status has already been sent then the connection is closed and the exception is logged. s?Some bytes, triggering the server to start sending the responsec3s|dgVtddSrrr0rr$r%rKs zIApplicationTests.test_applicationExceptionAfterWrite..application)rrr$rr%#test_applicationExceptionAfterWrites z4ApplicationTests.test_applicationExceptionAfterWritecs$dGfdddt}||S)z If the application returns a closeable iterator and the C{close} method raises an exception when called then the connection is still closed and the exception is logged. r:cs(eZdZddZfddZddZdS)zDApplicationTests.test_applicationCloseException..ApplicationcSs|dgdSrr$)r r1r2r$r$r%rAszMApplicationTests.test_applicationCloseException..Application.__init__c3s VdSr/r$r6rr$r%rszMApplicationTests.test_applicationCloseException..Application.__iter__cSs tddSrrr6r$r$r%rszJApplicationTests.test_applicationCloseException..Application.closeNrr$rr$r% Applications r)objectr)r rr$rr%test_applicationCloseExceptions z/ApplicationTests.test_applicationCloseExceptionN)r'r(r)r*rrrrrrrrrrrrrr$r$r$r%rSs*  %  ,r)?r*rZ __metaclass__sysrrYrr Zzope.interface.verifyrZtwisted.python.compatrrrZtwisted.python.failurerZtwisted.python.threadablerZtwisted.python.threadpoolr Ztwisted.internet.deferr r Ztwisted.internetr Ztwisted.internet.errorr Ztwisted.trial.unittestrrZ twisted.webrZtwisted.web.resourcerrZtwisted.web.serverrrrZtwisted.web.wsgirZtwisted.web.test.test_webrZtwisted.loggerrrZtwisted.test.proto_helpersrZtwisted.internet.addressrrrr+r.rYrrrMrSrUrXrZrr$r$r$r%sZ           z-@/  C