OwlCyberSecurity - MANAGER
Edit File: http.pyc
� �t�ac @ sB d 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 d d l m Z m Z d d l m Z d d l m Z m Z m Z d d l m Z m Z m Z d d l m Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e e e f d � � YZ! d S( s" Client-side HTTP implementation. i����( t implements( t Deferred( t LineReceiver( t TimeoutMixin( t BAD_REQUESTt HTTP_VERSION_NOT_SUPPORTED( t parseVersiont Response( t Headers( t ProducerStreamt StreamProducert IByteStream( t HTTPParsert PERSIST_NO_PIPELINEt PERSIST_PIPELINE( t IHTTPClientManagert ProtocolErrorc B s e Z d Z RS( s6 Exception raised when a HTTP error happened. ( t __name__t __module__t __doc__( ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR , s t ClientRequestc B s e Z d Z d � Z RS( sJ A class for describing an HTTP request to be sent to the server. c C sm | | _ | | _ t | t � r- | | _ n t | p9 i � | _ | d k r` t | � | _ n d | _ d S( s @param method: The HTTP method to for this request, ex: 'GET', 'HEAD', 'POST', etc. @type method: C{str} @param uri: The URI of the resource to request, this may be absolute or relative, however the interpretation of this URI is left up to the remote server. @type uri: C{str} @param headers: Headers to be sent to the server. It is important to note that this object does not create any implicit headers. So it is up to the HTTP Client to add required headers such as 'Host'. @type headers: C{dict}, L{txweb2.http_headers.Headers}, or C{None} @param stream: Content body to send to the remote HTTP server. @type stream: L{txweb2.stream.IByteStream} N( t methodt urit isinstanceR t headerst NoneR t stream( t selfR R R R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt __init__7 s ( R R R R ( ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR 2 s t HTTPClientChannelRequestc B s� e Z e Z d Z e Z e Z e 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 d � Z d � Z RS( s HTTP/1.1c C sA t j | | � | | _ | | _ | j j | _ t � | _ d S( N( R R t requestt closeAftert channelt transportR t responseDefer( R R R R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR a s c C s� g } | j } | j d k r* d | _ n | j d | j | j | j f � | j d k r� xH | j j � D]4 \ } } x% | D] } | j d | | f � q Wql Wn | j d k r| j j d k r� | j d d | j j f � q| j d d � t | _ n | j r"| j d d � n | j d d � | j d � | j j | � t | j � j | � } | j | j � j | j � d S( Nt HEADi s %s %s %s s %s: %s s Content-Lengths Transfer-Encodingt chunkedt Connectiont closes Keep-Alives ( s Transfer-EncodingR$ ( R% R& ( R% s Keep-Alive( R R t lengtht appendR t outgoing_versionR R t getAllRawHeadersR t Truet chunkedOutR R! t writeSequenceR t beginProducingt addCallbackt _finisht addErrbackt _error( R t lR t namet valuelistt valuet d( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt submith s, " c C s | j j | | � d S( s& Register a producer. N( R! t registerProducer( R t producert streaming( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR9 � s c C s | j j � d S( N( R! t unregisterProducer( R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR< � s c C sM | s d S| j r9 | j j d t | � | d f � n | j j | � d S( Ns %X s ( R, R! R- t lent write( R t data( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR> � s &c C s? | j r | j j d � n t | _ | j j | � | ` d S( s/ We are finished writing data. s 0 N( R, R! R> R+ t finishedR t requestWriteFinished( R t x( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR0 � s c C sO | j � t | d � r; | j d k r; | j j | � n | j j | � d S( s� Abort parsing, and depending of the status of the request, either fire the C{responseDefer} if no response has been sent yet, or close the stream. R N( t abortParset hasattrR R t finishR" t errback( R t err( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR2 � s c C s | j t | � � d S( sN Abort parsing by forwarding a C{ProtocolError} to C{_error}. N( R2 R ( R t errcodet text( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt _abortWithError� s c C s | j | � d S( N( R2 ( R t reason( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt connectionLost� s c C s� | j d d � } t | � d k r? | j t d | f � d S| \ } | _ } y, t | � } | d d k r| t � � n Wn) t k r� | j t d | f � d SX| d d !| _ | j d d k r� | j t d � d Sd S( Nt i i s Bad response line: %si t https Unknown protocol: %si s Only HTTP 1.x is supported.( t splitR= RJ R t codeR t ValueErrort versionR ( R t initialLinet partst strversiont _ignore_messaget protovers( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt gotInitialLine� s& c C sM t | j � | _ t | j | j | j � | _ | j j | t � | ` d S( N( R R' R R RP t inHeaderst responseR9 R+ ( R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt createRequest� s c C s | j j | j � d S( N( R" t callbackRZ ( R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt processRequest� s c C s | j j | � d S( N( R R> ( R R? ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt handleContentChunk� s c C s | j j � d S( N( R RE ( R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt handleContentComplete� s ( R R R+ t parseCloseAsEndR) t FalseR, R@ R R R8 R9 R< R> R0 R2 RJ RL RX R[ R] R^ R_ ( ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR Y s& " t EmptyHTTPClientManagerc B s< e Z d Z e e � d � Z d � Z d � Z d � Z RS( s� A dummy HTTPClientManager. It doesn't do any client management, and is meant to be used only when creating an HTTPClientProtocol directly. c C s d S( N( ( R t proto( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt clientBusy� s c C s d S( N( ( R Rc ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt clientIdle� s c C s d S( N( ( R Rc ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt clientPipelining� s c C s d S( N( ( R Rc ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt clientGone� s ( R R R R R Rd Re Rf Rg ( ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyRb � s t HTTPClientProtocolc B sz e Z d Z d Z d Z d Z e Z d Z d d � Z d � Z d � Z e d � Z d � Z d � Z d � Z d � Z RS( s< A HTTP 1.1 Client with request pipelining support. i ( i i< i c C s7 d | _ g | _ | d k r* t � } n | | _ d S( sz @param manager: The object this client reports it state to. @type manager: L{IHTTPClientManager} N( R t outRequestt inRequestsRb t manager( R Rk ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyR s c C s� | j s | j j � d S| j d | j k rC | j | j � n | j rl d | _ | j d j | � n | j d j | � d S( Ni ( Rj R! t loseConnectionRi t setTimeoutt inputTimeOutt firstLineRX t lineReceived( R t line( ( s% /opt/cpanel-ccs/txweb2/client/http.pyRp s c C s[ | j s | j j � d S| j d | j k rC | j | j � n | j d j | � d S( Ni ( Rj R! Rl Ri Rm Rn t rawDataReceived( R R? ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyRr + s c C s� | j d k s t � | j t k r. | j sC | j t k sC t � | j j | � | re t | _ n t | | | � | _ } | j j | � | j � | j S( s� @param request: The request to send to a remote server. @type request: L{ClientRequest} @param closeAfter: If True the 'Connection: close' header will be sent, otherwise 'Connection: keep-alive' @type closeAfter: C{bool} @rtype: L{twisted.internet.defer.Deferred} @return: A Deferred which will be called back with the L{txweb2.http.Response} from the server. N( Ri R t AssertionErrort readPersistentR Rj R Rk Rd Ra R R( R8 R" ( R R R t chanRequest( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt submitRequest7 s c C sT | | j k s t � d | _ | j | j � | j t k rP | j j | � n d S( N( Ri Rs R Rm Rn Rt R Rk Rf ( R R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyRA T s c C sr | j d | k s t � | j d =t | _ | j sn | j r^ | j d � | j j | � qn | j j � n d S( Ni ( Rj Rs R+ Ro Rt Rm R Rk Re R! Rl ( R R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt requestReadFinished] s c C sE | | _ | sA x" | j d D] } | j d � q W| j d 3n d S( Ni ( Rt Rj RL R ( R t persistR ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt setReadPersistentj s c C sZ t | _ | j d � | j j | � x- | j D]" } | d k r0 | j | � q0 q0 Wd S( N( Ra Rt Rm R Rk Rg Rj RL ( R RK R ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyRL r s Ni� ( R R R R Ru t maxHeaderLengthRo R Rt Rn R Rp Rr R+ Rv RA Rw Ry RL ( ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyRh s N(" R t zope.interfaceR t twisted.internet.deferR t twisted.protocols.basicR t twisted.protocols.policiesR t txweb2.responsecodeR R t txweb2.httpR R t txweb2.http_headersR t txweb2.streamR R R t txweb2.channel.httpR R R t txweb2.client.interfacesR t ExceptionR t objectR R Rb Rh ( ( ( s% /opt/cpanel-ccs/txweb2/client/http.pyt <module> s '�