waku-org/js-waku
1
0
Fork 0
mirror of https://github.com/waku-org/js-waku.git synced 2025-02-24 18:18:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Ensure observers are deleted

Browse Source
This commit is contained in:
Franck Royer 2021-06-17 16:22:49 +10:00
parent 8e8e3a366c
commit 0c6cb64b72
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
1 changed files with 14 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
examples/eth-dm/src/App.tsx
View File

@ -68,7 +68,9 @@ function App() {
setPublicKeys
);
const observerDirectMessage = handleDirectMessage.bind({}, setMessages);
const observerDirectMessage = ethDmKeyPair
? handleDirectMessage.bind({}, setMessages, ethDmKeyPair.privateKey)
: undefined;
useEffect(() => {
if (!waku) return;
@ -76,27 +78,24 @@ function App() {
return function cleanUp() {
if (!waku) return;
waku.relay.deleteObserver(observerPublicKeyMessage, [PublicKeyContentTopic]);
}
waku.relay.deleteObserver(observerPublicKeyMessage, [
PublicKeyContentTopic,
]);
};
});
useEffect(() => {
if (!waku) return;
if (!ethDmKeyPair) return;
waku.relay.addObserver(
observerDirectMessage.bind({}, ethDmKeyPair.privateKey),
[DirectMessageContentTopic]
);
if (!observerDirectMessage) return;
waku.relay.addObserver(observerDirectMessage, [DirectMessageContentTopic]);
return function cleanUp() {
if (!waku) return;
if (!ethDmKeyPair) return;
waku.relay.deleteObserver(
observerDirectMessage.bind({}, ethDmKeyPair.privateKey),
[DirectMessageContentTopic]
);
}
if (!observerDirectMessage) return;
waku.relay.deleteObserver(observerDirectMessage, [
DirectMessageContentTopic,
]);
};
});
const broadcastPublicKey = () => {