bin/utils.cjs

@@ -42,7 +42,7 @@ if (typeof persistenceDir === 'string') {
         ldb.storeUpdate(docName, update)
       })
     },
-    writeState: async (docName, ydoc) => {}
+    writeState: async (_docName, _ydoc) => {}
   }
 }
 
@@ -85,7 +85,22 @@ const updateHandler = (update, _origin, doc, _tr) => {
   doc.conns.forEach((_, conn) => send(doc, conn, message))
 }
 
-class WSSharedDoc extends Y.Doc {
+/**
+ * @type {(ydoc: Y.Doc) => Promise<void>}
+ */
+let contentInitializor = _ydoc => Promise.resolve()
+
+/**
+ * This function is called once every time a Yjs document is created. You can
+ * use it to pull data from an external source or initialize content.
+ *
+ * @param {(ydoc: Y.Doc) => Promise<void>} f
+ */
+export const setContentInitializor = (f) => {
+  contentInitializor = f
+}
+
+export class WSSharedDoc extends Y.Doc {
   /**
    * @param {string} name
    */
@@ -133,6 +148,7 @@ class WSSharedDoc extends Y.Doc {
         { maxWait: CALLBACK_DEBOUNCE_MAXWAIT }
       ))
     }
+    this.whenInitialized = contentInitializor(this)
   }
 }
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "y-websocket",
-  "version": "2.0.0",
+  "version": "2.0.1",
   "description": "Websockets provider for Yjs",
   "main": "./dist/y-websocket.cjs",
   "module": "./src/y-websocket.js",