[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

pycrdt_websocket/ystore.py

@@ -183,7 +183,7 @@ async def check_version(self) -> int:
                 await anyio.Path(self.path).rename(new_path)
         if version_mismatch:
             async with await anyio.open_file(self.path, "wb") as f:
-                version_bytes = f"VERSION:{self.version}\n".encode()  # noqa
+                version_bytes = f"VERSION:{self.version}\n".encode()
                 await f.write(version_bytes)
                 offset = len(version_bytes)
         return offset
@@ -424,7 +424,7 @@ async def write(self, data: bytes) -> None:
                     async with db.execute(
                         "SELECT yupdate FROM yupdates WHERE path = ?", (self.path,)
                     ) as cursor:
-                        async for update, in cursor:
+                        async for (update,) in cursor:
                             ydoc.apply_update(update)
                     # delete history
                     await db.execute("DELETE FROM yupdates WHERE path = ?", (self.path,))

pycrdt_websocket/yutils.py

@@ -78,7 +78,7 @@ def read_message(self) -> bytes | None:
         if length == 0:
             return b""
         i1 = self.i0 + length
-        message = self.stream[self.i0 : i1]  # noqa
+        message = self.stream[self.i0 : i1]
         self.i0 = i1
         self.length -= length
         return message

tests/test_asgi.py

@@ -26,14 +26,14 @@ async def test_asgi(unused_tcp_port):
         ydoc1["map"] = ymap1 = Map()
         ymap1["key"] = "value"
         async with connect(
-            f"ws://localhost:{unused_tcp_port}/my-roomname"  # noqa
+            f"ws://localhost:{unused_tcp_port}/my-roomname"
         ) as websocket1, WebsocketProvider(ydoc1, websocket1):
             await sleep(0.1)
 
         # client 2
         ydoc2 = Doc()
         async with connect(
-            f"ws://localhost:{unused_tcp_port}/my-roomname"  # noqa
+            f"ws://localhost:{unused_tcp_port}/my-roomname"
         ) as websocket2, WebsocketProvider(ydoc2, websocket2):
             await sleep(0.1)