Mirrored_Repos/python-kasa
1
0
Fork 0
mirror of https://github.com/python-kasa/python-kasa.git synced 2024-12-22 19:23:34 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Avoid recreating struct each request in legacy protocol (#628)

Browse Source
This commit is contained in:
J. Nick Koston 2024-01-09 13:51:04 -10:00 committed by GitHub
parent 510aea7207
commit 460054ced7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
kasa/protocol.py
View File

@ -31,6 +31,7 @@ from .json import loads as json_loads
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
_NO_RETRY_ERRORS = {errno.EHOSTDOWN, errno.EHOSTUNREACH, errno.ECONNREFUSED} _NO_RETRY_ERRORS = {errno.EHOSTDOWN, errno.EHOSTUNREACH, errno.ECONNREFUSED}
_UNSIGNED_INT_NETWORK_ORDER = struct.Struct(">I")
def md5(payload: bytes) -> bytes: def md5(payload: bytes) -> bytes:
@ -206,7 +207,7 @@ class TPLinkSmartHomeProtocol(TPLinkProtocol):
await self.writer.drain() await self.writer.drain()
packed_block_size = await self.reader.readexactly(self.BLOCK_SIZE) packed_block_size = await self.reader.readexactly(self.BLOCK_SIZE)
length = struct.unpack(">I", packed_block_size)[0] length = _UNSIGNED_INT_NETWORK_ORDER.unpack(packed_block_size)[0]
buffer = await self.reader.readexactly(length) buffer = await self.reader.readexactly(length)
response = TPLinkSmartHomeProtocol.decrypt(buffer) response = TPLinkSmartHomeProtocol.decrypt(buffer)
@ -311,7 +312,7 @@ class TPLinkSmartHomeProtocol(TPLinkProtocol):
:return: ciphertext to be send over wire, in bytes :return: ciphertext to be send over wire, in bytes
""" """
plainbytes = request.encode() plainbytes = request.encode()
return struct.pack(">I", len(plainbytes)) + bytes( return _UNSIGNED_INT_NETWORK_ORDER.pack(len(plainbytes)) + bytes(
TPLinkSmartHomeProtocol._xor_payload(plainbytes) TPLinkSmartHomeProtocol._xor_payload(plainbytes)
) )