fix: support http2 upgrade requests

due to an issue in underlying aiohttp library, http2 upgrade requests
caused an internal error.

This was fixed in [#8252](aio-libs/aiohttp#8252)
and presumeably included in release 3.9.4, but included test shows, that
is only fixed for >= 3.10.2.

Co-authored-by: Andreas Schimmelschulze <[email protected]>

requirements.txt

@@ -1,3 +1,3 @@
-aiohttp~=3.9.5
+aiohttp~=3.10.10
 types-setuptools
 pre-commit

setup.py

@@ -11,7 +11,7 @@
 
 setup(
     name='http_request_recorder',
-    version='1.0.2',
+    version='1.0.3',
     description='A package to record an respond to http requests, primarily for use in black box testing.',
     long_description=readme,
     author='',
@@ -21,7 +21,7 @@
     packages=['http_request_recorder'],
     package_data={"http_request_recorder": ["py.typed"]},
     install_requires=[
-        'aiohttp~=3.9.5',
+        'aiohttp~=3.10.10',
     ],
     zip_safe=False
 )

tests/test_http_request_recorder.py

@@ -287,3 +287,23 @@ async def test_matches_on_headers(self) -> None:
 
             recorded_foo_request = await foo_expect.wait()
             self.assertEqual(recorded_foo_request, b'foo-data')
+
+    # aiohttp (< 3.10.2) has buggy behavior when dealing with http2 upgrade requests.
+    # This was fixed in https://github.com/aio-libs/aiohttp/pull/8252 which according
+    # to release notes is included in 3.9.4. However, first working version is 3.10.2.
+    async def test_connection_with_http2_upgrade_does_not_fail(self) -> None:
+        http2_upgrade_headers = {
+            'Connection': 'Upgrade, HTTP2-Settings',
+            'Upgrade': 'h2c',
+            'HTTP2-Settings': 'AAEAAEAAAAIAAAAAAAMAAAAAAAQBAAAAAAUAAEAAAAYABgAA'
+        }
+
+        async with (HttpRequestRecorder(name="testrecorder",
+                                        port=self.port) as recorder, ClientSession(headers=http2_upgrade_headers) as http_session):
+            exp = recorder.expect_path('/anypath', responses='anywhere')
+
+            response = await http_session.post(f'http://localhost:{self.port}/anypath', data='anything')
+
+            await exp.wait()
+
+            self.assertEqual(200, response.status)