gC^dZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddlm Z ddl mZddlmZddlmZmZmZmZmZmZddlmZmZmZmZmZdd lmZ ddl Z dd l!m"Z#d Z$ ddl'Z'ddl(Z'ddl)Z)d Z*Gd de+Z,dZ-Gddej\Z/Gdde/Z0Gdde/Z1dZ2Gdde0Z3Gdde0Z4Gdde1Z5Gdde#Z6y#e%$re&Z#d Z$YwxYw#e%$rd Z*YwxYw)a  Adapters are HTTP client implementations used by geocoders. Some adapters might support keep-alives, request retries, http2, persistence of Cookies, response compression and so on. Adapters should be considered an implementation detail. Most of the time you wouldn't need to know about their existence unless you want to tune HTTP client settings. .. versionadded:: 2.0 Adapters are currently provided on a `provisional basis`_. .. _provisional basis: https://docs.python.org/3/glossary.html#term-provisional-api Ntimeout)SSLError) HTTPError)urlparse) HTTPSHandler ProxyHandlerRequestURLError build_opener getproxies)GeocoderParseErrorGeocoderServiceErrorGeocoderTimedOutGeocoderUnavailable GeopyError)logger) HTTPAdapterTFc"eZdZdZfdZxZS)AdapterHTTPErrorzAn exception which must be raised by adapters when an HTTP response with a non-successful status code has been received. Base Geocoder class translates this exception to an instance of :class:`geopy.exc.GeocoderServiceError`. cN||_||_||_t||y)a; :param str message: Standard exception message. :param int status_code: HTTP status code. :param dict headers: HTTP response readers. A mapping object with lowercased or case-insensitive keys. .. versionadded:: 2.2 :param str text: HTTP body text. N) status_codeheaderstextsuper__init__)selfmessagerrr __class__s N/var/www/api/v1/venv_getwork_v1/lib/python3.12/site-packages/geopy/adapters.pyrzAdapterHTTPError.__init__Js('   !)__name__ __module__ __qualname____doc__r __classcell__rs@r rrAs""r!rcx |d}|sy|j} t|}|dkrd}|S#t$rYywxYw#t$rrtj j |}|tjd|Yytj j|}|tjz }YwxYw)zKReturn Retry-After header value in seconds. .. versionadded:: 2.2 z retry-afterNzInvalid Retry-After header: %sr) KeyErrorstripint ValueErroremailutils parsedate_tzrwarning mktime_tztime)r retry_aftersecondsretry_date_tuple retry_dates r get_retry_afterr7[sm,  ##%K +k"{ N5  + ;;33K@  # NN;[ I[[**+;< tyy{*+s"/ > ;;AB96B98B9cbeZdZdZdZdZejdZejdZ y) BaseAdapteraBase class for an Adapter. There are two types of adapters: - :class:`.BaseSyncAdapter` -- synchronous adapter, - :class:`.BaseAsyncAdapter` -- asynchronous (asyncio) adapter. Concrete adapter implementations must extend one of the two base adapters above. See :attr:`geopy.geocoders.options.default_adapter_factory` for details on how to specify an adapter to be used by geocoders. Tcy)apInitialize adapter. :param dict proxies: An urllib-style proxies dict, e.g. ``{"http": "192.0.2.0:8080", "https": "192.0.2.0:8080"}``, ``{"https": "http://user:passw0rd@192.0.2.0:8080""}``. See :attr:`geopy.geocoders.options.default_proxies` (note that Adapters always receive a dict: the string proxy is transformed to dict in the base :class:`geopy.geocoders.base.Geocoder` class.). :type ssl_context: :class:`ssl.SSLContext` :param ssl_context: See :attr:`geopy.geocoders.options.default_ssl_context`. N)rproxies ssl_contexts r rzBaseAdapter.__init__r!cy)aSame as ``get_text`` except that the response is expected to be a valid JSON. The value returned is the parsed JSON. :class:`geopy.exc.GeocoderParseError` must be raised if the response cannot be parsed. :param str url: The target URL. :param float timeout: See :attr:`geopy.geocoders.options.default_timeout`. :param dict headers: A dict with custom HTTP request headers. Nr;rurlrrs r get_jsonzBaseAdapter.get_jsonr>r!cy)ajMake a GET request and return the response as string. This method should not raise any exceptions other than these: - :class:`geopy.adapters.AdapterHTTPError` should be raised if the response was successfully retrieved but the status code was non-successful. - :class:`geopy.exc.GeocoderTimedOut` should be raised when the request times out. - :class:`geopy.exc.GeocoderUnavailable` should be raised when the target host is unreachable. - :class:`geopy.exc.GeocoderServiceError` is the least specific error in the exceptions hierarchy and should be raised in any other cases. :param str url: The target URL. :param float timeout: See :attr:`geopy.geocoders.options.default_timeout`. :param dict headers: A dict with custom HTTP request headers. Nr;r@s r get_textzBaseAdapter.get_textr>r!N) r"r#r$r% is_availablerabcabstractmethodrBrDr;r!r r9r9sG "L "        r!r9ceZdZdZdZdZy)BaseSyncAdapterz)Base class for synchronous adapters. c|SNr;rs r __enter__zBaseSyncAdapter.__enter__ r!cyrKr;rexc_typeexc_valexc_tbs r __exit__zBaseSyncAdapter.__exit__s r!N)r"r#r$r%rMrTr;r!r rIrIs r!rIceZdZdZdZdZy)BaseAsyncAdapterzYBase class for asynchronous adapters. See also: :ref:`Async Mode `. cK|SwrKr;rLs r __aenter__zBaseAsyncAdapter.__aenter__  c KywrKr;rPs r __aexit__zBaseAsyncAdapter.__aexit__s  sN)r"r#r$r%rXr\r;r!r rVrVs  r!rVcz| t}|siSi}|jD]\}}|r d|vrd|z}|||<|S)zNormalize user-supplied `proxies`: - For `None` -- retrieve System proxies using :func:`urllib.request.getproxies` - Add `http://` scheme to proxy urls if missing. z://z http://%s)r items)r< normalizedschemerAs r _normalize_proxiesrasY,  J}}  5##C 6' r!c:eZdZdZfdZdZdZdZdZxZ S) URLLibAdaptera~The fallback adapter which uses urllib from the Python standard library, see :func:`urllib.request.urlopen`. urllib doesn't support keep-alives, request retries, doesn't persist Cookies and is HTTP/1.1 only. urllib was the only available option for making requests in geopy 1.x, so this adapter behaves the same as geopy 1.x in terms of HTTP requests. ct|}t| ||tt |t |}|j |_y)Nr<r=)context)rarrr rr openurlopen)rr<r=openerrs r rzURLLibAdapter.__init__ sH$W- kB  -  ! {{ r!c|j|||} tj|S#t$rt d|zwxYwNrrz,Could not deserialize using deserializer: %s)rDjsonloadsr,r)rrArrrs r rBzURLLibAdapter.get_jsonsN}}S'7}C ::d# # $?$F  s +Act||} |j||}|j|}|j}|dk\rM|jj D cic]\}} |j | } }} td|z|| ||Scc} }w#t$r2} t| jrt| jdn t| } t| trr| j} | jj D cic]\}} |j | ncc} }w} }} |j| }t| | | |t| trd| vr t!dd | vrEt#d t| t$r t!dt| t&rd| vr t!dt)| d} ~ wwxYw) N)rArrNon-successful status code %srrrr timed outService timed out unreachablezService not available)r rh _decode_pagegetcoderr^lowerr Exceptionlenargsstr isinstancer_read_http_error_bodyr rr SocketTimeoutrr)rrArrreqpagerrnamevalueresponse_headerserrorrcodebodys r rDzURLLibAdapter.get_text's#w/) <<W<5D8$$T*D,,.Kc!(,||'9'9';$'; eJJL%'';!$'3kA +,  $= 0,/ Oc%**Q-(UG%+}}(-}}':':'<$'< eJJL%''<$ $11%8& $,  E8,')*+>??"g--.EFFE=1&':;;E8,')*+>??&w/ /3 0s+B%B G'A5GD87BGGcr |j|S#t$rtjddYywxYw)Nz7Unable to fetch body for a non-successful HTTP responseT)exc_info)rvryrdebug)rrs r r~z#URLLibAdapter._read_http_error_bodyVs> $$U+ +  LLITX   s  66c|jjxsd} |j} t ||S#t$r t dwxYw#t $r tdwxYw)Nzutf-8zUnable to read the response)encodingz#Unable to decode the response bytes)rget_content_charsetreadryrr|r,r)rrr body_bytess r rvzURLLibAdapter._decode_page_sz<<335@ FJ LzH5 5  F&'DE E F  L$%JK K Ls> AAA+) r"r#r$r%rrBrDr~rvr&r's@r rcrcs# #"-^ Lr!rccVeZdZdZeZdddddfd ZdZdZd Z d Z d Z d Z xZ S) RequestsAdapteraThe adapter which uses `requests`_ library. .. _requests: https://requests.readthedocs.io `requests` supports keep-alives, retries, persists Cookies, allows response compression and uses HTTP/1.1 [currently]. ``requests`` package must be installed in order to use this adapter. The requests' ``trust_env`` value is set to false, meaning that environment doesn't affect the requests' configuration. The ``ssl_context`` and ``proxies`` settings can be used for configuration. .. versionchanged:: 2.4 This adapter used to use the `certifi` CA bundle by default, if an ``ssl_context`` wasn't provided explicitly. This has been changed to use the system CA store by default. Fpool_connections pool_maxsize max_retries pool_blockc ts tdt|}|tj}t |||tj|_ d|j_ ||j_ |jjdt|||||jjdt|||||y)Nz`requests` must be installed in order to use RequestsAdapter. If you have installed geopy via pip, you may use this command to install requests: `pip install "geopy[requests]"`.reFzhttp://rzhttps://)r=rrrr)requests_available ImportErrorrasslcreate_default_contextrrrequestsSessionsession trust_envr<mountRequestsHTTPAdapter!RequestsHTTPWithSSLContextAdapter)rr<r=rrrrrs r rzRequestsAdapter.__init__s"3  %W-  446K kB'') !& &    !1)'%      -'!1)'%   r!c|SrKr;rLs r rMzRequestsAdapter.__enter__rNr!c8|jjyrKrcloserPs r rTzRequestsAdapter.__exit__s r!cdt|dd}| |jyy#t$rYywxYw)Nr)getattrr TypeErrorrrs r __del__zRequestsAdapter.__del__sA$ 40       s # //cB|j|||}|jSNrl)_requestrrrArrresps r rDzRequestsAdapter.get_texts }}S'7}Cyyr!c|j|||} |jS#t$rtd|jzwxYwrk)rrmr,rrrs r rBzRequestsAdapter.get_jsonsO}}S'7}C 99;  $?$))K  s &"Acf |jj|||}|jdk\r:td|jz|j|j|j |S#t $r}t|}t|tr tdt|trd|vrrtdt|tjr(d|jvr t|t!|t|tj"r tdt|d}~wwxYw)Nrlrprqrrrtrs unauthorized)rgetrrrrryr|r}rrrrConnectionErrorrxrrTimeout)rrArrrrrs r rzRequestsAdapter._requests <<##C'#JD"3&&3d6F6FF $ 0 0 LL  1 0%jG%/&':;;E8,')*+>??E8#;#;<!W]]_4.w77-g66E8#3#34&':;;&w/ / 0sA++ D04B7D++D0)r"r#r$r%rrErrMrTrrDrBrr&r's@r rrlsA&&L9 v r!rc~eZdZdZeZfdZedZdZ dZ dZ dZ dZ d Zej d ZxZS) AioHTTPAdapteraThe adapter which uses `aiohttp`_ library. .. _aiohttp: https://docs.aiohttp.org/ `aiohttp` supports keep-alives, persists Cookies, allows response compression and uses HTTP/1.1 [currently]. ``aiohttp`` package must be installed in order to use this adapter. c|ts tdt|}t|||||_||_y)Nz`aiohttp` must be installed in order to use AioHTTPAdapter. If you have installed geopy via pip, you may use this command to install aiohttp: `pip install "geopy[aiohttp]"`.re)aiohttp_availablerrarrr<r=)rr<r=rs r rzAioHTTPAdapter.__init__ sE 2  %W- kB &r!c|jjd}|&tjdd}||jd<|S)NrF)rraise_for_status)__dict__raiohttp ClientSessionrs r rzAioHTTPAdapter.sessionsH --##I. ?++!&G(/DMM) $r!cK|SwrKr;rLs r rXzAioHTTPAdapter.__aenter__'rYrZcTK|jjd{y7wrKrrPs r r\zAioHTTPAdapter.__aexit__*s ll  """s (&(cbK|j5|j|||4d{}|j|d{|jd{cdddd{cdddS7O787"7#1d{7swYnxYw dddy#1swYyxYwwr)_normalize_exceptionsr_raise_for_statusrrs r rDzAioHTTPAdapter.get_text1s  ' ' )}}S'7}KKt,,T222!YY[(LKK* )K2(LKKKK* ) )sB/B#A<B#BA>BBB! B#-B.B#2 B/<B#>BBB#B B  B B# B/#B,(B/c K|j5|j|||4d{}|j|d{ |jd{cdddd{cdddS7Q7:7"7#tj j $rJtj|jd{7cYcdddd{7cdddSwxYw#t$r&td|jd{7zwxYw#1d{7swYnxYw dddy#1swYyxYwwrk) rrrrmrclient_exceptionsContentTypeErrorrnrr,rrs r rBzAioHTTPAdapter.get_json7s  ' ' )}}S'7}KKt,,T222 =%)YY[0 LKK* )K2 1 L #44EE= $zz *;*;<<LKK* ) =",G!%,,.LKKK* ) )sE EA>ED"BD" BB B# E/B0E4 E >ED"BE?C-C C-C0 ECE" E ,C--C00"DD DD""D4 (D+)D4 0E8 E E E cK|jdk\rFtd|jz|j|j|jd{y7 w)Nrprqrr)statusrrr)rrs r rz AioHTTPAdapter._raise_for_statusHsO ;;# "/$++= KK 99;&    'sA AA Ac|jr?t|j}|jj|j }nd}t j |d}|jj|||||jS)NT)encoded)rrproxyr) r<rr`rrxyarlURLrr=)rrArrr`rs r rzAioHTTPAdapter._requestQsv <<c]))FLL$$V\\^4EE hhsD)|| 'DDTDT   r!c#^K dy#tttf$rt$r}t |}t |t jr tdt |trd|vr0tdt |tjr t|t|d}~wwxYww)Nrtrs)rrAssertionErrorryr|r}asyncio TimeoutErrorrrrClientConnectionErrorrr)rrrs r rz$AioHTTPAdapter._normalize_exceptionsas 0 ,n=   0%jG%!5!56&':;;E8,')*+>??E7#@#@A)'22&w/ / 0s%B- B-B*A?B%%B**B-)r"r#r$r%rrErpropertyrrXr\rDrBrr contextlibcontextmanagerrr&r's@r rrs`%L '  #) " 00r!rcHeZdZddfd ZfdZfdZdZfdZxZS)rN)r=c @||_d|_t| di|y)NFr;)/_RequestsHTTPWithSSLContextAdapter__ssl_context2_RequestsHTTPWithSSLContextAdapter__urllib3_warnedrr)rr=kwargsrs r rz*RequestsHTTPWithSSLContextAdapter.__init__us#( % "6"r!cx|j|j|d<|jt| |i|SNr=)r7_RequestsHTTPWithSSLContextAdapter__warn_if_old_urllib3rinit_poolmanager)rr{rrs r rz2RequestsHTTPWithSSLContextAdapter.init_poolmanagerzsB    )%)$6$6F= !  & & (w'888r!c z|j|j|d<|jt| |fi|Sr)rrrproxy_manager_for)rr proxy_kwargsrs r rz3RequestsHTTPWithSSLContextAdapter.proxy_manager_fors@    )*.*<*.silent_ints" 1v   s c3.K|] }|ywrKr;).0vrs r zJRequestsHTTPWithSSLContextAdapter.__warn_if_old_urllib3..sN/M! 1 /Ms.)rzurllib3 prior to 1.24.2 is known to have a bug with custom ssl contexts: it attempts to load system certificates to them. Please consider upgrading `requests` and `urllib3` packages. See https://github.com/urllib3/urllib3/pull/1566) rrequests.packages.urllib3packagesurllib3rtuple __version__splitwarningswarn UserWarning)rrversionrs @r __warn_if_old_urllib3z7RequestsHTTPWithSSLContextAdapter.__warn_if_old_urllib3s   $  7 7  Nw/B/B/H/H/MNN Z  MMM      s A11 BBc|t||||||jd|_d|_d|_d|_yyrK)r cert_verifyrca_certs ca_cert_dir cert_filekey_file)rconnrAverifycertrs r rz-RequestsHTTPWithSSLContextAdapter.cert_verifysD D#vt4    ) DM#D !DN DM *r!) r"r#r$rrrrrr&r's@r rrts%&*# 9@ 8!!r!r)7r%rFrrr-rmrr2rsocketrrr urllib.errorr urllib.parserurllib.requestrr r r r r geopy.excrrrrr geopy.utilrrrequests.adaptersrrrrobjectraiohttp.client_exceptionsrrIOErrorrr7ABCr9rIrVrarcrrrr;r!r rs!  +"!D $ "w"4$NJ #''J Z k   {  4hLOhLVOoOdr0%r0l7!(;7!C s$ C$-C3$ C0/C03C=<C=