disabled corking of messages for now

Author: dmonad

src/server.js

@@ -516,23 +516,32 @@ class WSUser {
    */
   onStreamMessage (_room, ms) {
     if (ms.length > 0) {
-      const encoder = encoding.createEncoder()
+      /** @type {Array<Uint8Array<ArrayBuffer>>} */
+      const ydocUpdates = []
+      /** @type {Array<Uint8Array<ArrayBuffer>>} */
+      const awarenessUpdates = []
       ms.forEach(message => {
         switch (message.type) {
           case 'ydoc:update:v1': {
-            protocol.writeSyncUpdate(encoder, message.update)
+            ydocUpdates.push(message.update)
             break
           }
           case 'awareness:v1': {
-            protocol.writeAwarenessUpdate(encoder, message.update)
+            awarenessUpdates.push(message.update)
             break
           }
           default: {
             this.log.error('unexpected message type on stream: ' + /** @type {any} */ (message).type)
           }
         }
       })
-      this.sendData(encoding.toUint8Array(encoder))
+      // @todo send this as a single update message
+      if (ydocUpdates.length > 0) {
+        this.sendData(protocol.encodeSyncUpdate(Y.mergeUpdates(ydocUpdates)))
+      }
+      if (awarenessUpdates.length > 0) {
+        this.sendData(protocol.mergeAwarenessUpdates(awarenessUpdates))
+      }
     }
   }