fix(web): hotfix unclosed uvloop SSL transport

MagicStack/uvloop#471 (comment)
aio-libs/aiohttp#6762 (comment)
Signed-off-by: Rongrong <[email protected]>

Author: Rongronggg9

src/compat.py

@@ -4,6 +4,7 @@
 import sys
 import functools
 
+from aiohttp import ClientResponse
 from cachetools.keys import hashkey
 
 _version_info = sys.version_info
@@ -34,9 +35,19 @@ def __exit__(self, *excinfo):
         async def __aenter__(self):
             return self.enter_result
 
-        async def __aexit__(self, *excinfo):
+        async def __aexit__(self, exc_type, exc_value, traceback):
             pass
 
+
+class AiohttpUvloopTransportHotfix(AbstractAsyncContextManager):
+    def __init__(self, response: ClientResponse):
+        self.transport = response.connection and response.connection.transport
+
+    async def __aexit__(self, exc_type, exc_value, traceback):
+        if self.transport:
+            self.transport.abort()
+
+
 # default cipher list in Python 3.9
 _ciphers_py39 = (
     'TLS_AES_256_GCM_SHA384:'

src/web.py

@@ -2,7 +2,7 @@
 from typing import Union, Optional, AnyStr
 from typing_extensions import Final
 from collections.abc import Callable
-from .compat import nullcontext, ssl_create_default_context
+from .compat import nullcontext, ssl_create_default_context, AiohttpUvloopTransportHotfix
 
 import re
 import asyncio
@@ -225,15 +225,16 @@ async def _fetch():
         async with aiohttp.ClientSession(connector=proxy_connector, timeout=aiohttp.ClientTimeout(total=timeout),
                                          headers=_headers) as session:
             async with session.get(url, read_bufsize=read_bufsize, read_until_eof=read_until_eof) as response:
-                status = response.status
-                content = None
-                if status == 200:
-                    content = await resp_callback(response)
-                return WebResponse(url=url,
-                                   content=content,
-                                   headers=response.headers,
-                                   status=status,
-                                   reason=response.reason)
+                async with AiohttpUvloopTransportHotfix(response):
+                    status = response.status
+                    content = None
+                    if status == 200:
+                        content = await resp_callback(response)
+                    return WebResponse(url=url,
+                                       content=content,
+                                       headers=response.headers,
+                                       status=status,
+                                       reason=response.reason)
 
     tries = 0
     retry_in_v4_flag = False