From e043bc41f2be51741148b0f689f56d9351460084 Mon Sep 17 00:00:00 2001 From: "Masih H. Derkani" Date: Thu, 5 Dec 2024 14:41:48 +0000 Subject: [PATCH] Set GPBFT message ID function in observer Use a pubsub message ID function consistent with gpbft pubsub settings. --- observer/observer.go | 1 + 1 file changed, 1 insertion(+) diff --git a/observer/observer.go b/observer/observer.go index f7dfc353..937c0250 100644 --- a/observer/observer.go +++ b/observer/observer.go @@ -77,6 +77,7 @@ func (o *Observer) initialize(ctx context.Context) error { if o.pubSub, err = pubsub.NewGossipSub(ctx, o.host, pubsub.WithPeerExchange(true), pubsub.WithFloodPublish(true), + pubsub.WithMessageIdFn(psutil.GPBFTMessageIdFn), pubsub.WithPeerScore(psutil.PubsubPeerScoreParams, psutil.PubsubPeerScoreThresholds), ); err != nil { return fmt.Errorf("failed to initialise pubsub: %w", err)