Start the server awareness (#78)

* Start the server awareness * Stop the awareness * Apply suggestions from review Co-authored-by: David Brochart <[email protected]> * Stop awareness on error --------- Co-authored-by: David Brochart <[email protected]> Co-authored-by: David Brochart <[email protected]>
jupyter-server · Oct 14, 2024 · b43acfd · b43acfd
1 parent c7e3955
commit b43acfd
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/pycrdt_websocket/yroom.py b/pycrdt_websocket/yroom.py
@@ -213,6 +213,7 @@ async def start(
             self._task_group.start_soon(self._stopped.wait)
             self._task_group.start_soon(self._watch_ready)
             self._task_group.start_soon(self._broadcast_updates)
+            self._task_group.start_soon(self.awareness.start)
             return
 
         async with self._start_lock:
@@ -231,15 +232,18 @@ async def start(
                         self._task_group.start_soon(self._stopped.wait)
                         self._task_group.start_soon(self._watch_ready)
                         self._task_group.start_soon(self._broadcast_updates)
+                        self._task_group.start_soon(self.awareness.start)
                     return
                 except Exception as exception:
+                    await self.awareness.stop()
                     self._handle_exception(exception)
 
     async def stop(self) -> None:
         """Stop the room."""
         if self._task_group is None:
             raise RuntimeError("YRoom not running")
         self._stopped.set()
+        await self.awareness.stop()
         self._task_group.cancel_scope.cancel()
         self._task_group = None
         if self._subscription is not None:

diff --git a/pyproject.toml b/pyproject.toml
@@ -30,7 +30,7 @@ classifiers = [
 dependencies = [
     "anyio >=3.6.2,<5",
     "sqlite-anyio >=0.2.3,<0.3.0",
-    "pycrdt >=0.10.1,<0.11.0",
+    "pycrdt >=0.10.3,<0.11.0",
 ]
 
 [project.optional-dependencies]