logos-messaging/js-waku
1
0
Fork 0
mirror of https://github.com/logos-messaging/js-waku.git synced 2026-01-04 06:43:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge 9787f1d8edcc159704937f56be96dc9ab66e7959 into f2ad23ad4354fb3440ca369ed91ba4d882bbacf6

Browse Source
This commit is contained in:
fryorcraken 2025-12-09 15:20:42 -06:00 committed by GitHub
commit 90933a4ca7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 6 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
packages/sdk/src/reliable_channel/reliable_channel.spec.ts
View File

@ -186,7 +186,7 @@ describe("Reliable Channel", () => {
}); });
// TODO: https://github.com/waku-org/js-waku/issues/2648 // TODO: https://github.com/waku-org/js-waku/issues/2648
it.skip("Outgoing message is possibly acknowledged", async () => { it("Outgoing message is possibly acknowledged", async () => {
const commonEventEmitter = new TypedEventEmitter<MockWakuEvents>(); const commonEventEmitter = new TypedEventEmitter<MockWakuEvents>();
const mockWakuNodeAlice = new MockWakuNode(commonEventEmitter); const mockWakuNodeAlice = new MockWakuNode(commonEventEmitter);
const mockWakuNodeBob = new MockWakuNode(commonEventEmitter); const mockWakuNodeBob = new MockWakuNode(commonEventEmitter);

3
packages/sdk/src/reliable_channel/reliable_channel_encryption.spec.ts
View File

@ -187,8 +187,7 @@ describe("Reliable Channel: Encryption", () => {
expect(messageAcknowledged).to.be.false; expect(messageAcknowledged).to.be.false;
}); });
// TODO: https://github.com/waku-org/js-waku/issues/2648 it("Outgoing message is possibly acknowledged", async () => {
it.skip("Outgoing message is possibly acknowledged", async () => {
const commonEventEmitter = new TypedEventEmitter<MockWakuEvents>(); const commonEventEmitter = new TypedEventEmitter<MockWakuEvents>();
const mockWakuNodeAlice = new MockWakuNode(commonEventEmitter); const mockWakuNodeAlice = new MockWakuNode(commonEventEmitter);
const mockWakuNodeBob = new MockWakuNode(commonEventEmitter); const mockWakuNodeBob = new MockWakuNode(commonEventEmitter);

11
packages/sds/src/message_channel/message_channel.spec.ts
View File

@ -185,8 +185,7 @@ describe("MessageChannel", function () {
expect(timestampAfter).to.equal(timestampBefore + 1n); expect(timestampAfter).to.equal(timestampBefore + 1n);
}); });
// TODO: test is failing in CI, investigate in https://github.com/waku-org/js-waku/issues/2648 it("should update lamport timestamp if greater than current timestamp and dependencies are met", async () => {
it.skip("should update lamport timestamp if greater than current timestamp and dependencies are met", async () => {
const testChannelA = new MessageChannel(channelId, "alice"); const testChannelA = new MessageChannel(channelId, "alice");
const testChannelB = new MessageChannel(channelId, "bob"); const testChannelB = new MessageChannel(channelId, "bob");
@ -202,13 +201,11 @@ describe("MessageChannel", function () {
}); });
} }
const timestampAfter = testChannelA["lamportTimestamp"]; const timestampAfter = testChannelA["lamportTimestamp"];
expect(timestampAfter - timestampBefore).to.equal( // The timestamp must increase by at leat the number of messages.
BigInt(messagesB.length) expect(timestampAfter - timestampBefore >= messagesB.length).to.be.true;
);
}); });
// TODO: test is failing in CI, investigate in https://github.com/waku-org/js-waku/issues/2648 it("should maintain proper timestamps if all messages received", async () => {
it.skip("should maintain proper timestamps if all messages received", async () => {
const aTimestampBefore = channelA["lamportTimestamp"]; const aTimestampBefore = channelA["lamportTimestamp"];
let timestamp = channelB["lamportTimestamp"]; let timestamp = channelB["lamportTimestamp"];
for (const m of messagesA) { for (const m of messagesA) {