ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: opt / alt / python38 / lib64 / python3.8 / site-packages / aiohttp

import asyncio
import socket
from typing import Any, Dict, List, Optional

from .abc import AbstractResolver
from .helpers import get_running_loop

__all__ = ("ThreadedResolver", "AsyncResolver", "DefaultResolver")

try:
    import aiodns

# aiodns_default = hasattr(aiodns.DNSResolver, 'gethostbyname')
except ImportError:  # pragma: no cover
    aiodns = None

aiodns_default = False

class ThreadedResolver(AbstractResolver):
    """Use Executor for synchronous getaddrinfo() calls, which defaults to
    concurrent.futures.ThreadPoolExecutor.
    """

def __init__(self, loop: Optional[asyncio.AbstractEventLoop] = None) -> None:
        self._loop = get_running_loop(loop)

async def resolve(
        self, hostname: str, port: int = 0, family: int = socket.AF_INET
    ) -> List[Dict[str, Any]]:
        infos = await self._loop.getaddrinfo(
            hostname,
            port,
            type=socket.SOCK_STREAM,
            family=family,
            flags=socket.AI_ADDRCONFIG,
        )

hosts = []
        for family, _, proto, _, address in infos:
            if family == socket.AF_INET6 and address[3]:  # type: ignore
                # This is essential for link-local IPv6 addresses.
                # LL IPv6 is a VERY rare case. Strictly speaking, we should use
                # getnameinfo() unconditionally, but performance makes sense.
                host, _port = socket.getnameinfo(
                    address, socket.NI_NUMERICHOST | socket.NI_NUMERICSERV
                )
                port = int(_port)
            else:
                host, port = address[:2]
            hosts.append(
                {
                    "hostname": hostname,
                    "host": host,
                    "port": port,
                    "family": family,
                    "proto": proto,
                    "flags": socket.AI_NUMERICHOST | socket.AI_NUMERICSERV,
                }
            )

return hosts

async def close(self) -> None:
        pass

class AsyncResolver(AbstractResolver):
    """Use the `aiodns` package to make asynchronous DNS lookups"""

def __init__(
        self,
        loop: Optional[asyncio.AbstractEventLoop] = None,
        *args: Any,
        **kwargs: Any
    ) -> None:
        if aiodns is None:
            raise RuntimeError("Resolver requires aiodns library")

self._loop = get_running_loop(loop)
        self._resolver = aiodns.DNSResolver(*args, loop=loop, **kwargs)

if not hasattr(self._resolver, "gethostbyname"):
            # aiodns 1.1 is not available, fallback to DNSResolver.query
            self.resolve = self._resolve_with_query  # type: ignore

async def resolve(
        self, host: str, port: int = 0, family: int = socket.AF_INET
    ) -> List[Dict[str, Any]]:
        try:
            resp = await self._resolver.gethostbyname(host, family)
        except aiodns.error.DNSError as exc:
            msg = exc.args[1] if len(exc.args) >= 1 else "DNS lookup failed"
            raise OSError(msg) from exc
        hosts = []
        for address in resp.addresses:
            hosts.append(
                {
                    "hostname": host,
                    "host": address,
                    "port": port,
                    "family": family,
                    "proto": 0,
                    "flags": socket.AI_NUMERICHOST | socket.AI_NUMERICSERV,
                }
            )

if not hosts:
            raise OSError("DNS lookup failed")

return hosts

async def _resolve_with_query(
        self, host: str, port: int = 0, family: int = socket.AF_INET
    ) -> List[Dict[str, Any]]:
        if family == socket.AF_INET6:
            qtype = "AAAA"
        else:
            qtype = "A"

try:
            resp = await self._resolver.query(host, qtype)
        except aiodns.error.DNSError as exc:
            msg = exc.args[1] if len(exc.args) >= 1 else "DNS lookup failed"
            raise OSError(msg) from exc

hosts = []
        for rr in resp:
            hosts.append(
                {
                    "hostname": host,
                    "host": rr.host,
                    "port": port,
                    "family": family,
                    "proto": 0,
                    "flags": socket.AI_NUMERICHOST,
                }
            )

if not hosts:
            raise OSError("DNS lookup failed")

return hosts

async def close(self) -> None:
        return self._resolver.cancel()

DefaultResolver = AsyncResolver if aiodns_default else ThreadedResolver

[-] client_ws.py [edit]
[-] web_runner.py [edit]
[-] web.py [edit]
[-] web_request.py [edit]
[-] tcp_helpers.py [edit]
[-] web_urldispatcher.py [edit]
[-] client_proto.py [edit]
[-] _helpers.cpython-38-x86_64-linux-gnu.so [edit]
[-] web_ws.py [edit]
[-] web_response.py [edit]
[+] ..
[-] _find_header.pxd [edit]
[-] web_protocol.py [edit]
[-] _http_parser.pyx [edit]
[-] hdrs.py [edit]
[-] helpers.py [edit]
[-] multipart.py [edit]
[-] http.py [edit]
[-] _websocket.c [edit]
[-] _headers.pxi [edit]
[-] signals.pyi [edit]
[-] _http_parser.c [edit]
[-] client_exceptions.py [edit]
[-] _websocket.pyx [edit]
[-] http_writer.py [edit]
[-] _http_writer.cpython-38-x86_64-linux-gnu.so [edit]
[-] signals.py [edit]
[-] worker.py [edit]
[-] web_exceptions.py [edit]
[-] web_log.py [edit]
[-] client.py [edit]
[-] web_server.py [edit]
[-] py.typed [edit]
[-] abc.py [edit]
[-] payload.py [edit]
[-] formdata.py [edit]
[-] web_middlewares.py [edit]
[-] streams.py [edit]
[-] pytest_plugin.py [edit]
[-] frozenlist.py [edit]
[+] __pycache__
[-] _helpers.pyx [edit]
[-] web_app.py [edit]
[-] cookiejar.py [edit]
[-] http_exceptions.py [edit]
[-] payload_streamer.py [edit]
[-] log.py [edit]
[-] _helpers.c [edit]
[-] test_utils.py [edit]
[-] _find_header.c [edit]
[-] http_parser.py [edit]
[-] web_fileresponse.py [edit]
[-] locks.py [edit]
[-] _http_parser.cpython-38-x86_64-linux-gnu.so [edit]
[-] _http_writer.pyx [edit]
[-] tracing.py [edit]
[-] frozenlist.pyi [edit]
[-] resolver.py [edit]
[-] _helpers.pyi [edit]
[-] __init__.py [edit]
[-] _frozenlist.c [edit]
[-] _frozenlist.pyx [edit]
[+] .hash
[-] _cparser.pxd [edit]
[-] base_protocol.py [edit]
[-] web_routedef.py [edit]
[-] connector.py [edit]
[-] _frozenlist.cpython-38-x86_64-linux-gnu.so [edit]
[-] _find_header.h [edit]
[-] typedefs.py [edit]
[-] _websocket.cpython-38-x86_64-linux-gnu.so [edit]
[-] http_websocket.py [edit]
[-] _http_writer.c [edit]
[-] client_reqrep.py [edit]