From d69e31a2ee1b046ead75c1c45acacb6b66eb981f Mon Sep 17 00:00:00 2001
From: nick <nick@bisonai.com>
Date: Wed, 28 Aug 2024 12:40:40 +0900
Subject: [PATCH] fix: remove unnecessary threading

---
 .../chain/websocketchainreader/websocketreader.go  | 14 +-------------
 1 file changed, 1 insertion(+), 13 deletions(-)

diff --git a/node/pkg/chain/websocketchainreader/websocketreader.go b/node/pkg/chain/websocketchainreader/websocketreader.go
index 56ebd2d65..08abe9351 100644
--- a/node/pkg/chain/websocketchainreader/websocketreader.go
+++ b/node/pkg/chain/websocketchainreader/websocketreader.go
@@ -115,26 +115,14 @@ func (c *ChainReader) handleSubscription(ctx context.Context, config *SubscribeC
 			Addresses: []common.Address{common.HexToAddress(config.Address)},
 		}
 
-		headerSubChan := make(chan *types.Header, 1)
-		defer close(headerSubChan)
 		// Subscribe to new head just to keep connection alive (ignoring the results)
-		subNewHead, err := c.client(config.ChainType).SubscribeNewHead(ctx, headerSubChan)
+		subNewHead, err := c.client(config.ChainType).SubscribeNewHead(ctx, nil)
 		if err != nil {
 			log.Warn().Err(err).Msg("Failed to subscribe to new head")
 		} else {
 			defer subNewHead.Unsubscribe()
 		}
 
-		go func() {
-			for {
-				select {
-				case <-ctx.Done():
-					return
-				case <-headerSubChan:
-				}
-			}
-		}()
-
 		logs := make(chan types.Log)
 		sub, err := c.client(config.ChainType).SubscribeFilterLogs(ctx, query, logs)
 		if err != nil {