aio-libs-aiohttp-8445-8482

total 272
drwxr-xr-x 1 root root   4096 Nov  4 21:14 .
drwxr-xr-x 1 root root   4096 Nov  4 21:14 ..
-rw-r--r-- 1 root root    113 Nov  4 21:13 .cherry_picker.toml
-rw-r--r-- 1 root root    481 Nov  4 21:13 .codecov.yml
-rw-r--r-- 1 root root    111 Nov  4 21:13 .coveragerc
-rw-r--r-- 1 root root    376 Nov  4 21:13 .editorconfig
drwxr-xr-x 1 root root   4096 Nov  4 21:14 .git
-rw-r--r-- 1 root root   1337 Nov  4 21:13 .git-blame-ignore-revs
-rw-r--r-- 1 root root     58 Nov  4 21:13 .gitattributes
drwxr-xr-x 1 root root   4096 Nov  4 21:13 .github
-rw-r--r-- 1 root root    735 Nov  4 21:13 .gitignore

-rw-r--r-- 1 root root    118 Nov  4 21:13 .gitmodules
-rw-r--r-- 1 root root     44 Nov  4 21:13 .lgtm.yml
-rw-r--r-- 1 root root    985 Nov  4 21:13 .mypy.ini
-rw-r--r-- 1 root root     78 Nov  4 21:13 .pip-tools.toml
-rw-r--r-- 1 root root   2929 Nov  4 21:13 .pre-commit-config.yaml
-
…[744 chars omitted]…
96 Nov  4 21:13 examples
-rw-r--r-- 1 root root   2568 Nov  4 21:13 pyproject.toml
drwxr-xr-x 1 root root   4096 Nov  4 21:13 requirements
-rw-r--r-- 1 root root   5996 Nov  4 21:13 setup.cfg
-rw-r--r-- 1 root root   1599 Nov  4 21:13 setup.py
drwxr-xr-x 1 root root   4096 Nov  4 21:13 tests
drwxr-xr-x 1 root root   4096 Nov  4 21:13 tools
drwxr-xr-x 1 root root   4096 Nov  4 21:13 vendor
0c97c00 base

603:                        read_timeout=real_timeout.sock_read,
755:    def ws_connect(
780:            self._ws_connect(
803:    async def _ws_connect(
aiohttp/client_reqrep.py:701:class ClientResponse(HeadersMixin):
aiohttp/client_proto.py:25:class ResponseHandler(BaseProtocol, DataQueue[Tuple[RawResponseMessage, StreamReader]]):
aiohttp/client_proto.py:44:        self._read_timeout: Optional[float] = None
aiohttp/client_proto.py:45:        self._read_timeout_handle: Optional[asyncio.TimerHandle] = None
aiohttp/client_proto.py:194:        read_timeout: Optional[float] = None,
aiohttp/client_proto.py:202:        self._read_timeout = read_timeout
aiohttp/client_proto.py:224:        if self._read_timeout_handle is not None:
aiohttp/client_proto.py:225:            self._read_timeout_handle.cancel()

aiohttp/client_proto.py:226:            self._read_timeout_handle = None
aiohttp/client_
…[105 chars omitted]…
ut_handle is not None:
aiohttp/client_proto.py:231:            self._read_timeout_handle.cancel()
aiohttp/client_proto.py:234:            self._read_timeout_handle = self._loop.call_later(
aiohttp/client_proto.py:235:                timeout, self._on_read_timeout
aiohttp/client_proto.py:238:            self._read_timeout_handle = None
aiohttp/client_proto.py:243:    def _on_read_timeout(self) -> None:

import asyncio
from contextlib import suppress
from typing import Any, Optional, Tuple

from .base_protocol import BaseProtocol
from .client_exceptions import (
    ClientConnectionError,
    ClientOSError,
    ClientPayloadError,
    ServerDisconnectedError,
    SocketTimeoutError,
)

from .helpers import (
    _EXC_SENTINEL,
    BaseTimerContext,
    set_exception,
    set_result,
    status_code_must_be_empty_body,
)
from .http import HttpResponseParser, RawResponseMessage, WebSocketReader
from .http_exceptions import HttpProcessingError
from .streams import EMPTY_PAYLOAD, DataQueue, StreamReader


class ResponseHandler(BaseProtocol, DataQueue[Tuple[RawResponseMessage, StreamReader]]):
    """Helper class to adapt between Protocol and StreamReader."""

    def __init__(self, loop: asyncio.AbstractEventLoop) -> None:
        BaseProtocol.__init__(self, loop=loop)
        DataQueue.__
…[7922 chars omitted]…
       if self.transport is not None:
                        # connection.release() could be called BEFORE
                        # data_received(), the transport is already
                        # closed in this case
                        self.transport.close()
                    # should_close is True after the call
                    self.set_exception(HttpProcessingError(), underlying_exc)

if raise_for_status is None:
                pass
            elif callable(raise_for_status):
                await raise_for_status(resp)
            elif raise_for_status:
                resp.raise_for_status()

            # register connection
            if handle is not None:
                if resp.connection is not None:
                    resp.connection.add_callback(handle.cancel)
                else:

                    handle.cancel()

            resp._history = tuple(history)

            for trace in traces:
                await trace.send_request_end(
                    method, url.update_query(params), headers, resp
                )
            return resp

        except BaseException as e:
            # cleanup timer
            tm.close()
            if handle:
                handle.cancel()
                handle = None

            for trace i
…[6145 chars omitted]…
     message="Invalid connection header",
                    status=resp.status,
                    headers=resp.headers,
                )

            # key calculation
            r_key = resp.headers.get(hdrs.SEC_WEBSOCKET_ACCEPT, "")
            match = base64.b64encode(hashlib.sha1(sec_key + WS_KEY).digest()).decode()
            if r_key != match:
                raise WSServerHandshakeError(

raise WSServerHandshakeError(
                    resp.request_info,
                    resp.history,
                    message="Invalid challenge response",
                    status=resp.status,
                    headers=resp.headers,
                )

            # websocket protocol
            protocol = None
            if protocols and hdrs.SEC_WEBSOCKET_PROTOCOL in resp.headers:
                resp_protocols = [

                    proto.strip()
                    for proto in resp.headers[hdrs.SEC_WEBSOCKET_PROTOCOL].split(",")
                ]

                for proto in resp_protocols:
                    if proto in protocols:
                        protocol = proto
                        break

            # websocket compress
            notakeover = False
            if compress:
                compress_hdrs = resp.headers.get(hdrs.SEC_WEB
…[4113 chars omitted]…
orm HTTP OPTIONS request."""
            return _RequestContextManager(
                self._request(
                    hdrs.METH_OPTIONS, url, allow_redirects=allow_redirects, **kwargs
                )
            )

        def head(
            self, url: StrOrURL, *, allow_redirects: bool = False, **kwargs: Any
        ) -> "_RequestContextManager":
            """Perform HTTP HEAD request."""

39:from yarl import URL
57:    InvalidURL,
99:from .typedefs import JSONEncoder, LooseCookies, LooseHeaders, StrOrURL
116:    "InvalidURL",
172:    proxy: Union[StrOrURL, None]
251:        base_url: Optional[StrOrURL] = None,
281:        if base_url is None or isinstance(base_url, URL):
282:            self._base_url: Optional[URL] = base_url
284:            self._base_url = URL(base_url)
330:        self._requote_redirect_url = requote_redirect_url
375:        self, method: str, url: StrOrURL, **kwargs: Any
380:    def _build_url(self, str_or_url: StrOrURL) -> URL:

381:        url = URL(str_or_url)
391:        str_or_url: StrOrURL,
409:        proxy: Optional[StrOrURL] = None,
451:            url = self._build_url(str_or_url)
455:        if url.scheme not in HTTP_SCHEMA_SET:
465:                proxy = URL(proxy)
467:                raise InvalidURL(proxy) from e
510:                
…[1718 chars omitted]…
OrURL, *, data: Any = None, **kwargs: Any
1106:            self, url: StrOrURL, *, data: Any = None, **kwargs: Any
1114:            self, url: StrOrURL, *, data: Any = None, **kwargs: Any
1121:        def delete(self, url: StrOrURL, **kwargs: Any) -> "_RequestContextManager":
1162:        """Do URL requoting on redirection handling."""
1332:    url: StrOrURL,
1347:    proxy: Optional[StrOrURL] = None,

"InvalidUrlRedirectClientError",
    "NonHttpUrlRedirectClientError",
    "ServerConnectionError",
    "ServerDisconnectedError",
    "ServerFingerprintMismatch",
    "ServerTimeoutError",
    "SocketTimeoutError",
    "TooManyRedirects",
    "WSServerHandshakeError",
    # client_reqrep
    "ClientRequest",
    "ClientResponse",

    "Fingerprint",
    "RequestInfo",
    # connector
    "BaseConnector",
    "TCPConnector",
    "UnixConnector",
    "NamedPipeConnector",
    # client_ws
    "ClientWebSocketResponse",
    # client
    "ClientSession",
    "ClientTimeout",
    "request",
)


if TYPE_CHECKING:
    from ssl import SSLContext
else:
    SSLContext = None

if sys.version_info >= (3, 11) and TYPE_CHECKING:
    from typing import Unpack


class _RequestOptions(TypedDict, total=False):
    params: Union[Mapping[str, str], None]
    data: Any
    json: Any
    cookies: Union[L
…[6424 chars omitted]…
     tm = TimeoutHandle(
            self._loop, real_timeout.total, ceil_threshold=real_timeout.ceil_threshold
        )
        handle = tm.start()

        if read_bufsize is None:
aiohttp/client.py:212:HTTP_SCHEMA_SET = frozenset({"http", "https", ""})
aiohttp/client.py:455:        if url.scheme not in HTTP_SCHEMA_SET:
aiohttp/client.py:682:                        if scheme not in HTTP_SCHEMA_SET:

tests/test_client_functional.py:821:async def test_timeout_on_session_read_timeout(
tests/test_client_functional.py:842:async def test_read_timeout_between_chunks(aiohttp_client: Any, mocker: Any) -> None:
tests/test_client_functional.py:866:async def test_read_timeout_on_reading_chunks(aiohttp_client: Any, mocker: Any) -> None:
tests/test_client_functional.py:888:async def test_read_timeout_on_write(aiohttp_client: Any) -> None:
tests/test_client_functional.py:3335:async def test_read_timeout(aiohttp_client: Any) -> None:
tests/test_client_functional.py:3365:async def test_read_timeout_closes_connection(aiohttp_client: AiohttpClient) -> None:
tests/test_client_functional.py:3398:async def test_read_timeout_on_prepared_response(aiohttp_client: Any) -> None:
tests/test_client_proto.py:111:    proto.set_response_params(read_timeout=1)
tests/test_client_proto.py:112:    assert proto._rea
…[554 chars omitted]…
out_handle
tests/test_client_proto.py:133:    assert proto._read_timeout_handle is not None

tests/test_client_proto.py:134:    assert proto._read_timeout_handle is not h
tests/test_client_proto.py:139:    proto.set_response_params(read_timeout=1)
tests/test_client_proto.py:141:    assert proto._read_timeout_handle is not None
tests/test_client_proto.py:143:    assert proto._read_timeout_handle is None

tests/autobahn/client/fuzzingserver.json:3:   "url": "ws://localhost:9001",
tests/autobahn/server/fuzzingclient.json:8:            "url": "ws://localhost:9001",
tests/test_client_request.py:193:    req = make_request("get", "ws://python.org/")
tests/test_client_request.py:200:    req = make_request("get", "wss://python.org/")
tests/test_client_request.py:207:    req = make_request("get", "ws://python.org:960/")
tests/test_client_request.py:214:    req = make_request("get", "wss://python.org:960/")
tests/test_helpers.py:569:        ({"wss_proxy": "wss://aiohttp.io/path"}, "wss://aiohttp.io/path", "wss"),

CHANGES/3945.breaking.rst:1:Deprecate obsolete `timeout: float` and `receive_timeout: Optional[float]` in `ClientSession.ws_connect()`. Change default websocket receive timeout from `None` to `10.0`.
CHANGES/7941.feature:1:Added ``server_hostname`` parameter to ``ws_connect``.
CHANGES.rst:656:- Changed ``sock_read`` timeout to start after writing has finished, avoiding read timeouts caused by an unfinished write. -- by :user:`dtrifiro`
CHANGES.rst:1198:- Replace deprecated app handler design in ``tests/autobahn/server.py`` with call to ``web.run_app``; replace deprecated ``aiohttp.ws_connect`` calls in ``tests/autobahn/client.py`` with ``aiohttp.ClienSession.ws_connect``.
CHANGES.rst:1208:- Added ``params`` keyword argument to ``ClientSession.ws_connect``. --  :user:`hoh`.
CHANGES.rst:1867:- Add method argument to ``session.ws_connect()``.  Sometimes server API requires a
CHANGES.rst:2113:- Implement ``ClientTimeout`` class and support socket read timeout. (`#2768 <https://github.com/aio-libs/aiohttp/pull/2768>`_)
4.0.0a2.dev0 /repo/aiohttp/__init__.py

timeout: failed to run command ‘curl’: No such file or directory
rc=127

URLError <urlopen error [Errno -3] Temporary failure in name resolution>

0c97c00 base
* master

# type: ignore
from typing import Any
from unittest import mock

from yarl import URL

from aiohttp import http
from aiohttp.client_exceptions import ClientOSError, ServerDisconnectedError
from aiohttp.client_proto import ResponseHandler
from aiohttp.client_reqrep import ClientResponse
from aiohttp.helpers import TimerNoop

async def test_oserror(loop: Any) -> None:
    proto = ResponseHandler(loop=loop)
    transport = mock.Mock()
    proto.connection_made(transport)
    proto.connection_lost(OSError())

    assert proto.should_close
    assert isinstance(proto.exception(), ClientOSError)


async def test_pause_resume_on_error(loop: Any) -> None:
    proto = ResponseHandler(loop=loop)
    transport = mock.Mock()
    proto.connection_made(transport)

    proto.pause_reading()
    assert proto._reading_paused

    proto.resume_reading()
    assert not proto._reading_paused


async def
…[6461 chars omitted]…
nc def test_ws_connect_deflate_client_wbits(
687:            res = await aiohttp.ClientSession().ws_connect(
695:async def test_ws_connect_deflate_client_wbits_bad(
714:                await aiohttp.ClientSession().ws_connect("http://test.org", compress=15)
717:async def test_ws_connect_deflate_server_ext_bad(
735:                await aiohttp.ClientSession().ws_connect("http://test.org", compress=15)

tests/test_client_ws_functional.py:15:    import asyncio as async_timeout
tests/test_client_ws_functional.py:17:    import async_timeout
tests/test_client_ws_functional.py:398:async def test_close_timeout_sock_close_read(aiohttp_client: Any) -> None:
tests/test_client_ws_functional.py:410:    timeout = ClientWSTimeout(ws_close=0.2)
tests/test_client_ws_functional.py:411:    resp = await client.ws_connect("/", timeout=timeout, autoclose=False)
tests/test_client_ws_functional.py:424:async def test_close_timeout_deprecated(aiohttp_client: Any) -> None:
tests/test_client_ws_functional.py:438:        match="parameter 'timeout' of type 'float' "
tests/test_client_ws_functional.py:440:        r"'timeout=ClientWSTimeout\(ws_close=...\)'",
tests/test_client_ws_functional.py:442:        resp = await client.ws_connect("/", timeout=0.2, autoclose=False)
tests/test_client_ws_functional.py:546:asyn
…[5169 chars omitted]…
ders = {

        hdrs.UPGRADE: "websocket",
        hdrs.CONNECTION: "upgrade",
        hdrs.SEC_WEBSOCKET_ACCEPT: ws_key,
    }
    with mock.patch("aiohttp.client.os") as m_os:
        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
            m_os.urandom.return_value = key_data
            m_req.return_value = loop.create_future()
            m_req.return_value.set_result(resp)

client = await aiohttp_client(app)
    resp = await client.ws_connect("/", autoclose=False)
    await resp.send_bytes(b"ask")

    msg = await resp.receive()
    assert msg.data == "test"

    msg = await resp.receive()
    assert msg.type == aiohttp.WSMsgType.CLOSE
    assert msg.data == 1000
    assert msg.extra == ""
    assert not resp.closed

    await resp.close()
    await closed
    assert resp.closed


async def test_close_timeout_sock_close_read(aiohttp_client: Any) -> None:
    async def handler(request):
        ws = web.WebSocketResponse()
        await ws.prepare(request)
        await ws.receive_bytes()
        await ws.send_str("test")
        await asyncio.sleep(1)
        return ws

    app = web.Application()
    app.router.add_route("GET", "/", handler)
    client = await aiohttp_client(app)
    timeout = ClientWSTimeout(ws_close=0.2)
    resp = await client.ws
…[4662 chars omitted]…
ceive()
        if msg.type == aiohttp.WSMsgType.PING:
            ping_received = True
        await ws.close()
        return ws

    app = web.Application()
    app.router.add_route("GET", "/", handler)

    client = await aiohttp_client(app)
    resp = await client.ws_connect("/", heartbeat=0.01)
    await asyncio.sleep(0.1)
    await resp.receive()
    await resp.close()

    assert ping_received

Refused: `find /` walks the whole container FS. Scope under /repo.

3.12.13 (main, Aug  5 2026, 01:10:24) [GCC 14.2.0]
['/usr/local/lib/python3.12/site-packages']
total 20
drwxr-xr-x  5 root root 4096 Nov  4 21:16 .
drwxr-xr-x  3 root root 4096 Nov  4 21:15 ..
drwxr-xr-x 18 root root 4096 Nov  4 21:15 http-v2
drwxr-xr-x  2 root root 4096 Nov  4 21:16 selfcheck
drwxr-xr-x  5 root root 4096 Nov  4 21:16 wheels
pip 25.0.1 from /usr/local/lib/python3.12/site-packages/pip (python 3.12)

/root/.cache/pip/selfcheck/fe300af6f7d708c14827daac3afc81fbb8306b73de8dd6e3f1f8ea3b
/root/.cache/pip/wheels/3a/2a/71/6b7440057c755c3f53076056b834d2d9aad2531db1ed555be4/origin.json
/root/.cache/pip/wheels/3a/2a/71/6b7440057c755c3f53076056b834d2d9aad2531db1ed555be4/cffi-1.15.1-cp312-cp312-linux_x86_64.whl
/root/.cache/pip/wheels/16/cc/48/86b2f19a5c90663bd24b815a69f80de54f6afdc83bb6f172b7/origin.json
/root/.cache/pip/wheels/16/cc/48/86b2f19a5c90663bd24b815a69f80de54f6afdc83bb6f172b7/pycares-4.3.0-cp312-cp312-linux_x86_64.whl
/root/.cache/pip/wheels/62/21/26/24e73e5cb8863075e1ce495d0ae12d6c6b89f81844efb9e586/origin.json
/root/.cache/pip/wheels/62/21/26/24e73e5cb8863075e1ce495d0ae12d6c6b89f81844efb9e586/regex-2023.6.3-cp312-cp312-linux_x86_64.whl
/root/.cache/pip/http-v2/1/1/b/8/4/11b84327bf2b099da7db61bb6e9bd516c46829d9a9bcf7578f728822.body
/root/.cache/pip/http-v2/1/1/b/8/4/11b84327bf2b0
…[8629 chars omitted]…
.3.dist-info
requests

requests-2.31.0.dist-info
setuptools_git
setuptools_git-1.2.dist-info
six-1.16.0.dist-info
six.py
tests
tomli
tomli-2.0.1.dist-info
tqdm
tqdm-4.65.0.dist-info
trustme
trustme-1.1.0.dist-info
typer
typer-0.9.0.dist-info
typing_extensions-4.10.0.dist-info
typing_extensions.py
urllib3
urllib3-2.0.4.dist-info
uvloop
uvloop-0.19.0.dist-info
wait_for_it
wait_for_it-2.2.2.dist-info
yarl

/root/.cache/pip/http-v2/5/1/5/a/8/515a85c9d40cdae10a48318c07d7fdf7dd4cc33da7f1a2f2e056767f.body
/root/.cache/pip/http-v2/e/4/0/f/c/e40fc2e85bc37589d95cf7beb50fae382b8da7544f35eec61cc1015d.body
/root/.cache/pip/http-v2/f/b/e/3/a/fbe3a5eb3735a745707ab3bf39e17d76ea29c7cd1eaa7763f11e1766.body
/root/.cache/pip/http-v2/9/a/8/7/4/9a874ca0d6928a040f48fe00be58b57438f10e0c33e2d2d00b3c79ce.body
/root/.cache/pip/http-v2/2/c/a/9/3/2ca935c910c0dccdc2af96540a200cdd85c10703d673e78548927b25.body
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found

bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: c
…[4721 chars omitted]…
mand not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found
bash: line 58: file: command not found

==== /root/.cache/pip/http-v2/5/1/5/a/8/515a85c9d40cdae10a48318c07d7fdf7dd4cc33da7f1a2f2e056767f.body
Metadata-Version: 2.1
Name: uvloop
Version: 0.19.0
Summary: Fast implementation of asyncio event loop on top of libuv
Author-email: Yury Selivanov <yury@magic.io>
License: MIT License
Project-URL: github, https://github.com/MagicStack/uvloop
Keywords: asyncio,networking
Classifier: Development Statu

==== /root/.cache/pip/http-v2/e/4/0/f/c/e40fc2e85bc37589d95cf7beb50fae382b8da7544f35eec61cc1015d.body

Metadata-Version: 2.1
Name: proxy.py
Version: 2.4.4
Summary: 
 Fast 
 Lightweight 
 Dependency 
 Pluggable 
 TLS interception 
 DNS-over-HTTPS 
 Poor Mans VPN 
 Reverse & 
 Forward 
 Proxy Server framework 
 Web Server framewor

==== /root/.cache/pip/http-v2/f/b/e/3/a/fbe3a5eb3735a745707ab3bf39e17d76ea29c7cd1eaa7763f11e1766.body
Metadata-Version: 2.1
Name: aiosignal
Version: 1.3.1
Summary
…[645 chars omitted]…

==== /root/.cache/pip/http-v2/2/c/a/9/3/2ca935c910c0dccdc2af96540a200cdd85c10703d673e78548927b25.body
Metadata-Version: 2.1
Name: yarl
Version: 1.9.4
Summary: Yet another URL library
Home-page: https://github.com/aio-libs/yarl
Author: Andrew Svetlov
Author-email: andrew.svetlov@gmail.com
Maintainer: aiohttp team <team@aiohttp.org>
Maintainer-email: team@aiohttp.org
License: Apache-2.0
Project-URL: C

docs/client_reference.rst:45:                         cookie_jar=None, read_timeout=None, \
docs/client_reference.rst:145:   :param float read_timeout: Request operations timeout. ``read_timeout`` is
673:   .. method:: ws_connect(url, *, method='GET', \
1507:To connect to a websocket server :func:`aiohttp.ws_connect` or
1508::meth:`aiohttp.ClientSession.ws_connect` coroutines should be used, do
grep: aiohttp/__pycache__/client.cpython-312.pyc: binary file matches
grep: aiohttp/__pycache__/client_exceptions.cpython-312.pyc: binary file matches
grep: aiohttp/__pycache__/__init__.cpython-312.pyc: binary file matches
tests/test_client_functional.py:28:    NonHttpUrlClientError,
tests/test_client_functional.py:2455:            (url, message, NonHttpUrlClientError)
aiohttp/client.py:60:    NonHttpUrlClientError,
aiohttp/client.py:119:    "NonHttpUrlClientError",

aiohttp/client.py:212:HTTP_S
…[208 chars omitted]…
                  if scheme not in HTTP_SCHEMA_SET:
aiohttp/client_exceptions.py:45:    "NonHttpUrlClientError",
aiohttp/client_exceptions.py:292:class NonHttpUrlClientError(ClientError):
aiohttp/client_exceptions.py:300:class NonHttpUrlRedirectClientError(NonHttpUrlClientError, RedirectClientError):
aiohttp/__init__.py:31:    NonHttpUrlClientError,
aiohttp/__init__.py:139:    "NonHttpUrlClientError",

-rw-r--r-- 1 root root 49444 Nov  4 21:17 aiohttp/__pycache__/client.cpython-312.pyc
-rw-r--r-- 1 root root 15983 Nov  4 21:17 aiohttp/__pycache__/client_exceptions.cpython-312.pyc
-rw-r--r-- 1 root root 11335 Nov  4 21:17 aiohttp/__pycache__/client_proto.cpython-312.pyc
-rw-r--r-- 1 root root 51799 Nov  4 21:17 aiohttp/__pycache__/client_reqrep.cpython-312.pyc
-rw-r--r-- 1 root root 17718 Nov  4 21:17 aiohttp/__pycache__/client_ws.cpython-312.pyc
-rw-r--r-- 1 root root 49429 Nov  4 21:13 aiohttp/client.py
FOUND _request ('closed', 'RuntimeError', 'isinstance', 'SSL_ALLOWED_TYPES', 'TypeError', 'format', 'ValueError', 'payload', 'JsonPayload', '_json_serialize', '_version', '_prepare_headers', '_build_url', 'InvalidUrlClientError', 'scheme', 'HTTP_SCHEMA_SET', 'NonHttpUrlClientError', 'set', '_skip_auto_headers', 'add', 'istr', 'URL', 'InvalidURL', 'sentinel', '_timeout', 'TimeoutHand
…[8630 chars omitted]…
2092 -> 2806 [0]
  2094 to 2138 -> 2622 [2]
  2140 to 2160 -> 2806 [0]
  2164 to 2266 -> 2806 [0]

  2270 to 2296 -> 2632 [0]
  2298 to 2538 -> 2806 [0]
  2540 to 2616 -> 2866 [0] lasti
  2622 to 2630 -> 2806 [0]
  2632 to 2648 -> 2800 [1] lasti
  2650 to 2788 -> 2790 [1] lasti
  2790 to 2798 -> 2800 [1] lasti
  2800 to 2804 -> 2806 [0]
  2806 to 2858 -> 2860 [1] lasti
  2860 to 2864 -> 2866 [0] lasti

/opt:
total 8
drwxr-xr-x 2 root root 4096 Aug  3 00:00 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..

/root:
total 24
drwx------ 1 root root 4096 Nov  4 21:15 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..
-rw-r--r-- 1 root root  607 Jul  4 09:05 .bashrc
drwxr-xr-x 3 root root 4096 Nov  4 21:15 .cache
-rw-r--r-- 1 root root  132 Jul  4 09:05 .profile

-rw-r--r-- 1 root root  169 Aug  5 01:04 .wget-hsts

/tmp:
total 8
drwxrwxrwt 1 root root 4096 Nov  4 21:16 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..
-rw-r--r-- 1 root root    0 Nov  4 21:16 install.log
/tmp/install.log
/root/.bashrc
/root/.profile
/root/.wget-hsts

total 24
drwxr-xr-x 1 root root 4096 Nov  4 21:13 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..
-rw-r--r-- 1 root root 2391 Nov  4 21:13 .TEMPLATE.rst
-rw-r--r-- 1 root root  382 Nov  4 21:13 .gitignore
-rw-r--r-- 1 root root   96 Nov  4 21:13 2174.bugfix
-rw-r--r-- 1 root root  136 Nov  4 21:13 2492.feature
lrwxrwxrwx 1 root root   12 Nov  4 21:13 2507.feature.rst -> 6722.feature
-rw-r--r-- 1 root root  115 Nov  4 21:13 2835.breaking.rst
-rw-r--r-- 1 root root   25 Nov  4 21:13 2977.breaking.rst
-rw-r--r-- 1 root root   73 Nov  4 21:13 3310.bugfix
lrwxrwxrwx 1 root root   12 Nov  4 21:13 3315.feature.rst -> 6722.feature

-rw-r--r-- 1 root root   91 Nov  4 21:13 3462.feature
-rw-r--r-- 1 root root  123 Nov  4 21:13 3463.breaking.rst
-rw-r--r-- 1 root root  119 Nov  4 21:13 3482.bugfix
-rw-r--r-- 1 root root   68 Nov  4 21:13 3538.breaking.rst
-rw-r--r-- 1 root root  105 Nov  4 21:13 35
…[8629 chars omitted]…
d be useful to them. Then, when the maintainers publish
a new release, they'll automatically use these records to compose
a change log for the respective version. It is important to
understand that including unnecessary low-level implementation
related details generates noise that is not particularly useful
to the end-users most of the time. And so such details should be
1:__version__ = "4.0.0a2.dev0"

77:    import ssl
78:    from ssl import SSLContext
80:    ssl = None  # type: ignore[assignment]
139:        if not transport.get_extra_info("sslcontext"):
141:        sslobj = transport.get_extra_info("ssl_object")
142:        cert = sslobj.getpeercert(binary_form=True)
149:if ssl is not None:
150:    SSL_ALLOWED_TYPES = (ssl.SSLContext, bool, Fingerprint)
161:    is_ssl: bool
162:    ssl: Union[SSLContext, bool, Fingerprint]
216:        ssl: Union[SSLContext, bool, Fingerprint] = True,
251:        self._ssl = ssl

77:    import ssl
78:    from ssl import SSLContext
80:    ssl = None  # type: ignore[assignment]
139:        if not transport.get_extra_info("sslcontext"):
141:        sslobj = transport.get_extra_info("ssl_object")
142:        cert = sslobj.getpeercert(binary_form=True)
149:if ssl is not None:
150:    SSL_ALLOWED_TYPES = (ssl.SSLContext, bool, Fingerprint)
161:    is_ssl
…[1452 chars omitted]…
257:            if not req.is_ssl():
aiohttp/connector.py:1262:        if req.is_ssl():
aiohttp/client_reqrep.py:161:    is_ssl: bool
aiohttp/client_reqrep.py:289:    def is_ssl(self) -> bool:
aiohttp/client_reqrep.py:290:        return self.url.scheme in ("https", "wss")
aiohttp/client_reqrep.py:306:            self.is_ssl(),
aiohttp/client_reqrep.py:608:        elif self.proxy and not self.is_ssl():

docs/client_quickstart.rst:385:   async with session.ws_connect('http://example.org/ws') as ws:
docs/client_reference.rst:673:   .. method:: ws_connect(url, *, method='GET', \
docs/testing.rst:796:   .. method:: ws_connect(path, *args, **kwargs)
examples/client_ws.py:38:        async with session.ws_connect(url, autoclose=False, autoping=False) as ws:
./aiohttp/client.py-207-# 5 Minute default read timeout
./aiohttp/client.py-208-DEFAULT_TIMEOUT: Final[ClientTimeout] = ClientTimeout(total=5 * 60)
./aiohttp/client.py-209-
./aiohttp/client.py-210-# https://www.rfc-editor.org/rfc/rfc9110#section-9.2.2
./aiohttp/client.py-211-IDEMPOTENT_METHODS = frozenset({"GET", "HEAD", "OPTIONS", "TRACE", "PUT", "DELETE"})
./aiohttp/client.py:212:HTTP_SCHEMA_SET = frozenset({"http", "https", ""})
./aiohttp/client.py-213-
./aiohttp/client.py-214-_RetType = TypeVar("_RetType")

./aiohttp/client.py-215-_Ch
…[2008 chars omitted]…
client.py-687-
./aiohttp/client.py-688-                        is_same_host_https_redirect = (
./aiohttp/client.py-689-                            url.host == parsed_redirect_url.host
./aiohttp/client.py-690-                            and parsed_redirect_url.scheme == "https"
./aiohttp/client.py-691-                            and url.scheme == "http"
./aiohttp/client.py-692-                        )

CHANGES/6722.feature:2::py:exc:`~aiohttp.NonHttpUrlClientError`, :py:exc:`~aiohttp.InvalidUrlRedirectClientError`,
CHANGES/6722.feature:3::py:exc:`~aiohttp.NonHttpUrlRedirectClientError`
CHANGES/6722.feature:5::py:exc:`~aiohttp.InvalidUrlRedirectClientError`, :py:exc:`~aiohttp.NonHttpUrlRedirectClientError`
CHANGES/6722.feature:8::py:exc:`~aiohttp.NonHttpUrlClientError` are base for them.
CHANGES.rst:749:- Completed ``trust_env`` parameter description to honor ``wss_proxy``, ``ws_proxy`` or ``no_proxy`` env.
CHANGES.rst:1112:  By default, the transport is secure if https or wss scheme is used.
HISTORY.rst:1814:- Use X-FORWARDED-PROTO for wsgi.url_scheme when available
HISTORY.rst:1863:- Store http code and headers in WSServerHandshakeError (`#706 <https://github.com/aio-libs/aiohttp/pull/706>`_)
HISTORY.rst:1950:- Make '=' char and 'wss://' schema safe in urls (`#477 <https://github.com/aio-libs/aiohttp/pull/477>`_)

`#2988 <https://github.com/aio-libs/aiohttp/issues/2988>`_
- Switch from ``http-parser`` to ``llhttp``
  `#3561 <https://github.com/aio-libs/aiohttp/issues/3561>`_
- Use Brotli instead of brotlipy
  `#3803 <https://github.com/aio-libs/aiohttp/issues/3803>`_
- Disable implicit switch-back to pure python mode. The build fails loudly if aiohttp
  cannot be compiled with C Accelerators.  Use AIOHTTP_NO_EXTENSIONS=1 to explicitly
  disable C Extensions complication and switch to Pure-Python mode.  Note that Pure-Python
  mode is significantly slower than compiled one.
  `#3828 <https://github.com/aio-libs/aiohttp/issues/3828>`_
- Make access log use local time with timezone
  `#3853 <https://github.com/aio-libs/aiohttp/issues/3853>`_

- Implemented ``readuntil`` in ``StreamResponse``
  `#4054 <https://github.com/aio-libs/aiohttp/issues/4054>`_
- FileResponse now supports ETag.
  `#4594 <h
…[6755 chars omitted]…
89`.



- Treated values of ``Accept-Encoding`` header as case-insensitive when checking
  for gzip files -- by :user:`steverep`.


  *Related issues and pull requests on GitHub:*
  :issue:`8104`.



- Improved the DNS resolution performance on cache hit -- by :user:`bdraco`.

  This is achieved by avoiding an :mod:`asyncio` task creation in this case.


  *Related issues and pull requests on GitHub:*

# Generated by Docker Engine.
# This file can be edited; Docker Engine will not make further changes once it
# has been modified.

nameserver 192.168.65.7

# Based on host file: '/etc/resolv.conf' (legacy)
# Overrides: []
lock
partial

aiodns
aiodns-3.2.0.dist-info
aiohappyeyeballs
aiohappyeyeballs-2.3.2.dist-info
aiosignal
aiosignal-1.3.1.dist-info
template

def test_host_port_default_https(make_request: Any) -> None:
    req = make_request("get", "https://python.org/")
    assert req.host == "python.org"
    assert req.port == 443
    assert req.is_ssl()


def test_host_port_nondefault_http(make_request: Any) -> None:
    req = make_request("get", "http://python.org:960/")
    assert req.host == "python.org"
    assert req.port == 960
    assert not req.is_ssl()

def test_host_port_nondefault_https(make_request: Any) -> None:
    req = make_request("get", "https://python.org:960/")
    assert req.host == "python.org"
    assert req.port == 960
    assert req.is_ssl()


def test_host_port_default_ws(make_request: Any) -> None:
    req = make_request("get", "ws://python.org/")
    assert req.host == "python.org"
    assert req.port == 80
    assert not req.is_ssl()


def test_host_port_default_wss(make_request: Any) -> None:
    req = ma
…[4501 chars omitted]…
r(
                    f"Can not parse http version number: {version}"
                ) from None
        self.version = version

    def update_headers(self, headers: Optional[LooseHeaders]) -> None:
        """Update request headers."""
        self.headers: CIMultiDict[str] = CIMultiDict()

        # add host
        netloc = cast(str, self.url.raw_host)
        if helpers.is_ipv6_address(netloc):

285-        if netrc_obj and auth is None:
286-            if proxy.host is not None:
287-                try:
288-                    auth = basicauth_from_netrc(netrc_obj, proxy.host)
289-                except LookupError:
290-                    auth = None
291-        ret[proto] = ProxyInfo(proxy, auth)
292-    return ret
293-
294-
295:def get_env_proxy_for_url(url: URL) -> Tuple[URL, Optional[BasicAuth]]:
296-    """Get a permitted proxy for the given URL from the env."""

297-    if url.host is not None and proxy_bypass(url.host):
298-        raise LookupError(f"Proxying is disallowed for `{url.host!r}`")
299-
300-    proxies_in_env = proxies_from_env()
301-    try:
302-        proxy_info = proxies_in_env[url.scheme]
303-    except KeyError:
304-        raise LookupError(f"No proxies found for `{url!s}` in the env")
305-    else:
306-        return proxy_info.proxy, proxy_info.p
…[991 chars omitted]…
343-        params.add(key.lower().strip(), value.strip(' "'))
344-
345-    fulltype = parts[0].strip().lower()
346-    if fulltype == "*":
347-        fulltype = "*/*"
348-
349-    mtype, _, stype = fulltype.partition("/")
350-    stype, _, suffix = stype.partition("+")
351-
352-    return MimeType(
353-        type=mtype, subtype=stype, suffix=suffix, parameters=MultiDictProxy(params)
354-    )
355-

client_logger.warning("Could not parse .netrc file: %s", e)
    except OSError as e:
        netrc_exists = False
        with contextlib.suppress(OSError):
            netrc_exists = netrc_path.is_file()
        # we couldn't read the file (doesn't exist, permissions, etc.)
        if netrc_env or netrc_exists:
            # only warn if the environment wanted us to load it,
            # or it appears like the default file does actually exist
            client_logger.warning("Could not read .netrc file: %s", e)

    return None

@dataclasses.dataclass(frozen=True)
class ProxyInfo:
    proxy: URL
    proxy_auth: Optional[BasicAuth]


def basicauth_from_netrc(netrc_obj: Optional[netrc.netrc], host: str) -> BasicAuth:
    """
    Return :py:class:`~aiohttp.BasicAuth` credentials for ``host`` from ``netrc_obj``.

    :raises LookupError: if ``netrc_obj`` is :py:data:`None` or 
…[2001 chars omitted]…
env()
    try:
        proxy_info = proxies_in_env[url.scheme]
    except KeyError:
        raise LookupError(f"No proxies found for `{url!s}` in the env")
    else:
        return proxy_info.proxy, proxy_info.proxy_auth


@dataclasses.dataclass(frozen=True)
class MimeType:
1035:        """Issue a warning if the requested URL has HTTPS scheme."""
1036:        if req.request_info.url.scheme != "https":

grep: aiohttp/__pycache__/client.cpython-312.pyc: binary file matches
grep: aiohttp/__pycache__/client_ws.cpython-312.pyc: binary file matches
aiohttp/client.py:79:    DEFAULT_WS_CLIENT_TIMEOUT,
aiohttp/client.py:827:            ws_timeout = DEFAULT_WS_CLIENT_TIMEOUT
aiohttp/client.py:845:                "'timeout=ClientWSTimeout(ws_receive=...)'",
aiohttp/client.py:849:            ws_timeout = dataclasses.replace(ws_timeout, ws_receive=receive_timeout)
aiohttp/client_ws.py:35:class ClientWSTimeout:
aiohttp/client_ws.py:36:    ws_receive: Optional[float] = None
aiohttp/client_ws.py:40:DEFAULT_WS_CLIENT_TIMEOUT: Final[ClientWSTimeout] = ClientWSTimeout(
aiohttp/client_ws.py:41:    ws_receive=None, ws_close=10.0
aiohttp/client_ws.py:261:                        timeout or self._timeout.ws_receive
tests/test_client_ws_functional.py:583:    receive_timeout = ClientWSTimeout(ws_receive=0.1)

…[4006 chars omitted]…
f._conn is not None
                    else 5
                ),
            )

    def _pong_not_received(self) -> None:
        if not self._closed:
            self._closed = True
            self._close_code = WSCloseCode.ABNORMAL_CLOSURE
            self._exception = asyncio.TimeoutError()
            self._response.close()

    @property
    def closed(self) -> bool:
        return self._closed

5075
5191
5258
5278
5284
5284
5287
5516
5533
5558
5634
5783

5806
5829
5870
5894
6180
6181
6193
6547
6721
6722
6979
6998
7107
7265
7297
7583
7677
7772
7784
7801
7815
7829
7941
7954
8048
8062
8088
8139
8197
8270
8303
8346
8364
8403
8463
8491
8498
8501
6721.misc: Remove unused argument `max_headers` of HeadersParser. 
6722.feature: Added 5 new exceptions: :py:exc:`~aiohttp.InvalidUrlClientError`, :py:exc:`~aiohttp.RedirectClientError`, :py:exc:`~aiohttp.NonHttpUrlClientError`, :py:exc:`~aiohttp.InvalidUrlRedirectClientError`, :py:exc:`~aiohttp.NonHttpUrlRedirectClientError`  :py:exc:`~aiohttp.InvalidUrlRedirectClientError`, :py:exc:`~aiohttp.NonHttpUrlRedirectClientError` are raised instead of :py:exc:`ValueError` or :py:exc:`~aiohttp.InvalidURL` when the redirect URL is invalid. Classes :py:exc:`~aiohttp.InvalidUrlClientError`, :py:exc:`~aiohttp.RedirectClientError`, :py:exc:`~aiohttp.N
…[3952 chars omitted]…
or the `ssl` params. 
8463.misc.rst: Added a 3.11-specific overloads to ``ClientSession``  -- by :user:`max-muoto`. 
8491.misc.rst: Simplified path checks for ``UrlDispatcher.add_static()`` method -- by :user:`steverep`. 
8498.misc.rst: Avoid creating a future on every websocket receive -- by :user:`bdraco`. 
8501.misc.rst: Use identity checks for all ``WSMsgType`` type compares -- by :user:`bdraco`.

16

total 16
drwxr-xr-x 3 root root 4096 Nov  4 21:16 .
drwxr-xr-x 1 root root 4096 Nov  4 21:16 ..
drwxr-xr-x 4 root root 4096 Nov  4 21:16 python_on_whales
/usr/local/lib/python3.12/site-packages/tests/python_on_whales/test_exceptions.py
/usr/local/lib/python3.12/site-packages/tests/python_on_whales/test_utils.py
/usr/local/lib/python3.12/site-packages/tests/python_on_whales/test_docker_client.py
/usr/local/lib/python3.12/site-packages/tests/python_on_whales/test_download_binaries.py
/usr/local/lib/python3.12/site-packages/tests/python_on_whales/test_client_config.py
template

total 40
drwxr-xr-x 1 root root 4096 Aug  5 01:04 .
drwxr-xr-x 1 root root 4096 Aug  3 00:00 ..
drwxr-xr-x 2 root root 4096 May  6  2025 adduser
drwxr-xr-x 1 root root 4096 Aug  5 01:04 apt
drwxr-xr-x 1 root root 4096 Nov  4 21:15 debconf
drwx------ 1 root root 4096 Nov  4 21:15 ldconfig
total 12
drwxr-xr-x 2 root root 4096 Jul  4 09:05 .
drwxr-xr-x 1 root root 4096 Aug  3 00:00 ..

Package: python3-aiohttp
Source: python-aiohttp
Version: 3.11.16-1+deb13u1
Installed-Size: 1732
Maintainer: Debian Python Team <team+python@tracker.debian.org>
Architecture: amd64
Depends: python3-yarl (>= 1.18.3), python3-async-timeout (>= 4.0.1), python3 (<< 3.14), python3 (>= 3.13~), python3-aiohappyeyeballs, python3-aiosignal, python3-attr, python3-frozenlist, python3-multidict, python3-propcache, python3:any, libc6 (>= 2.14)
Recommends: libjs-jquery, python3-aiodns
Description: http client/server for asyncio
Description-md5: f730c1eb49e4f113817da234d7a43357
Homepage: https://aiohttp.readthedocs.org
Section: python

Priority: optional
Filename: pool/main/p/python-aiohttp/python3-aiohttp_3.11.16-1+deb13u1_amd64.deb
Size: 405784
MD5sum: 831439a8a390cb72059733588f5bd21c
SHA256: bfd26da23cb1d797121644a62c88deb9dc3c48bbf2dd1024facde12711aae845

auxfiles
deb.debian.org_debian-security_dists_trixie-security_InRelease
deb.debian.org_debian-security_dists_trixie-security_main_binary-amd64_Packages.lz4
deb.debian.org_debian_dists_trixie-updates_InRelease
deb.debian.org_debian_dists_trixie-updates_main_binary-amd64_Packages.lz4
deb.debian.org_debian_dists_trixie_InRelease
deb.debian.org_debian_dists_trixie_main_binary-amd64_Packages.lz4
lock
partial

Ign:1 http://deb.debian.org/debian trixie/main amd64 python3-aiohttp amd64 3.11.16-1+deb13u1
Ign:1 http://deb.debian.org/debian trixie/main amd64 python3-aiohttp amd64 3.11.16-1+deb13u1
Ign:1 http://deb.debian.org/debian trixie/main amd64 python3-aiohttp amd64 3.11.16-1+deb13u1
Ign:1 http://deb.debian.org/debian trixie/main amd64 python3-aiohttp amd64 3.11.16-1+deb13u1
Err:1 http://deb.debian.org/debian trixie/main amd64 python3-aiohttp amd64 3.11.16-1+deb13u1
  Temporary failure resolving 'deb.debian.org'
E: Failed to fetch http://deb.debian.org/debian-security/pool/updates/main/p/python-aiohttp/python3-aiohttp_3.11.16-1%2bdeb13u1_amd64.deb  Temporary failure resolving 'deb.debian.org'

960 695 0:102 / / rw,relatime - overlay overlay rw,lowerdir=/var/lib/desktop-containerd/daemon/io.containerd.snapshotter.v1.overlayfs/snapshots/98865/fs:/var/lib/desktop-containerd/daemon/io.containerd.snapshotter.v1.overlayfs/snapshots/4/fs:/var/lib/desktop-containerd/daemon/io.containerd.snapshotter.v1.overlayfs/snapshots/3/fs:/var/lib/desktop-containerd/daemon/io.containerd.snapshotter.v1.overlayfs/snapshots/2/fs:/var/lib/desktop-containerd/daemon/io.containerd.snapshotter.v1.overlayfs/snapshots/1/fs,upperdir=/var/lib/desktop-containerd/daemon/io.containerd.snapshotter.v1.overlayfs/snapshots/98866/fs,workdir=/var/lib/desktop-containerd/daemon/io.containerd.snapshotter.v1.overlayfs/snapshots/98866/work
962 960 0:172 / /proc rw,nosuid,nodev,noexec,relatime - proc proc rw
963 960 0:173 / /dev rw,nosuid - tmpfs tmpfs rw,size=65536k,mode=755
964 963 0:174 / /dev/pts rw,nosuid,noexec,rel
…[1448 chars omitted]…
 /proc/sysrq-trigger ro,nosuid,nodev,noexec,relatime - proc proc rw
713 962 0:177 / /proc/acpi ro,relatime - tmpfs tmpfs ro,size=4k,nr_inodes=1
714 962 0:173 /null /proc/interrupts rw,nosuid - tmpfs tmpfs rw,size=65536k,mode=755
715 962 0:173 /null /proc/kcore rw,nosuid - tmpfs tmpfs rw,size=65536k,mode=755
total 12
drwx------ 1 _apt root 4096 Nov  4 21:14 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..

/mnt:
total 8
drwxr-xr-x 2 root root 4096 Aug  3 00:00 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..
127.0.0.1	localhost
::1	localhost ip6-localhost ip6-loopback
fe00::	ip6-localnet
ff00::	ip6-mcastprefix
ff02::1	ip6-allnodes
ff02::2	ip6-allrouters
e5f8bb59662c

8-import json
9-import pathlib
10-import socket
11-import ssl
12-import sys
13-import time
14-from typing import Any, AsyncIterator, Type
15-from unittest import mock
16-
17-import pytest
18-from multidict import MultiDict
19-from yarl import URL

20-
21-import aiohttp
22-from aiohttp import Fingerprint, ServerFingerprintMismatch, hdrs, web
23-from aiohttp.abc import AbstractResolver
24-from aiohttp.client_exceptions import (
25-    InvalidURL,
26-    InvalidUrlClientError,
27-    InvalidUrlRedirectClientError,
28:    NonHttpUrlClientError,
29-    NonHttpUrlRedirectClientError,
30-    SocketTimeoutError,
31-    TooManyRedirects,
32-)
33-from aiohttp.pytest_plugin import AiohttpClient, TestClient
34-from aiohttp.test_utils import unused_port
35-
36-
37-@pytest.fixture
38-def here():
39-    return pathlib.Path(__file__).parent
40-
41-
42-@pytest.fixture
43-def fname(here: Any):
44-    re
…[8629 chars omitted]…
2474-            (url, message, InvalidUrlRedirectClientError)
2475-            for (url, message) in INVALID_URL_WITH_ERROR_MESSAGE_YARL_ORIGIN
2476-            + INVALID_URL_WITH_ERROR_MESSAGE_YARL_NEW
2477-        ),
2478-        *(
2479-            (url, message, NonHttpUrlRedirectClientError)
2480-            for (url, message) in NON_HTTP_URL_WITH_ERROR_MESSAGE
2481-        ),
2482-    ),
2483-)

app.router.add_post("/", handler)
    client = await aiohttp_client(app)

    async with client.post(
        "/", headers={"Content-Type": "application/json", "x-api-key": "foo"}
    ) as resp:
        assert resp.status == 200


async def test_redirect_to_absolute_url(aiohttp_client: Any) -> None:
    async def handler(request):
        return web.Response(text=request.method)

    async def redirect(request):
        raise web.HTTPFound(location=client.make_url("/"))

    app = web.Application()
    app.router.add_get("/", handler)
    app.router.add_get("/redirect", redirect)

    client = await aiohttp_client(app)
    async with client.get("/redirect") as resp:
        assert 200 == resp.status


async def test_redirect_without_location_header(aiohttp_client: Any) -> None:
    body = b"redirect"

    async def handler_redirect(request):
        return web.Response(status=301,
…[675 chars omitted]…
TH_ERROR_MESSAGE = (
    ("call:+380123456789", r"call:\+380123456789"),
    ("skype:handle", "skype:handle"),
    ("slack://instance/room", "slack://instance/room"),
    ("steam:code", "steam:code"),
    ("twitter://handle", "twitter://handle"),
    ("bluesky://profile/d:i:d", "bluesky://profile/d:i:d"),
)


@pytest.mark.parametrize(
    ("url", "error_message_url", "expected_exception_class"),
    (

Iface	Destination	Gateway 	Flags	RefCnt	Use	Metric	Mask		MTU	Window	IRTT                                                       
Main:
  +-- 127.0.0.0/8 2 0 2
     +-- 127.0.0.0/31 1 0 0
        |-- 127.0.0.0
           /8 host LOCAL
        |-- 127.0.0.1
           /32 host LOCAL
     |-- 127.255.255.255
        /32 link BROADCAST
Local:
  +-- 127.0.0.0/8 2 0 2

     +-- 127.0.0.0/31 1 0 0
        |-- 127.0.0.0
           /8 host LOCAL
        |-- 127.0.0.1
           /32 host LOCAL
     |-- 127.255.255.255
        /32 link BROADCAST
1.1.1.1 OSError [Errno 101] Network is unreachable
8.8.8.8 OSError [Errno 101] Network is unreachable
192.168.65.7 OSError [Errno 101] Network is unreachable
151.101.0.223 OSError [Errno 101] Network is unreachable

aiohttp/client.py:690:                            and parsed_redirect_url.scheme == "https"
aiohttp/client.py:691:                            and url.scheme == "http"
aiohttp/http_parser.py:606:            if url.scheme == "":
aiohttp/web_request.py:314:        return self.scheme == "https"
tests/test_client_functional.py:2722:        if url.scheme == "https":
tests/test_test_utils.py:217:    assert client.scheme == "http"
tests/test_test_utils.py:233:    assert client.scheme == "http"
tests/test_web_request.py:168:    assert req.scheme == "https"
tests/test_web_request.py:712:    assert req2.scheme == "https"
755:    def ws_connect(
780:            self._ws_connect(
803:    async def _ws_connect(

no
total 52
drwxr-xr-x 1 root root 4096 Nov  4 21:14 .
drwxr-xr-x 1 root root 4096 Aug  3 00:00 ..
drwxr-xr-x 1 root root 4096 Nov  4 21:15 apt
drwxr-xr-x 1 root root 4096 Nov  4 21:15 dpkg
drwxr-xr-x 2 root root 4096 Jul 30  2025 git
drwxr-xr-x 2 root root 4096 Jul  4 09:05 misc
drwxr-xr-x 2 root root 4096 Aug  3 00:00 pam
-rw-r--r-- 1 root root   84 Aug  3 00:00 shells.state
drwxr-xr-x 1 root root 4096 Nov  4 21:14 systemd

count: 401
size: 1628
in-pack: 0
packs: 0
size-pack: 0
prune-packable: 0
garbage: 0
size-garbage: 0
.git/objects/info:
total 0
drwxr-xr-x 1 root root 4096 Nov  4 21:14 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..

.git/objects/pack:
total 0
drwxr-xr-x 1 root root 4096 Nov  4 21:14 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..
[core]
	repositoryformatversion = 0
	filemode = true
	bare = false
	logallrefupdates = true
	ignorecase = true
.git/COMMIT_EDITMSG
.git/config
.git/description
.git/HEAD
.git/hooks/applypatch-msg.sample
.git/hooks/commit-msg.sample
.git/hooks/fsmonitor-watchman.sample
.git/hooks/post-update.sample
.git/hooks/pre-applypatch.sample
.git/hooks/pre-commit.sample
.git/hooks/pre-merge-commit.sample
.git/hooks/pre-push.sample
.git/hooks/pre-rebase.sample
.git/hooks/pre-receive.sample
.git/hooks/prepare-commit-msg.sample
.git/hooks/push-to-checkout.sample
.git/hooks/sendemail-validate.sample
.git/hooks/update.sample
.git/index
.git/info/exclude
.git/logs/HEAD

aiohttp/client.py:212:HTTP_SCHEMA_SET = frozenset({"http", "https", ""})
aiohttp/client.py:455:        if url.scheme not in HTTP_SCHEMA_SET:
aiohttp/client.py:682:                        if scheme not in HTTP_SCHEMA_SET:

msg = await resp.receive()
                assert msg.type == aiohttp.WSMsgType.ERROR
                assert resp.exception() is exc

                await session.close()


async def test_receive_runtime_err(loop: Any) -> None:
    resp = client.ClientWebSocketResponse(
        mock.Mock(), mock.Mock(), mock.Mock(), mock.Mock(), 10.0, True, True, loop
    )
    resp._waiting = True

    with pytest.raises(RuntimeError):
        await resp.receive()


async def test_ws_connect_close_resp_on_err(
    loop: Any, ws_key: Any, key_data: Any
) -> None:
    resp = mock.Mock()
    resp.status = 500
    resp.headers = {
        hdrs.UPGRADE: "websocket",
        hdrs.CONNECTION: "upgrade",
        hdrs.SEC_WEBSOCKET_ACCEPT: ws_key,
    }
    with mock.patch("aiohttp.client.os") as m_os:
        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
            m_os
…[6245 chars omitted]…
ders = {}

    async def test_connection() -> None:
        async def mock_get(*args, **kwargs):
            resp = mock.Mock()
            resp.status = 101
            key = kwargs.get("headers").get(hdrs.SEC_WEBSOCKET_KEY)
            accept = base64.b64encode(
                hashlib.sha1(base64.b64encode(base64.b64decode(key)) + WS_KEY).digest()
            ).decode()
            resp.headers = {

142-
143-    @abstractmethod  # pragma: no cover
144-    async def _make_runner(self, **kwargs: Any) -> BaseRunner:
145-        pass
146-
147:    def make_url(self, path: StrOrURL) -> URL:
148-        assert self._root is not None
149-        url = URL(path)
150-        if not self.skip_url_asserts:
151-            assert not url.is_absolute()
152-            return self._root.join(url)
153-        else:

154-            return URL(str(self._root) + str(path))
155-
156-    @property
157-    def started(self) -> bool:
158-        return self.runner is not None
159-
160-    @property
161-    def closed(self) -> bool:
162-        return self._closed
163-
164-    @property
165-    def handler(self) -> Server:
166-        # for backward compatibility
167-        # web.Server instance
168-        runner = self.runner
169-        assert runner is not None
170-        assert runner.server is n
…[5854 chars omitted]…
path: StrOrURL, **kwargs: Any) -> _WSRequestContextManager:
aiohttp/test_utils.py:357:        The api corresponds to aiohttp.ClientSession.ws_connect.
aiohttp/test_utils.py:360:        return _WSRequestContextManager(self._ws_connect(path, **kwargs))
aiohttp/test_utils.py:362:    async def _ws_connect(
aiohttp/test_utils.py:365:        ws = await self._session.ws_connect(self.make_url(path), **kwargs)

In order to modify inner
      :meth:`request<aiohttp.ClientSession.request>`
      parameters, provide `kwargs`.

      :param url: Request URL, :class:`str` or :class:`~yarl.URL`

      :param data: Data to send in the body of the request; see
                   :meth:`request<aiohttp.ClientSession.request>`
                   for details (optional)

      :return ClientResponse: a :class:`client response
                              <ClientResponse>` object.

   .. method:: ws_connect(url, *, method='GET', \
                            protocols=(), timeout=10.0,\
                            receive_timeout=None,\
                            auth=None,\
                            autoclose=True,\
                            autoping=True,\
                            heartbeat=None,\
                            origin=None, \
                            params=None, \
     
…[7570 chars omitted]…
             else:
                   await ws.send_str(msg.data + '/answer')
           elif msg.type == aiohttp.WSMsgType.ERROR:
               break


You **must** use the only websocket task for both reading (e.g. ``await
ws.receive()`` or ``async for msg in ws:``) and writing but may have
multiple writer tasks which can only send data asynchronously (by
``await ws.send_str('data')`` for example).

94:- Ensure websocket transport is closed when client does not close it
107:- Leave websocket transport open if receive times out or is cancelled
299:- Fixed server-side websocket connection leak.
499:- Fixed async concurrency safety in websocket compressor.
580:- Performance: Only check origin if insecure scheme and there are origins to treat as secure, in ``CookieJar.filter_cookies()``.
613:- Added ``WebSocketResponse.get_extra_info()`` to access a protocol transport's extra info.
680:- Added check to validate that absolute URIs have schemes.
708:- Fixed ``ClientWebSocketResponse.close_code`` being erroneously set to ``None`` when there are concurrent async tasks receiving data and closing the connection.
720:- Performance: Fixed increase in latency with small messages from websocket compression changes.
1112:  By default, the transport is secure if https or wss scheme is used.
1157
…[6745 chars omitted]…

-libs/aiohttp/pull/255>`_)
2284:- add `aiohttp.web.WebSocketResponse`
2286:- According to RFC 6455 websocket subprotocol preference order is
2289:- websocket's ping and pong accept optional message parameter
2393:- Make websocket subprotocols conform to spec (`#181 <https://github.com/aio-libs/aiohttp/pull/181>`_)
2443:- Better websocket support (`#150 <https://github.com/aio-libs/aiohttp/pull/150>`_)

..
    You should *NOT* be adding new change log entries to this file, this
    file is managed by towncrier. You *may* edit previous change logs to
    fix problems like typo corrections or such.
    To add a new change log entry, please see
    https://pip.pypa.io/en/latest/development/#adding-a-news-entry
    we named the news folder "changes".

    WARNING: Don't drop the next directive!

.. towncrier release notes start

3.9.5 (2024-04-16)
==================

Bug fixes
---------

- Fixed "Unclosed client session" when initialization of
  :py:class:`~aiohttp.ClientSession` fails -- by :user:`NewGlad`.


  *Related issues and pull requests on GitHub:*
  :issue:`8253`.



- Fixed regression (from :pr:`8280`) with adding ``Content-Disposition`` to the ``form-data``
  part after appending to writer -- by :user:`Dreamsorcerer`/:user:`Olegt0rr`.


  *Related issues and pull requests on 
…[4652 chars omitted]…
ibs/aiohttp/issues/7719>`_

- Fixed Python HTTP parser not treating 204/304/1xx as an empty body.

  `#7755 <https://github.com/aio-libs/aiohttp/issues/7755>`_

- Ensure empty body response for 1xx/204/304 per RFC 9112 sec 6.3.

  `#7756 <https://github.com/aio-libs/aiohttp/issues/7756>`_

- Fixed an issue when a client request is closed before completing a chunked payload. -- by :user:`Dreamsorcerer`

E: You must put some 'deb-src' URIs in your sources.list

lo
Inter-|   Receive                                                |  Transmit
 face |bytes    packets errs drop fifo frame compressed multicast|bytes    packets errs drop fifo colls carrier compressed
    lo:       0       0    0    0    0     0          0         0        0       0    0    0    0     0       0          0
Main:
  +-- 127.0.0.0/8 2 0 2
     +-- 127.0.0.0/31 1 0 0
        |-- 127.0.0.0
           /8 host LOCAL
        |-- 127.0.0.1
           /32 host LOCAL
     |-- 127.255.255.255

        /32 link BROADCAST
Local:
  +-- 127.0.0.0/8 2 0 2
     +-- 127.0.0.0/31 1 0 0
        |-- 127.0.0.0
           /8 host LOCAL
        |-- 127.0.0.1
           /32 host LOCAL
     |-- 127.255.255.255
        /32 link BROADCAST

docs/abc.rst
docs/aiohttp-icon.svg
docs/aiohttp-plain.svg
docs/built_with.rst
docs/changes.rst
docs/client.rst
docs/client_advanced.rst
docs/client_quickstart.rst
docs/client_reference.rst
docs/conf.py
docs/contributing-admins.rst
docs/contributing.rst

docs/deployment.rst
docs/essays.rst
docs/external.rst
docs/faq.rst
docs/favicon.ico
docs/glossary.rst
docs/http_request_lifecycle.rst
docs/index.rst
docs/logging.rst
docs/make.bat
docs/Makefile
docs/migration_to_2xx.rst
docs/misc.rst
docs/multipart.rst
docs/multipart_reference.rst
docs/new_router.rst
docs/old-logo.png
docs/old-logo.svg
docs/powered_by.rst
docs/spelling_wordlist.txt
docs/streams.rst
docs/structures.rst
docs/testing.rst
docs/third_party.rst
docs/tracing_reference.rst
docs/utilities.rst
docs/web.rst
docs/websocket_utilities.rst
docs/web_advanced.rst
docs/web_exceptions.rst
docs/web_lowlevel.rst
docs/web_quickstart.rst
docs/web_reference.rst
docs/whats_new_1_1.rst
docs/whats_new_3_0.rst
docs/_static/css/logo-adjustments.css
docs/_static/img/contributing-cov-comment.svg
docs/_static/img/contributing-cov-header.svg

[metadata]
name = aiohttp
version = attr: aiohttp.__version__
url = https://github.com/aio-libs/aiohttp
project_urls =
  Chat: Matrix = https://matrix.to/#/#aio-libs:matrix.org
  Chat: Matrix Space = https://matrix.to/#/#aio-libs-space:matrix.org
  CI: GitHub Actions = https://github.com/aio-libs/aiohttp/actions?query=workflow%%3ACI
  Coverage: codecov = https://codecov.io/github/aio-libs/aiohttp
  Docs: Changelog = https://docs.aiohttp.org/en/stable/changes.html
  Docs: RTD = https://docs.aiohttp.org
  GitHub: issues = https://github.com/aio-libs/aiohttp/issues

  GitHub: repo = https://github.com/aio-libs/aiohttp
description = Async http client/server framework (asyncio)
long_description = file: README.rst
long_description_content_type = text/x-rst
maintainer = aiohttp team <team@aiohttp.org>
maintainer_email = team@aiohttp.org
license = Apache 2
license_files = LICENSE.txt
classifie
…[6644 chars omitted]…
ocols[pyloop]
0.01s teardown tests/test_client_ws.py::test_ws_connect_deflate_server_ext_bad[pyloop]
0.01s teardown tests/test_client_ws.py::test_close_eofstream[pyloop]
0.01s teardown tests/test_client_ws.py::test_close_exc[pyloop]
0.01s teardown tests/test_client_ws.py::test_ws_connect_non_overlapped_protocols_2[pyloop]
============================== 27 passed in 5.93s ==============================

Traceback (most recent call last):
  File "/tmp/repro_ws.py", line 2, in <module>
    import aiohttp
ModuleNotFoundError: No module named 'aiohttp'

ws NonHttpUrlClientError ws://127.0.0.1:37619/
http AttributeError 'ResponseHandler' object has no attribute 'read_timeout'

GPG_KEY=7169605F62C751356D054A26A821E680E5FA6305
HOME=/root
HOSTNAME=e5f8bb59662c
LANG=C.UTF-8
OLDPWD=/repo
PATH=/usr/local/bin:/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin
PS1=
PWD=/repo
PYTHON_SHA256=c08bc65a81971c1dd5783182826503369466c7e67374d1646519adf05207b684
PYTHON_VERSION=3.12.13
SHLVL=1
TERM=dumb

_=/usr/bin/env
e5f8bb59662c
total 68
drwxr-xr-x   1 root root 4096 Nov  4 21:14 .
drwxr-xr-x   1 root root 4096 Nov  4 21:14 ..
-rwxr-xr-x   1 root root    0 Nov  4 21:14 .dockerenv
lrwxrwxrwx   1 root root    7 Jul  4 09:05 bin -> usr/bin
drwxr-xr-x   2 root root 4096 Jul  4 09:05 boot
drwxr-xr-x   5 root root  340 Nov  4 21:14 dev
drwxr-xr-x   1 root root 4096 Nov  4 21:15 etc
drwxr-xr-x   2 root root 4096 Jul  4 09:05 home
lrwxrwxrwx   1 root root    7 Jul  4 09:05 lib -> usr/lib
lrwxrwxrwx   1 root root    9 Jul  4 09:05 lib64 -> usr/lib64
drwxr-xr-x   2 root roo
…[216 chars omitted]…
drwx------   1 root root 4096 Nov  4 21:15 root
drwxr-xr-x   1 root root 4096 Nov  4 21:14 run
lrwxrwxrwx   1 root root    8 Jul  4 09:05 sbin -> usr/sbin
drwxr-xr-x   2 root root 4096 Aug  3 00:00 srv
dr-xr-xr-x  13 root root    0 Oct 28 20:41 sys
drwxrwxrwt   1 root root 4096 Nov  4 21:20 tmp
drwxr-xr-x   1 root root 4096 Aug  3 00:00 usr
drwxr-xr-x   1 root root 4096 Aug  3 00:00 var
sleep infinity

12647633 /root/.cache/pip/http-v2/0/6/6/b/f/066bf21eb6192b71949005890d6ddbbff41d9b5a7a3d5f06e0468519.body
4320468 /root/.cache/pip/http-v2/8/a/3/2/f/8a32fd6dd033c7a345ce75eb69dbdc0b5f058ed4124607588b4c18bd.body
4159957 /root/.cache/pip/http-v2/c/1/0/f/d/c10fd70c73d96e129ee049ef6b8aa05132d1a9d80a72b196f903370e.body
2919252 /root/.cache/pip/http-v2/c/8/e/8/6/c8e8604e16e07b5f0d277a29047421b602e3d6592391dd00349211c8.body
994273 /root/.cache/pip/http-v2/c/8/e/9/c/c8e9c9575b76dc7560f19a6f67bb475254f4f4259cf71e96521b67d9.body
893610 /root/.cache/pip/http-v2/8/1/3/c/c/813cc7096c25ba43edba14a4ab40832db33af638c43e975795995aec.body
876263 /root/.cache/pip/http-v2/6/f/5/8/3/6f58315105f89fee1362c31502969537488db877c79a9478a63bd668.body
821580 /root/.cache/pip/http-v2/8/0/c/4/8/80c48f7bcc8aa30a81b35c277ca36430896f63624bef1af01be4bbea.body
777221 /root/.cache/pip/wheels/62/21/26/24e73e5cb8863075e1ce
…[1912 chars omitted]…
t/.cache/pip/http-v2/0/7/b/f/2/07bf2457415926f58794b3cef9c228230c664b8dde991731225af0e0.body
191988 /root/.cache/pip/http-v2/0/4/1/8/c/0418c83b80f7f7bfaec2738bfbbee53d2c1562196c0781702f6eddc8.body

171511 /root/.cache/pip/http-v2/5/5/5/7/9/5557924ac8e72c0afd98720da4d1a1eb3823a0b1adfbcd327a664e12.body
165729 /root/.cache/pip/http-v2/6/1/1/6/9/611699bcca7ce514f90cb461f38ad86797eb635e61c8d63ee79b6ac2.body

508501 /root/.cache/pip/http-v2/1/1/b/8/4/11b84327bf2b099da7db61bb6e9bd516c46829d9a9bcf7578f728822.body TAR cffi-1.15.1
247702 /root/.cache/pip/http-v2/1/5/8/5/6/15856d84ee205815a9da20d464181272415376d8ef0d14a6313288ea.body ZIP dateutil/__init__.py
129956 /root/.cache/pip/http-v2/b/1/1/9/0/b11909f451f61fb29636217082b1c638b177c59eac335e0200a136e6.body ZIP packaging/__init__.py
634226 /root/.cache/pip/http-v2/b/f/d/6/3/bfd6322b8f4c82d6b7ed54608512187e126478b3b0851b74973f4adc.body RAW b'\x1f\x8b\x08\x00\x00\x00\x00\x00\x02\xff\xec\xbd\xd9\x92%\xc9q%\xf8/\xf5\xcc\n7\xdd\xccT\xe3;\xf04\xf3@\xb1\x95\x804\xb6\xc12\xddlJ\xff\xfb\x1c\xbd\x008dUe\xdc\x08gV\xb7HE\x16\x12\x99\x19K\x86\xbb\xab\x1fS=\xc7L\x97\x7f\xfb\xee\xfc\xe6\xb7\xfb'
130779 /root/.cache/pip/http-v2/0/1/9/7/a/0197ab0dfa1054a7851b8292055f64ee3e163df2b676ddb9bc396cb7.body ZIP multidict.libs/
191988 /root/.cache/pip/http-v2/0/4/1/8
…[5986 chars omitted]…
xcal\xceW\xf4\xd3\x9c\x07Y\\[\xb2)]F%\xcd\xf4\xc5\xe6\xdf\x8f#K=j\x95T\xdc;\x17)\x1d31[\xec$\x8bLr\xaf\x85\xf0\x00\xdc\x11\x08\xe0?\xbe9\xbf'
876263 /root/.cache/pip/http-v2/6/f/5/8/3/6f58315105f89fee1362c31502969537488db877c79a9478a63bd668.body ZIP distutils-precedence.pth
118697 /root/.cache/pip/http-v2/7/5/8/e/0/758e07d7bdfb8212737d84f4f36245f9f40d44fd1c9ad0df0cf25708.body ZIP pycparser/__init__.py

bfd6322b8f4c82d6b7ed54608512187e126478b3b0851b74973f4adc.body 4092064 b'{"files":[{"core-metadata":{"sha256":"9ce90ca615d6df5c0707f64bfbb3bf4d396c9a9462aab456337898abdc76d921"},"data-dist-info-metadata":{"sha256":"9ce90ca615d6df5c0707f64bfbb3bf4d396c9a9462aab456337898abdc'
0418c83b80f7f7bfaec2738bfbbee53d2c1562196c0781702f6eddc8.body 777793 b'{"files":[{"core-metadata":false,"data-dist-info-metadata":false,"filename":"setuptools-0.6b1-py2.3.egg","hashes":{"sha256":"ae0a6ec6090a92d08fe7f3dbf9f1b2ce889bce2a3d7724b62322a29b92cf93f0"},"provena'
361bf053ab706a1212f013301d35a0c4b0af9cd8cc559d24c73d6a6f.body 1315554 b'{"files":[{"core-metadata":false,"data-dist-info-metadata":false,"filename":"cffi-0.1.tar.gz","hashes":{"sha256":"c9638c80a712464b42b9cc2e2d51176bbe5e300f74ff93606a63a8001ca4e925"},"provenance":null,"'
5bd894eeb3dfe1c8aaee1daecdfb74bbb314293813a730238621f077.body 1842134 b'{"fi
…[1984 chars omitted]…
name":"regex-2013-02-16.tar.gz","hashes":{"sha256":"3d402b272a28892eb3569116fe354100c6809b256a8fb194c6a52f475dac564b"},"provenance'
61678d682a1ea716fb4acccebc1350da197d2251a96e4b9220061051.body 827042 b'{"files":[{"core-metadata":{"sha256":"61c65d42bace7b376df077c88077a69e7ba3574c5cd89a4df45041ad04d49ce9"},"data-dist-info-metadata":{"sha256":"61c65d42bace7b376df077c88077a69e7ba3574c5cd89a4df45041ad04'

diff --git a/aiohttp/client.py b/aiohttp/client.py
index 4c0ad89..f5e07b1 100644
--- a/aiohttp/client.py
+++ b/aiohttp/client.py
@@ -879,6 +879,15 @@ class ClientSession:
                 "got {!r} instead.".format(ssl)
             )
 
+        # The request machinery only supports HTTP(S) URLs, so convert
+        # WebSocket schemes to their HTTP(S) equivalents.
+        if isinstance(url, str):
+            url = URL(url)

+        if url.scheme == "ws":
+            url = url.with_scheme("http")
+        elif url.scheme == "wss":
+            url = url.with_scheme("https")
+
         # send request
         resp = await self.request(
             method,
@@ -984,6 +993,17 @@ class ClientSession:
                 compress=compress,
                 notakeover=notakeover,
             )
+
+            # The HTTP read timeout may be shorter than the WebSocket
+            # receive t
…[816 chars omitted]…
 upgraded(self) -> bool:
         return self._upgraded
 
+    @property
+    def read_timeout(self) -> Optional[float]:
+        return self._read_timeout
+
+    @read_timeout.setter
+    def read_timeout(self, value: Optional[float]) -> None:
+        self._read_timeout = value
+
     @property
     def should_close(self) -> bool:
         if self._payload is not None and not self._payload.is_eof():

ws connected None
http connected None

current=None ws_receive=None -> None
current=0.5 ws_receive=None -> None
current=None ws_receive=1.0 -> None
current=0.5 ws_receive=1.0 -> 1.0
current=1.0 ws_receive=0.5 -> 1.0

tests/test_tcp_helpers.py                   52     52     14      0     0%
tests/test_test_utils.py                   230    230     54      0     0%
tests/test_tracing.py                       49     49      2      0     0%
tests/test_urldispatch.py                  859    859     98      0     0%
tests/test_web_app.py                      381    381     30      0     0%
tests/test_web_cli.py                       76     76     20      0     0%
tests/test_web_exceptions.py               274    274     42      0     0%
tests/test_web_functional.py              1487   1487    152      0     0%
tests/test_web_log.py                      143    143     12      0     0%
tests/test_web_middleware.py               230    230     26      0     0%
tests/test_web_request.py                  543    543     40      0     0%
tests/test_web_request_handler.py           40     40      2      0     

…[1662 chars omitted]…
t_client_ws_functional.py::test_receive_timeout_deprecation[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_send_recv_text[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_custom_receive_timeout[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_receive_timeout_sock_read[pyloop]
============================== 74 passed in 8.07s ==============================

WS://Example.COM/path -> ws://example.com/path ws http://example.com/path
WSS://Example.COM/path -> wss://example.com/path wss http://example.com/path
ws://x -> ws://x ws http://x
wss://x -> wss://x wss http://x

lrwxrwxrwx 1 root root    4 Aug  3 00:00 /var/run -> /run

/run:
total 12
drwxr-xr-x 1 root root 4096 Nov  4 21:14 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..
-rw-r--r-- 1 root root    0 Nov  4 21:14 adduser
drwxrwxrwt 2 root root 4096 Aug  3 00:00 lock

678 107                                 "Server attempted redirecting to a location that does not look like a URL",
compile-ok

tests/test_websocket_handshake.py          153    153     26      0     0%
tests/test_websocket_parser.py             293    293     44      0     0%
tests/test_websocket_writer.py              95     95     16      0     0%
tests/test_worker.py                       190    190     20      0     0%
--------------------------------------------------------------------------
TOTAL                                    33045  21429   7632    605    37%

============================= slowest 10 durations =============================
2.01s call     tests/test_client_functional.py::test_read_timeout_between_chunks[pyloop]
2.01s call     tests/test_client_functional.py::test_set_cookies_max_age[pyloop]
1.01s call     tests/test_client_functional.py::test_readline_error_on_conn_close[pyloop]
1.00s call     tests/test_client_functional.py::test_timeout_on_reading_data[pyloop]

0.51s call     tests
…[695 chars omitted]…
jected_upload[pyloop] - #7599
XFAIL tests/test_client_functional.py::test_header_too_large_error[pyloop] - #8395 Error message regression for large headers in 3.9.4
FAILED tests/test_client_session.py::test_client_session_timeout_zero - aioht...
FAILED tests/test_client_session.py::test_client_session_timeout_bad_argument
================== 2 failed, 348 passed, 3 xfailed in 24.75s ===================

============================= test session starts ==============================
collected 2 items

tests/test_client_session.py FF                                          [100%]

=================================== FAILURES ===================================
_______________________ test_client_session_timeout_zero _______________________

self = <aiohttp.connector.TCPConnector object at 0x735a55b90380>
req = <aiohttp.client_reqrep.ClientRequest object at 0x735a56dce180>
traces = []
timeout = ClientTimeout(total=10, connect=0, sock_read=0, sock_connect=0, ceil_threshold=5)

    async def _create_direct_connection(
        self,
        req: ClientRequest,
        traces: List["Trace"],
        timeout: "ClientTimeout",
        *,
        client_error: Type[Exception] = ClientConnectorError,
    ) -> Tuple[asyncio.Transport, ResponseHandler]:
        sslcontext = self._get_ssl_contex
…[4230 chars omitted]…
      for res in _socket.getaddrinfo(host, port, family, type, proto, flags):
E       socket.gaierror: [Errno -3] Temporary failure in name resolution

addrlist   = []
family     = <AddressFamily.AF_UNSPEC: 0>
flags      = <AddressInfo.AI_ADDRCONFIG: 32>
host       = 'example.com'
port       = 80
proto      = 0
type       = <SocketKind.SOCK_STREAM: 1>

/usr/local/lib/python3.12/socket.py:978: gaierror

ws://test.org http://test.org True '/' '/'
ws://test.org http://test.org True '/' '/'
wss://test.org https://test.org True '/' '/'

http://:/ ValueError Invalid URL: host is required for absolute urls
http:/ -> http:///
http://example.org:non_int_port/ ValueError Invalid URL: port can't be converted to integer
ws://:/ ValueError Invalid URL: host is required for absolute urls
ws://example.org:non_int_port/ ValueError Invalid URL: port can't be converted to integer

ws connected None
http connected None
current=None ws_receive=None -> None
current=0.5 ws_receive=None -> None
current=None ws_receive=1.0 -> None
current=0.5 ws_receive=1.0 -> 1.0
current=1.0 ws_receive=0.5 -> 1.0

ws://:/ InvalidUrlClientError ws://:/
ws://example.org:non_int_port/ InvalidUrlClientError ws://example.org:non_int_port/
http://:/ InvalidUrlClientError http://:/

0.20s call     tests/test_client_ws_functional.py::test_close_timeout_sock_close_read[pyloop]
0.10s call     tests/test_client_ws_functional.py::test_heartbeat[pyloop]
0.10s call     tests/test_client_ws_functional.py::test_concurrent_task_close[pyloop]
0.06s call     tests/test_client_ws_functional.py::test_receive_timeout_deprecation[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_custom_receive_timeout[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_receive_timeout_sock_read[pyloop]
0.04s call     tests/test_client_ws_functional.py::test_send_recv_text[pyloop]
============================== 74 passed in 8.12s ==============================

2026-11-04 21:20 tests/__pycache__/conftest.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:20 tests/__pycache__/test_client_ws.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:21 tests/__pycache__/test_client_proto.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:21 tests/__pycache__/test_client_ws_functional.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:22 tests/__pycache__/test_client_functional.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:22 tests/__pycache__/test_client_session.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:20 tests/__pycache__/conftest.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:20 tests/__pycache__/test_client_ws.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:21 tests/__pycache__/test_client_proto.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:21 tests/__pycache__/test_client_ws_functional.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:22 tests/__pycache__/test_client_functional.cpython-312-pytest-8.1.1.pyc
2026-11-04 21:22 tests/__pycache__/test_client_session.cpython-312-pytest-8.1.1.pyc

diff --git a/aiohttp/client.py b/aiohttp/client.py
index 4c0ad89..203df30 100644
--- a/aiohttp/client.py
+++ b/aiohttp/client.py
@@ -879,6 +879,18 @@ class ClientSession:
                 "got {!r} instead.".format(ssl)
             )
 
+        # The request machinery only supports HTTP(S) URLs, so convert
+        # WebSocket schemes to their HTTP(S) equivalents.
+        if isinstance(url, str):
+            try:

+                url = URL(url)
+            except ValueError as e:
+                raise InvalidUrlClientError(url) from e
+        if url.scheme == "ws":
+            url = url.with_scheme("http")
+        elif url.scheme == "wss":
+            url = url.with_scheme("https")
+
         # send request
         resp = await self.request(
             method,
@@ -984,6 +996,17 @@ class ClientSession:
                 compress=compress,
                 notakeover=notakeov
…[980 chars omitted]…
pgraded
 
+    @property
+    def read_timeout(self) -> Optional[float]:
+        return self._read_timeout
+
+    @read_timeout.setter
+    def read_timeout(self, value: Optional[float]) -> None:
+        self._read_timeout = value
+
     @property
     def should_close(self) -> bool:
         if self._payload is not None and not self._payload.is_eof():
 M aiohttp/client.py
 M aiohttp/client_proto.py

============================= slowest 10 durations =============================
0.05s call     tests/test_client_request.py::test_terminate_with_closed_loop[pyloop]
0.02s call     tests/test_client_response.py::test_http_processing_error
0.02s teardown tests/test_client_request.py::test_precompressed_data_stays_intact[pyloop]
0.02s teardown tests/test_client_request.py::test_file_upload_not_chunked[pyloop]
0.02s teardown tests/test_client_request.py::test_file_upload_not_chunked_seek[pyloop]
0.02s teardown tests/test_client_request.py::test_content_type_auto_header_bytes[pyloop]
0.02s teardown tests/test_client_request.py::test_urlencoded_formdata_charset[pyloop]
0.02s teardown tests/test_client_response.py::test_read_and_release_connection[pyloop]
0.02s teardown tests/test_client_request.py::test_formdata_boundary_from_headers[pyloop]
0.02s teardown tests/test_client_request.py::test_terminate_with_closed_loop[pyloop]
============================= 197 passed in 9.01s ==============================

read_timeout 1.0
received 1 late
read_timeout no ws receive None

tests/test_helpers.py:546:        ({"ws_proxy": "http://aiohttp.io/path"}, "http://aiohttp.io/path", "ws"),
tests/test_helpers.py:547:        ({"wss_proxy": "http://aiohttp.io/path"}, "http://aiohttp.io/path", "wss"),
tests/test_helpers.py:569:        ({"wss_proxy": "wss://aiohttp.io/path"}, "wss://aiohttp.io/path", "wss"),
tests/test_client_session.py:865:        ("trust_env", "_trust_env"),
tests/test_helpers.py:538:# --------------------- proxies_from_env ------------------------------
tests/test_helpers.py:553:def test_proxies_from_env(url_input, expected_scheme) -> None:
tests/test_helpers.py:555:    ret = helpers.proxies_from_env()
tests/test_helpers.py:575:def test_proxies_from_env_skipped(caplog, url_input, expected_scheme) -> None:
tests/test_helpers.py:577:    assert helpers.proxies_from_env() == {}
tests/test_helpers.py:598:def test_proxies_from_env_http_with_auth(url_input
…[140 chars omitted]…
 get_env_proxy_for_url ------------------------------

tests/test_helpers.py:668:def test_get_env_proxy_for_url_negative(url_input, expected_err_msg) -> None:
tests/test_helpers.py:671:        helpers.get_env_proxy_for_url(url)
tests/test_helpers.py:691:def test_get_env_proxy_for_url(proxy_env_vars, url_input) -> None:
tests/test_helpers.py:693:    proxy, proxy_auth = helpers.get_env_proxy_for_url(url)

============================== 74 passed in 8.04s ==============================

755:    def ws_connect(
756-        self,
757-        url: StrOrURL,
758-        *,
759-        method: str = hdrs.METH_GET,
760-        protocols: Collection[str] = (),
761-        timeout: Union[ClientWSTimeout, float, _SENTINEL, None] = sentinel,
762-        receive_timeout: Optional[float] = None,
763-        autoclose: bool = True,
764-        autoping: bool = True,
765-        heartbeat: Optional[float] = None,
766-        auth: Optional[BasicAuth] = None,

767-        origin: Optional[str] = None,
768-        params: Optional[Mapping[str, str]] = None,
769-        headers: Optional[LooseHeaders] = None,
770-        proxy: Optional[StrOrURL] = None,
771-        proxy_auth: Optional[BasicAuth] = None,
772-        ssl: Union[SSLContext, bool, Fingerprint] = True,
773-        server_hostname: Optional[str] = None,
774-        proxy_headers: Optional[LooseHeaders] = None,
775-       
…[24 chars omitted]…
        max_msg_size: int = 4 * 1024 * 1024,
777-    ) -> "_WSRequestContextManager":
778-        """Initiate websocket connection."""
779-        return _WSRequestContextManager(
780-            self._ws_connect(
781-                url,
782-                method=method,
783-                protocols=protocols,
784-                timeout=timeout,
785-                receive_timeout=receive_timeout,

aiohttp/client.py:755:    def ws_connect(
aiohttp/test_utils.py:354:    def ws_connect(self, path: StrOrURL, **kwargs: Any) -> _WSRequestContextManager:

total 12
drwxr-xr-x 1 _apt root 4096 Aug  5 01:04 .
drwxr-xr-x 1 root root 4096 Nov  4 21:14 ..

Success: no issues found in 2 source files

diff --git a/aiohttp/client.py b/aiohttp/client.py
index 4c0ad89..a68bfd6 100644
--- a/aiohttp/client.py
+++ b/aiohttp/client.py
@@ -879,6 +879,18 @@ class ClientSession:
                 "got {!r} instead.".format(ssl)
             )
 
+        # The request machinery only supports HTTP(S) URLs, so convert
+        # WebSocket schemes to their HTTP(S) equivalents.
+        if isinstance(url, str):
+            try:

+                url = URL(url)
+            except ValueError as e:
+                raise InvalidUrlClientError(url) from e
+        if url.scheme == "ws":
+            url = url.with_scheme("http")
+        elif url.scheme == "wss":
+            url = url.with_scheme("https")
+
         # send request
         resp = await self.request(
             method,
@@ -971,6 +983,18 @@ class ClientSession:
             assert conn is not None
             conn_proto = conn.prot
…[386 chars omitted]…
None:
+                conn_proto.read_timeout = None
+            elif conn_proto.read_timeout is not None:
+                conn_proto.read_timeout = max(
+                    conn_proto.read_timeout, ws_timeout.ws_receive
+                )
+
             transport = conn.transport
             assert transport is not None
             reader: FlowControlDataQueue[WSMessage] = FlowControlDataQueue(

ws connected None
http connected None
current=None ws_receive=None -> None
current=0.5 ws_receive=None -> None
current=None ws_receive=1.0 -> None
current=0.5 ws_receive=1.0 -> 1.0
current=1.0 ws_receive=0.5 -> 1.0
read_timeout 1.0
received 1 late
read_timeout no ws receive None
============================== 74 passed in 7.99s ==============================

read_timeout 1.0
received 1 first
received 1 second

Success: no issues found in 2 source files
diff --git a/aiohttp/client.py b/aiohttp/client.py
index 4c0ad89..a68bfd6 100644
--- a/aiohttp/client.py
+++ b/aiohttp/client.py
@@ -879,6 +879,18 @@ class ClientSession:
                 "got {!r} instead.".format(ssl)
             )
 
+        # The request machinery only supports HTTP(S) URLs, so convert
+        # WebSocket schemes to their HTTP(S) equivalents.
+        if isinstance(url, str):

+            try:
+                url = URL(url)
+            except ValueError as e:
+                raise InvalidUrlClientError(url) from e
+        if url.scheme == "ws":
+            url = url.with_scheme("http")
+        elif url.scheme == "wss":
+            url = url.with_scheme("https")
+
         # send request
         resp = await self.request(
             method,
@@ -971,6 +983,18 @@ class ClientSession:
             assert conn is n
…[1095 chars omitted]…
 upgraded(self) -> bool:
         return self._upgraded
 
+    @property
+    def read_timeout(self) -> Optional[float]:
+        return self._read_timeout
+
+    @read_timeout.setter
+    def read_timeout(self, value: Optional[float]) -> None:
+        self._read_timeout = value
+
     @property
     def should_close(self) -> bool:
         if self._payload is not None and not self._payload.is_eof():

None None -> None req url https://test.org
0.5 None -> None req url https://test.org
None 1.0 -> None req url https://test.org
0.5 1.0 -> 1.0 req url https://test.org
1.0 0.5 -> 1.0 req url https://test.org

======================= 292 passed, 3 xfailed in 22.91s ========================

/repo
total 272
drwxr-xr-x 1 root root   4096 Nov  2 06:38 .
drwxr-xr-x 1 root root   4096 Nov  2 06:38 ..
-rw-r--r-- 1 root root    113 Nov  2 06:37 .cherry_picker.toml
-rw-r--r-- 1 root root    481 Nov  2 06:37 .codecov.yml
-rw-r--r-- 1 root root    111 Nov  2 06:37 .coveragerc
-rw-r--r-- 1 root root    376 Nov  2 06:37 .editorconfig
drwxr-xr-x 1 root root   4096 Nov  2 06:38 .git
-rw-r--r-- 1 root root   1337 Nov  2 06:37 .git-blame-ignore-revs
-rw-r--r-- 1 root root     58 Nov  2 06:37 .gitattributes
drwxr-xr-x 1 root root   4096 Nov  2 06:37 .github

-rw-r--r-- 1 root root    735 Nov  2 06:37 .gitignore
-rw-r--r-- 1 root root    118 Nov  2 06:37 .gitmodules
-rw-r--r-- 1 root root     44 Nov  2 06:37 .lgtm.yml
-rw-r--r-- 1 root root    985 Nov  2 06:37 .mypy.ini
-rw-r--r-- 1 root root     78 Nov  2 06:37 .pip-tools.toml
-rw-r--r-- 1 root root   2929 Nov  2 06:37 .pre-commit-config.
…[4796 chars omitted]…
y
./aiohttp/cookiejar.py
./aiohttp/formdata.py
./aiohttp/hdrs.py
./aiohttp/helpers.py
./aiohttp/http.py
./aiohttp/http_exceptions.py
./aiohttp/http_parser.py
./aiohttp/http_websocket.py
./aiohttp/http_writer.py
./aiohttp/locks.py
./aiohttp/log.py
./aiohttp/multipart.py
./aiohttp/payload.py
./aiohttp/py.typed
./aiohttp/pytest_plugin.py
./aiohttp/resolver.py
./aiohttp/streams.py
./aiohttp/tcp_helpers.py

aiohttp/client.py:755:    def ws_connect(
aiohttp/client.py:780:            self._ws_connect(
aiohttp/client.py:803:    async def _ws_connect(
tests/autobahn/client/client.py:10:        async with session.ws_connect(url + "/getCaseCount") as ws:
tests/autobahn/client/client.py:17:            async with session.ws_connect(text_url) as ws:
tests/autobahn/client/client.py:27:        async with session.ws_connect(url) as ws:
tests/test_client_ws.py:33:async def test_ws_connect(ws_key: Any, loop: Any, key_data: Any) -> None:
tests/test_client_ws.py:48:            res = await aiohttp.ClientSession().ws_connect(
tests/test_client_ws.py:57:async def test_ws_connect_with_origin(key_data: Any, loop: Any) -> None:
tests/test_client_ws.py:68:                await aiohttp.ClientSession().ws_connect(
tests/test_client_ws.py:76:async def test_ws_connect_with_params(ws_key: Any, loop: Any, key_data: 
…[8629 chars omitted]…

 self._read_timeout_handle = None
aiohttp/client_proto.py:243:    def _on_read_timeout(self) -> None:
tests/test_client_connection.py
tests/test_client_exceptions.py
tests/test_client_fingerprint.py
tests/test_client_functional.py
tests/test_client_proto.py
tests/test_client_request.py
tests/test_client_response.py
tests/test_client_session.py
tests/test_client_ws.py
tests/test_client_ws_functional.py

import asyncio
from contextlib import suppress
from typing import Any, Optional, Tuple

from .base_protocol import BaseProtocol
from .client_exceptions import (
    ClientConnectionError,
    ClientOSError,
    ClientPayloadError,
    ServerDisconnectedError,
    SocketTimeoutError,
)

from .helpers import (
    _EXC_SENTINEL,
    BaseTimerContext,
    set_exception,
    set_result,
    status_code_must_be_empty_body,
)
from .http import HttpResponseParser, RawResponseMessage, WebSocketReader
from .http_exceptions import HttpProcessingError
from .streams import EMPTY_PAYLOAD, DataQueue, StreamReader


class ResponseHandler(BaseProtocol, DataQueue[Tuple[RawResponseMessage, StreamReader]]):
    """Helper class to adapt between Protocol and StreamReader."""

    def __init__(self, loop: asyncio.AbstractEventLoop) -> None:
        BaseProtocol.__init__(self, loop=loop)
        DataQueue.__
…[8630 chars omitted]…
ut_handle is not None:
aiohttp/client_proto.py:231:            self._read_timeout_handle.cancel()
aiohttp/client_proto.py:234:            self._read_timeout_handle = self._loop.call_later(
aiohttp/client_proto.py:235:                timeout, self._on_read_timeout
aiohttp/client_proto.py:238:            self._read_timeout_handle = None
aiohttp/client_proto.py:243:    def _on_read_timeout(self) -> None:

self._drop_timeout()

        if self._tail:
            data, self._tail = self._tail, b""
            self.data_received(data)

    def set_response_params(
        self,
        *,
        timer: Optional[BaseTimerContext] = None,
        skip_payload: bool = False,
        read_until_eof: bool = False,

        auto_decompress: bool = True,
        read_timeout: Optional[float] = None,
        read_bufsize: int = 2**16,
        timeout_ceil_threshold: float = 5,
        max_line_size: int = 8190,
        max_field_size: int = 8190,
    ) -> None:
        self._skip_payload = skip_payload

        self._read_timeout = read_timeout

        self._timeout_ceil_threshold = timeout_ceil_threshold

        self._parser = HttpResponseParser(
            self,
            self._loop,
            read_bufsize,
            timer=timer,
            payload_exception=ClientPayloadErro
…[8630 chars omitted]…
                     and url.scheme == "http"
aiohttp/client_reqrep.py:39:    InvalidURL,
aiohttp/client_reqrep.py:290:        return self.url.scheme in ("https", "wss")
aiohttp/client_reqrep.py:332:            raise InvalidURL(url)
aiohttp/connector.py:1035:        """Issue a warning if the requested URL has HTTPS scheme."""
aiohttp/connector.py:1036:        if req.request_info.url.scheme != "https":

resp.connection.add_callback(handle.cancel)
                else:
                    handle.cancel()

            resp._history = tuple(history)

            for trace in traces:
                await trace.send_request_end(
                    method, url.update_query(params), headers, resp
                )
            return resp

        except BaseException as e:
            # cleanup timer
            tm.close()
            if handle:
                handle.cancel()
                handle = None

            for trace in traces:
                await trace.send_request_exception(
                    method, url.update_query(params), headers, e
                )
            raise

    def ws_connect(
        self,
        url: StrOrURL,
        *,
        method: str = hdrs.METH_GET,
        protocols: Collection[str] = (),
        timeout: Union[ClientWSTime
…[8630 chars omitted]…
ders = {}

    async def test_connection() -> None:
        async def mock_get(*args, **kwargs):
            resp = mock.Mock()
            resp.status = 101
            key = kwargs.get("headers").get(hdrs.SEC_WEBSOCKET_KEY)
            accept = base64.b64encode(
                hashlib.sha1(base64.b64encode(base64.b64decode(key)) + WS_KEY).digest()
            ).decode()
            resp.headers = {

if receive_timeout is not None:
            warnings.warn(
                "float parameter 'receive_timeout' "
                "is deprecated, please use parameter "
                "'timeout=ClientWSTimeout(ws_receive=...)'",
                DeprecationWarning,
                stacklevel=2,
            )
            ws_timeout = dataclasses.replace(ws_timeout, ws_receive=receive_timeout)

        if headers is None:
            real_headers: CIMultiDict[str] = CIMultiDict()

        else:
            real_headers = CIMultiDict(headers)

        default_headers = {
            hdrs.UPGRADE: "websocket",
            hdrs.CONNECTION: "Upgrade",
            hdrs.SEC_WEBSOCKET_VERSION: "13",
        }

        for key, value in default_headers.items():
            real_headers.setdefault(key, value)

        sec_key = base64.b64encode(os.urandom(16))
        real_headers[hdrs.SEC
…[8630 chars omitted]…
  m_os.urandom.return_value = key_data
            m_req.return_value = loop.create_future()
374:    def request(
388:    async def _request(
455:        if url.scheme not in HTTP_SCHEMA_SET:
681:                        scheme = parsed_redirect_url.scheme
690:                            and parsed_redirect_url.scheme == "https"
691:                            and url.scheme == "http"
1330:def request(

self._trace_configs = trace_configs or []
        for trace_config in self._trace_configs:
            trace_config.freeze()

        self._resolve_charset = fallback_charset_resolver

    def __init_subclass__(cls: Type["ClientSession"]) -> None:
        raise TypeError(
            "Inheritance class {} from ClientSession "
            "is forbidden".format(cls.__name__)
        )

    def __del__(self, _warnings: Any = warnings) -> None:
        if not self.closed:
            _warnings.warn(
                f"Unclosed client session {self!r}",
                ResourceWarning,
                source=self,
            )
            context = {"client_session": self, "message": "Unclosed client session"}
            if self._source_traceback is not None:
                context["source_traceback"] = self._source_traceback
            self._loop.call_exception_handler(context)
…[8629 chars omitted]…
         timeout or self._timeout.ws_receive
307:    async def receive_str(self, *, timeout: Optional[float] = None) -> str:
308:        msg = await self.receive(timeout)
313:    async def receive_bytes(self, *, timeout: Optional[float] = None) -> bytes:
314:        msg = await self.receive(timeout)
323:        timeout: Optional[float] = None,
325:        data = await self.receive_str(timeout=timeout)

aiohttp/client.py:212:HTTP_SCHEMA_SET = frozenset({"http", "https", ""})
aiohttp/client.py:455:        if url.scheme not in HTTP_SCHEMA_SET:
aiohttp/client.py:682:                        if scheme not in HTTP_SCHEMA_SET:
import asyncio
import codecs
import contextlib
import dataclasses
import functools
import io
import re
import sys
import traceback

import warnings
from hashlib import md5, sha1, sha256
from http.cookies import CookieError, Morsel, SimpleCookie
from types import MappingProxyType, TracebackType
from typing import (
    TYPE_CHECKING,
    Any,
    Callable,
    Dict,
    Iterable,
    List,
    Mapping,
    Optional,
    Tuple,
    Type,
    Union,
    cast,
)

from multidict import CIMultiDict, CIMultiDictProxy, MultiDict, MultiDictProxy
from yarl import URL

from . import hdrs, helpers, http, multipart, payload
from .abc import AbstractStreamWriter
from .client_excepti
…[8629 chars omitted]…
ponse":
        return self

    async def __anext__(self) -> WSMessage:
        msg = await self.receive()
        if msg.type in (WSMsgType.CLOSE, WSMsgType.CLOSING, WSMsgType.CLOSED):
            raise StopAsyncIteration
        return msg
tests/test_client_functional.py:28:    NonHttpUrlClientError,
tests/test_client_functional.py:2455:            (url, message, NonHttpUrlClientError)
1dbd302 base

# connection timeout
                    try:
                        async with ceil_timeout(
                            real_timeout.connect,
                            ceil_threshold=real_timeout.ceil_threshold,
                        ):
                            assert self._connector is not None
                            conn = await self._connector.connect(
                                req, traces=traces, timeout=real_timeout
                            )
                    except asyncio.TimeoutError as exc:
                        raise ConnectionTimeoutError(

                            f"Connection timeout to host {url}"
                        ) from exc

                    assert conn.transport is not None

                    assert conn.protocol is not None
                    conn.protocol.set_response_params(
                        time
…[8629 chars omitted]…
 DEFAULT_WS_CLIENT_TIMEOUT
aiohttp/client.py:845:                "'timeout=ClientWSTimeout(ws_receive=...)'",
aiohttp/client.py:849:            ws_timeout = dataclasses.replace(ws_timeout, ws_receive=receive_timeout)
tests/test_client_ws_functional.py:583:    receive_timeout = ClientWSTimeout(ws_receive=0.1)
tests/test_client_ws_functional.py:608:        r"'timeout=ClientWSTimeout\(ws_receive=...\)'",

await self._continue
            except asyncio.CancelledError:
                return

        protocol = conn.protocol
        assert protocol is not None
        try:
            if isinstance(self.body, payload.Payload):
                await self.body.write(writer)
            else:
                if isinstance(self.body, (bytes, bytearray)):
                    self.body = (self.body,)  # type: ignore[assignment]

                for chunk in self.body:
                    await writer.write(chunk)  # type: ignore[arg-type]
        except OSError as underlying_exc:
            reraised_exc = underlying_exc

            exc_is_not_timeout = underlying_exc.errno is not None or not isinstance(
                underlying_exc, asyncio.TimeoutError
            )
            if exc_is_not_timeout:
                reraised_exc = ClientOSError(
                    underl
…[8629 chars omitted]…
    (url, message, NonHttpUrlRedirectClientError)
            for (url, message) in NON_HTTP_URL_WITH_ERROR_MESSAGE
        ),
    ),
)
async def test_invalid_redirect_url(
    aiohttp_client: Any,
    invalid_redirect_url: Any,
    error_message_url: str,
    expected_exception_class: Any,
) -> None:
    headers = {hdrs.LOCATION: invalid_redirect_url}
cat: CHANGES/8498.misc: No such file or directory

aiohttp/__init__.py:1:__version__ = "4.0.0a2.dev0"
setup.py:7:if sys.version_info < (3, 8):
pyproject.toml:11:  title_format = "{version} ({project_date})"
4.0.0a2.dev0
ws://example.com/path True ws://example.com 80 ws
wss://example.com/path True wss://example.com 443 wss
NonHttpUrlClientError ws://127.0.0.1:1/
has read_timeout: False

./aiohttp/client.py:603:                        read_timeout=real_timeout.sock_read,
./aiohttp/client_proto.py:44:        self._read_timeout: Optional[float] = None
./aiohttp/client_proto.py:45:        self._read_timeout_handle: Optional[asyncio.TimerHandle] = None
./aiohttp/client_proto.py:194:        read_timeout: Optional[float] = None,
./aiohttp/client_proto.py:202:        self._read_timeout = read_timeout
./aiohttp/client_proto.py:224:        if self._read_timeout_handle is not None:
./aiohttp/client_proto.py:225:            self._read_timeout_handle.cancel()
./aiohttp/client_proto.py:226:            self._read_timeout_handle = None
./aiohttp/client_proto.py:229:        timeout = self._read_timeout
./aiohttp/client_proto.py:230:        if self._read_timeout_handle is not None:
./aiohttp/client_proto.py:231:            self._read_timeout_handle.cancel()
./aiohttp/client_proto.py:2

…[5612 chars omitted]…
_(self) -> Literal[True]:
        """Force subclasses to not be falsy, to make checks simpler."""
        return True

    @property
    def transport(self) -> Optional[asyncio.Transport]:
        if self._protocol is None:
            return None
aiohttp/client_reqrep.py:290:        return self.url.scheme in ("https", "wss")
aiohttp/connector.py:1036:        if req.request_info.url.scheme != "https":

172:    def set_parser(self, parser: Any, payload: Any) -> None:
240:    def start_timeout(self) -> None:
                original_connection_error,
            )

        if self._payload_parser is not None:
            with suppress(Exception):  # FIXME: log this somehow?
                self._payload_parser.feed_eof()

        uncompleted = None
        if self._parser is not None:
            try:

                uncompleted = self._parser.feed_eof()
            except Exception as underlying_exc:
                if self._payload is not None:
                    client_payload_exc_msg = (
                        f"Response payload is not completed: {underlying_exc !r}"
                    )
                    if not connection_closed_cleanly:
                        client_payload_exc_msg = (
                            f"{client_payload_exc_msg !s}. "
                           
…[4802 chars omitted]…

                exc,
            )

    async def _drain_helper(self) -> None:
        if not self.connected:
            raise ConnectionResetError("Connection lost")
        if not self._paused:
            return
        waiter = self._drain_waiter
        if waiter is None:
            waiter = self._loop.create_future()
            self._drain_waiter = waiter
        await asyncio.shield(waiter)

"""HTTP Client for asyncio."""

import asyncio
import base64
import dataclasses
import hashlib
import json
import os
import sys
import traceback
import warnings
from contextlib import suppress

from types import SimpleNamespace, TracebackType
from typing import (
    TYPE_CHECKING,
    Any,
    Awaitable,
    Callable,
    Collection,
    Coroutine,
    Final,
    FrozenSet,
    Generator,
    Generic,
    Iterable,
    List,
    Mapping,
    Optional,
    Set,
    Tuple,
    Type,
    TypedDict,
    TypeVar,
    Union,
    final,
)

from multidict import CIMultiDict, MultiDict, MultiDictProxy, istr
from yarl import URL

from . import hdrs, http, payload
from .abc import AbstractCookieJar
from .client_exceptions import (
    ClientConnectionError,
    ClientConnectorCertificateError,
    ClientConnectorError,
    ClientConnectorSSLError,
    ClientError,
    ClientHttpProxyError,
    C
…[2829 chars omitted]…
_auto_headers: Union[Iterable[str], None]
    auth: Union[BasicAuth, None]
    allow_redirects: bool
39:from yarl import URL
tests/test_client_request.py:200:    req = make_request("get", "wss://python.org/")
tests/test_client_request.py:214:    req = make_request("get", "wss://python.org:960/")
tests/test_helpers.py:569:        ({"wss_proxy": "wss://aiohttp.io/path"}, "wss://aiohttp.io/path", "wss"),

Traceback (most recent call last):
  File "<stdin>", line 40, in <module>
  File "/usr/local/lib/python3.12/asyncio/runners.py", line 195, in run
    return runner.run(main)
           ^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/asyncio/runners.py", line 118, in run
    return self._loop.run_until_complete(task)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/asyncio/base_events.py", line 691, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^
  File "<stdin>", line 25, in main

  File "/repo/aiohttp/__init__.py", line 244, in __getattr__
    raise AttributeError(f"module {__name__} has no attribute {name}")
AttributeError: module aiohttp has no attribute ClientWSTimeout. Did you mean: 'ClientTimeout'?

timeout immediately after upgrade: 0.05
first message: first
receive timed out at configured timeout

diff --git a/aiohttp/client.py b/aiohttp/client.py
index 4c0ad89..9e33ddc 100644
--- a/aiohttp/client.py
+++ b/aiohttp/client.py
@@ -209,7 +209,7 @@ DEFAULT_TIMEOUT: Final[ClientTimeout] = ClientTimeout(total=5 * 60)
 
 # https://www.rfc-editor.org/rfc/rfc9110#section-9.2.2
 IDEMPOTENT_METHODS = frozenset({"GET", "HEAD", "OPTIONS", "TRACE", "PUT", "DELETE"})
-HTTP_SCHEMA_SET = frozenset({"http", "https", ""})
+HTTP_SCHEMA_SET = frozenset({"http", "https", "ws", "wss", ""})
 
 _RetType = TypeVar("_RetType")

 _CharsetResolver = Callable[[ClientResponse, bytes], str]
@@ -971,6 +971,11 @@ class ClientSession:
             assert conn is not None
             conn_proto = conn.protocol
             assert conn_proto is not None
+            read_timeout = conn_proto.read_timeout
+            if ws_timeout.ws_receive is None or read_timeout is None:
+                conn_proto.read_timeout 
…[511 chars omitted]…
, StreamRe
 
         self.closed: asyncio.Future[None] = self._loop.create_future()
 
+    @property
+    def read_timeout(self) -> Optional[float]:
+        return self._read_timeout
+
+    @read_timeout.setter
+    def read_timeout(self, read_timeout: Optional[float]) -> None:
+        self._read_timeout = read_timeout
+
     @property
     def upgraded(self) -> bool:
         return self._upgraded

aiohttp/client.py:455:        if url.scheme not in HTTP_SCHEMA_SET:
aiohttp/client.py:681:                        scheme = parsed_redirect_url.scheme
aiohttp/client.py:690:                            and parsed_redirect_url.scheme == "https"
aiohttp/client.py:691:                            and url.scheme == "http"
aiohttp/connector.py:1036:        if req.request_info.url.scheme != "https":
aiohttp/client_reqrep.py:290:        return self.url.scheme in ("https", "wss")
                            )

                        redirects += 1
                        history.append(resp)
                        if max_redirects and redirects >= max_redirects:
                            resp.close()

                            raise TooManyRedirects(
                                history[0].request_info, tuple(history)
                            )

                        # For 301 and 3
…[8628 chars omitted]…
      set_result(protocol.closed, None)

            if key.is_ssl and not self._cleanup_closed_disabled:
                self._cleanup_closed_transports.append(transport)
        else:
            conns = self._conns.get(key)
            if conns is None:
                conns = self._conns[key] = []
            conns.append((protocol, self._loop.time()))

            if self._cleanup_handle is None:

aiohttp/client.py:90:    get_env_proxy_for_url,
aiohttp/client.py:552:                            proxy, proxy_auth = get_env_proxy_for_url(url)
aiohttp/client_reqrep.py:306:            self.is_ssl(),
aiohttp/client_reqrep.py:608:        elif self.proxy and not self.is_ssl():
aiohttp/connector.py:321:                            if key.is_ssl and not self._cleanup_closed_disabled:
aiohttp/connector.py:328:                        if key.is_ssl and not self._cleanup_closed_disabled:
aiohttp/connector.py:571:                    if key.is_ssl and not self._cleanup_closed_disabled:
aiohttp/connector.py:581:                if key.is_ssl and not self._cleanup_closed_disabled:
aiohttp/connector.py:652:            if key.is_ssl and not self._cleanup_closed_disabled:
aiohttp/connector.py:972:        if req.is_ssl():
aiohttp/connector.py:1079:        # `req.is_ssl()` evaluates to `False` which is
…[5437 chars omitted]…

ax_sock_len - sock_path_len >= unique_prefix_len:
                    # If we're lucky to have extra space in the path,
                    # let's also make it more unique
                    sock_path = str(tmpd / "".join((unique_prefix, sock_file_name)))
                    # Double-checking it:
                    assert_sock_fits(sock_path)
                yield sock_path
                return

215:class ServerTimeoutError(ServerConnectionError, asyncio.TimeoutError):
219:class ConnectionTimeoutError(ServerTimeoutError):
223:class SocketTimeoutError(ServerTimeoutError):
316:    async def readline(self) -> bytes:
319:    async def readuntil(self, separator: bytes = b"\n") -> bytes:
355:    async def read(self, n: int = -1) -> bytes:
383:    async def readany(self) -> bytes:
395:    async def readchunk(self) -> Tuple[bytes, bool]:
429:    async def readexactly(self, n: int) -> bytes:
540:    async def readline(self) -> bytes:
543:    async def read(self, n: int = -1) -> bytes:
546:    # TODO add async def readuntil

548:    async def readany(self) -> bytes:
551:    async def readchunk(self) -> Tuple[bytes, bool]:
558:    async def readexactly(self, n: int) -> bytes:
568:class DataQueue(Generic[_SizedT]):
621:    async def read(self) -> _SizedT:
665:    async def read(self) -> _
…[1434 chars omitted]…
parsed data.
    """

    def __init__(
        self, protocol: BaseProtocol, limit: int, *, loop: asyncio.AbstractEventLoop
    ) -> None:
        super().__init__(loop=loop)

        self._protocol = protocol
        self._limit = limit * 2

    def feed_data(self, data: _SizedT) -> None:
        super().feed_data(data)
156:    def set_exception(
512:    def set_exception(
591:    def set_exception(

after handshake 0.5 <TimerHandle when=525499.876771957 ResponseHandler._on_read_timeout()> <aiohttp.streams.FlowControlDataQueue object at 0x7e83d40aaf30>
first 1.2340955436229706e-05 WSMessage(type=<WSMsgType.TEXT: 1>, data='first', extra='') timeout handle <TimerHandle when=525499.876771957 ResponseHandler._on_read_timeout()> payload exception None
Traceback (most recent call last):
  File "/repo/aiohttp/client_ws.py", line 263, in receive
    msg = await self._reader.read()
          ^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/repo/aiohttp/streams.py", line 667, in read
    return await super().read()
           ^^^^^^^^^^^^^^^^^^^^
  File "/repo/aiohttp/streams.py", line 626, in read
    await self._waiter
asyncio.exceptions.CancelledError

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "<stdin>", line 30, in <module>
  File 
…[324 chars omitted]…
ncio/base_events.py", line 691, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^
  File "<stdin>", line 26, in main
  File "/repo/aiohttp/client_ws.py", line 260, in receive
    async with async_timeout.timeout(
               ^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/asyncio/timeouts.py", line 115, in __aexit__
    raise TimeoutError from exc_val
TimeoutError

25-        assert res.protocol == "chat"
26-        assert hdrs.ORIGIN not in m_req.call_args[1]["headers"]
27-
28:    await test_connection()
29-    # Generate a new ws key
30-    key_data = os.urandom(16)
31:    await test_connection()
32-
33-
34-async def test_close(loop: Any, ws_key: Any, key_data: Any) -> None:

def test_host_port_default_https(make_request: Any) -> None:
    req = make_request("get", "https://python.org/")
    assert req.host == "python.org"
    assert req.port == 443
    assert req.is_ssl()


def test_host_port_nondefault_http(make_request: Any) -> None:
    req = make_request("get", "http://python.org:960/")
    assert req.host == "python.org"
    assert req.port == 960
    assert not req.is_ssl()

def test_host_port_nondefault_https(make_request: Any) -> None:
    req = make_request("get", "https://python.org:960/")
    assert req.host == "python.org"
    assert req.port == 960
    assert req.is_ssl()


def test_host_port_default_ws(make_request: Any) -> None:
    req = make_request("get", "ws://python.org/")
    assert req.host == "python.org"
    assert req.port == 80
    assert not req.is_ssl()


def test_host_port_default_wss(make_request: Any) -> None:
    req = ma
…[3317 chars omitted]…
tps://github.com/python/cpython/pull/28073\n\n"
            "You can temporarily patch this as follows:\n"
            "* https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support\n"
            "* https://github.com/aio-libs/aiohttp/discussions/6044\n",
            RuntimeWarning,
156:class ConnectionKey:
297:    def connection_key(self) -> ConnectionKey:
303:        return ConnectionKey(

class DataQueue(Generic[_SizedT]):
    """DataQueue is a general-purpose blocking queue with one reader."""

    def __init__(self, loop: asyncio.AbstractEventLoop) -> None:
        self._loop = loop
        self._eof = False
        self._waiter: Optional[asyncio.Future[None]] = None
        self._exception: Optional[BaseException] = None
        self._size = 0
        self._buffer: Deque[_SizedT] = collections.deque()

    def __len__(self) -> int:

        return len(self._buffer)

    def is_eof(self) -> bool:
        return self._eof

    def at_eof(self) -> bool:
        return self._eof and not self._buffer

    def exception(self) -> Optional[BaseException]:
        return self._exception

    def set_exception(
        self,
        exc: BaseException,
        exc_cause: BaseException = _EXC_SENTINEL,
    ) -> None:
        self._eof = True
        self._exception = exc

     
…[1890 chars omitted]…
ng()

    async def read(self) -> _SizedT:
        try:
            return await super().read()
        finally:
            if self._size < self._limit and self._protocol._reading_paused:
                self._protocol.resume_reading()
153:    def exception(self) -> Optional[BaseException]:
509:    def exception(self) -> Optional[BaseException]:
588:    def exception(self) -> Optional[BaseException]:

after handshake timeout: None handle: None
first: first
second returned after 1.0013565639965236 as WSMessage(type=<WSMsgType.TEXT: 1>, data='second', extra='') close code None exception None protocol exc None

ImportError while loading conftest '/repo/tests/conftest.py'.
tests/conftest.py:16: in <module>
    from aiohttp.test_utils import loop_context
E   ModuleNotFoundError: No module named 'aiohttp'

============================= test session starts ==============================
platform linux -- Python 3.12.13, pytest-8.1.1, pluggy-1.4.0
rootdir: /repo
configfile: setup.cfg
plugins: mock-3.14.0, cov-5.0.0
collected 74 items

tests/test_client_ws.py ...........................                      [ 36%]
tests/test_client_proto.py ...........                                   [ 51%]
tests/test_client_ws_functional.py ....................................  [100%]

---------- coverage: platform linux, python 3.12.13-final-0 ----------

Name                                     Stmts   Miss Branch BrPart  Cover
--------------------------------------------------------------------------
aiohttp/__init__.py                         26      8      2      1    68%
aiohttp/abc.py                              97      2     66      0    99%
aiohttp/base_protocol.py                    67     28 
…[8355 chars omitted]…
t_client_ws_functional.py::test_receive_timeout_deprecation[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_custom_receive_timeout[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_receive_timeout_sock_read[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_send_recv_text[pyloop]
============================== 74 passed in 7.20s ==============================

aiohttp/client_proto.py:55:    @read_timeout.setter
aiohttp/client_reqrep.py:281:    @_writer.setter
aiohttp/client_reqrep.py:774:    @_writer.setter
aiohttp/web_response.py:199:    @content_length.setter
aiohttp/web_response.py:216:    @content_type.setter
aiohttp/web_response.py:227:    @charset.setter
aiohttp/web_response.py:250:    @last_modified.setter
aiohttp/web_response.py:283:    @etag.setter
aiohttp/web_response.py:583:    @body.setter
aiohttp/web_response.py:619:    @text.setter
aiohttp/web_response.py:651:    @content_length.setter
aiohttp/client_proto.py:51:    @property

aiohttp/client_proto.py:61:    @property
aiohttp/client_proto.py:65:    @property
aiohttp/client.py:1142:    @property
aiohttp/client.py:1150:    @property
aiohttp/client.py:1155:    @property
aiohttp/client.py:1160:    @property
aiohttp/client.py:1165:    @property
aiohttp/client.py:1170:    @property
ai
…[476 chars omitted]…
tter
aiohttp/web_response.py:199:    @content_length.setter
aiohttp/web_response.py:216:    @content_type.setter
aiohttp/web_response.py:227:    @charset.setter
aiohttp/web_response.py:250:    @last_modified.setter
aiohttp/web_response.py:283:    @etag.setter
aiohttp/web_response.py:583:    @body.setter
aiohttp/web_response.py:619:    @text.setter
aiohttp/web_response.py:651:    @content_length.setter

ws:// protocol timeout: 0.5
ws:// timeout without ws_receive: None

trustme available <module 'trustme' from '/usr/local/lib/python3.12/site-packages/trustme/__init__.py'>

269:def proxies_from_env() -> Dict[str, ProxyInfo]:
295:def get_env_proxy_for_url(url: URL) -> Tuple[URL, Optional[BasicAuth]]:
300:    proxies_in_env = proxies_from_env()
    if delay > ceil_threshold:
        when = ceil(when)
    return async_timeout.timeout_at(when)


class HeadersMixin:
    __slots__ = ("_content_type", "_content_dict", "_stored_content_type")

    def __init__(self) -> None:

        super().__init__()
        self._content_type: Optional[str] = None
        self._content_dict: Optional[Dict[str, str]] = None
        self._stored_content_type: Union[str, _SENTINEL] = sentinel

    def _parse_content_type(self, raw: str) -> None:
        self._stored_content_type = raw
        if raw is None:
            # default value according to RFC 2616
            self._content_type = "application/octet-stream"
            self._content_dict = {}
        else:
            ms
…[1928 chars omitted]…
 that is a direct cause of ``exc``.
                      Only set if provided.
    """
    if asyncio.isfuture(fut) and fut.done():
        return

    exc_is_sentinel = exc_cause is _EXC_SENTINEL
    exc_causes_itself = exc is exc_cause
    if not exc_is_sentinel and not exc_causes_itself:
        exc.__cause__ = exc_cause

364:        if self.url.port is not None and not self.url.is_default_port():

if auth_from_netrc is None:
        raise LookupError(f"No entry for {host!s} found in the `.netrc` file.")
    login, account, password = auth_from_netrc

    # TODO(PY311): username = login or account
    # Up to python 3.10, account could be None if not specified,
    # and login will be empty string if not specified. From 3.11,
    # login and account will be empty string if not specified.
    username = login if (login or account is None) else account

    # TODO(PY311): Remove this, as password will be empty string
    # if not specified

    if password is None:
        password = ""

    return BasicAuth(username, password)


def proxies_from_env() -> Dict[str, ProxyInfo]:
    proxy_urls = {
        k: URL(v)
        for k, v in getproxies().items()
        if k in ("http", "https", "ws", "wss")
    }
    netrc_obj = netrc_from_env()
    stripped = {k: strip_auth_from_url(
…[2585 chars omitted]…
ub.com/aio-libs/aiohttp/pull/2784>`_)
2338:- Fix websocket demo. (`#2789 <https://github.com/aio-libs/aiohttp/pull/2789>`_)
7801.feature
7815.bugfix
7829.misc
7941.feature
7954.feature
8048.breaking.rst
8062.feature.rst
8088.contrib.rst
8139.contrib.rst
8197.doc
8270.bugfix.rst
8303.breaking.rst
8346.misc.rst
8364.misc.rst
8403.doc.rst
8463.misc.rst
8491.misc.rst
8498.misc.rst
8501.misc.rst
README.rst

wss:// handshake completed; received 'secure'

43:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
54:    assert hdrs.ORIGIN not in m_req.call_args[1]["headers"]
61:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
72:    assert hdrs.ORIGIN in m_req.call_args[1]["headers"]
73:    assert m_req.call_args[1]["headers"][hdrs.ORIGIN] == origin
88:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
97:    assert m_req.call_args[1]["params"] == params
115:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
136:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
158:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
180:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
202:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:

240:                "aiohttp.clien
…[1064 chars omitted]…
st") as m_req:
630:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
656:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
682:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
708:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:
729:        with mock.patch("aiohttp.client.ClientSession.request") as m_req:

setup.cfg:102:[isort]
22:strict_equality = True
 M aiohttp/client.py
 M aiohttp/client_proto.py

after handshake 2 <TimerHandle when=526169.696675665 ResponseHandler._on_read_timeout()>
assigned manually 0.05 <TimerHandle when=526169.696675665 ResponseHandler._on_read_timeout()>
first first
message WSMessage(type=<WSMsgType.TEXT: 1>, data='second', extra='') elapsed 1.001357733970508 close None exc None proto None handle <TimerHandle when=526168.74802969 ResponseHandler._on_read_timeout()>

============================= test session starts ==============================
platform linux -- Python 3.12.13, pytest-8.1.1, pluggy-1.4.0
rootdir: /repo
configfile: setup.cfg
plugins: mock-3.14.0, cov-5.0.0
collected 352 items

tests/test_client_functional.py ........................................ [ 11%]
........................................................................ [ 31%]
..x..................................................................... [ 52%]
...............................x....x                                    [ 62%]
tests/test_client_request.py ........................................... [ 75%]

........................................................................ [ 95%]
................                                                         [100%]

================================== XFAILURES ===================================
_______________________
…[8630 chars omitted]…
 summary info ============================
XFAIL tests/test_client_functional.py::test_broken_connection[pyloop]
XFAIL tests/test_client_functional.py::test_rejected_upload[pyloop] - #7599
XFAIL tests/test_client_functional.py::test_header_too_large_error[pyloop] - #8395 Error message regression for large headers in 3.9.4
======================= 349 passed, 3 xfailed in 20.13s ========================

aiohttp/client.py       | 7 ++++++-
 aiohttp/client_proto.py | 8 ++++++++
 2 files changed, 14 insertions(+), 1 deletion(-)
diff --git a/aiohttp/client.py b/aiohttp/client.py
index 4c0ad89..9e33ddc 100644
--- a/aiohttp/client.py
+++ b/aiohttp/client.py
@@ -209,7 +209,7 @@ DEFAULT_TIMEOUT: Final[ClientTimeout] = ClientTimeout(total=5 * 60)
 
 # https://www.rfc-editor.org/rfc/rfc9110#section-9.2.2
 IDEMPOTENT_METHODS = frozenset({"GET", "HEAD", "OPTIONS", "TRACE", "PUT", "DELETE"})
-HTTP_SCHEMA_SET = frozenset({"http", "https", ""})

+HTTP_SCHEMA_SET = frozenset({"http", "https", "ws", "wss", ""})
 
 _RetType = TypeVar("_RetType")
 _CharsetResolver = Callable[[ClientResponse, bytes], str]
@@ -971,6 +971,11 @@ class ClientSession:
             assert conn is not None
             conn_proto = conn.protocol
             assert conn_proto is not None
+            read_timeout = conn_proto.
…[8629 chars omitted]…
t_client_ws_functional.py::test_receive_timeout_deprecation[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_custom_receive_timeout[pyloop]
0.05s call     tests/test_client_ws_functional.py::test_receive_timeout_sock_read[pyloop]
0.04s call     tests/test_client_ws_functional.py::test_send_recv_text[pyloop]
============================== 74 passed in 6.74s ==============================

read timeout: None timeout handle after upgrade: None
first message: first
second message after 1.005021419026889 257 None close 1006 exception ConnectionResetError('Cannot write to closing transport')

after handshake read_timeout 1 timer <TimerHandle when=526447.474936236 ResponseHandler._on_read_timeout()>
first: first
second after 0.300628243945539 = WSMessage(type=<WSMsgType.TEXT: 1>, data='second', extra='') close None exc None proto None

reschedule start 0.05 None parser? False upgraded? False tail len 0
reschedule end <TimerHandle when=526510.814159002 ResponseHandler._on_read_timeout()>
reschedule start 0.05 <TimerHandle when=526510.814159002 ResponseHandler._on_read_timeout()> parser? False upgraded? False tail len 0
reschedule end <TimerHandle when=526510.8143750251 ResponseHandler._on_read_timeout()>
reschedule start 0.05 None parser? False upgraded? True tail len 0
reschedule end <TimerHandle when=526510.814449979 ResponseHandler._on_read_timeout()>
reschedule start None None parser? True upgraded? True tail len 0
reschedule end None
AFTER None None
SLEEP None None protoexc None ws exc None

sock_read=0.5, ws_receive=1.0 -> 1.0
sock_read=0.5, ws_receive=0.25 -> 0.5
sock_read=0.5, ws_receive=None -> None
sock_read=None, ws_receive=1.0 -> None

aiohttp/client.py:378:        return _RequestContextManager(self._request(method, url, **kwargs))
aiohttp/client.py:1077:                self._request(
aiohttp/client.py:1087:                self._request(
aiohttp/client.py:1097:                self._request(
aiohttp/client.py:1107:                self._request(hdrs.METH_POST, url, data=data, **kwargs)
aiohttp/client.py:1115:                self._request(hdrs.METH_PUT, url, data=data, **kwargs)
aiohttp/client.py:1123:                self._request(hdrs.METH_PATCH, url, data=data, **kwargs)
aiohttp/client.py:1129:                self._request(hdrs.METH_DELETE, url, **kwargs)
aiohttp/client.py:1412:        session._request(
aiohttp/test_utils.py:324:        return _RequestContextManager(self._request(method, path, **kwargs))
aiohttp/test_utils.py:328:        return _RequestContextManager(self._request(hdrs.METH_GET, path, **kwargs))
aioh

…[2893 chars omitted]…
t(
1087:                self._request(
1097:                self._request(
1107:                self._request(hdrs.METH_POST, url, data=data, **kwargs)
1115:                self._request(hdrs.METH_PUT, url, data=data, **kwargs)
1123:                self._request(hdrs.METH_PATCH, url, data=data, **kwargs)
1129:                self._request(hdrs.METH_DELETE, url, **kwargs)
1412:        session._request(

M aiohttp/client.py
 M aiohttp/client_proto.py
Makefile:22:# Recipe from https://www.cmcrossroads.com/article/rebuilding-when-files-checksum-changes
Makefile:25:# check_sum.py works perfectly fine but slow when called for every file from $(ALLS)
Makefile:36:	@if ! (sha256sum --check $($@_ABS) 1>/dev/null 2>/dev/null); then \
Makefile:43:	@./tools/check_sum.py $@ # --debug
Makefile:81:lint: fmt mypy
Makefile:87:.PHONY: mypy
Makefile:88:mypy:
Makefile:89:	mypy
setup.cfg:88:[flake8]
setup.cfg:97:# flake8-requirements

[metadata]
name = aiohttp
version = attr: aiohttp.__version__
url = https://github.com/aio-libs/aiohttp
project_urls =
  Chat: Matrix = https://matrix.to/#/#aio-libs:matrix.org
  Chat: Matrix Space = https://matrix.to/#/#aio-libs-space:matrix.org
  CI: GitHub Actions = https://github.com/aio-libs/aiohttp/actions?query=workflow%%3ACI
  Coverage: codecov = https://codecov.io/
…[4651 chars omitted]…
s.readthedocs.io/en/latest/using.html#migrating-from-legacy for migration advice.:DeprecationWarning:certifi.core
    # Dateutil deprecation warning already fixed upstream.
    # Can be dropped with the next release, `dateutil > 2.8.2`
    # https://github.com/dateutil/dateutil/pull/1285
    ignore:datetime.*utcfromtimestamp\(\) is deprecated and scheduled for removal:DeprecationWarning:dateutil.tz.tz

/usr/local/bin/mypy
aiohttp/http_writer.py:192: error: Unused "type: ignore" comment 
[unused-ignore]
        import aiohttp._http_writer as _http_writer  # type: ignore[import...
        ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
aiohttp/http_parser.py:985: error: Unused "type: ignore[import-not-found]"
comment  [unused-ignore]
            from ._http_parser import (  # type: ignore[import-not-found,n...
            ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
aiohttp/http_websocket.py:172: error: Unused "type: ignore" comment 
[unused-ignore]
            from ._websocket import _websocket_mask_cython  # type: ignore...

            ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~...
Found 3 errors in 3 files (checked 2 source files)

submitted.