From e4739d8c8e50b7d9ed9528e7bd6f672f71963b4e Mon Sep 17 00:00:00 2001 From: Jon Oberheide Date: Thu, 14 Nov 2024 12:10:21 -0500 Subject: [PATCH] unnecessary utf decode pre-loads --- src/pylutron_caseta/leap.py | 2 +- src/pylutron_caseta/pairing.py | 2 +- tests/test_leap.py | 6 +++--- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/pylutron_caseta/leap.py b/src/pylutron_caseta/leap.py index 98f92ab..c413c43 100644 --- a/src/pylutron_caseta/leap.py +++ b/src/pylutron_caseta/leap.py @@ -85,7 +85,7 @@ async def run(self): if received == b"": break - resp_json = orjson.loads(received.decode("UTF-8")) + resp_json = orjson.loads(received) if isinstance(resp_json, dict): tag = resp_json.get("Header", {}).pop("ClientTag", None) diff --git a/src/pylutron_caseta/pairing.py b/src/pylutron_caseta/pairing.py index 064b23b..18b20d2 100644 --- a/src/pylutron_caseta/pairing.py +++ b/src/pylutron_caseta/pairing.py @@ -57,7 +57,7 @@ async def async_read_json(self, timeout): return None LOGGER.debug("received: %s", buffer) - return orjson.loads(buffer.decode("UTF-8")) + return orjson.loads(buffer) async def async_write_json(self, obj): """Write an object.""" diff --git a/tests/test_leap.py b/tests/test_leap.py index cd48a73..6056311 100644 --- a/tests/test_leap.py +++ b/tests/test_leap.py @@ -109,7 +109,7 @@ async def test_call(pipe: Pipe): """Test basic call and response.""" task = asyncio.create_task(pipe.leap.request("ReadRequest", "/test")) - received = orjson.loads((await pipe.test_reader.readline()).decode("utf-8")) + received = orjson.loads(await pipe.test_reader.readline()) # message should contain ClientTag tag = received.get("Header", {}).pop("ClientTag", None) @@ -232,7 +232,7 @@ def handler(response): task = asyncio.create_task(pipe.leap.subscribe("/test", handler)) - received = orjson.loads((await pipe.test_reader.readline()).decode("utf-8")) + received = orjson.loads(await pipe.test_reader.readline()) # message should contain ClientTag tag = received.get("Header", {}).pop("ClientTag", None) @@ -287,7 +287,7 @@ def _handler(_: Response): task = asyncio.create_task(pipe.leap.subscribe("/test", _handler)) - received = orjson.loads((await pipe.test_reader.readline()).decode("utf-8")) + received = orjson.loads(await pipe.test_reader.readline()) tag = received.get("Header", {}).pop("ClientTag", None) response_obj = {