fix: Use WS client for event subscriptions (#90)

Nuffle-Labs · Apr 18, 2024 · d2894d2 · d2894d2
1 parent aa68e8e
commit d2894d2
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/aggregator/aggregator.go b/aggregator/aggregator.go
@@ -103,6 +103,12 @@ func NewAggregator(ctx context.Context, config *config.Config, logger logging.Lo
 		return nil, err
 	}
 
+	ethWsClient, err := eth.NewClient(config.EthWsRpcUrl)
+	if err != nil {
+		logger.Errorf("Cannot create ws ethclient", "err", err)
+		return nil, err
+	}
+
 	avsReader, err := chainio.BuildAvsReaderFromConfig(config, ethHttpClient, logger)
 	if err != nil {
 		logger.Error("Cannot create avsReader", "err", err)
@@ -135,7 +141,7 @@ func NewAggregator(ctx context.Context, config *config.Config, logger logging.Lo
 		return nil, err
 	}
 
-	avsSubscriber, err := chainio.BuildAvsSubscriber(config.SFFLRegistryCoordinatorAddr, config.OperatorStateRetrieverAddr, ethHttpClient, logger)
+	avsSubscriber, err := chainio.BuildAvsSubscriber(config.SFFLRegistryCoordinatorAddr, config.OperatorStateRetrieverAddr, ethWsClient, logger)
 	if err != nil {
 		logger.Error("Cannot create AvsSubscriber", "err", err)
 		return nil, err