fix: treat peers already connected to the host before pubsub is initialized as...

fix: treat peers already connected to the host before pubsub is initialized as valid potential pubsub peers

notify.go

@@ -32,3 +32,12 @@ func (p *PubSubNotif) Listen(n network.Network, _ ma.Multiaddr) {
 
 func (p *PubSubNotif) ListenClose(n network.Network, _ ma.Multiaddr) {
 }
+
+func (p *PubSubNotif) Initialize() {
+	for _, pr := range p.host.Network().Peers() {
+		select {
+		case p.newPeers <- pr:
+		case <-p.ctx.Done():
+		}
+	}
+}

pubsub.go

@@ -292,6 +292,8 @@ func NewPubSub(ctx context.Context, h host.Host, rt PubSubRouter, opts ...Option
 
 	go ps.processLoop(ctx)
 
+	(*PubSubNotif)(ps).Initialize()
+
 	return ps, nil
 }