LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2025-03-10 06:05:47 +03:00
Code Issues Packages Projects Releases Wiki Activity

Remove forgotten points

Browse Source
This commit is contained in:
Andrey Egorov 2017-10-29 15:33:03 +03:00
parent 6dc0ee9d6c
commit cb2d943139
3 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
telethon/network/mtproto_sender.py
View File

@ -275,12 +275,10 @@ class MtProtoSender:
async def _resend_request(self, msg_id): async def _resend_request(self, msg_id):
request = self._pop_request(msg_id) request = self._pop_request(msg_id)
if request: if request:
self._logger.debug('requests is about to resend')
await self.send(request) await self.send(request)
return return
requests = self._pop_requests_of_container(msg_id) requests = self._pop_requests_of_container(msg_id)
if requests: if requests:
self._logger.debug('container of requests is about to resend')
await self.send(*requests) await self.send(*requests)
async def _handle_pong(self, msg_id, sequence, reader): async def _handle_pong(self, msg_id, sequence, reader):
@ -362,6 +360,7 @@ class MtProtoSender:
# TODO For now, simply ack msg_new.answer_msg_id # TODO For now, simply ack msg_new.answer_msg_id
# Relevant tdesktop source code: https://goo.gl/VvpCC6 # Relevant tdesktop source code: https://goo.gl/VvpCC6
await self._send_acknowledge(msg_new.answer_msg_id)
return True return True
async def _handle_msg_new_detailed_info(self, msg_id, sequence, reader): async def _handle_msg_new_detailed_info(self, msg_id, sequence, reader):
@ -370,6 +369,7 @@ class MtProtoSender:
# TODO For now, simply ack msg_new.answer_msg_id # TODO For now, simply ack msg_new.answer_msg_id
# Relevant tdesktop source code: https://goo.gl/G7DPsR # Relevant tdesktop source code: https://goo.gl/G7DPsR
await self._send_acknowledge(msg_new.answer_msg_id)
return True return True
async def _handle_new_session_created(self, msg_id, sequence, reader): async def _handle_new_session_created(self, msg_id, sequence, reader):

2
telethon/telegram_bare_client.py
View File

@ -693,7 +693,7 @@ class TelegramBareClient:
""" """
self.updates.process(await self(GetStateRequest())) self.updates.process(await self(GetStateRequest()))
async def add_update_handler(self, handler): def add_update_handler(self, handler):
"""Adds an update handler (a function which takes a TLObject, """Adds an update handler (a function which takes a TLObject,
an update, as its parameter) and listens for updates""" an update, as its parameter) and listens for updates"""
self.updates.handlers.append(handler) self.updates.handlers.append(handler)

2
telethon/tl/tl_message.py
View File

@ -1,5 +1,4 @@
import struct import struct
import logging
from . import TLObject, GzipPacked from . import TLObject, GzipPacked
@ -13,7 +12,6 @@ class TLMessage(TLObject):
self.seq_no = session.generate_sequence(request.content_related) self.seq_no = session.generate_sequence(request.content_related)
self.request = request self.request = request
self.container_msg_id = None self.container_msg_id = None
logging.getLogger(__name__).debug(self)
def to_dict(self, recursive=True): def to_dict(self, recursive=True):
return { return {