Browse Source

Also rewrite shared doc

Shun Miyazawa 1 year ago
parent
commit
c9954f75d9
1 changed files with 3 additions and 1 deletions
  1. 3 1
      apps/app/src/server/service/yjs-connection-manager.ts

+ 3 - 1
apps/app/src/server/service/yjs-connection-manager.ts

@@ -68,7 +68,7 @@ class YjsConnectionManager {
       currentYdoc.getText('codemirror').insert(0, initialValue);
       currentYdoc.getText('codemirror').insert(0, initialValue);
     }
     }
 
 
-    await this.syncWithPersistedYdoc(pageId, currentYdoc, persistedYdoc);
+    this.syncWithPersistedYdoc(pageId, currentYdoc, persistedYdoc);
 
 
     currentYdoc.on('update', async(update) => {
     currentYdoc.on('update', async(update) => {
       await this.mdb.storeUpdate(pageId, update);
       await this.mdb.storeUpdate(pageId, update);
@@ -103,6 +103,8 @@ class YjsConnectionManager {
     if (diff.reduce((prev, curr) => prev + curr, 0) > 0) {
     if (diff.reduce((prev, curr) => prev + curr, 0) > 0) {
       await this.mdb.storeUpdate(pageId, diff);
       await this.mdb.storeUpdate(pageId, diff);
     }
     }
+
+    Y.applyUpdate(currentYdoc, Y.encodeStateAsUpdate(persistedYdoc));
   }
   }
 
 
   public getCurrentYdoc(pageId: string): Ydoc | undefined {
   public getCurrentYdoc(pageId: string): Ydoc | undefined {