AF[i ddlZddlZddlmZddlZddlZddlmZmZddl m Z m Z m Z m Z mZmZmZddlZdZeZdedefdZd ed eedefd Zdd efd Zed edeefdZd edefdZGddej:Z dded eedzdej>edzdzdej@fdZ!y)N)Path) lru_cachewraps)Any AwaitableCallable CoroutineLiteralTTuplecttjdz }t|d5}|j j cdddS#1swYyxYw)Nz version.txtr)r__file__parentopenreadstrip) version_filefs [/var/www/html/chatbot/moweb-chatbot/venv/lib/python3.12/site-packages/safehttpx/__init__.py get_versionr sG>((=8L lC  Avvx~~   s AAipreturnc tj|}|jxs6|jxs(|jxs|j xs |j S#t$rYywxYw)NF) ipaddress ip_address is_private is_loopback is_link_local is_multicast is_reserved ValueError)rip_objs r is_public_ipr$sz %%b)    "!! "## """ "!!    sAA A('A(hostnamedomain_whitelistc|r|sy|j}|D]N}|s|j}|jdr!|dd}||k(s|jd|zsFy||k(sNyy)NFz*..T)lower startswithendswith)r%r&domainsuffixs rmatches_domain_whitelistr/ s| +~~H"     T "ABZF6!X%6%6sV|%D    maxsizecdtdttttffdtdttfffd }|S)N async_func.rc ttdtdtdttffd }|S)N)r1argskwargsrc:tj|i|SN)asyncio create_task)r5r6r3s rwrapperz3lru_cache_async..decorator..wrapper5s &&z4'B6'BC Cr0)rrrrr )r3r;r1s` r decoratorz"lru_cache_async..decorator2sN 7 # z  D3 D# D)A, D  $ Dr0)rr rr r)r1r<s` rlru_cache_asyncr=1sCS)CaK"889 #y|# $ r0c Ktj4d{} |jd|dd{}|jd|dd{}g}|j|jfD]4}|j |jdgDcgc]}|d c}6|cdddd{S777tcc}w7#t $rgcYcdddd{7SwxYw#1d{7swYyxYww)Nz https://dns.google/resolve?name=z&type=Az &type=AAAAAnswerdata)httpx AsyncClientgetjsonextend Exception)r%client response_v4 response_v6ipsresponseanswers rasync_resolve_hostname_googlerM?s  "f  & 28*GD!K!' 28*JG!KC(--/1A1A1CD V hPR9STvF6NTU V U I sD CD C7CC CC AC C + C5 D CD  C C CD  C4C7 D ,C/-D 3C44C77D =D >D D cK tj}|j|dd{}|D]?\}}}}}|d}|tj tjfvs1t|s=|cSt|d{D]}t|s|cSt d|d7~#tj$r}t d|d||d}~wwxYw7Vw)NzUnable to resolve hostname z: rz Hostname z failed validation) r9get_event_loop getaddrinfosocketgaierrorr"AF_INETAF_INET6r$rM)r%loopaddrinfoefamily_sockaddrrs rasync_validate_urlr[RsO%%'))(D99&.!1aa[ fnnfoo6 6< ;S  :(CC  #  y *<= >>: ??O6xj1#FGQNODsUC)B.B,B.2C% C1CCCC,B..CCCCcneZdZdeffd Zdej deee e ejfffd Z xZ S)AsyncSecureTransport verified_ipc0||_t| yr8)r^super__init__)selfr^ __class__s rrazAsyncSecureTransport.__init__fs& r0requestrcK|j}|j}|j|j}||_||jd<d|i|_t ||d{S7w)N)hostHost sni_hostname)urlrf copy_withr^headers extensionsr`handle_async_request)rbrd original_url original_hostnew_urlrcs rrmz)AsyncSecureTransport.handle_async_requestjsn{{ $)) ((d.>.>(? "/,m<W1'::::sA&A0)A.*A0) __name__ __module__ __qualname__strrarARequestr intbytesHeadersrm __classcell__)rcs@rr]r]esAC ; ; sE5%--/ 0 ; ;r0r]ri _transportFcKtj|}|j}|std|d|g}|r|}n1|dus t ||rd}nt |d{}t |}tj|4d{}|j|fddi|d{cdddd{S7\7477 #1d{7swYyxYww)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) rAURLrfr"r/r[r]rBrC) rir&rzr6 parsed_urlr%r|r^rGs rrCrCvs"3JH 4u$CDEE u  8CS T .x88 (5   95GGVZZFeFvFFGGG9GFGGGGslACB< )C B> C C&C'C* C6C7C>CCCC C CC))NN)"r9rpathlibrrQos functoolsrrtypingrrrr r r r rAr __version__rtboolr$listr/rvr=rMr[AsyncHTTPTransportr]AsyncBaseTransportResponserCr0rrs &III  m  S T sd3iD" S #$s)$?s?s?&;533;&*.CG!G !G3i$&!G((75>9D@!G  ^^ !Gr0