Pi ddlZddlZddlmZddlZddlZddlmZmZddl m Z m Z m Z m Z mZmZmZddlZdZeZdedefdZd ed eedefd Zdd efdZed edeefdZd edefdZGddejZ dded eedzdejedzdzdej fdZ!dS)N)Path) lru_cachewraps)Any AwaitableCallable CoroutineLiteralTTuplecttjdz }t|d5}|cdddS#1swxYwYdS)Nz version.txtr)r__file__parentopenreadstrip) version_filefs f/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/safehttpx/__init__.py get_versionr s>>(=8L lC  Avvxx~~                  s&A  A$'A$ipreturnc tj|}|jp|jp|jp |jp|j S#t$rYdSwxYw)NF) ipaddress ip_address is_private is_loopback is_link_local is_multicast is_reserved ValueError)rip_objs r is_public_ipr$s{ %b))   "! "# "" "!    uus7: AAhostnamedomain_whitelistc|r|sdS|}|D]c}|s|}|dr,|dd}||ks|d|zrdSZ||krdSddS)NFz*..T)lower startswithendswith)r%r&domainsuffixs rmatches_domain_whitelistr/ s +u~~H"       T " " ABBZF6!!X%6%6sV|%D%D!tt"   44 5maxsizecdtdttttffdtdttfffd }|S)N async_func.rc ttdtdtdttffd }|S)N)r2argskwargsrc8tj|i|SN)asyncio create_task)r6r7r4s rwrapperz3lru_cache_async..decorator..wrapper5s%&zz4'B6'B'BCC Cr0)rrrrr )r4r<r2s` r decoratorz"lru_cache_async..decorator2sv 7 # # # z   D3 D# D)A, D D D D D   $ # Dr0)rr rr r)r2r=s` rlru_cache_asyncr>1s\S)CaK"889 #y|# $ r0c Ktj4d{V} |d|dd{V}|d|dd{V}g}||fD]5}|d|dgD6|cdddd{VS#t $rgcYcdddd{VSwxYw#1d{VswxYwYdS)Nz https://dns.google/resolve?name=z&type=Az &type=AAAAcg|] }|d S)data).0answers r z1async_resolve_hostname_google..LsTTTvF6NTTTr0Answer)httpx AsyncClientgetjsonextend Exception)r%client response_v4 response_v6ipsresponses rasync_resolve_hostname_googlerR?s* ""f  & D8DDD!!K!' G8GGG!!KC(--//1A1A1C1CD V V TThPR9S9STTTUUUU   II s/C4BC C1C40C11C44 C>C>cK tj}||dd{V}n-#tj$r}t d|d||d}~wwxYw|D]=\}}}}}|d}|tjtjfvrt|r|cS>t|d{VD]}t|r|cSt d|d)NzUnable to resolve hostname z: rz Hostname z failed validation) r:get_event_loop getaddrinfosocketgaierrorr"AF_INETAF_INET6r$rR)r%loopaddrinfoefamily_sockaddrrs rasync_validate_urlr`RsBO%''))(D99999999 ?OOOFxFF1FFGGQNO&.!1aa[ fnfo6 6 6< ;S;S 6   9(CCCCCCCC  # #      ==== > >>s/4AAAc`eZdZdeffd Zdejdeee e ej fffd Z xZ S)AsyncSecureTransport verified_ipcV||_tdSr9)rcsuper__init__)selfrc __class__s rrfzAsyncSecureTransport.__init__fs'& r0requestrcK|j}|j}||j}||_||jd<d|i|_t |d{VS)N)hostHost sni_hostname)urlrk copy_withrcheaders extensionsrehandle_async_request)rgri original_url original_hostnew_urlrhs rrrz)AsyncSecureTransport.handle_async_requestjs{{ $) ((d.>(?? "/,m<WW11':::::::::r0) __name__ __module__ __qualname__strrfrGRequestr intbytesHeadersrr __classcell__)rhs@rrbrbesC ; ; sE5%-/ 0 ; ; ; ; ; ; ; ; ; ;r0rbrn _transportFcKtj|}|j}|std|d|g}|r|}n;|dust ||rd}n$t |d{V}t |}tj|4d{V}|j|fddi|d{Vcdddd{VS#1d{VswxYwYdS)a< This is the main function that should be used to make async HTTP GET requests. It will automatically use a secure transport for non-whitelisted domains, unless a proxy is set in the environment variables (HTTP_PROXY, HTTPS_PROXY, http_proxy, https_proxy). Parameters: - url (str): The URL to make a GET request to. - domain_whitelist (list[str] | None): A list of domains to whitelist, which will not use a secure transport. Supports wildcard subdomains with "*.domain.com" format (asterisk must be at the beginning). - _transport (httpx.AsyncBaseTransport | Literal[False] | None): A custom transport to use for the request. Takes precedence over domain_whitelist. Set to False to use no transport. - **kwargs: Additional keyword arguments to pass to the httpx.AsyncClient.get() function. zURL z does not have a valid hostnameNF) transportfollow_redirects) rGURLrkr"r/r`rbrHrI) rnr&rr7 parsed_urlr%rrcrMs rrIrIvs"3JH FDDDDEEE6 u   8CS T T  .x88888888 (55  9555GGGGGGGVZFFeFvFFFFFFFFGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGsB;; CC)r1)NN)"r:rpathlibrrVos functoolsrrtypingrrrr r r r rGr __version__ryboolr$listr/r{r>rRr`AsyncHTTPTransportrbAsyncBaseTransportResponserIrBr0rrs  &&&&&&&&IIIIIIIIIIIIIIIIII    kmm  S T    sd3iD"  S    #$s)$?s?s????&;;;;;53;;;&*.CG!G!G !G3i$&!G(75>9D@!G  ^ !G!G!G!G!G!Gr0