mirror of
https://github.com/logos-messaging/waku-react.git
synced 2026-04-18 01:33:44 +00:00
update types, add usePeers, add prettierignore
This commit is contained in:
parent
0d34db28b7
commit
c32769a859
1
.prettierignore
Normal file
1
.prettierignore
Normal file
@ -0,0 +1 @@
|
|||||||
|
dist
|
||||||
@ -8,6 +8,7 @@ export {
|
|||||||
} from "./useCreateWaku";
|
} from "./useCreateWaku";
|
||||||
export { useFilterMessages } from "./useFilterMessages";
|
export { useFilterMessages } from "./useFilterMessages";
|
||||||
export { useLightPush } from "./useLightPush";
|
export { useLightPush } from "./useLightPush";
|
||||||
|
export { usePeers } from "./usePeers";
|
||||||
export { useStoreMessages } from "./useStoreMessages";
|
export { useStoreMessages } from "./useStoreMessages";
|
||||||
export {
|
export {
|
||||||
FullNodeProvider,
|
FullNodeProvider,
|
||||||
|
|||||||
@ -23,7 +23,7 @@ type PushFn = (
|
|||||||
) => Promise<SendResult>;
|
) => Promise<SendResult>;
|
||||||
|
|
||||||
type UseLightPushResult = {
|
type UseLightPushResult = {
|
||||||
push: undefined | PushFn;
|
push?: undefined | PushFn;
|
||||||
};
|
};
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -45,9 +45,7 @@ export const useLightPush = (
|
|||||||
);
|
);
|
||||||
|
|
||||||
if (!node && !encoder) {
|
if (!node && !encoder) {
|
||||||
return {
|
return {};
|
||||||
push: undefined,
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return {
|
return {
|
||||||
|
|||||||
71
src/usePeers.ts
Normal file
71
src/usePeers.ts
Normal file
@ -0,0 +1,71 @@
|
|||||||
|
import React from "react";
|
||||||
|
import type {
|
||||||
|
Peer,
|
||||||
|
PeerProtocolsChangeData,
|
||||||
|
} from "@libp2p/interface-peer-store";
|
||||||
|
import type { Waku } from "@waku/interfaces";
|
||||||
|
|
||||||
|
type UsePeersParams = {
|
||||||
|
node: undefined | Waku;
|
||||||
|
};
|
||||||
|
|
||||||
|
type UsePeersResults = {
|
||||||
|
storePeers?: undefined | Peer[];
|
||||||
|
filterPeers?: undefined | Peer[];
|
||||||
|
lightPushPeers?: undefined | Peer[];
|
||||||
|
peerExchangePeers?: undefined | Peer[];
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Hook returns map of peers for different protocols.
|
||||||
|
* If protocol is not implemented on the node peers are undefined.
|
||||||
|
* @example
|
||||||
|
* const { storePeers } = usePeers({ node });
|
||||||
|
* @param {Waku} params.node - Waku node, if not set then no peers will be returned
|
||||||
|
* @returns {Object} map of peers, if some of the protocols is not implemented then undefined
|
||||||
|
*/
|
||||||
|
export const usePeers = (params: UsePeersParams): UsePeersResults => {
|
||||||
|
const { node } = params;
|
||||||
|
const [peers, setPeers] = React.useState<UsePeersResults>({});
|
||||||
|
|
||||||
|
React.useEffect(() => {
|
||||||
|
if (!node) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const listener = async (_event: CustomEvent<PeerProtocolsChangeData>) => {
|
||||||
|
const peers = await Promise.all([
|
||||||
|
handleCatch(node?.store?.peers()),
|
||||||
|
handleCatch(node?.filter?.peers()),
|
||||||
|
handleCatch(node?.lightPush?.peers()),
|
||||||
|
handleCatch(node?.peerExchange?.peers()),
|
||||||
|
]);
|
||||||
|
|
||||||
|
setPeers({
|
||||||
|
storePeers: peers[0],
|
||||||
|
filterPeers: peers[1],
|
||||||
|
lightPushPeers: peers[2],
|
||||||
|
peerExchangePeers: peers[3],
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
node.libp2p.peerStore.addEventListener("change:protocols", listener);
|
||||||
|
|
||||||
|
return () => {
|
||||||
|
node.libp2p.peerStore.removeEventListener("change:protocols", listener);
|
||||||
|
};
|
||||||
|
}, [node, setPeers]);
|
||||||
|
|
||||||
|
return peers;
|
||||||
|
};
|
||||||
|
|
||||||
|
// TODO: handle error in case fetching of peers failed
|
||||||
|
function handleCatch(promise?: Promise<Peer[]>): Promise<Peer[] | undefined> {
|
||||||
|
if (!promise) {
|
||||||
|
return Promise.resolve(undefined);
|
||||||
|
}
|
||||||
|
|
||||||
|
return promise.catch((_) => {
|
||||||
|
return undefined;
|
||||||
|
});
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user