status-im/js-waku
2
0
Fork 0
mirror of https://github.com/status-im/js-waku.git synced 2025-02-22 09:58:10 +00:00
Code Issues Projects Releases Wiki Activity

Reference GitHub issues

Browse Source
This commit is contained in:
Franck Royer 2021-04-01 11:04:48 +11:00
parent 58838ec898
commit f15f4ff7f2
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/chat/index.ts
View File

@ -28,6 +28,7 @@ import { ChatMessage } from './chat_message';
const waku = await Waku.create({ listenAddresses: [opts.listenAddr] }); const waku = await Waku.create({ listenAddresses: [opts.listenAddr] });
// TODO: Bubble event to waku, infer topic, decode msg // TODO: Bubble event to waku, infer topic, decode msg
// Tracked with https://github.com/status-im/js-waku/issues/19
waku.libp2p.pubsub.on(TOPIC, (event) => { waku.libp2p.pubsub.on(TOPIC, (event) => {
const wakuMsg = Message.decode(event.data); const wakuMsg = Message.decode(event.data);
if (wakuMsg.payload) { if (wakuMsg.payload) {
@ -55,9 +56,11 @@ import { ChatMessage } from './chat_message';
); );
// TODO: identify if it is possible to listen to an event to confirm dial // TODO: identify if it is possible to listen to an event to confirm dial
// finished instead of an arbitrary delay. // finished instead of an arbitrary delay. Tracked with
// https://github.com/status-im/js-waku/issues/18
await delay(2000); await delay(2000);
// TODO: Automatically subscribe // TODO: Automatically subscribe, tracked with
// https://github.com/status-im/js-waku/issues/17
await waku.relay.subscribe(); await waku.relay.subscribe();
console.log('Subscribed to waku relay'); console.log('Subscribed to waku relay');