fix tests

Author: gonpombo8

package-lock.json

@@ -6,7 +6,7 @@
   "bugs": "https://github.com/decentraland/js-sdk-toolchain/issues",
   "dependencies": {
     "@actions/core": "^1.10.0",
-    "@dcl/protocol": "https://sdk-team-cdn.decentraland.org/@dcl/protocol/branch//dcl-protocol-1.0.0-12791463180.commit-127443e.tgz",
+    "@dcl/protocol": "https://sdk-team-cdn.decentraland.org/@dcl/protocol/branch//dcl-protocol-1.0.0-12826974654.commit-3b9cde0.tgz",
     "@dcl/quickjs-emscripten": "^0.21.0-3680274614.commit-1808aa1",
     "@dcl/ts-proto": "1.153.0",
     "@types/fs-extra": "^9.0.12",

package.json

@@ -53,7 +53,7 @@ export function addSyncTransport(
       }
       const peerMessages = getMessagesToSend()
 
-      const response = await sendBinary({ data: [], peerData: peerMessages })
+      const response = await sendBinary({ data: peerMessages.map(($) => $.data).flat(), peerData: peerMessages })
       binaryMessageBus.__processMessages(response.data)
       transportInitialzed = true
     },

packages/@dcl/sdk/src/network/message-bus-sync.ts

@@ -18,6 +18,7 @@ import { createRendererTransport } from '../../../packages/@dcl/sdk/internal/tra
 import { ReadWriteByteBuffer } from '../../../packages/@dcl/ecs/src/serialization/ByteBuffer'
 import { readMessage } from '../../../packages/@dcl/ecs/src/serialization/crdt/message'
 import { EntityState, PutNetworkComponentOperation } from '../../../packages/@dcl/ecs/src'
+import { SendBinaryRequest, SendBinaryResponse } from '~system/CommunicationsController'
 
 function defineComponents(engine: IEngine) {
   return {
@@ -73,15 +74,17 @@ describe('Network Parenting', () => {
   const messagesA: Uint8Array[] = []
   const messagesB: Uint8Array[] = []
 
-  const sendBinaryA = async (msg: { data: Uint8Array[] }) => {
-    for (const value of msg.data) {
-      const messageType = value.subarray(0, 1)[0]
-      if (messageType === CommsMessage.CRDT) {
-        const crdtMessage = value.subarray(1)
-        intercept(crdtMessage, 'a->b')
+  const sendBinaryA: (msg: SendBinaryRequest) => Promise<SendBinaryResponse> = async (msg) => {
+    for (const value of msg.peerData) {
+      for (const data of value.data) {
+        messagesB.push(data)
+        const messageType = data.subarray(0, 1)[0]
+        if (messageType === CommsMessage.CRDT) {
+          const crdtMessage = data.subarray(1)
+          intercept(crdtMessage, 'a->b')
+        }
       }
     }
-    messagesB.push(...msg.data)
     const messages = [...messagesA].map(($) => {
       const senderBytes = encodeString('B')
       const serializedMessage = new Uint8Array($.byteLength + senderBytes.byteLength + 1)
@@ -93,16 +96,18 @@ describe('Network Parenting', () => {
     messagesA.length = 0
     return { data: messages }
   }
-  const sendBinaryB = async (msg: { data: Uint8Array[] }) => {
-    for (const value of msg.data) {
-      const messageType = value.subarray(0, 1)[0]
-      if (messageType === CommsMessage.CRDT) {
-        const crdtMessage = value.subarray(1)
-        intercept(crdtMessage, 'b->a')
+  const sendBinaryB: (msg: SendBinaryRequest) => Promise<SendBinaryResponse> = async (msg) => {
+    for (const value of msg.peerData) {
+      for (const data of value.data) {
+        messagesA.push(data)
+        const messageType = data.subarray(0, 1)[0]
+        if (messageType === CommsMessage.CRDT) {
+          const crdtMessage = data.subarray(1)
+          intercept(crdtMessage, 'b->a')
+        }
       }
     }
 
-    messagesA.push(...msg.data)
     const messages = [...messagesB].map(($) => {
       const senderBytes = encodeString('A')
       const serializedMessage = new Uint8Array($.byteLength + senderBytes.byteLength + 1)