TeamPGM/pyrogram
2
0
Fork 0
mirror of https://github.com/TeamPGM/pyrogram.git synced 2024-11-18 13:34:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make TCPAbridgedO async

Browse Source
This commit is contained in:
Dan 2018-10-08 20:17:04 +02:00
parent 1bf0d93140
commit 78a768f52c
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pyrogram/connection/transport/tcp/tcp_abridged_o.py
View File

@ -34,8 +34,8 @@ class TCPAbridgedO(TCP):
self.encrypt = None self.encrypt = None
self.decrypt = None self.decrypt = None
def connect(self, address: tuple): async def connect(self, address: tuple):
super().connect(address) await super().connect(address)
while True: while True:
nonce = bytearray(os.urandom(64)) nonce = bytearray(os.urandom(64))
@ -53,12 +53,12 @@ class TCPAbridgedO(TCP):
nonce[56:64] = AES.ctr256_encrypt(nonce, *self.encrypt)[56:64] nonce[56:64] = AES.ctr256_encrypt(nonce, *self.encrypt)[56:64]
super().sendall(nonce) await super().send(nonce)
def sendall(self, data: bytes, *args): async def send(self, data: bytes, *args):
length = len(data) // 4 length = len(data) // 4
super().sendall( await super().send(
AES.ctr256_encrypt( AES.ctr256_encrypt(
(bytes([length]) (bytes([length])
if length <= 126 if length <= 126
@ -68,8 +68,8 @@ class TCPAbridgedO(TCP):
) )
) )
def recvall(self, length: int = 0) -> bytes or None: async def recv(self, length: int = 0) -> bytes or None:
length = super().recvall(1) length = await super().recv(1)
if length is None: if length is None:
return None return None
@ -77,14 +77,14 @@ class TCPAbridgedO(TCP):
length = AES.ctr256_decrypt(length, *self.decrypt) length = AES.ctr256_decrypt(length, *self.decrypt)
if length == b"\x7f": if length == b"\x7f":
length = super().recvall(3) length = await super().recv(3)
if length is None: if length is None:
return None return None
length = AES.ctr256_decrypt(length, *self.decrypt) length = AES.ctr256_decrypt(length, *self.decrypt)
data = super().recvall(int.from_bytes(length, "little") * 4) data = await super().recv(int.from_bytes(length, "little") * 4)
if data is None: if data is None:
return None return None