⚝
One Hat Cyber Team
⚝
Your IP:
216.73.217.4
Server IP:
41.128.143.86
Server:
Linux host.raqmix.cloud 6.8.0-1025-azure #30~22.04.1-Ubuntu SMP Wed Mar 12 15:28:20 UTC 2025 x86_64
Server Software:
Apache
PHP Version:
8.3.23
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
httplib2
/
__pycache__
/
View File Name :
__init__.cpython-310.pyc
o ݀a @ s d Z dZdZg dZdZdZddlZddlZddlZddl Z ddl Z ddl m Z ddl Z ddl Z ddlZdd lmZ ddlZdd lmZ dd lmZ ddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddl!Z!ddl"Z#ddl$Z$zddl%Z%W n e&y d d l'm%Z% Y nw d dl'm(Z( d dl)T d dl*m*Z* dd Z+g dZ,dZ-dZ.dZ/g dZ0dZ1e2dZ3ddl4m5Z5 e56 Z7e8e ddpe8e dZ9 ddd d Z:d d Z;d d! Z<e =d"Z>d#d$ Z?d%d& Z@e =d'ZAe =d(e jBZCd)d* ZDe =d+ZEd,d- ZFd.d/ ZGd0d1 ZHdZId2d3 ZJd4d5 ZKd6d7 ZLd8d9 ZMd:d; ZNd<d= ZOG d>d? d?ePZQG d@dA dAeQZRG dBdC dCeQZSG dDdE dEeQZTG dFdG dGeQZUG dHdI dIeQZVeReUeSeTeVdJZWg dKZXG dLdM dMePZYG dNdO dOePZZG dPdQ dQeZZ[G dRdS dSePZ\G dTdU dUePZ]dedWdXZ^dfdYdZZ_G d[d\ d\ej`jaZbG d]d^ d^ej`jcZdebedd_ZeG d`da daePZfG dbdc dcegZhdS )gz+Small, fast HTTP client library for Python.z!Joe Gregorio (joe@bitworking.org)z Copyright 2006, Joe Gregorio) !Thomas Broyer (t.broyer@ltgt.net)z James AntillzXavier Verges FarrerozJonathan Feinbergz Blair ZajaczSam RubyzLouis Nyffeneggerz Mark PilgrimzAlex YuZMITz0.20.2 N)header)gettext)md5)sha1 )socks)auth)*)iri2uric C s$ t tdr| d uo | tjuS | d uS )N_GLOBAL_DEFAULT_TIMEOUT)hasattrsocketr )timeout r 3/usr/lib/python3/dist-packages/httplib2/__init__.py has_timeout9 s r ) debuglevelFailedToDecompressContentHttpZ HttpLib2Error ProxyInfo RedirectLimitRedirectMissingLocationResponseRETRIES"UnimplementedDigestAuthOptionError&UnimplementedHmacDigestAuthOptionError ) connectionz keep-alivezproxy-authenticatezproxy-authorizationteZtrailerstransfer-encodingZupgrade)GETHEADZOPTIONSZTRACE), - . / i3 4 )certsZ PROTOCOL_TLSZPROTOCOL_SSLv23c C s t tds tdtt}| rtjntj|_|d ur3t |dr/t|t r+t tj |}||_ ntd|d urOt |drKt|t rGt tj |}||_ ntdt |drX| |_|| |rf|||| |S )N SSLContextz0httplib2 requires Python 3.2+ for ssl.SSLContextmaximum_versionzHsetting tls_maximum_version requires Python 3.7 and OpenSSL 1.1 or newerminimum_versionzHsetting tls_minimum_version requires Python 3.7 and OpenSSL 1.1 or newercheck_hostname)r ssl RuntimeErrorr* DEFAULT_TLS_VERSIONZ CERT_NONEZ CERT_REQUIREDZ verify_mode isinstancestrgetattrZ TLSVersionr+ r, r- Zload_verify_locationsZload_cert_chain)"disable_ssl_certificate_validationca_certs cert_filekey_filer+ r, key_passwordcontextr r r _build_ssl_context s, r: c sD t t dd | dddD fddt | D S )Nc S g | ]}| qS r strip.0xr r r <listcomp> z(_get_end2end_headers.<locals>.<listcomp>r ,c s g | ]}| vr|qS r r )r? r Zhopbyhopr r rA )list HOP_BY_HOPextendgetsplitkeys)responser rE r _get_end2end_headers s "rN c C sj t | jdkrt| jd tjr| jd jS | jS t| dr3| j}t|jd tjr0|jd jS |jS d S )Nr socket_err)lenargsr1 r errorerrnor rO )eZe_intr r r _errno_from_exception s $ $rU z9^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?c C s0 t | }|d |d |d |d |d fS )zParses a URI using the regex given in Appendix B of RFC 3986. (scheme, authority, path, query, fragment) = parse_uri(uri) r )URImatchgroups)urir\ r r r parse_uri s "r^ c C sx t | \}}}}}|r |std| | }| }|s d}|r(d||gp)|}| }|d | | }||||fS )Nz(Only absolute URIs are allowed. uri = %s/?z://)r^ ZRelativeURIErrorlowerjoin)r] scheme authoritypathqueryfragment request_uri defrag_urir r r urlnorm s rj z^\w+://z[^\w\-_.()=!]+c C sb t | tr | }| d} n| d}t| }td| } td| } | dd } d | |fS )zReturn a filename suitable for the cache. Strips dangerous and common characters to create a filename we can use to store the cache in. utf-8rC NZ rD ) r1 bytesdecodeencode_md5 hexdigest re_url_schemesub re_unsaferb )filenameZfilename_bytesZfilemd5r r r safename s rv z(?:\r\n)?[ \t]+c C s t dd | D S )Nc S s0 g | ]\}}t | tt |d fqS ) )_convert_byte_strra NORMALIZE_SPACErs r= )r? keyvaluer r r rA s z&_normalize_headers.<locals>.<listcomp>)dictitemsheadersr r r _normalize_headers s r c C s t | ts t| dS | S Nrk )r1 r2 )sr r r rx s rx c C sF i }d| v r!| d d}dd |D }dd |D }t|| }|S )N cache-controlrD c S s4 g | ]}d | dkrtdd |ddD qS )=c S s g | ]}| qS r )r= ra r> r r r rA rF z3_parse_cache_control.<locals>.<listcomp>.<listcomp>r )findtuplerK )r? partr r r rA s z(_parse_cache_control.<locals>.<listcomp>c S s* g | ]}d | dkr| dfqS )r r r )r r= ra )r? namer r r rA s * )rK r| )r retvalpartsZparts_with_argsZ parts_wo_argsr r r _parse_cache_control s r c C s d}t |}t | }d|v r%|d ddkr%d}d|vr#d|d< |S d|v r-d}|S d|v r5d}|S d|v r=d}|S d | v rttj| d }t }t d || }d |v rozt |d }W n+ t yn d }Y n!w d | v rtj| d } d | krd }n t d t| | }nd }d |v rzt |d }W n t y d }Y nw d|v rzt |d } W n t y d } Y nw || 7 }||krd}|S )a Determine freshness from the Date, Expires and Cache-Control headers. We don't handle the following: 1. Cache-Control: max-stale 2. Age: headers are not used in the calculations. Not that this algorithm is simpler than you might think because we are operating as a private (non-shared) cache. This lets us ignore 's-maxage'. We can also ignore 'proxy-invalidate' since we aren't a proxy. We will never return a stale document as fresh as a design decision, and thus the non-implementation of 'max-stale'. This also lets us safely ignore 'must-revalidate' since we operate as if every server has sent 'must-revalidate'. Since we are private we get to ignore both 'public' and 'private' parameters. We also ignore 'no-transform' since we don't do any transformations. The 'no-store' parameter is handled at a higher level. So the only Cache-Control parameters we look at are: no-cache only-if-cached max-age min-fresh STALEZpragmazno-cacher TRANSPARENTr only-if-cachedFRESHdater zmax-ageexpiresNz min-fresh) r ra r calendarZtimegmemailZutilsZ parsedate_tztimemaxint ValueError) response_headersrequest_headersr cc cc_responser ZnowZ current_ageZfreshness_lifetimer Z min_freshr r r _entry_disposition& sb %#! r c C s |}z<| dd }|dv r<|dkr tjt|d }|dkr(t|tj }t t || d< | d | d< | d= W |S W |S t tj fyW d}t td | d | |w ) Ncontent-encoding)gzipdeflater )Zfileobjr content-lengthz-content-encodingrC zDContent purported to be compressed with %s but failed to decompress.)rJ r ZGzipFileioBytesIOreadzlib decompress MAX_WBITSr2 rP IOErrorrR r _)rM new_contentcontentencodingr r r _decompressContentq s, r c s fdd}|S )Nc s D ]4\}}td| d| jd t|tjr%t|j| jd| jd qtj|| jd|d}t| | jd qt| jd d S )Nz%s:rw )endfile) maxlinelen)r rk )r charsetZ header_name)r} print_fpr1 r ZHeaderro Z _maxheaderlen)selfhvr msgr r _write_headers s z+_bind_write_headers.<locals>._write_headersr )r r r r r _bind_write_headers s r c C sH |rt | }t |}d|v sd|v r|| d S tj }| D ] \}} |dvr.| ||< q"|dd } | r\| dd d} | D ]} d| }z| | ||< W qD t y[ Y qDw |j } | dkred } d | }z| }W n t y t|d t| | }Y nw td d |}d|d|d|g}||| d S d S )Nzno-store)statusr r! varyrw rC rD -varied-%s0 z status: %d r z (?! )|(?<! ) z rk )r deleter messageMessager} rJ ra replacerK KeyErrorr Z as_stringUnicodeEncodeErrorsetattrr rers rb ro set)r r r cachecachekeyr r inforz r{ r vary_headersr r Z status_headerZ header_strtextr r r _updateCache sD r c C s8 t dt dd tdD f d } | d d S )N%s:%sc S s g | ] }d t dd qS ) 0123456789r )randomZ randrange)r? ir r r rA s z_cnonce.<locals>.<listcomp> rk )rp r ctimerangero rq )digr r r _cnonce s " r c C s, t td| ||f d dS )Nz%s%s%srk )base64 b64encode_sharo digestr= rn )cnonceiso_nowpasswordr r r _wsse_username_token s *r c @ sl e Zd Zdd Zdd Zdd Zdd Zd d Zd d Zd d Z dd Z dd Z dd Z dd Z dd ZdS )Authenticationc C s. t |\}} } } } | | _|| _|| _|| _d S N)r^ re host credentialshttp) r r r rh r rM r r rc rd re rf rg r r r __init__ s zAuthentication.__init__c C s* t |\}}}}}|t| jd dS )Nr_ )r^ rP re count)r rh rc rd re rf rg r r r depth s zAuthentication.depthc C s( t |\}}}}}|| jko|| jS r )r^ r startswithre )r r rh rc rd re rf rg r r r inscope s zAuthentication.inscopec C dS )znModify the request headers to add the appropriate Authorization header. Over-rise this in sub-classes.Nr r methodrh r r r r r request s zAuthentication.requestc C r )a Gives us a chance to update with new nonces or such returned from the last authorized response. Over-rise this in sub-classes if necessary. Return TRUE is the request is to be retried, for example Digest may return stale=true. Fr )r rM r r r r rM s zAuthentication.responsec C r NFr r r r r r __eq__ zAuthentication.__eq__c C r NTr r r r r __ne__ r zAuthentication.__ne__c C r r r r r r r __lt__ r zAuthentication.__lt__c C r r r r r r r __gt__ r zAuthentication.__gt__c C r r r r r r r __le__ r zAuthentication.__le__c C r r r r r r r __ge__ r zAuthentication.__ge__c C r r r r r r r __bool__ r zAuthentication.__bool__N)__name__ __module__ __qualname__r r r r rM r r r r r r r r r r r r s r c @ e Zd Zdd Zdd ZdS )BasicAuthenticationc C t | ||||||| d S r r r r r r rh r rM r r r r r r z BasicAuthentication.__init__c C s, dt d| j d d |d< dS )OModify the request headers to add the appropriate Authorization header.zBasic r rk authorizationN)r r r ro r= rn r r r r r s zBasicAuthentication.requestNr r r r r r r r r r s r c @ s* e Zd ZdZdd Zd ddZdd ZdS ) DigestAuthenticationzMOnly do qop='auth' and MD5, since that is all Apache currently implementsc C s t | ||||||| t|dd | _| jdd}ddd | D v r)dp*d | jd< | jd d u r=ttd| | jdd | jd< | jd d kr[ttd | jd d | j d d | jd d | j d g| _ d| jd< d S )Nwww-authenticater qopr c S r; r r< r> r r r rA # rB z1DigestAuthentication.__init__.<locals>.<listcomp>z Unsupported value for qop: %s. algorithmMD5$Unsupported value for algorithm: %s.rC r :realmr nc) r r r _parse_www_authenticate challengerJ rK r r upperrb r A1) r r r rh r rM r r r r r r r s $(z DigestAuthentication.__init__Nc s dd fdd}d |d|g}|pt | jd< d| | jd| jd d | jd | jd | jd |f }d | jd | jd | jd || jd || jd | jd | jd f |d< | jdrr|d d| jd 7 < | jd d7 < dS )Modify the request headersc S s t | d S r )rp ro rq )r@ r r r <lambda>0 s z.DigestAuthentication.request.<locals>.<lambda>c s d| |f S )Nr r )r dHr r r 1 s rC r r z"%s"%s:%s:%s:%s:%snoncez%08xr r zoDigest username="%s", realm="%s", nonce="%s", uri="%s", algorithm=%s, response=%s, qop=%s, nc=%08x, cnonce="%s"r r r r Zopaquez , opaque="%s"r N)rb r r r r rJ ) r r rh r r r ZKDZA2request_digestr r r r . s< z DigestAuthentication.requestc C sz d|vr%t |ddi }d|dkr#|d | jd< d| jd< d S d S t |d}d |v r;|d | jd< d| jd< d S ) Nzauthentication-infor r truestaler r r TZ nextnonceF)r r rJ r Z_parse_authentication_info)r rM r r Zupdated_challenger r r rM R s z DigestAuthentication.responser )r r r __doc__r r rM r r r r r s $r c @ s, e Zd ZdZdZdd Zdd Zdd Zd S ) HmacDigestAuthenticationz@Adapted from Robert Sayre's code and DigestAuthentication above.r c C s t | ||||||| t|d}|d | _| jdd| jd< | jd dvr-d| jd< | jdd| jd< | jdsCttd | jd d | jd < | jd d vr_ttd | jd | jdd| jd< | jd dvr{ttd| jd | jd dkrt| _ nt | _ | jd dkrt| _ nt | _ d | j d d| j d | j d | jd g d| jd g| _| j | j | _d S )Nr hmacdigestreason unauthorized)r$ integrityZsaltrC snoncezCThe challenge doesn't contain a server nonce, or this one is empty.r HMAC-SHA-1)r' HMAC-MD5r z pw-algorithmSHA-1)r) r z'Unsupported value for pw-algorithm: %s.r( r r r r r )r r r r r rJ r r rp hashmodr Z pwhashmodrb r newrq ra rz ) r r r rh r rM r r r r r r r g sH ( z!HmacDigestAuthentication.__init__c s t }ddd |D }d fdd|D }tdt }t } d||| | jd |f } t| j | | j } d| j d | jd | jd | ||| |f d < d S ) r rC c S s g | ]}d | qS )z%s r r? kr r r rA rB z4HmacDigestAuthentication.request.<locals>.<listcomp>c s g | ]} | qS r r r, r~ r r rA rB %Y-%m-%dT%H:%M:%SZr r& zsHMACDigest username="%s", realm="%s", snonce="%s", cnonce="%s", uri="%s", created="%s", response="%s", headers="%s"r r r N)rN rb r strftimegmtimer r hmacr+ rz r* rq ra r ) r r rh r r rL ZkeylistZ headers_valZcreatedr r r r~ r r s$ z HmacDigestAuthentication.requestc C s* t |ddi }|ddv rdS dS )Nr r" r# )r% r TF)r r rJ )r rM r r r r r rM s z!HmacDigestAuthentication.responseN)r r r r __author__r r rM r r r r r! b s * r! c @ e Zd ZdZdd Zdd ZdS )WsseAuthenticationa This is thinly tested and should not be relied upon. At this time there isn't any third party server to test against. Blogger and TypePad implemented this algorithm at one point but Blogger has since switched to Basic over HTTPS and TypePad has implemented it wrong, by never issuing a 401 challenge but instead requiring your client to telepathically know that their endpoint is expecting WSSE profile="UsernameToken".c C r r r r r r r r r zWsseAuthentication.__init__c C sN d|d< t dt }t }t||| jd }d| jd |||f |d< dS ) r z WSSE profile="UsernameToken"r r. r zJUsernameToken Username="%s", PasswordDigest="%s", Nonce="%s", Created="%s"r zX-WSSEN)r r/ r0 r r r )r r rh r r r r Zpassword_digestr r r r s zWsseAuthentication.requestN)r r r r r r r r r r r4 s r4 c @ r )GoogleLoginAuthenticationc C s ddl m} t| ||||||| | |d} | d dd} | dkr-|ddkr-d} t|d |d | |d d } | jj d d || ddid\} }| d} tdd | D }| j dkrcd| _ d S |d | _ d S )Nr ) urlencoder googleloginserviceZxapir Zclr user-agent)ZEmailZPasswdr8 sourcez+https://www.google.com/accounts/ClientLoginZPOSTz Content-Typez!application/x-www-form-urlencoded)r bodyr c S s g | ] }|rt |d dqS )r r )r rK )r? liner r r rA s z6GoogleLoginAuthentication.__init__.<locals>.<listcomp>i rC Auth) urllib.parser6 r r r rJ r r| r r rK r r> )r r r rh r rM r r r6 r r r8 Zresplinesr r r r r s$ z"GoogleLoginAuthentication.__init__c C s d| j |d< dS )r zGoogleLogin Auth=r N)r> r r r r r s z!GoogleLoginAuthentication.requestNr r r r r r5 s r5 )basicwsser r" r7 )r" r7 r rB rA c @ s4 e Zd ZdZefddZdd Zdd Zdd Zd S ) FileCachezUses a local directory as a store for cached files. Not really safe to use if multiple threads or processes are going to be running on the same cache. c C s, || _ || _tj|st| j d S d S r )r safeosre existsmakedirs)r r rD r r r r s zFileCache.__init__c C sP d }t j| j| |}zt|d}| }| W |S ty' Y |S w )Nrb) rE re rb r rD openr closer )r rz r cacheFullPathfr r r rJ s z FileCache.getc C s6 t j| j| |}t|d}|| | d S )Nwb)rE re rb r rD rI writerJ )r rz r{ rK rL r r r r s z FileCache.setc C s4 t j| j| |}t j|rt | d S d S r )rE re rb r rD rF remove)r rz rK r r r r s zFileCache.deleteN) r r r r rv r rJ r r r r r r rC s rC c @ s. e Zd Zdd Zd ddZdd Zdd Zd S ) Credentialsc C g | _ d S r r r r r r r zCredentials.__init__rC c C s | j | ||f d S r r appendra r r r domainr r r add s zCredentials.addc C rQ r rR r r r r clear# rS zCredentials.clearc c s2 | j D ]\}}}|dks||kr||fV qd S NrC rR )r rW cdomainr r r r r iter& s zCredentials.iterNrC )r r r r rX rY r\ r r r r rP s rP c @ r3 )KeyCertszNIdentical to Credentials except that name/password are mapped to key/cert.c C s | j | |||f d S r rT r rz certrW r r r r rX 0 r z KeyCerts.addc c s6 | j D ]\}}}}|dks||kr|||fV qd S rZ rR )r rW r[ rz r` r r r r r\ 3 s z KeyCerts.iterN)r r r r rX r\ r r r r r^ , s r^ c @ s e Zd ZdS )AllHostsN)r r r r r r r ra 9 s ra c @ sH e Zd ZdZdZ dddZdd Zd d Zd d Zd d Z dd Z dS )r z,Collect information required to use a proxy.r TNc C sV t |tr | }t |tr| }|||||||f\| _| _| _| _| _| _| _ dS )a Args: proxy_type: The type of proxy server. This must be set to one of socks.PROXY_TYPE_XXX constants. For example: p = ProxyInfo(proxy_type=socks.PROXY_TYPE_HTTP, proxy_host='localhost', proxy_port=8000) proxy_host: The hostname or IP address of the proxy server. proxy_port: The port that the proxy server is running on. proxy_rdns: If True (default), DNS queries will not be performed locally, and instead, handed to the proxy to resolve. This is useful if the network does not allow resolution of non-local names. In httplib2 0.9 and earlier, this defaulted to False. proxy_user: The username used to authenticate with the proxy server. proxy_pass: The password used to authenticate with the proxy server. proxy_headers: Additional or modified headers for the proxy connect request. N) r1 rm rn proxy_type proxy_host proxy_port proxy_rdns proxy_user proxy_pass proxy_headers)r rb rc rd re rf rg rh r r r r B s( zProxyInfo.__init__c C s | j | j| j| j| j| j| jfS r )rb rc rd re rf rg rh r r r r astuplel s zProxyInfo.astuplec C s t o | jd ko | jd kS r )r rc rd r r r r isgoodw s zProxyInfo.isgoodc C s | | S r ) bypass_host)r hostnamer r r applies_toz s zProxyInfo.applies_toc C sX | j tu rdS d|d }| j D ]}|dr ||r dS |d| kr) dS qdS )z1Has this host been excluded from the proxy configT.F) bypass_hostsra lstripr endswith)r rl Z skip_namer r r rk } s zProxyInfo.bypass_hostc C s dj | dS )Nz<ProxyInfo type={p.proxy_type} host:port={p.proxy_host}:{p.proxy_port} rdns={p.proxy_rdns} user={p.proxy_user} headers={p.proxy_headers}>)p)formatr r r r __repr__ s zProxyInfo.__repr__)TNNN) r r r r ro r ri rj rm rk rt r r r r r = s * r r c C sD | dvrdS | d }t j|t j| }|sdS t|| ddS )z4Read proxy info from the environment variables. r httpsN_proxy)noproxy)rE environrJ r proxy_info_from_url)r Zenv_varurlr r r proxy_info_from_environment s r| c C s t j| } d}d}d}d| d v r,| d dd\}}d|v r)|dd\}}n|}n| d }d|v r=|dd\}}n|}|rFt|}ntddd| }d} t| |||pWd|pZddd } g } |du rptj d tj d d }|d krwt } n| r|d} t t t| } | | _| S )zBConstruct a ProxyInfo from a URL (such as http_proxy env var) N@r r i P )rv r rV )rb rc rd rf rg rh Zno_proxyZNO_PROXYrC r rD )urllibparseZurlparserK r r| r rE ry rJ ra r= r filterboolro ) r{ r rx Zusernamer portZidentZ host_portr rb Zpiro r r r rz sF rz c @ s" e Zd ZdZdddZdd ZdS )HTTPConnectionWithTimeoutag HTTPConnection subclass that supports timeouts HTTPConnection subclass that supports timeouts All timeouts are in seconds. If None is passed for timeout then Python's default timeout for sockets will be used. See for example the docs of socket.setdefaulttimeout(): http://docs.python.org/library/socket.html#socket.setdefaulttimeout Nc C s@ t jjj| |||d || _|r t|ts |d| _d S d S d S )N)r r r )r clientHTTPConnectionr proxy_infor1 r )r r r r r r r r r s z"HTTPConnectionWithTimeout.__init__c C s | j r tdu r td| j r-| j r-| j | jr-d}| j \}}}}}}}|} |} n d}| j} | j} d}d} t | | dtj D ]} | \} }}}}zf|rbt | ||| _ | j |||||| nt| ||| _ | j tjtjd t| jr| j | j | jdkrtd| j| j |rtdt||||||f | j | j| jf|d d W n@ tjy } z3|} | jdkrtd | j| j |rtd t||||||f | j r| j d| _ W Y d}~qBd}~ww | j s| dS ) z3Connect to the host and port specified in __init__.Nz2Proxy support missing but proxy use was requested!TFr r z connect: ({0}, {1}) ************zproxy: {0} ************r connect fail: ({0}, {1}) proxy: {0})r r ZProxiesUnavailableErrorrj rm r ri r r getaddrinfo SOCK_STREAM socksocketsocksetproxy setsockopt IPPROTO_TCP TCP_NODELAYr r settimeoutr r rs r2 connectrR rJ )r use_proxyrb rc rd re rf rg rh r r rO resafsocktypeproto canonnameZsarT r r r r sz $ z!HTTPConnectionWithTimeout.connect)NNN)r r r r r r r r r r r s r c s> e Zd ZdZ d fdd Zdd Z ZS ) HTTPSConnectionWithTimeouta- This class allows communication via SSL. All timeouts are in seconds. If None is passed for timeout then Python's default timeout for sockets will be used. See for example the docs of socket.setdefaulttimeout(): http://docs.python.org/library/socket.html#socket.setdefaulttimeout NFc sz || _ |r|nt| _|| _|rt|ts|d| _t| j | j||| | | d} tt| j |||| d || _ || _ | | _ d S )Nrv )r+ r, r8 )r r r9 ) r4 CA_CERTSr5 r r1 r r: superr r r7 r6 r8 ) r r r r7 r6 r r r5 r4 tls_maximum_versiontls_minimum_versionr8 r9 __class__r r r 3 s( z#HTTPSConnectionWithTimeout.__init__c C s | j r"| j r"| j | jr"d}| j \}}}}}}}|} |} n d}| j} | j} d}d}d} t| | dtj} | D ]\} }}}}z|rXt | ||}| |||||| nt| ||}| tj tjd t| jrs|| j || j| jf | jj|| jd| _t| jds| jsz t| j | j W n ty | j tj | j w | j dkrt d!| j| j |rt d !t"||||||f W np tj#tj$fy } z|r| | jr| j d| _ d}~w tjtj%fy tj&yA } z6|} | j dkr+t d !| j| j |r+t d !t"||||||f | jr4| j d| _W Y d}~q;d}~ww | jsI| dS ) z(Connect to a host on a given (SSL) port.TFNr r )Zserver_hostnamer- zconnect: ({0}, {1})r r )'r rj rm r ri r r r r r r r r r r r r r r Z_contextZ wrap_socketr r r4 r. Zmatch_hostnameZ getpeercert ExceptionZshutdownZ SHUT_RDWRrJ r r rs r2 ZSSLErrorZCertificateErrorgaierrorrR )r r rb rc rd re rf rg rh r r rO Z address_infoZfamilyr r r Zsockaddrr rT r r r r Y s z"HTTPSConnectionWithTimeout.connect) NNNNNNFNNN)r r r r r r __classcell__r r r r r * s &r ru c @ s e Zd ZdZddeddddfddZdd Zdd Zd d Zd d Z d ddZ d ddZ dd Z dd Z dd Zdd Zdddedfd d ZdS ) r zAn HTTP client that handles: - all methods - caching - ETags - compression, - HTTPS - Basic - Digest - WSSE and more. NFc C s || _ || _|| _|| _|| _i | _|r t|tr t|| _ n|| _ t | _ t | _ g | _d| _t| _ddg| _tt| _d| _d| _d| _|| _d| _dS )a If 'cache' is a string then it is used as a directory name for a disk cache. Otherwise it must be an object that supports the same interface as FileCache. All timeouts are in seconds. If None is passed for timeout then Python's default timeout for sockets will be used. See for example the docs of socket.setdefaulttimeout(): http://docs.python.org/library/socket.html#socket.setdefaulttimeout `proxy_info` may be: - a callable that takes the http scheme ('http' or 'https') and returns a ProxyInfo instance per request. By default, uses proxy_info_from_environment. - a ProxyInfo instance (static proxy config). - None (proxy disabled). ca_certs is the path of a file containing root CA certificates for SSL server certificate validation. By default, a CA cert file bundled with httplib2 is used. If disable_ssl_certificate_validation is true, SSL cert validation will not be performed. tls_maximum_version / tls_minimum_version require Python 3.7+ / OpenSSL 1.1.0g+. A value of "TLSv1_3" requires OpenSSL 1.1.1+. TZPUTZPATCHFN)r r5 r4 r r connectionsr1 r2 rC r rP r r^ certificatesauthorizationsfollow_redirectsREDIRECT_CODESredirect_codes optimistic_concurrency_methodsrG SAFE_METHODS safe_methodsfollow_all_redirects ignore_etag force_exception_to_status_coder forward_authorization_headers)r r r r r5 r4 r r r r r r s* $ z Http.__init__c C s> | j i }| _ | D ]\}}| q | j | dS )zClose persistent connections, clear sensitive data. Not thread-safe, requires external synchronization against concurrent requests. N)r r} rJ r rY clear_credentials)r existingr cr r r rJ s z Http.closec C s, t | j}d|v r |d= d|v r|d= |S )Nr r )copy__dict__)r Z state_dictr r r __getstate__$ s zHttp.__getstate__c C s | j | i | _d S r )r updater )r stater r r __setstate__. s zHttp.__setstate__c c sP t |d}| j|D ]}tD ]}||v r$t| ||||||| V qq dS )zcA generator that creates Authorization objects that can be applied to requests. r N)r r r r\ AUTH_SCHEME_ORDERAUTH_SCHEME_CLASSES) r r rh r rM r Z challengesZcredrc r r r _auth_from_challenge2 s zHttp._auth_from_challengerC c C s | j ||| dS )z]Add a name and password that will be used any time a request requires authentication.N)r rX rV r r r add_credentials< s zHttp.add_credentialsc C s | j |||| dS )zXAdd a key and cert that will be used any time a request requires authentication.N)r rX r_ r r r add_certificateA s zHttp.add_certificatec C s | j g | _dS )zKRemove all the names and passwords that are used for authenticationN)r rY r r r r r r F s zHttp.clear_credentialsc C s d}d}|t k r |d7 }z|jd u r| ||||| W nv tjy- | tjy? | td|j tj yb } zt |} | t j t jfv r]|t k r]W Y d }~q d }~w tjjy |jd u r|t d k r| | Y q| |t d k r| | Y qY nw z| } W nL tjjtjjfy |s|dkrd}d}| | Y q| tjy tj tjjfy | |dkr| | Y q w d} |dkr| n| } t| } |dkrt| | } | | fS | | fS )Nr Fr z Unable to find the server at %sTr r# )r r r r r r rJ r ZServerNotFoundErrorr rR rU rS Z ENETUNREACHZ EADDRNOTAVAILr r Z HTTPExceptionZ getresponseZ BadStatusLineZResponseNotReadyr r r ) r connrh r r; r r Zseen_bad_status_linerT Zerrno_rM r r r r _conn_requestL s zHttp._conn_requestc s fdd| j D } | rt| d d pd} | r!| ||| | ||||\} } | rJ| | |rJ| ||| | ||||\} } d| _| jdkr| || | D ](}|||| | ||||\} } | jdkr| j | || | nqX| j s|| j v s| jdv ri| j rK| j| j v rK|rEd| vr| jd krt td | | d| v r| d }t|\}}}}}|dkrtj||| d< | jd ks| jd kr|| j v r| d | d < d| vr|| d< t|| | | j| d|v r|d= d|v r|d= d|v r | js |d= d| v rA| d }t| }d|vr$||d< |}| jdv r0d}d}| j|||||d d\} } || _| | fS td| | | jdv ri|| j v rid| vr`|| d< t|| | | j| | | fS )zmDo the actual request using the connection object and also follow one level of redirects if necessaryc s& g | ]}| r||fqS r )r r )r? r r rh r r rA s & z!Http._request.<locals>.<listcomp>r r Ni )r' r( locationr$ z:Redirected but the response is missing a Location: header.r( r% -x-permanent-redirect-urlzcontent-location if-none-matchif-modified-sincer )r& r' r" )r r; r redirections4Redirected more times than redirection_limit allows.)r )r sortedr r rM _stale_digestr r rU r r r r r r r^ r r Zurljoinr r r r Zdeepcopypreviousr )r r r Z absolute_urirh r r; r r r Zauthsr rM r r r rc rd re rf rg Z old_responseredirect_methodr r r _request s z Http._requestc C s t |S r )r )r r r r r r s zHttp._normalize_headersr" c ! C sh d}z|du r i }n| |}d|vrdt |d< t|}|ddddd d }t|\}} } } |d | }| j|} | du r|sJt| }t| j | } t |t r| r|| | d d | d d | j | j| j| j| j| j| d d d } | j|< n%|| | j | j| j| j| j| jd } | j|< n|| | j | jd } | j|< | t d|vrd|vrd|d< tj }d}d}| jr| }| j|}|rz0|dd \}}t|}| D ] \}}| dr| dr| |t tj !|d qW n t"t#fy | j$| d}d}Y nw || j%v r2| jr2d|v r2| j&s2d|vr2|d |d< | jrE|rE|| j'vrE| j$| || j'v rzd|v rz|d }|( ddd}|D ]}d | }|| }||d|krxd} nqa| jrs|rs|| j'v s|d d krsd|vrs|}|d d vrd }d!|v r|d krt)d"i d| j*|d! |||d d#\}}t+||_,d$|j,_-nat.||} | d%kr|sd&|d < d'}t+|}|rd$|_-||fW S | d(krd|v r| j&sd)|vr|d |d)< d*|v rd*|vr|d* |d+< n| d,kr | /| | || ||||| \}}|j0d-kra|d krat1|D ] }|| ||< q7t+|} t2|d.rO|j3| _3t4|| || j| | }d/|_0d$|_-n?|j0d/krj|}n;| j$| |}n(t5|} d0| v rd&|d < t+|}d'}n#| /| | || ||||| \}}W ||fS W ||fS W ||fS W ||fS W ||fS t6y3 } zxt7| t8j } | r| j9|d} | r| : | j;rt7| t<r| j=}| j>}d1|_0t | |_?n6t7| t8j rd2}t+d3d4t@|d5}d6|_?n(t | Ad7}t+d3d8t@|d5}d9|_?n W Y d} ~ ||fS W Y d} ~ ||fS W Y d} ~ ||fS d} ~ ww ):a Performs a single HTTP request. The 'uri' is the URI of the HTTP resource and can begin with either 'http' or 'https'. The value of 'uri' must be an absolute URI. The 'method' is the HTTP method to perform, such as GET, POST, DELETE, etc. There is no restriction on the methods allowed. The 'body' is the entity body to be sent with the request. It is a string object. Any extra headers that are to be sent with the request should be provided in the 'headers' dictionary. The maximum number of redirect to follow before raising an exception is 'redirections. The default is 5. The return value is a tuple of (response, content), the first being and instance of the 'Response' class, the second being a string that contains the response entity body. rC Nr9 zPython-httplib2/%s (gzip)rw z%20 z%0Dr< z%0Ar r r r ) r7 r6 r r r5 r4 r r r8 )r r r5 r4 r r )r r r zaccept-encodingz gzip, deflates z=?z?=Zetagzif-matchr rD r r 308)Z307r r" r r )r r r Tr Z504r r r z last-modifiedr r r r r r i s Request Timeoutz text/plainZ408)z content-typer r zRequest Timeoutrk Z400z Bad Request)Br __version__r r rj r rJ SCHEME_TO_CONNECTIONrG r r\ issubclassr r r r5 r4 r r Zset_debuglevelr r r r r rK Zmessage_from_bytesr} r rq Zreplace_headerr2 r Z decode_header IndexErrorr r r r r ra r r r r fromcacher r r rN r r r r r r1 r poprJ r ZHttpLib2ErrorWithResponserM r r# rP ro )!r r] r r; r r Zconnection_typeZconn_keyrc rd rh ri r r) r r Z cached_valuer r- r r r r rz r{ r rM r Zentry_dispositionZmerged_responser rT Z is_timeoutr r r r s #)& z Http.requestr] r )r r r r r| r rJ r r r r r r r r r DEFAULT_MAX_REDIRECTSr r r r r r s, S JO r c @ s< e Zd ZdZ dZ dZ dZ dZdZdd Z d d Z dS ) r z<An object more like email.message than httplib.HTTPResponse.F r ZOkNc C s t |tjjr=| D ] \}}| }| |}|d ur#d||f}|| |< q |j| _t | j| d< |j | _ |j | _ d S t |t j jr^t| D ] \}}|| | < qJt| d | _d S | D ] \}}|| | < qbt| d| j| _d S )Nz, r )r1 r r Z HTTPResponseZ getheadersra rJ rb r r2 r# versionr r r rG r} r )r r rz r{ prevr r r r s$ zResponse.__init__c C s |dkr| S t |)Nr| )AttributeError)r r r r r __getattr__ s zResponse.__getattr__) r r r r r r r r# r r r r r r r r s r )NNNNN)r )r N)ir r2 Z __copyright__Z__contributors__Z __license__r r r r r Zemail.feedparserr Z email.messageZ email.utilsrS r r r Zhashlibr rp r r r1 Z http.clientr r rE r r r r. sysr r? r r r ImportErrorrC r rR r r __all__r r r rH r frozensetr Zhttplib2r) wherer r3 r0 r: rN rU compilerZ r^ rj rr ASCIIrt rv ry r rx r ZUSE_WWW_AUTH_STRICT_PARSINGr r r r r r objectr r r r! r4 r5 r r rC rP r^ ra r r| rz r r r ZHTTPSConnectionr r r r| r r r r r <module> s - K*6 GN$# W 2W '