gandc/mtprotoproxy
1
0
Fork 0
mirror of https://github.com/alexbers/mtprotoproxy.git synced 2026-03-14 07:13:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix small bugs

Browse Source
This commit is contained in:
Alexander Bersenev
2026-02-10 16:49:20 +05:00
parent 375fee1535
commit 34f743858c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
mtprotoproxy.py
View File

@@ -657,7 +657,7 @@ class CryptoWrappedStreamReader(LayeredStreamReaderBase):
needed_till_full_block = -len(data) % self.block_size needed_till_full_block = -len(data) % self.block_size
if needed_till_full_block > 0: if needed_till_full_block > 0:
data += self.upstream.readexactly(needed_till_full_block) data += await self.upstream.readexactly(needed_till_full_block)
return self.decryptor.decrypt(data) return self.decryptor.decrypt(data)
async def readexactly(self, n): async def readexactly(self, n):
@@ -1364,7 +1364,7 @@ async def do_direct_handshake(proto_tag, dc_idx, dec_key_and_iv=None):
print_err("Got connection refused while trying to connect to", dc, TG_DATACENTER_PORT) print_err("Got connection refused while trying to connect to", dc, TG_DATACENTER_PORT)
return False return False
except ConnectionAbortedError as E: except ConnectionAbortedError as E:
print_err("The Telegram server connection is bad: %d (%s %s) %s" % (dc_idx, addr, port, E)) print_err("The Telegram server connection is bad: %d (%s %s) %s" % (dc_idx, dc, TG_DATACENTER_PORT, E))
return False return False
except (OSError, asyncio.TimeoutError) as E: except (OSError, asyncio.TimeoutError) as E:
print_err("Unable to connect to", dc, TG_DATACENTER_PORT) print_err("Unable to connect to", dc, TG_DATACENTER_PORT)