o .jA @sPUdZddlmZddlZdZded<zddlmZmZm Z m Z ddl m Z d d l mZWn8eyed d lmZzddlZWneyOed eYnwd dlmZmZmZmZmZdZescYnwesddlZddlmZddlmZd dlmZm Z d dl!m"Z"m#Z#d dl$m%Z%d dl&m'Z'd dl(m)Z)d dl*m+Z+m,Z,d dl-m.Z.m/Z/d dl0m1Z1d dlm2Z2m3Z3d dl4m5Z5d dl6m7Z7Gddde+ZGdd d ee,ZGd!d"d"e.ZGd#d$d$e/ZGd%d&d&e5ZGd'd(d(eZ8Gd)d*d*e8e Z9Gd+d,d,e"Z:Gd-d.d.e#Z;Gd/d0d0e%Z z+SOCKSConnection._new_conn..rr:r>quic_upgrade_via_dns_rr timing_hookignore)_socketConnection to  timed out. (connect timeout=)&Failed to establish a new connection: )r:r>lenappendlowerr'r int _resolvercreate_connectionrwarningscatch_warnings simplefilterDeprecationWarningconnectrGrH SocketTimeoutrr!rrr"OSError) r3extra_kwonly_tcp_optionsoptprotocolprWsocker6rPr7 _new_conn{s            (   zSOCKSConnection._new_connr'rr(r)r*r)r+r,)r+r__name__ __module__ __qualname____doc__r1rp __classcell__r6r6r4r7rm rc@ eZdZdS)rNrsrtrur6r6r6r7rrc@eZdZeZdS)rN)rsrtrur ConnectionClsr6r6r6r7rrc@r|)rN)rsrtrurr}r6r6r6r7rr~rc6eZdZdZeedZ    ddfdd ZZS)rt A version of the urllib3 ProxyManager that routes connections via the defined SOCKS proxy. httphttpsN proxy_urlstrrB str | NonerC num_poolsr_headerstyping.Mapping[str, str] | Noneconnection_pool_kwr)c  t|}|dur!|dur!|jdur!|jd}t|dkr!|\}}|jdkr,tj} d} n(|jdkr7tj} d} n|jdkrBtj} d} n|jdkrMtj} d} ntd |||_ | |j |j ||| d } | |d <d |vrot |d <|d  tjtj||fi|tj|_dS N:r socks5Fsocks5hTsocks4socks4az'Unable to determine SOCKS version from )rAr?r@rBrCrDr' disabled_svn)r$authsplitr\schemerSOCKS5SOCKS4 ValueErrorrrGrHsetaddrh3r0r1rpool_classes_by_scheme r3rrBrCrrrparsedrrArD socks_optionsr4r6r7r1@         zSOCKSProxyManager.__init__NNrN rrrBrrCrrr_rrrr)) rsrtrurvrrrr1rwr6r6r4r7rrcr%)AsyncSOCKSConnectionr&r'rr(r)r*r+r,cr-r.r/r2r4r6r7r1r8zAsyncSOCKSConnection.__init__r c si}jr j|d<jr@g}jD](}t|dkr!||qt|dkr;|d}|dkr2q||ddq||d<z`jddusJJjddusSJtjd jdtjdjd jd jd d }jj jdtjdfj j|ddfdddIdH}| j j j |IdHWSttfy}ztdj dj d|d}~wttfy}z td||d}~wty}z td||d}~ww)r9r:r;r<r=Nr>r?r@rArBrCrDrEFcrIrJrLrNrPr6r7rQMrRz0AsyncSOCKSConnection._new_conn..rSrXrYrZr[)r:r>r\r]r^r'r r_r`rarrfrGrHrgrr!rrr"rh)r3rirjrkrlrmrWror6rPr7rp!s               zAsyncSOCKSConnection._new_connrq)r+r rrr6r6r4r7rrxrc@ry)AsyncSOCKSHTTPSConnectionNrzr6r6r6r7rjr{rc@r|)AsyncSOCKSHTTPConnectionPoolN)rsrtrurr}r6r6r6r7rmr~rc@r|)AsyncSOCKSHTTPSConnectionPoolN)rsrtrurr}r6r6r6r7rpr~rcr)AsyncSOCKSProxyManagerrrNrrrrBrrCrr_rrrr)c  rr)r$rrr\rrrrrrrGrHrrrrr0r1rrrr4r6r7r1~rzAsyncSOCKSProxyManager.__init__rr) rsrtrurvrrrr1rwr6r6r4r7rsrr)rrrrr)rrrrr)>rv __future__rrbr__annotations__ python_socksrrrrpython_socks.syncr _socks_overrider ImportError exceptionsr sockswarn _socks_legacyrrrrrtypingrrrg_async.connectionrr_async.connectionpoolrr_async.poolmanagerr_typingrbackendr connectionrrconnectionpoolrr contrib.ssar r!r" poolmanagerr#util.urlr$rrrrr__all__r6r6r6r7sj (               _>W?