feat: broadcast floodsub message when there no peers

blockchainluffy · blockchainluffy · commit c2cfb2a69b8c · 2024-10-14T15:01:29.000+05:30
diff --git a/rolling-shutter/p2p/floodsubpeerdiscovery/gossippeerdiscovery.go b/rolling-shutter/p2p/floodsubpeerdiscovery/gossippeerdiscovery.go
@@ -104,10 +104,6 @@ func (pd *FloodsubPeerDiscovery) broadcast() error {
 	}
 
 	for _, topic := range pd.Topics {
-		if len(pd.Pubsub.ListPeers(topic.String())) == 0 {
-			log.Info().Msgf("skipping broadcasting our peer data on topic %s because there are no peers present", topic)
-			continue
-		}
 		log.Info().Msgf("broadcasting our peer data on topic %s", topic)
 
 		if err := topic.Publish(context.Background(), pbPeer); err != nil {

Original file line number	Diff line number	Diff line change
`@@ -104,10 +104,6 @@ func (pd *FloodsubPeerDiscovery) broadcast() error {`
`104`	`104`	`}`
`105`	`105`
`106`	`106`	`for _, topic := range pd.Topics {`
`107`		`- if len(pd.Pubsub.ListPeers(topic.String())) == 0 {`
`108`		`- log.Info().Msgf("skipping broadcasting our peer data on topic %s because there are no peers present", topic)`
`109`		`- continue`
`110`		`- }`
`111`	`107`	`log.Info().Msgf("broadcasting our peer data on topic %s", topic)`
`112`	`108`
`113`	`109`	`if err := topic.Publish(context.Background(), pbPeer); err != nil {`