L^i|dZddlZddlZddlmZmZmZgdZeedre ddgGdd Z Gd d e ej Z Gd d ej ZGddejZeedr'Gdde ejZGddejZdZdZdS)aStreaming HTTP uploads module. This module extends the standard httplib and urllib2 objects so that iterable objects can be used in the body of HTTP requests. In most cases all one should have to do is call :func:`register_openers()` to register the new streaming http handlers which will take priority over the default handlers, and then you can use iterable objects in the body of HTTP requests. **N.B.** You must specify a Content-Length header if using an iterable object since there is no way to determine in advance the total size that will be yielded, and there is no way to reset an interator. Example usage: >>> from StringIO import StringIO >>> import urllib2, poster.streaminghttp >>> opener = poster.streaminghttp.register_openers() >>> s = "Test file data" >>> f = StringIO(s) >>> req = urllib2.Request("http://localhost:5000", f, ... {'Content-Length': str(len(s))}) N) NotConnectedhttpliburllib2)StreamingHTTPConnectionStreamingHTTPRedirectHandlerStreamingHTTPHandlerregister_openersHTTPSStreamingHTTPSHandlerStreamingHTTPSConnectionceZdZdZdZdS)_StreamingHTTPMixinzWMixin class for HTTP and HTTPS connections that implements a streaming send method.c|j*|jr|nt|jdkrt dt | d}t|drt|dr|d|jdkrt d| |}|r3|j || |}|1dSdSt|dr_t|d r| |jdkrt d |D]}|j |dS|j |dS#tj $r;tjd }|dd kr|wxYw) zSend ``value`` to the server. ``value`` can be a string object, a file-like object that supports a .read() method, or an iterable object that supports a .next() method. Nrzsend:i readseekzsendIng a read()ablenextresetzsendIng an iterable )sock auto_openconnectr debuglevelprintreprhasattrrrsendallrsocketerrorsysexc_infoclose)selfvalue blocksizedataes BD:\Nbitz\venv\Lib\site-packages\cloudinary/poster/streaminghttp.pysendz_StreamingHTTPMixin.send-s 9 ~ % "nn$ ?Q   '4;; ' ' ' Iuf%% )5&))"JJqMMM?Q&&0111zz),,1I%%d+++ ::i00D11111'' )5'**"KKMMM?Q&&/000!,,DI%%d++++,, !!%(((((|    q!Atrzz   sBF8A-F'FA G N)__name__ __module__ __qualname____doc__r)r(rr*s------r/rceZdZdZdS)rzlSubclass of `httplib.HTTPConnection` that overrides the `send()` method to support iterable body objectsNr*r+r,r-r.r/r(rr]s((((r/rc6eZdZdZejjdz ZdZdS)ralSubclass of `urllib2.HTTPRedirectHandler` that overrides the `redirect_request` method to properly handle redirected POST requests This class is required because python 2.5's HTTPRedirectHandler does not remove the Content-Type or Content-Length headers when requesting the new resource, but the body of the original request is not preserved. rc|}|dvr|dvs |dvrv|dkrp|dd}td|jD}t j|||d St j| ||||) aReturn a Request or None in response to a redirect. This is called by the http_error_30x methods when a redirection response is received. If a redirection should take place, return a new Request to allow http_error_30x to perform the redirect. Otherwise, raise HTTPError if no-one else should try to handle this url. Return None if you can't but another Handler might. )-./i3)GETHEAD)r4r5r6POST z%20c3PK|]!\}}|dv||fV"dS))zcontent-lengthz content-typeN)lower).0kvs r( z@StreamingHTTPRedirectHandler.redirect_request..s^  A!"3D"D"D !!f"D"D"D"D  r/T)headersorigin_req_host unverifiable) get_methodreplacedictrAitemsrRequestget_origin_req_host HTTPError get_full_url) r#reqfpcodemsgrAnewurlm newheaderss r(redirect_requestz-StreamingHTTPRedirectHandler.redirect_requestns NN   ( ( (Q/-A-A?**qF{{^^C//F  1B1B1D1D     J?" # 7 7 9 9! ### # #C$4$4$6$6c7BOO Or/N)r*r+r,r-rHTTPRedirectHandler handler_orderrSr.r/r(rrbsD/=AMPPPPPr/rc<eZdZdZejjdz ZdZdZdS)rzeSubclass of `urllib2.HTTPHandler` that uses StreamingHTTPConnection as its http connection class.rc8|t|S)z4Open a StreamingHTTPConnection for the given request)do_openrr#rLs r( http_openzStreamingHTTPHandler.http_opens||3S999r/c|rX|}t|dst|dr$|dst dt j||S)zlHandle a HTTP request. Make sure that Content-Length is specified if we're using an interable valuerrContent-length-No Content-Length specified for iterable body)has_dataget_datar has_header ValueErrorr HTTPHandler do_request_r#rLr&s r( http_requestz!StreamingHTTPHandler.http_requests <<>> M<<>>DtV$$ Mf(=(= M~~&677M$KMMM"..tS999r/N) r*r+r,r-rrbrUrZrer.r/r(rrsN=='59M::: : : : : :r/rceZdZdZdS)r zpSubclass of `httplib.HTTSConnection` that overrides the `send()` method to support iterable body objectsNr1r.r/r(r r s 3 3 3 3r/c<eZdZdZejjdz ZdZdZdS)r zkSubclass of `urllib2.HTTPSHandler` that uses StreamingHTTPSConnection as its http connection class.rc8|t|S)N)rXr rYs r( https_openz StreamingHTTPSHandler.https_opens<< 8#>> >r/c|rX|}t|dst|dr$|dst dt j||S)Nrrr\r])r^r_rr`rar HTTPSHandlerrcrds r( https_requestz#StreamingHTTPSHandler.https_requests||~~ M||~~4((MGD&,A,AM>>*:;;M(KMMM'33D#>> >r/N) r*r+r,r-rrkrUrirlr.r/r(r r sP B B ,:Q>  ? ? ? ? ? ? ? ?r/cttg}ttdr|t |S)Nr )rrrrappendr )handlerss r( get_handlersrps7$&BCHw  /-... Or/cbtjt}tj||S)zRegister the streaming http handlers in the global urllib2 default opener object. Returns the created OpenerDirector object.)r build_openerrpinstall_opener)openers r(r r s+  !<>> 2F 6""" Mr/)r-rr cloudinary.compatrrr__all__rextendrHTTPConnectionrrTrrbrHTTPSConnectionr rkr rpr r.r/r(rzs8 <<<<<<<<<< 7 7 7 77GJ NN+-GHIII00000000f(((((173I((( *P*P*P*P*P7#>*P*P*PZ:::::7.:::0 77G?33333#68O333????? 4???*     r/