mirror/pyTelegramBotAPI
1
0
Fork 0
mirror of https://github.com/eternnoir/pyTelegramBotAPI.git synced 2023-08-10 21:12:57 +03:00
Code Releases Activity

Merge pull request #1638 from coder2020official/master

Browse Source 
Fixes #1637, #1636
This commit is contained in:
Badiboy
2022-07-18 18:14:52 +03:00
committed by GitHub
parent 54ad1582aa 49d3b463ed
commit e553f3aa1d
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
telebot/asyncio_helper.py
View File

@ -1,5 +1,7 @@
import asyncio # for future uses import asyncio # for future uses
import ssl
import aiohttp import aiohttp
import certifi
from telebot import types from telebot import types
try: try:
@ -26,18 +28,22 @@ REQUEST_LIMIT = 50
class SessionManager: class SessionManager:
def __init__(self) -> None: def __init__(self) -> None:
self.session = aiohttp.ClientSession(connector=aiohttp.TCPConnector( self.session = None
limit=REQUEST_LIMIT self.ssl_context = ssl.create_default_context(cafile=certifi.where())
))
async def create_session(self): async def create_session(self):
self.session = aiohttp.ClientSession(connector=aiohttp.TCPConnector( self.session = aiohttp.ClientSession(connector=aiohttp.TCPConnector(
limit=REQUEST_LIMIT limit=REQUEST_LIMIT,
ssl_context=self.ssl_context
)) ))
return self.session return self.session
async def get_session(self): async def get_session(self):
if self.session is None:
self.session = await self.create_session()
return self.session
if self.session.closed: if self.session.closed:
self.session = await self.create_session() self.session = await self.create_session()