o 'hex#@sdZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z m Z mZmZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)e(r~ddl*Z*ej+j,Z-ddZ.dYdd Z/ dYd ej0j1d eej2j3e4fd e d e e5de e6e5ff ddZ7          dZd ej0j1d e e d e e5de8de8de e ej9j:ej;jd e e5d!e6d"e e>d#e6de8de8de8de8d e ej0j1d$e ej0j?de8dej2j3fd%d&Z@           d\dej2j3de>d e e5d!e6d"e e>d#e6de8de8de8d'e ej0j1d(e ej0jAd$e ej0j?de8de ej2j3e8ffd)d*ZB dYd ej0jAd eej2j3e4fd e e5de e6e5ffd+d,ZCd-d.ZD     d]d ej0jAd e e5de8de e ej9j:ej;jd e e5d!e6d"e e>d#e6de8de8d e ej0jAd$e ej0j?dej2j3fd1d2ZF  3         4d_dej2j3de>d e e5d!e6d"e e>d#e6de8de8d e ej0jAd$e ej0j?d5e e)jGd6e e>d7ee8e>fdej2j3fd8d9ZHd:e d;dd;fddddddd?d4d4ddejJejKfdej2j3de>d e e5d!e6d"e e>d#e6de8de8d@e dAdBe>dCe8d7ee8e>fdDe e>d:e d;dEe6dFedej2j3f"dGdHZL  3     4   4d`dej2j3de>dIe>d e e5d!e6d"e e>d#e6de8de8d7ee8e>fd$e ej0j?dJe e>dCe8dej2j3fdKdLZM  3      4   dadej2j3de>d e e5d!e6d"e e>d#e6de8de8dMe ejNjOd7ee8e>fd$e ej0j?dJe e>d6e e>dej2j3fdNdOZNdPejPjQdQej0jRdej2j3dRe e6d e e5d e5de fdSdTZSdddddde"jTdfde>dPejPjQde ej2j3d!e6d e e5dUe e5d"e e>d#e6dVe"d$e ej0j?ddfdWdXZUdS)bzTalk to a DNS server.N)AnyDictOptionalTupleUnioncast) NullContext) BadResponse HTTPVersionNoDOHNoDOQUDPMode _check_status_compute_times_make_dot_ssl_context_matches_destination _remaininghave_dohsslcCsV|s|r)|dur%|tjkrd}||fS|tjkrd}||fStd|||fSdS)Nz0.0.0.0z::zunknown address family )socketAF_INETAF_INET6NotImplementedError)afaddressportrJ/var/www/html/olx_land/venv/lib/python3.10/site-packages/dns/asyncquery.py _source_tuple>s  rcCs&|dur|s t}t||dSdSNr)timemax) expirationnowrrr_timeoutNs r$sockwhat destinationr"returncsBt|tjjr |}t}|||t||IdH}||fS)aSend a DNS message to the specified UDP socket. *sock*, a ``dns.asyncbackend.DatagramSocket``. *what*, a ``bytes`` or ``dns.message.Message``, the message to send. *destination*, a destination tuple appropriate for the address family of the socket, specifying where to send the query. *expiration*, a ``float`` or ``None``, the absolute time at which a timeout exception should be raised. If ``None``, no timeout will occur. The expiration value is meaningless for the asyncio backend, as asyncio's transport sendto() never blocks. Returns an ``(int, float)`` tuple of bytes sent and the sent time. N) isinstancednsmessageMessageto_wirer sendtor$)r%r&r'r" sent_timenrrrsend_udpWs r1Fignore_unexpectedone_rr_per_rrsetkeyring request_macignore_trailingraise_on_truncation ignore_errorsqueryc  sd} |dt|IdH\} } t|j| ||sqt} ztjj| |||||d}Wn-tjjyN}z| rI| durI| |sIWYd}~qd}~wt yY| rXYqw| rf| durf| |sfq|| | fS)ajRead a DNS message from a UDP socket. *sock*, a ``dns.asyncbackend.DatagramSocket``. See :py:func:`dns.query.receive_udp()` for the documentation of the other parameters, and exceptions. Returns a ``(dns.message.Message, float, tuple)`` tuple of the received message, the received time, and the address where the message arrived from. r2TN)r5r6r4r7r8) recvfromr$rfamilyr r*r+ from_wire Truncated is_response Exception)r%r'r"r3r4r5r6r7r8r9r:wire from_address received_timererrr receive_udpusF      rG5qwheretimeoutrsource source_portbackendc  s$|} t|\}}tj|}t||f|}| rt| }n%| s&tj} t |||}| r5||f}nd}| |t j d||IdH}|4IdH;}t|| ||IdHt||||||j|j|| | | IdH\}}}|||_| sy||syt|WdIdHS1IdHswYdS)aFReturn the response obtained after sending a query via UDP. *sock*, a ``dns.asyncbackend.DatagramSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided, the *source*, *source_port*, and *backend* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.udp()` for the documentation of the other parameters, exceptions, and return type of this method. Nr)r-rr*inetaf_for_address_lltupler asyncbackendget_default_backendrdatagram_connection_required make_socketr SOCK_DGRAMr1rGr5macr r@r )rIrJrKrrLrMr3r4r7r8r%rNr9rB begin_timer"rr'cmstupledtuplesrErD_rrrudpsD       0r^udp_socktcp_sockc srzt|||||||||d| | | IdH} | dfWStjjy8t||||||||| | IdH} | dfYSw)aReturn the response to the query, trying UDP first and falling back to TCP if UDP results in a truncated response. *udp_sock*, a ``dns.asyncbackend.DatagramSocket``, or ``None``, the socket to use for the UDP query. If ``None``, the default, a socket is created. Note that if a socket is provided the *source*, *source_port*, and *backend* are ignored for the UDP query. *tcp_sock*, a ``dns.asyncbackend.StreamSocket``, or ``None``, the socket to use for the TCP query. If ``None``, the default, a socket is created. Note that if a socket is provided *where*, *source*, *source_port*, and *backend* are ignored for the TCP query. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.udp_with_fallback()` for the documentation of the other parameters, exceptions, and return type of this method. TNF)r^r*r+r?tcp)rIrJrKrrLrMr3r4r7r_r`rNr9responserrrudp_with_fallbacksB#  rccs^t|tjjr|jdd}n t|dd|}t}||t ||IdHt||fS)zSend a DNS message to the specified TCP socket. *sock*, a ``dns.asyncbackend.StreamSocket``. See :py:func:`dns.query.send_tcp()` for the documentation of the other parameters, exceptions, and return type of this method. T)prepend_lengthbigN) r)r*r+r,r-lento_bytesr sendallr$)r%r&r"tcpmsgr/rrrsend_tcp8s  rkcsTd}|dkr(||t|IdH}|dkrtd|t|}||}|dks|S)z|Read the specified number of bytes from stream. Keep trying until we either get the desired amount, or we hit EOF. r2rNEOF)recvr$EOFErrorrg)r%countr"r\r0rrr _read_exactlyQs rpc sZt|d|IdH}td|\}t|||IdH}t} tjj|||||d} | | fS)zRead a DNS message from a TCP socket. *sock*, a ``dns.asyncbackend.StreamSocket``. See :py:func:`dns.query.receive_tcp()` for the documentation of the other parameters, exceptions, and return type of this method. reN!Hr5r6r4r7)rpstructunpackr r*r+r>) r%r"r4r5r6r7ldatalrBrDrErrr receive_tcp_srwc  s|} t|\} } |r|IdHt|} n%tj|}t|||}||f}| s0tj } | |t j d|||IdH} | 4IdH2}t || | IdHt|| ||j|j|IdH\}}|| |_||sjt|WdIdHS1IdHs|wYdS)aOReturn the response obtained after sending a query via TCP. *sock*, a ``dns.asyncbacket.StreamSocket``, or ``None``, the socket to use for the query. If ``None``, the default, a socket is created. Note that if a socket is provided *where*, *port*, *source*, *source_port*, and *backend* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.tcp()` for the documentation of the other parameters, exceptions, and return type of this method. Nr)r-r getpeernamerr*rOrPrrRrSrUr SOCK_STREAMrkrwr5rWr r@r )rIrJrKrrLrMr4r7r%rNrBrXr"rYrrZr[r\rErDrrrra}s0        0raUT ssl_contextserver_hostnameverifyc  st|\} }|rt|}n0| durt| | } tj|}t|||}||f}| s.tj} | |t j d|||| | IdH}|4IdH*}t |}t |||||||||| IdH}t}|| |_|WdIdHS1IdHstwYdS)aReturn the response obtained after sending a query via TLS. *sock*, an ``asyncbackend.StreamSocket``, or ``None``, 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 connected SSL stream socket, and *where*, *port*, *source*, *source_port*, *backend*, *ssl_context*, and *server_hostname* are ignored. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.tls()` for the documentation of the other parameters, exceptions, and return type of this method. Nr)rrrr*rOrPrrRrSrUrryr$rar )rIrJrKrrLrMr4r7r%rNr{r|r}rXr"rYrrZr[r\rbend_timerrrtlssN          0rresolverzdns.asyncresolver.ResolvercCs|dur ddl}|j}|Sr)dns.asyncresolver asyncresolverResolver)rr*rrr_maybe_get_resolvers riz /dns-queryclientzhttpx.AsyncClientpathpostbootstrap_addressr= http_versionc" s0ztj|}Wn tyd}Ynw|dur?tj|r?|tjkr/d|d|| }n|tjkr>d|d|| }n|}i}| durmtj |}|j durVtdtj|j re|j } |j |d<|j durm|j }|t jksy|t jkrts| durt| } |j dusJ| |j |IdH}tt|} t|| |||||||| | d IdHStst|rt|tjstd |}d d i}|t jt jfv}|t jt jfv}tj }|durd}d }n|}|}|rt!|}n|"|||| || | |d }tj||| |d}|4IdHI}| r,|#d t$t%|d|&|j'||||d|IdH}nt()|*d}|+} |&|j,||d| i|d|IdH}WdIdHn 1IdHs[wY|j-dksl|j-dkrzt|d|j-d|j.tj/j0|j.|j1|j2||d}!|j34|!_5|6|!st7|!S)aReturn the response obtained after sending a query via DNS-over-HTTPS. *client*, a ``httpx.AsyncClient``. If provided, the client to use for the query. Unlike the other dnspython async functions, a backend cannot be provided in this function because httpx always auto-detects the async backend. See :py:func:`dns.query.https()` for the documentation of the other parameters, exceptions, and return type of this method. Nzhttps://:z https://[z]:zno hostname in URL sni_hostname)r}rz.session parameter must be an httpx.AsyncClientacceptzapplication/dns-messager) local_addresshttp1http2r} local_portrrr=)rrr} transport)z content-typezcontent-length)headerscontent extensions=r*)rparamsri+z responded with status code z Response body: rr)8r*rOrP ValueError is_addressrrrurllibparseurlparsehostnamerr H3DEFAULTrr resolve_namerandomchoicelist addresses_http3r r)httpx AsyncClientr-H1H2rRrSrget_transport_classupdatestrrgwait_forrbase64urlsafe_b64encoderstripdecodeget status_coderr+r>r5r6elapsed total_secondsr r@r )"rIrJrKrrLrMr4r7rrrr}rrr=rrurlrparsedanswersrBrh1h2rNrrrYr the_clientrbtwirerErrrhttps s                *"  rrrc  stjjs tdtj|} | j} | jdur| j}d|_ | }tj | \}}|4IdH}||| | dd4IdHZ}| ||||}t |\}}||IdH}|4IdH$|||| |t|IdH}t|||WdIdHn 1IdHswYt}WdIdHn 1IdHswYtjj||j|j||d}WdIdHn 1IdHswYt||d|_||st|S)Nz DNS-over-HTTP3 is not available.rT) verify_mode server_nameh3rr)r*quic have_quicr rrrrridr-factories_for_backendconnectr make_streamsend_h3receiverrrr r+r>r5r6r!r@r )rIrJrrKrrLrMr4r7r}rNrr url_partsrBcfactorymfactorycontext the_managerthe_connectionstartr"streamfinishrErrrrsJ   ( ( ( r connectionc  stjjs td| dur| dur| } d|_|} |r'tjj}tjj}|}ntj| \}}|4IdH}||| | d4IdHV}|sM|||||}t |\}}| |IdH}|4IdH| | dIdH| t |IdH} WdIdHn 1IdHswYt}WdIdHn 1IdHswYtjj| |j|j||d}WdIdHn 1IdHswYt||d|_||st|S)aiReturn the response obtained after sending an asynchronous query via DNS-over-QUIC. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.quic()` for the documentation of the other parameters, exceptions, and return type of this method. zDNS-over-QUIC is not available.Nr)rrTrrr)r*rrr rr- null_factoryrrrrsendrrr r+r>r5r6r!r@r )rIrJrKrrLrMr4r7rr}rNrr|rBrrrrrrr"rrrErrrrsR ( ( ( r txn_managerr\serialc Cs|jdj}|tjjk}|}|} |jtj k} | r1t tj j |} | | dt|IdHnt tj j|} tdt| | } | | |IdHtj|||| }d}d}|st|\}}|dusm|duro||kro|}| rt|}| d|IdH\}}nt| d|IdH}td|\}t| ||IdH}tjj||j|jd||| |d}||}|V|j}|r[|jr|j stj!"d WddSWddS1swYdS) z'Given a socket, does the zone transfer.rNrqFr;reT)r5r6xfrorigintsig_ctxmultir4z missing TSIG)#questionrdtyper* rdatatypeIXFRfrom_wire_originr-typerrVrrRDatagramSocketr.r$ StreamSocketrspackrgrirInboundrr<rprtr+r>r5rWprocess_messagerhad_tsig exception FormError)rr\r:rrKr"ris_ixfrrrBis_udpr_r`rjinbounddonerr] mexpirationrwirerurvrErrr _inbound_xfr(s\      "rlifetimeudp_modec  s|durtj|\}} ntj|} tj|} t| ||} ||f} | s+tj} t |\}}|j dj tj j kr|tjkr| | tjd| | t|IdH}|4IdH:zt|||| ||2z3dHW}qa6WWdIdHdStjjy|tjkrYnwWdIdHn 1IdHswY| | tjd| | t|IdH}|4IdHt|||| ||2z3dHW}q6WdIdHdS1IdHswYdS)amConduct an inbound transfer and apply it via a transaction from the txn_manager. *backend*, a ``dns.asyncbackend.Backend``, or ``None``. If ``None``, the default, then dnspython will use the default backend. See :py:func:`dns.query.inbound_xfr()` for the documentation of the other parameters, exceptions, and return type of this method. Nr)r*r make_queryextract_serial_from_queryrOrPrrRrSrrrrrr NEVERrUrrVr$rUseTCPONLYry)rJrr:rrKrrLrMrrNrrrZr[r]r"r\rrr inbound_xfr^sL        (  .r)N) NNFFNr2FFFN) NrHNrFFFFNNF) NrHNrFFFNNNF)NFNr2F)NrHNrFFNN) NrzNrFFNNNNT) NrzNrFFTNNT) NrzNrFFNTNNN)V__doc__r contextlibrrrsr urllib.parsertypingrrrrrrdns.asyncbackendr* dns.exceptiondns.inet dns.messagedns.namedns.quic dns.rcodedns.rdataclass dns.rdatatypedns.transactiondns._asyncbackendr dns.queryr r r r r rrrrrrrrrOlow_level_address_tuplerQrr$rRrr+r,bytesfloatintr1boolnameNametsigKeyrGrBackendr^rrcrkrprwra SSLContextrr AF_UNSPECrrrrAsyncQuicConnection transactionTransactionManagerSocketrrrrrrrsf  8         @      E      G   !   ;      F       +      8      D 9