chore: lint

renaynay · Oct 13, 2023 · 510d51d · 510d51d
1 parent 4108883
commit 510d51d
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 5 deletions.
diff --git a/core/listener_test.go b/core/listener_test.go
@@ -31,8 +31,13 @@ func TestListener(t *testing.T) {
 
 	// create mocknet with two pubsub endpoints
 	ps0, ps1 := createMocknetWithTwoPubsubEndpoints(ctx, t)
-	subscriber := p2p.NewSubscriber[*header.ExtendedHeader](ps1, header.MsgID, p2p.WithSubscriberNetworkID(networkID))
-	err := subscriber.SetVerifier(func(context.Context, *header.ExtendedHeader) error {
+	subscriber, err := p2p.NewSubscriber[*header.ExtendedHeader](
+		ps1,
+		header.MsgID,
+		p2p.WithSubscriberNetworkID(networkID),
+	)
+	require.NoError(t, err)
+	err = subscriber.SetVerifier(func(context.Context, *header.ExtendedHeader) error {
 		return nil
 	})
 	require.NoError(t, err)
@@ -162,8 +167,9 @@ func createListener(
 	edsSub *shrexsub.PubSub,
 	store *eds.Store,
 ) *Listener {
-	p2pSub := p2p.NewSubscriber[*header.ExtendedHeader](ps, header.MsgID, p2p.WithSubscriberNetworkID(networkID))
-	err := p2pSub.Start(ctx)
+	p2pSub, err := p2p.NewSubscriber[*header.ExtendedHeader](ps, header.MsgID, p2p.WithSubscriberNetworkID(networkID))
+	require.NoError(t, err)
+	err = p2pSub.Start(ctx)
 	require.NoError(t, err)
 	t.Cleanup(func() {
 		require.NoError(t, p2pSub.Stop(ctx))

diff --git a/nodebuilder/header/module.go b/nodebuilder/header/module.go
@@ -50,7 +50,7 @@ func ConstructModule[H libhead.Header[H]](tp node.Type, cfg *Config) fx.Option {
 			}),
 		)),
 		fx.Provide(fx.Annotate(
-			func(cfg Config, ps *pubsub.PubSub, network modp2p.Network) *p2p.Subscriber[H] {
+			func(cfg Config, ps *pubsub.PubSub, network modp2p.Network) (*p2p.Subscriber[H], error) {
 				opts := []p2p.SubscriberOption{p2p.WithSubscriberNetworkID(network.String())}
 				if cfg.MetricsEnabled {
 					opts = append(opts, p2p.WithSubscriberMetrics())