mirror of https://github.com/waku-org/js-waku.git
Merge pull request #1222 from waku-org/fix/peer-tag-discovery
This commit is contained in:
commit
98695f12e7
|
@ -96,6 +96,13 @@ export class PeerDiscoveryDns
|
||||||
if (!this._started) return;
|
if (!this._started) return;
|
||||||
const peerInfos = multiaddrsToPeerInfo(peer.getFullMultiaddrs());
|
const peerInfos = multiaddrsToPeerInfo(peer.getFullMultiaddrs());
|
||||||
peerInfos.forEach(async (peerInfo) => {
|
peerInfos.forEach(async (peerInfo) => {
|
||||||
|
if (
|
||||||
|
(await this._components.peerStore.getTags(peerInfo.id)).find(
|
||||||
|
({ name }) => name === DEFAULT_BOOTSTRAP_TAG_NAME
|
||||||
|
)
|
||||||
|
)
|
||||||
|
return;
|
||||||
|
|
||||||
await this._components.peerStore.tagPeer(
|
await this._components.peerStore.tagPeer(
|
||||||
peerInfo.id,
|
peerInfo.id,
|
||||||
DEFAULT_BOOTSTRAP_TAG_NAME,
|
DEFAULT_BOOTSTRAP_TAG_NAME,
|
||||||
|
|
|
@ -170,8 +170,6 @@ export class PeerExchangeDiscovery
|
||||||
|
|
||||||
if (!peerId || !multiaddrs || multiaddrs.length === 0) continue;
|
if (!peerId || !multiaddrs || multiaddrs.length === 0) continue;
|
||||||
|
|
||||||
if (await this.components.peerStore.has(peerId)) continue;
|
|
||||||
|
|
||||||
if (
|
if (
|
||||||
(await this.components.peerStore.getTags(peerId)).find(
|
(await this.components.peerStore.getTags(peerId)).find(
|
||||||
({ name }) => name === DEFAULT_PEER_EXCHANGE_TAG_NAME
|
({ name }) => name === DEFAULT_PEER_EXCHANGE_TAG_NAME
|
||||||
|
|
Loading…
Reference in New Issue