fix: remove change:multiaddrs listener (#387)

src/index.ts

@@ -78,7 +78,7 @@ import { InboundStream, OutboundStream } from './stream.js'
 import { Uint8ArrayList } from 'uint8arraylist'
 import { decodeRpc, DecodeRPCLimits, defaultDecodeRpcLimits } from './message/decodeRpc.js'
 import { ConnectionManager } from '@libp2p/interface-connection-manager'
-import { PeerMultiaddrsChangeData, PeerStore } from '@libp2p/interface-peer-store'
+import { PeerStore } from '@libp2p/interface-peer-store'
 import { Multiaddr } from '@multiformats/multiaddr'
 import { multiaddrToIPStr } from './utils/multiaddr.js'
 
@@ -590,8 +590,6 @@ export class GossipSub extends EventEmitter<GossipsubEvents> implements PubSub<G
     const heartbeatTimeout = setTimeout(this.runHeartbeat, constants.GossipsubHeartbeatInitialDelay)
     // Then, run heartbeat every `heartbeatInterval` offset by `GossipsubHeartbeatInitialDelay`
 
-    this.components.peerStore.addEventListener('change:multiaddrs', this.onPeerAddressChange)
-
     this.status = {
       code: GossipStatusCode.started,
       registrarTopologyIds,
@@ -628,8 +626,6 @@ export class GossipSub extends EventEmitter<GossipsubEvents> implements PubSub<G
     const { registrarTopologyIds } = this.status
     this.status = { code: GossipStatusCode.stopped }
 
-    this.components.peerStore.removeEventListener('change:multiaddrs', this.onPeerAddressChange)
-
     // unregister protocol and handlers
     const registrar = this.components.registrar
     registrarTopologyIds.forEach((id) => registrar.unregister(id))
@@ -879,36 +875,6 @@ export class GossipSub extends EventEmitter<GossipsubEvents> implements PubSub<G
     this.acceptFromWhitelist.delete(id)
   }
 
-  private onPeerAddressChange = (evt: CustomEvent<PeerMultiaddrsChangeData>): void => {
-    const { peerId, multiaddrs, oldMultiaddrs } = evt.detail
-    const newIps = new Set<string>()
-    const oldIps = new Set<string>()
-    for (const mu of multiaddrs) {
-      const ipStr = multiaddrToIPStr(mu)
-      if (ipStr) {
-        newIps.add(ipStr)
-      }
-    }
-    for (const mu of oldMultiaddrs) {
-      const ipStr = multiaddrToIPStr(mu)
-      if (ipStr) {
-        // Remove multiaddrs that aren't new
-        if (newIps.has(ipStr)) {
-          newIps.delete(ipStr)
-        } else {
-          oldIps.add(ipStr)
-        }
-      }
-    }
-    const id = peerId.toString()
-    for (const ipStr of oldIps) {
-      this.score.removeIP(id, ipStr)
-    }
-    for (const ipStr of newIps) {
-      this.score.addIP(id, ipStr)
-    }
-  }
-
   // API METHODS
 
   get started(): boolean {