feat: updated subscription to listen messages

Author: blockchainluffy

rolling-shutter/p2p/floodsubpeerdiscovery/gossippeerdiscovery.go

@@ -129,3 +129,18 @@ func (pd *FloodsubPeerDiscovery) broadcast() error {
 	}
 	return nil
 }
+
+func (pd *FloodsubPeerDiscovery) ReadLoop(ctx context.Context, subs *pubsub.Subscription) error {
+	for {
+		msg, err := subs.Next(ctx)
+		if err != nil {
+			return err
+		}
+
+		if msg.ReceivedFrom == pd.PeerID.ID {
+			continue
+		}
+
+		log.Info().Msgf("found a floodsub discovery message | %v", err)
+	}
+}

rolling-shutter/p2p/p2p.go

@@ -147,6 +147,12 @@ func (p *P2PNode) Run(
 		runner.Go(func() error {
 			return p.FloodSubDiscovery.Start(ctx)
 		})
+
+		for _, subs := range p.FloodSubDiscovery.Subscription {
+			runner.Go(func() error {
+				return p.FloodSubDiscovery.ReadLoop(ctx, subs)
+			})
+		}
 	}
 	runner.Go(func() error {
 		log.Info().Str("namespace", p.config.DiscoveryNamespace).Msg("starting advertizing discovery node")