fix: trim message after persist

Author: stanley2058

src/y-socket-io/y-socket-io.js

@@ -411,8 +411,12 @@ export class YSocketIO {
         changed = tr.changed.size > 0
       })
       Y.transact(existDoc.ydoc, () => {
-        for (const msg of updates) Y.applyUpdate(existDoc.ydoc, msg)
+        for (const msg of updates) {
+          if (msg.length === 0) continue
+          Y.applyUpdate(existDoc.ydoc, msg)
+        }
         for (const msg of awareness) {
+          if (msg.length === 0) continue
           AwarenessProtocol.applyAwarenessUpdate(existDoc.awareness, msg, null)
         }
       })
@@ -429,7 +433,6 @@ export class YSocketIO {
     this.debouncedPersist(namespace, doc.ydoc)
     this.namespaceDocMap.get(namespace)?.ydoc.destroy()
     this.namespaceDocMap.set(namespace, doc)
-    await this.client.trimRoomStream(namespace, 'index', nsp.sockets.size === 0)
   }
 
   /**
@@ -456,6 +459,7 @@ export class YSocketIO {
           const doc = this.debouncedPersistDocMap.get(namespace)
           if (!doc) return
           await this.client.store.persistDoc(namespace, 'index', doc)
+          await this.client.trimRoomStream(namespace, 'index', true)
           this.debouncedPersistDocMap.delete(namespace)
           this.debouncedPersistMap.delete(namespace)
         },