waku-org/js-waku
1
0
Fork 0
mirror of https://github.com/waku-org/js-waku.git synced 2025-01-13 05:54:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: group encoder/decoder declaration

Browse Source
This commit is contained in:
fryorcraken.eth 2022-09-20 12:41:37 +10:00
parent 8679adcf80
commit ae46640ba8
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
2 changed files with 13 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/lib/waku_filter/index.node.spec.ts
View File

@ -13,6 +13,8 @@ import { DecoderV0, EncoderV0 } from "../waku_message/version_0";
const log = debug("waku:test");
const TestContentTopic = "/test/1/waku-filter";
const TestEncoder = new EncoderV0(TestContentTopic);
const TestDecoder = new DecoderV0(TestContentTopic);
describe("Waku Filter", () => {
let waku: WakuFull;
@ -50,16 +52,13 @@ describe("Waku Filter", () => {
expect(bytesToUtf8(msg.payload!)).to.eq(messageText);
};
const decoder = new DecoderV0(TestContentTopic);
await waku.filter.subscribe([decoder], callback);
await waku.filter.subscribe([TestDecoder], callback);
// As the filter protocol does not cater for an ack of subscription
// we cannot know whether the subscription happened. Something we want to
// correct in future versions of the protocol.
await delay(200);
const encoder = new EncoderV0(TestContentTopic);
await waku.lightPush.push(encoder, message);
await waku.lightPush.push(TestEncoder, message);
while (messageCount === 0) {
await delay(250);
}
@ -74,15 +73,13 @@ describe("Waku Filter", () => {
messageCount++;
expect(msg.contentTopic).to.eq(TestContentTopic);
};
const decoder = new DecoderV0(TestContentTopic);
await waku.filter.subscribe([decoder], callback);
await waku.filter.subscribe([TestDecoder], callback);
await delay(200);
const encoder = new EncoderV0(TestContentTopic);
await waku.lightPush.push(encoder, {
await waku.lightPush.push(TestEncoder, {
payload: utf8ToBytes("Filtering works!"),
});
await waku.lightPush.push(encoder, {
await waku.lightPush.push(TestEncoder, {
payload: utf8ToBytes("Filtering still works!"),
});
while (messageCount < 2) {
@ -96,19 +93,16 @@ describe("Waku Filter", () => {
const callback = (): void => {
messageCount++;
};
const decoder = new DecoderV0(TestContentTopic);
const unsubscribe = await waku.filter.subscribe([decoder], callback);
const encoder = new EncoderV0(TestContentTopic);
const unsubscribe = await waku.filter.subscribe([TestDecoder], callback);
await delay(200);
await waku.lightPush.push(encoder, {
await waku.lightPush.push(TestEncoder, {
payload: utf8ToBytes("This should be received"),
});
await delay(100);
await unsubscribe();
await delay(200);
await waku.lightPush.push(encoder, {
await waku.lightPush.push(TestEncoder, {
payload: utf8ToBytes("This should not be received"),
});
await delay(100);

7
src/lib/waku_light_push/index.node.spec.ts
View File

@ -18,6 +18,7 @@ import { EncoderV0 } from "../waku_message/version_0";
const log = debug("waku:test:lightpush");
const TestContentTopic = "/test/1/waku-light-push/utf8";
const TestEncoder = new EncoderV0(TestContentTopic);
describe("Waku Light Push [node only]", () => {
let waku: WakuFull;
@ -42,9 +43,8 @@ describe("Waku Light Push [node only]", () => {
await waitForRemotePeer(waku, [Protocols.LightPush]);
const messageText = "Light Push works!";
const encoder = new EncoderV0(TestContentTopic);
const pushResponse = await waku.lightPush.push(encoder, {
const pushResponse = await waku.lightPush.push(TestEncoder, {
payload: utf8ToBytes(messageText),
});
expect(pushResponse?.isSuccess).to.be.true;
@ -79,11 +79,10 @@ describe("Waku Light Push [node only]", () => {
const nimPeerId = await nwaku.getPeerId();
const messageText = "Light Push works!";
const encoder = new EncoderV0(TestContentTopic);
log("Send message via lightpush");
const pushResponse = await waku.lightPush.push(
encoder,
TestEncoder,
{ payload: utf8ToBytes(messageText) },
{
peerId: nimPeerId,