mirror of https://github.com/waku-org/js-waku.git
parent
ad4101f612
commit
0d00328715
|
@ -86,8 +86,17 @@ export default function App() {
|
||||||
localStorage.setItem('nick', nick);
|
localStorage.setItem('nick', nick);
|
||||||
}, [nick]);
|
}, [nick]);
|
||||||
|
|
||||||
// Waku: Start, process messages, send messages
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
|
if (stateWaku) return;
|
||||||
|
|
||||||
|
initWaku(setWaku)
|
||||||
|
.then(() => console.log('Waku init done'))
|
||||||
|
.catch((e) => console.log('Waku init failed ', e));
|
||||||
|
}, [stateWaku]);
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
if (!stateWaku) return;
|
||||||
|
|
||||||
const handleRelayMessage = (wakuMsg: WakuMessage) => {
|
const handleRelayMessage = (wakuMsg: WakuMessage) => {
|
||||||
console.log('Message received: ', wakuMsg);
|
console.log('Message received: ', wakuMsg);
|
||||||
const msg = Message.fromWakuMessage(wakuMsg);
|
const msg = Message.fromWakuMessage(wakuMsg);
|
||||||
|
@ -96,6 +105,14 @@ export default function App() {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
stateWaku.relay.addObserver(handleRelayMessage, [ChatContentTopic]);
|
||||||
|
|
||||||
|
return;
|
||||||
|
}, [stateWaku]);
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
if (!stateWaku) return;
|
||||||
|
|
||||||
const handleProtocolChange = async (
|
const handleProtocolChange = async (
|
||||||
waku: Waku,
|
waku: Waku,
|
||||||
{ peerId, protocols }: { peerId: PeerId; protocols: string[] }
|
{ peerId, protocols }: { peerId: PeerId; protocols: string[] }
|
||||||
|
@ -118,13 +135,6 @@ export default function App() {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
if (!stateWaku) {
|
|
||||||
initWaku(setWaku)
|
|
||||||
.then(() => console.log('Waku init done'))
|
|
||||||
.catch((e) => console.log('Waku init failed ', e));
|
|
||||||
} else {
|
|
||||||
stateWaku.relay.addObserver(handleRelayMessage, [ChatContentTopic]);
|
|
||||||
|
|
||||||
stateWaku.libp2p.peerStore.on(
|
stateWaku.libp2p.peerStore.on(
|
||||||
'change:protocols',
|
'change:protocols',
|
||||||
handleProtocolChange.bind({}, stateWaku)
|
handleProtocolChange.bind({}, stateWaku)
|
||||||
|
@ -137,7 +147,6 @@ export default function App() {
|
||||||
handleProtocolChange.bind({}, stateWaku)
|
handleProtocolChange.bind({}, stateWaku)
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
}
|
|
||||||
}, [stateWaku]);
|
}, [stateWaku]);
|
||||||
|
|
||||||
return (
|
return (
|
||||||
|
|
Loading…
Reference in New Issue