TeamPGM/pyrogram
2
0
Fork 0
mirror of https://github.com/TeamPGM/pyrogram.git synced 2024-11-17 21:22:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'develop' into asyncio

Browse Source 
# Conflicts:
#	pyrogram/session/session.py
This commit is contained in:
Dan 2019-03-03 16:54:43 +01:00
commit 4b73358922
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pyrogram/session/session.py
View File

@ -44,6 +44,7 @@ class Result:
class Session: class Session:
INITIAL_SALT = 0x616e67656c696361 INITIAL_SALT = 0x616e67656c696361
NET_WORKERS = 1 NET_WORKERS = 1
START_TIMEOUT = 1
WAIT_TIMEOUT = 15 WAIT_TIMEOUT = 15
MAX_RETRIES = 5 MAX_RETRIES = 5
ACKS_THRESHOLD = 8 ACKS_THRESHOLD = 8
@ -118,8 +119,14 @@ class Session:
self.recv_task = asyncio.ensure_future(self.recv()) self.recv_task = asyncio.ensure_future(self.recv())
self.current_salt = FutureSalt(0, 0, Session.INITIAL_SALT) self.current_salt = FutureSalt(0, 0, Session.INITIAL_SALT)
self.current_salt = FutureSalt(0, 0, (await self._send(functions.Ping(0))).new_server_salt) self.current_salt = FutureSalt(
self.current_salt = (await self._send(functions.GetFutureSalts(1))).salts[0] 0, 0,
(await self._send(
functions.Ping(0),
timeout=self.START_TIMEOUT
)).new_server_salt
)
self.current_salt = (await self._send(functions.GetFutureSalts(1), timeout=self.START_TIMEOUT)).salts[0]
self.next_salt_task = asyncio.ensure_future(self.next_salt()) self.next_salt_task = asyncio.ensure_future(self.next_salt())
@ -137,7 +144,8 @@ class Session:
lang_pack="", lang_pack="",
query=functions.help.GetConfig(), query=functions.help.GetConfig(),
) )
) ),
timeout=self.START_TIMEOUT
) )
self.ping_task = asyncio.ensure_future(self.ping()) self.ping_task = asyncio.ensure_future(self.ping())