U @f @sdZddlZddlZddlZddlZddlmZddlmZddlmZddlm Z ddlm Z ddlm Z d d Z e d Z e d e _e jjd ddge jjD]Zee jee deqe jjjD]Zee jjee deqe jjjD]Zee jjee deqe jD](Zedkr&qee ee deq[ eZdZdZeejdZeejdZeZejdd dkre!edreej"dZddZ#dd Z$d!d"Z%d#d$Z&e!e j'd%rd&d'Z(nd(d'Z(Gd)d*d*e j)j*Z+Gd+d,d,Z,Gd-d.d.Z-e-e,d/Z)ej.d0dd0fd1d2Z/d3d4Z0d5d6Z1d7d8Z2dNd9d:Z3d;d<Z4d=d>Z5d?d@Z6dAdBZ7dCdDZ8ze j9j:dd0dEWn6e j9j;k rd0ZedGddddFdFdfdJdKZ?dLdMZ@e?e j'_?e>e j'_>dS)Oz1greendns - non-blocking DNS support for Eventlet N)patcher) _socket_nodns)os)time)select)sslcCstttttd}tj|f|S)N)rrrsocketr)rrrrrrimport_patched) module_namemodulesr S/var/www/html/chatgpt/venv/lib/python3.8/site-packages/eventlet/support/greendns.pyr 0sr dnsz dns.rdtypesZ dnskeybaseZdsbaseZtxtbasez dns.rdtypes.zdns.rdtypes.IN.zdns.rdtypes.ANY.rdtypeszdns.g$@zLookup timed outzName or service not knownZEVENTLET_DEPRECATED_EAI_NODATA)1yyes EAI_NODATA#No address associated with hostnamecCs|j|jdSN) __class__args)Zerror_instancer r r _raise_new_errorcsrcCsBt|tsdSztj|Wntjjk r8YdSXdSdS)z+Return True if host is a valid IPv4 addressFTN) isinstancestrrZipv4 inet_aton exception SyntaxErrorhostr r r is_ipv4_addrgs r!cCsRt|tsdS|ddd}ztj|Wntjjk rHYdSXdSdS)z+Return True if host is a valid IPv6 addressF%rTN)rrsplitripv6rrrrr r r is_ipv6_addrss r&cCst|pt|S)z3Return True if host is a valid IPv4 or IPv6 address)r!r&rr r r is_ip_addrsr'_compute_expirationcCs ||Sr)r(querytimeoutr r r compute_expirationsr,cCs||dS)Nr#)Z_compute_timesr)r r r r,sc@seZdZdZdddZdS) HostsAnswerz%Answer class for HostsResolver objectTcCsXd|_||_||_||_||_|s0|r0tj||_t |drNt |j nd|_ dS)a^Create a new answer :qname: A dns.name.Name instance of the query name :rdtype: The rdatatype of the query :rdclass: The rdataclass of the query :rrset: The dns.rrset.RRset with the response, must have ttl attribute :raise_on_no_answer: Whether to raise dns.resolver.NoAnswer if no answer. Nttlr) responseqnamerdtyperdclasscanonical_namerresolverNoAnswerrrsethasattrrr. expiration)selfr0r1r2r6raise_on_no_answerr r r __init__s  zHostsAnswer.__init__N)T)__name__ __module__ __qualname____doc__r;r r r r r-sr-c@s`eZdZdZedejZdefddZ ddZ dd Z e j je jjd dd fd d ZddZdS) HostsResolverzClass to parse the hosts file Attributes ---------- :fname: The filename of the hosts file in use. :interval: The time between checking for hosts file modification z \s* # Leading space ([^\r\n#]*?) # The actual match, non-greedy so as not to include trailing space \s* # Trailing space (?:[#][^\r\n]+)? # Comments (?:$|[\r\n]+) # EOF or newline NcCshi|_i|_i|_||_||_|dkrPtjdkr8d|_ntjdkrPtjd|_d|_ |jrd| dS)Nposixz /etc/hostsntz'%SystemRoot%\system32\drivers\etc\hostsr) _v4_v6_aliasesintervalfnamernamepath expandvars _last_load_load)r9rGrFr r r r;s  zHostsResolver.__init__c Cs\z$t|jd}|}W5QRXWntk r<gYSX|jdd}td|j|S)zRead the contents of the hosts file Return list of lines, comment lines and empty lines are excluded. Note that this performs disk I/O so can be blocking. rbignore)errorsN)openrGreadOSErrordecodefilterLINES_REfindall)r9fpfdataZudatar r r _readliness  zHostsResolver._readlinescCs|}|j|j|j|D]}|}t|dkrDq*|d}t|r^|j}nt |r*| drrq*|j}nq*|d }|||<|D]}| }|||<||j|<qq*t |_ dS)zjLoad hosts file This will unconditionally (re)load the data from the hosts file. rZfe80N)rYrCclearrDrEr$lenpopr!r& startswithlowerrrK)r9lineslinepartsipZipmapcnamealiasr r r rLs.      zHostsResolver._loadFTc Cst}|j|j|kr |tjj}t|trD|}tj |}n*t|t rf| d}tj |}nt|}| }tj|||} |j|j|| _|tjjkr|tjjkr|j|} | s|r|j|dd} | r| tjjj||| n|tjjkrj|tjjkrj|j|} | sH|rH|j|dd} | r| tjjj||| nt|tjjkr|tjjkr|j|} | s|r|j|dd} | r| tjjj||tj | t|||| |S)aYQuery the hosts file The known rdtypes are dns.rdatatype.A, dns.rdatatype.AAAA and dns.rdatatype.CNAME. The ``rdclass`` parameter must be dns.rdataclass.IN while the ``tcp`` and ``source`` parameters are ignored. Return a HostAnswer instance or raise a dns.resolver.NoAnswer exception. asciiN)rrKrFrLr rdataclassINrrrH from_textbytesrSr_r6ZRRsetr. rdatatypeArCget is_absoluteaddrAAAArDCNAMErEANYr-) r9r0r1r2tcpsourcer:nowrHr6addrrdr r r r*sJ         zHostsResolver.querycCs\g}||jkr|j|}n|}|||jD]\}}||kr2||q2|||S)z1Return a list of all the aliases of a given cname)rEappenditemsremove)r9hostnamealiasesZcannonrerdr r r getaliases-s     zHostsResolver.getaliases)r<r=r>r?recompileVERBOSErU HOSTS_TTLr;rYrLrrlrmrhrir*r}r r r r r@s   1r@c@speZdZdZdddZeddZejddZd d Ze j j e j j d dd e j j e j jfd fd dZddZdS) ResolverProxyzResolver class which can also use /etc/hosts Initialise with a HostsResolver instance in order for it to also use the hosts file. N/etc/resolv.confcCs||_||_d|_dS)ahInitialise the resolver proxy :param hosts_resolver: An instance of HostsResolver to use. :param filename: The filename containing the resolver configuration. The default value is correct for both UNIX and Windows, on Windows it will result in the configuration being read from the Windows registry. N)_hosts _filename_cached_resolver)r9hosts_resolverfilenamer r r r;Fs zResolverProxy.__init__cCs|jdkr||jSr)rr[r9r r r _resolverXs zResolverProxy._resolvercCs ||_dSr)r)r9valuer r r r^scCs$tjj|jd|_tj|j_dS)N)r)rr4ResolverrrZLRUCachecacherr r r r[bszResolverProxy.clearFTc sdddgdkrdtts*ttr8tjdfdd} fdd} |jr|tjjkr||kr| |jj |dd rddk sd dk s|s| S| |j j ||||dd t d kr| |j j tjj ||||dd | S) aPQuery the resolver, using /etc/hosts if enabled. Behavior: 1. if hosts is enabled and contains answer, return it now 2. query nameservers for qname if use_network is True 3. if qname did not contain dots, pretend it was top-level domain, query "foobar." and append to previous result Nrz0.0.0.0c sz|||}Wn0tk r>}z|d<WYdSd}~XYnX|jdk rt|jrddkrj|d<ndj|jdt|j7<dS)Nr#FrrZT) Exceptionr6r\Z union_update)Zfunrkwargsae)resultr r stepys  z!ResolverProxy.query..stepcsjddk r,r$ddkr$tjjdSddk rVsNtdtjjsVdtjjfddS)NrrZr#)Zqnames)rr4r5rNXDOMAINr r0r:rr r ends  z ResolverProxy.query..endF)r:r#)rrrkrrHrjrrhrir*rr\Z concatenateroot) r9r0r1r2rtrur:Z_hosts_rdtypes use_networkrrr rr r*fs*    zResolverProxy.queryc Csz|jr|j|}ng}z|j|tjj}Wn$tjjtjj fk rRYqvYqX| dd|j D|dj }q|S)z4Return a list of all the aliases of a given hostnamecss|]}t|jVqdSr)rtarget.0Zrrr r r sz+ResolverProxy.getaliases..r) rr}rr*rrlrrr4r5rextendr6r)r9r{r|ansr r r r}s  zResolverProxy.getaliases)Nr)r<r=r>r?r;propertyrsetterr[rrlrmrhrirqr*r}r r r r r?s     ?r)rTc Cs|tjkrtjj}n"|tjkr(tjj}nttjd|dkrBt }z\z|j ||||dWWStj j k r|st tj ||tjjddYWSYnXWn>tjjk rttYn tjjk rttYnXdS)a8Resolve a name for a given family using the global resolver proxy. This method is called by the global getaddrinfo() function. If use_network is False, only resolution via hosts file will be performed. Return a dns.resolver.Answer instance. If there is no answer it's rrset will be emtpy. zAddress family not supportedN)r:rF)rAF_INETrrlrmAF_INET6rqgaierror EAI_FAMILYr4r*rr-rHNamerhrirTimeoutrEAI_EAGAIN_ERROR DNSExceptionEAI_NODATA_ERROR)rHfamilyZraises_proxyrr1r r r resolves6          rcCszt|tjj}WnXtjjk r0|YStjjk rNtt Yn.tjj k rltt YnXt |dj SdS)z'Return the canonical name of a hostnamerN)r4r*rrlrrr5rrrrrrrr)r rr r r resolve_cnames rcCsPz t|WStjjk r,ttYn tjjk rJttYnXdS)zReturn a list of for aliases for the given hostname This method does translate the dnspython exceptions into socket.gaierror exceptions. If no aliases are available an empty list will be returned. N) r4r}rrrrrrrrr r r r}s   r}c Csv|tj@rttg}|tjkrd}dD]}tjtjfD]v}zt||d|d}Wn@tjk r}z |j tj tj t j fkr||}W5d}~XYq8X|j r8| dd|j Dq8|r(qq(|dk r|s|n|tjkrD|tj@rDt|tjd}|j r dd|j D}|r|tj@rht|tjd}|j rhd d|j D}n$t||d}|j rhd d|j D}t|j|fS) zTResolve a hostname to a list of addresses Helper function for getaddrinfo. N)FTF)rcss|] }|jVqdSraddressrr r r r sz&_getaddrinfo_lookup..cSsg|] }|jqSr rrr r r sz'_getaddrinfo_lookup..cSsg|]}d|jqS)z::ffff:rrr r r rscSsg|] }|jqSr rrr r r rs)rAI_NUMERICHOSTrEAI_NONAME_ERROR AF_UNSPECrrrrerrno EAI_AGAINrr6r AI_V4MAPPEDAI_ALLrr0) r rflagsaddrserrrZqfamilyZanswerrr r r _getaddrinfo_lookups>    rc CsRt|tr|dd}nt|tr0|d}|dk rRt|sRt|||\}}n |}|g}|tjBdtj A@}g} d} |D]b} zt | |||||} Wn:t k r} z|tj @r| } WYq|W5d} ~ XYnX| | q|| s| r| ttjd|tj @rNt|s$t|dd}| d} | d| d| d|| d f| d<| S) aCReplacement for Python's socket.getaddrinfo This does the A and AAAA lookups asynchronously after which it calls the OS' getaddrinfo(3) using the AI_NUMERICHOST flag. This flag ensures getaddrinfo(3) does not use the network itself and allows us to respect all the other arguments like the native OS. idnarfNzNo address foundrr#rZ)rrencoderSrkr'rrr AI_CANONNAME getaddrinforR AI_ADDRCONFIGrr EAI_NONAMEr)r portrtypeprotorr0rZaiflagsresrrwZairr r r r!sD        "rcCst|r |St|}|djS)z-Replacement for Python's socket.gethostbynamer)r!rr)r{r6r r r gethostbynameKsrcCs`t|r|g|gfSt|}t|}dd|jD}t|j}|ddkrV|dd}|||fS)z0Replacement for Python's socket.gethostbyname_excSsg|] }|jqSr rrr r r rYsz$gethostbyname_ex..rg.N)r!rr}r6rr0)r{rr|rr0r r r gethostbyname_exSs    rc Csz |\}}Wn6ttfk rBt|ts6~tdnttYnX|tj@r`|tj@r`ttt |rzBt t j |t jj}t|dkrtd|djjdd}WnRt jjk r|tj@rttYn*t jjk r|tj@rttYnXnz:t |}t|dkr$td|tj@r:|dj}WnJt jjk r^ttYn*t jjk rttjdfYnX|tj@s|tj@rdpd }t||}||fS) zTReplacement for Python's socket.getnameinfo. Currently only supports IPv4. z(getnameinfo() argument 1 must be a tupler#z'sockaddr resolved to multiple addressesrT)Zomit_final_dotrudprt) ValueError TypeErrorrtuplerrr NI_NAMEREQDNI_NUMERICHOSTr!r4r*rZ reversename from_addressrlZPTRr\rRrZto_textrrrrrrrNI_NUMERICSERVNI_DGRAM getservbyport)sockaddrrr rr6rr r r getnameinfo`sP               rcCst}|dkr|z||}Wn<tjk rX|tdkrFtjjt dYqYnX|dkrft |t |}||7}q|S)acoro friendly replacement for dns.query._net_read Read the specified number of bytes from sock. Keep trying until we either get the desired amount, or we hit EOF. A Timeout exception will be raised if the operation is not completed by the expiration time. r{Gz?) bytearrayrecvrr+rrrreventletsleepEOFErrorr\)sockcountr8snr r r _net_reads    rcCsdd}t|}||kr`z||||d7}Wq tjk r\|tdkrXtjjYq Xq dS)zcoro friendly replacement for dns.query._net_write Write the specified data to the socket. A Timeout exception will be raised if the operation is not completed by the expiration time. rNr)r\sendrr+rrrr)rdatar8currentlr r r _net_writesr)raise_on_truncationF5c  Cs|} |dkr6ztj|}Wntjj}YnX|tjjkr\||f}|dk r||f}n@|tjjkrtjtj|}||ddf}|dk r||ddf}| r| }nt |t j }| |z2t tj|}|dk r||z|| |Wq:Wqt jk r6|tdkr$tjjtdYqYqXqd}|r^|tdkr^tjj|rntdd}z|d\} }Wnt jk rYq>YnXtj|dtjjkr|d}tjtj|}||d|d |d f}||kr|rq>ntjd ||fz^trBtjj| |j|j|| | d }ntjj| |j|j|| d }||srtjWqWnptjj k r}z(| r||sWY q>nW5d}~XYn&t!k r| rYq>nYnXq>W5| X|S)aXcoro friendly replacement for dns.query.udp Return the response obtained after sending a query via UDP. @param q: the query @type q: dns.message.Message @param where: where to send the message @type where: string containing an IPv4 or IPv6 address @param timeout: The number of seconds to wait before the query times out. If None, the default, wait forever. @type timeout: float @param port: The port to which to send the message. The default is 53. @type port: int @param af: the address family to use. The default is None, which causes the address family to use to be inferred from the form of of where. If the inference attempt fails, AF_INET is used. @type af: int @rtype: dns.message.Message object @param source: source address. The default is the IPv4 wildcard address. @type source: string @param source_port: The port from which to send the message. The default is 0. @type source_port: int @param ignore_unexpected: If True, ignore responses from unexpected sources. The default is False. @type ignore_unexpected: bool @param one_rr_per_rrset: If True, put each RR into its own RRset. @type one_rr_per_rrset: bool @param ignore_trailing: If True, ignore trailing junk at end of the received message. @type ignore_trailing: bool @param raise_on_truncation: If True, raise an exception if the TC bit is set. @type raise_on_truncation: bool @param sock: the socket to use for the query. If None, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking datagram socket, and the source and source_port are ignored. @type sock: socket.socket | None @param ignore_errors: if various format errors or response mismatches occur, continue listening. @type ignore_errors: boolNrrrFTrr#rZz$got a response from %s instead of %s)keyring request_macone_rr_per_rrsetignore_trailingrrrrr)"to_wirerinetaf_for_addressrrr% inet_ntoarr SOCK_DGRAM settimeoutcloser,r*bindsendtor+rrrrrrecvfromZUnexpectedSource_handle_raise_on_truncationmessage from_wirermac is_response BadResponseZ Truncatedr)qwherer+rafru source_portZignore_unexpectedrrrr ignore_errorswire destinationZ where_truncrr8Ztriedrrwrrr r r rs/                    rc Cs|} |dkr6ztj|}Wntjj}YnX|tjjkr\||f} |dk r||f}n,|tjjkr||ddf} |dk r||ddf}| r| } nt|tj} | |zt tj |} |dk r| |z| | Wq"Wqtjk r| tdkr tjjtdYqYqXqt| }td|| }t| || t| d| }td|\}tt| || } W5| Xtjj| |j|j||d}||stj |S)acoro friendly replacement for dns.query.tcp Return the response obtained after sending a query via TCP. @param q: the query @type q: dns.message.Message object @param where: where to send the message @type where: string containing an IPv4 or IPv6 address @param timeout: The number of seconds to wait before the query times out. If None, the default, wait forever. @type timeout: float @param port: The port to which to send the message. The default is 53. @type port: int @param af: the address family to use. The default is None, which causes the address family to use to be inferred from the form of of where. If the inference attempt fails, AF_INET is used. @type af: int @rtype: dns.message.Message object @param source: source address. The default is the IPv4 wildcard address. @type source: string @param source_port: The port from which to send the message. The default is 0. @type source_port: int @type ignore_unexpected: bool @param one_rr_per_rrset: If True, put each RR into its own RRset. @type one_rr_per_rrset: bool @param ignore_trailing: If True, ignore trailing junk at end of the received message. @type ignore_trailing: bool @param sock: the socket to use for the query. If None, the default, a socket is created. Note that if a socket is provided, it must be a nonblocking datagram socket, and the source and source_port are ignored. @type sock: socket.socket | NoneNrrrz!HrZr)!rrrrrrr SOCK_STREAMrrr,r*rconnectr+rrrrrr\structpackrrunpackrkrrrrrr)rrr+rrrurrrrrrrr8rZtcpmsgZldatarr r r rt^sX&                 rtcCs tdSr)r4r[r r r r resetsr)rrrr)Ar?r~r sysrrZeventlet.greenrrrrrr rr__all__rpkgsetattrrirsrZDNS_QUERY_TIMEOUTrrrrrrrenvironrnr_r7rrr!r&r'r*r,r4ZAnswerr-r@rrrrr}rrrrrrrrrZ ShortHeaderrrrrtrr r r r s"             w  #( * 5   [