o 2cE@s2dZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl Zddl mZmZmZmZmZejjZddZd ddZd dd Z  d!d d Z   d"ddZ  d#ddZd ddZddZ d$ddZ   d%ddZ   d&ddZ ddddddej!dfddZ"dS)'zTalk to a DNS server.N)_compute_times_matches_destination BadResponsesslUDPModecCsV|s|r)|dur%|tjkrd}||fS|tjkrd}||fStd|||fSdS)Nz0.0.0.0z::zunknown address family )socketAF_INETAF_INET6NotImplementedError)afaddressportrD/var/www/html/gps/gps/lib/python3.10/site-packages/dns/asyncquery.py _source_tuple)s  rcCs"|r|st}t||dSdS)Nr)timemax) expirationnowrrr_timeout9s rcsBt|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. Returns an ``(int, float)`` tuple of bytes sent and the sent time. N) isinstancednsmessageMessageto_wirersendtor)sockwhat destinationr sent_timenrrrsend_udpBs r!Fc s`d} |dt|IdH\} } t|j| ||rnqt} tjj| |||||d} | | | fS)zRead 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, exceptions, and return type of this method. r"N)keyring request_macone_rr_per_rrsetignore_trailingraise_on_truncation)recvfromrrfamilyrrr from_wire) rrrignore_unexpectedr'r%r&r(r)wire from_address received_timerrrr receive_udpZs     r25c  s|} t|\} }d}zetj|}t||f|}| r | }n| s'tj} t|||}| |t j d|IdH}t || ||IdHt ||||||j|j|| IdH\}}}|| |_||sct|W| sq|rr|IdHSSS| s|r|IdHwww)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)rrrinetaf_for_address_lltuple asyncbackendget_default_backendr make_socketr SOCK_DGRAMr!r2r%macr is_responserclose)qwheretimeoutr source source_portr-r'r(r)rbackendr. begin_timersr rstupler1r0_rrrudpss<       rHc spzt|||||||||d| | IdH} | dfWStjjy7t||||||||| | 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)rHrr Truncatedtcp) r>r?r@r rArBr-r'r(udp_socktcp_sockrCresponserrrudp_with_fallbacks  rNcs\t|tjjr |}t|}td||}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. !HN) rrrrrlenstructpackrsendallr)rrrltcpmsgrrrrsend_tcps  rVcsPd}|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)recvrEOFErrorrP)rcountrrEr rrr _read_exactlys rZc 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. NrO)r%r&r'r()rZrQunpackrrrr,) rrr'r%r&r(ldatarTr.r0r1rrr receive_tcps  r^c s|} t|\} } d} zf|r|IdH|} n%tj|}t|||}||f}| s1tj} | |t j d|||IdH} t | | | IdHt | | ||j|j|IdH\}}|| |_||sdt|W|sr| rs| IdHSSS|s| r| IdHwww)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)rr getpeernamerr4r5rr7r8r9r SOCK_STREAMrVr^r%r;rr<rr=)r>r?r@r rArBr'r(rrCr.rDrrEr rFdtupler1r0rrrrJs<        rJUc  st|\} } |sE| durt} | durd| _nd} d} tj|}t|||}||f}| s4tj } | |t j d|||| | IdH}n|}z-t | }t|||||||||| IdH}t}|| |_|W|ss|rt|IdHSSS|s|r|IdHwww)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. NFr)rrcreate_default_contextcheck_hostnamerr4r5rr7r8r9rr`rrJrr=)r>r?r@r rArBr'r(rrC ssl_contextserver_hostnamerDrr rFrarErMend_timerrrtls/sB        rhc # s|dur tj|\}} |jdj} | tjjk} |} |}tj |}t |||}||f}t |\}}d}|rnd}| rK|t jkrKtj}d}ntj}d}| sWtj} | ||d||t|IdH}|4IdH|r||||t|IdHntdt||}|||IdHtj|| | |}d}d}|s3t |\}}|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&y-|sJ|t j'kr$d}d}t j}Yqw|"j(}|r|sD|j#rD|"j)sDtj*+d Wdn 1sOwYWdIdHn 1IdHsewY|ssd    . $  3 1