refactor(pkg/p2p): swap GossipSub by FloodSub

julienrbrt · julienrbrt · commit 28ec4f98ba43 · 2026-04-17T11:17:30.000+02:00
diff --git a/pkg/p2p/client.go b/pkg/p2p/client.go
@@ -450,7 +450,7 @@ func (c *Client) tryConnect(ctx context.Context, peer peer.AddrInfo) {
 
 func (c *Client) setupGossiping(ctx context.Context) error {
 	var err error
-	c.ps, err = pubsub.NewGossipSub(ctx, c.host)
+	c.ps, err = pubsub.NewFloodSub(ctx, c.host)
 	if err != nil {
 		return err
 	}

Original file line number	Diff line number	Diff line change
`@@ -450,7 +450,7 @@ func (c *Client) tryConnect(ctx context.Context, peer peer.AddrInfo) {`
`450`	`450`
`451`	`451`	`func (c *Client) setupGossiping(ctx context.Context) error {`
`452`	`452`	`var err error`
`453`		`- c.ps, err = pubsub.NewGossipSub(ctx, c.host)`
	`453`	`+ c.ps, err = pubsub.NewFloodSub(ctx, c.host)`
`454`	`454`	`if err != nil {`
`455`	`455`	`return err`
`456`	`456`	`}`