ó þ› Nc@s`dZeZddgZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z mZddlZddlmZddlZddlmZdd lmZdd lmZdd lmZmZdd lmZdd l mZmZm Z d„Z!de fd„ƒYZ"de fd„ƒYZ#ddd„ƒYZ$dS(sïBrowser object to make requests of lazr.restful web services. The `Browser` class does some massage of HTTP requests and responses, and handles custom caches. It is not part of the public lazr.restfulclient API. (But maybe it should be?) tBrowsert RestfulHttpiÿÿÿÿN(tsleep(tFailedToDecompressContentt FileCachetHttpturlnorm(tStringIO(t urlencode(t Application(tURI(t error_fort HTTPError(tDatetimeJSONEncoder(t_md5t re_url_schemetre_slashcCs yUtj|ƒrTt|tƒrB|jdƒ}|jdƒ}qT|jdƒ}nWntk rhnXt|tƒrŠ|jdƒ}nt|ƒj ƒ}tj d|ƒ}t j d|ƒ}t j }|dd}t|ƒ|krö|| }ndj||fƒS(s•Return a filename suitable for the cache. Strips dangerous and common characters to create a filename we can use to store the cache in. sutf-8tidnatt,i i(Rtmatcht isinstancetstrtdecodetencodet UnicodeErrortunicodeRt hexdigesttsubRRtmaximum_cache_filename_lengthtlentjoin(tfilenametfilemd5tmaximum_filename_lengthtmaximum_length_before_md5_sum((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pytsafename6s$   cBs;eZdZdZddddd„Zd„Zd„ZRS(súAn Http subclass with some custom behavior. This Http client uses the TE header instead of the Accept-Encoding header to ask for compressed representations. It also knows how to react when its cache is a MultipleRepresentationCache. icCsKtt|ƒj|||ƒ||_|jdk rG|jj|ƒndS(N(tsuperRt__init__t authorizertNonetauthorizeSession(tselfR'tcachettimeoutt proxy_info((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyR&ks c Csr|jdƒr|d=n|jdk rD|jj||||ƒntt|ƒj||||||||| ƒ S(s4Use the authorizer to authorize an outgoing request.t authorizationN(thas_keyR'R(tauthorizeRequestR%Rt_request( R*tconnthostt absolute_urit request_uritmethodtbodytheaderst redirectionstcachekey((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyR1rs  cCs)t|jtƒr%|jj||ƒSdS(s+Retrieve a cached value for an HTTP header.N(RR+tMultipleRepresentationCachet_getCachedHeaderR((R*turitheader((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyR<„sN(t__name__t __module__t__doc__RR(R&R1R<(((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyRas    R;cBs)eZdZd„Zd„Zd„ZRS(s>A cache that can hold different representations of the same resource. If a resource has two representations with two media types, FileCache will only store the most recently fetched representation. This cache can keep track of multiple representations of the same resource. This class works on the assumption that outside calling code sets an instance's request_media_type attribute to the value of the 'Accept' header before initiating the request. This class is very much not thread-safe, but FileCache isn't thread-safe anyway. cCs)tt|ƒj||jƒd|_dS(s>Tell FileCache to call append_media_type when generating keys.N(R%R;R&tappend_media_typeR(trequest_media_type(R*R+((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyR&šs cCs-|jdk r#|d|j}nt|ƒS(s×Append the request media type to the cache key. This ensures that representations of the same resource will be cached separately, so long as they're served as different media types. t-N(RCR(R$(R*tkey((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyRB sc Cs~t|ƒ\}}}}|j|ƒ}|d}|dk rzx:t|ƒD])} | j|ƒrJ| t|ƒjƒSqJWndS(s+Retrieve a cached value for an HTTP header.t:N(RtgetR(Rt startswithRtstrip( R*R=R>tschemet authorityR5R:t cached_valuet header_starttline((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyR<¬s  (R?R@RAR&RBR<(((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyR;‹s  cBs•eZdZeƒZdZd d d d ed„Zd„Zd ddd d„Z d e d„Z d„Z d „Z d d „Zd „Zd d „ZRS(s6A class for making calls to lazr.restful web services.icCs}|dkr.tjƒ}tjtj|ƒnt|tƒrLt |ƒ}n|j ||||ƒ|_ ||_ ||_ dS(såInitialize, possibly creating a cache. If no cache is provided, a temporary directory will be used as a cache. The temporary directory will be automatically removed when the Python process exits. N(R(ttempfiletmkdtemptatexittregistertshutiltrmtreeRt basestringR;t httpFactoryt _connectiont user_agentt max_retries(R*t service_roott credentialsR+R,R-RXRY((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyR&¾s   c Cs•xˆtd|jdƒD]p}|jj|d|d|d|ƒ\}}|jd kr†||jkr†td|dƒ}t|ƒqPqW||fS( NiiR6R7R8iöi÷i(iöi÷(trangeRYRWtrequesttstatustintR( R*turlR6R7R8t retry_counttresponsetcontentt sleep_for((s?/usr/lib/python2.7/dist-packages/lazr/restfulclient/_browser.pyt_request_and_retryÐs ! tGETsapplication/jsonc CsJ|dkrtdƒ‚ni|d6}|jd k rG|j|ds,     "   +*-