LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2024-11-23 01:46:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix MTProtoSender should not send content-related queries

Browse Source
This commit is contained in:
Lonami Exo 2018-06-17 16:23:22 +02:00
parent 145d4b7105
commit d9d586171f
2 changed files with 5 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
telethon/client/telegrambaseclient.py
View File

@ -170,7 +170,6 @@ class TelegramBaseClient(abc.ABC):
self._connection = connection
self._sender = MTProtoSender(
state, connection, self._loop,
first_query=self._init_with(functions.help.GetConfigRequest()),
update_callback=self._handle_update
)
@ -231,6 +230,9 @@ class TelegramBaseClient(abc.ABC):
await self._sender.connect(
self.session.server_address, self.session.port)
await self._sender.send(self._init_with(
functions.help.GetConfigRequest()))
if not had_auth:
self.session.auth_key = self._sender.state.auth_key
self.session.save()

12
telethon/network/mtprotosender.py
View File

@ -45,16 +45,14 @@ class MTProtoSender:
A new authorization key will be generated on connection if no other
key exists yet.
"""
def __init__(self, state, connection, loop, *, retries=5,
first_query=None, update_callback=None):
def __init__(self, state, connection, loop, *,
retries=5, update_callback=None):
self.state = state
self._connection = connection
self._loop = loop
self._ip = None
self._port = None
self._retries = retries
self._first_query = first_query
self._is_first_query = bool(first_query)
self._update_callback = update_callback
# Whether the user has explicitly connected or disconnected.
@ -225,7 +223,6 @@ class MTProtoSender:
__log__.debug('Connection success!')
if self.state.auth_key is None:
self._is_first_query = bool(self._first_query)
plain = MTProtoPlainSender(self._connection)
for retry in range(1, self._retries + 1):
try:
@ -248,11 +245,6 @@ class MTProtoSender:
__log__.debug('Starting receive loop')
self._recv_loop_handle = self._loop.create_task(self._recv_loop())
if self._is_first_query:
__log__.debug('Running first query')
self._is_first_query = False
await self.send(self._first_query)
__log__.info('Connection to {} complete!'.format(self._ip))
async def _reconnect(self):