Bump pycrdt-v0.8.30

Author: davidbrochart

pyproject.toml

@@ -19,7 +19,7 @@ keywords = [
 ]
 dependencies = [
     "comm >=0.1.4,<1",
-    "pycrdt >=0.8.2,<0.9.0",
+    "pycrdt >=0.8.30,<0.9.0",
     "declare >=1.0.1,<2.0.0",
 ]
 

tests/conftest.py

@@ -4,10 +4,16 @@
 
 import comm
 import pytest
-from pycrdt import TransactionEvent
+from pycrdt import (
+    YMessageType,
+    YSyncMessageType,
+    TransactionEvent,
+    create_sync_message,
+    create_update_message,
+    handle_sync_message,
+)
 from ypywidgets import Widget
 from ypywidgets.comm import CommWidget
-from ypywidgets.utils import YMessageType, YSyncMessageType, create_update_message, process_sync_message, sync
 
 
 class MockComm(comm.base_comm.BaseComm):
@@ -73,13 +79,13 @@ async def receive(self):
             msg_type, data, metadata, buffers, target_name, target_module = await self.comm.send_queue.get()
             if msg_type == "comm_open":
                 self.widget = self.widget_factory()
-                msg = sync(self.widget.ydoc)
-                self.comm.handle_msg(msg)
+                msg = create_sync_message(self.widget.ydoc)
+                self.comm.handle_msg({"buffers": [msg]})
             elif msg_type == "comm_msg":
                 message = buffers[0]
                 if message[0] == YMessageType.SYNC:
-                    reply = process_sync_message(message[1:], self.widget.ydoc)
-                    if reply:
+                    reply = handle_sync_message(message[1:], self.widget.ydoc)
+                    if reply is not None:
                         self.comm.handle_msg({"buffers": [reply]})
                     if message[1] == YSyncMessageType.SYNC_STEP2:
                         self.widget.ydoc.observe(self.send)

ypywidgets/comm.py

@@ -1,15 +1,17 @@
 from __future__ import annotations
 
 import comm
-from pycrdt import Doc, Text, TransactionEvent
-
-from .utils import (
+from pycrdt import (
+    Doc,
+    Text,
+    TransactionEvent,
     YMessageType,
     YSyncMessageType,
+    create_sync_message,
     create_update_message,
-    process_sync_message,
-    sync,
+    handle_sync_message,
 )
+
 from .widget import Widget
 
 
@@ -35,15 +37,15 @@ def __init__(
     ) -> None:
         self._ydoc = ydoc
         self._comm = comm
-        msg = sync(ydoc)
-        self._comm.send(**msg)
+        msg = create_sync_message(ydoc)
+        self._comm.send(buffers=[msg])
         self._comm.on_msg(self._receive)
 
     def _receive(self, msg):
         message = bytes(msg["buffers"][0])
         if message[0] == YMessageType.SYNC:
-            reply = process_sync_message(message[1:], self._ydoc)
-            if reply:
+            reply = handle_sync_message(message[1:], self._ydoc)
+            if reply is not None:
                 self._comm.send(buffers=[reply])
             if message[1] == YSyncMessageType.SYNC_STEP2:
                 self._ydoc.observe(self._send)