`Wa- @ s d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z
d d l Z d d l m
Z
y$ d d l m Z d d l m Z Wn2 e k
r d d l m Z d d l m Z Yn Xy d d l Z e j Z Wn4 e e f k
r&d Z Gd d d e Z Yn Xy
e Z Wn( e k
r[Gd
d d e Z Yn Xd d l m Z m Z m Z m Z d d
l! m" Z" m# Z# d d l$ m% Z% m& Z& m' Z' m( Z( d d l) m* Z* d d l+ m, Z, e j- e. Z/ d d d d i Z0 e j1 d d d Z2 Gd d d e3 Z4 Gd d d e e3 Z Gd d d e Z5 Gd d d e5 Z6 d d Z7 e re5 Z8 e6 Z5 n e4 Z5 d S) )absolute_importN)errortimeout )six)HTTPConnection)
HTTPExceptionc @ s e Z d Z d S) BaseSSLErrorN)__name__
__module__ __qualname__ r
r
/connection.pyr s r c @ s e Z d Z d S)ConnectionErrorN)r
r r r
r
r
r r s r )NewConnectionErrorConnectTimeoutErrorSubjectAltNameWarningSystemTimeWarning)match_hostnameCertificateError)resolve_cert_reqsresolve_ssl_versionssl_wrap_socketassert_fingerprint)
connection)HTTPHeaderDicthttpP httpsi i c @ s e Z d Z d Z d S)DummyConnectionz-Used to detect a failed ConnectionCls import.N)r
r r __doc__r
r
r
r r B s r c @ s e Z d Z d Z e d Z e j e j d f g Z d Z
d d Z d d Z d d
Z
d d Z d
d
d d Z d
S)r a{
Based on httplib.HTTPConnection but provides an extra constructor
backwards-compatibility layer between older and newer Pythons.
Additional keyword parameters are used to configure attributes of the connection.
Accepted parameters include:
- ``strict``: See the documentation on :class:`urllib3.connectionpool.HTTPConnectionPool`
- ``source_address``: Set the source address for the current connection.
.. note:: This is ignored for Python 2.6. It is only applied for 2.7 and 3.x
- ``socket_options``: Set specific options on the underlying socket. If not specified, then
defaults are loaded from ``HTTPConnection.default_socket_options`` which includes disabling
Nagle's algorithm (sets TCP_NODELAY to 1) unless the connection is behind a proxy.
For example, if you wish to enable TCP Keep Alive in addition to the defaults,
you might pass::
HTTPConnection.default_socket_options + [
(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1),
]
Or you may want to disable the defaults by passing an empty list (e.g., ``[]``).
r r Fc O sy t j r | j d d | j d | _ t j d k rJ | j d d | j d | j | _ t j
| | | d S)Nstrictsource_address socket_options)r# r$ ) r ZPY3popgetr" sys version_infodefault_socket_optionsr% _HTTPConnection__init__)selfargskwr
r
r r, k s zHTTPConnection.__init__c C s i } | j r | j | d <| j r2 | j | d <y( t j | j | j f | j | } Wn{ t k
r } z$ t | d | j | j f WYd d } ~ Xn8 t k
r } z t
| d | WYd d } ~ Xn X| S)zp Establish a socket connection and set nodelay settings on it.
:return: New socket connection.
r" r% z0Connection to %s timed out. (connect timeout=%s)Nz(Failed to establish a new connection: %s) r" r% r create_connectionhostportr
SocketTimeoutr SocketErrorr )r- Zextra_kwconner
r
r _new_conn s
"(#zHTTPConnection._new_connc C s2 | | _ t | d d r. | j d | _ d S)N _tunnel_hostr )sockgetattr_tunnel auto_open)r- r5 r
r
r
_prepare_conn s
z HTTPConnection._prepare_connc C s | j } | j | d S)N)r7 r= )r- r5 r
r
r connect s zHTTPConnection.connectNc C so t | d k r | n i } d | k } | j | | d | x* | j D] \ } } | j | | qM Wd | k r | j d d | j | d k r^t j t j f } t | | r | f } x | D] } | s q t | t j s| j d } t
t | d d }
| j |
j d | j d
| j | | j d
q W| j d d S) z
Alternative to the common request method, which sends the
body with chunked encoding and not as one block
Nzaccept-encodingskip_accept_encodingztransfer-encodingzTransfer-EncodingZchunkedutf8r# zutf-8s
s 0
)
r Z
putrequestitemsZ putheaderZ
endheadersr Z string_typesZ binary_type
isinstanceencodehexlensend) r- methodZurlZbodyZheadersr? headervalueZstringish_typeschunkZlen_strr
r
r request_chunked s.
z HTTPConnection.request_chunked)r
r r r port_by_scheme default_portsocket IPPROTO_TCP TCP_NODELAYr* is_verifiedr, r7 r= r> rK r
r
r
r r G s
r c @ sD e Z d Z e d Z d d d d e j d d Z d d Z d S)HTTPSConnectionr Nc K sA t j | | | d | d | | | | _ | | _ d | _ d S)Nr! r r )r r, key_file cert_fileZ _protocol)r- r1 r2 rS rT r! r r/ r
r
r r, s
zHTTPSConnection.__init__c C s; | j } | j | t j | | j | j | _ d S)N)r7 r= sslZ wrap_socketrS rT r9 )r- r5 r
r
r r> s
zHTTPSConnection.connect) r
r r rL rM rN _GLOBAL_DEFAULT_TIMEOUTr, r> r
r
r
r rR s
rR c @ sa e Z d Z d Z d Z d Z d Z d Z d Z d d d d d d d d d Z d d Z
d S)VerifiedHTTPSConnectionz[
Based on httplib.HTTPSConnection but wraps the socket with
SSL certification.
Nc C s | s | r | d k r d } | | _ | | _ | | _ | | _ | | _ | o` t j j | | _ | o{ t j j | | _ d S)N
CERT_REQUIRED)
rS rT cert_reqsassert_hostnamer ospath
expanduserca_certs ca_cert_dir)r- rS rT rY r^ rZ r r_ r
r
r set_cert s z VerifiedHTTPSConnection.set_certc C s | j } t | j } t | j } | j } t | d d rj | | _ | j d | _ | j
} t j j
t k } | r t j d j t t t | | j | j d | d | j d | j d | d | | _ | j rt | j j d d
| j nn | t j k rv| j d k rv| j j } | j d f s`t j d
j | t t | | j pr| | t j k p| j d k | _! d S)Nr8 r zWSystem time is way off (before {0}). This will probably lead to SSL verification errorsrY r^ r_ Zserver_hostname ssl_versionZ binary_formTFZsubjectAltNamezCertificate for {0} has no `subjectAltName`, falling back to check for a `commonName` for now. This feature is being removed by major browsers and deprecated by RFC 2818. (See https://github.com/shazow/urllib3/issues/497 for details.))"r7 r rY r ra r1 r: r9 r; r< r8 datetimedateZtoday RECENT_DATEwarningswarnformatr r rS rT r^ r_ r Z getpeercertrU Z CERT_NONErZ r' r _match_hostnamerX rQ )r- r5 Zresolved_cert_reqsZresolved_ssl_versionhostnameZ is_time_offcertr
r
r r> sF
z VerifiedHTTPSConnection.connect) r
r r r rY r^ r_ ra r r` r> r
r
r
r rW s
rW c C s\ y t | | WnD t k
rW } z$ t j d | | | | _ WYd d } ~ Xn Xd S)Nz@Certificate did not match expected hostname: %s. Certificate: %s)r r logr Z
_peer_cert)rj Zasserted_hostnamer6 r
r
r rh 7 s
rh )9Z
__future__r rb loggingr[ r( rN r r4 r r3 re Zpackagesr Z http.clientr r+ r ImportErrorhttplibrU ZSSLErrorr AttributeError
BaseExceptionr NameError Exception
exceptionsr r r r Zpackages.ssl_match_hostnamer r Z util.ssl_r r r r utilr _collectionsr getLoggerr
rk rL rc rd objectr rR rW rh ZUnverifiedHTTPSConnectionr
r
r
r <module> sT
"" V