o gh!@sdZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z ddl Z ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlZ ddlmZddlmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#e"rpddl$Z$e j%j&Z'ddZ(dNdd Z) dNd e j*j+d e e j,j-e.fd ed e e/de e0e/ff ddZ1          dOd e j*j+d e ed e e/de2de2de ee j3j4e j5j6fde e.de2de2de2de e j,j-defddZ7           dPde j,j-de8d e e/d!e0d"e e8d#e0de2de2de2de2d e e j*j+d$e e j*j9de2de j,j-fd%d&Z:           dQde j,j-de8d e e/d!e0d"e e8d#e0de2de2de2d'e e j*j+d(e e j*j;d$e e j*j9de2de e j,j-e2ffd)d*Z< dNd e j*j;d e e j,j-e.fd e e/de e0e/ffd+d,Z=d-d.Z>     dRd e j*j;d e e/de2de ee j3j4e j5j6fde e.de2de e j,j-e/ffd/d0Z?        dSde j,j-de8d e e/d!e0d"e e8d#e0de2de2d e e j*j;d$e e j*j9de j,j-fd1d2Z@  3         4dTde j,j-de8d e e/d!e0d"e e8d#e0de2de2d e e j*j;d$e e j*j9d5e e#jAd6e e8d7e e2e8fde j,j-fd8d9ZBdd:dddddd;d4d4ddejCf de j,j-de8d e e/d!e0d"e e8d#e0de2de2de8d?e2d7e e2e8fd@e e8dAe dBdCe e0de j,j-f dDdEZDddddddejEdfde8dFe jFjGde e j,j-d!e0d e e/dGe e/d"e e8d#e0dHed$e e j*j9ddfdIdJZH  3      4  dUde j,j-de8d e e/d!e0d"e e8d#e0de2de2dKe e jIjJd7e e2e8fd$e e j*j9d6e e8de j,j-fdLdMZIdS)VzTalk to a DNS server.N)AnyDictOptionalTupleUnion) NullContext) BadResponseNoDOHNoDOQUDPMode_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)afaddressportr[/var/www/html/portale_awareness/portale-venv/lib/python3.10/site-packages/dns/asyncquery.py _source_tuple:s  rcCs&|dur|s t}t||dSdS)Nr)timemax) expirationnowrrr_timeoutJs r sockwhat destinationrreturncsBt|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_wirersendtor )r!r"r#r sent_timenrrrsend_udpSs r-Fignore_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. r.TN)r1r2r0r3r4) recvfromr rfamilyrr&r' from_wire Truncated is_response Exception)r!r#rr/r0r1r2r3r4r5r6wire from_address received_timererrr receive_udpqsF      rC5qwheretimeoutrsource 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)r r&inetaf_for_address_lltupler asyncbackendget_default_backendrdatagram_connection_required make_socketr SOCK_DGRAMr-rCr1macrr<r)rErFrGrrHrIr/r0r3r4r!rJr5r> begin_timerrr#cmstupledtuplesrAr@_rrrudpsD       0rZudp_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)rZr&r'r;tcp)rErFrGrrHrIr/r0r3r[r\rJr5responserrrudp_with_fallbacksB#  r_cs^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_bytesrsendallr )r!r"rtcpmsgr+rrrsend_tcp4s  rgcsPd}|dkr&||t|IdH}|dkrt|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. r.rN)recvr EOFErrorrc)r!countrrXr,rrr _read_exactlyMs rkc 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. raN!Hr1r2r0r3)rkstructunpackrr&r'r:) r!rr0r1r2r3ldatalr>r@rArrr receive_tcp[srrc  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&rKrLrrNrOrQr SOCK_STREAMrgrrr1rSrr<r)rErFrGrrHrIr0r3r!rJr>rTrrUrrVrWrXrAr@rrrr]ys0        0r]UT 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)r rr r&rKrLrrNrOrQrrtr r]r)rErFrGrrHrIr0r3r!rJrvrwrxrTrrUrrVrWrXr^end_timerrrtlssN          0rziz /dns-queryclientzhttpx.AsyncClientpathpostbootstrap_addressresolverzdns.asyncresolver.Resolverr9c stst|rt|tjstd|}ztj |}Wn ty(d}Ynwd}ddi}|durStj |rS|t j krFd ||| }n|t jkrRd ||| }n|}tj}|durcd}d}n|}|}||dd| || | |d }|r|t|}n tjdd| |d }|4IdHF}| r|dtt|d ||j|||d |IdH}nt|d }|}||j||d|id|IdH}WdIdHn 1IdHswY|jdks|jdkrtd ||j|jtjj |j|j!|j"||d}|j#$|_%|&|s t'|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. z.session parameter must be an httpx.AsyncClientNacceptzapplication/dns-messagezhttps://{}:{}{}zhttps://[{}]:{}{}rT) local_addresshttp1http2rx local_portr~rr9)rrrx transport)z content-typezcontent-length)headerscontent=r&)rparamsi+z4{} responded with status code {} Response body: {!r}rm)(rr r%httpx AsyncClient ValueErrorr)r&rKrL is_addressrrformatrrNrOget_transport_classrupdatestrrcwait_forr}base64urlsafe_b64encoderstripdecodeget status_coderr'r:r1r2elapsed total_secondsrr<r)rErFrGrrHrIr0r3r{r|r}rxr~rr9r>rrrurlrJrrrU the_clientr^twirerArrrhttpss        (   r txn_managerlifetimeudp_modec # s|durtj|\}} ntj|} |jdj} | tjjk} |} | }tj |}t |||}||f}t |\}}d}|rud}| rR|tjkrRtj}d}ntj}d}| s^tj} | ||d||t|IdH}|4IdH|r|||t|IdHntdt||}|||IdHtj|| | |}d}d}|s:t |\}}|dus|dur||kr|}|rt||f|} t|}|d|IdH\}}t|||drnqnt |d|IdH} t!d| \}!t ||!|IdH}| tjjk} tj"j#||j$|j%d| || | d}"z|&|"}Wntjj'y4|s$J|tj(kr+d}d}tj}Yqw|"j)}|r|sK|j$rK|"j*sKtj+,d Wdn 1sVwYWdIdHn 1IdHslwY|sCdSdS) 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. NrTFrlr7ra)r1r2xfrorigintsig_ctxmultir0z missing TSIG)-r&r make_queryextract_serial_from_queryquestionrdtype rdatatypeIXFRfrom_wire_originr)rKrLrr r NEVERrrRrtrNrOrQr r*rnpackrcreInboundrMr8rrkror'r:r1rSprocess_messageUseTCPONLYrhad_tsig exception FormError)#rFrr6rrGrrHrIrrJserialris_ixfrrr>rrVrWrYrretry sock_typeis_udprXrfinbounddoner mexpirationr#rwirer?rprqrArrr inbound_xfrls             )  * r connectionc  stjjs tdd|_|} |rtjj} tjj}|}ntj| \} }| 4IdH}||| | d4IdHV}|sC|||||}t |\}}| |IdH}|4IdH| | dIdH| t |IdH} WdIdHn 1IdHs{wYt}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.rN) verify_mode server_nameTrmg)r&quic have_quicr idr) null_factoryfactories_for_backendconnectr make_streamsendreceiverrr'r:r1r2rr<r)rErFrGrrHrIr0r3rrxrJrwr>cfactorymfactorythe_connectioncontext the_managerstartrstreamfinishrArrrrsJ ( ( ( r)N) NNFFNr.FFFN) NrDNrFFFFNNF) NrDNrFFFNNNF)NFNr.F)NrDNrFFNN) NruNrFFNNNNT) NruNrFFNTNN)K__doc__r contextlibrrnrtypingrrrrrdns.asyncbackendr& dns.exceptiondns.inet dns.messagedns.namedns.quic dns.rcodedns.rdataclass dns.rdatatypedns.transactiondns._asyncbackendr dns.queryrr r r r r rrrrrrKlow_level_address_tuplerMrr rNDatagramSocketr'r(bytesfloatintr-boolnameNametsigKeyrCrBackendrZ StreamSocketr_rgrkrrr] SSLContextrz AF_UNSPECrr transactionTransactionManagerrrAsyncQuicConnectionrrrrs 0          @      E      G   !   ;      I      x    h