OwlCyberSecurity - MANAGER
Edit File: http.pyc
� �t�ac @ s^ d Z d d l Z d d l Z d d l m Z m Z d d l m Z d d l m Z m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z m Z e � Z i d d 6d d 6d d 6Z d � Z d � Z d e f d � � YZ d e f d � � YZ d e f d � � YZ! d e f d � � YZ" d e" f d � � YZ# d d � Z% d e& d d d � Z' d! � Z( d" e j) f d# � � YZ* e j+ e j, f Z- d$ e f d% � � YZ. d& e f d' � � YZ/ d( e f d) � � YZ0 e j1 e e2 e j3 � d d* d$ d d d d+ d, d- d. d/ d& d( g Z4 d S(0 s] HyperText Transfer Protocol implementation. The second coming. Maintainer: James Y Knight i����N( t interfacest error( t components( t Elementt XMLStringt renderert flattenString( t implements( t Logger( t responsecode( t http_headers( t iweb( t stream( t IByteStreamt readAndDiscardiP t httpi� t httpsi t ftpc C sn | j d d � } y. t | � d k r? | d t | d � f SWn t k rS n X| d t j | d � f S( s� Split the host in "host:port" format into host and port fields. If port was not specified, use the default for the given scheme, if known. Returns a tuple of (hostname, portnumber).t :i i i ( t splitt lent intt ValueErrort defaultPortForSchemet get( t schemet hostport( ( s /opt/cpanel-ccs/txweb2/http.pyt splitHostPort9 s c C s} | j d � \ } } | j d � \ } } t | � t | � } } | d k s[ | d k rj t d � � n | j � | | f S( s� Parse version strings of the form Protocol '/' Major '.' Minor. E.g. 'HTTP/1.1'. Returns (protocol, major, minor). Will raise ValueError on bad syntax.t /t .i s negative number( R R R t lower( t strversiont protot majort minor( ( s /opt/cpanel-ccs/txweb2/http.pyt parseVersionH s t HTTPErrorc B s e Z d � Z d � Z RS( c C s/ t j | � | _ t j | t | j � � d S( s� An Exception for propagating HTTP Error Responses. @param codeOrResponse: The numeric HTTP code or a complete http.Response object. @type codeOrResponse: C{int} or L{http.Response} N( R t IResponset responset Exceptiont __init__t str( t selft codeOrResponse( ( s /opt/cpanel-ccs/txweb2/http.pyR( W s c C s d | j j | j f S( Ns <%s %s>( t __class__t __name__R& ( R* ( ( s /opt/cpanel-ccs/txweb2/http.pyt __repr__a s ( R- t __module__R( R. ( ( ( s /opt/cpanel-ccs/txweb2/http.pyR$ U s t Responsec B sK e Z d Z e e j � e j Z d Z d Z d d d d � Z d � Z RS( sF An object representing an HTTP Response to be sent to the client. c C s� | d k r t | � | _ n | d k rW t | t � rK t j | � } n | | _ n t j � | _ | d k r� t | � | _ n d S( se @param code: The HTTP status code for this Response @type code: C{int} @param headers: Headers to be sent to the client. @type headers: C{dict}, L{txweb2.http_headers.Headers}, or C{None} @param stream: Content body to send to the HTTP client @type stream: L{txweb2.stream.IByteStream} N( t NoneR t codet isinstancet dictR t Headerst headersR R ( R* R2 R6 R ( ( s /opt/cpanel-ccs/txweb2/http.pyR( n s c C sD | j d k r d } n | j j } d | j | j j | j | f S( Ns <%s.%s code=%d, streamlen=%s>( R R1 t lengthR/ R, R- R2 ( R* t streamlen( ( s /opt/cpanel-ccs/txweb2/http.pyR. � s N( R- R/ t __doc__R R R% R t OKR2 R1 R6 R R( R. ( ( ( s /opt/cpanel-ccs/txweb2/http.pyR0 e s t StatusResponseElementc B s2 e Z d Z e d � Z d � Z e d � � Z RS( s1 Render the HTML for a L{StatusResponse} s <html xmlns:t="http://twistedmatrix.com/ns/twisted.web.template/0.1" t:render="response"><head><title><t:slot name="title" /></title></head><body><h1><t:slot name="title" /></h1><p><t:slot name="description" /></p></body></html>c C s) t t | � j � | | _ | | _ d S( N( t superR; R( t titlet description( R* R= R> ( ( s /opt/cpanel-ccs/txweb2/http.pyR( � s c C s | j d | j d | j � S( s% Top-level renderer. R= R> ( t fillSlotsR= R> ( R* t requestt tag( ( s /opt/cpanel-ccs/txweb2/http.pyR& � s ( R- R/ R9 R t loaderR( R R& ( ( ( s /opt/cpanel-ccs/txweb2/http.pyR; � s t StatusResponsec B s# e Z d Z d d � Z d � Z RS( sj A L{Response} object which simply contains a status code and a description of what happened. c C s� | d k r t j | } n t | | � } g } t d | � j | j � i d d 6} t t | � j d | d | d � | j j d t j d d | � � | | _ d S( s� @param code: a response code in L{responsecode.RESPONSES}. @param description: a string description. @param title: the message title. If not specified or C{None}, defaults to C{responsecode.RESPONSES[code]}. s utf-8t charsetR2 R i s content-typet textt htmlN( R1 R t RESPONSESR; R t addCallbackt appendR< RC R( R6 t setHeaderR t MimeTypeR> ( R* R2 R> R= t elementt outt mime_params( ( s /opt/cpanel-ccs/txweb2/http.pyR( � s # c C s d | j j | j | j f S( Ns <%s %s %s>( R, R- R2 R> ( R* ( ( s /opt/cpanel-ccs/txweb2/http.pyR. � s N( R- R/ R9 R1 R( R. ( ( ( s /opt/cpanel-ccs/txweb2/http.pyRC � s t RedirectResponsec B s e Z d Z e d � Z RS( sT A L{Response} object that contains a redirect to another network location. c C sO | r t j n t j } t t | � j | d | f � | j j d | � d S( s� @param location: the URI to redirect to. @param temporary: whether it's a temporary redirect or permanent s Document moved to %s.t locationN( R t TEMPORARY_REDIRECTt MOVED_PERMANENTLYR< RO R( R6 RJ ( R* RP t temporaryR2 ( ( s /opt/cpanel-ccs/txweb2/http.pyR( � s ( R- R/ R9 t FalseR( ( ( ( s /opt/cpanel-ccs/txweb2/http.pyRO � s c C sy | d k r] t j � } xH d D]7 } | j j | � } | d k r | j | | � q q Wn d } t d t j d | � S( Nt datet etags content-locationt expiress cache-controlt varyt servers proxy-authenticates www-authenticatet warningR2 R6 ( RU RV s content-locationRW s cache-controlRX RY s proxy-authenticates www-authenticateRZ ( R1 R R5 R6 t getRawHeaderst setRawHeadersR0 R t NOT_MODIFIED( t oldResponseR6 t headert value( ( s /opt/cpanel-ccs/txweb2/http.pyt NotModifiedResponse� s c s/ | r � d k r | d k s$ t � | j d k rB | j d k pQ | j t j k sX t S| j j d � � | j j d � } n � � f d � } | j j d � } | r� | | t � s� t t t j d � � � q� n | j j d � } | r | s| | k r t t t j d � � � q n d } | j j d � } | rd| t j � k o^| o^| | k } n | j j d � } | r | j d k r�| j j d � } | t k r| | | � rt t | � � � qq+| t k r+| | t � r+t t t j d � � � q+n! | t k r+t t | � � � n d S( s� Check to see if this request passes the conditional checks specified by the client. May raise an HTTPError with result codes L{NOT_MODIFIED} or L{PRECONDITION_FAILED}, as appropriate. This function is called automatically as an output filter for GET and HEAD requests. With GET/HEAD, it is not important for the precondition check to occur before doing the action, as the method is non-destructive. However, if you are implementing other request methods, like PUT for your resource, you will need to call this after determining the etag and last-modified time of the existing resource but before actually doing the requested action. In that case, This examines the appropriate request headers for conditionals, (If-Modified-Since, If-Unmodified-Since, If-Match, If-None-Match, or If-Range), compares with the etag and last and and then sets the response code as necessary. @param response: This should be provided for GET/HEAD methods. If it is specified, the etag and lastModified arguments will be retrieved automatically from the response headers and shouldn't be separately specified. Not providing the response with a GET request may cause the emitted "Not Modified" responses to be non-conformant. @param entityExists: Set to False if the entity in question doesn't yet exist. Necessary for PUT support with 'If-None-Match: *'. @param etag: The etag of the resource to check against, or None. @param lastModified: The last modified date of the resource to check against, or None. @raise: HTTPError: Raised when the preconditions fail, in order to abort processing and emit an error page. i� i+ RV s last-modifiedc sc � r d | k r t S� d k r& t S| s6 � j ob g | D]" } � j | d | �r= | ^ q= S( Nt *t strongCompare( t TrueR1 RT t weakt match( t tagst allowWeakt etagmatch( t entityExistsRV ( s /opt/cpanel-ccs/txweb2/http.pyt matchETag s s if-matchs1 Requested resource does not have a matching ETag.s if-unmodified-sinces Requested resource has changed.s if-modified-sinces if-none-matcht HEADt GETt Ranges' Requested resource has a matching ETag.N( Rl Rm ( R1 t AssertionErrorR2 R t PRECONDITION_FAILEDRT R6 t getHeaderR$ RC t timet methodt hasHeaderRa Rd ( R@ R& Rj RV t lastModifiedRk Rf t unmod_sincet notModifiedt imst inmt canBeWeak( ( Rj RV s /opt/cpanel-ccs/txweb2/http.pyt checkPreconditions� s< & ' c C sm | j j d � } | d k r" t St | t j � rS | j | j j d � d t �S| | j j d � k Sd S( s� Checks for the If-Range header, and if it exists, checks if the test passes. Returns true if the server should return partial data.s if-rangeRV Rc s last-modifiedN( R6 Rq R1 Rd R3 R t ETagRf ( R@ R& t ifrange( ( s /opt/cpanel-ccs/txweb2/http.pyt checkIfRangeT s t _NotifyingProducerStreamc B s8 e Z d Z d d d � Z d � Z d � Z d � Z RS( c C s# t j j | d | �| | _ d S( NR7 ( R t ProducerStreamR( t doStartReading( R* R7 R� ( ( s /opt/cpanel-ccs/txweb2/http.pyR( e s c C s; | j d k r+ | j } d | _ | � n t j j | � S( N( R� R1 R R� t read( R* R� ( ( s /opt/cpanel-ccs/txweb2/http.pyR� i s c C s d | _ t j j | | � d S( N( R1 R� R R� t write( R* t data( ( s /opt/cpanel-ccs/txweb2/http.pyR� q s c C s d | _ t j j | � d S( N( R1 R� R R� t finish( R* ( ( s /opt/cpanel-ccs/txweb2/http.pyR� u s N( R- R/ R1 R� R( R� R� R� ( ( ( s /opt/cpanel-ccs/txweb2/http.pyR b s t Requestc B s� e Z d Z e e j e j � d Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( so A HTTP request. Subclasses should override the process() method to determine how the request will be processed. @ivar method: The HTTP method that was used. @ivar uri: The full URI that was requested (includes arguments). @ivar headers: All received headers @ivar clientproto: client HTTP version @ivar stream: incoming data stream. s 100-continuec C s� | | _ | | _ | | _ | | _ | | _ d | j j d d � k rT | j } n d } t | | � | _ | j j | j t � d S( sP @param chanRequest: the channel request we're associated with. s 100-continuet expectN( ( t chanRequestRs t urit clientprotoR6 Rq t _sendContinueR1 R R t registerProducerRd ( R* R� t commandt patht versiont contentLengthR6 R� ( ( s /opt/cpanel-ccs/txweb2/http.pyR( � s c C sK | j j d d � } x/ | D]' } | | j k r t t j � � q q Wd S( sm Ensure there are no expectations that cannot be met. Checks Expect header against self.known_expects.R� N( ( R6 Rq t known_expectsR$ R t EXPECTATION_FAILED( R* t expectsR� ( ( s /opt/cpanel-ccs/txweb2/http.pyt checkExpect� s c C s d S( sr Called by channel to let you process the request. Can be overridden by a subclass to do something useful.N( ( R* ( ( s /opt/cpanel-ccs/txweb2/http.pyt process� s c C s | j j | � d S( s^ Callback from channel when a piece of data has been received. Puts the data in .streamN( R R� ( R* R� ( ( s /opt/cpanel-ccs/txweb2/http.pyt handleContentChunk� s c C s | j j � | j j � d S( s7 Callback from channel when all data has been received. N( R t unregisterProducerR� ( R* ( ( s /opt/cpanel-ccs/txweb2/http.pyt handleContentComplete� s c C s d S( s connection was lostN( ( R* t reason( ( s /opt/cpanel-ccs/txweb2/http.pyt connectionLost� s c C s d | j | j | j f S( Ns <%s %s %s>( Rs R� R� ( R* ( ( s /opt/cpanel-ccs/txweb2/http.pyR. � s c C s | j j t j � d S( N( R� t writeIntermediateResponseR t CONTINUE( R* ( ( s /opt/cpanel-ccs/txweb2/http.pyR� � s c C s | j j � d S( s We are finished writing data.N( R� R� ( R* t x( ( s /opt/cpanel-ccs/txweb2/http.pyt _reallyFinished� s c C sH | j j d k r7 t | j � j | j � j | j � S| j | � d S( sR We are finished writing data. But we need to check that we have also finished reading all data as we might have sent a, for example, 401 response before we read any data. To make sure that the stream/producer sequencing works properly we need to discard the remaining data in the request. i N( R R7 R RH R� t addErrbackt _error( R* R� ( ( s /opt/cpanel-ccs/txweb2/http.pyt _finished� s %c C sO | j t j � r. t j d d | j � �n t j d | � | j j � d S( Ns Request error: {msg}t msgs Request error( t checkR t ConnectionLostt logt infot getErrorMessaget failureR� t abortConnection( R* R� ( ( s /opt/cpanel-ccs/txweb2/http.pyR� � s c C sB | j j d k r5 | j j j t � | j j � n | j t j k r� | j d k rl | j j d d � q� | j j d k r� | j j d | j j � q� n | j j | j | j � | j d k s� | j t k r| j d k r� | j j � n | j d � d St j | j � j | j � } | j | j � j | j � d S( s# Write a response. s content-lengthi Rl N( R R� R1 R� t channelt setReadPersistentRT t allContentReceivedR2 R R] R6 RJ R7 t writeHeadersRs t NO_BODY_CODESt closeR� t StreamProducert beginProducingRH R� R� ( R* R& t d( ( s /opt/cpanel-ccs/txweb2/http.pyt writeResponse� s ( s 100-continue( R- R/ R9 R R t IRequestR t IConsumerR� R( R� R� R� R� R� R. R� R� R� R� R� ( ( ( s /opt/cpanel-ccs/txweb2/http.pyR� ~ s t XMLResponsec B s e Z d Z d � Z RS( sH XML L{Response} object. Renders itself as an XML document. c C s? t j | | d | j � �| j j d t j d d � � d S( sO @param xml_responses: an iterable of davxml.Response objects. R s content-typeRE t xmlN( R0 R( t toxmlR6 RJ R RK ( R* R2 RL ( ( s /opt/cpanel-ccs/txweb2/http.pyR( s ( R- R/ R9 R( ( ( ( s /opt/cpanel-ccs/txweb2/http.pyR� s t JSONResponsec B s e Z d Z d e d � Z RS( sJ JSON L{Response} object. Renders itself as an JSON document. s application/jsonc C sn i } | r# d | d <d | d <n t j | | d t j | | � �| j j d t j | j d � � � d S( sN @param jobj: a Python object that can be serialized to JSON. i t indentt ,R t separatorsR s content-typeR N( R� R ( R0 R( t jsont dumpsR6 RJ R RK R ( R* R2 t jobjt contentTypet prettyt kwargs( ( s /opt/cpanel-ccs/txweb2/http.pyR( s "( R- R/ R9 RT R( ( ( ( s /opt/cpanel-ccs/txweb2/http.pyR� s Ra R~ R{ R R# R (5 R9 R� Rr t twisted.internetR R t twisted.pythonR t twisted.web.templateR R R R t zope.interfaceR t twext.python.logR t txweb2R R R R t txweb2.streamR R R� R R R# R' R$ t objectR0 R; RC RO R1 Ra Rd R{ R~ R� R t NO_CONTENTR] R� R� R� R� t registerAdapterR R% t __all__( ( ( s /opt/cpanel-ccs/txweb2/http.pyt <module> s> " ,! d �