-

Author: davidbrochart

tests/test_pycrdt_yjs.py

@@ -93,7 +93,7 @@ def callback(_event):
 
         output_text.observe(callback)
 
-        with move_on_after(20):
+        with move_on_after(10):
             await event.wait()
 
         assert output_text.to_py() == ["Hello,", " World!"]

tests/yjs_client_1.js

@@ -8,46 +8,16 @@ import { WebsocketProvider } from 'y-websocket'
 import ws from 'ws'
 
 const notebook = new YNotebook()
-const cells = notebook.ydoc.getArray('cells')
-
-function append_text() {
-  const cell = notebook.getCell(0)
-  const youtput = cell.youtputs.get(0)
-  const text = youtput.get('text')
-  text.insert(1, [' World!'])
-}
-
-function callback2(event) {
-  if (event.transaction.local) {
-    return
-  }
-
-  const cell = notebook.getCell(0)
-  if (cell.youtputs.length > 0) {
-    setTimeout(append_text, 100)
-  }
-}
-
-function callback1(event) {
-  if (event.transaction.local) {
-    return
-  }
-
-  if (cells.length > 0) {
-    const cell = notebook.getCell(0)
-    if (cell.youtputs.length > 0) {
-      setTimeout(append_text, 100)
-    }
-    else {
-      cell.youtputs.observe(callback2)
-    }
-  }
-}
-
-cells.observe(callback1)
 
 const wsProvider = new WebsocketProvider(
   'ws://localhost:1234', 'my-roomname',
   notebook.ydoc,
   { WebSocketPolyfill: ws }
 )
+
+wsProvider.on('sync', (isSynced) => {
+  const cell = notebook.getCell(0)
+  const youtput = cell.youtputs.get(0)
+  const text = youtput.get('text')
+  text.insert(1, [' World!'])
+})