From ed30485eacc5bc7b8e344f88fe5c6b70f880e2e0 Mon Sep 17 00:00:00 2001 From: fryorcraken Date: Wed, 1 Oct 2025 16:30:06 +1000 Subject: [PATCH] fix test by adding a message to channel history --- .../reliable_channel_sync.spec.ts | 65 +++++++++++++++++++ 1 file changed, 65 insertions(+) diff --git a/packages/sdk/src/reliable_channel/reliable_channel_sync.spec.ts b/packages/sdk/src/reliable_channel/reliable_channel_sync.spec.ts index 75dbb2eda0..226d5b8c6a 100644 --- a/packages/sdk/src/reliable_channel/reliable_channel_sync.spec.ts +++ b/packages/sdk/src/reliable_channel/reliable_channel_sync.spec.ts @@ -56,6 +56,19 @@ describe("Reliable Channel: Sync", () => { } ); + // Send a message to have a history + const sentMsgId = reliableChannel.send(utf8ToBytes("some message")); + let messageSent = false; + reliableChannel.addEventListener("message-sent", (event) => { + if (event.detail === sentMsgId) { + messageSent = true; + } + }); + + while (!messageSent) { + await delay(50); + } + let syncMessageSent = false; reliableChannel.messageChannel.addEventListener( MessageChannelEvent.OutSyncSent, @@ -131,6 +144,19 @@ describe("Reliable Channel: Sync", () => { return 1; }; // will wait a full second + // Send a message to have a history + const sentMsgId = reliableChannelAlice.send(utf8ToBytes("some message")); + let messageSent = false; + reliableChannelAlice.addEventListener("message-sent", (event) => { + if (event.detail === sentMsgId) { + messageSent = true; + } + }); + + while (!messageSent) { + await delay(50); + } + let syncMessageSent = false; reliableChannelBob.messageChannel.addEventListener( MessageChannelEvent.OutSyncSent, @@ -191,6 +217,19 @@ describe("Reliable Channel: Sync", () => { return 1; }; // will wait a full second + // Send a message to have a history + const sentMsgId = reliableChannelAlice.send(utf8ToBytes("some message")); + let messageSent = false; + reliableChannelAlice.addEventListener("message-sent", (event) => { + if (event.detail === sentMsgId) { + messageSent = true; + } + }); + + while (!messageSent) { + await delay(50); + } + let syncMessageSent = false; reliableChannelBob.messageChannel.addEventListener( MessageChannelEvent.OutSyncSent, @@ -232,6 +271,19 @@ describe("Reliable Channel: Sync", () => { return 1; }; // will wait a full second + // Send a message to have a history + const sentMsgId = reliableChannel.send(utf8ToBytes("some message")); + let messageSent = false; + reliableChannel.addEventListener("message-sent", (event) => { + if (event.detail === sentMsgId) { + messageSent = true; + } + }); + + while (!messageSent) { + await delay(50); + } + let syncMessageSent = false; reliableChannel.messageChannel.addEventListener( MessageChannelEvent.OutSyncSent, @@ -273,6 +325,19 @@ describe("Reliable Channel: Sync", () => { return 1; }; // will wait a full second + // Send a message to have a history + const sentMsgId = reliableChannel.send(utf8ToBytes("some message")); + let messageSent = false; + reliableChannel.addEventListener("message-sent", (event) => { + if (event.detail === sentMsgId) { + messageSent = true; + } + }); + + while (!messageSent) { + await delay(50); + } + let syncMessageSent = false; reliableChannel.messageChannel.addEventListener( MessageChannelEvent.OutSyncSent,