logos-messaging/examples.waku.org
1
0
Fork 0
mirror of https://github.com/logos-messaging/examples.waku.org.git synced 2026-01-03 13:23:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

update @waku/react, remove old libp2p dep

Browse Source
This commit is contained in:
Sasha 2023-07-28 14:56:44 +02:00
parent 9fb6b185e7
commit 0c0b8fcd8d
No known key found for this signature in database
2 changed files with 11 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
examples/web-chat/package.json
View File

@ -4,14 +4,13 @@
"private": true,
"homepage": "/web-chat",
"dependencies": {
"@libp2p/bootstrap": "^5.0.0",
"@livechat/ui-kit": "^0.5.0-24",
"@multiformats/multiaddr": "11.0.7",
"@waku/react": "^0.0.2",
"@waku/sdk": "^0.0.16",
"@waku/dns-discovery": "^0.0.14",
"@waku/interfaces": "^0.0.15",
"@waku/peer-exchange": "^0.0.13",
"@waku/react": "0.0.3-7aeb24a",
"@waku/sdk": "^0.0.17",
"@waku/dns-discovery": "^0.0.15",
"@waku/interfaces": "^0.0.16",
"@waku/peer-exchange": "^0.0.14",
"process": "^0.11.10",
"protons-runtime": "^3.1.0",
"react": "^17.0.2",

15
examples/web-chat/src/hooks.ts
View File

@ -3,7 +3,6 @@ import { generate } from "server-name-generator";
import { Message } from "./Message";
import type {
Peer,
PeerProtocolsChangeData,
} from "@libp2p/interface-peer-store";
import type { LightNode, StoreQueryOptions, Waku } from "@waku/interfaces";
import type { waku } from "@waku/sdk";
@ -70,9 +69,7 @@ export const useNodePeers = (node: undefined | LightNode) => {
const listener = async (evt: any) => {
const { peerId } = evt.detail;
const tags = (await node.libp2p.peerStore.getTags(peerId)).map(
(t) => t.name
);
const tags = Array.from((await node.libp2p.peerStore.get(peerId)).tags.keys());
if (tags.includes("peer-exchange")) {
setPeerExchangePeers((peers) => new Set(peers).add(peerId.toString()));
} else {
@ -81,9 +78,9 @@ export const useNodePeers = (node: undefined | LightNode) => {
};
// Update store peer when new peer connected & identified
node.libp2p.peerStore.addEventListener("change:protocols", listener);
node.libp2p.addEventListener("peer:identify", listener);
return () => {
node.libp2p.peerStore.removeEventListener("change:protocols", listener);
node.libp2p.removeEventListener("peer:identify", listener);
};
}, [node]);
@ -128,7 +125,7 @@ export const usePeers = (params: UsePeersParams): UsePeersResults => {
return;
}
const listener = async (_event?: CustomEvent<PeerProtocolsChangeData>) => {
const listener = async (_event?: any) => {
const peers = await Promise.all([
handleCatch(node?.store?.peers()),
handleCatch(node?.filter?.peers()),
@ -143,9 +140,9 @@ export const usePeers = (params: UsePeersParams): UsePeersResults => {
};
listener(); // populate peers before event is invoked
node.libp2p.peerStore.addEventListener("change:protocols", listener);
node.libp2p.addEventListener("peer:identify", listener);
return () => {
node.libp2p.peerStore.removeEventListener("change:protocols", listener);
node.libp2p.removeEventListener("peer:identify", listener);
};
}, [node, setPeers]);