platformio/platformio-core
1
0
Fork 1
mirror of https://github.com/platformio/platformio-core.git synced 2025-08-01 02:54:25 +02:00
Code Issues Packages Projects Releases Wiki Activity

Keep http session per active PIO Home

Browse Source
This commit is contained in:
Ivan Kravets
2023-06-29 21:28:46 +03:00
parent 450f48ba81
commit a28a3d31c9
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
platformio/home/rpc/handlers/os.py
View File

@@ -37,8 +37,10 @@ class HTTPAsyncSession(HTTPSession):
class OSRPC(BaseRPCHandler): class OSRPC(BaseRPCHandler):
@staticmethod _http_session = None
async def fetch_content(url, data=None, headers=None, cache_valid=None):
@classmethod
async def fetch_content(cls, url, data=None, headers=None, cache_valid=None):
if not headers: if not headers:
headers = { headers = {
"User-Agent": ( "User-Agent": (
@@ -57,11 +59,13 @@ class OSRPC(BaseRPCHandler):
# check internet before and resolve issue with 60 seconds timeout # check internet before and resolve issue with 60 seconds timeout
ensure_internet_on(raise_exception=True) ensure_internet_on(raise_exception=True)
session = HTTPAsyncSession() if not cls._http_session:
cls._http_session = HTTPAsyncSession()
if data: if data:
r = await session.post(url, data=data, headers=headers) r = await cls._http_session.post(url, data=data, headers=headers)
else: else:
r = await session.get(url, headers=headers) r = await cls._http_session.get(url, headers=headers)
r.raise_for_status() r.raise_for_status()
result = r.text result = r.text